events

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 27, 2025 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
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

Variables

This section is empty.

Functions

This section is empty.

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.