activity

Documentation

Index

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

Functions

func WithActivityState

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

Types

type ActivityState

type ActivityState struct {
	ActivityID string
	Instance   *workflow.Instance
	Logger     log.Logger
}

func GetActivityState

func GetActivityState(context context.Context) *ActivityState

func NewActivityState

func NewActivityState(activityID string, instance *workflow.Instance, logger log.Logger) *ActivityState

type Executor

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

func NewExecutor

func NewExecutor(logger log.Logger, tracer trace.Tracer, converter converter.Converter, r *workflow.Registry) Executor

func (*Executor) ExecuteActivity

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