sessionworkflows

Documentation

Index

• type Config
• type TemporalConfig
• type WorkflowConfig
• type Workflows
  • func New(z *zap.Logger, cfg Config, sessions sdkservices.Sessions, ...) Workflows

Types

type Config

type Config struct {
	Temporal TemporalConfig `koanf:"temporal"`
	Workflow WorkflowConfig `koanf:"workflow"`

	// Enable internal test functionality.
	Test     bool `koanf:"test"`
	OSModule bool `koanf:"os_module"`
}

type TemporalConfig

type TemporalConfig struct {
	WorkflowTaskTimeout         time.Duration  `koanf:"workflow_task_timeout"`
	LocalScheduleToCloseTimeout time.Duration  `koanf:"local_schedule_to_close_timeout"`
	Worker                      worker.Options `koanf:"worker"`
}

type WorkflowConfig

type WorkflowConfig struct{}

type Workflows

type Workflows interface {
	StartWorkers(context.Context) error
	StartWorkflow(ctx context.Context, session sdktypes.Session, debug bool) error
	StopWorkflow(ctx context.Context, sessionID sdktypes.SessionID, reason string, force bool) error
}

func New

func New(z *zap.Logger,
	cfg Config,
	sessions sdkservices.Sessions,
	svcs *sessionsvcs.Svcs,
	calls sessioncalls.Calls,
	telemetry *telemetry.Telemetry,
) Workflows