activity

Documentation

Index

• func WithActivityState(ctx context.Context, as *ActivityState) context.Context
• type ActivityState
  • func GetActivityState(context context.Context) *ActivityState
  • func NewActivityState(activityID string, attempt int, instance *workflow.Instance, ...) *ActivityState
• type Executor
  • func NewExecutor(logger *slog.Logger, tracer trace.Tracer, converter converter.Converter, ...) *Executor
  • func (e *Executor) ExecuteActivity(ctx context.Context, task *backend.ActivityTask) (payload.Payload, error)

Functions

func WithActivityState

func WithActivityState(ctx context.Context, as *ActivityState) context.Context

Types

type ActivityState

type ActivityState struct {
	ActivityID string
	Attempt    int
	Instance   *workflow.Instance
	Logger     *slog.Logger
}

func GetActivityState

func GetActivityState(context context.Context) *ActivityState

func NewActivityState

func NewActivityState(activityID string, attempt int, instance *workflow.Instance, logger *slog.Logger) *ActivityState

type Executor

type Executor struct {
	// contains filtered or unexported fields
}

func NewExecutor

func NewExecutor(
	logger *slog.Logger,
	tracer trace.Tracer,
	converter converter.Converter,
	propagators []wf.ContextPropagator,
	r *registry.Registry,
) *Executor

func (*Executor) ExecuteActivity

func (e *Executor) ExecuteActivity(ctx context.Context, task *backend.ActivityTask) (payload.Payload, error)