Versions in this module Expand all Collapse all v0 v0.2.0 Aug 19, 2022 Changes in this version + type Config struct + AcceptBackend []string + ForwardInterval time.Duration + Forwarders map[string]*ConfigForwarder + HttpUrl []string + Listen string + RequestHeaders []string + func NewConfig() (cfg *Config) + func (cfg *Config) Load(path string) (err error) + func (cfg *Config) SetListen(v string) + type ConfigForwarder struct + Bucket string + Org string + Pass string + Token string + Url string + User string + Version string + type Forwarder interface + Forwards func(halogs []*HttpLog) + type Haminer struct + func NewHaminer(cfg *Config) (h *Haminer) + func (h *Haminer) Start() (err error) + func (h *Haminer) Stop() + type HttpLog struct + BackendName string + BytesRead int64 + ClientIP string + ClientPort int32 + ConnActive int32 + ConnBackend int32 + ConnFrontend int32 + ConnRetries int32 + ConnServer int32 + CookieReq string + CookieRsp string + FrontendName string + HTTPMethod string + HTTPProto string + HTTPQuery string + HTTPStatus int32 + HTTPURL string + QueueBackend int32 + QueueServer int32 + RequestHeaders map[string]string + ServerName string + TermState string + TimeAll int32 + TimeConnect int32 + TimeReq int32 + TimeRsp int32 + TimeWait int32 + Timestamp time.Time + func (halog *HttpLog) Parse(in []byte, reqHeaders []string) (ok bool) + func (halog *HttpLog) ParseUDPPacket(packet []byte, reqHeaders []string) bool + type InfluxdClient struct + func NewInfluxdClient(cfg *ConfigForwarder) (cl *InfluxdClient) + func (cl *InfluxdClient) Forwards(halogs []*HttpLog)