cronv1

package
v0.2.3 Latest Latest
Warning

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

Go to latest
Published: Oct 3, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Weekday_name = map[int32]string{
		0: "WEEKDAY_UNSPECIFIED",
		1: "WEEKDAY_SUNDAY",
		2: "WEEKDAY_MONDAY",
		3: "WEEKDAY_TUESDAY",
		4: "WEEKDAY_WEDNESDAY",
		5: "WEEKDAY_THURSDAY",
		6: "WEEKDAY_FRIDAY",
		7: "WEEKDAY_SATURDAY",
	}
	Weekday_value = map[string]int32{
		"WEEKDAY_UNSPECIFIED": 0,
		"WEEKDAY_SUNDAY":      1,
		"WEEKDAY_MONDAY":      2,
		"WEEKDAY_TUESDAY":     3,
		"WEEKDAY_WEDNESDAY":   4,
		"WEEKDAY_THURSDAY":    5,
		"WEEKDAY_FRIDAY":      6,
		"WEEKDAY_SATURDAY":    7,
	}
)

Enum value maps for Weekday.

View Source
var (
	CronDialect_name = map[int32]string{
		0: "CRON_DIALECT_UNSPECIFIED",
		1: "CRON_DIALECT_ROBFIG_STANDARD",
	}
	CronDialect_value = map[string]int32{
		"CRON_DIALECT_UNSPECIFIED":     0,
		"CRON_DIALECT_ROBFIG_STANDARD": 1,
	}
)

Enum value maps for CronDialect.

View Source
var (
	CatchUpPolicy_name = map[int32]string{
		0: "CATCH_UP_POLICY_UNSPECIFIED",
		1: "CATCH_UP_POLICY_NONE",
		2: "CATCH_UP_POLICY_LATEST",
		3: "CATCH_UP_POLICY_ALL",
	}
	CatchUpPolicy_value = map[string]int32{
		"CATCH_UP_POLICY_UNSPECIFIED": 0,
		"CATCH_UP_POLICY_NONE":        1,
		"CATCH_UP_POLICY_LATEST":      2,
		"CATCH_UP_POLICY_ALL":         3,
	}
)

Enum value maps for CatchUpPolicy.

View Source
var (
	OverlapPolicy_name = map[int32]string{
		0: "OVERLAP_POLICY_UNSPECIFIED",
		1: "OVERLAP_POLICY_SKIP",
		2: "OVERLAP_POLICY_ALLOW",
	}
	OverlapPolicy_value = map[string]int32{
		"OVERLAP_POLICY_UNSPECIFIED": 0,
		"OVERLAP_POLICY_SKIP":        1,
		"OVERLAP_POLICY_ALLOW":       2,
	}
)

Enum value maps for OverlapPolicy.

View Source
var (
	RunState_name = map[int32]string{
		0: "RUN_STATE_UNSPECIFIED",
		1: "RUN_STATE_PENDING",
		2: "RUN_STATE_RUNNING",
		3: "RUN_STATE_SUCCEEDED",
		4: "RUN_STATE_FAILED",
		5: "RUN_STATE_CANCELED",
		6: "RUN_STATE_SKIPPED",
	}
	RunState_value = map[string]int32{
		"RUN_STATE_UNSPECIFIED": 0,
		"RUN_STATE_PENDING":     1,
		"RUN_STATE_RUNNING":     2,
		"RUN_STATE_SUCCEEDED":   3,
		"RUN_STATE_FAILED":      4,
		"RUN_STATE_CANCELED":    5,
		"RUN_STATE_SKIPPED":     6,
	}
)

Enum value maps for RunState.

View Source
var File_cron_v1_cron_proto protoreflect.FileDescriptor

Functions

func ValidateIntervalSchedule

func ValidateIntervalSchedule(message *IntervalSchedule) error

ValidateIntervalSchedule checks this message's annotated fields; it does not recurse. A failed predicate returns *liquidproto.Error. Nil input also returns an error.

