events

Documentation

Index

• type EmitMetadata
• type Emitter
  • func NewEmitter() *Emitter
  • func (e *Emitter) Emit(ctx context.Context, msg Message) error
  • func (e *Emitter) With(md EmitMetadata) *Emitter
• type Message

Types

type EmitMetadata

type EmitMetadata struct {
	WorkflowOwner string // required
	WorkflowID    string // required
	WorkflowName  string // required

	WorkflowExecutionID       string // optional
	CapabilityContractAddress string // optional
	CapabilityID              string // optional
	CapabilityVersion         string // optional
	CapabilityName            string // optional
}

type Emitter

type Emitter struct {
	// contains filtered or unexported fields
}

func NewEmitter

func NewEmitter() *Emitter

func (*Emitter) Emit

func (e *Emitter) Emit(ctx context.Context, msg Message) error

func (*Emitter) With

func (e *Emitter) With(md EmitMetadata) *Emitter

type Message

type Message struct {
	Msg      string
	Labels   map[string]any
	Metadata EmitMetadata
}