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 ¶
EventRecorder is an autogenerated mock type for the EventRecorder type
func (*EventRecorder) OnRecordNodeEvent ¶
func (_m *EventRecorder) OnRecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent) *EventRecorder_RecordNodeEvent
func (*EventRecorder) OnRecordNodeEventMatch ¶
func (_m *EventRecorder) OnRecordNodeEventMatch(matchers ...interface{}) *EventRecorder_RecordNodeEvent
func (*EventRecorder) OnRecordTaskEvent ¶
func (_m *EventRecorder) OnRecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent) *EventRecorder_RecordTaskEvent
func (*EventRecorder) OnRecordTaskEventMatch ¶
func (_m *EventRecorder) OnRecordTaskEventMatch(matchers ...interface{}) *EventRecorder_RecordTaskEvent
func (*EventRecorder) OnRecordWorkflowEvent ¶
func (_m *EventRecorder) OnRecordWorkflowEvent(ctx context.Context, _a1 *event.WorkflowExecutionEvent) *EventRecorder_RecordWorkflowEvent
func (*EventRecorder) OnRecordWorkflowEventMatch ¶
func (_m *EventRecorder) OnRecordWorkflowEventMatch(matchers ...interface{}) *EventRecorder_RecordWorkflowEvent
func (*EventRecorder) RecordNodeEvent ¶
func (_m *EventRecorder) RecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent) error
RecordNodeEvent provides a mock function with given fields: ctx, _a1
func (*EventRecorder) RecordTaskEvent ¶
func (_m *EventRecorder) RecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent) error
RecordTaskEvent provides a mock function with given fields: ctx, _a1
func (*EventRecorder) RecordWorkflowEvent ¶
func (_m *EventRecorder) RecordWorkflowEvent(ctx context.Context, _a1 *event.WorkflowExecutionEvent) error
RecordWorkflowEvent provides a mock function with given fields: ctx, _a1
type EventRecorder_RecordNodeEvent ¶
func (EventRecorder_RecordNodeEvent) Return ¶
func (_m EventRecorder_RecordNodeEvent) Return(_a0 error) *EventRecorder_RecordNodeEvent
type EventRecorder_RecordTaskEvent ¶
func (EventRecorder_RecordTaskEvent) Return ¶
func (_m EventRecorder_RecordTaskEvent) Return(_a0 error) *EventRecorder_RecordTaskEvent
type EventRecorder_RecordWorkflowEvent ¶
func (EventRecorder_RecordWorkflowEvent) Return ¶
func (_m EventRecorder_RecordWorkflowEvent) Return(_a0 error) *EventRecorder_RecordWorkflowEvent
type EventSink ¶
EventSink is an autogenerated mock type for the EventSink type
func (*EventSink) OnClose ¶
func (_m *EventSink) OnClose() *EventSink_Close
func (*EventSink) OnCloseMatch ¶
func (_m *EventSink) OnCloseMatch(matchers ...interface{}) *EventSink_Close
func (*EventSink) OnSink ¶
func (_m *EventSink) OnSink(ctx context.Context, message protoiface.MessageV1) *EventSink_Sink
func (*EventSink) OnSinkMatch ¶
func (_m *EventSink) OnSinkMatch(matchers ...interface{}) *EventSink_Sink
type EventSink_Close ¶
func (EventSink_Close) Return ¶
func (_m EventSink_Close) Return(_a0 error) *EventSink_Close
type EventSink_Sink ¶
func (EventSink_Sink) Return ¶
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