MCPcopy
hub / github.com/docker/compose / emitDoneEvent

Function emitDoneEvent

pkg/compose/executor_events.go:132–153  ·  view source on GitHub ↗

emitDoneEvent emits the appropriate Done event for an ungrouped node.

(node *PlanNode, events api.EventProcessor)

Source from the content-addressed store, hash-verified

130
131// emitDoneEvent emits the appropriate Done event for an ungrouped node.
132func emitDoneEvent(node *PlanNode, events api.EventProcessor) {
133 op := node.Operation
134 switch op.Type {
135 case OpCreateContainer:
136 events.On(createdEvent("Container " + op.Name))
137 case OpStartContainer:
138 name := getContainerProgressName(*op.Container)
139 events.On(newEvent(name, api.Done, api.StatusStarted))
140 case OpStopContainer:
141 events.On(stoppedEvent(getContainerProgressName(*op.Container)))
142 case OpRemoveContainer:
143 events.On(removedEvent(getContainerProgressName(*op.Container)))
144 case OpCreateNetwork:
145 events.On(createdEvent("Network " + op.Name))
146 case OpRemoveNetwork:
147 events.On(removedEvent("Network " + op.Name))
148 case OpCreateVolume:
149 events.On(createdEvent("Volume " + op.Name))
150 case OpRemoveVolume:
151 events.On(removedEvent("Volume " + op.Name))
152 }
153}
154
155// emitErrorEvent emits an error event for an ungrouped node.
156func emitErrorEvent(node *PlanNode, events api.EventProcessor, err error) {

Callers 1

onNodeDoneMethod · 0.85

Calls 6

createdEventFunction · 0.85
getContainerProgressNameFunction · 0.85
newEventFunction · 0.85
stoppedEventFunction · 0.85
removedEventFunction · 0.85
OnMethod · 0.65

Tested by

no test coverage detected