emitStartEvent emits the appropriate Working event for an ungrouped node.
(node *PlanNode, events api.EventProcessor)
| 106 | |
| 107 | // emitStartEvent emits the appropriate Working event for an ungrouped node. |
| 108 | func emitStartEvent(node *PlanNode, events api.EventProcessor) { |
| 109 | op := node.Operation |
| 110 | switch op.Type { |
| 111 | case OpCreateContainer: |
| 112 | events.On(creatingEvent("Container " + op.Name)) |
| 113 | case OpStartContainer: |
| 114 | name := getContainerProgressName(*op.Container) |
| 115 | events.On(newEvent(name, api.Working, api.StatusStarting)) |
| 116 | case OpStopContainer: |
| 117 | events.On(stoppingEvent(getContainerProgressName(*op.Container))) |
| 118 | case OpRemoveContainer: |
| 119 | events.On(removingEvent(getContainerProgressName(*op.Container))) |
| 120 | case OpCreateNetwork: |
| 121 | events.On(creatingEvent("Network " + op.Name)) |
| 122 | case OpRemoveNetwork: |
| 123 | events.On(removingEvent("Network " + op.Name)) |
| 124 | case OpCreateVolume: |
| 125 | events.On(creatingEvent("Volume " + op.Name)) |
| 126 | case OpRemoveVolume: |
| 127 | events.On(removingEvent("Volume " + op.Name)) |
| 128 | } |
| 129 | } |
| 130 | |
| 131 | // emitDoneEvent emits the appropriate Done event for an ungrouped node. |
| 132 | func emitDoneEvent(node *PlanNode, events api.EventProcessor) { |
no test coverage detected