cronv1

package
v0.1.3 Latest Latest
Warning

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

Go to latest
Published: Oct 1, 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 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

func ValidateJobStatus(message *JobStatus) error

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

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.

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 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) Descriptor() ([]byte, []int)

Deprecated: Use JobStatus.ProtoReflect.Descriptor instead.

func (*JobStatus) GetActiveRuns

func (x *JobStatus) GetActiveRuns() uint32

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

func (*JobStatus) Reset

func (x *JobStatus) Reset()

func (*JobStatus) String

func (x *JobStatus) 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"`
	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) 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 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