scheduler

Documentation

Index

• Constants
• Variables
• func NewResult(dcCollection *dynamicconfig.Collection, params activityDeps) fxResult
• func SchedulerWorkflow(ctx workflow.Context, args *schedspb.StartScheduleArgs) error
• type CompiledSpec
  • func NewCompiledSpec(spec *schedpb.ScheduleSpec) (*CompiledSpec, error)
  • func (cs *CompiledSpec) CanonicalForm() *schedpb.ScheduleSpec

Constants

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

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"

	MemoFieldInfo = "ScheduleInfo"

	InitialConflictToken = 1
)

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

Types

type CompiledSpec

type CompiledSpec struct {
	// contains filtered or unexported fields
}

func NewCompiledSpec

func NewCompiledSpec(spec *schedpb.ScheduleSpec) (*CompiledSpec, error)

func (*CompiledSpec) CanonicalForm

func (cs *CompiledSpec) CanonicalForm() *schedpb.ScheduleSpec