contextpropagation

Documentation

Index

• func Extract(ctx context.Context, metadata *core.WorkflowMetadata, ...) (context.Context, error)
• func ExtractToWorkflow(ctx sync.Context, metadata *core.WorkflowMetadata, ...) (sync.Context, error)
• func Inject(ctx context.Context, metadata *core.WorkflowMetadata, ...) error
• func InjectFromWorkflow(ctx sync.Context, metadata *core.WorkflowMetadata, ...) error
• func WithPropagators(ctx sync.Context, propagators []ContextPropagator) sync.Context
• type ContextPropagator
  • func Propagators(ctx sync.Context) []ContextPropagator

Functions

func Extract

func Extract(ctx context.Context, metadata *core.WorkflowMetadata, propagators []ContextPropagator) (context.Context, error)

func ExtractToWorkflow

func ExtractToWorkflow(ctx sync.Context, metadata *core.WorkflowMetadata, propagators []ContextPropagator) (sync.Context, error)

func Inject

func Inject(ctx context.Context, metadata *core.WorkflowMetadata, propagators []ContextPropagator) error

func InjectFromWorkflow

func InjectFromWorkflow(ctx sync.Context, metadata *core.WorkflowMetadata, propagators []ContextPropagator) error

func WithPropagators

func WithPropagators(ctx sync.Context, propagators []ContextPropagator) sync.Context

Types

type ContextPropagator

type ContextPropagator interface {
	Inject(context.Context, *core.WorkflowMetadata) error
	Extract(context.Context, *core.WorkflowMetadata) (context.Context, error)

	InjectFromWorkflow(sync.Context, *core.WorkflowMetadata) error
	ExtractToWorkflow(sync.Context, *core.WorkflowMetadata) (sync.Context, error)
}

func Propagators

func Propagators(ctx sync.Context) []ContextPropagator