emitErrorEvent emits an error event for an ungrouped node.
(node *PlanNode, events api.EventProcessor, err error)
| 154 | |
| 155 | // emitErrorEvent emits an error event for an ungrouped node. |
| 156 | func emitErrorEvent(node *PlanNode, events api.EventProcessor, err error) { |
| 157 | op := node.Operation |
| 158 | var id string |
| 159 | switch { |
| 160 | case op.Container != nil: |
| 161 | id = getContainerProgressName(*op.Container) |
| 162 | default: |
| 163 | id = op.ResourceID |
| 164 | } |
| 165 | events.On(api.Resource{ |
| 166 | ID: id, |
| 167 | Status: api.Error, |
| 168 | Text: err.Error(), |
| 169 | }) |
| 170 | } |
no test coverage detected