diff options
| author | Shulhan <ms@kilabit.info> | 2024-03-17 22:45:55 +0700 |
|---|---|---|
| committer | Shulhan <ms@kilabit.info> | 2024-03-18 21:55:35 +0700 |
| commit | 0b791515c819b4742c95f98f970e838b3373b0ef (patch) | |
| tree | 7b8b9a25b24070a6c40972b7e7247a55295b7775 /forwarder_influxd.go | |
| parent | a37fef27aa5411b7df102cb227768fe8a010ea42 (diff) | |
| download | haminer-0b791515c819b4742c95f98f970e838b3373b0ef.tar.xz | |
all: rename some fields in HTTPLog for readability
Diffstat (limited to 'forwarder_influxd.go')
| -rw-r--r-- | forwarder_influxd.go | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/forwarder_influxd.go b/forwarder_influxd.go index 3ee358c..dc093e1 100644 --- a/forwarder_influxd.go +++ b/forwarder_influxd.go @@ -142,8 +142,8 @@ func (cl *forwarderInfluxd) write(halogs []*HTTPLog) (err error) { l.HTTPURL, l.HTTPQuery, l.HTTPProto, - l.HTTPStatus, - l.TermState, + l.StatusCode, + l.TerminationState, l.ClientIP, l.ClientPort, ) @@ -151,7 +151,7 @@ func (cl *forwarderInfluxd) write(halogs []*HTTPLog) (err error) { return err } - for k, v = range l.RequestHeaders { + for k, v = range l.HeaderRequest { _, err = fmt.Fprintf(&cl.buf, ",%s=%s", k, v) if err != nil { return err @@ -161,18 +161,18 @@ func (cl *forwarderInfluxd) write(halogs []*HTTPLog) (err error) { cl.buf.WriteByte(' ') _, err = fmt.Fprintf(&cl.buf, influxdFields, - l.TimeReq, l.TimeWait, l.TimeConnect, - l.TimeRsp, l.TimeAll, + l.TimeRequest, l.TimeWait, l.TimeConnect, + l.TimeResponse, l.TimeAll, l.ConnActive, l.ConnFrontend, l.ConnBackend, - l.ConnServer, l.ConnRetries, - l.QueueServer, l.QueueBackend, + l.ConnServer, l.Retries, + l.ServerQueue, l.BackendQueue, l.BytesRead, ) if err != nil { return err } - _, err = fmt.Fprintf(&cl.buf, " %d\n", l.Timestamp.UnixNano()) + _, err = fmt.Fprintf(&cl.buf, " %d\n", l.RequestDate.UnixNano()) if err != nil { return err } |
