correcting newrelic unknown containers/volumes metric
@@ -136,8 +136,6 @@ func (emitter *NewRelicEmitter) Emit(logger lager.Logger, event metric.Event) {
emitter.containers.deleted = event.Value
case "containers created":
emitter.containers.created = event.Value
- case "unknown containers":
- emitter.containers.unknown = event.Value
case "failed containers":
newPayload := emitter.simplePayload(logger, event, "containers")
newPayload["failed"] = newPayload["value"]
@@ -150,8 +148,6 @@ func (emitter *NewRelicEmitter) Emit(logger lager.Logger, event metric.Event) {
emitter.volumes.deleted = event.Value
case "volumes created":
emitter.volumes.created = event.Value
- case "unknown volumes":
- emitter.volumes.unknown = event.Value
case "failed volumes":
newPayload := emitter.simplePayload(logger, event, "volumes")
newPayload["failed"] = newPayload["value"]
@@ -160,6 +156,11 @@ 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)":
payload = append(payload, emitter.simplePayload(logger, event, "scheduling_full_duration_ms"))
