activity

Documentation

Index

• func InstrumentedExecuteFunctionActivity(...) ...
• func NewExecuteFunctionActivity(registry *fn.Registry) ...

Functions

func InstrumentedExecuteFunctionActivity

func InstrumentedExecuteFunctionActivity(
	inner func(ctx context.Context, input payload.FunctionExecutionInput) (*payload.FunctionExecutionOutput, error),
) func(ctx context.Context, input payload.FunctionExecutionInput) (*payload.FunctionExecutionOutput, error)

InstrumentedExecuteFunctionActivity wraps a function activity with OTel spans and metrics. When OTel config is not in context, the wrapper is a transparent pass-through with zero overhead.

func NewExecuteFunctionActivity

func NewExecuteFunctionActivity(registry *fn.Registry) func(ctx context.Context, input payload.FunctionExecutionInput) (*payload.FunctionExecutionOutput, error)

NewExecuteFunctionActivity creates a Temporal activity that dispatches to registered handlers.

Error handling semantics:

• Validation errors and registry lookup failures return an error, causing Temporal retries.
• Handler execution errors are captured in the output (Success=false, Error set) but return nil error, so Temporal does NOT retry. This treats handler failures as business logic results.