Skip to content

Commit c47dfe4

Browse files
authored
more fixes (#24)
1 parent 8b2aad5 commit c47dfe4

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

proxy/proxy.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -107,6 +107,12 @@ func (m *Multiplexer) ServeHTTP(resp http.ResponseWriter, req *http.Request) {
107107
}
108108
}
109109
}
110+
111+
if m.hcServer == nil {
112+
if _, wErr := resp.Write([]byte("{}")); wErr != nil {
113+
logger.Error(wErr.Error())
114+
}
115+
}
110116
}
111117

112118
func (m *Multiplexer) forward(resp http.ResponseWriter, req *http.Request) {
@@ -180,6 +186,7 @@ func RequestToEvents(req *http.Request) (events []axiom.Event, dataset string, e
180186
for _, event := range events {
181187
if timeStr, ok := event["time"].(string); ok {
182188
event["_time"] = timeStr
189+
delete(event, "time")
183190
}
184191
}
185192
case []interface{}:
@@ -193,6 +200,7 @@ func RequestToEvents(req *http.Request) (events []axiom.Event, dataset string, e
193200

194201
if timeStr, ok := event["time"].(string); ok {
195202
event["_time"] = timeStr
203+
delete(event, "time")
196204
}
197205
events = append(events, event)
198206
}

0 commit comments

Comments
 (0)