scheduler

Documentation

Index

• Constants
• Variables
• func NewResult(dcCollection *dynamicconfig.Collection, params activityDeps) fxResult
• func SchedulerWorkflow(ctx workflow.Context, args *schedspb.StartScheduleArgs) error

Constants

const (
	// Schedules are implemented by a workflow whose ID is this string plus the schedule ID.
	WorkflowIDPrefix = "temporal-sys-scheduler:"

	// This is an example of a timestamp that's appended to the workflow
	// id, used for validation in the frontend.
	AppendedTimestampForValidation = "-2009-11-10T23:00:00Z"

	SignalNameUpdate  = "update"
	SignalNamePatch   = "patch"
	SignalNameRefresh = "refresh"

	QueryNameDescribe          = "describe"
	QueryNameListMatchingTimes = "listMatchingTimes"

	InitialConflictToken = 1
)

const (
	WorkflowType = "temporal-sys-scheduler-workflow"
)

Variables

var Module = fx.Options(
	fx.Provide(NewResult),
)

Functions

func NewResult

func NewResult(
	dcCollection *dynamicconfig.Collection,
	params activityDeps,
) fxResult

func SchedulerWorkflow

func SchedulerWorkflow(ctx workflow.Context, args *schedspb.StartScheduleArgs) error