aboutsummaryrefslogtreecommitdiff
path: root/forwarder_influxd.go
diff options
context:
space:
mode:
authorShulhan <ms@kilabit.info>2024-03-17 22:45:55 +0700
committerShulhan <ms@kilabit.info>2024-03-18 21:55:35 +0700
commit0b791515c819b4742c95f98f970e838b3373b0ef (patch)
tree7b8b9a25b24070a6c40972b7e7247a55295b7775 /forwarder_influxd.go
parenta37fef27aa5411b7df102cb227768fe8a010ea42 (diff)
downloadhaminer-0b791515c819b4742c95f98f970e838b3373b0ef.tar.xz
all: rename some fields in HTTPLog for readability
Diffstat (limited to 'forwarder_influxd.go')
-rw-r--r--forwarder_influxd.go16
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
}