schedule

package
v0.15.1 Latest Latest
Warning

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

 Go to latest Published: Jun 1, 2022 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type BackfillRequest 

type BackfillRequest struct {
	// Time range to evaluate schedule in.
	StartTime *time.Time `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	EndTime   *time.Time `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time,omitempty"`
	// Override overlap policy for this request.
	OverlapPolicy v1.ScheduleOverlapPolicy `` /* 150-byte string literal not displayed */
}

func (*BackfillRequest) Descriptor 

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

func (*BackfillRequest) Equal 

func (this *BackfillRequest) Equal(that interface{}) bool

func (*BackfillRequest) GetEndTime 

func (m *BackfillRequest) GetEndTime() *time.Time

func (*BackfillRequest) GetOverlapPolicy 

func (m *BackfillRequest) GetOverlapPolicy() v1.ScheduleOverlapPolicy

func (*BackfillRequest) GetStartTime 

func (m *BackfillRequest) GetStartTime() *time.Time

func (*BackfillRequest) GoString 

func (this *BackfillRequest) GoString() string

func (*BackfillRequest) Marshal 

func (m *BackfillRequest) Marshal() (dAtA []byte, err error)

func (*BackfillRequest) MarshalTo 

func (m *BackfillRequest) MarshalTo(dAtA []byte) (int, error)

func (*BackfillRequest) MarshalToSizedBuffer 

func (m *BackfillRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BackfillRequest) ProtoMessage 

func (*BackfillRequest) ProtoMessage()

func (*BackfillRequest) Reset 

func (m *BackfillRequest) Reset()

func (*BackfillRequest) Size 

func (m *BackfillRequest) Size() (n int)

func (*BackfillRequest) String 

func (this *BackfillRequest) String() string

func (*BackfillRequest) Unmarshal 

func (m *BackfillRequest) Unmarshal(dAtA []byte) error

func (*BackfillRequest) XXX_DiscardUnknown 

func (m *BackfillRequest) XXX_DiscardUnknown()

func (*BackfillRequest) XXX_Marshal 

func (m *BackfillRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackfillRequest) XXX_Merge 

func (m *BackfillRequest) XXX_Merge(src proto.Message)

func (*BackfillRequest) XXX_Size 

func (m *BackfillRequest) XXX_Size() int

func (*BackfillRequest) XXX_Unmarshal 

func (m *BackfillRequest) XXX_Unmarshal(b []byte) error

type CalendarSpec 

type CalendarSpec struct {
	// Expression to match seconds. Default: 0
	Second string `protobuf:"bytes,1,opt,name=second,proto3" json:"second,omitempty"`
	// Expression to match minutes. Default: 0
	Minute string `protobuf:"bytes,2,opt,name=minute,proto3" json:"minute,omitempty"`
	// Expression to match hours. Default: 0
	Hour string `protobuf:"bytes,3,opt,name=hour,proto3" json:"hour,omitempty"`
	// Expression to match days of the month. Default: *
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: standard name of field --)
	DayOfMonth string `protobuf:"bytes,4,opt,name=day_of_month,json=dayOfMonth,proto3" json:"day_of_month,omitempty"`
	// Expression to match months. Default: *
	Month string `protobuf:"bytes,5,opt,name=month,proto3" json:"month,omitempty"`
	// Expression to match years. Default: *
	Year string `protobuf:"bytes,6,opt,name=year,proto3" json:"year,omitempty"`
	// Expression to match days of the week. Default: *
	DayOfWeek string `protobuf:"bytes,7,opt,name=day_of_week,json=dayOfWeek,proto3" json:"day_of_week,omitempty"`
}

CalendarSpec describes an event specification relative to the calendar, similar to a traditional cron specification. Each field can be one of: 

*: matches always
x: matches when the field equals x
x/y : matches when the field equals x+n*y where n is an integer
x-z: matches when the field is between x and z inclusive
w,x,y,...: matches when the field is one of the listed values

Each x, y, z, ... is either a decimal integer, or a month or day of week name or abbreviation (in the appropriate fields). A second in time matches if all fields match. Note that the special case that some cron implementations have for treating day_of_month and day_of_week as "or" instead of "and" when both are set is not implemented. day_of_week can accept 0 or 7 as Sunday TODO: add relative-to-end-of-month TODO: add nth day-of-week in month

func (*CalendarSpec) Descriptor 

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

func (*CalendarSpec) Equal 

func (this *CalendarSpec) Equal(that interface{}) bool

func (*CalendarSpec) GetDayOfMonth 

func (m *CalendarSpec) GetDayOfMonth() string

func (*CalendarSpec) GetDayOfWeek 

func (m *CalendarSpec) GetDayOfWeek() string

func (*CalendarSpec) GetHour 

func (m *CalendarSpec) GetHour() string

func (*CalendarSpec) GetMinute 

func (m *CalendarSpec) GetMinute() string

func (*CalendarSpec) GetMonth 

func (m *CalendarSpec) GetMonth() string

func (*CalendarSpec) GetSecond 

func (m *CalendarSpec) GetSecond() string

func (*CalendarSpec) GetYear 

func (m *CalendarSpec) GetYear() string

func (*CalendarSpec) GoString 

func (this *CalendarSpec) GoString() string

func (*CalendarSpec) Marshal 

