sessioncalls

Documentation

Overview

Adapted from https://github.com/dynajoe/temporal-terraform-demo/blob/main/heartbeat/heartbeat.go.

Index

• func BeginHeartbeat(ctx context.Context, interval time.Duration) (context.Context, func())
• type CallOpts
• type CallParams
• type Calls
  • func New(l *zap.Logger, config Config, svcs *sessionsvcs.Svcs) Calls
• type Config

Functions

func BeginHeartbeat

func BeginHeartbeat(ctx context.Context, interval time.Duration) (context.Context, func())

Types

type CallOpts

type CallOpts struct {
	Catch   bool          `json:"catch"`
	Timeout time.Duration `json:"timeout"`
}

type CallParams

type CallParams struct {
	SessionID sdktypes.SessionID
	CallSpec  sdktypes.SessionCallSpec

	Executors *sdkexecutor.Executors // needed for session specific calls (global modules, script functions).
}

type Calls

type Calls interface {
	StartWorkers(context.Context) error
	Call(ctx workflow.Context, params *CallParams) (sdktypes.SessionCallAttemptResult, error)
}

func New

func New(l *zap.Logger, config Config, svcs *sessionsvcs.Svcs) Calls

type Config

type Config struct {
	// common
	Worker temporalclient.WorkerConfig `koanf:"worker"`

	// override above
	GeneralWorker temporalclient.WorkerConfig `koanf:"general_worker"`
	UniqueWorker  temporalclient.WorkerConfig `koanf:"unique_worker"`

	Activity       temporalclient.ActivityConfig `koanf:"activity"`
	UniqueActivity temporalclient.ActivityConfig `koanf:"unique_activity"`

	ActivityHeartbeatInterval time.Duration `koanf:"activity_heartbeat_interval"`
}