Documentation
¶
Index ¶
- type EventRecorder
- func (_m *EventRecorder) OnRecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent) *EventRecorder_RecordNodeEvent
- func (_m *EventRecorder) OnRecordNodeEventMatch(matchers ...interface{}) *EventRecorder_RecordNodeEvent
- func (_m *EventRecorder) OnRecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent) *EventRecorder_RecordTaskEvent
- func (_m *EventRecorder) OnRecordTaskEventMatch(matchers ...interface{}) *EventRecorder_RecordTaskEvent
- func (_m *EventRecorder) OnRecordWorkflowEvent(ctx context.Context, _a1 *event.WorkflowExecutionEvent) *EventRecorder_RecordWorkflowEvent
- func (_m *EventRecorder) OnRecordWorkflowEventMatch(matchers ...interface{}) *EventRecorder_RecordWorkflowEvent
- func (_m *EventRecorder) RecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent) error
- func (_m *EventRecorder) RecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent) error
- func (_m *EventRecorder) RecordWorkflowEvent(ctx context.Context, _a1 *event.WorkflowExecutionEvent) error
- type EventRecorder_RecordNodeEvent
- type EventRecorder_RecordTaskEvent
- type EventRecorder_RecordWorkflowEvent
- type EventSink
- func (_m *EventSink) Close() error
- func (_m *EventSink) OnClose() *EventSink_Close
- func (_m *EventSink) OnCloseMatch(matchers ...interface{}) *EventSink_Close
- func (_m *EventSink) OnSink(ctx context.Context, message protoiface.MessageV1) *EventSink_Sink
- func (_m *EventSink) OnSinkMatch(matchers ...interface{}) *EventSink_Sink
- func (_m *EventSink) Sink(ctx context.Context, message protoiface.MessageV1) error
- type EventSink_Close
- type EventSink_Sink
- type MockEventSink
- type NodeEventRecorder
- func (_m *NodeEventRecorder) OnRecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent, ...) *NodeEventRecorder_RecordNodeEvent
- func (_m *NodeEventRecorder) OnRecordNodeEventMatch(matchers ...interface{}) *NodeEventRecorder_RecordNodeEvent
- func (_m *NodeEventRecorder) RecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent, ...) error
- type NodeEventRecorder_RecordNodeEvent
- type TaskEventRecorder
- func (_m *TaskEventRecorder) OnRecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent, ...) *TaskEventRecorder_RecordTaskEvent
- func (_m *TaskEventRecorder) OnRecordTaskEventMatch(matchers ...interface{}) *TaskEventRecorder_RecordTaskEvent
- func (_m *TaskEventRecorder) RecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent, ...) error
- type TaskEventRecorder_RecordTaskEvent
- type WorkflowEventRecorder
- func (_m *WorkflowEventRecorder) OnRecordWorkflowEvent(ctx context.Context, _a1 *event.WorkflowExecutionEvent, ...) *WorkflowEventRecorder_RecordWorkflowEvent
- func (_m *WorkflowEventRecorder) OnRecordWorkflowEventMatch(matchers ...interface{}) *WorkflowEventRecorder_RecordWorkflowEvent
- func (_m *WorkflowEventRecorder) RecordWorkflowEvent(ctx context.Context, _a1 *event.WorkflowExecutionEvent, ...) error
- type WorkflowEventRecorder_RecordWorkflowEvent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventRecorder ¶ added in v0.16.7
EventRecorder is an autogenerated mock type for the EventRecorder type
func (*EventRecorder) OnRecordNodeEvent ¶ added in v0.16.7
func (_m *EventRecorder) OnRecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent) *EventRecorder_RecordNodeEvent
func (*EventRecorder) OnRecordNodeEventMatch ¶ added in v0.16.7
func (_m *EventRecorder) OnRecordNodeEventMatch(matchers ...interface{}) *EventRecorder_RecordNodeEvent
func (*EventRecorder) OnRecordTaskEvent ¶ added in v0.16.7
func (_m *EventRecorder) OnRecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent) *EventRecorder_RecordTaskEvent
func (*EventRecorder) OnRecordTaskEventMatch ¶ added in v0.16.7
func (_m *EventRecorder) OnRecordTaskEventMatch(matchers ...interface{}) *EventRecorder_RecordTaskEvent
func (*EventRecorder) OnRecordWorkflowEvent ¶ added in v0.16.7
func (_m *EventRecorder) OnRecordWorkflowEvent(ctx context.Context, _a1 *event.WorkflowExecutionEvent) *EventRecorder_RecordWorkflowEvent
func (*EventRecorder) OnRecordWorkflowEventMatch ¶ added in v0.16.7
func (_m *EventRecorder) OnRecordWorkflowEventMatch(matchers ...interface{}) *EventRecorder_RecordWorkflowEvent
func (*EventRecorder) RecordNodeEvent ¶ added in v0.16.7
func (_m *EventRecorder) RecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent) error
RecordNodeEvent provides a mock function with given fields: ctx, _a1
func (*EventRecorder) RecordTaskEvent ¶ added in v0.16.7
func (_m *EventRecorder) RecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent) error
RecordTaskEvent provides a mock function with given fields: ctx, _a1
func (*EventRecorder) RecordWorkflowEvent ¶ added in v0.16.7
func (_m *EventRecorder) RecordWorkflowEvent(ctx context.Context, _a1 *event.WorkflowExecutionEvent) error
RecordWorkflowEvent provides a mock function with given fields: ctx, _a1
type EventRecorder_RecordNodeEvent ¶ added in v0.16.7
func (EventRecorder_RecordNodeEvent) Return ¶ added in v0.16.7
func (_m EventRecorder_RecordNodeEvent) Return(_a0 error) *EventRecorder_RecordNodeEvent
type EventRecorder_RecordTaskEvent ¶ added in v0.16.7
func (EventRecorder_RecordTaskEvent) Return ¶ added in v0.16.7
func (_m EventRecorder_RecordTaskEvent) Return(_a0 error) *EventRecorder_RecordTaskEvent
type EventRecorder_RecordWorkflowEvent ¶ added in v0.16.7
func (EventRecorder_RecordWorkflowEvent) Return ¶ added in v0.16.7
func (_m EventRecorder_RecordWorkflowEvent) Return(_a0 error) *EventRecorder_RecordWorkflowEvent
type EventSink ¶ added in v0.16.7
EventSink is an autogenerated mock type for the EventSink type
func (*EventSink) OnClose ¶ added in v0.16.7
func (_m *EventSink) OnClose() *EventSink_Close
func (*EventSink) OnCloseMatch ¶ added in v0.16.7
func (_m *EventSink) OnCloseMatch(matchers ...interface{}) *EventSink_Close
func (*EventSink) OnSink ¶ added in v0.16.7
func (_m *EventSink) OnSink(ctx context.Context, message protoiface.MessageV1) *EventSink_Sink
func (*EventSink) OnSinkMatch ¶ added in v0.16.7
func (_m *EventSink) OnSinkMatch(matchers ...interface{}) *EventSink_Sink
type EventSink_Close ¶ added in v0.16.7
func (EventSink_Close) Return ¶ added in v0.16.7
func (_m EventSink_Close) Return(_a0 error) *EventSink_Close
type EventSink_Sink ¶ added in v0.16.7
func (EventSink_Sink) Return ¶ added in v0.16.7
func (_m EventSink_Sink) Return(_a0 error) *EventSink_Sink
type MockEventSink ¶
type MockEventSink struct { SinkCb func(ctx context.Context, message proto.Message) error CloseCb func() error }
func NewMockEventSink ¶
func NewMockEventSink() *MockEventSink
func (*MockEventSink) Close ¶
func (t *MockEventSink) Close() error
type NodeEventRecorder ¶
NodeEventRecorder is an autogenerated mock type for the NodeEventRecorder type
func (*NodeEventRecorder) OnRecordNodeEvent ¶
func (_m *NodeEventRecorder) OnRecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent, eventConfig *config.EventConfig) *NodeEventRecorder_RecordNodeEvent
func (*NodeEventRecorder) OnRecordNodeEventMatch ¶
func (_m *NodeEventRecorder) OnRecordNodeEventMatch(matchers ...interface{}) *NodeEventRecorder_RecordNodeEvent
func (*NodeEventRecorder) RecordNodeEvent ¶
func (_m *NodeEventRecorder) RecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent, eventConfig *config.EventConfig) error
RecordNodeEvent provides a mock function with given fields: ctx, _a1, eventConfig
type NodeEventRecorder_RecordNodeEvent ¶
func (NodeEventRecorder_RecordNodeEvent) Return ¶
func (_m NodeEventRecorder_RecordNodeEvent) Return(_a0 error) *NodeEventRecorder_RecordNodeEvent
type TaskEventRecorder ¶
TaskEventRecorder is an autogenerated mock type for the TaskEventRecorder type
func (*TaskEventRecorder) OnRecordTaskEvent ¶
func (_m *TaskEventRecorder) OnRecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent, eventConfig *config.EventConfig) *TaskEventRecorder_RecordTaskEvent
func (*TaskEventRecorder) OnRecordTaskEventMatch ¶
func (_m *TaskEventRecorder) OnRecordTaskEventMatch(matchers ...interface{}) *TaskEventRecorder_RecordTaskEvent
func (*TaskEventRecorder) RecordTaskEvent ¶
func (_m *TaskEventRecorder) RecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent, eventConfig *config.EventConfig) error
RecordTaskEvent provides a mock function with given fields: ctx, _a1, eventConfig
type TaskEventRecorder_RecordTaskEvent ¶
func (TaskEventRecorder_RecordTaskEvent) Return ¶
func (_m TaskEventRecorder_RecordTaskEvent) Return(_a0 error) *TaskEventRecorder_RecordTaskEvent
type WorkflowEventRecorder ¶
WorkflowEventRecorder is an autogenerated mock type for the WorkflowEventRecorder type
func (*WorkflowEventRecorder) OnRecordWorkflowEvent ¶
func (_m *WorkflowEventRecorder) OnRecordWorkflowEvent(ctx context.Context, _a1 *event.WorkflowExecutionEvent, eventConfig *config.EventConfig) *WorkflowEventRecorder_RecordWorkflowEvent
func (*WorkflowEventRecorder) OnRecordWorkflowEventMatch ¶
func (_m *WorkflowEventRecorder) OnRecordWorkflowEventMatch(matchers ...interface{}) *WorkflowEventRecorder_RecordWorkflowEvent
func (*WorkflowEventRecorder) RecordWorkflowEvent ¶
func (_m *WorkflowEventRecorder) RecordWorkflowEvent(ctx context.Context, _a1 *event.WorkflowExecutionEvent, eventConfig *config.EventConfig) error
RecordWorkflowEvent provides a mock function with given fields: ctx, _a1, eventConfig
type WorkflowEventRecorder_RecordWorkflowEvent ¶
func (WorkflowEventRecorder_RecordWorkflowEvent) Return ¶
func (_m WorkflowEventRecorder_RecordWorkflowEvent) Return(_a0 error) *WorkflowEventRecorder_RecordWorkflowEvent