func (m *CalendarSpec) Marshal() (dAtA []byte, err error)

func (*CalendarSpec) MarshalTo 

func (m *CalendarSpec) MarshalTo(dAtA []byte) (int, error)

func (*CalendarSpec) MarshalToSizedBuffer 

func (m *CalendarSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CalendarSpec) ProtoMessage 

func (*CalendarSpec) ProtoMessage()

func (*CalendarSpec) Reset 

func (m *CalendarSpec) Reset()

func (*CalendarSpec) Size 

func (m *CalendarSpec) Size() (n int)

func (*CalendarSpec) String 

func (this *CalendarSpec) String() string

func (*CalendarSpec) Unmarshal 

func (m *CalendarSpec) Unmarshal(dAtA []byte) error

func (*CalendarSpec) XXX_DiscardUnknown 

func (m *CalendarSpec) XXX_DiscardUnknown()

func (*CalendarSpec) XXX_Marshal 

func (m *CalendarSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CalendarSpec) XXX_Merge 

func (m *CalendarSpec) XXX_Merge(src proto.Message)

func (*CalendarSpec) XXX_Size 

func (m *CalendarSpec) XXX_Size() int

func (*CalendarSpec) XXX_Unmarshal 

func (m *CalendarSpec) XXX_Unmarshal(b []byte) error

type IntervalSpec 

type IntervalSpec struct {
	Interval *time.Duration `protobuf:"bytes,1,opt,name=interval,proto3,stdduration" json:"interval,omitempty"`
	Phase    *time.Duration `protobuf:"bytes,2,opt,name=phase,proto3,stdduration" json:"phase,omitempty"`
}

IntervalSpec matches times that can be expressed as: epoch + n * interval + phase where n is an integer. phase defaults to zero if missing. interval is required. Both interval and phase must be non-negative and are truncated to the nearest second before any calculations. For example, an interval of 1 hour with phase of zero would match every hour, on the hour. The same interval but a phase of 19 minutes would match every xx:19:00. An interval of 28 days with phase zero would match 2022-02-17T00:00:00Z (among other times). The same interval with a phase of 3 days, 5 hours, and 23 minutes would match 2022-02-20T05:23:00Z instead.

func (*IntervalSpec) Descriptor 

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

func (*IntervalSpec) Equal 

func (this *IntervalSpec) Equal(that interface{}) bool

func (*IntervalSpec) GetInterval 

func (m *IntervalSpec) GetInterval() *time.Duration

func (*IntervalSpec) GetPhase 

func (m *IntervalSpec) GetPhase() *time.Duration

func (*IntervalSpec) GoString 

func (this *IntervalSpec) GoString() string

func (*IntervalSpec) Marshal 

func (m *IntervalSpec) Marshal() (dAtA []byte, err error)

func (*IntervalSpec) MarshalTo 

func (m *IntervalSpec) MarshalTo(dAtA []byte) (int, error)

func (*IntervalSpec) MarshalToSizedBuffer 

func (m *IntervalSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IntervalSpec) ProtoMessage 

func (*IntervalSpec) ProtoMessage()

func (*IntervalSpec) Reset 

func (m *IntervalSpec) Reset()

func (*IntervalSpec) Size 

func (m *IntervalSpec) Size() (n int)

func (*IntervalSpec) String 

func (this *IntervalSpec) String() string

func (*IntervalSpec) Unmarshal 

func (m *IntervalSpec) Unmarshal(dAtA []byte) error

func (*IntervalSpec) XXX_DiscardUnknown 

func (m *IntervalSpec) XXX_DiscardUnknown()

func (*IntervalSpec) XXX_Marshal 

func (m *IntervalSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IntervalSpec) XXX_Merge 

func (m *IntervalSpec) XXX_Merge(src proto.Message)

func (*IntervalSpec) XXX_Size 

func (m *IntervalSpec) XXX_Size() int

func (*IntervalSpec) XXX_Unmarshal 

func (m *IntervalSpec) XXX_Unmarshal(b []byte) error

type Schedule 

