telemetry

Documentation

Index

• type TelemetryOption
  • func WithDefaultTTL(ttl time.Duration) TelemetryOption
  • func WithHumanStepTTL(ttl time.Duration) TelemetryOption
• type TelemetryPlugin
  • func New(tracer trace.Tracer, opts ...TelemetryOption) *TelemetryPlugin
  • func (p *TelemetryPlugin) OnRollbackStepChain(ctx context.Context, instanceID int64, stepName string, depth int) error
  • func (p *TelemetryPlugin) OnStepComplete(ctx context.Context, instance *floxy.WorkflowInstance, ...) error
  • func (p *TelemetryPlugin) OnStepFailed(ctx context.Context, instance *floxy.WorkflowInstance, ...) error
  • func (p *TelemetryPlugin) OnStepStart(ctx context.Context, instance *floxy.WorkflowInstance, ...) error
  • func (p *TelemetryPlugin) OnWorkflowComplete(ctx context.Context, instance *floxy.WorkflowInstance) error
  • func (p *TelemetryPlugin) OnWorkflowFailed(ctx context.Context, instance *floxy.WorkflowInstance) error
  • func (p *TelemetryPlugin) OnWorkflowStart(ctx context.Context, instance *floxy.WorkflowInstance) error

Types

type TelemetryOption

type TelemetryOption func(*TelemetryPlugin)

func WithDefaultTTL

func WithDefaultTTL(ttl time.Duration) TelemetryOption

func WithHumanStepTTL

func WithHumanStepTTL(ttl time.Duration) TelemetryOption

type TelemetryPlugin

type TelemetryPlugin struct {
	floxy.BasePlugin
	// contains filtered or unexported fields
}

func New

func New(tracer trace.Tracer, opts ...TelemetryOption) *TelemetryPlugin

func (*TelemetryPlugin) OnRollbackStepChain

func (p *TelemetryPlugin) OnRollbackStepChain(
	ctx context.Context,
	instanceID int64,
	stepName string,
	depth int,
) error

func (*TelemetryPlugin) OnStepComplete

func (p *TelemetryPlugin) OnStepComplete(
	ctx context.Context,
	instance *floxy.WorkflowInstance,
	step *floxy.WorkflowStep,
) error

func (*TelemetryPlugin) OnStepFailed

func (p *TelemetryPlugin) OnStepFailed(
	ctx context.Context,
	instance *floxy.WorkflowInstance,
	step *floxy.WorkflowStep,
	err error,
) error

func (*TelemetryPlugin) OnStepStart

func (p *TelemetryPlugin) OnStepStart(
	ctx context.Context,
	instance *floxy.WorkflowInstance,
	step *floxy.WorkflowStep,
) error

func (*TelemetryPlugin) OnWorkflowComplete

func (p *TelemetryPlugin) OnWorkflowComplete(ctx context.Context, instance *floxy.WorkflowInstance) error

func (*TelemetryPlugin) OnWorkflowFailed

func (p *TelemetryPlugin) OnWorkflowFailed(ctx context.Context, instance *floxy.WorkflowInstance) error

func (*TelemetryPlugin) OnWorkflowStart

func (p *TelemetryPlugin) OnWorkflowStart(ctx context.Context, instance *floxy.WorkflowInstance) error