schedule

package
v1.20.4 Latest Latest
Warning

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

 Go to latest Published: Jul 13, 2023 License: MIT Imports: 15 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 BufferedStart 

type BufferedStart struct {
	// Nominal (pre-jitter) and Actual (post-jitter) time of action
	NominalTime *time.Time `protobuf:"bytes,1,opt,name=nominal_time,json=nominalTime,proto3,stdtime" json:"nominal_time,omitempty"`
	ActualTime  *time.Time `protobuf:"bytes,2,opt,name=actual_time,json=actualTime,proto3,stdtime" json:"actual_time,omitempty"`
	// Overridden overlap policy
	OverlapPolicy v1.ScheduleOverlapPolicy `` /* 150-byte string literal not displayed */
	// Trigger-immediately or backfill
	Manual bool `protobuf:"varint,4,opt,name=manual,proto3" json:"manual,omitempty"`
}

func (*BufferedStart) Descriptor 

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

func (*BufferedStart) Equal 

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

func (*BufferedStart) GetActualTime 

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

func (*BufferedStart) GetManual 

func (m *BufferedStart) GetManual() bool

func (*BufferedStart) GetNominalTime 

func (m *BufferedStart) GetNominalTime() *time.Time

func (*BufferedStart) GetOverlapPolicy 

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

func (*BufferedStart) GoString 

func (this *BufferedStart) GoString() string

func (*BufferedStart) Marshal 

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

func (*BufferedStart) MarshalTo 

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

func (*BufferedStart) MarshalToSizedBuffer 

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

func (*BufferedStart) ProtoMessage 

func (*BufferedStart) ProtoMessage()

func (*BufferedStart) Reset 

func (m *BufferedStart) Reset()

func (*BufferedStart) Size 

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

func (*BufferedStart) String 

func (this *BufferedStart) String() string

func (*BufferedStart) Unmarshal 

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

func (*BufferedStart) XXX_DiscardUnknown 

func (m *BufferedStart) XXX_DiscardUnknown()

func (*BufferedStart) XXX_Marshal 

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

func (*BufferedStart) XXX_Merge 

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

func (*BufferedStart) XXX_Size 

func (m *BufferedStart) XXX_Size() int

func (*BufferedStart) XXX_Unmarshal 

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

type CancelWorkflowRequest 