type Schedule struct {
	Spec     *ScheduleSpec     `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Action   *ScheduleAction   `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	Policies *SchedulePolicies `protobuf:"bytes,3,opt,name=policies,proto3" json:"policies,omitempty"`
	State    *ScheduleState    `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
}

func (*Schedule) Descriptor 

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

func (*Schedule) Equal 

func (this *Schedule) Equal(that interface{}) bool

func (*Schedule) GetAction 

func (m *Schedule) GetAction() *ScheduleAction

func (*Schedule) GetPolicies 

func (m *Schedule) GetPolicies() *SchedulePolicies

func (*Schedule) GetSpec 

func (m *Schedule) GetSpec() *ScheduleSpec

func (*Schedule) GetState 

func (m *Schedule) GetState() *ScheduleState

func (*Schedule) GoString 

func (this *Schedule) GoString() string

func (*Schedule) Marshal 

func (m *Schedule) Marshal() (dAtA []byte, err error)

func (*Schedule) MarshalTo 

func (m *Schedule) MarshalTo(dAtA []byte) (int, error)

func (*Schedule) MarshalToSizedBuffer 

func (m *Schedule) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Schedule) ProtoMessage 

func (*Schedule) ProtoMessage()

func (*Schedule) Reset 

func (m *Schedule) Reset()

func (*Schedule) Size 

func (m *Schedule) Size() (n int)

func (*Schedule) String 

func (this *Schedule) String() string

func (*Schedule) Unmarshal 

func (m *Schedule) Unmarshal(dAtA []byte) error

func (*Schedule) XXX_DiscardUnknown 

func (m *Schedule) XXX_DiscardUnknown()

func (*Schedule) XXX_Marshal 

func (m *Schedule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Schedule) XXX_Merge 

func (m *Schedule) XXX_Merge(src proto.Message)

func (*Schedule) XXX_Size 

func (m *Schedule) XXX_Size() int

func (*Schedule) XXX_Unmarshal 

func (m *Schedule) XXX_Unmarshal(b []byte) error

type ScheduleAction 

type ScheduleAction struct {
	// Types that are valid to be assigned to Action:
	//	*ScheduleAction_StartWorkflow
	Action isScheduleAction_Action `protobuf_oneof:"action"`
}

func (*ScheduleAction) Descriptor 

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

func (*ScheduleAction) Equal 

func (this *ScheduleAction) Equal(that interface{}) bool

func (*ScheduleAction) GetAction 

func (m *ScheduleAction) GetAction() isScheduleAction_Action

func (*ScheduleAction) GetStartWorkflow 

func (m *ScheduleAction) GetStartWorkflow() *v11.NewWorkflowExecutionInfo

func (*ScheduleAction) GoString 

func (this *ScheduleAction) GoString() string

func (*ScheduleAction) Marshal 

func (m *ScheduleAction) Marshal() (dAtA []byte, err error)

func (*ScheduleAction) MarshalTo 

func (m *ScheduleAction) MarshalTo(dAtA []byte) (int, error)

func (*ScheduleAction) MarshalToSizedBuffer 

func (m *ScheduleAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScheduleAction) ProtoMessage 

func (*ScheduleAction) ProtoMessage()

func (*ScheduleAction) Reset 

func (m *ScheduleAction) Reset()

func (*ScheduleAction) Size 

func (m *ScheduleAction) Size() (n int)

func (*ScheduleAction) String 

func (this *ScheduleAction) String() string

func (*ScheduleAction) Unmarshal 

func (m *ScheduleAction) Unmarshal(dAtA []byte) error

func (*ScheduleAction) XXX_DiscardUnknown 

func (m *ScheduleAction) XXX_DiscardUnknown()

func (*ScheduleAction) XXX_Marshal 

func (m *ScheduleAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScheduleAction) XXX_Merge 

func (m *ScheduleAction) XXX_Merge(src proto.Message)

func (*ScheduleAction) XXX_OneofWrappers 

func (*ScheduleAction) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ScheduleAction) XXX_Size 

func (m *ScheduleAction) XXX_Size() int

func (*ScheduleAction) XXX_Unmarshal 

func (m *ScheduleAction) XXX_Unmarshal(b []byte) error

type ScheduleActionResult 

type ScheduleActionResult struct {
	// Time that the action was taken (according to the schedule, including jitter).
	ScheduleTime *time.Time `protobuf:"bytes,1,opt,name=schedule_time,json=scheduleTime,proto3,stdtime" json:"schedule_time,omitempty"`
	// Time that the action was taken (real time).
	ActualTime *time.Time `protobuf:"bytes,2,opt,name=actual_time,json=actualTime,proto3,stdtime" json:"actual_time,omitempty"`
	// If action was start_workflow:
	StartWorkflowResult *v12.WorkflowExecution `protobuf:"bytes,11,opt,name=start_workflow_result,json=startWorkflowResult,proto3" json:"start_workflow_result,omitempty"`
}

func (*ScheduleActionResult) Descriptor 

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

func (*ScheduleActionResult) Equal 

func (this *ScheduleActionResult) Equal(that interface{}) bool

func (*ScheduleActionResult) GetActualTime 

func (m *ScheduleActionResult) GetActualTime() *time.Time

func (*ScheduleActionResult) GetScheduleTime 

func (m *ScheduleActionResult) GetScheduleTime() *time.Time

func (*ScheduleActionResult) GetStartWorkflowResult 

func (m *ScheduleActionResult) GetStartWorkflowResult() *v12.WorkflowExecution

func (*ScheduleActionResult) GoString 

func (this *ScheduleActionResult) GoString() string

func (*ScheduleActionResult) Marshal 

func (m *ScheduleActionResult) Marshal() (dAtA []byte, err error)

func (*ScheduleActionResult) MarshalTo 

func (m *ScheduleActionResult) MarshalTo(dAtA []byte) (int, error)

func (*ScheduleActionResult) MarshalToSizedBuffer 

func (m *ScheduleActionResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScheduleActionResult) ProtoMessage 

func (*ScheduleActionResult) ProtoMessage()

func (*ScheduleActionResult) Reset 

func (m *ScheduleActionResult) Reset()

func (*ScheduleActionResult) Size 

func (m *ScheduleActionResult) Size() (n int)

func (*ScheduleActionResult) String 

func (this *ScheduleActionResult) String() string

func (*ScheduleActionResult) Unmarshal 

func (m *ScheduleActionResult) Unmarshal(dAtA []byte) error

func (*ScheduleActionResult) XXX_DiscardUnknown 

func (m *ScheduleActionResult) XXX_DiscardUnknown()

func (*ScheduleActionResult) XXX_Marshal 

func (m *ScheduleActionResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScheduleActionResult) XXX_Merge 

func (m *ScheduleActionResult) XXX_Merge(src proto.Message)

func (*ScheduleActionResult) XXX_Size 

func (m *ScheduleActionResult) XXX_Size() int

func (*ScheduleActionResult) XXX_Unmarshal 

func (m *ScheduleActionResult) XXX_Unmarshal(b []byte) error

type ScheduleAction_StartWorkflow 

type ScheduleAction_StartWorkflow struct {
	StartWorkflow *v11.NewWorkflowExecutionInfo `protobuf:"bytes,1,opt,name=start_workflow,json=startWorkflow,proto3,oneof" json:"start_workflow,omitempty"`
}

func (*ScheduleAction_StartWorkflow) Equal 

func (this *ScheduleAction_StartWorkflow) Equal(that interface{}) bool

func (*ScheduleAction_StartWorkflow) GoString 

func (this *ScheduleAction_StartWorkflow) GoString() string

func (*ScheduleAction_StartWorkflow) MarshalTo 

func (m *ScheduleAction_StartWorkflow) MarshalTo(dAtA []byte) (int, error)

func (*ScheduleAction_StartWorkflow) MarshalToSizedBuffer 

func (m *ScheduleAction_StartWorkflow) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScheduleAction_StartWorkflow) Size 

func (m *ScheduleAction_StartWorkflow) Size() (n int)

func (*ScheduleAction_StartWorkflow) String 

func (this *ScheduleAction_StartWorkflow) String() string

type ScheduleInfo 

type ScheduleInfo struct {
	// Number of actions taken so far.
	ActionCount int64 `protobuf:"varint,1,opt,name=action_count,json=actionCount,proto3" json:"action_count,omitempty"`
	// Number of times a scheduled action was skipped due to missing the catchup window.
	MissedCatchupWindow int64 `protobuf:"varint,2,opt,name=missed_catchup_window,json=missedCatchupWindow,proto3" json:"missed_catchup_window,omitempty"`
	// Number of skipped actions due to overlap.
	OverlapSkipped int64 `protobuf:"varint,3,opt,name=overlap_skipped,json=overlapSkipped,proto3" json:"overlap_skipped,omitempty"`
	// Currently-running workflows started by this schedule. (There might be
	// more than one if the overlap policy allows overlaps.)
	// Note that the run_ids in here are the original execution run ids as
	// started by the schedule. If the workflows retried, did continue-as-new,
	// or were reset, they might still be running but with a different run_id.
	RunningWorkflows []*v12.WorkflowExecution `protobuf:"bytes,9,rep,name=running_workflows,json=runningWorkflows,proto3" json:"running_workflows,omitempty"`
	// Most recent ten actual action times (including manual triggers).
	RecentActions []*ScheduleActionResult `protobuf:"bytes,4,rep,name=recent_actions,json=recentActions,proto3" json:"recent_actions,omitempty"`
	// Next ten scheduled action times.
	FutureActionTimes []*time.Time `protobuf:"bytes,5,rep,name=future_action_times,json=futureActionTimes,proto3,stdtime" json:"future_action_times,omitempty"`
	// Timestamps of schedule creation and last update.
	CreateTime *time.Time `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3,stdtime" json:"create_time,omitempty"`
	UpdateTime *time.Time `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3,stdtime" json:"update_time,omitempty"`
	// Error for invalid schedule. If this is set, no actions will be taken.
	InvalidScheduleError string `protobuf:"bytes,8,opt,name=invalid_schedule_error,json=invalidScheduleError,proto3" json:"invalid_schedule_error,omitempty"`
}

