ctxutil

package

v0.0.1-alpha Latest Latest Go to latest Published: Oct 2, 2024 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

View Source

var ErrNotFoundInContext = errors.New("not found in context")

This section is empty.

type DerivationFunc[T any] func(current T) (next T, err error)

type Loader[T any] interface {
	Load(ctx ValueContainer) (T, error)
}

type LoaderFunc[T any] func(ctx ValueContainer) (T, error)

type Propagator[T any] interface {
	workflow.ContextPropagator
}

type Provider[T any] interface {
	Loader[T]
	Saver[T]
	WorkflowSaver[T]
}

type Saver[T any] interface {
	Save(ctx context.Context, v T) context.Context
}

type Store[T any, K any] struct {
	// contains filtered or unexported fields
}

func NewStore[T any, K any]() *Store[T, K]

func (s *Store[T, K]) Derive(ctx ValueContainer, derive DerivationFunc[T]) (T, error)

func (s *Store[T, K]) Load(ctx ValueContainer) (r T, err error)

func (s *Store[T, K]) LoadOrDefault(ctx ValueContainer, defaultValue T) (r T, err error)

func (s *Store[T, K]) LoadOrDefaultFunc(ctx ValueContainer, defaultValueFunc func() (T, error)) (r T, err error)

func (s *Store[T, K]) Save(ctx context.Context, v T) context.Context

func (s *Store[T, K]) SaveToWorkflow(ctx workflow.Context, v T) workflow.Context

type ValueContainer interface {
	Value(any) any
}

type WorkflowPropagator[T any] struct {
	// contains filtered or unexported fields
}

func NewPropagator[T any](key string, provider Provider[T]) *WorkflowPropagator[T]

func (p *WorkflowPropagator[T]) Extract(ctx context.Context, reader workflow.HeaderReader) (context.Context, error)

Extract extracts context information from headers and returns a context

func (p *WorkflowPropagator[T]) ExtractToWorkflow(ctx workflow.Context, reader workflow.HeaderReader) (workflow.Context, error)

ExtractToWorkflow extracts context information from headers and returns a workflow context

func (p *WorkflowPropagator[T]) Inject(ctx context.Context, writer workflow.HeaderWriter) (err error)

Inject injects information from a Go Context into headers

func (p *WorkflowPropagator[T]) InjectFromWorkflow(ctx workflow.Context, writer workflow.HeaderWriter) (err error)

InjectFromWorkflow injects information from workflow context into headers

type WorkflowSaver[T any] interface {
	SaveToWorkflow(ctx workflow.Context, v T) workflow.Context
}