events

Documentation

Index

• Constants
• 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

Constants

const (
	LabelWorkflowOwner             = "workflow_owner_address"
	LabelWorkflowID                = "workflow_id"
	LabelWorkflowExecutionID       = "workflow_execution_id"
	LabelWorkflowName              = "workflow_name"
	LabelCapabilityContractAddress = "capability_contract_address"
	LabelCapabilityID              = "capability_id"
	LabelCapabilityVersion         = "capability_version"
	LabelCapabilityName            = "capability_name"
)

Duplicates the attributes in beholder/message.go::Metadata

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
}