func (*ScheduleInfo) Descriptor 

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

func (*ScheduleInfo) Equal 

func (this *ScheduleInfo) Equal(that interface{}) bool

func (*ScheduleInfo) GetActionCount 

func (m *ScheduleInfo) GetActionCount() int64

func (*ScheduleInfo) GetCreateTime 

func (m *ScheduleInfo) GetCreateTime() *time.Time

func (*ScheduleInfo) GetFutureActionTimes 

func (m *ScheduleInfo) GetFutureActionTimes() []*time.Time

func (*ScheduleInfo) GetInvalidScheduleError 

func (m *ScheduleInfo) GetInvalidScheduleError() string

func (*ScheduleInfo) GetMissedCatchupWindow 

func (m *ScheduleInfo) GetMissedCatchupWindow() int64

func (*ScheduleInfo) GetOverlapSkipped 

func (m *ScheduleInfo) GetOverlapSkipped() int64

func (*ScheduleInfo) GetRecentActions 

func (m *ScheduleInfo) GetRecentActions() []*ScheduleActionResult

func (*ScheduleInfo) GetRunningWorkflows 

func (m *ScheduleInfo) GetRunningWorkflows() []*v12.WorkflowExecution

func (*ScheduleInfo) GetUpdateTime 

func (m *ScheduleInfo) GetUpdateTime() *time.Time

func (*ScheduleInfo) GoString 

func (this *ScheduleInfo) GoString() string

func (*ScheduleInfo) Marshal 

func (m *ScheduleInfo) Marshal() (dAtA []byte, err error)