type CancelWorkflowRequest struct {
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Identity  string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	// Note: run id in execution is first execution run id
	Execution *v11.WorkflowExecution `protobuf:"bytes,5,opt,name=execution,proto3" json:"execution,omitempty"`
	Reason    string                 `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
}

func (*CancelWorkflowRequest) Descriptor 

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

func (*CancelWorkflowRequest) Equal 

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

func (*CancelWorkflowRequest) GetExecution 

func (m *CancelWorkflowRequest) GetExecution() *v11.WorkflowExecution

func (*CancelWorkflowRequest) GetIdentity 

func (m *CancelWorkflowRequest) GetIdentity() string

func (*CancelWorkflowRequest) GetReason 

func (m *CancelWorkflowRequest) GetReason() string

func (*CancelWorkflowRequest) GetRequestId 

func (m *CancelWorkflowRequest) GetRequestId() string

func (*CancelWorkflowRequest) GoString 

func (this *CancelWorkflowRequest) GoString() string

func (*CancelWorkflowRequest) Marshal 

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

func (*CancelWorkflowRequest) MarshalTo 

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

func (*CancelWorkflowRequest) MarshalToSizedBuffer 

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

func (*CancelWorkflowRequest) ProtoMessage 

func (*CancelWorkflowRequest) ProtoMessage()

func (*CancelWorkflowRequest) Reset 

func (m *CancelWorkflowRequest) Reset()

func (*CancelWorkflowRequest) Size 

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

func (*CancelWorkflowRequest) String 

func (this *CancelWorkflowRequest) String() string

func (*CancelWorkflowRequest) Unmarshal 

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

func (*CancelWorkflowRequest) XXX_DiscardUnknown 

func (m *CancelWorkflowRequest) XXX_DiscardUnknown()

func (*CancelWorkflowRequest) XXX_Marshal 

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

func (*CancelWorkflowRequest) XXX_Merge 

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

func (*CancelWorkflowRequest) XXX_Size 

func (m *CancelWorkflowRequest) XXX_Size() int

func (*CancelWorkflowRequest) XXX_Unmarshal 

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

type DescribeResponse 

type DescribeResponse struct {
	Schedule      *v13.Schedule     `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Info          *v13.ScheduleInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	ConflictToken int64             `protobuf:"varint,3,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
}

func (*DescribeResponse) Descriptor 

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

func (*DescribeResponse) Equal 

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

func (*DescribeResponse) GetConflictToken 

func (m *DescribeResponse) GetConflictToken() int64

func (*DescribeResponse) GetInfo 

func (m *DescribeResponse) GetInfo() *v13.ScheduleInfo

func (*DescribeResponse) GetSchedule 

func (m *DescribeResponse) GetSchedule() *v13.Schedule

func (*DescribeResponse) GoString 

func (this *DescribeResponse) GoString() string

func (*DescribeResponse) Marshal 

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

func (*DescribeResponse) MarshalTo 

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

func (*DescribeResponse) MarshalToSizedBuffer 

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

func (*DescribeResponse) ProtoMessage 

func (*DescribeResponse) ProtoMessage()

func (*DescribeResponse) Reset 

func (m *DescribeResponse) Reset()

func (*DescribeResponse) Size 

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

func (*DescribeResponse) String 

func (this *DescribeResponse) String() string

func (*DescribeResponse) Unmarshal 

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

func (*DescribeResponse) XXX_DiscardUnknown 

func (m *DescribeResponse) XXX_DiscardUnknown()

func (*DescribeResponse) XXX_Marshal 

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

func (*DescribeResponse) XXX_Merge 

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

func (*DescribeResponse) XXX_Size 

func (m *DescribeResponse) XXX_Size() int

func (*DescribeResponse) XXX_Unmarshal 

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

type FullUpdateRequest 

type FullUpdateRequest struct {
	Schedule      *v13.Schedule `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	ConflictToken int64         `protobuf:"varint,2,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
}

func (*FullUpdateRequest) Descriptor 

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

func (*FullUpdateRequest) Equal 

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

func (*FullUpdateRequest) GetConflictToken 

func (m *FullUpdateRequest) GetConflictToken() int64

func (*FullUpdateRequest) GetSchedule 

func (m *FullUpdateRequest) GetSchedule() *v13.Schedule

func (*FullUpdateRequest) GoString 

func (this *FullUpdateRequest) GoString() string

func (*FullUpdateRequest) Marshal 

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

func (*FullUpdateRequest) MarshalTo 

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

func (*FullUpdateRequest) MarshalToSizedBuffer 

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

func (*FullUpdateRequest) ProtoMessage 

func (*FullUpdateRequest) ProtoMessage()

func (*FullUpdateRequest) Reset 

func (m *FullUpdateRequest) Reset()

func (*FullUpdateRequest) Size 

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

func (*FullUpdateRequest) String 

func (this *FullUpdateRequest) String() string

func (*FullUpdateRequest) Unmarshal 

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

func (*FullUpdateRequest) XXX_DiscardUnknown 

func (m *FullUpdateRequest) XXX_DiscardUnknown()

func (*FullUpdateRequest) XXX_Marshal 

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

func (*FullUpdateRequest) XXX_Merge 

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

func (*FullUpdateRequest) XXX_Size 

func (m *FullUpdateRequest) XXX_Size() int

func (*FullUpdateRequest) XXX_Unmarshal 

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

type InternalState 

type InternalState struct {
	Namespace   string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	NamespaceId string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// this is just the workflow id of the scheduler, but accessing that from the workflow is
	// currently not available during replay, so we just pass it in here.
	ScheduleId        string           `protobuf:"bytes,8,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	LastProcessedTime *time.Time       `protobuf:"bytes,3,opt,name=last_processed_time,json=lastProcessedTime,proto3,stdtime" json:"last_processed_time,omitempty"`
	BufferedStarts    []*BufferedStart `protobuf:"bytes,4,rep,name=buffered_starts,json=bufferedStarts,proto3" json:"buffered_starts,omitempty"`
	// last completion/failure
	LastCompletionResult *v11.Payloads `protobuf:"bytes,5,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"`
	ContinuedFailure     *v12.Failure  `protobuf:"bytes,6,opt,name=continued_failure,json=continuedFailure,proto3" json:"continued_failure,omitempty"`
	// conflict token is implemented as simple sequence number
	ConflictToken int64 `protobuf:"varint,7,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	NeedRefresh   bool  `protobuf:"varint,9,opt,name=need_refresh,json=needRefresh,proto3" json:"need_refresh,omitempty"`
}

func (*InternalState) Descriptor 

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

func (*InternalState) Equal 

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

func (*InternalState) GetBufferedStarts 

func (m *InternalState) GetBufferedStarts() []*BufferedStart

func (*InternalState) GetConflictToken 

func (m *InternalState) GetConflictToken() int64

func (*InternalState) GetContinuedFailure 

func (m *InternalState) GetContinuedFailure() *v12.Failure

func (*InternalState) GetLastCompletionResult 

func (m *InternalState) GetLastCompletionResult() *v11.Payloads

func (*InternalState) GetLastProcessedTime 

func (m *InternalState) GetLastProcessedTime() *time.Time

func (*InternalState) GetNamespace 

func (m *InternalState) GetNamespace() string

func (*InternalState) GetNamespaceId 

func (m *InternalState) GetNamespaceId() string

func (*InternalState) GetNeedRefresh added in v1.17.3 

func (m *InternalState) GetNeedRefresh() bool

func (*InternalState) GetScheduleId 

func (m *InternalState) GetScheduleId() string

func (*InternalState) GoString 

func (this *InternalState) GoString() string

func (*InternalState) Marshal 

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

func (*InternalState) MarshalTo 

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

func (*InternalState) MarshalToSizedBuffer 

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

func (*InternalState) ProtoMessage 

func (*InternalState) ProtoMessage()

func (*InternalState) Reset 

func (m *InternalState) Reset()

func (*InternalState) Size 

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

func (*InternalState) String 

func (this *InternalState) String() string

func (*InternalState) Unmarshal 

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

func (*InternalState) XXX_DiscardUnknown 

func (m *InternalState) XXX_DiscardUnknown()

func (*InternalState) XXX_Marshal 

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

func (*InternalState) XXX_Merge 

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

func (*InternalState) XXX_Size 

func (m *InternalState) XXX_Size() int

func (*InternalState) XXX_Unmarshal 

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

type StartScheduleArgs 

type StartScheduleArgs struct {
	Schedule     *v13.Schedule      `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Info         *v13.ScheduleInfo  `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	InitialPatch *v13.SchedulePatch `protobuf:"bytes,3,opt,name=initial_patch,json=initialPatch,proto3" json:"initial_patch,omitempty"`
	State        *InternalState     `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
}

