schedule

package
v1.21.5-rc2 Latest Latest
Warning

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

Go to latest
Published: Aug 14, 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 (*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 (*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

Jump to

Keyboard shortcuts

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