func (*ScheduleInfo) MarshalTo 

func (m *ScheduleInfo) MarshalTo(dAtA []byte) (int, error)

func (*ScheduleInfo) MarshalToSizedBuffer 

func (m *ScheduleInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScheduleInfo) ProtoMessage 

func (*ScheduleInfo) ProtoMessage()

func (*ScheduleInfo) Reset 

func (m *ScheduleInfo) Reset()

func (*ScheduleInfo) Size 

func (m *ScheduleInfo) Size() (n int)

func (*ScheduleInfo) String 

func (this *ScheduleInfo) String() string

func (*ScheduleInfo) Unmarshal 

func (m *ScheduleInfo) Unmarshal(dAtA []byte) error

func (*ScheduleInfo) XXX_DiscardUnknown 

func (m *ScheduleInfo) XXX_DiscardUnknown()

func (*ScheduleInfo) XXX_Marshal 

func (m *ScheduleInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScheduleInfo) XXX_Merge 

func (m *ScheduleInfo) XXX_Merge(src proto.Message)

func (*ScheduleInfo) XXX_Size 

func (m *ScheduleInfo) XXX_Size() int

func (*ScheduleInfo) XXX_Unmarshal 

func (m *ScheduleInfo) XXX_Unmarshal(b []byte) error

type ScheduleListEntry 

type ScheduleListEntry struct {
	ScheduleId       string                `protobuf:"bytes,1,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	Memo             *v12.Memo             `protobuf:"bytes,2,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v12.SearchAttributes `protobuf:"bytes,3,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
}

ScheduleListEntry is returned by ListSchedules.

func (*ScheduleListEntry) Descriptor 

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

func (*ScheduleListEntry) Equal 

func (this *ScheduleListEntry) Equal(that interface{}) bool

func (*ScheduleListEntry) GetMemo 

func (m *ScheduleListEntry) GetMemo() *v12.Memo

func (*ScheduleListEntry) GetScheduleId 

func (m *ScheduleListEntry) GetScheduleId() string

func (*ScheduleListEntry) GetSearchAttributes 

func (m *ScheduleListEntry) GetSearchAttributes() *v12.SearchAttributes

func (*ScheduleListEntry) GoString 

func (this *ScheduleListEntry) GoString() string

func (*ScheduleListEntry) Marshal 

func (m *ScheduleListEntry) Marshal() (dAtA []byte, err error)

func (*ScheduleListEntry) MarshalTo 

func (m *ScheduleListEntry) MarshalTo(dAtA []byte) (int, error)

func (*ScheduleListEntry) MarshalToSizedBuffer 

func (m *ScheduleListEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScheduleListEntry) ProtoMessage 

func (*ScheduleListEntry) ProtoMessage()

func (*ScheduleListEntry) Reset 

func (m *ScheduleListEntry) Reset()

func (*ScheduleListEntry) Size 

func (m *ScheduleListEntry) Size() (n int)

func (*ScheduleListEntry) String 

func (this *ScheduleListEntry) String() string

func (*ScheduleListEntry) Unmarshal 

func (m *ScheduleListEntry) Unmarshal(dAtA []byte) error

func (*ScheduleListEntry) XXX_DiscardUnknown 

func (m *ScheduleListEntry) XXX_DiscardUnknown()

func (*ScheduleListEntry) XXX_Marshal 

func (m *ScheduleListEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScheduleListEntry) XXX_Merge 

func (m *ScheduleListEntry) XXX_Merge(src proto.Message)

func (*ScheduleListEntry) XXX_Size 

func (m *ScheduleListEntry) XXX_Size() int

func (*ScheduleListEntry) XXX_Unmarshal 

func (m *ScheduleListEntry) XXX_Unmarshal(b []byte) error

type SchedulePatch 

type SchedulePatch struct {
	// If set, trigger one action immediately.
	TriggerImmediately *TriggerImmediatelyRequest `protobuf:"bytes,1,opt,name=trigger_immediately,json=triggerImmediately,proto3" json:"trigger_immediately,omitempty"`
	// If set, runs though the specified time period(s) and takes actions as if that time
	// passed by right now, all at once. The overlap policy can be overridden for the
	// scope of the backfill.
	BackfillRequest []*BackfillRequest `protobuf:"bytes,2,rep,name=backfill_request,json=backfillRequest,proto3" json:"backfill_request,omitempty"`
	// If set, change the state to paused or unpaused (respectively) and set the
	// notes field to the value of the string.
	Pause   string `protobuf:"bytes,3,opt,name=pause,proto3" json:"pause,omitempty"`
	Unpause string `protobuf:"bytes,4,opt,name=unpause,proto3" json:"unpause,omitempty"`
}

func (*SchedulePatch) Descriptor 

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

func (*SchedulePatch) Equal 

func (this *SchedulePatch) Equal(that interface{}) bool

func (*SchedulePatch) GetBackfillRequest 

func (m *SchedulePatch) GetBackfillRequest() []*BackfillRequest

func (*SchedulePatch) GetPause 

func (m *SchedulePatch) GetPause() string

func (*SchedulePatch) GetTriggerImmediately 

func (m *SchedulePatch) GetTriggerImmediately() *TriggerImmediatelyRequest

func (*SchedulePatch) GetUnpause 

func (m *SchedulePatch) GetUnpause() string

