events

Documentation

Index

• type NodeEventRecorder
  • func NewNodeEventRecorder(eventSink events.EventSink, scope promutils.Scope, store *storage.DataStore) NodeEventRecorder
• type TaskEventRecorder
  • func NewTaskEventRecorder(eventSink events.EventSink, scope promutils.Scope, store *storage.DataStore) TaskEventRecorder
• type WorkflowEventRecorder
  • func NewWorkflowEventRecorder(eventSink events.EventSink, scope promutils.Scope, store *storage.DataStore) WorkflowEventRecorder

Types

type NodeEventRecorder

type NodeEventRecorder interface {
	// Records node execution events indicating the node has undergone a phase change and additional metadata.
	RecordNodeEvent(ctx context.Context, event *event.NodeExecutionEvent, eventConfig *config.EventConfig) error
}

Recorder for Node events

func NewNodeEventRecorder

func NewNodeEventRecorder(eventSink events.EventSink, scope promutils.Scope, store *storage.DataStore) NodeEventRecorder

type TaskEventRecorder

type TaskEventRecorder interface {
	// Records task execution events indicating the task has undergone a phase change and additional metadata.
	RecordTaskEvent(ctx context.Context, event *event.TaskExecutionEvent, eventConfig *config.EventConfig) error
}

Recorder for Task events

func NewTaskEventRecorder

func NewTaskEventRecorder(eventSink events.EventSink, scope promutils.Scope, store *storage.DataStore) TaskEventRecorder

type WorkflowEventRecorder

type WorkflowEventRecorder interface {
	// Records workflow execution events indicating the workflow has undergone a phase change and additional metadata.
	RecordWorkflowEvent(ctx context.Context, event *event.WorkflowExecutionEvent, eventConfig *config.EventConfig) error
}

Recorder for Workflow events

func NewWorkflowEventRecorder

func NewWorkflowEventRecorder(eventSink events.EventSink, scope promutils.Scope, store *storage.DataStore) WorkflowEventRecorder