func (*StartScheduleArgs) Descriptor 

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

func (*StartScheduleArgs) Equal 

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

func (*StartScheduleArgs) GetInfo 

func (m *StartScheduleArgs) GetInfo() *v13.ScheduleInfo

func (*StartScheduleArgs) GetInitialPatch 

func (m *StartScheduleArgs) GetInitialPatch() *v13.SchedulePatch

func (*StartScheduleArgs) GetSchedule 

func (m *StartScheduleArgs) GetSchedule() *v13.Schedule

func (*StartScheduleArgs) GetState 

func (m *StartScheduleArgs) GetState() *InternalState

func (*StartScheduleArgs) GoString 

func (this *StartScheduleArgs) GoString() string

func (*StartScheduleArgs) Marshal 

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

func (*StartScheduleArgs) MarshalTo 

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

func (*StartScheduleArgs) MarshalToSizedBuffer 

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

func (*StartScheduleArgs) ProtoMessage 

func (*StartScheduleArgs) ProtoMessage()

func (*StartScheduleArgs) Reset 

func (m *StartScheduleArgs) Reset()

func (*StartScheduleArgs) Size 

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

func (*StartScheduleArgs) String 

func (this *StartScheduleArgs) String() string

func (*StartScheduleArgs) Unmarshal 

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