func (*SchedulePatch) GoString 

func (this *SchedulePatch) GoString() string

func (*SchedulePatch) Marshal 

func (m *SchedulePatch) Marshal() (dAtA []byte, err error)

func (*SchedulePatch) MarshalTo 

func (m *SchedulePatch) MarshalTo(dAtA []byte) (int, error)

func (*SchedulePatch) MarshalToSizedBuffer 

func (m *SchedulePatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SchedulePatch) ProtoMessage 

func (*SchedulePatch) ProtoMessage()

func (*SchedulePatch) Reset 

func (m *SchedulePatch) Reset()

func (*SchedulePatch) Size 

func (m *SchedulePatch) Size() (n int)

func (*SchedulePatch) String 

func (this *SchedulePatch) String() string

func (*SchedulePatch) Unmarshal 

func (m *SchedulePatch) Unmarshal(dAtA []byte) error

func (*SchedulePatch) XXX_DiscardUnknown 

func (m *SchedulePatch) XXX_DiscardUnknown()

func (*SchedulePatch) XXX_Marshal 

func (m *SchedulePatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulePatch) XXX_Merge 

func (m *SchedulePatch) XXX_Merge(src proto.Message)

func (*SchedulePatch) XXX_Size 

func (m *SchedulePatch) XXX_Size() int

func (*SchedulePatch) XXX_Unmarshal 

func (m *SchedulePatch) XXX_Unmarshal(b []byte) error

type SchedulePolicies 

type SchedulePolicies struct {
	// Policy for overlaps.
	// Note that this can be changed after a schedule has taken some actions, and we can't
	// provide 100% sensible semantics for all changes. The most confusing case would be
	// changes to/from ALLOW_ALL: with that policy multiple scheduled workflows can run
	// concurrently, but for all other policies only one can run at a time. Changing
	// between these two classes will leave all workflows with the other class alone.
	// E.g., if changing from ALLOW_ALL to CANCEL_OTHER, and there are workflows running,
	// those workflows will not be cancelled. If changing from ALLOW_ALL to SKIP with
	// workflows running, the running workflows will not cause the next action to be
	// skipped.
	OverlapPolicy v1.ScheduleOverlapPolicy `` /* 150-byte string literal not displayed */
	// Policy for catchups:
	// If the Temporal server misses an action due to one or more components
	// being down, and comes back up, the action will be run if the scheduled
	// time is within this window from the current time.
	// This value defaults to 60 seconds, and can't be less than 10 seconds.
	CatchupWindow *time.Duration `protobuf:"bytes,2,opt,name=catchup_window,json=catchupWindow,proto3,stdduration" json:"catchup_window,omitempty"`
	// If true, and a workflow run fails or times out, turn on "paused".
	// This applies after retry policies: the full chain of retries must fail to
	// trigger a pause here.
	PauseOnFailure bool `protobuf:"varint,3,opt,name=pause_on_failure,json=pauseOnFailure,proto3" json:"pause_on_failure,omitempty"`
}

func (*SchedulePolicies) Descriptor 

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

func (*SchedulePolicies) Equal 

func (this *SchedulePolicies) Equal(that interface{}) bool

func (*SchedulePolicies) GetCatchupWindow 

func (m *SchedulePolicies) GetCatchupWindow() *time.Duration

func (*SchedulePolicies) GetOverlapPolicy 

func (m *SchedulePolicies) GetOverlapPolicy() v1.ScheduleOverlapPolicy

func (*SchedulePolicies) GetPauseOnFailure 

func (m *SchedulePolicies) GetPauseOnFailure() bool

func (*SchedulePolicies) GoString 

func (this *SchedulePolicies) GoString() string

func (*SchedulePolicies) Marshal 

func (m *SchedulePolicies) Marshal() (dAtA []byte, err error)

func (*SchedulePolicies) MarshalTo 

func (m *SchedulePolicies) MarshalTo(dAtA []byte) (int, error)

func (*SchedulePolicies) MarshalToSizedBuffer 

func (m *SchedulePolicies) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SchedulePolicies) ProtoMessage 

func (*SchedulePolicies) ProtoMessage()

func (*SchedulePolicies) Reset 

func (m *SchedulePolicies) Reset()

func (*SchedulePolicies) Size 

func (m *SchedulePolicies) Size() (n int)

func (*SchedulePolicies) String 

func (this *SchedulePolicies) String() string

func (*SchedulePolicies) Unmarshal 

func (m *SchedulePolicies) Unmarshal(dAtA []byte) error

func (*SchedulePolicies) XXX_DiscardUnknown 

func (m *SchedulePolicies) XXX_DiscardUnknown()

func (*SchedulePolicies) XXX_Marshal 

func (m *SchedulePolicies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulePolicies) XXX_Merge 

func (m *SchedulePolicies) XXX_Merge(src proto.Message)

func (*SchedulePolicies) XXX_Size 

func (m *SchedulePolicies) XXX_Size() int

func (*SchedulePolicies) XXX_Unmarshal 

func (m *SchedulePolicies) XXX_Unmarshal(b []byte) error

type ScheduleSpec 

