scheduler

package
v1.24.0-m1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 15, 2024 License: MIT Imports: 46 Imported by: 0

Documentation

Index

Constants

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

	// represents the state before Version is introduced
	InitialVersion SchedulerWorkflowVersion = 0
	// skip over entire time range if paused and batch and cache getNextTime queries
	BatchAndCacheTimeQueries = 1
	// use cache v2, and include ids in jitter
	NewCacheAndJitter = 2
	// Don't put possibly-overlapping runs (from SCHEDULE_OVERLAP_POLICY_ALLOW_ALL) in
	// RunningWorkflows.
	DontTrackOverlapping = 3
	// start time in backfill is inclusive rather than exclusive
	InclusiveBackfillStartTime = 4
	// do backfill incrementally
	IncrementalBackfill = 5
	// update from previous action instead of current time
	UpdateFromPrevious = 6
)
View Source
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"
	SignalNameForceCAN = "force-continue-as-new"

	QueryNameDescribe          = "describe"
	QueryNameListMatchingTimes = "listMatchingTimes"

	MemoFieldInfo = "ScheduleInfo"

	InitialConflictToken = 1
)

Variables

Functions

func CleanSpec added in v1.20.1

func CleanSpec(spec *schedpb.ScheduleSpec)

CleanSpec sets default values in ranges.

func GetListInfoFromStartArgs added in v1.20.0

func GetListInfoFromStartArgs(args *schedspb.StartScheduleArgs, now time.Time, specBuilder *SpecBuilder) *schedpb.ScheduleListInfo

func NewResult

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

func SchedulerWorkflow

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

Types

type CompiledSpec added in v1.18.0

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

func (*CompiledSpec) CanonicalForm added in v1.18.0

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

type SchedulerWorkflowVersion added in v1.20.3

type SchedulerWorkflowVersion int64

type SpecBuilder added in v1.24.0

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

func NewSpecBuilder added in v1.24.0

func NewSpecBuilder() *SpecBuilder

func (*SpecBuilder) NewCompiledSpec added in v1.24.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL