mirror of
https://github.com/simon987/Architeuthis.git
synced 2025-04-19 23:46:41 +00:00
config update pt2
This commit is contained in:
parent
5fa1b8c0eb
commit
45bd47649c
15
main.go
15
main.go
@ -25,21 +25,6 @@ func New() *Architeuthis {
|
|||||||
|
|
||||||
a.setupProxyReviver()
|
a.setupProxyReviver()
|
||||||
|
|
||||||
var err error
|
|
||||||
const InfluxDBUrl = "http://localhost:8086"
|
|
||||||
a.influxdb, err = influx.NewHTTPClient(influx.HTTPConfig{
|
|
||||||
Addr: InfluxDBUrl,
|
|
||||||
})
|
|
||||||
|
|
||||||
_, err = http.Post(InfluxDBUrl+"/query", "application/x-www-form-urlencoded", strings.NewReader("q=CREATE DATABASE \"architeuthis\""))
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
a.points = make(chan *influx.Point, InfluxDbBufferSize)
|
|
||||||
|
|
||||||
go a.asyncWriter(a.points)
|
|
||||||
|
|
||||||
a.server = goproxy.NewProxyHttpServer()
|
a.server = goproxy.NewProxyHttpServer()
|
||||||
a.server.OnRequest().HandleConnect(goproxy.AlwaysMitm)
|
a.server.OnRequest().HandleConnect(goproxy.AlwaysMitm)
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user