type ScheduleSpec struct {
	// Calendar-based specifications of times.
	Calendar []*CalendarSpec `protobuf:"bytes,1,rep,name=calendar,proto3" json:"calendar,omitempty"`
	// Interval-based specifications of times.
	Interval []*IntervalSpec `protobuf:"bytes,2,rep,name=interval,proto3" json:"interval,omitempty"`
	// Any timestamps matching any of the exclude_calendar specs will be
	// skipped.
	ExcludeCalendar []*CalendarSpec `protobuf:"bytes,3,rep,name=exclude_calendar,json=excludeCalendar,proto3" json:"exclude_calendar,omitempty"`
	// Any timestamps before start_time will be skipped. Together, start_time
	// and end_time make an inclusive interval.
	StartTime *time.Time `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	// Any timestamps after end_time will be skipped.
	EndTime *time.Time `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time,omitempty"`
	// All timestamps will be incremented by a random value from 0 to this
	// amount of jitter. Default: 1 second
	Jitter *time.Duration `protobuf:"bytes,6,opt,name=jitter,proto3,stdduration" json:"jitter,omitempty"`
	// Time zone to interpret all CalendarSpecs in.
	//
	// If unset, defaults to UTC. We recommend using UTC for your application if
	// at all possible, to avoid various surprising properties of time zones.
	//
	// Time zones may be provided by name, corresponding to names in the IANA
	// time zone database (see https://www.iana.org/time-zones). The definition
	// will be loaded by the Temporal server from the environment it runs in.
	//
	// If your application requires more control over the time zone definition
	// used, it may pass in a complete definition in the form of a TZif file
	// from the time zone database. If present, this will be used instead of
	// loading anything from the environment. You are then responsible for
	// updating timezone_data when the definition changes.
	//
	// Calendar spec matching is based on literal matching of the clock time
	// with no special handling of DST: if you write a calendar spec that fires
	// at 2:30am and specify a time zone that follows DST, that action will not
	// be triggered on the day that has no 2:30am. Similarly, an action that
	// fires at 1:30am will be triggered twice on the day that has two 1:30s.
	TimezoneName string `protobuf:"bytes,10,opt,name=timezone_name,json=timezoneName,proto3" json:"timezone_name,omitempty"`
	TimezoneData []byte `protobuf:"bytes,11,opt,name=timezone_data,json=timezoneData,proto3" json:"timezone_data,omitempty"`
}

ScheduleSpec is a complete description of a set of absolute timestamps (possibly infinite) that an action should occur at. The meaning of a ScheduleSpec depends only on its contents and never changes, except that the definition of a time zone can change over time (most commonly, when daylight saving time policy changes for an area). To create a totally self-contained ScheduleSpec, use UTC or include timezone_data.

func (*ScheduleSpec) Descriptor 

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

func (*ScheduleSpec) Equal 

func (this *ScheduleSpec) Equal(that interface{}) bool

func (*ScheduleSpec) GetCalendar 

func (m *ScheduleSpec) GetCalendar() []*CalendarSpec

func (*ScheduleSpec) GetEndTime 

func (m *ScheduleSpec) GetEndTime() *time.Time

func (*ScheduleSpec) GetExcludeCalendar 

func (m *ScheduleSpec) GetExcludeCalendar() []*CalendarSpec

func (*ScheduleSpec) GetInterval 

func (m *ScheduleSpec) GetInterval() []*IntervalSpec

func (*ScheduleSpec) GetJitter 

func (m *ScheduleSpec) GetJitter() *time.Duration

func (*ScheduleSpec) GetStartTime 

func (m *ScheduleSpec) GetStartTime() *time.Time

func (*ScheduleSpec) GetTimezoneData 

func (m *ScheduleSpec) GetTimezoneData() []byte

func (*ScheduleSpec) GetTimezoneName 

func (m *ScheduleSpec) GetTimezoneName() string

func (*ScheduleSpec) GoString 

func (this *ScheduleSpec) GoString() string

func (*ScheduleSpec) Marshal 

func (m *ScheduleSpec) Marshal() (dAtA []byte, err error)

func (*ScheduleSpec) MarshalTo 

func (m *ScheduleSpec) MarshalTo(dAtA []byte) (int, error)

func (*ScheduleSpec) MarshalToSizedBuffer 

func (m *ScheduleSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScheduleSpec) ProtoMessage 

func (*ScheduleSpec) ProtoMessage()

func (*ScheduleSpec) Reset 

func (m *ScheduleSpec) Reset()

func (*ScheduleSpec) Size 

func (m *ScheduleSpec) Size() (n int)

func (*ScheduleSpec) String 

func (this *ScheduleSpec) String() string

func (*ScheduleSpec) Unmarshal 

func (m *ScheduleSpec) Unmarshal(dAtA []byte) error

func (*ScheduleSpec) XXX_DiscardUnknown 

func (m *ScheduleSpec) XXX_DiscardUnknown()

func (*ScheduleSpec) XXX_Marshal 

func (m *ScheduleSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScheduleSpec) XXX_Merge 

func (m *ScheduleSpec) XXX_Merge(src proto.Message)

func (*ScheduleSpec) XXX_Size 

func (m *ScheduleSpec) XXX_Size() int

func (*ScheduleSpec) XXX_Unmarshal 

func (m *ScheduleSpec) XXX_Unmarshal(b []byte) error

type ScheduleState 

