(md *message.Metadata, resourceLcuuid string, event *eventapi.ResourceEvent)
| 89 | } |
| 90 | |
| 91 | func (e *ManagerComponent) enqueue(md *message.Metadata, resourceLcuuid string, event *eventapi.ResourceEvent) { |
| 92 | log.Infof("put %s event (lcuuid: %s): %+v into shared queue", e.resourceType, resourceLcuuid, toLoggableEvent(event), md.LogPrefixes) |
| 93 | err := e.Queue.Put(event) |
| 94 | if err != nil { |
| 95 | log.Error(putEventIntoQueueFailed(e.resourceType, err), md.LogPrefixes) |
| 96 | } |
| 97 | } |
| 98 | |
| 99 | func (e *ManagerComponent) enqueueInstanceIfInsertIntoMetadbFailed( |
| 100 | md *message.Metadata, |
no test coverage detected