func (*StartScheduleArgs) XXX_DiscardUnknown 

func (m *StartScheduleArgs) XXX_DiscardUnknown()

func (*StartScheduleArgs) XXX_Marshal 

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

func (*StartScheduleArgs) XXX_Merge 

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

func (*StartScheduleArgs) XXX_Size 

func (m *StartScheduleArgs) XXX_Size() int

func (*StartScheduleArgs) XXX_Unmarshal 

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

type StartWorkflowRequest 

type StartWorkflowRequest struct {
	Request                 *v14.StartWorkflowExecutionRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	CompletedRateLimitSleep bool                               `` /* 135-byte string literal not displayed */
}

func (*StartWorkflowRequest) Descriptor 

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

func (*StartWorkflowRequest) Equal 

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

func (*StartWorkflowRequest) GetCompletedRateLimitSleep added in v1.20.0 

func (m *StartWorkflowRequest) GetCompletedRateLimitSleep() bool

func (*StartWorkflowRequest) GetRequest 

func (m *StartWorkflowRequest) GetRequest() *v14.StartWorkflowExecutionRequest

func (*StartWorkflowRequest) GoString 

func (this *StartWorkflowRequest) GoString() string

func (*StartWorkflowRequest) Marshal 

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

func (*StartWorkflowRequest) MarshalTo 

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

func (*StartWorkflowRequest) MarshalToSizedBuffer 

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

func (*StartWorkflowRequest) ProtoMessage 

func (*StartWorkflowRequest) ProtoMessage()

func (*StartWorkflowRequest) Reset 

func (m *StartWorkflowRequest) Reset()

func (*StartWorkflowRequest) Size 

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

func (*StartWorkflowRequest) String 

func (this *StartWorkflowRequest) String() string

func (*StartWorkflowRequest) Unmarshal 

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

func (*StartWorkflowRequest) XXX_DiscardUnknown 

func (m *StartWorkflowRequest) XXX_DiscardUnknown()

func (*StartWorkflowRequest) XXX_Marshal 

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

func (*StartWorkflowRequest) XXX_Merge 

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

func (*StartWorkflowRequest) XXX_Size 

func (m *StartWorkflowRequest) XXX_Size() int

func (*StartWorkflowRequest) XXX_Unmarshal 

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

type StartWorkflowResponse 

type StartWorkflowResponse struct {
	RunId         string     `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	RealStartTime *time.Time `protobuf:"bytes,2,opt,name=real_start_time,json=realStartTime,proto3,stdtime" json:"real_start_time,omitempty"`
}

func (*StartWorkflowResponse) Descriptor 

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

func (*StartWorkflowResponse) Equal 

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

func (*StartWorkflowResponse) GetRealStartTime 

func (m *StartWorkflowResponse) GetRealStartTime() *time.Time

func (*StartWorkflowResponse) GetRunId 

func (m *StartWorkflowResponse) GetRunId() string

func (*StartWorkflowResponse) GoString 

func (this *StartWorkflowResponse) GoString() string

func (*StartWorkflowResponse) Marshal 

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

func (*StartWorkflowResponse) MarshalTo 

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

func (*StartWorkflowResponse) MarshalToSizedBuffer 

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

func (*StartWorkflowResponse) ProtoMessage 

func (*StartWorkflowResponse) ProtoMessage()

func (*StartWorkflowResponse) Reset 

func (m *StartWorkflowResponse) Reset()

func (*StartWorkflowResponse) Size 

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

func (*StartWorkflowResponse) String 

func (this *StartWorkflowResponse) String() string

func (*StartWorkflowResponse) Unmarshal 

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

func (*StartWorkflowResponse) XXX_DiscardUnknown 

func (m *StartWorkflowResponse) XXX_DiscardUnknown()

func (*StartWorkflowResponse) XXX_Marshal 

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

func (*StartWorkflowResponse) XXX_Merge 

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

func (*StartWorkflowResponse) XXX_Size 

func (m *StartWorkflowResponse) XXX_Size() int

func (*StartWorkflowResponse) XXX_Unmarshal 

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

type TerminateWorkflowRequest 

type TerminateWorkflowRequest struct {
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Identity  string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	// Note: run id in execution is first execution run id
	Execution *v11.WorkflowExecution `protobuf:"bytes,5,opt,name=execution,proto3" json:"execution,omitempty"`
	Reason    string                 `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
}

