Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + const MaxErrorMessageLength + func IDFromMessage(message proto.Message) ([]byte, error) + type Config struct + Capacity int + FilePath string + Rate int64 + Type EventReportingType + func GetConfig(ctx context.Context) *Config + func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet + type EventRecorder interface + RecordNodeEvent func(ctx context.Context, event *event.NodeExecutionEvent) error + RecordTaskEvent func(ctx context.Context, event *event.TaskExecutionEvent) error + RecordWorkflowEvent func(ctx context.Context, event *event.WorkflowExecutionEvent) error + func NewEventRecorder(eventSink EventSink, scope promutils.Scope) EventRecorder + type EventReportingType = string + const EventSinkAdmin + const EventSinkFile + const EventSinkLog + type EventSink interface + Close func() error + Sink func(ctx context.Context, message proto.Message) error + func ConstructEventSink(ctx context.Context, config *Config, scope promutils.Scope) (EventSink, error) + func NewAdminEventSink(ctx context.Context, adminClient service.AdminServiceClient, config *Config, ...) (EventSink, error) + func NewFileSink(path string) (EventSink, error) + func NewLogSink() (EventSink, error) + func NewStdoutSink() (EventSink, error) + type EventSinkType = string + type FileWriter struct + func (fw *FileWriter) Flush() error + func (fw *FileWriter) Write(ctx context.Context, content string) error + type LogWriter struct + func (w *LogWriter) Flush() error + func (w *LogWriter) Write(ctx context.Context, content string) error + type NodeEventRecorder interface + RecordNodeEvent func(ctx context.Context, event *event.NodeExecutionEvent, ...) error + func NewNodeEventRecorder(eventSink EventSink, scope promutils.Scope, store *storage.DataStore) NodeEventRecorder + type StdWriter struct + func (s *StdWriter) Flush() error + func (s *StdWriter) Write(ctx context.Context, content string) error + type TaskEventRecorder interface + RecordTaskEvent func(ctx context.Context, event *event.TaskExecutionEvent, ...) error + func NewTaskEventRecorder(eventSink EventSink, scope promutils.Scope, store *storage.DataStore) TaskEventRecorder + type WorkflowEventRecorder interface + RecordWorkflowEvent func(ctx context.Context, event *event.WorkflowExecutionEvent, ...) error + func NewWorkflowEventRecorder(eventSink EventSink, scope promutils.Scope, store *storage.DataStore) WorkflowEventRecorder
Go to main page