func ValidateInvocation

func ValidateInvocation(message *Invocation) error

ValidateInvocation checks this message's annotated fields; it does not recurse. A failed predicate returns *liquidproto.Error. Nil input also returns an error.

func ValidateMonthlyDaySchedule

func ValidateMonthlyDaySchedule(message *MonthlyDaySchedule) error

ValidateMonthlyDaySchedule checks this message's annotated fields; it does not recurse. A failed predicate returns *liquidproto.Error. Nil input also returns an error.

func ValidateRawCronSchedule

func ValidateRawCronSchedule(message *RawCronSchedule) error

ValidateRawCronSchedule checks this message's annotated fields; it does not recurse. A failed predicate returns *liquidproto.Error. Nil input also returns an error.

func ValidateRunSummary

func ValidateRunSummary(message *RunSummary) error

ValidateRunSummary checks this message's annotated fields; it does not recurse. A failed predicate returns *liquidproto.Error. Nil input also returns an error.

func ValidateScheduleSpec

func ValidateScheduleSpec(message *ScheduleSpec) error

ValidateScheduleSpec checks this message's annotated fields; it does not recurse. A failed predicate returns *liquidproto.Error. Nil input also returns an error.

func ValidateTimeOfDay

func ValidateTimeOfDay(message *TimeOfDay) error

ValidateTimeOfDay checks this message's annotated fields; it does not recurse. A failed predicate returns *liquidproto.Error. Nil input also returns an error.

func ValidateTriggerDefinition added in v0.2.0

func ValidateTriggerDefinition(message *TriggerDefinition) error

ValidateTriggerDefinition checks this message's annotated fields; it does not recurse. A failed predicate returns *liquidproto.Error. Nil input also returns an error.

func ValidateTriggerStatus added in v0.2.0

func ValidateTriggerStatus(message *TriggerStatus) error

ValidateTriggerStatus checks this message's annotated fields; it does not recurse. A failed predicate returns *liquidproto.Error. Nil input also returns an error.

Types

type CatchUpPolicy

type CatchUpPolicy int32
const (
	CatchUpPolicy_CATCH_UP_POLICY_UNSPECIFIED CatchUpPolicy = 0
	CatchUpPolicy_CATCH_UP_POLICY_NONE        CatchUpPolicy = 1
	CatchUpPolicy_CATCH_UP_POLICY_LATEST      CatchUpPolicy = 2
	CatchUpPolicy_CATCH_UP_POLICY_ALL         CatchUpPolicy = 3
)

func (CatchUpPolicy) Descriptor

func (CatchUpPolicy) Enum

func (x CatchUpPolicy) Enum() *CatchUpPolicy

func (CatchUpPolicy) EnumDescriptor deprecated