func (*TerminateWorkflowRequest) Descriptor 

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

func (*TerminateWorkflowRequest) Equal 

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

func (*TerminateWorkflowRequest) GetExecution 

func (m *TerminateWorkflowRequest) GetExecution() *v11.WorkflowExecution

func (*TerminateWorkflowRequest) GetIdentity 

func (m *TerminateWorkflowRequest) GetIdentity() string

func (*TerminateWorkflowRequest) GetReason 

func (m *TerminateWorkflowRequest) GetReason() string

func (*TerminateWorkflowRequest) GetRequestId 

func (m *TerminateWorkflowRequest) GetRequestId() string

func (*TerminateWorkflowRequest) GoString 

func (this *TerminateWorkflowRequest) GoString() string

func (*TerminateWorkflowRequest) Marshal 

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

func (*TerminateWorkflowRequest) MarshalTo 

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

func (*TerminateWorkflowRequest) MarshalToSizedBuffer 

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

func (*TerminateWorkflowRequest) ProtoMessage 

func (*TerminateWorkflowRequest) ProtoMessage()

func (*TerminateWorkflowRequest) Reset 

func (m *TerminateWorkflowRequest) Reset()

func (*TerminateWorkflowRequest) Size 

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

func (*TerminateWorkflowRequest) String 

func (this *TerminateWorkflowRequest) String() string

func (*TerminateWorkflowRequest) Unmarshal 

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

func (*TerminateWorkflowRequest) XXX_DiscardUnknown 

func (m *TerminateWorkflowRequest) XXX_DiscardUnknown()

func (*TerminateWorkflowRequest) XXX_Marshal 

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

func (*TerminateWorkflowRequest) XXX_Merge 

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

func (*TerminateWorkflowRequest) XXX_Size 

func (m *TerminateWorkflowRequest) XXX_Size() int

func (*TerminateWorkflowRequest) XXX_Unmarshal 

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

type WatchWorkflowRequest 

type WatchWorkflowRequest struct {
	// Note: this will be sent to the activity with empty execution.run_id, and
	// the run id that we started in first_execution_run_id.
	Execution           *v11.WorkflowExecution `protobuf:"bytes,3,opt,name=execution,proto3" json:"execution,omitempty"`
	FirstExecutionRunId string                 `protobuf:"bytes,4,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
	LongPoll            bool                   `protobuf:"varint,5,opt,name=long_poll,json=longPoll,proto3" json:"long_poll,omitempty"`
}

func (*WatchWorkflowRequest) Descriptor 

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

func (*WatchWorkflowRequest) Equal 

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

func (*WatchWorkflowRequest) GetExecution 

func (m *WatchWorkflowRequest) GetExecution() *v11.WorkflowExecution

func (*WatchWorkflowRequest) GetFirstExecutionRunId 

func (m *WatchWorkflowRequest) GetFirstExecutionRunId() string

func (*WatchWorkflowRequest) GetLongPoll 

func (m *WatchWorkflowRequest) GetLongPoll() bool

func (*WatchWorkflowRequest) GoString 

func (this *WatchWorkflowRequest) GoString() string

func (*WatchWorkflowRequest) Marshal 

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

func (*WatchWorkflowRequest) MarshalTo 

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

func (*WatchWorkflowRequest) MarshalToSizedBuffer 

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

func (*WatchWorkflowRequest) ProtoMessage 

func (*WatchWorkflowRequest) ProtoMessage()

func (*WatchWorkflowRequest) Reset 

func (m *WatchWorkflowRequest) Reset()

func (*WatchWorkflowRequest) Size 

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

func (*WatchWorkflowRequest) String 

func (this *WatchWorkflowRequest) String() string

func (*WatchWorkflowRequest) Unmarshal 

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

func (*WatchWorkflowRequest) XXX_DiscardUnknown 

func (m *WatchWorkflowRequest) XXX_DiscardUnknown()

func (*WatchWorkflowRequest) XXX_Marshal 

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

func (*WatchWorkflowRequest) XXX_Merge 

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

func (*WatchWorkflowRequest) XXX_Size 

func (m *WatchWorkflowRequest) XXX_Size() int

func (*WatchWorkflowRequest) XXX_Unmarshal 

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

type WatchWorkflowResponse 

type WatchWorkflowResponse struct {
	Status v1.WorkflowExecutionStatus `protobuf:"varint,1,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	// Types that are valid to be assigned to ResultFailure:
	//	*WatchWorkflowResponse_Result
	//	*WatchWorkflowResponse_Failure
	ResultFailure isWatchWorkflowResponse_ResultFailure `protobuf_oneof:"result_failure"`
}

