sessionworkflows

Documentation

Index

• type Config
• type StartWorkflowOptions
• type Workflows
  • func New(l *zap.Logger, cfg Config, sessions sdkservices.Sessions, ...) Workflows

Types

type Config

type Config struct {
	SessionWorkflow     temporalclient.WorkflowConfig `koanf:"session_workflow"`
	TerminationWorkflow temporalclient.WorkflowConfig `koanf:"termination_workflow"`

	Activity temporalclient.ActivityConfig `koanf:"activity"`

	Worker temporalclient.WorkerConfig `koanf:"worker"`

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

	SlowOperationTimeout time.Duration `koanf:"slow_operation_timeout"`

	// Enable test tools.
	Test bool `koanf:"test"`
}

type StartWorkflowOptions

type StartWorkflowOptions struct {
	UseTemporalForSessionLogs bool
}

type Workflows

type Workflows interface {
	StartWorkers(context.Context) error
	StartWorkflow(ctx context.Context, session sdktypes.Session, opts StartWorkflowOptions) error
	GetWorkflowLog(ctx context.Context, filter sdkservices.SessionLogRecordsFilter) (*sdkservices.GetLogResults, error)
	StopWorkflow(ctx context.Context, sessionID sdktypes.SessionID, reason string, force bool, cancelTimeout time.Duration) error
}

func New

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