Documentation
¶
Index ¶
- Variables
- func ValidateIntervalSchedule(message *IntervalSchedule) error
- func ValidateInvocation(message *Invocation) error
- func ValidateJobDefinition(message *JobDefinition) error
- func ValidateJobStatus(message *JobStatus) error
- func ValidateMonthlyDaySchedule(message *MonthlyDaySchedule) error
- func ValidateRawCronSchedule(message *RawCronSchedule) error
- func ValidateRunSummary(message *RunSummary) error
- func ValidateScheduleSpec(message *ScheduleSpec) error
- func ValidateTimeOfDay(message *TimeOfDay) error
- type CatchUpPolicy
- func (CatchUpPolicy) Descriptor() protoreflect.EnumDescriptor
- func (x CatchUpPolicy) Enum() *CatchUpPolicy
- func (CatchUpPolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x CatchUpPolicy) Number() protoreflect.EnumNumber
- func (x CatchUpPolicy) String() string
- func (CatchUpPolicy) Type() protoreflect.EnumType
- type CronDialect
- func (CronDialect) Descriptor() protoreflect.EnumDescriptor
- func (x CronDialect) Enum() *CronDialect
- func (CronDialect) EnumDescriptor() ([]byte, []int)deprecated
- func (x CronDialect) Number() protoreflect.EnumNumber
- func (x CronDialect) String() string
- func (CronDialect) Type() protoreflect.EnumType
- type DailySchedule
- type IntervalSchedule
- func (*IntervalSchedule) Descriptor() ([]byte, []int)deprecated
- func (x *IntervalSchedule) GetAnchor() *timestamppb.Timestamp
- func (x *IntervalSchedule) GetIntervalNanoseconds() int64
- func (*IntervalSchedule) ProtoMessage()
- func (x *IntervalSchedule) ProtoReflect() protoreflect.Message
- func (x *IntervalSchedule) Reset()
- func (x *IntervalSchedule) String() string
- type Invocation
- func (*Invocation) Descriptor() ([]byte, []int)deprecated
- func (x *Invocation) GetAttempt() uint32
- func (x *Invocation) GetJobName() string
- func (x *Invocation) GetOccurrenceId() string
- func (x *Invocation) GetScheduledAt() *timestamppb.Timestamp
- func (x *Invocation) GetStartedAt() *timestamppb.Timestamp
- func (*Invocation) ProtoMessage()
- func (x *Invocation) ProtoReflect() protoreflect.Message
- func (x *Invocation) Reset()
- func (x *Invocation) String() string
- type JobDefinition
- func (*JobDefinition) Descriptor() ([]byte, []int)deprecated
- func (x *JobDefinition) GetCatchUpPolicy() CatchUpPolicy
- func (x *JobDefinition) GetName() string
- func (x *JobDefinition) GetOverlapPolicy() OverlapPolicy
- func (x *JobDefinition) GetSchedule() *ScheduleSpec
- func (*JobDefinition) ProtoMessage()
- func (x *JobDefinition) ProtoReflect() protoreflect.Message
- func (x *JobDefinition) Reset()
- func (x *JobDefinition) String() string
- type JobStatus
- func (*JobStatus) Descriptor() ([]byte, []int)deprecated
- func (x *JobStatus) GetActiveRuns() uint32
- func (x *JobStatus) GetDefinition() *JobDefinition
- func (x *JobStatus) GetIntervalAnchor() *timestamppb.Timestamp
- func (x *JobStatus) GetLastRun() *RunSummary
- func (x *JobStatus) GetNextRunAt() *timestamppb.Timestamp
- func (*JobStatus) ProtoMessage()
- func (x *JobStatus) ProtoReflect() protoreflect.Message
- func (x *JobStatus) Reset()
- func (x *JobStatus) String() string
- type MonthlyDaySchedule
- func (*MonthlyDaySchedule) Descriptor() ([]byte, []int)deprecated
- func (x *MonthlyDaySchedule) GetAt() *TimeOfDay
- func (x *MonthlyDaySchedule) GetDayOfMonth() uint32
- func (*MonthlyDaySchedule) ProtoMessage()
- func (x *MonthlyDaySchedule) ProtoReflect() protoreflect.Message
- func (x *MonthlyDaySchedule) Reset()
- func (x *MonthlyDaySchedule) String() string
- type MonthlyLastDaySchedule
- func (*MonthlyLastDaySchedule) Descriptor() ([]byte, []int)deprecated
- func (x *MonthlyLastDaySchedule) GetAt() *TimeOfDay
- func (*MonthlyLastDaySchedule) ProtoMessage()
- func (x *MonthlyLastDaySchedule) ProtoReflect() protoreflect.Message
- func (x *MonthlyLastDaySchedule) Reset()
- func (x *MonthlyLastDaySchedule) String() string
- type OverlapPolicy
- func (OverlapPolicy) Descriptor() protoreflect.EnumDescriptor
- func (x OverlapPolicy) Enum() *OverlapPolicy
- func (OverlapPolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x OverlapPolicy) Number() protoreflect.EnumNumber
- func (x OverlapPolicy) String() string
- func (OverlapPolicy) Type() protoreflect.EnumType
- type RawCronSchedule
- func (*RawCronSchedule) Descriptor() ([]byte, []int)deprecated
- func (x *RawCronSchedule) GetDialect() CronDialect
- func (x *RawCronSchedule) GetExpression() string
- func (*RawCronSchedule) ProtoMessage()
- func (x *RawCronSchedule) ProtoReflect() protoreflect.Message
- func (x *RawCronSchedule) Reset()
- func (x *RawCronSchedule) String() string
- type RunState
- type RunSummary
- func (*RunSummary) Descriptor() ([]byte, []int)deprecated
- func (x *RunSummary) GetErrorSummary() string
- func (x *RunSummary) GetFinishedAt() *timestamppb.Timestamp
- func (x *RunSummary) GetInvocation() *Invocation
- func (x *RunSummary) GetSkipReason() string
- func (x *RunSummary) GetState() RunState
- func (x *RunSummary) GetWorkerId() string
- func (*RunSummary) ProtoMessage()
- func (x *RunSummary) ProtoReflect() protoreflect.Message
- func (x *RunSummary) Reset()
- func (x *RunSummary) String() string
- type ScheduleSpec
- func (*ScheduleSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ScheduleSpec) GetDaily() *DailySchedule
- func (x *ScheduleSpec) GetInterval() *IntervalSchedule
- func (x *ScheduleSpec) GetMonthlyDay() *MonthlyDaySchedule
- func (x *ScheduleSpec) GetMonthlyLastDay() *MonthlyLastDaySchedule
- func (x *ScheduleSpec) GetRawCron() *RawCronSchedule
- func (x *ScheduleSpec) GetRule() isScheduleSpec_Rule
- func (x *ScheduleSpec) GetTimezone() string
- func (x *ScheduleSpec) GetWeekly() *WeeklySchedule
- func (*ScheduleSpec) ProtoMessage()
- func (x *ScheduleSpec) ProtoReflect() protoreflect.Message
- func (x *ScheduleSpec) Reset()
- func (x *ScheduleSpec) String() string
- type ScheduleSpec_Daily
- type ScheduleSpec_Interval
- type ScheduleSpec_MonthlyDay
- type ScheduleSpec_MonthlyLastDay
- type ScheduleSpec_RawCron
- type ScheduleSpec_Weekly
- type StatusSnapshot
- func (*StatusSnapshot) Descriptor() ([]byte, []int)deprecated
- func (x *StatusSnapshot) GetJobs() []*JobStatus
- func (x *StatusSnapshot) GetObservedAt() *timestamppb.Timestamp
- func (*StatusSnapshot) ProtoMessage()
- func (x *StatusSnapshot) ProtoReflect() protoreflect.Message
- func (x *StatusSnapshot) Reset()
- func (x *StatusSnapshot) String() string
- type TimeOfDay
- type Weekday
- type WeeklySchedule
- func (*WeeklySchedule) Descriptor() ([]byte, []int)deprecated
- func (x *WeeklySchedule) GetAt() *TimeOfDay
- func (x *WeeklySchedule) GetWeekday() Weekday
- func (*WeeklySchedule) ProtoMessage()
- func (x *WeeklySchedule) ProtoReflect() protoreflect.Message
- func (x *WeeklySchedule) Reset()
- func (x *WeeklySchedule) String() string
Constants ¶
This section is empty.
Variables ¶
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.
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.
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.
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.
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.
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 ValidateJobDefinition ¶
func ValidateJobDefinition(message *JobDefinition) error
ValidateJobDefinition checks this message's annotated fields; it does not recurse. A failed predicate returns *liquidproto.Error. Nil input also returns an error.
func ValidateJobStatus ¶
ValidateJobStatus 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 ¶
ValidateTimeOfDay 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) Descriptor() protoreflect.EnumDescriptor
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 (x CatchUpPolicy) Number() protoreflect.EnumNumber
func (CatchUpPolicy) String ¶
func (x CatchUpPolicy) String() string
func (CatchUpPolicy) Type ¶
func (CatchUpPolicy) Type() protoreflect.EnumType
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) Descriptor() protoreflect.EnumDescriptor
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 ¶
func (CronDialect) Type() protoreflect.EnumType
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 JobStatus.
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"`
JobName string `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_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 job name and scheduled time and is the handler'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) GetJobName ¶
func (x *Invocation) GetJobName() string
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) 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 JobDefinition ¶
type JobDefinition 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
}
JobDefinition is the portable desired job configuration. The executable Go handler is registered locally by name and is deliberately not serializable.
func (*JobDefinition) Descriptor
deprecated
func (*JobDefinition) Descriptor() ([]byte, []int)
Deprecated: Use JobDefinition.ProtoReflect.Descriptor instead.
func (*JobDefinition) GetCatchUpPolicy ¶
func (x *JobDefinition) GetCatchUpPolicy() CatchUpPolicy
func (*JobDefinition) GetName ¶
func (x *JobDefinition) GetName() string
func (*JobDefinition) GetOverlapPolicy ¶
func (x *JobDefinition) GetOverlapPolicy() OverlapPolicy
func (*JobDefinition) GetSchedule ¶
func (x *JobDefinition) GetSchedule() *ScheduleSpec
func (*JobDefinition) ProtoMessage ¶
func (*JobDefinition) ProtoMessage()
func (*JobDefinition) ProtoReflect ¶
func (x *JobDefinition) ProtoReflect() protoreflect.Message
func (*JobDefinition) Reset ¶
func (x *JobDefinition) Reset()
func (*JobDefinition) String ¶
func (x *JobDefinition) String() string
type JobStatus ¶
type JobStatus struct {
Definition *JobDefinition `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
}
JobStatus is a read-only status projection suitable for an authenticated Gin route. PostgreSQL remains relational and is mapped explicitly.
func (*JobStatus) Descriptor
deprecated
func (*JobStatus) GetActiveRuns ¶
func (*JobStatus) GetDefinition ¶
func (x *JobStatus) GetDefinition() *JobDefinition
func (*JobStatus) GetIntervalAnchor ¶
func (x *JobStatus) GetIntervalAnchor() *timestamppb.Timestamp
func (*JobStatus) GetLastRun ¶
func (x *JobStatus) GetLastRun() *RunSummary
func (*JobStatus) GetNextRunAt ¶
func (x *JobStatus) GetNextRunAt() *timestamppb.Timestamp
func (*JobStatus) ProtoMessage ¶
func (*JobStatus) ProtoMessage()
func (*JobStatus) ProtoReflect ¶
func (x *JobStatus) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
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 (x OverlapPolicy) Number() protoreflect.EnumNumber
func (OverlapPolicy) String ¶
func (x OverlapPolicy) String() string
func (OverlapPolicy) Type ¶
func (OverlapPolicy) Type() protoreflect.EnumType
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
func (RunState) Descriptor ¶
func (RunState) Descriptor() protoreflect.EnumDescriptor
func (RunState) EnumDescriptor
deprecated
func (RunState) Number ¶
func (x RunState) Number() protoreflect.EnumNumber
func (RunState) Type ¶
func (RunState) Type() protoreflect.EnumType
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"`
Jobs []*JobStatus `protobuf:"bytes,2,rep,name=jobs,proto3" json:"jobs,omitempty"`
// contains filtered or unexported fields
}
func (*StatusSnapshot) Descriptor
deprecated
func (*StatusSnapshot) Descriptor() ([]byte, []int)
Deprecated: Use StatusSnapshot.ProtoReflect.Descriptor instead.
func (*StatusSnapshot) GetJobs ¶
func (x *StatusSnapshot) GetJobs() []*JobStatus
func (*StatusSnapshot) GetObservedAt ¶
func (x *StatusSnapshot) GetObservedAt() *timestamppb.Timestamp
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) ProtoMessage ¶
func (*TimeOfDay) ProtoMessage()
func (*TimeOfDay) ProtoReflect ¶
func (x *TimeOfDay) ProtoReflect() protoreflect.Message
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) EnumDescriptor
deprecated
func (Weekday) Number ¶
func (x Weekday) Number() protoreflect.EnumNumber
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