func (*WatchWorkflowResponse) Descriptor 

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

func (*WatchWorkflowResponse) Equal 

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

func (*WatchWorkflowResponse) GetFailure 

func (m *WatchWorkflowResponse) GetFailure() *v12.Failure

func (*WatchWorkflowResponse) GetResult 

func (m *WatchWorkflowResponse) GetResult() *v11.Payloads

func (*WatchWorkflowResponse) GetResultFailure 

func (m *WatchWorkflowResponse) GetResultFailure() isWatchWorkflowResponse_ResultFailure

func (*WatchWorkflowResponse) GetStatus 

func (m *WatchWorkflowResponse) GetStatus() v1.WorkflowExecutionStatus

func (*WatchWorkflowResponse) GoString 

func (this *WatchWorkflowResponse) GoString() string

func (*WatchWorkflowResponse) Marshal 

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

func (*WatchWorkflowResponse) MarshalTo 

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

func (*WatchWorkflowResponse) MarshalToSizedBuffer 

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

func (*WatchWorkflowResponse) ProtoMessage 

func (*WatchWorkflowResponse) ProtoMessage()

func (*WatchWorkflowResponse) Reset 

func (m *WatchWorkflowResponse) Reset()

func (*WatchWorkflowResponse) Size 

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

func (*WatchWorkflowResponse) String 

func (this *WatchWorkflowResponse) String() string

func (*WatchWorkflowResponse) Unmarshal 

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

func (*WatchWorkflowResponse) XXX_DiscardUnknown 

func (m *WatchWorkflowResponse) XXX_DiscardUnknown()

func (*WatchWorkflowResponse) XXX_Marshal 

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

func (*WatchWorkflowResponse) XXX_Merge 

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

func (*WatchWorkflowResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*WatchWorkflowResponse) XXX_Size 

func (m *WatchWorkflowResponse) XXX_Size() int

func (*WatchWorkflowResponse) XXX_Unmarshal 

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

type WatchWorkflowResponse_Failure 

type WatchWorkflowResponse_Failure struct {
	Failure *v12.Failure `protobuf:"bytes,3,opt,name=failure,proto3,oneof" json:"failure,omitempty"`
}

func (*WatchWorkflowResponse_Failure) Equal 

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

func (*WatchWorkflowResponse_Failure) GoString 

func (this *WatchWorkflowResponse_Failure) GoString() string

func (*WatchWorkflowResponse_Failure) MarshalTo 

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

func (*WatchWorkflowResponse_Failure) MarshalToSizedBuffer 

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

func (*WatchWorkflowResponse_Failure) Size 

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

func (*WatchWorkflowResponse_Failure) String 

func (this *WatchWorkflowResponse_Failure) String() string

type WatchWorkflowResponse_Result 

type WatchWorkflowResponse_Result struct {
	Result *v11.Payloads `protobuf:"bytes,2,opt,name=result,proto3,oneof" json:"result,omitempty"`
}

func (*WatchWorkflowResponse_Result) Equal 

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

func (*WatchWorkflowResponse_Result) GoString 

func (this *WatchWorkflowResponse_Result) GoString() string

func (*WatchWorkflowResponse_Result) MarshalTo 

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

func (*WatchWorkflowResponse_Result) MarshalToSizedBuffer 

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

func (*WatchWorkflowResponse_Result) Size 

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

func (*WatchWorkflowResponse_Result) String 

func (this *WatchWorkflowResponse_Result) String() string

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.
JackTT - Gopher 🇻🇳