func (CatchUpPolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use CatchUpPolicy.Descriptor instead.

func (CatchUpPolicy) Number

func (CatchUpPolicy) String

func (x CatchUpPolicy) String() string

func (CatchUpPolicy) Type

type CronDialect

type CronDialect int32
const (
	CronDialect_CRON_DIALECT_UNSPECIFIED CronDialect = 0
	// Robfig's standard five-field grammar, including descriptors such as
	// @daily. Interval scheduling should use IntervalSchedule instead.
	CronDialect_CRON_DIALECT_ROBFIG_STANDARD CronDialect = 1
)

func (CronDialect) Descriptor

func (CronDialect) Enum

func (x CronDialect) Enum() *CronDialect

func (CronDialect) EnumDescriptor deprecated

func (CronDialect) EnumDescriptor() ([]byte, []int)

Deprecated: Use CronDialect.Descriptor instead.

func (CronDialect) Number

func (x CronDialect) Number() protoreflect.EnumNumber

func (CronDialect) String

func (x CronDialect) String() string

func (CronDialect) Type

type DailySchedule

type DailySchedule struct {
	At *TimeOfDay `protobuf:"bytes,1,opt,name=at,proto3" json:"at,omitempty"`
	// contains filtered or unexported fields
}

func (*DailySchedule) Descriptor deprecated

func (*DailySchedule) Descriptor() ([]byte, []int)

Deprecated: Use DailySchedule.ProtoReflect.Descriptor instead.

func (*DailySchedule) GetAt

func (x *DailySchedule) GetAt() *TimeOfDay

func (*DailySchedule) ProtoMessage

func (*DailySchedule) ProtoMessage()

func (*DailySchedule) ProtoReflect

func (x *DailySchedule) ProtoReflect() protoreflect.Message

func (*DailySchedule) Reset

func (x *DailySchedule) Reset()

func (*DailySchedule) String

func (x *DailySchedule) String() string

type IntervalSchedule

type IntervalSchedule struct {
	IntervalNanoseconds int64                  `protobuf:"varint,1,opt,name=interval_nanoseconds,json=intervalNanoseconds,proto3" json:"interval_nanoseconds,omitempty"`
	Anchor              *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=anchor,proto3" json:"anchor,omitempty"`
	// contains filtered or unexported fields
}

IntervalSchedule is elapsed-time scheduling. anchor is optional desired configuration; when absent, the durable store establishes it exactly once and exposes the resulting value on TriggerStatus.

func (*IntervalSchedule) Descriptor deprecated

func (*IntervalSchedule) Descriptor() ([]byte, []int)

Deprecated: Use IntervalSchedule.ProtoReflect.Descriptor instead.

func (*IntervalSchedule) GetAnchor

func (x *IntervalSchedule) GetAnchor() *timestamppb.Timestamp

func (*IntervalSchedule) GetIntervalNanoseconds

func (x *IntervalSchedule) GetIntervalNanoseconds() int64

func (*IntervalSchedule) ProtoMessage

func (*IntervalSchedule) ProtoMessage()

func (*IntervalSchedule) ProtoReflect

func (x *IntervalSchedule) ProtoReflect() protoreflect.Message

func (*IntervalSchedule) Reset

func (x *IntervalSchedule) Reset()

func (*IntervalSchedule) String

func (x *IntervalSchedule) String() string

type Invocation

type Invocation struct {
	OccurrenceId string                 `protobuf:"bytes,1,opt,name=occurrence_id,json=occurrenceId,proto3" json:"occurrence_id,omitempty"`
	TriggerName  string                 `protobuf:"bytes,2,opt,name=trigger_name,json=triggerName,proto3" json:"trigger_name,omitempty"`
	ScheduledAt  *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	StartedAt    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	Attempt      uint32                 `protobuf:"varint,5,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// contains filtered or unexported fields
}

Invocation identifies one scheduled occurrence. occurrence_id is stable for a given trigger name and scheduled time and is the operation's idempotency key.

func (*Invocation) Descriptor deprecated

func (*Invocation) Descriptor() ([]byte, []int)

Deprecated: Use Invocation.ProtoReflect.Descriptor instead.

func (*Invocation) GetAttempt

func (x *Invocation) GetAttempt() uint32

func (*Invocation) GetOccurrenceId

func (x *Invocation) GetOccurrenceId() string

func (*Invocation) GetScheduledAt

func (x *Invocation) GetScheduledAt() *timestamppb.Timestamp

func (*Invocation) GetStartedAt

func (x *Invocation) GetStartedAt() *timestamppb.Timestamp

func (*Invocation) GetTriggerName added in v0.2.0

func (x *Invocation) GetTriggerName() string

func (*Invocation) ProtoMessage

func (*Invocation) ProtoMessage()

func (*Invocation) ProtoReflect

func (x *Invocation) ProtoReflect() protoreflect.Message

func (*Invocation) Reset

func (x *Invocation) Reset()

func (*Invocation) String

func (x *Invocation) String() string

type MonthlyDaySchedule

type MonthlyDaySchedule struct {
	DayOfMonth uint32     `protobuf:"varint,1,opt,name=day_of_month,json=dayOfMonth,proto3" json:"day_of_month,omitempty"`
	At         *TimeOfDay `protobuf:"bytes,2,opt,name=at,proto3" json:"at,omitempty"`
	// contains filtered or unexported fields
}

func (*MonthlyDaySchedule) Descriptor deprecated

func (*MonthlyDaySchedule) Descriptor() ([]byte, []int)

Deprecated: Use MonthlyDaySchedule.ProtoReflect.Descriptor instead.

func (*MonthlyDaySchedule) GetAt

func (x *MonthlyDaySchedule) GetAt() *TimeOfDay

func (*MonthlyDaySchedule) GetDayOfMonth

func (x *MonthlyDaySchedule) GetDayOfMonth() uint32

func (*MonthlyDaySchedule) ProtoMessage

func (*MonthlyDaySchedule) ProtoMessage()

func (*MonthlyDaySchedule) ProtoReflect

func (x *MonthlyDaySchedule) ProtoReflect() protoreflect.Message

func (*MonthlyDaySchedule) Reset

func (x *MonthlyDaySchedule) Reset()

func (*MonthlyDaySchedule) String

func (x *MonthlyDaySchedule) String() string

type MonthlyLastDaySchedule

type MonthlyLastDaySchedule struct {
	At *TimeOfDay `protobuf:"bytes,1,opt,name=at,proto3" json:"at,omitempty"`
	// contains filtered or unexported fields
}

func (*MonthlyLastDaySchedule) Descriptor deprecated

func (*MonthlyLastDaySchedule) Descriptor() ([]byte, []int)

Deprecated: Use MonthlyLastDaySchedule.ProtoReflect.Descriptor instead.

func (*MonthlyLastDaySchedule) GetAt

func (x *MonthlyLastDaySchedule) GetAt() *TimeOfDay

func (*MonthlyLastDaySchedule) ProtoMessage

func (*MonthlyLastDaySchedule) ProtoMessage()

func (*MonthlyLastDaySchedule) ProtoReflect

func (x *MonthlyLastDaySchedule) ProtoReflect() protoreflect.Message

func (*MonthlyLastDaySchedule) Reset

func (x *MonthlyLastDaySchedule) Reset()

func (*MonthlyLastDaySchedule) String

func (x *MonthlyLastDaySchedule) String() string

type OverlapPolicy

type OverlapPolicy int32
const (
	OverlapPolicy_OVERLAP_POLICY_UNSPECIFIED OverlapPolicy = 0
	OverlapPolicy_OVERLAP_POLICY_SKIP        OverlapPolicy = 1
	OverlapPolicy_OVERLAP_POLICY_ALLOW       OverlapPolicy = 2
)

func (OverlapPolicy) Descriptor

func (OverlapPolicy) Enum

func (x OverlapPolicy) Enum() *OverlapPolicy

func (OverlapPolicy) EnumDescriptor deprecated

func (OverlapPolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use OverlapPolicy.Descriptor instead.

func (OverlapPolicy) Number

func (OverlapPolicy) String

func (x OverlapPolicy) String() string

func (OverlapPolicy) Type

type RawCronSchedule

type RawCronSchedule struct {
	Dialect    CronDialect `protobuf:"varint,1,opt,name=dialect,proto3,enum=candace.cron.v1.CronDialect" json:"dialect,omitempty"`
	Expression string      `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

RawCronSchedule is an explicit robfig-compatible escape hatch. The dialect is required so a future parser cannot silently reinterpret an expression.

func (*RawCronSchedule) Descriptor deprecated

func (*RawCronSchedule) Descriptor() ([]byte, []int)

Deprecated: Use RawCronSchedule.ProtoReflect.Descriptor instead.

func (*RawCronSchedule) GetDialect

func (x *RawCronSchedule) GetDialect() CronDialect

func (*RawCronSchedule) GetExpression

func (x *RawCronSchedule) GetExpression() string

func (*RawCronSchedule) ProtoMessage

func (*RawCronSchedule) ProtoMessage()

func (*RawCronSchedule) ProtoReflect

func (x *RawCronSchedule) ProtoReflect() protoreflect.Message

func (*RawCronSchedule) Reset

func (x *RawCronSchedule) Reset()

func (*RawCronSchedule) String

func (x *RawCronSchedule) String() string

type RunState

type RunState int32
const (
	RunState_RUN_STATE_UNSPECIFIED RunState = 0
	RunState_RUN_STATE_PENDING     RunState = 1
	RunState_RUN_STATE_RUNNING     RunState = 2
	RunState_RUN_STATE_SUCCEEDED   RunState = 3
	RunState_RUN_STATE_FAILED      RunState = 4
	RunState_RUN_STATE_CANCELED    RunState = 5
	RunState_RUN_STATE_SKIPPED     RunState = 6
)

func (RunState) Descriptor

func (RunState) Descriptor() protoreflect.EnumDescriptor

func (RunState) Enum

func (x RunState) Enum() *RunState

func (RunState) EnumDescriptor deprecated

func (RunState) EnumDescriptor() ([]byte, []int)

Deprecated: Use RunState.Descriptor instead.

func (RunState) Number

func (x RunState) Number() protoreflect.EnumNumber

func (RunState) String

func (x RunState) String() string

func (RunState) Type

type RunSummary

type RunSummary struct {
	Invocation   *Invocation            `protobuf:"bytes,1,opt,name=invocation,proto3" json:"invocation,omitempty"`
	State        RunState               `protobuf:"varint,2,opt,name=state,proto3,enum=candace.cron.v1.RunState" json:"state,omitempty"`
	FinishedAt   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	WorkerId     string                 `protobuf:"bytes,4,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	ErrorSummary string                 `protobuf:"bytes,5,opt,name=error_summary,json=errorSummary,proto3" json:"error_summary,omitempty"`
	SkipReason   string                 `protobuf:"bytes,6,opt,name=skip_reason,json=skipReason,proto3" json:"skip_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*RunSummary) Descriptor deprecated

func (*RunSummary) Descriptor() ([]byte, []int)

Deprecated: Use RunSummary.ProtoReflect.Descriptor instead.

func (*RunSummary) GetErrorSummary

func (x *RunSummary) GetErrorSummary() string

func (*RunSummary) GetFinishedAt

func (x *RunSummary) GetFinishedAt() *timestamppb.Timestamp

func (*RunSummary) GetInvocation

func (x *RunSummary) GetInvocation() *Invocation

func (*RunSummary) GetSkipReason

func (x *RunSummary) GetSkipReason() string

func (*RunSummary) GetState

func (x *RunSummary) GetState() RunState

func (*RunSummary) GetWorkerId

func (x *RunSummary) GetWorkerId() string

func (*RunSummary) ProtoMessage

func (*RunSummary) ProtoMessage()

func (*RunSummary) ProtoReflect

func (x *RunSummary) ProtoReflect() protoreflect.Message

func (*RunSummary) Reset

func (x *RunSummary) Reset()

func (*RunSummary) String

func (x *RunSummary) String() string

type ScheduleSpec

type ScheduleSpec struct {
	Timezone string `protobuf:"bytes,1,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// Types that are valid to be assigned to Rule:
	//
	//	*ScheduleSpec_Daily
	//	*ScheduleSpec_Weekly
	//	*ScheduleSpec_MonthlyDay
	//	*ScheduleSpec_MonthlyLastDay
	//	*ScheduleSpec_Interval
	//	*ScheduleSpec_RawCron
	Rule isScheduleSpec_Rule `protobuf_oneof:"rule"`
	// contains filtered or unexported fields
}

ScheduleSpec is the versioned boundary representation produced by the fluent Go schedule DSL. Exactly one rule must be set.

func (*ScheduleSpec) Descriptor deprecated

func (*ScheduleSpec) Descriptor() ([]byte, []int)

Deprecated: Use ScheduleSpec.ProtoReflect.Descriptor instead.

func (*ScheduleSpec) GetDaily

func (x *ScheduleSpec) GetDaily() *DailySchedule

func (*ScheduleSpec) GetInterval

func (x *ScheduleSpec) GetInterval() *IntervalSchedule

func (*ScheduleSpec) GetMonthlyDay

func (x *ScheduleSpec) GetMonthlyDay() *MonthlyDaySchedule

func (*ScheduleSpec) GetMonthlyLastDay

func (x *ScheduleSpec) GetMonthlyLastDay() *MonthlyLastDaySchedule

func (*ScheduleSpec) GetRawCron

func (x *ScheduleSpec) GetRawCron() *RawCronSchedule

func (*ScheduleSpec) GetRule

func (x *ScheduleSpec) GetRule() isScheduleSpec_Rule

func (*ScheduleSpec) GetTimezone

func (x *ScheduleSpec) GetTimezone() string

func (*ScheduleSpec) GetWeekly

func (x *ScheduleSpec) GetWeekly() *WeeklySchedule

func (*ScheduleSpec) ProtoMessage

func (*ScheduleSpec) ProtoMessage()

func (*ScheduleSpec) ProtoReflect

func (x *ScheduleSpec) ProtoReflect() protoreflect.Message

func (*ScheduleSpec) Reset

func (x *ScheduleSpec) Reset()

func (*ScheduleSpec) String

func (x *ScheduleSpec) String() string

type ScheduleSpec_Daily

type ScheduleSpec_Daily struct {
	Daily *DailySchedule `protobuf:"bytes,2,opt,name=daily,proto3,oneof"`
}

type ScheduleSpec_Interval

type ScheduleSpec_Interval struct {
	Interval *IntervalSchedule `protobuf:"bytes,6,opt,name=interval,proto3,oneof"`
}

type ScheduleSpec_MonthlyDay

type ScheduleSpec_MonthlyDay struct {
	MonthlyDay *MonthlyDaySchedule `protobuf:"bytes,4,opt,name=monthly_day,json=monthlyDay,proto3,oneof"`
}

type ScheduleSpec_MonthlyLastDay

type ScheduleSpec_MonthlyLastDay struct {
	MonthlyLastDay *MonthlyLastDaySchedule `protobuf:"bytes,5,opt,name=monthly_last_day,json=monthlyLastDay,proto3,oneof"`
}

type ScheduleSpec_RawCron

type ScheduleSpec_RawCron struct {
	RawCron *RawCronSchedule `protobuf:"bytes,7,opt,name=raw_cron,json=rawCron,proto3,oneof"`
}

type ScheduleSpec_Weekly

type ScheduleSpec_Weekly struct {
	Weekly *WeeklySchedule `protobuf:"bytes,3,opt,name=weekly,proto3,oneof"`
}

type StatusSnapshot

type StatusSnapshot struct {
	ObservedAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=observed_at,json=observedAt,proto3" json:"observed_at,omitempty"`
	Triggers   []*TriggerStatus       `protobuf:"bytes,2,rep,name=triggers,proto3" json:"triggers,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusSnapshot) Descriptor deprecated

func (*StatusSnapshot) Descriptor() ([]byte, []int)

Deprecated: Use StatusSnapshot.ProtoReflect.Descriptor instead.

func (*StatusSnapshot) GetObservedAt

func (x *StatusSnapshot) GetObservedAt() *timestamppb.Timestamp

func (*StatusSnapshot) GetTriggers added in v0.2.0

func (x *StatusSnapshot) GetTriggers() []*TriggerStatus

func (*StatusSnapshot) ProtoMessage

func (*StatusSnapshot) ProtoMessage()

func (*StatusSnapshot) ProtoReflect

func (x *StatusSnapshot) ProtoReflect() protoreflect.Message

func (*StatusSnapshot) Reset

func (x *StatusSnapshot) Reset()

func (*StatusSnapshot) String

func (x *StatusSnapshot) String() string

type TimeOfDay

type TimeOfDay struct {
	Hour   uint32 `protobuf:"varint,1,opt,name=hour,proto3" json:"hour,omitempty"`
	Minute uint32 `protobuf:"varint,2,opt,name=minute,proto3" json:"minute,omitempty"`
	// contains filtered or unexported fields
}

TimeOfDay is canonical 24-hour wall time. AM/PM exists only in the fluent Go DSL and is normalized before crossing a boundary.

func (*TimeOfDay) Descriptor deprecated

func (*TimeOfDay) Descriptor() ([]byte, []int)

Deprecated: Use TimeOfDay.ProtoReflect.Descriptor instead.

func (*TimeOfDay) GetHour

func (x *TimeOfDay) GetHour() uint32

func (*TimeOfDay) GetMinute

func (x *TimeOfDay) GetMinute() uint32

func (*TimeOfDay) ProtoMessage

func (*TimeOfDay) ProtoMessage()

func (*TimeOfDay) ProtoReflect

func (x *TimeOfDay) ProtoReflect() protoreflect.Message

func (*TimeOfDay) Reset

func (x *TimeOfDay) Reset()

func (*TimeOfDay) String

func (x *TimeOfDay) String() string

type TriggerDefinition added in v0.2.0

type TriggerDefinition struct {
	Name          string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Schedule      *ScheduleSpec `protobuf:"bytes,2,opt,name=schedule,proto3" json:"schedule,omitempty"`
	CatchUpPolicy CatchUpPolicy `` /* 138-byte string literal not displayed */
	OverlapPolicy OverlapPolicy `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerDefinition is the portable declaration of one trigger: its name, its schedule and its catch-up and overlap policies. The operation it invokes is registered locally by name and is deliberately not serializable.

func (*TriggerDefinition) Descriptor deprecated added in v0.2.0

func (*TriggerDefinition) Descriptor() ([]byte, []int)

Deprecated: Use TriggerDefinition.ProtoReflect.Descriptor instead.

func (*TriggerDefinition) GetCatchUpPolicy added in v0.2.0

func (x *TriggerDefinition) GetCatchUpPolicy() CatchUpPolicy

func (*TriggerDefinition) GetName added in v0.2.0

func (x *TriggerDefinition) GetName() string

func (*TriggerDefinition) GetOverlapPolicy added in v0.2.0

func (x *TriggerDefinition) GetOverlapPolicy() OverlapPolicy

func (*TriggerDefinition) GetSchedule added in v0.2.0

func (x *TriggerDefinition) GetSchedule() *ScheduleSpec

func (*TriggerDefinition) ProtoMessage added in v0.2.0

func (*TriggerDefinition) ProtoMessage()

func (*TriggerDefinition) ProtoReflect added in v0.2.0

func (x *TriggerDefinition) ProtoReflect() protoreflect.Message

func (*TriggerDefinition) Reset added in v0.2.0

func (x *TriggerDefinition) Reset()

func (*TriggerDefinition) String added in v0.2.0

func (x *TriggerDefinition) String() string

type TriggerStatus added in v0.2.0

type TriggerStatus struct {
	Definition     *TriggerDefinition     `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"`
	NextRunAt      *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=next_run_at,json=nextRunAt,proto3" json:"next_run_at,omitempty"`
	IntervalAnchor *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=interval_anchor,json=intervalAnchor,proto3" json:"interval_anchor,omitempty"`
	ActiveRuns     uint32                 `protobuf:"varint,5,opt,name=active_runs,json=activeRuns,proto3" json:"active_runs,omitempty"`
	LastRun        *RunSummary            `protobuf:"bytes,6,opt,name=last_run,json=lastRun,proto3" json:"last_run,omitempty"`
	// contains filtered or unexported fields
}

TriggerStatus is a read-only status projection of one trigger. PostgreSQL remains relational and is mapped explicitly.

func (*TriggerStatus) Descriptor deprecated added in v0.2.0

func (*TriggerStatus) Descriptor() ([]byte, []int)

Deprecated: Use TriggerStatus.ProtoReflect.Descriptor instead.

func (*TriggerStatus) GetActiveRuns added in v0.2.0

func (x *TriggerStatus) GetActiveRuns() uint32

func (*TriggerStatus) GetDefinition added in v0.2.0

func (x *TriggerStatus) GetDefinition() *TriggerDefinition

func (*TriggerStatus) GetIntervalAnchor added in v0.2.0

func (x *TriggerStatus) GetIntervalAnchor() *timestamppb.Timestamp

func (*TriggerStatus) GetLastRun added in v0.2.0

func (x *TriggerStatus) GetLastRun() *RunSummary

func (*TriggerStatus) GetNextRunAt added in v0.2.0

func (x *TriggerStatus) GetNextRunAt() *timestamppb.Timestamp

func (*TriggerStatus) ProtoMessage added in v0.2.0

func (*TriggerStatus) ProtoMessage()

func (*TriggerStatus) ProtoReflect added in v0.2.0

func (x *TriggerStatus) ProtoReflect() protoreflect.Message

func (*TriggerStatus) Reset added in v0.2.0

func (x *TriggerStatus) Reset()

func (*TriggerStatus) String added in v0.2.0

func (x *TriggerStatus) String() string

type Weekday

type Weekday int32
const (
	Weekday_WEEKDAY_UNSPECIFIED Weekday = 0
	Weekday_WEEKDAY_SUNDAY      Weekday = 1
	Weekday_WEEKDAY_MONDAY      Weekday = 2
	Weekday_WEEKDAY_TUESDAY     Weekday = 3
	Weekday_WEEKDAY_WEDNESDAY   Weekday = 4
	Weekday_WEEKDAY_THURSDAY    Weekday = 5
	Weekday_WEEKDAY_FRIDAY      Weekday = 6
	Weekday_WEEKDAY_SATURDAY    Weekday = 7
)

func (Weekday) Descriptor

func (Weekday) Descriptor() protoreflect.EnumDescriptor

func (Weekday) Enum

func (x Weekday) Enum() *Weekday

func (Weekday) EnumDescriptor deprecated

func (Weekday) EnumDescriptor() ([]byte, []int)

Deprecated: Use Weekday.Descriptor instead.

func (Weekday) Number

func (x Weekday) Number() protoreflect.EnumNumber

func (Weekday) String

func (x Weekday) String() string

func (Weekday) Type

func (Weekday) Type() protoreflect.EnumType

type WeeklySchedule

type WeeklySchedule struct {
	Weekday Weekday    `protobuf:"varint,1,opt,name=weekday,proto3,enum=candace.cron.v1.Weekday" json:"weekday,omitempty"`
	At      *TimeOfDay `protobuf:"bytes,2,opt,name=at,proto3" json:"at,omitempty"`
	// contains filtered or unexported fields
}

func (*WeeklySchedule) Descriptor deprecated

func (*WeeklySchedule) Descriptor() ([]byte, []int)

Deprecated: Use WeeklySchedule.ProtoReflect.Descriptor instead.

func (*WeeklySchedule) GetAt

func (x *WeeklySchedule) GetAt() *TimeOfDay

func (*WeeklySchedule) GetWeekday

func (x *WeeklySchedule) GetWeekday() Weekday

func (*WeeklySchedule) ProtoMessage

func (*WeeklySchedule) ProtoMessage()

func (*WeeklySchedule) ProtoReflect

func (x *WeeklySchedule) ProtoReflect() protoreflect.Message

func (*WeeklySchedule) Reset

func (x *WeeklySchedule) Reset()

func (*WeeklySchedule) String

func (x *WeeklySchedule) String() string

Jump to

Keyboard shortcuts

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