emitDoneEvent emits the appropriate Done event for an ungrouped node.
(node *PlanNode, events api.EventProcessor)
| 130 | |
| 131 | // emitDoneEvent emits the appropriate Done event for an ungrouped node. |
| 132 | func 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. |
| 156 | func emitErrorEvent(node *PlanNode, events api.EventProcessor, err error) { |
no test coverage detected