workflows

Documentation

Index

• Constants
• func CreateSessionsForWorkflow(event sdktypes.Event, sessionsData []SessionData) ([]*sdktypes.Session, error)
• type Services
• type SessionData
• type Workflow
  • func (wf *Workflow) CreateEventRecord(ctx context.Context, eventID sdktypes.EventID, state sdktypes.EventState)
  • func (wf *Workflow) StartSessions(ctx workflow.Context, event sdktypes.Event, sessionsData []SessionData) error

Constants

const (
	EventsWorkflow        = "events_workflow"
	SchedulerWorkflow     = "scheduler_workflow"
	TaskQueueName         = "events-task-queue"
	ScheduleTaskQueueName = "schedule-task-queue"

	DispatcherWorkerID = "dispatcher-worker"
	SchedulerWorkerID  = "scheduler-worker"
)

Functions

func CreateSessionsForWorkflow

func CreateSessionsForWorkflow(event sdktypes.Event, sessionsData []SessionData) ([]*sdktypes.Session, error)

used by both dispatcher and scheduler

Types

type Services

type Services struct {
	fx.In

	Connections  sdkservices.Connections
	Deployments  sdkservices.Deployments
	Events       sdkservices.Events
	Integrations sdkservices.Integrations
	Projects     sdkservices.Projects
	Triggers     sdkservices.Triggers
	Sessions     sdkservices.Sessions
	Envs         sdkservices.Envs
}

type SessionData

type SessionData struct {
	Deployment            sdktypes.Deployment
	CodeLocation          sdktypes.CodeLocation
	Trigger               sdktypes.Trigger
	AdditionalTriggerData map[string]sdktypes.Value
}

type Workflow

type Workflow struct {
	Z        *zap.Logger
	Services Services
	Tmprl    temporalclient.Client
}

func (*Workflow) CreateEventRecord

func (wf *Workflow) CreateEventRecord(ctx context.Context, eventID sdktypes.EventID, state sdktypes.EventState)

func (*Workflow) StartSessions

func (wf *Workflow) StartSessions(ctx workflow.Context, event sdktypes.Event, sessionsData []SessionData) error