type ScheduleState struct {
	// Informative human-readable message with contextual notes, e.g. the reason
	// a schedule is paused. The system may overwrite this message on certain
	// conditions, e.g. when pause-on-failure happens.
	Notes string `protobuf:"bytes,1,opt,name=notes,proto3" json:"notes,omitempty"`
	// If true, do not take any actions based on the schedule spec.
	Paused bool `protobuf:"varint,2,opt,name=paused,proto3" json:"paused,omitempty"`
	// If limited_actions is true, decrement remaining_actions after each action, and do
	// not take any more scheduled actions if remaining_actions is zero. Actions may still
	// be taken by explicit request. Skipped actions (due to overlap policy) do not count
	// against remaining actions.
	LimitedActions   bool  `protobuf:"varint,3,opt,name=limited_actions,json=limitedActions,proto3" json:"limited_actions,omitempty"`
	RemainingActions int64 `protobuf:"varint,4,opt,name=remaining_actions,json=remainingActions,proto3" json:"remaining_actions,omitempty"`
}

func (*ScheduleState) Descriptor 

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

func (*ScheduleState) Equal 

func (this *ScheduleState) Equal(that interface{}) bool

func (*ScheduleState) GetLimitedActions 

func (m *ScheduleState) GetLimitedActions() bool

func (*ScheduleState) GetNotes 

func (m *ScheduleState) GetNotes() string

func (*ScheduleState) GetPaused 

func (m *ScheduleState) GetPaused() bool

func (*ScheduleState) GetRemainingActions 

func (m *ScheduleState) GetRemainingActions() int64

func (*ScheduleState) GoString 

func (this *ScheduleState) GoString() string

func (*ScheduleState) Marshal 

func (m *ScheduleState) Marshal() (dAtA []byte, err error)

func (*ScheduleState) MarshalTo 

func (m *ScheduleState) MarshalTo(dAtA []byte) (int, error)

func (*ScheduleState) MarshalToSizedBuffer 

func (m *ScheduleState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScheduleState) ProtoMessage 

func (*ScheduleState) ProtoMessage()

func (*ScheduleState) Reset 

func (m *ScheduleState) Reset()

func (*ScheduleState) Size 

func (m *ScheduleState) Size() (n int)

func (*ScheduleState) String 

func (this *ScheduleState) String() string

func (*ScheduleState) Unmarshal 

func (m *ScheduleState) Unmarshal(dAtA []byte) error

func (*ScheduleState) XXX_DiscardUnknown 

func (m *ScheduleState) XXX_DiscardUnknown()

func (*ScheduleState) XXX_Marshal 

func (m *ScheduleState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScheduleState) XXX_Merge 

func (m *ScheduleState) XXX_Merge(src proto.Message)

func (*ScheduleState) XXX_Size 

func (m *ScheduleState) XXX_Size() int

func (*ScheduleState) XXX_Unmarshal 

func (m *ScheduleState) XXX_Unmarshal(b []byte) error

type TriggerImmediatelyRequest 

type TriggerImmediatelyRequest struct {
	// Override overlap policy for this one request.
	OverlapPolicy v1.ScheduleOverlapPolicy `` /* 150-byte string literal not displayed */
}

func (*TriggerImmediatelyRequest) Descriptor 

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

func (*TriggerImmediatelyRequest) Equal 

func (this *TriggerImmediatelyRequest) Equal(that interface{}) bool

func (*TriggerImmediatelyRequest) GetOverlapPolicy 

func (m *TriggerImmediatelyRequest) GetOverlapPolicy() v1.ScheduleOverlapPolicy

func (*TriggerImmediatelyRequest) GoString 

func (this *TriggerImmediatelyRequest) GoString() string

func (*TriggerImmediatelyRequest) Marshal 

func (m *TriggerImmediatelyRequest) Marshal() (dAtA []byte, err error)

func (*TriggerImmediatelyRequest) MarshalTo 

func (m *TriggerImmediatelyRequest) MarshalTo(dAtA []byte) (int, error)

func (*TriggerImmediatelyRequest) MarshalToSizedBuffer 

func (m *TriggerImmediatelyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TriggerImmediatelyRequest) ProtoMessage 

func (*TriggerImmediatelyRequest) ProtoMessage()

func (*TriggerImmediatelyRequest) Reset 

func (m *TriggerImmediatelyRequest) Reset()

func (*TriggerImmediatelyRequest) Size 

func (m *TriggerImmediatelyRequest) Size() (n int)

func (*TriggerImmediatelyRequest) String 

func (this *TriggerImmediatelyRequest) String() string

func (*TriggerImmediatelyRequest) Unmarshal 

func (m *TriggerImmediatelyRequest) Unmarshal(dAtA []byte) error

func (*TriggerImmediatelyRequest) XXX_DiscardUnknown 

func (m *TriggerImmediatelyRequest) XXX_DiscardUnknown()

func (*TriggerImmediatelyRequest) XXX_Marshal 

func (m *TriggerImmediatelyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TriggerImmediatelyRequest) XXX_Merge 

func (m *TriggerImmediatelyRequest) XXX_Merge(src proto.Message)

func (*TriggerImmediatelyRequest) XXX_Size 

func (m *TriggerImmediatelyRequest) XXX_Size() int

func (*TriggerImmediatelyRequest) XXX_Unmarshal 

func (m *TriggerImmediatelyRequest) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.