update newrelic unknown containers/volumes emitter
@@ -17,7 +17,6 @@ type (
stats struct {
created interface{}
deleted interface{}
- unknown interface{}
}
NewRelicEmitter struct {
@@ -102,7 +101,6 @@ func (emitter *NewRelicEmitter) emitPayload(logger lager.Logger, payload fullPay
req.Header.Add("X-Insert-Key", emitter.apikey)
resp, err := emitter.client.Do(req)
-
if err != nil {
logger.Error("failed-to-send-request",
errors.Wrap(metric.ErrFailedToEmit, err.Error()))
@@ -124,7 +122,9 @@ func (emitter *NewRelicEmitter) Emit(logger lager.Logger, event metric.Event) {
"worker volumes",
"http response time",
"database queries",
- "database connections":
+ "database connections",
+ "worker unknown containers",
+ "worker unknown volumes":
payload = append(payload, emitter.simplePayload(logger, event, ""))
// These are periodic metrics that are consolidated and only emitted once
@@ -156,10 +156,6 @@ func (emitter *NewRelicEmitter) Emit(logger lager.Logger, event metric.Event) {
delete(newPayload, "value")
payload = append(payload, newPayload)
- case "worker unknown containers":
- emitter.containers.unknown = event.Value
- case "worker unknown volumes":
- emitter.volumes.unknown = event.Value
// And a couple that need a small rename (new relic doesn't like some chars)
case "scheduling: full duration (ms)":
