Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterTaskHubSidecarServiceServer(s grpc.ServiceRegistrar, srv TaskHubSidecarServiceServer)
- type ActivityInvocation
- func (*ActivityInvocation) Descriptor() ([]byte, []int)deprecated
- func (x *ActivityInvocation) GetHistoryEvent() *HistoryEvent
- func (x *ActivityInvocation) GetPropagatedHistory() *PropagatedHistory
- func (*ActivityInvocation) ProtoMessage()
- func (x *ActivityInvocation) ProtoReflect() protoreflect.Message
- func (x *ActivityInvocation) Reset()
- func (x *ActivityInvocation) String() string
- type ActivityRequest
- func (*ActivityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActivityRequest) GetInput() *wrapperspb.StringValue
- func (x *ActivityRequest) GetName() string
- func (x *ActivityRequest) GetParentTraceContext() *TraceContext
- func (x *ActivityRequest) GetPropagatedHistory() *PropagatedHistory
- func (x *ActivityRequest) GetTaskExecutionId() string
- func (x *ActivityRequest) GetTaskId() int32
- func (x *ActivityRequest) GetVersion() *wrapperspb.StringValue
- func (x *ActivityRequest) GetWorkflowInstance() *WorkflowInstance
- func (*ActivityRequest) ProtoMessage()
- func (x *ActivityRequest) ProtoReflect() protoreflect.Message
- func (x *ActivityRequest) Reset()
- func (x *ActivityRequest) String() string
- type ActivityResponse
- func (*ActivityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ActivityResponse) GetCompletionToken() string
- func (x *ActivityResponse) GetFailureDetails() *TaskFailureDetails
- func (x *ActivityResponse) GetInstanceId() string
- func (x *ActivityResponse) GetResult() *wrapperspb.StringValue
- func (x *ActivityResponse) GetTaskId() int32
- func (*ActivityResponse) ProtoMessage()
- func (x *ActivityResponse) ProtoReflect() protoreflect.Message
- func (x *ActivityResponse) Reset()
- func (x *ActivityResponse) String() string
- type AddEventRequest
- func (*AddEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddEventRequest) GetEvent() *HistoryEvent
- func (x *AddEventRequest) GetInstance() *WorkflowInstance
- func (*AddEventRequest) ProtoMessage()
- func (x *AddEventRequest) ProtoReflect() protoreflect.Message
- func (x *AddEventRequest) Reset()
- func (x *AddEventRequest) String() string
- type AddEventResponse
- type BackendWorkflowState
- func (*BackendWorkflowState) Descriptor() ([]byte, []int)deprecated
- func (x *BackendWorkflowState) GetCustomStatus() *wrapperspb.StringValue
- func (x *BackendWorkflowState) GetGeneration() uint64
- func (x *BackendWorkflowState) GetHistory() []*HistoryEvent
- func (x *BackendWorkflowState) GetInbox() []*HistoryEvent
- func (*BackendWorkflowState) ProtoMessage()
- func (x *BackendWorkflowState) ProtoReflect() protoreflect.Message
- func (x *BackendWorkflowState) Reset()
- func (x *BackendWorkflowState) String() string
- type BackendWorkflowStateMetadata
- func (*BackendWorkflowStateMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *BackendWorkflowStateMetadata) GetGeneration() uint64
- func (x *BackendWorkflowStateMetadata) GetHistoryLength() uint64
- func (x *BackendWorkflowStateMetadata) GetInboxLength() uint64
- func (*BackendWorkflowStateMetadata) ProtoMessage()
- func (x *BackendWorkflowStateMetadata) ProtoReflect() protoreflect.Message
- func (x *BackendWorkflowStateMetadata) Reset()
- func (x *BackendWorkflowStateMetadata) String() string
- type CachedHistory
- type ChildWorkflowInstanceCompletedEvent
- func (*ChildWorkflowInstanceCompletedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ChildWorkflowInstanceCompletedEvent) GetResult() *wrapperspb.StringValue
- func (x *ChildWorkflowInstanceCompletedEvent) GetTaskScheduledId() int32
- func (*ChildWorkflowInstanceCompletedEvent) ProtoMessage()
- func (x *ChildWorkflowInstanceCompletedEvent) ProtoReflect() protoreflect.Message
- func (x *ChildWorkflowInstanceCompletedEvent) Reset()
- func (x *ChildWorkflowInstanceCompletedEvent) String() string
- type ChildWorkflowInstanceCreatedEvent
- func (*ChildWorkflowInstanceCreatedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ChildWorkflowInstanceCreatedEvent) GetHistoryPropagationScope() HistoryPropagationScope
- func (x *ChildWorkflowInstanceCreatedEvent) GetInput() *wrapperspb.StringValue
- func (x *ChildWorkflowInstanceCreatedEvent) GetInstanceId() string
- func (x *ChildWorkflowInstanceCreatedEvent) GetName() string
- func (x *ChildWorkflowInstanceCreatedEvent) GetParentTraceContext() *TraceContext
- func (x *ChildWorkflowInstanceCreatedEvent) GetRetryParentInstanceInfo() *RetryParentInstanceInfo
- func (x *ChildWorkflowInstanceCreatedEvent) GetVersion() *wrapperspb.StringValue
- func (*ChildWorkflowInstanceCreatedEvent) ProtoMessage()
- func (x *ChildWorkflowInstanceCreatedEvent) ProtoReflect() protoreflect.Message
- func (x *ChildWorkflowInstanceCreatedEvent) Reset()
- func (x *ChildWorkflowInstanceCreatedEvent) String() string
- type ChildWorkflowInstanceFailedEvent
- func (*ChildWorkflowInstanceFailedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ChildWorkflowInstanceFailedEvent) GetFailureDetails() *TaskFailureDetails
- func (x *ChildWorkflowInstanceFailedEvent) GetTaskScheduledId() int32
- func (*ChildWorkflowInstanceFailedEvent) ProtoMessage()
- func (x *ChildWorkflowInstanceFailedEvent) ProtoReflect() protoreflect.Message
- func (x *ChildWorkflowInstanceFailedEvent) Reset()
- func (x *ChildWorkflowInstanceFailedEvent) String() string
- type CompleteActivityWorkItemRequest
- func (*CompleteActivityWorkItemRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompleteActivityWorkItemRequest) GetCompletionToken() string
- func (x *CompleteActivityWorkItemRequest) GetResponseEvent() *HistoryEvent
- func (*CompleteActivityWorkItemRequest) ProtoMessage()
- func (x *CompleteActivityWorkItemRequest) ProtoReflect() protoreflect.Message
- func (x *CompleteActivityWorkItemRequest) Reset()
- func (x *CompleteActivityWorkItemRequest) String() string
- type CompleteActivityWorkItemResponse
- func (*CompleteActivityWorkItemResponse) Descriptor() ([]byte, []int)deprecated
- func (*CompleteActivityWorkItemResponse) ProtoMessage()
- func (x *CompleteActivityWorkItemResponse) ProtoReflect() protoreflect.Message
- func (x *CompleteActivityWorkItemResponse) Reset()
- func (x *CompleteActivityWorkItemResponse) String() string
- type CompleteOrchestrationActiondeprecated
- type CompleteOrchestrationWorkItemRequestdeprecated
- type CompleteOrchestrationWorkItemResponsedeprecated
- type CompleteTaskResponse
- type CompleteWorkflowAction
- func (*CompleteWorkflowAction) Descriptor() ([]byte, []int)deprecated
- func (x *CompleteWorkflowAction) GetCarryoverEvents() []*HistoryEvent
- func (x *CompleteWorkflowAction) GetDetails() *wrapperspb.StringValue
- func (x *CompleteWorkflowAction) GetFailureDetails() *TaskFailureDetails
- func (x *CompleteWorkflowAction) GetNewVersion() *wrapperspb.StringValue
- func (x *CompleteWorkflowAction) GetOrchestrationStatus() OrchestrationStatusdeprecated
- func (x *CompleteWorkflowAction) GetResult() *wrapperspb.StringValue
- func (x *CompleteWorkflowAction) GetWorkflowStatus() OrchestrationStatus
- func (*CompleteWorkflowAction) ProtoMessage()
- func (x *CompleteWorkflowAction) ProtoReflect() protoreflect.Message
- func (x *CompleteWorkflowAction) Reset()
- func (x *CompleteWorkflowAction) String() string
- type CompleteWorkflowWorkItemRequest
- func (*CompleteWorkflowWorkItemRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompleteWorkflowWorkItemRequest) GetCompletionToken() string
- func (x *CompleteWorkflowWorkItemRequest) GetCustomStatus() *wrapperspb.StringValue
- func (x *CompleteWorkflowWorkItemRequest) GetInstance() *WorkflowInstance
- func (x *CompleteWorkflowWorkItemRequest) GetNewHistory() []*HistoryEvent
- func (x *CompleteWorkflowWorkItemRequest) GetNewMessages() []*WorkflowMessage
- func (x *CompleteWorkflowWorkItemRequest) GetNewTasks() []*HistoryEvent
- func (x *CompleteWorkflowWorkItemRequest) GetNewTimers() []*HistoryEvent
- func (x *CompleteWorkflowWorkItemRequest) GetNumEventsProcessed() *wrapperspb.Int32Value
- func (x *CompleteWorkflowWorkItemRequest) GetRuntimeStatus() OrchestrationStatus
- func (*CompleteWorkflowWorkItemRequest) ProtoMessage()
- func (x *CompleteWorkflowWorkItemRequest) ProtoReflect() protoreflect.Message
- func (x *CompleteWorkflowWorkItemRequest) Reset()
- func (x *CompleteWorkflowWorkItemRequest) String() string
- type CompleteWorkflowWorkItemResponse
- func (*CompleteWorkflowWorkItemResponse) Descriptor() ([]byte, []int)deprecated
- func (*CompleteWorkflowWorkItemResponse) ProtoMessage()
- func (x *CompleteWorkflowWorkItemResponse) ProtoReflect() protoreflect.Message
- func (x *CompleteWorkflowWorkItemResponse) Reset()
- func (x *CompleteWorkflowWorkItemResponse) String() string
- type ContinueAsNewEvent
- func (*ContinueAsNewEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ContinueAsNewEvent) GetInput() *wrapperspb.StringValue
- func (*ContinueAsNewEvent) ProtoMessage()
- func (x *ContinueAsNewEvent) ProtoReflect() protoreflect.Message
- func (x *ContinueAsNewEvent) Reset()
- func (x *ContinueAsNewEvent) String() string
- type CreateChildWorkflowAction
- func (*CreateChildWorkflowAction) Descriptor() ([]byte, []int)deprecated
- func (x *CreateChildWorkflowAction) GetHistoryPropagationScope() HistoryPropagationScope
- func (x *CreateChildWorkflowAction) GetInput() *wrapperspb.StringValue
- func (x *CreateChildWorkflowAction) GetInstanceId() string
- func (x *CreateChildWorkflowAction) GetName() string
- func (x *CreateChildWorkflowAction) GetRetryParentInstanceInfo() *RetryParentInstanceInfo
- func (x *CreateChildWorkflowAction) GetVersion() *wrapperspb.StringValue
- func (*CreateChildWorkflowAction) ProtoMessage()
- func (x *CreateChildWorkflowAction) ProtoReflect() protoreflect.Message
- func (x *CreateChildWorkflowAction) Reset()
- func (x *CreateChildWorkflowAction) String() string
- type CreateDetachedWorkflowAction
- func (*CreateDetachedWorkflowAction) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDetachedWorkflowAction) GetExecutionId() *wrapperspb.StringValue
- func (x *CreateDetachedWorkflowAction) GetInput() *wrapperspb.StringValue
- func (x *CreateDetachedWorkflowAction) GetInstanceId() string
- func (x *CreateDetachedWorkflowAction) GetName() string
- func (x *CreateDetachedWorkflowAction) GetParentTraceContext() *TraceContext
- func (x *CreateDetachedWorkflowAction) GetScheduledStartTimestamp() *timestamppb.Timestamp
- func (x *CreateDetachedWorkflowAction) GetTags() map[string]string
- func (x *CreateDetachedWorkflowAction) GetVersion() *wrapperspb.StringValue
- func (*CreateDetachedWorkflowAction) ProtoMessage()
- func (x *CreateDetachedWorkflowAction) ProtoReflect() protoreflect.Message
- func (x *CreateDetachedWorkflowAction) Reset()
- func (x *CreateDetachedWorkflowAction) String() string
- type CreateInstanceRequest
- func (*CreateInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateInstanceRequest) GetEnforceUniqueInstanceId() bool
- func (x *CreateInstanceRequest) GetExecutionId() *wrapperspb.StringValue
- func (x *CreateInstanceRequest) GetInput() *wrapperspb.StringValue
- func (x *CreateInstanceRequest) GetInstanceId() string
- func (x *CreateInstanceRequest) GetName() string
- func (x *CreateInstanceRequest) GetParentTraceContext() *TraceContext
- func (x *CreateInstanceRequest) GetRouter() *TaskRouter
- func (x *CreateInstanceRequest) GetScheduledStartTimestamp() *timestamppb.Timestamp
- func (x *CreateInstanceRequest) GetTags() map[string]string
- func (x *CreateInstanceRequest) GetVersion() *wrapperspb.StringValue
- func (*CreateInstanceRequest) ProtoMessage()
- func (x *CreateInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateInstanceRequest) Reset()
- func (x *CreateInstanceRequest) String() string
- type CreateInstanceResponse
- func (*CreateInstanceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateInstanceResponse) GetInstanceId() string
- func (*CreateInstanceResponse) ProtoMessage()
- func (x *CreateInstanceResponse) ProtoReflect() protoreflect.Message
- func (x *CreateInstanceResponse) Reset()
- func (x *CreateInstanceResponse) String() string
- type CreateSubOrchestrationActiondeprecated
- type CreateTimerAction
- func (*CreateTimerAction) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTimerAction) GetActivityRetry() *TimerOriginActivityRetry
- func (x *CreateTimerAction) GetChildWorkflowRetry() *TimerOriginChildWorkflowRetry
- func (x *CreateTimerAction) GetCreateTimer() *TimerOriginCreateTimer
- func (x *CreateTimerAction) GetExternalEvent() *TimerOriginExternalEvent
- func (x *CreateTimerAction) GetFireAt() *timestamppb.Timestamp
- func (x *CreateTimerAction) GetName() string
- func (m *CreateTimerAction) GetOrigin() isCreateTimerAction_Origin
- func (*CreateTimerAction) ProtoMessage()
- func (x *CreateTimerAction) ProtoReflect() protoreflect.Message
- func (x *CreateTimerAction) Reset()
- func (x *CreateTimerAction) String() string
- type CreateTimerAction_ActivityRetry
- type CreateTimerAction_ChildWorkflowRetry
- type CreateTimerAction_CreateTimer
- type CreateTimerAction_ExternalEvent
- type CreateWorkflowInstanceRequest
- func (*CreateWorkflowInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateWorkflowInstanceRequest) GetEnforceUniqueInstanceId() bool
- func (x *CreateWorkflowInstanceRequest) GetPropagatedHistory() *PropagatedHistory
- func (x *CreateWorkflowInstanceRequest) GetStartEvent() *HistoryEvent
- func (*CreateWorkflowInstanceRequest) ProtoMessage()
- func (x *CreateWorkflowInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateWorkflowInstanceRequest) Reset()
- func (x *CreateWorkflowInstanceRequest) String() string
- type DetachedWorkflowInstanceCreatedEvent
- func (*DetachedWorkflowInstanceCreatedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *DetachedWorkflowInstanceCreatedEvent) GetInstanceId() string
- func (*DetachedWorkflowInstanceCreatedEvent) ProtoMessage()
- func (x *DetachedWorkflowInstanceCreatedEvent) ProtoReflect() protoreflect.Message
- func (x *DetachedWorkflowInstanceCreatedEvent) Reset()
- func (x *DetachedWorkflowInstanceCreatedEvent) String() string
- type DurableTimer
- func (*DurableTimer) Descriptor() ([]byte, []int)deprecated
- func (x *DurableTimer) GetGeneration() uint64
- func (x *DurableTimer) GetTimerEvent() *HistoryEvent
- func (*DurableTimer) ProtoMessage()
- func (x *DurableTimer) ProtoReflect() protoreflect.Message
- func (x *DurableTimer) Reset()
- func (x *DurableTimer) String() string
- type EventRaisedEvent
- func (*EventRaisedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *EventRaisedEvent) GetInput() *wrapperspb.StringValue
- func (x *EventRaisedEvent) GetName() string
- func (*EventRaisedEvent) ProtoMessage()
- func (x *EventRaisedEvent) ProtoReflect() protoreflect.Message
- func (x *EventRaisedEvent) Reset()
- func (x *EventRaisedEvent) String() string
- type EventSentEvent
- func (*EventSentEvent) Descriptor() ([]byte, []int)deprecated
- func (x *EventSentEvent) GetInput() *wrapperspb.StringValue
- func (x *EventSentEvent) GetInstanceId() string
- func (x *EventSentEvent) GetName() string
- func (*EventSentEvent) ProtoMessage()
- func (x *EventSentEvent) ProtoReflect() protoreflect.Message
- func (x *EventSentEvent) Reset()
- func (x *EventSentEvent) String() string
- type ExecutionCompletedEvent
- func (*ExecutionCompletedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutionCompletedEvent) GetFailureDetails() *TaskFailureDetails
- func (x *ExecutionCompletedEvent) GetOrchestrationStatus() OrchestrationStatusdeprecated
- func (x *ExecutionCompletedEvent) GetResult() *wrapperspb.StringValue
- func (x *ExecutionCompletedEvent) GetWorkflowStatus() OrchestrationStatus
- func (*ExecutionCompletedEvent) ProtoMessage()
- func (x *ExecutionCompletedEvent) ProtoReflect() protoreflect.Message
- func (x *ExecutionCompletedEvent) Reset()
- func (x *ExecutionCompletedEvent) String() string
- type ExecutionResumedEvent
- func (*ExecutionResumedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutionResumedEvent) GetInput() *wrapperspb.StringValue
- func (*ExecutionResumedEvent) ProtoMessage()
- func (x *ExecutionResumedEvent) ProtoReflect() protoreflect.Message
- func (x *ExecutionResumedEvent) Reset()
- func (x *ExecutionResumedEvent) String() string
- type ExecutionStalledEvent
- func (*ExecutionStalledEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutionStalledEvent) GetDescription() string
- func (x *ExecutionStalledEvent) GetReason() StalledReason
- func (*ExecutionStalledEvent) ProtoMessage()
- func (x *ExecutionStalledEvent) ProtoReflect() protoreflect.Message
- func (x *ExecutionStalledEvent) Reset()
- func (x *ExecutionStalledEvent) String() string
- type ExecutionStartedEvent
- func (*ExecutionStartedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutionStartedEvent) GetInput() *wrapperspb.StringValue
- func (x *ExecutionStartedEvent) GetName() string
- func (x *ExecutionStartedEvent) GetOrchestrationInstance() *WorkflowInstancedeprecated
- func (x *ExecutionStartedEvent) GetOrchestrationSpanID() *wrapperspb.StringValuedeprecated
- func (x *ExecutionStartedEvent) GetParentInstance() *ParentInstanceInfo
- func (x *ExecutionStartedEvent) GetParentTraceContext() *TraceContext
- func (x *ExecutionStartedEvent) GetScheduledStartTimestamp() *timestamppb.Timestamp
- func (x *ExecutionStartedEvent) GetTags() map[string]string
- func (x *ExecutionStartedEvent) GetVersion() *wrapperspb.StringValue
- func (x *ExecutionStartedEvent) GetWorkflowInstance() *WorkflowInstance
- func (x *ExecutionStartedEvent) GetWorkflowSpanID() *wrapperspb.StringValue
- func (*ExecutionStartedEvent) ProtoMessage()
- func (x *ExecutionStartedEvent) ProtoReflect() protoreflect.Message
- func (x *ExecutionStartedEvent) Reset()
- func (x *ExecutionStartedEvent) String() string
- type ExecutionSuspendedEvent
- func (*ExecutionSuspendedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutionSuspendedEvent) GetInput() *wrapperspb.StringValue
- func (*ExecutionSuspendedEvent) ProtoMessage()
- func (x *ExecutionSuspendedEvent) ProtoReflect() protoreflect.Message
- func (x *ExecutionSuspendedEvent) Reset()
- func (x *ExecutionSuspendedEvent) String() string
- type ExecutionTerminatedEvent
- func (*ExecutionTerminatedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutionTerminatedEvent) GetInput() *wrapperspb.StringValue
- func (x *ExecutionTerminatedEvent) GetRecurse() bool
- func (*ExecutionTerminatedEvent) ProtoMessage()
- func (x *ExecutionTerminatedEvent) ProtoReflect() protoreflect.Message
- func (x *ExecutionTerminatedEvent) Reset()
- func (x *ExecutionTerminatedEvent) String() string
- type GetInstanceHistoryRequest
- func (*GetInstanceHistoryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetInstanceHistoryRequest) GetInstanceId() string
- func (*GetInstanceHistoryRequest) ProtoMessage()
- func (x *GetInstanceHistoryRequest) ProtoReflect() protoreflect.Message
- func (x *GetInstanceHistoryRequest) Reset()
- func (x *GetInstanceHistoryRequest) String() string
- type GetInstanceHistoryResponse
- func (*GetInstanceHistoryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetInstanceHistoryResponse) GetEvents() []*HistoryEvent
- func (*GetInstanceHistoryResponse) ProtoMessage()
- func (x *GetInstanceHistoryResponse) ProtoReflect() protoreflect.Message
- func (x *GetInstanceHistoryResponse) Reset()
- func (x *GetInstanceHistoryResponse) String() string
- type GetInstanceRequest
- func (*GetInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetInstanceRequest) GetGetInputsAndOutputs() bool
- func (x *GetInstanceRequest) GetInstanceId() string
- func (x *GetInstanceRequest) GetRouter() *TaskRouter
- func (*GetInstanceRequest) ProtoMessage()
- func (x *GetInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *GetInstanceRequest) Reset()
- func (x *GetInstanceRequest) String() string
- type GetInstanceResponse
- func (*GetInstanceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetInstanceResponse) GetExists() bool
- func (x *GetInstanceResponse) GetWorkflowState() *WorkflowState
- func (*GetInstanceResponse) ProtoMessage()
- func (x *GetInstanceResponse) ProtoReflect() protoreflect.Message
- func (x *GetInstanceResponse) Reset()
- func (x *GetInstanceResponse) String() string
- type GetWorkItemsRequest
- func (*GetWorkItemsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkItemsRequest) GetCapabilities() []WorkerCapability
- func (*GetWorkItemsRequest) ProtoMessage()
- func (x *GetWorkItemsRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkItemsRequest) Reset()
- func (x *GetWorkItemsRequest) String() string
- type HistoryEvent
- func (*HistoryEvent) Descriptor() ([]byte, []int)deprecated
- func (x *HistoryEvent) GetChildWorkflowInstanceCompleted() *ChildWorkflowInstanceCompletedEvent
- func (x *HistoryEvent) GetChildWorkflowInstanceCreated() *ChildWorkflowInstanceCreatedEvent
- func (x *HistoryEvent) GetChildWorkflowInstanceFailed() *ChildWorkflowInstanceFailedEvent
- func (x *HistoryEvent) GetContinueAsNew() *ContinueAsNewEvent
- func (x *HistoryEvent) GetDetachedWorkflowInstanceCreated() *DetachedWorkflowInstanceCreatedEvent
- func (x *HistoryEvent) GetEventId() int32
- func (x *HistoryEvent) GetEventRaised() *EventRaisedEvent
- func (x *HistoryEvent) GetEventSent() *EventSentEvent
- func (m *HistoryEvent) GetEventType() isHistoryEvent_EventType
- func (x *HistoryEvent) GetExecutionCompleted() *ExecutionCompletedEvent
- func (x *HistoryEvent) GetExecutionResumed() *ExecutionResumedEvent
- func (x *HistoryEvent) GetExecutionStalled() *ExecutionStalledEvent
- func (x *HistoryEvent) GetExecutionStarted() *ExecutionStartedEvent
- func (x *HistoryEvent) GetExecutionSuspended() *ExecutionSuspendedEvent
- func (x *HistoryEvent) GetExecutionTerminated() *ExecutionTerminatedEvent
- func (x *HistoryEvent) GetOrchestratorCompleted() *WorkflowCompletedEventdeprecated
- func (x *HistoryEvent) GetOrchestratorStarted() *WorkflowStartedEventdeprecated
- func (x *HistoryEvent) GetRouter() *TaskRouter
- func (x *HistoryEvent) GetSubOrchestrationInstanceCompleted() *ChildWorkflowInstanceCompletedEventdeprecated
- func (x *HistoryEvent) GetSubOrchestrationInstanceCreated() *ChildWorkflowInstanceCreatedEventdeprecated
- func (x *HistoryEvent) GetSubOrchestrationInstanceFailed() *ChildWorkflowInstanceFailedEventdeprecated
- func (x *HistoryEvent) GetTaskCompleted() *TaskCompletedEvent
- func (x *HistoryEvent) GetTaskFailed() *TaskFailedEvent
- func (x *HistoryEvent) GetTaskScheduled() *TaskScheduledEvent
- func (x *HistoryEvent) GetTimerCreated() *TimerCreatedEvent
- func (x *HistoryEvent) GetTimerFired() *TimerFiredEvent
- func (x *HistoryEvent) GetTimestamp() *timestamppb.Timestamp
- func (x *HistoryEvent) GetWorkflowCompleted() *WorkflowCompletedEvent
- func (x *HistoryEvent) GetWorkflowStarted() *WorkflowStartedEvent
- func (*HistoryEvent) ProtoMessage()
- func (x *HistoryEvent) ProtoReflect() protoreflect.Message
- func (x *HistoryEvent) Reset()
- func (x *HistoryEvent) String() string
- type HistoryEvent_ChildWorkflowInstanceCompleted
- type HistoryEvent_ChildWorkflowInstanceCreated
- type HistoryEvent_ChildWorkflowInstanceFailed
- type HistoryEvent_ContinueAsNew
- type HistoryEvent_DetachedWorkflowInstanceCreated
- type HistoryEvent_EventRaised
- type HistoryEvent_EventSent
- type HistoryEvent_ExecutionCompleted
- type HistoryEvent_ExecutionResumed
- type HistoryEvent_ExecutionStalled
- type HistoryEvent_ExecutionStarted
- type HistoryEvent_ExecutionSuspended
- type HistoryEvent_ExecutionTerminated
- type HistoryEvent_OrchestratorCompleteddeprecated
- type HistoryEvent_OrchestratorStarteddeprecated
- type HistoryEvent_SubOrchestrationInstanceCompleteddeprecated
- type HistoryEvent_SubOrchestrationInstanceCreateddeprecated
- type HistoryEvent_SubOrchestrationInstanceFaileddeprecated
- type HistoryEvent_TaskCompleted
- type HistoryEvent_TaskFailed
- type HistoryEvent_TaskScheduled
- type HistoryEvent_TimerCreated
- type HistoryEvent_TimerFired
- type HistoryEvent_WorkflowCompleted
- type HistoryEvent_WorkflowStarted
- type HistoryPropagationScope
- func (HistoryPropagationScope) Descriptor() protoreflect.EnumDescriptor
- func (x HistoryPropagationScope) Enum() *HistoryPropagationScope
- func (HistoryPropagationScope) EnumDescriptor() ([]byte, []int)deprecated
- func (x HistoryPropagationScope) Number() protoreflect.EnumNumber
- func (x HistoryPropagationScope) String() string
- func (HistoryPropagationScope) Type() protoreflect.EnumType
- type ListInstanceIDsRequest
- func (*ListInstanceIDsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListInstanceIDsRequest) GetContinuationToken() string
- func (x *ListInstanceIDsRequest) GetPageSize() uint32
- func (*ListInstanceIDsRequest) ProtoMessage()
- func (x *ListInstanceIDsRequest) ProtoReflect() protoreflect.Message
- func (x *ListInstanceIDsRequest) Reset()
- func (x *ListInstanceIDsRequest) String() string
- type ListInstanceIDsResponse
- func (*ListInstanceIDsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListInstanceIDsResponse) GetContinuationToken() string
- func (x *ListInstanceIDsResponse) GetInstanceIds() []string
- func (*ListInstanceIDsResponse) ProtoMessage()
- func (x *ListInstanceIDsResponse) ProtoReflect() protoreflect.Message
- func (x *ListInstanceIDsResponse) Reset()
- func (x *ListInstanceIDsResponse) String() string
- type OrchestrationInstancedeprecated
- type OrchestrationMetadatadeprecated
- type OrchestrationRuntimeStatedeprecated
- type OrchestrationRuntimeStateMessagedeprecated
- type OrchestrationStatedeprecated
- type OrchestrationStatus
- func (OrchestrationStatus) Descriptor() protoreflect.EnumDescriptor
- func (x OrchestrationStatus) Enum() *OrchestrationStatus
- func (OrchestrationStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x OrchestrationStatus) Number() protoreflect.EnumNumber
- func (x OrchestrationStatus) String() string
- func (OrchestrationStatus) Type() protoreflect.EnumType
- type OrchestratorActiondeprecated
- type OrchestratorAction_CompleteOrchestrationdeprecated
- type OrchestratorAction_CreateSubOrchestrationdeprecated
- type OrchestratorAction_CreateTimerdeprecated
- type OrchestratorAction_OrchestratorVersionNotAvailabledeprecated
- type OrchestratorAction_ScheduleTaskdeprecated
- type OrchestratorAction_SendEventdeprecated
- type OrchestratorAction_TerminateOrchestrationdeprecated
- type OrchestratorCompletedEventdeprecated
- type OrchestratorMessagedeprecated
- type OrchestratorRequestdeprecated
- type OrchestratorResponsedeprecated
- type OrchestratorStartedEventdeprecated
- type OrchestratorVersionNotAvailableActiondeprecated
- type ParentInstanceInfo
- func (*ParentInstanceInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ParentInstanceInfo) GetAppID() string
- func (x *ParentInstanceInfo) GetAppNamespace() string
- func (x *ParentInstanceInfo) GetName() *wrapperspb.StringValue
- func (x *ParentInstanceInfo) GetOrchestrationInstance() *WorkflowInstancedeprecated
- func (x *ParentInstanceInfo) GetTaskScheduledId() int32
- func (x *ParentInstanceInfo) GetVersion() *wrapperspb.StringValue
- func (x *ParentInstanceInfo) GetWorkflowInstance() *WorkflowInstance
- func (*ParentInstanceInfo) ProtoMessage()
- func (x *ParentInstanceInfo) ProtoReflect() protoreflect.Message
- func (x *ParentInstanceInfo) Reset()
- func (x *ParentInstanceInfo) String() string
- type PropagatedHistory
- func (*PropagatedHistory) Descriptor() ([]byte, []int)deprecated
- func (x *PropagatedHistory) GetChunks() []*PropagatedHistoryChunk
- func (x *PropagatedHistory) GetScope() HistoryPropagationScope
- func (*PropagatedHistory) ProtoMessage()
- func (x *PropagatedHistory) ProtoReflect() protoreflect.Message
- func (x *PropagatedHistory) Reset()
- func (x *PropagatedHistory) String() string
- type PropagatedHistoryChunk
- func (*PropagatedHistoryChunk) Descriptor() ([]byte, []int)deprecated
- func (x *PropagatedHistoryChunk) GetAppId() string
- func (x *PropagatedHistoryChunk) GetInstanceId() string
- func (x *PropagatedHistoryChunk) GetRawEvents() [][]byte
- func (x *PropagatedHistoryChunk) GetWorkflowName() string
- func (*PropagatedHistoryChunk) ProtoMessage()
- func (x *PropagatedHistoryChunk) ProtoReflect() protoreflect.Message
- func (x *PropagatedHistoryChunk) Reset()
- func (x *PropagatedHistoryChunk) String() string
- type PurgeInstanceFilter
- func (*PurgeInstanceFilter) Descriptor() ([]byte, []int)deprecated
- func (x *PurgeInstanceFilter) GetCreatedTimeFrom() *timestamppb.Timestamp
- func (x *PurgeInstanceFilter) GetCreatedTimeTo() *timestamppb.Timestamp
- func (x *PurgeInstanceFilter) GetRuntimeStatus() []OrchestrationStatus
- func (*PurgeInstanceFilter) ProtoMessage()
- func (x *PurgeInstanceFilter) ProtoReflect() protoreflect.Message
- func (x *PurgeInstanceFilter) Reset()
- func (x *PurgeInstanceFilter) String() string
- type PurgeInstancesRequest
- func (*PurgeInstancesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PurgeInstancesRequest) GetForce() bool
- func (x *PurgeInstancesRequest) GetInstanceId() string
- func (x *PurgeInstancesRequest) GetPurgeInstanceFilter() *PurgeInstanceFilter
- func (x *PurgeInstancesRequest) GetRecursive() bool
- func (m *PurgeInstancesRequest) GetRequest() isPurgeInstancesRequest_Request
- func (x *PurgeInstancesRequest) GetRouter() *TaskRouter
- func (*PurgeInstancesRequest) ProtoMessage()
- func (x *PurgeInstancesRequest) ProtoReflect() protoreflect.Message
- func (x *PurgeInstancesRequest) Reset()
- func (x *PurgeInstancesRequest) String() string
- type PurgeInstancesRequest_InstanceId
- type PurgeInstancesRequest_PurgeInstanceFilter
- type PurgeInstancesResponse
- func (*PurgeInstancesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PurgeInstancesResponse) GetDeletedInstanceCount() int32
- func (x *PurgeInstancesResponse) GetIsComplete() *wrapperspb.BoolValue
- func (*PurgeInstancesResponse) ProtoMessage()
- func (x *PurgeInstancesResponse) ProtoReflect() protoreflect.Message
- func (x *PurgeInstancesResponse) Reset()
- func (x *PurgeInstancesResponse) String() string
- type RaiseEventRequest
- func (*RaiseEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RaiseEventRequest) GetInput() *wrapperspb.StringValue
- func (x *RaiseEventRequest) GetInstanceId() string
- func (x *RaiseEventRequest) GetName() string
- func (x *RaiseEventRequest) GetRouter() *TaskRouter
- func (*RaiseEventRequest) ProtoMessage()
- func (x *RaiseEventRequest) ProtoReflect() protoreflect.Message
- func (x *RaiseEventRequest) Reset()
- func (x *RaiseEventRequest) String() string
- type RaiseEventResponse
- type ResumeRequest
- func (*ResumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResumeRequest) GetInstanceId() string
- func (x *ResumeRequest) GetReason() *wrapperspb.StringValue
- func (x *ResumeRequest) GetRouter() *TaskRouter
- func (*ResumeRequest) ProtoMessage()
- func (x *ResumeRequest) ProtoReflect() protoreflect.Message
- func (x *ResumeRequest) Reset()
- func (x *ResumeRequest) String() string
- type ResumeResponse
- type RetryParentInstanceInfo
- func (*RetryParentInstanceInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RetryParentInstanceInfo) GetInstanceID() string
- func (*RetryParentInstanceInfo) ProtoMessage()
- func (x *RetryParentInstanceInfo) ProtoReflect() protoreflect.Message
- func (x *RetryParentInstanceInfo) Reset()
- func (x *RetryParentInstanceInfo) String() string
- type RuntimeStateStalled
- func (*RuntimeStateStalled) Descriptor() ([]byte, []int)deprecated
- func (x *RuntimeStateStalled) GetDescription() string
- func (x *RuntimeStateStalled) GetReason() StalledReason
- func (*RuntimeStateStalled) ProtoMessage()
- func (x *RuntimeStateStalled) ProtoReflect() protoreflect.Message
- func (x *RuntimeStateStalled) Reset()
- func (x *RuntimeStateStalled) String() string
- type ScheduleTaskAction
- func (*ScheduleTaskAction) Descriptor() ([]byte, []int)deprecated
- func (x *ScheduleTaskAction) GetHistoryPropagationScope() HistoryPropagationScope
- func (x *ScheduleTaskAction) GetInput() *wrapperspb.StringValue
- func (x *ScheduleTaskAction) GetName() string
- func (x *ScheduleTaskAction) GetTaskExecutionId() string
- func (x *ScheduleTaskAction) GetVersion() *wrapperspb.StringValue
- func (*ScheduleTaskAction) ProtoMessage()
- func (x *ScheduleTaskAction) ProtoReflect() protoreflect.Message
- func (x *ScheduleTaskAction) Reset()
- func (x *ScheduleTaskAction) String() string
- type SendEventAction
- func (*SendEventAction) Descriptor() ([]byte, []int)deprecated
- func (x *SendEventAction) GetData() *wrapperspb.StringValue
- func (x *SendEventAction) GetInstance() *WorkflowInstance
- func (x *SendEventAction) GetName() string
- func (*SendEventAction) ProtoMessage()
- func (x *SendEventAction) ProtoReflect() protoreflect.Message
- func (x *SendEventAction) Reset()
- func (x *SendEventAction) String() string
- type StalledReason
- func (StalledReason) Descriptor() protoreflect.EnumDescriptor
- func (x StalledReason) Enum() *StalledReason
- func (StalledReason) EnumDescriptor() ([]byte, []int)deprecated
- func (x StalledReason) Number() protoreflect.EnumNumber
- func (x StalledReason) String() string
- func (StalledReason) Type() protoreflect.EnumType
- type SubOrchestrationInstanceCompletedEventdeprecated
- type SubOrchestrationInstanceCreatedEventdeprecated
- type SubOrchestrationInstanceFailedEventdeprecated
- type SuspendRequest
- func (*SuspendRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SuspendRequest) GetInstanceId() string
- func (x *SuspendRequest) GetReason() *wrapperspb.StringValue
- func (x *SuspendRequest) GetRouter() *TaskRouter
- func (*SuspendRequest) ProtoMessage()
- func (x *SuspendRequest) ProtoReflect() protoreflect.Message
- func (x *SuspendRequest) Reset()
- func (x *SuspendRequest) String() string
- type SuspendResponse
- type TaskCompletedEvent
- func (*TaskCompletedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TaskCompletedEvent) GetResult() *wrapperspb.StringValue
- func (x *TaskCompletedEvent) GetTaskExecutionId() string
- func (x *TaskCompletedEvent) GetTaskScheduledId() int32
- func (*TaskCompletedEvent) ProtoMessage()
- func (x *TaskCompletedEvent) ProtoReflect() protoreflect.Message
- func (x *TaskCompletedEvent) Reset()
- func (x *TaskCompletedEvent) String() string
- type TaskFailedEvent
- func (*TaskFailedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TaskFailedEvent) GetFailureDetails() *TaskFailureDetails
- func (x *TaskFailedEvent) GetTaskExecutionId() string
- func (x *TaskFailedEvent) GetTaskScheduledId() int32
- func (*TaskFailedEvent) ProtoMessage()
- func (x *TaskFailedEvent) ProtoReflect() protoreflect.Message
- func (x *TaskFailedEvent) Reset()
- func (x *TaskFailedEvent) String() string
- type TaskFailureDetails
- func (*TaskFailureDetails) Descriptor() ([]byte, []int)deprecated
- func (x *TaskFailureDetails) GetErrorMessage() string
- func (x *TaskFailureDetails) GetErrorType() string
- func (x *TaskFailureDetails) GetInnerFailure() *TaskFailureDetails
- func (x *TaskFailureDetails) GetIsNonRetriable() bool
- func (x *TaskFailureDetails) GetStackTrace() *wrapperspb.StringValue
- func (*TaskFailureDetails) ProtoMessage()
- func (x *TaskFailureDetails) ProtoReflect() protoreflect.Message
- func (x *TaskFailureDetails) Reset()
- func (x *TaskFailureDetails) String() string
- type TaskHubSidecarServiceClient
- type TaskHubSidecarServiceServer
- type TaskHubSidecarService_GetWorkItemsClient
- type TaskHubSidecarService_GetWorkItemsServer
- type TaskRouter
- func (*TaskRouter) Descriptor() ([]byte, []int)deprecated
- func (x *TaskRouter) GetSourceAppID() string
- func (x *TaskRouter) GetTargetAppID() string
- func (x *TaskRouter) GetTargetAppNamespace() string
- func (*TaskRouter) ProtoMessage()
- func (x *TaskRouter) ProtoReflect() protoreflect.Message
- func (x *TaskRouter) Reset()
- func (x *TaskRouter) String() string
- type TaskScheduledEvent
- func (*TaskScheduledEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TaskScheduledEvent) GetHistoryPropagationScope() HistoryPropagationScope
- func (x *TaskScheduledEvent) GetInput() *wrapperspb.StringValue
- func (x *TaskScheduledEvent) GetName() string
- func (x *TaskScheduledEvent) GetParentTraceContext() *TraceContext
- func (x *TaskScheduledEvent) GetTaskExecutionId() string
- func (x *TaskScheduledEvent) GetVersion() *wrapperspb.StringValue
- func (*TaskScheduledEvent) ProtoMessage()
- func (x *TaskScheduledEvent) ProtoReflect() protoreflect.Message
- func (x *TaskScheduledEvent) Reset()
- func (x *TaskScheduledEvent) String() string
- type TerminateOrchestrationActiondeprecated
- type TerminateRequest
- func (*TerminateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TerminateRequest) GetInstanceId() string
- func (x *TerminateRequest) GetOutput() *wrapperspb.StringValue
- func (x *TerminateRequest) GetRecursive() bool
- func (x *TerminateRequest) GetRouter() *TaskRouter
- func (*TerminateRequest) ProtoMessage()
- func (x *TerminateRequest) ProtoReflect() protoreflect.Message
- func (x *TerminateRequest) Reset()
- func (x *TerminateRequest) String() string
- type TerminateResponse
- type TerminateWorkflowAction
- func (*TerminateWorkflowAction) Descriptor() ([]byte, []int)deprecated
- func (x *TerminateWorkflowAction) GetInstanceId() string
- func (x *TerminateWorkflowAction) GetReason() *wrapperspb.StringValue
- func (x *TerminateWorkflowAction) GetRecurse() bool
- func (*TerminateWorkflowAction) ProtoMessage()
- func (x *TerminateWorkflowAction) ProtoReflect() protoreflect.Message
- func (x *TerminateWorkflowAction) Reset()
- func (x *TerminateWorkflowAction) String() string
- type TimerCreatedEvent
- func (*TimerCreatedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TimerCreatedEvent) GetActivityRetry() *TimerOriginActivityRetry
- func (x *TimerCreatedEvent) GetChildWorkflowRetry() *TimerOriginChildWorkflowRetry
- func (x *TimerCreatedEvent) GetCreateTimer() *TimerOriginCreateTimer
- func (x *TimerCreatedEvent) GetExternalEvent() *TimerOriginExternalEvent
- func (x *TimerCreatedEvent) GetFireAt() *timestamppb.Timestamp
- func (x *TimerCreatedEvent) GetName() string
- func (m *TimerCreatedEvent) GetOrigin() isTimerCreatedEvent_Origin
- func (*TimerCreatedEvent) ProtoMessage()
- func (x *TimerCreatedEvent) ProtoReflect() protoreflect.Message
- func (x *TimerCreatedEvent) Reset()
- func (x *TimerCreatedEvent) String() string
- type TimerCreatedEvent_ActivityRetry
- type TimerCreatedEvent_ChildWorkflowRetry
- type TimerCreatedEvent_CreateTimer
- type TimerCreatedEvent_ExternalEvent
- type TimerFiredEvent
- func (*TimerFiredEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TimerFiredEvent) GetFireAt() *timestamppb.Timestamp
- func (x *TimerFiredEvent) GetTimerId() int32
- func (*TimerFiredEvent) ProtoMessage()
- func (x *TimerFiredEvent) ProtoReflect() protoreflect.Message
- func (x *TimerFiredEvent) Reset()
- func (x *TimerFiredEvent) String() string
- type TimerOriginActivityRetry
- func (*TimerOriginActivityRetry) Descriptor() ([]byte, []int)deprecated
- func (x *TimerOriginActivityRetry) GetTaskExecutionId() string
- func (*TimerOriginActivityRetry) ProtoMessage()
- func (x *TimerOriginActivityRetry) ProtoReflect() protoreflect.Message
- func (x *TimerOriginActivityRetry) Reset()
- func (x *TimerOriginActivityRetry) String() string
- type TimerOriginChildWorkflowRetry
- func (*TimerOriginChildWorkflowRetry) Descriptor() ([]byte, []int)deprecated
- func (x *TimerOriginChildWorkflowRetry) GetInstanceId() string
- func (*TimerOriginChildWorkflowRetry) ProtoMessage()
- func (x *TimerOriginChildWorkflowRetry) ProtoReflect() protoreflect.Message
- func (x *TimerOriginChildWorkflowRetry) Reset()
- func (x *TimerOriginChildWorkflowRetry) String() string
- type TimerOriginCreateTimer
- type TimerOriginExternalEvent
- func (*TimerOriginExternalEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TimerOriginExternalEvent) GetName() string
- func (*TimerOriginExternalEvent) ProtoMessage()
- func (x *TimerOriginExternalEvent) ProtoReflect() protoreflect.Message
- func (x *TimerOriginExternalEvent) Reset()
- func (x *TimerOriginExternalEvent) String() string
- type TraceContext
- func (*TraceContext) Descriptor() ([]byte, []int)deprecated
- func (x *TraceContext) GetSpanID() stringdeprecated
- func (x *TraceContext) GetTraceParent() string
- func (x *TraceContext) GetTraceState() *wrapperspb.StringValue
- func (*TraceContext) ProtoMessage()
- func (x *TraceContext) ProtoReflect() protoreflect.Message
- func (x *TraceContext) Reset()
- func (x *TraceContext) String() string
- type UnimplementedTaskHubSidecarServiceServer
- func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask(context.Context, *ActivityResponse) (*CompleteTaskResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) CompleteOrchestratorTask(context.Context, *WorkflowResponse) (*CompleteTaskResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) CompleteWorkflowTask(context.Context, *WorkflowResponse) (*CompleteTaskResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) GetInstanceHistory(context.Context, *GetInstanceHistoryRequest) (*GetInstanceHistoryResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems(*GetWorkItemsRequest, TaskHubSidecarService_GetWorkItemsServer) error
- func (UnimplementedTaskHubSidecarServiceServer) Hello(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
- func (UnimplementedTaskHubSidecarServiceServer) ListInstanceIDs(context.Context, *ListInstanceIDsRequest) (*ListInstanceIDsResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) RaiseEvent(context.Context, *RaiseEventRequest) (*RaiseEventResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) ResumeInstance(context.Context, *ResumeRequest) (*ResumeResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) StartInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) SuspendInstance(context.Context, *SuspendRequest) (*SuspendResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) TerminateInstance(context.Context, *TerminateRequest) (*TerminateResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceCompletion(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
- func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceStart(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
- type UnsafeTaskHubSidecarServiceServer
- type WorkItem
- func (*WorkItem) Descriptor() ([]byte, []int)deprecated
- func (x *WorkItem) GetActivityRequest() *ActivityRequest
- func (x *WorkItem) GetCompletionToken() string
- func (x *WorkItem) GetOrchestratorRequest() *WorkflowRequestdeprecated
- func (m *WorkItem) GetRequest() isWorkItem_Request
- func (x *WorkItem) GetWorkflowRequest() *WorkflowRequest
- func (*WorkItem) ProtoMessage()
- func (x *WorkItem) ProtoReflect() protoreflect.Message
- func (x *WorkItem) Reset()
- func (x *WorkItem) String() string
- type WorkItem_ActivityRequest
- type WorkItem_OrchestratorRequestdeprecated
- type WorkItem_WorkflowRequest
- type WorkerCapability
- func (WorkerCapability) Descriptor() protoreflect.EnumDescriptor
- func (x WorkerCapability) Enum() *WorkerCapability
- func (WorkerCapability) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkerCapability) Number() protoreflect.EnumNumber
- func (x WorkerCapability) String() string
- func (WorkerCapability) Type() protoreflect.EnumType
- type WorkflowAction
- func (*WorkflowAction) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowAction) GetCompleteOrchestration() *CompleteWorkflowActiondeprecated
- func (x *WorkflowAction) GetCompleteWorkflow() *CompleteWorkflowAction
- func (x *WorkflowAction) GetCreateChildWorkflow() *CreateChildWorkflowAction
- func (x *WorkflowAction) GetCreateDetachedWorkflow() *CreateDetachedWorkflowAction
- func (x *WorkflowAction) GetCreateSubOrchestration() *CreateChildWorkflowActiondeprecated
- func (x *WorkflowAction) GetCreateTimer() *CreateTimerAction
- func (x *WorkflowAction) GetId() int32
- func (x *WorkflowAction) GetOrchestratorVersionNotAvailable() *WorkflowVersionNotAvailableActiondeprecated
- func (x *WorkflowAction) GetRouter() *TaskRouter
- func (x *WorkflowAction) GetScheduleTask() *ScheduleTaskAction
- func (x *WorkflowAction) GetSendEvent() *SendEventAction
- func (x *WorkflowAction) GetTerminateOrchestration() *TerminateWorkflowActiondeprecated
- func (x *WorkflowAction) GetTerminateWorkflow() *TerminateWorkflowAction
- func (m *WorkflowAction) GetWorkflowActionType() isWorkflowAction_WorkflowActionType
- func (x *WorkflowAction) GetWorkflowVersionNotAvailable() *WorkflowVersionNotAvailableAction
- func (*WorkflowAction) ProtoMessage()
- func (x *WorkflowAction) ProtoReflect() protoreflect.Message
- func (x *WorkflowAction) Reset()
- func (x *WorkflowAction) String() string
- type WorkflowAction_CompleteWorkflow
- type WorkflowAction_CreateChildWorkflow
- type WorkflowAction_CreateDetachedWorkflow
- type WorkflowAction_CreateTimer
- type WorkflowAction_ScheduleTask
- type WorkflowAction_SendEvent
- type WorkflowAction_TerminateWorkflow
- type WorkflowAction_WorkflowVersionNotAvailable
- type WorkflowCompletedEvent
- type WorkflowInstance
- func (*WorkflowInstance) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowInstance) GetExecutionId() *wrapperspb.StringValue
- func (x *WorkflowInstance) GetInstanceId() string
- func (*WorkflowInstance) ProtoMessage()
- func (x *WorkflowInstance) ProtoReflect() protoreflect.Message
- func (x *WorkflowInstance) Reset()
- func (x *WorkflowInstance) String() string
- type WorkflowMessage
- func (*WorkflowMessage) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowMessage) GetEvent() *HistoryEvent
- func (x *WorkflowMessage) GetInstance() *WorkflowInstance
- func (*WorkflowMessage) ProtoMessage()
- func (x *WorkflowMessage) ProtoReflect() protoreflect.Message
- func (x *WorkflowMessage) Reset()
- func (x *WorkflowMessage) String() string
- type WorkflowMetadata
- func (*WorkflowMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowMetadata) GetCompletedAt() *timestamppb.Timestamp
- func (x *WorkflowMetadata) GetCreatedAt() *timestamppb.Timestamp
- func (x *WorkflowMetadata) GetCustomStatus() *wrapperspb.StringValue
- func (x *WorkflowMetadata) GetFailureDetails() *TaskFailureDetails
- func (x *WorkflowMetadata) GetInput() *wrapperspb.StringValue
- func (x *WorkflowMetadata) GetInstanceId() string
- func (x *WorkflowMetadata) GetLastUpdatedAt() *timestamppb.Timestamp
- func (x *WorkflowMetadata) GetName() string
- func (x *WorkflowMetadata) GetOutput() *wrapperspb.StringValue
- func (x *WorkflowMetadata) GetParentAppId() *wrapperspb.StringValue
- func (x *WorkflowMetadata) GetParentInstanceId() string
- func (x *WorkflowMetadata) GetRuntimeStatus() OrchestrationStatus
- func (x *WorkflowMetadata) GetStartedAt() *timestamppb.Timestamp
- func (x *WorkflowMetadata) GetVersion() *wrapperspb.StringValue
- func (*WorkflowMetadata) ProtoMessage()
- func (x *WorkflowMetadata) ProtoReflect() protoreflect.Message
- func (x *WorkflowMetadata) Reset()
- func (x *WorkflowMetadata) String() string
- type WorkflowRequest
- func (*WorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowRequest) GetCachedHistory() *CachedHistory
- func (x *WorkflowRequest) GetExecutionId() *wrapperspb.StringValue
- func (x *WorkflowRequest) GetInstanceId() string
- func (x *WorkflowRequest) GetNewEvents() []*HistoryEvent
- func (x *WorkflowRequest) GetPastEvents() []*HistoryEvent
- func (x *WorkflowRequest) GetPropagatedHistory() *PropagatedHistory
- func (x *WorkflowRequest) GetRequiresHistoryStreaming() bool
- func (x *WorkflowRequest) GetRouter() *TaskRouter
- func (*WorkflowRequest) ProtoMessage()
- func (x *WorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *WorkflowRequest) Reset()
- func (x *WorkflowRequest) String() string
- type WorkflowResponse
- func (*WorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowResponse) GetActions() []*WorkflowAction
- func (x *WorkflowResponse) GetCompletionToken() string
- func (x *WorkflowResponse) GetCustomStatus() *wrapperspb.StringValue
- func (x *WorkflowResponse) GetInstanceId() string
- func (x *WorkflowResponse) GetNumEventsProcessed() *wrapperspb.Int32Value
- func (x *WorkflowResponse) GetVersion() *WorkflowVersion
- func (*WorkflowResponse) ProtoMessage()
- func (x *WorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *WorkflowResponse) Reset()
- func (x *WorkflowResponse) String() string
- type WorkflowRuntimeState
- func (*WorkflowRuntimeState) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowRuntimeState) GetCompletedEvent() *ExecutionCompletedEvent
- func (x *WorkflowRuntimeState) GetCompletedTime() *timestamppb.Timestamp
- func (x *WorkflowRuntimeState) GetContinuedAsNew() bool
- func (x *WorkflowRuntimeState) GetCreatedTime() *timestamppb.Timestamp
- func (x *WorkflowRuntimeState) GetCustomStatus() *wrapperspb.StringValue
- func (x *WorkflowRuntimeState) GetInstanceId() string
- func (x *WorkflowRuntimeState) GetIsSuspended() bool
- func (x *WorkflowRuntimeState) GetLastUpdatedTime() *timestamppb.Timestamp
- func (x *WorkflowRuntimeState) GetNewEvents() []*HistoryEvent
- func (x *WorkflowRuntimeState) GetOldEvents() []*HistoryEvent
- func (x *WorkflowRuntimeState) GetPendingMessages() []*WorkflowRuntimeStateMessage
- func (x *WorkflowRuntimeState) GetPendingTasks() []*HistoryEvent
- func (x *WorkflowRuntimeState) GetPendingTimers() []*HistoryEvent
- func (x *WorkflowRuntimeState) GetStalled() *RuntimeStateStalled
- func (x *WorkflowRuntimeState) GetStartEvent() *ExecutionStartedEvent
- func (*WorkflowRuntimeState) ProtoMessage()
- func (x *WorkflowRuntimeState) ProtoReflect() protoreflect.Message
- func (x *WorkflowRuntimeState) Reset()
- func (x *WorkflowRuntimeState) String() string
- type WorkflowRuntimeStateMessage
- func (*WorkflowRuntimeStateMessage) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowRuntimeStateMessage) GetHistoryEvent() *HistoryEvent
- func (x *WorkflowRuntimeStateMessage) GetPropagatedHistory() *PropagatedHistory
- func (x *WorkflowRuntimeStateMessage) GetTargetInstanceId() string
- func (*WorkflowRuntimeStateMessage) ProtoMessage()
- func (x *WorkflowRuntimeStateMessage) ProtoReflect() protoreflect.Message
- func (x *WorkflowRuntimeStateMessage) Reset()
- func (x *WorkflowRuntimeStateMessage) String() string
- type WorkflowStartedEvent
- func (*WorkflowStartedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowStartedEvent) GetVersion() *WorkflowVersion
- func (*WorkflowStartedEvent) ProtoMessage()
- func (x *WorkflowStartedEvent) ProtoReflect() protoreflect.Message
- func (x *WorkflowStartedEvent) Reset()
- func (x *WorkflowStartedEvent) String() string
- type WorkflowState
- func (*WorkflowState) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowState) GetCompletedTimestamp() *timestamppb.Timestamp
- func (x *WorkflowState) GetCreatedTimestamp() *timestamppb.Timestamp
- func (x *WorkflowState) GetCustomStatus() *wrapperspb.StringValue
- func (x *WorkflowState) GetExecutionId() *wrapperspb.StringValue
- func (x *WorkflowState) GetFailureDetails() *TaskFailureDetails
- func (x *WorkflowState) GetInput() *wrapperspb.StringValue
- func (x *WorkflowState) GetInstanceId() string
- func (x *WorkflowState) GetLastUpdatedTimestamp() *timestamppb.Timestamp
- func (x *WorkflowState) GetName() string
- func (x *WorkflowState) GetOutput() *wrapperspb.StringValue
- func (x *WorkflowState) GetParentAppId() *wrapperspb.StringValue
- func (x *WorkflowState) GetParentInstanceId() *wrapperspb.StringValue
- func (x *WorkflowState) GetScheduledStartTimestamp() *timestamppb.Timestamp
- func (x *WorkflowState) GetStartedAt() *timestamppb.Timestamp
- func (x *WorkflowState) GetTags() map[string]string
- func (x *WorkflowState) GetVersion() *wrapperspb.StringValue
- func (x *WorkflowState) GetWorkflowStatus() OrchestrationStatus
- func (*WorkflowState) ProtoMessage()
- func (x *WorkflowState) ProtoReflect() protoreflect.Message
- func (x *WorkflowState) Reset()
- func (x *WorkflowState) String() string
- type WorkflowVersion
- func (*WorkflowVersion) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowVersion) GetName() string
- func (x *WorkflowVersion) GetPatches() []string
- func (*WorkflowVersion) ProtoMessage()
- func (x *WorkflowVersion) ProtoReflect() protoreflect.Message
- func (x *WorkflowVersion) Reset()
- func (x *WorkflowVersion) String() string
- type WorkflowVersionNotAvailableAction
- func (*WorkflowVersionNotAvailableAction) Descriptor() ([]byte, []int)deprecated
- func (*WorkflowVersionNotAvailableAction) ProtoMessage()
- func (x *WorkflowVersionNotAvailableAction) ProtoReflect() protoreflect.Message
- func (x *WorkflowVersionNotAvailableAction) Reset()
- func (x *WorkflowVersionNotAvailableAction) String() string
Constants ¶
const ( TaskHubSidecarService_Hello_FullMethodName = "/TaskHubSidecarService/Hello" TaskHubSidecarService_StartInstance_FullMethodName = "/TaskHubSidecarService/StartInstance" TaskHubSidecarService_GetInstance_FullMethodName = "/TaskHubSidecarService/GetInstance" TaskHubSidecarService_WaitForInstanceStart_FullMethodName = "/TaskHubSidecarService/WaitForInstanceStart" TaskHubSidecarService_WaitForInstanceCompletion_FullMethodName = "/TaskHubSidecarService/WaitForInstanceCompletion" TaskHubSidecarService_RaiseEvent_FullMethodName = "/TaskHubSidecarService/RaiseEvent" TaskHubSidecarService_TerminateInstance_FullMethodName = "/TaskHubSidecarService/TerminateInstance" TaskHubSidecarService_SuspendInstance_FullMethodName = "/TaskHubSidecarService/SuspendInstance" TaskHubSidecarService_ResumeInstance_FullMethodName = "/TaskHubSidecarService/ResumeInstance" TaskHubSidecarService_PurgeInstances_FullMethodName = "/TaskHubSidecarService/PurgeInstances" TaskHubSidecarService_GetWorkItems_FullMethodName = "/TaskHubSidecarService/GetWorkItems" TaskHubSidecarService_CompleteActivityTask_FullMethodName = "/TaskHubSidecarService/CompleteActivityTask" TaskHubSidecarService_CompleteOrchestratorTask_FullMethodName = "/TaskHubSidecarService/CompleteOrchestratorTask" TaskHubSidecarService_CompleteWorkflowTask_FullMethodName = "/TaskHubSidecarService/CompleteWorkflowTask" TaskHubSidecarService_ListInstanceIDs_FullMethodName = "/TaskHubSidecarService/ListInstanceIDs" TaskHubSidecarService_GetInstanceHistory_FullMethodName = "/TaskHubSidecarService/GetInstanceHistory" )
Variables ¶
var ( StalledReason_name = map[int32]string{ 0: "PATCH_MISMATCH", 1: "VERSION_NOT_AVAILABLE", 2: "PAYLOAD_SIZE_EXCEEDED", } StalledReason_value = map[string]int32{ "PATCH_MISMATCH": 0, "VERSION_NOT_AVAILABLE": 1, "PAYLOAD_SIZE_EXCEEDED": 2, } )
Enum value maps for StalledReason.
var ( OrchestrationStatus_name = map[int32]string{ 0: "ORCHESTRATION_STATUS_RUNNING", 1: "ORCHESTRATION_STATUS_COMPLETED", 2: "ORCHESTRATION_STATUS_CONTINUED_AS_NEW", 3: "ORCHESTRATION_STATUS_FAILED", 4: "ORCHESTRATION_STATUS_CANCELED", 5: "ORCHESTRATION_STATUS_TERMINATED", 6: "ORCHESTRATION_STATUS_PENDING", 7: "ORCHESTRATION_STATUS_SUSPENDED", 8: "ORCHESTRATION_STATUS_STALLED", } OrchestrationStatus_value = map[string]int32{ "ORCHESTRATION_STATUS_RUNNING": 0, "ORCHESTRATION_STATUS_COMPLETED": 1, "ORCHESTRATION_STATUS_CONTINUED_AS_NEW": 2, "ORCHESTRATION_STATUS_FAILED": 3, "ORCHESTRATION_STATUS_CANCELED": 4, "ORCHESTRATION_STATUS_TERMINATED": 5, "ORCHESTRATION_STATUS_PENDING": 6, "ORCHESTRATION_STATUS_SUSPENDED": 7, "ORCHESTRATION_STATUS_STALLED": 8, } )
Enum value maps for OrchestrationStatus.
var ( HistoryPropagationScope_name = map[int32]string{ 0: "HISTORY_PROPAGATION_SCOPE_NONE", 1: "HISTORY_PROPAGATION_SCOPE_OWN_HISTORY", 2: "HISTORY_PROPAGATION_SCOPE_LINEAGE", } HistoryPropagationScope_value = map[string]int32{ "HISTORY_PROPAGATION_SCOPE_NONE": 0, "HISTORY_PROPAGATION_SCOPE_OWN_HISTORY": 1, "HISTORY_PROPAGATION_SCOPE_LINEAGE": 2, } )
Enum value maps for HistoryPropagationScope.
var ( WorkerCapability_name = map[int32]string{ 0: "WORKER_CAPABILITY_UNSPECIFIED", 2: "WORKER_CAPABILITY_STATEFUL_HISTORY", } WorkerCapability_value = map[string]int32{ "WORKER_CAPABILITY_UNSPECIFIED": 0, "WORKER_CAPABILITY_STATEFUL_HISTORY": 2, } )
Enum value maps for WorkerCapability.
var File_backend_service_proto protoreflect.FileDescriptor
var File_history_events_proto protoreflect.FileDescriptor
var File_orchestration_proto protoreflect.FileDescriptor
var File_orchestrator_actions_proto protoreflect.FileDescriptor
var File_orchestrator_service_proto protoreflect.FileDescriptor
var File_runtime_state_proto protoreflect.FileDescriptor
var TaskHubSidecarService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "TaskHubSidecarService", HandlerType: (*TaskHubSidecarServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Hello", Handler: _TaskHubSidecarService_Hello_Handler, }, { MethodName: "StartInstance", Handler: _TaskHubSidecarService_StartInstance_Handler, }, { MethodName: "GetInstance", Handler: _TaskHubSidecarService_GetInstance_Handler, }, { MethodName: "WaitForInstanceStart", Handler: _TaskHubSidecarService_WaitForInstanceStart_Handler, }, { MethodName: "WaitForInstanceCompletion", Handler: _TaskHubSidecarService_WaitForInstanceCompletion_Handler, }, { MethodName: "RaiseEvent", Handler: _TaskHubSidecarService_RaiseEvent_Handler, }, { MethodName: "TerminateInstance", Handler: _TaskHubSidecarService_TerminateInstance_Handler, }, { MethodName: "SuspendInstance", Handler: _TaskHubSidecarService_SuspendInstance_Handler, }, { MethodName: "ResumeInstance", Handler: _TaskHubSidecarService_ResumeInstance_Handler, }, { MethodName: "PurgeInstances", Handler: _TaskHubSidecarService_PurgeInstances_Handler, }, { MethodName: "CompleteActivityTask", Handler: _TaskHubSidecarService_CompleteActivityTask_Handler, }, { MethodName: "CompleteOrchestratorTask", Handler: _TaskHubSidecarService_CompleteOrchestratorTask_Handler, }, { MethodName: "CompleteWorkflowTask", Handler: _TaskHubSidecarService_CompleteWorkflowTask_Handler, }, { MethodName: "ListInstanceIDs", Handler: _TaskHubSidecarService_ListInstanceIDs_Handler, }, { MethodName: "GetInstanceHistory", Handler: _TaskHubSidecarService_GetInstanceHistory_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetWorkItems", Handler: _TaskHubSidecarService_GetWorkItems_Handler, ServerStreams: true, }, }, Metadata: "orchestrator_service.proto", }
TaskHubSidecarService_ServiceDesc is the grpc.ServiceDesc for TaskHubSidecarService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTaskHubSidecarServiceServer ¶
func RegisterTaskHubSidecarServiceServer(s grpc.ServiceRegistrar, srv TaskHubSidecarServiceServer)
Types ¶
type ActivityInvocation ¶
type ActivityInvocation struct {
HistoryEvent *HistoryEvent `protobuf:"bytes,1,opt,name=historyEvent,proto3" json:"historyEvent,omitempty"`
// Propagated history from the calling workflow.
PropagatedHistory *PropagatedHistory `protobuf:"bytes,2,opt,name=propagatedHistory,proto3,oneof" json:"propagatedHistory,omitempty"`
// contains filtered or unexported fields
}
ActivityInvocation wraps a TaskScheduled HistoryEvent with optional propagated history for delivery to an activity actor.
func (*ActivityInvocation) Descriptor
deprecated
func (*ActivityInvocation) Descriptor() ([]byte, []int)
Deprecated: Use ActivityInvocation.ProtoReflect.Descriptor instead.
func (*ActivityInvocation) GetHistoryEvent ¶
func (x *ActivityInvocation) GetHistoryEvent() *HistoryEvent
func (*ActivityInvocation) GetPropagatedHistory ¶
func (x *ActivityInvocation) GetPropagatedHistory() *PropagatedHistory
func (*ActivityInvocation) ProtoMessage ¶
func (*ActivityInvocation) ProtoMessage()
func (*ActivityInvocation) ProtoReflect ¶
func (x *ActivityInvocation) ProtoReflect() protoreflect.Message
func (*ActivityInvocation) Reset ¶
func (x *ActivityInvocation) Reset()
func (*ActivityInvocation) String ¶
func (x *ActivityInvocation) String() string
type ActivityRequest ¶
type ActivityRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Version *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
WorkflowInstance *WorkflowInstance `protobuf:"bytes,4,opt,name=workflowInstance,proto3" json:"workflowInstance,omitempty"`
TaskId int32 `protobuf:"varint,5,opt,name=taskId,proto3" json:"taskId,omitempty"`
ParentTraceContext *TraceContext `protobuf:"bytes,6,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
TaskExecutionId string `protobuf:"bytes,7,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
// Propagated history from the calling workflow.
// Delivered via the work item stream to the SDK, so that the
// activity function can access it via ctx.
PropagatedHistory *PropagatedHistory `protobuf:"bytes,8,opt,name=propagatedHistory,proto3,oneof" json:"propagatedHistory,omitempty"`
// contains filtered or unexported fields
}
func (*ActivityRequest) Descriptor
deprecated
func (*ActivityRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActivityRequest.ProtoReflect.Descriptor instead.
func (*ActivityRequest) GetInput ¶
func (x *ActivityRequest) GetInput() *wrapperspb.StringValue
func (*ActivityRequest) GetName ¶
func (x *ActivityRequest) GetName() string
func (*ActivityRequest) GetParentTraceContext ¶
func (x *ActivityRequest) GetParentTraceContext() *TraceContext
func (*ActivityRequest) GetPropagatedHistory ¶
func (x *ActivityRequest) GetPropagatedHistory() *PropagatedHistory
func (*ActivityRequest) GetTaskExecutionId ¶
func (x *ActivityRequest) GetTaskExecutionId() string
func (*ActivityRequest) GetTaskId ¶
func (x *ActivityRequest) GetTaskId() int32
func (*ActivityRequest) GetVersion ¶
func (x *ActivityRequest) GetVersion() *wrapperspb.StringValue
func (*ActivityRequest) GetWorkflowInstance ¶
func (x *ActivityRequest) GetWorkflowInstance() *WorkflowInstance
func (*ActivityRequest) ProtoMessage ¶
func (*ActivityRequest) ProtoMessage()
func (*ActivityRequest) ProtoReflect ¶
func (x *ActivityRequest) ProtoReflect() protoreflect.Message
func (*ActivityRequest) Reset ¶
func (x *ActivityRequest) Reset()
func (*ActivityRequest) String ¶
func (x *ActivityRequest) String() string
type ActivityResponse ¶
type ActivityResponse struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
TaskId int32 `protobuf:"varint,2,opt,name=taskId,proto3" json:"taskId,omitempty"`
Result *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
FailureDetails *TaskFailureDetails `protobuf:"bytes,4,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
CompletionToken string `protobuf:"bytes,5,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
// contains filtered or unexported fields
}
func (*ActivityResponse) Descriptor
deprecated
func (*ActivityResponse) Descriptor() ([]byte, []int)
Deprecated: Use ActivityResponse.ProtoReflect.Descriptor instead.
func (*ActivityResponse) GetCompletionToken ¶
func (x *ActivityResponse) GetCompletionToken() string
func (*ActivityResponse) GetFailureDetails ¶
func (x *ActivityResponse) GetFailureDetails() *TaskFailureDetails
func (*ActivityResponse) GetInstanceId ¶
func (x *ActivityResponse) GetInstanceId() string
func (*ActivityResponse) GetResult ¶
func (x *ActivityResponse) GetResult() *wrapperspb.StringValue
func (*ActivityResponse) GetTaskId ¶
func (x *ActivityResponse) GetTaskId() int32
func (*ActivityResponse) ProtoMessage ¶
func (*ActivityResponse) ProtoMessage()
func (*ActivityResponse) ProtoReflect ¶
func (x *ActivityResponse) ProtoReflect() protoreflect.Message
func (*ActivityResponse) Reset ¶
func (x *ActivityResponse) Reset()
func (*ActivityResponse) String ¶
func (x *ActivityResponse) String() string
type AddEventRequest ¶
type AddEventRequest struct {
// The ID of the workflow to send an event to.
Instance *WorkflowInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
// The event to send to the workflow.
Event *HistoryEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
// contains filtered or unexported fields
}
Request payload for adding new workflow events.
func (*AddEventRequest) Descriptor
deprecated
func (*AddEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddEventRequest.ProtoReflect.Descriptor instead.
func (*AddEventRequest) GetEvent ¶
func (x *AddEventRequest) GetEvent() *HistoryEvent
func (*AddEventRequest) GetInstance ¶
func (x *AddEventRequest) GetInstance() *WorkflowInstance
func (*AddEventRequest) ProtoMessage ¶
func (*AddEventRequest) ProtoMessage()
func (*AddEventRequest) ProtoReflect ¶
func (x *AddEventRequest) ProtoReflect() protoreflect.Message
func (*AddEventRequest) Reset ¶
func (x *AddEventRequest) Reset()
func (*AddEventRequest) String ¶
func (x *AddEventRequest) String() string
type AddEventResponse ¶
type AddEventResponse struct {
// contains filtered or unexported fields
}
Response payload for adding new workflow events.
func (*AddEventResponse) Descriptor
deprecated
func (*AddEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddEventResponse.ProtoReflect.Descriptor instead.
func (*AddEventResponse) ProtoMessage ¶
func (*AddEventResponse) ProtoMessage()
func (*AddEventResponse) ProtoReflect ¶
func (x *AddEventResponse) ProtoReflect() protoreflect.Message
func (*AddEventResponse) Reset ¶
func (x *AddEventResponse) Reset()
func (*AddEventResponse) String ¶
func (x *AddEventResponse) String() string
type BackendWorkflowState ¶
type BackendWorkflowState struct {
Inbox []*HistoryEvent `protobuf:"bytes,1,rep,name=inbox,proto3" json:"inbox,omitempty"`
History []*HistoryEvent `protobuf:"bytes,2,rep,name=history,proto3" json:"history,omitempty"`
CustomStatus *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
Generation uint64 `protobuf:"varint,4,opt,name=generation,proto3" json:"generation,omitempty"`
// contains filtered or unexported fields
}
func (*BackendWorkflowState) Descriptor
deprecated
func (*BackendWorkflowState) Descriptor() ([]byte, []int)
Deprecated: Use BackendWorkflowState.ProtoReflect.Descriptor instead.
func (*BackendWorkflowState) GetCustomStatus ¶
func (x *BackendWorkflowState) GetCustomStatus() *wrapperspb.StringValue
func (*BackendWorkflowState) GetGeneration ¶
func (x *BackendWorkflowState) GetGeneration() uint64
func (*BackendWorkflowState) GetHistory ¶
func (x *BackendWorkflowState) GetHistory() []*HistoryEvent
func (*BackendWorkflowState) GetInbox ¶
func (x *BackendWorkflowState) GetInbox() []*HistoryEvent
func (*BackendWorkflowState) ProtoMessage ¶
func (*BackendWorkflowState) ProtoMessage()
func (*BackendWorkflowState) ProtoReflect ¶
func (x *BackendWorkflowState) ProtoReflect() protoreflect.Message
func (*BackendWorkflowState) Reset ¶
func (x *BackendWorkflowState) Reset()
func (*BackendWorkflowState) String ¶
func (x *BackendWorkflowState) String() string
type BackendWorkflowStateMetadata ¶
type BackendWorkflowStateMetadata struct {
InboxLength uint64 `protobuf:"varint,1,opt,name=inboxLength,proto3" json:"inboxLength,omitempty"`
HistoryLength uint64 `protobuf:"varint,2,opt,name=historyLength,proto3" json:"historyLength,omitempty"`
Generation uint64 `protobuf:"varint,3,opt,name=generation,proto3" json:"generation,omitempty"`
// contains filtered or unexported fields
}
func (*BackendWorkflowStateMetadata) Descriptor
deprecated
func (*BackendWorkflowStateMetadata) Descriptor() ([]byte, []int)
Deprecated: Use BackendWorkflowStateMetadata.ProtoReflect.Descriptor instead.
func (*BackendWorkflowStateMetadata) GetGeneration ¶
func (x *BackendWorkflowStateMetadata) GetGeneration() uint64
func (*BackendWorkflowStateMetadata) GetHistoryLength ¶
func (x *BackendWorkflowStateMetadata) GetHistoryLength() uint64
func (*BackendWorkflowStateMetadata) GetInboxLength ¶
func (x *BackendWorkflowStateMetadata) GetInboxLength() uint64
func (*BackendWorkflowStateMetadata) ProtoMessage ¶
func (*BackendWorkflowStateMetadata) ProtoMessage()
func (*BackendWorkflowStateMetadata) ProtoReflect ¶
func (x *BackendWorkflowStateMetadata) ProtoReflect() protoreflect.Message
func (*BackendWorkflowStateMetadata) Reset ¶
func (x *BackendWorkflowStateMetadata) Reset()
func (*BackendWorkflowStateMetadata) String ¶
func (x *BackendWorkflowStateMetadata) String() string
type CachedHistory ¶
type CachedHistory struct {
// eventCount is the number of leading (committed) history events the
// service believes the worker already holds, i.e. the length of the prefix
// omitted from pastEvents. The worker's cached prefix must contain exactly
// this many events; if it does not, the worker must treat this as a cache
// miss and fetch the full history via GetInstanceHistory before applying
// newEvents.
EventCount int32 `protobuf:"varint,1,opt,name=eventCount,proto3" json:"eventCount,omitempty"`
// contains filtered or unexported fields
}
CachedHistory is set on a WorkflowRequest when the service has intentionally omitted the committed history prefix the worker is expected to already hold for this instance from a previous turn on the same stream (see WORKER_CAPABILITY_STATEFUL_HISTORY). Its presence means pastEvents carries only the delta since the worker was last brought up to date; its absence means pastEvents is the full committed history. The worker reconstructs the full past history by prepending its cached events to pastEvents. The service only sets this for workers that advertised WORKER_CAPABILITY_STATEFUL_HISTORY and that it believes to be warm for the instance, so it is always safe for a worker to fall back to the GetInstanceHistory RPC.
func (*CachedHistory) Descriptor
deprecated
func (*CachedHistory) Descriptor() ([]byte, []int)
Deprecated: Use CachedHistory.ProtoReflect.Descriptor instead.
func (*CachedHistory) GetEventCount ¶
func (x *CachedHistory) GetEventCount() int32
func (*CachedHistory) ProtoMessage ¶
func (*CachedHistory) ProtoMessage()
func (*CachedHistory) ProtoReflect ¶
func (x *CachedHistory) ProtoReflect() protoreflect.Message
func (*CachedHistory) Reset ¶
func (x *CachedHistory) Reset()
func (*CachedHistory) String ¶
func (x *CachedHistory) String() string
type ChildWorkflowInstanceCompletedEvent ¶
type ChildWorkflowInstanceCompletedEvent struct {
TaskScheduledId int32 `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
Result *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
// contains filtered or unexported fields
}
func (*ChildWorkflowInstanceCompletedEvent) Descriptor
deprecated
func (*ChildWorkflowInstanceCompletedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowInstanceCompletedEvent.ProtoReflect.Descriptor instead.
func (*ChildWorkflowInstanceCompletedEvent) GetResult ¶
func (x *ChildWorkflowInstanceCompletedEvent) GetResult() *wrapperspb.StringValue
func (*ChildWorkflowInstanceCompletedEvent) GetTaskScheduledId ¶
func (x *ChildWorkflowInstanceCompletedEvent) GetTaskScheduledId() int32
func (*ChildWorkflowInstanceCompletedEvent) ProtoMessage ¶
func (*ChildWorkflowInstanceCompletedEvent) ProtoMessage()
func (*ChildWorkflowInstanceCompletedEvent) ProtoReflect ¶
func (x *ChildWorkflowInstanceCompletedEvent) ProtoReflect() protoreflect.Message
func (*ChildWorkflowInstanceCompletedEvent) Reset ¶
func (x *ChildWorkflowInstanceCompletedEvent) Reset()
func (*ChildWorkflowInstanceCompletedEvent) String ¶
func (x *ChildWorkflowInstanceCompletedEvent) String() string
type ChildWorkflowInstanceCreatedEvent ¶
type ChildWorkflowInstanceCreatedEvent struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Version *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
ParentTraceContext *TraceContext `protobuf:"bytes,5,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
// History propagation scope used when this child workflow was originally
// scheduled. Persisted on the event so rerun can re-issue the child with
// the same scope after the action has been discarded.
HistoryPropagationScope *HistoryPropagationScope `` /* 135-byte string literal not displayed */
// If defined, indicates that this child workflow is a retry attempt and
// links it back to the first attempt in the retry chain. Absent on the
// first attempt. Consumers correlate retry attempts by grouping on
// retryParentInstanceInfo.instanceID when present, otherwise on this
// event's own instanceId.
RetryParentInstanceInfo *RetryParentInstanceInfo `protobuf:"bytes,8,opt,name=retryParentInstanceInfo,proto3,oneof" json:"retryParentInstanceInfo,omitempty"`
// contains filtered or unexported fields
}
func (*ChildWorkflowInstanceCreatedEvent) Descriptor
deprecated
func (*ChildWorkflowInstanceCreatedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowInstanceCreatedEvent.ProtoReflect.Descriptor instead.
func (*ChildWorkflowInstanceCreatedEvent) GetHistoryPropagationScope ¶
func (x *ChildWorkflowInstanceCreatedEvent) GetHistoryPropagationScope() HistoryPropagationScope
func (*ChildWorkflowInstanceCreatedEvent) GetInput ¶
func (x *ChildWorkflowInstanceCreatedEvent) GetInput() *wrapperspb.StringValue
func (*ChildWorkflowInstanceCreatedEvent) GetInstanceId ¶
func (x *ChildWorkflowInstanceCreatedEvent) GetInstanceId() string
func (*ChildWorkflowInstanceCreatedEvent) GetName ¶
func (x *ChildWorkflowInstanceCreatedEvent) GetName() string
func (*ChildWorkflowInstanceCreatedEvent) GetParentTraceContext ¶
func (x *ChildWorkflowInstanceCreatedEvent) GetParentTraceContext() *TraceContext
func (*ChildWorkflowInstanceCreatedEvent) GetRetryParentInstanceInfo ¶
func (x *ChildWorkflowInstanceCreatedEvent) GetRetryParentInstanceInfo() *RetryParentInstanceInfo
func (*ChildWorkflowInstanceCreatedEvent) GetVersion ¶
func (x *ChildWorkflowInstanceCreatedEvent) GetVersion() *wrapperspb.StringValue
func (*ChildWorkflowInstanceCreatedEvent) ProtoMessage ¶
func (*ChildWorkflowInstanceCreatedEvent) ProtoMessage()
func (*ChildWorkflowInstanceCreatedEvent) ProtoReflect ¶
func (x *ChildWorkflowInstanceCreatedEvent) ProtoReflect() protoreflect.Message
func (*ChildWorkflowInstanceCreatedEvent) Reset ¶
func (x *ChildWorkflowInstanceCreatedEvent) Reset()
func (*ChildWorkflowInstanceCreatedEvent) String ¶
func (x *ChildWorkflowInstanceCreatedEvent) String() string
type ChildWorkflowInstanceFailedEvent ¶
type ChildWorkflowInstanceFailedEvent struct {
TaskScheduledId int32 `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
FailureDetails *TaskFailureDetails `protobuf:"bytes,2,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
// contains filtered or unexported fields
}
func (*ChildWorkflowInstanceFailedEvent) Descriptor
deprecated
func (*ChildWorkflowInstanceFailedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowInstanceFailedEvent.ProtoReflect.Descriptor instead.
func (*ChildWorkflowInstanceFailedEvent) GetFailureDetails ¶
func (x *ChildWorkflowInstanceFailedEvent) GetFailureDetails() *TaskFailureDetails
func (*ChildWorkflowInstanceFailedEvent) GetTaskScheduledId ¶
func (x *ChildWorkflowInstanceFailedEvent) GetTaskScheduledId() int32
func (*ChildWorkflowInstanceFailedEvent) ProtoMessage ¶
func (*ChildWorkflowInstanceFailedEvent) ProtoMessage()
func (*ChildWorkflowInstanceFailedEvent) ProtoReflect ¶
func (x *ChildWorkflowInstanceFailedEvent) ProtoReflect() protoreflect.Message
func (*ChildWorkflowInstanceFailedEvent) Reset ¶
func (x *ChildWorkflowInstanceFailedEvent) Reset()
func (*ChildWorkflowInstanceFailedEvent) String ¶
func (x *ChildWorkflowInstanceFailedEvent) String() string
type CompleteActivityWorkItemRequest ¶
type CompleteActivityWorkItemRequest struct {
// The completion token that was provided when the work item was fetched.
CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
// The response event that will be sent to the workflow.
// This must be either a TaskCompleted event or a TaskFailed event.
ResponseEvent *HistoryEvent `protobuf:"bytes,2,opt,name=responseEvent,proto3" json:"responseEvent,omitempty"`
// contains filtered or unexported fields
}
Request payload for completing an activity work item.
func (*CompleteActivityWorkItemRequest) Descriptor
deprecated
func (*CompleteActivityWorkItemRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompleteActivityWorkItemRequest.ProtoReflect.Descriptor instead.
func (*CompleteActivityWorkItemRequest) GetCompletionToken ¶
func (x *CompleteActivityWorkItemRequest) GetCompletionToken() string
func (*CompleteActivityWorkItemRequest) GetResponseEvent ¶
func (x *CompleteActivityWorkItemRequest) GetResponseEvent() *HistoryEvent
func (*CompleteActivityWorkItemRequest) ProtoMessage ¶
func (*CompleteActivityWorkItemRequest) ProtoMessage()
func (*CompleteActivityWorkItemRequest) ProtoReflect ¶
func (x *CompleteActivityWorkItemRequest) ProtoReflect() protoreflect.Message
func (*CompleteActivityWorkItemRequest) Reset ¶
func (x *CompleteActivityWorkItemRequest) Reset()
func (*CompleteActivityWorkItemRequest) String ¶
func (x *CompleteActivityWorkItemRequest) String() string
type CompleteActivityWorkItemResponse ¶
type CompleteActivityWorkItemResponse struct {
// contains filtered or unexported fields
}
Response payload for completing an activity work item.
func (*CompleteActivityWorkItemResponse) Descriptor
deprecated
func (*CompleteActivityWorkItemResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompleteActivityWorkItemResponse.ProtoReflect.Descriptor instead.
func (*CompleteActivityWorkItemResponse) ProtoMessage ¶
func (*CompleteActivityWorkItemResponse) ProtoMessage()
func (*CompleteActivityWorkItemResponse) ProtoReflect ¶
func (x *CompleteActivityWorkItemResponse) ProtoReflect() protoreflect.Message
func (*CompleteActivityWorkItemResponse) Reset ¶
func (x *CompleteActivityWorkItemResponse) Reset()
func (*CompleteActivityWorkItemResponse) String ¶
func (x *CompleteActivityWorkItemResponse) String() string
type CompleteOrchestrationAction
deprecated
type CompleteOrchestrationAction = CompleteWorkflowAction
Deprecated: Use CompleteWorkflowAction instead.
type CompleteOrchestrationWorkItemRequest
deprecated
type CompleteOrchestrationWorkItemRequest = CompleteWorkflowWorkItemRequest
Deprecated: Use CompleteWorkflowWorkItemRequest instead.
type CompleteOrchestrationWorkItemResponse
deprecated
type CompleteOrchestrationWorkItemResponse = CompleteWorkflowWorkItemResponse
Deprecated: Use CompleteWorkflowWorkItemResponse instead.
type CompleteTaskResponse ¶
type CompleteTaskResponse struct {
// contains filtered or unexported fields
}
func (*CompleteTaskResponse) Descriptor
deprecated
func (*CompleteTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompleteTaskResponse.ProtoReflect.Descriptor instead.
func (*CompleteTaskResponse) ProtoMessage ¶
func (*CompleteTaskResponse) ProtoMessage()
func (*CompleteTaskResponse) ProtoReflect ¶
func (x *CompleteTaskResponse) ProtoReflect() protoreflect.Message
func (*CompleteTaskResponse) Reset ¶
func (x *CompleteTaskResponse) Reset()
func (*CompleteTaskResponse) String ¶
func (x *CompleteTaskResponse) String() string
type CompleteWorkflowAction ¶
type CompleteWorkflowAction struct {
WorkflowStatus OrchestrationStatus `protobuf:"varint,1,opt,name=workflowStatus,proto3,enum=OrchestrationStatus" json:"workflowStatus,omitempty"`
Result *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
Details *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
NewVersion *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=newVersion,proto3" json:"newVersion,omitempty"`
CarryoverEvents []*HistoryEvent `protobuf:"bytes,5,rep,name=carryoverEvents,proto3" json:"carryoverEvents,omitempty"`
FailureDetails *TaskFailureDetails `protobuf:"bytes,6,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
// contains filtered or unexported fields
}
func (*CompleteWorkflowAction) Descriptor
deprecated
func (*CompleteWorkflowAction) Descriptor() ([]byte, []int)
Deprecated: Use CompleteWorkflowAction.ProtoReflect.Descriptor instead.
func (*CompleteWorkflowAction) GetCarryoverEvents ¶
func (x *CompleteWorkflowAction) GetCarryoverEvents() []*HistoryEvent
func (*CompleteWorkflowAction) GetDetails ¶
func (x *CompleteWorkflowAction) GetDetails() *wrapperspb.StringValue
func (*CompleteWorkflowAction) GetFailureDetails ¶
func (x *CompleteWorkflowAction) GetFailureDetails() *TaskFailureDetails
func (*CompleteWorkflowAction) GetNewVersion ¶
func (x *CompleteWorkflowAction) GetNewVersion() *wrapperspb.StringValue
func (*CompleteWorkflowAction) GetOrchestrationStatus
deprecated
func (x *CompleteWorkflowAction) GetOrchestrationStatus() OrchestrationStatus
Deprecated: Use GetWorkflowStatus on CompleteWorkflowAction instead.
func (*CompleteWorkflowAction) GetResult ¶
func (x *CompleteWorkflowAction) GetResult() *wrapperspb.StringValue
func (*CompleteWorkflowAction) GetWorkflowStatus ¶
func (x *CompleteWorkflowAction) GetWorkflowStatus() OrchestrationStatus
func (*CompleteWorkflowAction) ProtoMessage ¶
func (*CompleteWorkflowAction) ProtoMessage()
func (*CompleteWorkflowAction) ProtoReflect ¶
func (x *CompleteWorkflowAction) ProtoReflect() protoreflect.Message
func (*CompleteWorkflowAction) Reset ¶
func (x *CompleteWorkflowAction) Reset()
func (*CompleteWorkflowAction) String ¶
func (x *CompleteWorkflowAction) String() string
type CompleteWorkflowWorkItemRequest ¶
type CompleteWorkflowWorkItemRequest struct {
// The completion token that was provided when the work item was fetched.
CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
Instance *WorkflowInstance `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
RuntimeStatus OrchestrationStatus `protobuf:"varint,3,opt,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
CustomStatus *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
NewHistory []*HistoryEvent `protobuf:"bytes,5,rep,name=newHistory,proto3" json:"newHistory,omitempty"`
NewTasks []*HistoryEvent `protobuf:"bytes,6,rep,name=newTasks,proto3" json:"newTasks,omitempty"`
NewTimers []*HistoryEvent `protobuf:"bytes,7,rep,name=newTimers,proto3" json:"newTimers,omitempty"`
NewMessages []*WorkflowMessage `protobuf:"bytes,8,rep,name=newMessages,proto3" json:"newMessages,omitempty"`
// The number of work item events that were processed by the workflow.
// This field is optional. If not set, the service should assume that the workflow processed all events.
NumEventsProcessed *wrapperspb.Int32Value `protobuf:"bytes,9,opt,name=numEventsProcessed,proto3" json:"numEventsProcessed,omitempty"`
// contains filtered or unexported fields
}
Request payload for completing a workflow work item.
func (*CompleteWorkflowWorkItemRequest) Descriptor
deprecated
func (*CompleteWorkflowWorkItemRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompleteWorkflowWorkItemRequest.ProtoReflect.Descriptor instead.
func (*CompleteWorkflowWorkItemRequest) GetCompletionToken ¶
func (x *CompleteWorkflowWorkItemRequest) GetCompletionToken() string
func (*CompleteWorkflowWorkItemRequest) GetCustomStatus ¶
func (x *CompleteWorkflowWorkItemRequest) GetCustomStatus() *wrapperspb.StringValue
func (*CompleteWorkflowWorkItemRequest) GetInstance ¶
func (x *CompleteWorkflowWorkItemRequest) GetInstance() *WorkflowInstance
func (*CompleteWorkflowWorkItemRequest) GetNewHistory ¶
func (x *CompleteWorkflowWorkItemRequest) GetNewHistory() []*HistoryEvent
func (*CompleteWorkflowWorkItemRequest) GetNewMessages ¶
func (x *CompleteWorkflowWorkItemRequest) GetNewMessages() []*WorkflowMessage
func (*CompleteWorkflowWorkItemRequest) GetNewTasks ¶
func (x *CompleteWorkflowWorkItemRequest) GetNewTasks() []*HistoryEvent
func (*CompleteWorkflowWorkItemRequest) GetNewTimers ¶
func (x *CompleteWorkflowWorkItemRequest) GetNewTimers() []*HistoryEvent
func (*CompleteWorkflowWorkItemRequest) GetNumEventsProcessed ¶
func (x *CompleteWorkflowWorkItemRequest) GetNumEventsProcessed() *wrapperspb.Int32Value
func (*CompleteWorkflowWorkItemRequest) GetRuntimeStatus ¶
func (x *CompleteWorkflowWorkItemRequest) GetRuntimeStatus() OrchestrationStatus
func (*CompleteWorkflowWorkItemRequest) ProtoMessage ¶
func (*CompleteWorkflowWorkItemRequest) ProtoMessage()
func (*CompleteWorkflowWorkItemRequest) ProtoReflect ¶
func (x *CompleteWorkflowWorkItemRequest) ProtoReflect() protoreflect.Message
func (*CompleteWorkflowWorkItemRequest) Reset ¶
func (x *CompleteWorkflowWorkItemRequest) Reset()
func (*CompleteWorkflowWorkItemRequest) String ¶
func (x *CompleteWorkflowWorkItemRequest) String() string
type CompleteWorkflowWorkItemResponse ¶
type CompleteWorkflowWorkItemResponse struct {
// contains filtered or unexported fields
}
Response payload for completing a workflow work item.
func (*CompleteWorkflowWorkItemResponse) Descriptor
deprecated
func (*CompleteWorkflowWorkItemResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompleteWorkflowWorkItemResponse.ProtoReflect.Descriptor instead.
func (*CompleteWorkflowWorkItemResponse) ProtoMessage ¶
func (*CompleteWorkflowWorkItemResponse) ProtoMessage()
func (*CompleteWorkflowWorkItemResponse) ProtoReflect ¶
func (x *CompleteWorkflowWorkItemResponse) ProtoReflect() protoreflect.Message
func (*CompleteWorkflowWorkItemResponse) Reset ¶
func (x *CompleteWorkflowWorkItemResponse) Reset()
func (*CompleteWorkflowWorkItemResponse) String ¶
func (x *CompleteWorkflowWorkItemResponse) String() string
type ContinueAsNewEvent ¶
type ContinueAsNewEvent struct {
Input *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
// contains filtered or unexported fields
}
func (*ContinueAsNewEvent) Descriptor
deprecated
func (*ContinueAsNewEvent) Descriptor() ([]byte, []int)
Deprecated: Use ContinueAsNewEvent.ProtoReflect.Descriptor instead.
func (*ContinueAsNewEvent) GetInput ¶
func (x *ContinueAsNewEvent) GetInput() *wrapperspb.StringValue
func (*ContinueAsNewEvent) ProtoMessage ¶
func (*ContinueAsNewEvent) ProtoMessage()
func (*ContinueAsNewEvent) ProtoReflect ¶
func (x *ContinueAsNewEvent) ProtoReflect() protoreflect.Message
func (*ContinueAsNewEvent) Reset ¶
func (x *ContinueAsNewEvent) Reset()
func (*ContinueAsNewEvent) String ¶
func (x *ContinueAsNewEvent) String() string
type CreateChildWorkflowAction ¶
type CreateChildWorkflowAction struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Version *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
// History propagation scope. Absent/SCOPE_NONE = no propagation.
HistoryPropagationScope *HistoryPropagationScope `` /* 135-byte string literal not displayed */
// If defined, indicates that this child workflow is a retry attempt and
// links it back to the first attempt in the retry chain. Absent on the
// first attempt. The runtime persists this onto the resulting
// ChildWorkflowInstanceCreatedEvent so consumers can correlate retry
// attempts by grouping on retryParentInstanceInfo.instanceID when present,
// otherwise on the created instance's own instanceId.
RetryParentInstanceInfo *RetryParentInstanceInfo `protobuf:"bytes,7,opt,name=retryParentInstanceInfo,proto3,oneof" json:"retryParentInstanceInfo,omitempty"`
// contains filtered or unexported fields
}
func (*CreateChildWorkflowAction) Descriptor
deprecated
func (*CreateChildWorkflowAction) Descriptor() ([]byte, []int)
Deprecated: Use CreateChildWorkflowAction.ProtoReflect.Descriptor instead.
func (*CreateChildWorkflowAction) GetHistoryPropagationScope ¶
func (x *CreateChildWorkflowAction) GetHistoryPropagationScope() HistoryPropagationScope
func (*CreateChildWorkflowAction) GetInput ¶
func (x *CreateChildWorkflowAction) GetInput() *wrapperspb.StringValue
func (*CreateChildWorkflowAction) GetInstanceId ¶
func (x *CreateChildWorkflowAction) GetInstanceId() string
func (*CreateChildWorkflowAction) GetName ¶
func (x *CreateChildWorkflowAction) GetName() string
func (*CreateChildWorkflowAction) GetRetryParentInstanceInfo ¶
func (x *CreateChildWorkflowAction) GetRetryParentInstanceInfo() *RetryParentInstanceInfo
func (*CreateChildWorkflowAction) GetVersion ¶
func (x *CreateChildWorkflowAction) GetVersion() *wrapperspb.StringValue
func (*CreateChildWorkflowAction) ProtoMessage ¶
func (*CreateChildWorkflowAction) ProtoMessage()
func (*CreateChildWorkflowAction) ProtoReflect ¶
func (x *CreateChildWorkflowAction) ProtoReflect() protoreflect.Message
func (*CreateChildWorkflowAction) Reset ¶
func (x *CreateChildWorkflowAction) Reset()
func (*CreateChildWorkflowAction) String ¶
func (x *CreateChildWorkflowAction) String() string
type CreateDetachedWorkflowAction ¶
type CreateDetachedWorkflowAction struct {
// instanceId is the ID assigned to the new workflow. It is mandatory:
// implementors must set a stable, deterministic ID so that on replay the
// call resolves to the same DetachedWorkflowInstanceCreatedEvent in
// history.
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
// name of the workflow to schedule. Mandatory.
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// The remaining fields mirror the optional inputs of
// CreateInstanceRequest. Wrapper types (StringValue) carry presence via
// the wrapper; bare message fields are explicitly marked optional.
Version *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
ScheduledStartTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3,oneof" json:"scheduledStartTimestamp,omitempty"`
ExecutionId *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=executionId,proto3" json:"executionId,omitempty"`
Tags map[string]string `` /* 149-byte string literal not displayed */
ParentTraceContext *TraceContext `protobuf:"bytes,8,opt,name=parentTraceContext,proto3,oneof" json:"parentTraceContext,omitempty"`
// contains filtered or unexported fields
}
CreateDetachedWorkflowAction creates a new, detached workflow instance from a running workflow. Mirrors the fields of CreateInstanceRequest (the client scheduling API) so the runtime has all the information needed to schedule the new instance directly from this action. The spawned workflow is fully decoupled from the caller: no parent pointer is recorded on the new workflow, no completion is awaited, and no failure propagation flows back. The creation is recorded once in the caller's history as a DetachedWorkflowInstanceCreatedEvent referencing the new instance ID.
func (*CreateDetachedWorkflowAction) Descriptor
deprecated
func (*CreateDetachedWorkflowAction) Descriptor() ([]byte, []int)
Deprecated: Use CreateDetachedWorkflowAction.ProtoReflect.Descriptor instead.
func (*CreateDetachedWorkflowAction) GetExecutionId ¶
func (x *CreateDetachedWorkflowAction) GetExecutionId() *wrapperspb.StringValue
func (*CreateDetachedWorkflowAction) GetInput ¶
func (x *CreateDetachedWorkflowAction) GetInput() *wrapperspb.StringValue
func (*CreateDetachedWorkflowAction) GetInstanceId ¶
func (x *CreateDetachedWorkflowAction) GetInstanceId() string
func (*CreateDetachedWorkflowAction) GetName ¶
func (x *CreateDetachedWorkflowAction) GetName() string
func (*CreateDetachedWorkflowAction) GetParentTraceContext ¶
func (x *CreateDetachedWorkflowAction) GetParentTraceContext() *TraceContext
func (*CreateDetachedWorkflowAction) GetScheduledStartTimestamp ¶
func (x *CreateDetachedWorkflowAction) GetScheduledStartTimestamp() *timestamppb.Timestamp
func (*CreateDetachedWorkflowAction) GetTags ¶
func (x *CreateDetachedWorkflowAction) GetTags() map[string]string
func (*CreateDetachedWorkflowAction) GetVersion ¶
func (x *CreateDetachedWorkflowAction) GetVersion() *wrapperspb.StringValue
func (*CreateDetachedWorkflowAction) ProtoMessage ¶
func (*CreateDetachedWorkflowAction) ProtoMessage()
func (*CreateDetachedWorkflowAction) ProtoReflect ¶
func (x *CreateDetachedWorkflowAction) ProtoReflect() protoreflect.Message
func (*CreateDetachedWorkflowAction) Reset ¶
func (x *CreateDetachedWorkflowAction) Reset()
func (*CreateDetachedWorkflowAction) String ¶
func (x *CreateDetachedWorkflowAction) String() string
type CreateInstanceRequest ¶
type CreateInstanceRequest struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Version *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
ScheduledStartTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
ExecutionId *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=executionId,proto3" json:"executionId,omitempty"`
Tags map[string]string `` /* 149-byte string literal not displayed */
ParentTraceContext *TraceContext `protobuf:"bytes,9,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
// When true, the request fails with an ALREADY_EXISTS error if a workflow
// instance with the same instanceId already exists, whether active or
// completed. When false, an existing completed instance is restarted.
EnforceUniqueInstanceId bool `protobuf:"varint,10,opt,name=enforceUniqueInstanceId,proto3" json:"enforceUniqueInstanceId,omitempty"`
// router optionally routes this operation to the workflow instance owned
// by another app. When targetAppID names a different app, the operation is
// executed against that app's instance (same namespace unless
// targetAppNamespace is set). sourceAppID is stamped by the sidecar, not
// the client.
Router *TaskRouter `protobuf:"bytes,11,opt,name=router,proto3,oneof" json:"router,omitempty"`
// contains filtered or unexported fields
}
func (*CreateInstanceRequest) Descriptor
deprecated
func (*CreateInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.
func (*CreateInstanceRequest) GetEnforceUniqueInstanceId ¶
func (x *CreateInstanceRequest) GetEnforceUniqueInstanceId() bool
func (*CreateInstanceRequest) GetExecutionId ¶
func (x *CreateInstanceRequest) GetExecutionId() *wrapperspb.StringValue
func (*CreateInstanceRequest) GetInput ¶
func (x *CreateInstanceRequest) GetInput() *wrapperspb.StringValue
func (*CreateInstanceRequest) GetInstanceId ¶
func (x *CreateInstanceRequest) GetInstanceId() string
func (*CreateInstanceRequest) GetName ¶
func (x *CreateInstanceRequest) GetName() string
func (*CreateInstanceRequest) GetParentTraceContext ¶
func (x *CreateInstanceRequest) GetParentTraceContext() *TraceContext
func (*CreateInstanceRequest) GetRouter ¶
func (x *CreateInstanceRequest) GetRouter() *TaskRouter
func (*CreateInstanceRequest) GetScheduledStartTimestamp ¶
func (x *CreateInstanceRequest) GetScheduledStartTimestamp() *timestamppb.Timestamp
func (*CreateInstanceRequest) GetTags ¶
func (x *CreateInstanceRequest) GetTags() map[string]string
func (*CreateInstanceRequest) GetVersion ¶
func (x *CreateInstanceRequest) GetVersion() *wrapperspb.StringValue
func (*CreateInstanceRequest) ProtoMessage ¶
func (*CreateInstanceRequest) ProtoMessage()
func (*CreateInstanceRequest) ProtoReflect ¶
func (x *CreateInstanceRequest) ProtoReflect() protoreflect.Message
func (*CreateInstanceRequest) Reset ¶
func (x *CreateInstanceRequest) Reset()
func (*CreateInstanceRequest) String ¶
func (x *CreateInstanceRequest) String() string
type CreateInstanceResponse ¶
type CreateInstanceResponse struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
// contains filtered or unexported fields
}
func (*CreateInstanceResponse) Descriptor
deprecated
func (*CreateInstanceResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateInstanceResponse.ProtoReflect.Descriptor instead.
func (*CreateInstanceResponse) GetInstanceId ¶
func (x *CreateInstanceResponse) GetInstanceId() string
func (*CreateInstanceResponse) ProtoMessage ¶
func (*CreateInstanceResponse) ProtoMessage()
func (*CreateInstanceResponse) ProtoReflect ¶
func (x *CreateInstanceResponse) ProtoReflect() protoreflect.Message
func (*CreateInstanceResponse) Reset ¶
func (x *CreateInstanceResponse) Reset()
func (*CreateInstanceResponse) String ¶
func (x *CreateInstanceResponse) String() string
type CreateSubOrchestrationAction
deprecated
type CreateSubOrchestrationAction = CreateChildWorkflowAction
Deprecated: Use CreateChildWorkflowAction instead.
type CreateTimerAction ¶
type CreateTimerAction struct {
FireAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fireAt,proto3" json:"fireAt,omitempty"`
Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
// If set, provides additional context attached to this timer.
//
// Types that are assignable to Origin:
//
// *CreateTimerAction_CreateTimer
// *CreateTimerAction_ExternalEvent
// *CreateTimerAction_ActivityRetry
// *CreateTimerAction_ChildWorkflowRetry
Origin isCreateTimerAction_Origin `protobuf_oneof:"origin"`
// contains filtered or unexported fields
}
func (*CreateTimerAction) Descriptor
deprecated
func (*CreateTimerAction) Descriptor() ([]byte, []int)
Deprecated: Use CreateTimerAction.ProtoReflect.Descriptor instead.
func (*CreateTimerAction) GetActivityRetry ¶
func (x *CreateTimerAction) GetActivityRetry() *TimerOriginActivityRetry
func (*CreateTimerAction) GetChildWorkflowRetry ¶
func (x *CreateTimerAction) GetChildWorkflowRetry() *TimerOriginChildWorkflowRetry
func (*CreateTimerAction) GetCreateTimer ¶
func (x *CreateTimerAction) GetCreateTimer() *TimerOriginCreateTimer
func (*CreateTimerAction) GetExternalEvent ¶
func (x *CreateTimerAction) GetExternalEvent() *TimerOriginExternalEvent
func (*CreateTimerAction) GetFireAt ¶
func (x *CreateTimerAction) GetFireAt() *timestamppb.Timestamp
func (*CreateTimerAction) GetName ¶
func (x *CreateTimerAction) GetName() string
func (*CreateTimerAction) GetOrigin ¶
func (m *CreateTimerAction) GetOrigin() isCreateTimerAction_Origin
func (*CreateTimerAction) ProtoMessage ¶
func (*CreateTimerAction) ProtoMessage()
func (*CreateTimerAction) ProtoReflect ¶
func (x *CreateTimerAction) ProtoReflect() protoreflect.Message
func (*CreateTimerAction) Reset ¶
func (x *CreateTimerAction) Reset()
func (*CreateTimerAction) String ¶
func (x *CreateTimerAction) String() string
type CreateTimerAction_ActivityRetry ¶
type CreateTimerAction_ActivityRetry struct {
ActivityRetry *TimerOriginActivityRetry `protobuf:"bytes,5,opt,name=activityRetry,proto3,oneof"`
}
type CreateTimerAction_ChildWorkflowRetry ¶
type CreateTimerAction_ChildWorkflowRetry struct {
ChildWorkflowRetry *TimerOriginChildWorkflowRetry `protobuf:"bytes,6,opt,name=childWorkflowRetry,proto3,oneof"`
}
type CreateTimerAction_CreateTimer ¶
type CreateTimerAction_CreateTimer struct {
CreateTimer *TimerOriginCreateTimer `protobuf:"bytes,3,opt,name=createTimer,proto3,oneof"`
}
type CreateTimerAction_ExternalEvent ¶
type CreateTimerAction_ExternalEvent struct {
ExternalEvent *TimerOriginExternalEvent `protobuf:"bytes,4,opt,name=externalEvent,proto3,oneof"`
}
type CreateWorkflowInstanceRequest ¶
type CreateWorkflowInstanceRequest struct {
StartEvent *HistoryEvent `protobuf:"bytes,1,opt,name=startEvent,proto3" json:"startEvent,omitempty"`
// Propagated history from the parent workflow.
PropagatedHistory *PropagatedHistory `protobuf:"bytes,3,opt,name=propagatedHistory,proto3,oneof" json:"propagatedHistory,omitempty"`
// When true, the request fails with an ALREADY_EXISTS error if a workflow
// instance with the same instanceId already exists, whether active or
// completed. When false, an existing completed instance is restarted.
EnforceUniqueInstanceId bool `protobuf:"varint,4,opt,name=enforceUniqueInstanceId,proto3" json:"enforceUniqueInstanceId,omitempty"`
// contains filtered or unexported fields
}
func (*CreateWorkflowInstanceRequest) Descriptor
deprecated
func (*CreateWorkflowInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateWorkflowInstanceRequest.ProtoReflect.Descriptor instead.
func (*CreateWorkflowInstanceRequest) GetEnforceUniqueInstanceId ¶
func (x *CreateWorkflowInstanceRequest) GetEnforceUniqueInstanceId() bool
func (*CreateWorkflowInstanceRequest) GetPropagatedHistory ¶
func (x *CreateWorkflowInstanceRequest) GetPropagatedHistory() *PropagatedHistory
func (*CreateWorkflowInstanceRequest) GetStartEvent ¶
func (x *CreateWorkflowInstanceRequest) GetStartEvent() *HistoryEvent
func (*CreateWorkflowInstanceRequest) ProtoMessage ¶
func (*CreateWorkflowInstanceRequest) ProtoMessage()
func (*CreateWorkflowInstanceRequest) ProtoReflect ¶
func (x *CreateWorkflowInstanceRequest) ProtoReflect() protoreflect.Message
func (*CreateWorkflowInstanceRequest) Reset ¶
func (x *CreateWorkflowInstanceRequest) Reset()
func (*CreateWorkflowInstanceRequest) String ¶
func (x *CreateWorkflowInstanceRequest) String() string
type DetachedWorkflowInstanceCreatedEvent ¶
type DetachedWorkflowInstanceCreatedEvent struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
// contains filtered or unexported fields
}
DetachedWorkflowInstanceCreatedEvent records that a running workflow created a new, detached workflow instance via CreateDetachedWorkflowAction. The new workflow has no parent linkage (no completion or failure flows back), so this event only stores a pointer to the spawned instance — the inputs themselves are consumed directly from the action when scheduling. Replay matches on instanceId, so it is the same value the action carried.
func (*DetachedWorkflowInstanceCreatedEvent) Descriptor
deprecated
func (*DetachedWorkflowInstanceCreatedEvent) Descriptor() ([]byte, []int)
Deprecated: Use DetachedWorkflowInstanceCreatedEvent.ProtoReflect.Descriptor instead.
func (*DetachedWorkflowInstanceCreatedEvent) GetInstanceId ¶
func (x *DetachedWorkflowInstanceCreatedEvent) GetInstanceId() string
func (*DetachedWorkflowInstanceCreatedEvent) ProtoMessage ¶
func (*DetachedWorkflowInstanceCreatedEvent) ProtoMessage()
func (*DetachedWorkflowInstanceCreatedEvent) ProtoReflect ¶
func (x *DetachedWorkflowInstanceCreatedEvent) ProtoReflect() protoreflect.Message
func (*DetachedWorkflowInstanceCreatedEvent) Reset ¶
func (x *DetachedWorkflowInstanceCreatedEvent) Reset()
func (*DetachedWorkflowInstanceCreatedEvent) String ¶
func (x *DetachedWorkflowInstanceCreatedEvent) String() string
type DurableTimer ¶
type DurableTimer struct {
TimerEvent *HistoryEvent `protobuf:"bytes,1,opt,name=timerEvent,proto3" json:"timerEvent,omitempty"`
Generation uint64 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
// contains filtered or unexported fields
}
func (*DurableTimer) Descriptor
deprecated
func (*DurableTimer) Descriptor() ([]byte, []int)
Deprecated: Use DurableTimer.ProtoReflect.Descriptor instead.
func (*DurableTimer) GetGeneration ¶
func (x *DurableTimer) GetGeneration() uint64
func (*DurableTimer) GetTimerEvent ¶
func (x *DurableTimer) GetTimerEvent() *HistoryEvent
func (*DurableTimer) ProtoMessage ¶
func (*DurableTimer) ProtoMessage()
func (*DurableTimer) ProtoReflect ¶
func (x *DurableTimer) ProtoReflect() protoreflect.Message
func (*DurableTimer) Reset ¶
func (x *DurableTimer) Reset()
func (*DurableTimer) String ¶
func (x *DurableTimer) String() string
type EventRaisedEvent ¶
type EventRaisedEvent struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
// contains filtered or unexported fields
}
func (*EventRaisedEvent) Descriptor
deprecated
func (*EventRaisedEvent) Descriptor() ([]byte, []int)
Deprecated: Use EventRaisedEvent.ProtoReflect.Descriptor instead.
func (*EventRaisedEvent) GetInput ¶
func (x *EventRaisedEvent) GetInput() *wrapperspb.StringValue
func (*EventRaisedEvent) GetName ¶
func (x *EventRaisedEvent) GetName() string
func (*EventRaisedEvent) ProtoMessage ¶
func (*EventRaisedEvent) ProtoMessage()
func (*EventRaisedEvent) ProtoReflect ¶
func (x *EventRaisedEvent) ProtoReflect() protoreflect.Message
func (*EventRaisedEvent) Reset ¶
func (x *EventRaisedEvent) Reset()
func (*EventRaisedEvent) String ¶
func (x *EventRaisedEvent) String() string
type EventSentEvent ¶
type EventSentEvent struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
// contains filtered or unexported fields
}
func (*EventSentEvent) Descriptor
deprecated
func (*EventSentEvent) Descriptor() ([]byte, []int)
Deprecated: Use EventSentEvent.ProtoReflect.Descriptor instead.
func (*EventSentEvent) GetInput ¶
func (x *EventSentEvent) GetInput() *wrapperspb.StringValue
func (*EventSentEvent) GetInstanceId ¶
func (x *EventSentEvent) GetInstanceId() string
func (*EventSentEvent) GetName ¶
func (x *EventSentEvent) GetName() string
func (*EventSentEvent) ProtoMessage ¶
func (*EventSentEvent) ProtoMessage()
func (*EventSentEvent) ProtoReflect ¶
func (x *EventSentEvent) ProtoReflect() protoreflect.Message
func (*EventSentEvent) Reset ¶
func (x *EventSentEvent) Reset()
func (*EventSentEvent) String ¶
func (x *EventSentEvent) String() string
type ExecutionCompletedEvent ¶
type ExecutionCompletedEvent struct {
WorkflowStatus OrchestrationStatus `protobuf:"varint,1,opt,name=workflowStatus,proto3,enum=OrchestrationStatus" json:"workflowStatus,omitempty"`
Result *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
FailureDetails *TaskFailureDetails `protobuf:"bytes,3,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
// contains filtered or unexported fields
}
func (*ExecutionCompletedEvent) Descriptor
deprecated
func (*ExecutionCompletedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ExecutionCompletedEvent.ProtoReflect.Descriptor instead.
func (*ExecutionCompletedEvent) GetFailureDetails ¶
func (x *ExecutionCompletedEvent) GetFailureDetails() *TaskFailureDetails
func (*ExecutionCompletedEvent) GetOrchestrationStatus
deprecated
func (x *ExecutionCompletedEvent) GetOrchestrationStatus() OrchestrationStatus
Deprecated: Use GetWorkflowStatus on ExecutionCompletedEvent instead.
func (*ExecutionCompletedEvent) GetResult ¶
func (x *ExecutionCompletedEvent) GetResult() *wrapperspb.StringValue
func (*ExecutionCompletedEvent) GetWorkflowStatus ¶
func (x *ExecutionCompletedEvent) GetWorkflowStatus() OrchestrationStatus
func (*ExecutionCompletedEvent) ProtoMessage ¶
func (*ExecutionCompletedEvent) ProtoMessage()
func (*ExecutionCompletedEvent) ProtoReflect ¶
func (x *ExecutionCompletedEvent) ProtoReflect() protoreflect.Message
func (*ExecutionCompletedEvent) Reset ¶
func (x *ExecutionCompletedEvent) Reset()
func (*ExecutionCompletedEvent) String ¶
func (x *ExecutionCompletedEvent) String() string
type ExecutionResumedEvent ¶
type ExecutionResumedEvent struct {
Input *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
// contains filtered or unexported fields
}
func (*ExecutionResumedEvent) Descriptor
deprecated
func (*ExecutionResumedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ExecutionResumedEvent.ProtoReflect.Descriptor instead.
func (*ExecutionResumedEvent) GetInput ¶
func (x *ExecutionResumedEvent) GetInput() *wrapperspb.StringValue
func (*ExecutionResumedEvent) ProtoMessage ¶
func (*ExecutionResumedEvent) ProtoMessage()
func (*ExecutionResumedEvent) ProtoReflect ¶
func (x *ExecutionResumedEvent) ProtoReflect() protoreflect.Message
func (*ExecutionResumedEvent) Reset ¶
func (x *ExecutionResumedEvent) Reset()
func (*ExecutionResumedEvent) String ¶
func (x *ExecutionResumedEvent) String() string
type ExecutionStalledEvent ¶
type ExecutionStalledEvent struct {
Reason StalledReason `protobuf:"varint,1,opt,name=reason,proto3,enum=StalledReason" json:"reason,omitempty"`
Description *string `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"`
// contains filtered or unexported fields
}
func (*ExecutionStalledEvent) Descriptor
deprecated
func (*ExecutionStalledEvent) Descriptor() ([]byte, []int)
Deprecated: Use ExecutionStalledEvent.ProtoReflect.Descriptor instead.
func (*ExecutionStalledEvent) GetDescription ¶
func (x *ExecutionStalledEvent) GetDescription() string
func (*ExecutionStalledEvent) GetReason ¶
func (x *ExecutionStalledEvent) GetReason() StalledReason
func (*ExecutionStalledEvent) ProtoMessage ¶
func (*ExecutionStalledEvent) ProtoMessage()
func (*ExecutionStalledEvent) ProtoReflect ¶
func (x *ExecutionStalledEvent) ProtoReflect() protoreflect.Message
func (*ExecutionStalledEvent) Reset ¶
func (x *ExecutionStalledEvent) Reset()
func (*ExecutionStalledEvent) String ¶
func (x *ExecutionStalledEvent) String() string
type ExecutionStartedEvent ¶
type ExecutionStartedEvent struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Version *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
WorkflowInstance *WorkflowInstance `protobuf:"bytes,4,opt,name=workflowInstance,proto3" json:"workflowInstance,omitempty"`
ParentInstance *ParentInstanceInfo `protobuf:"bytes,5,opt,name=parentInstance,proto3" json:"parentInstance,omitempty"`
ScheduledStartTimestamp *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
ParentTraceContext *TraceContext `protobuf:"bytes,7,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
WorkflowSpanID *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=workflowSpanID,proto3" json:"workflowSpanID,omitempty"`
Tags map[string]string `` /* 149-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*ExecutionStartedEvent) Descriptor
deprecated
func (*ExecutionStartedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ExecutionStartedEvent.ProtoReflect.Descriptor instead.
func (*ExecutionStartedEvent) GetInput ¶
func (x *ExecutionStartedEvent) GetInput() *wrapperspb.StringValue
func (*ExecutionStartedEvent) GetName ¶
func (x *ExecutionStartedEvent) GetName() string
func (*ExecutionStartedEvent) GetOrchestrationInstance
deprecated
func (x *ExecutionStartedEvent) GetOrchestrationInstance() *WorkflowInstance
Deprecated: Use GetWorkflowInstance instead.
func (*ExecutionStartedEvent) GetOrchestrationSpanID
deprecated
func (x *ExecutionStartedEvent) GetOrchestrationSpanID() *wrapperspb.StringValue
Deprecated: Use GetWorkflowSpanID instead.
func (*ExecutionStartedEvent) GetParentInstance ¶
func (x *ExecutionStartedEvent) GetParentInstance() *ParentInstanceInfo
func (*ExecutionStartedEvent) GetParentTraceContext ¶
func (x *ExecutionStartedEvent) GetParentTraceContext() *TraceContext
func (*ExecutionStartedEvent) GetScheduledStartTimestamp ¶
func (x *ExecutionStartedEvent) GetScheduledStartTimestamp() *timestamppb.Timestamp
func (*ExecutionStartedEvent) GetTags ¶
func (x *ExecutionStartedEvent) GetTags() map[string]string
func (*ExecutionStartedEvent) GetVersion ¶
func (x *ExecutionStartedEvent) GetVersion() *wrapperspb.StringValue
func (*ExecutionStartedEvent) GetWorkflowInstance ¶
func (x *ExecutionStartedEvent) GetWorkflowInstance() *WorkflowInstance
func (*ExecutionStartedEvent) GetWorkflowSpanID ¶
func (x *ExecutionStartedEvent) GetWorkflowSpanID() *wrapperspb.StringValue
func (*ExecutionStartedEvent) ProtoMessage ¶
func (*ExecutionStartedEvent) ProtoMessage()
func (*ExecutionStartedEvent) ProtoReflect ¶
func (x *ExecutionStartedEvent) ProtoReflect() protoreflect.Message
func (*ExecutionStartedEvent) Reset ¶
func (x *ExecutionStartedEvent) Reset()
func (*ExecutionStartedEvent) String ¶
func (x *ExecutionStartedEvent) String() string
type ExecutionSuspendedEvent ¶
type ExecutionSuspendedEvent struct {
Input *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
// contains filtered or unexported fields
}
func (*ExecutionSuspendedEvent) Descriptor
deprecated
func (*ExecutionSuspendedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ExecutionSuspendedEvent.ProtoReflect.Descriptor instead.
func (*ExecutionSuspendedEvent) GetInput ¶
func (x *ExecutionSuspendedEvent) GetInput() *wrapperspb.StringValue
func (*ExecutionSuspendedEvent) ProtoMessage ¶
func (*ExecutionSuspendedEvent) ProtoMessage()
func (*ExecutionSuspendedEvent) ProtoReflect ¶
func (x *ExecutionSuspendedEvent) ProtoReflect() protoreflect.Message
func (*ExecutionSuspendedEvent) Reset ¶
func (x *ExecutionSuspendedEvent) Reset()
func (*ExecutionSuspendedEvent) String ¶
func (x *ExecutionSuspendedEvent) String() string
type ExecutionTerminatedEvent ¶
type ExecutionTerminatedEvent struct {
Input *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
Recurse bool `protobuf:"varint,2,opt,name=recurse,proto3" json:"recurse,omitempty"`
// contains filtered or unexported fields
}
func (*ExecutionTerminatedEvent) Descriptor
deprecated
func (*ExecutionTerminatedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ExecutionTerminatedEvent.ProtoReflect.Descriptor instead.
func (*ExecutionTerminatedEvent) GetInput ¶
func (x *ExecutionTerminatedEvent) GetInput() *wrapperspb.StringValue
func (*ExecutionTerminatedEvent) GetRecurse ¶
func (x *ExecutionTerminatedEvent) GetRecurse() bool
func (*ExecutionTerminatedEvent) ProtoMessage ¶
func (*ExecutionTerminatedEvent) ProtoMessage()
func (*ExecutionTerminatedEvent) ProtoReflect ¶
func (x *ExecutionTerminatedEvent) ProtoReflect() protoreflect.Message
func (*ExecutionTerminatedEvent) Reset ¶
func (x *ExecutionTerminatedEvent) Reset()
func (*ExecutionTerminatedEvent) String ¶
func (x *ExecutionTerminatedEvent) String() string
type GetInstanceHistoryRequest ¶
type GetInstanceHistoryRequest struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
// contains filtered or unexported fields
}
GetInstanceHistoryRequest is used to get the full history of a workflow instance.
func (*GetInstanceHistoryRequest) Descriptor
deprecated
func (*GetInstanceHistoryRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetInstanceHistoryRequest.ProtoReflect.Descriptor instead.
func (*GetInstanceHistoryRequest) GetInstanceId ¶
func (x *GetInstanceHistoryRequest) GetInstanceId() string
func (*GetInstanceHistoryRequest) ProtoMessage ¶
func (*GetInstanceHistoryRequest) ProtoMessage()
func (*GetInstanceHistoryRequest) ProtoReflect ¶
func (x *GetInstanceHistoryRequest) ProtoReflect() protoreflect.Message
func (*GetInstanceHistoryRequest) Reset ¶
func (x *GetInstanceHistoryRequest) Reset()
func (*GetInstanceHistoryRequest) String ¶
func (x *GetInstanceHistoryRequest) String() string
type GetInstanceHistoryResponse ¶
type GetInstanceHistoryResponse struct {
Events []*HistoryEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
// contains filtered or unexported fields
}
GetInstanceHistoryResponse is the response to executing GetInstanceHistory.
func (*GetInstanceHistoryResponse) Descriptor
deprecated
func (*GetInstanceHistoryResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetInstanceHistoryResponse.ProtoReflect.Descriptor instead.
func (*GetInstanceHistoryResponse) GetEvents ¶
func (x *GetInstanceHistoryResponse) GetEvents() []*HistoryEvent
func (*GetInstanceHistoryResponse) ProtoMessage ¶
func (*GetInstanceHistoryResponse) ProtoMessage()
func (*GetInstanceHistoryResponse) ProtoReflect ¶
func (x *GetInstanceHistoryResponse) ProtoReflect() protoreflect.Message
func (*GetInstanceHistoryResponse) Reset ¶
func (x *GetInstanceHistoryResponse) Reset()
func (*GetInstanceHistoryResponse) String ¶
func (x *GetInstanceHistoryResponse) String() string
type GetInstanceRequest ¶
type GetInstanceRequest struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
GetInputsAndOutputs bool `protobuf:"varint,2,opt,name=getInputsAndOutputs,proto3" json:"getInputsAndOutputs,omitempty"`
// router optionally routes this operation to the workflow instance owned
// by another app. sourceAppID is stamped by the sidecar, not the client.
Router *TaskRouter `protobuf:"bytes,3,opt,name=router,proto3,oneof" json:"router,omitempty"`
// contains filtered or unexported fields
}
func (*GetInstanceRequest) Descriptor
deprecated
func (*GetInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.
func (*GetInstanceRequest) GetGetInputsAndOutputs ¶
func (x *GetInstanceRequest) GetGetInputsAndOutputs() bool
func (*GetInstanceRequest) GetInstanceId ¶
func (x *GetInstanceRequest) GetInstanceId() string
func (*GetInstanceRequest) GetRouter ¶
func (x *GetInstanceRequest) GetRouter() *TaskRouter
func (*GetInstanceRequest) ProtoMessage ¶
func (*GetInstanceRequest) ProtoMessage()
func (*GetInstanceRequest) ProtoReflect ¶
func (x *GetInstanceRequest) ProtoReflect() protoreflect.Message
func (*GetInstanceRequest) Reset ¶
func (x *GetInstanceRequest) Reset()
func (*GetInstanceRequest) String ¶
func (x *GetInstanceRequest) String() string
type GetInstanceResponse ¶
type GetInstanceResponse struct {
Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
WorkflowState *WorkflowState `protobuf:"bytes,2,opt,name=workflowState,proto3" json:"workflowState,omitempty"`
// contains filtered or unexported fields
}
func (*GetInstanceResponse) Descriptor
deprecated
func (*GetInstanceResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetInstanceResponse.ProtoReflect.Descriptor instead.
func (*GetInstanceResponse) GetExists ¶
func (x *GetInstanceResponse) GetExists() bool
func (*GetInstanceResponse) GetWorkflowState ¶
func (x *GetInstanceResponse) GetWorkflowState() *WorkflowState
func (*GetInstanceResponse) ProtoMessage ¶
func (*GetInstanceResponse) ProtoMessage()
func (*GetInstanceResponse) ProtoReflect ¶
func (x *GetInstanceResponse) ProtoReflect() protoreflect.Message
func (*GetInstanceResponse) Reset ¶
func (x *GetInstanceResponse) Reset()
func (*GetInstanceResponse) String ¶
func (x *GetInstanceResponse) String() string
type GetWorkItemsRequest ¶
type GetWorkItemsRequest struct {
// capabilities advertises the optional protocol features this worker
// supports, so the service can opt into optimizations on a per-stream
// basis. Workers that leave this empty receive the default (fully
// self-contained) behavior.
Capabilities []WorkerCapability `protobuf:"varint,4,rep,packed,name=capabilities,proto3,enum=WorkerCapability" json:"capabilities,omitempty"`
// contains filtered or unexported fields
}
func (*GetWorkItemsRequest) Descriptor
deprecated
func (*GetWorkItemsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkItemsRequest.ProtoReflect.Descriptor instead.
func (*GetWorkItemsRequest) GetCapabilities ¶
func (x *GetWorkItemsRequest) GetCapabilities() []WorkerCapability
func (*GetWorkItemsRequest) ProtoMessage ¶
func (*GetWorkItemsRequest) ProtoMessage()
func (*GetWorkItemsRequest) ProtoReflect ¶
func (x *GetWorkItemsRequest) ProtoReflect() protoreflect.Message
func (*GetWorkItemsRequest) Reset ¶
func (x *GetWorkItemsRequest) Reset()
func (*GetWorkItemsRequest) String ¶
func (x *GetWorkItemsRequest) String() string
type HistoryEvent ¶
type HistoryEvent struct {
EventId int32 `protobuf:"varint,1,opt,name=eventId,proto3" json:"eventId,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// Types that are assignable to EventType:
//
// *HistoryEvent_ExecutionStarted
// *HistoryEvent_ExecutionCompleted
// *HistoryEvent_ExecutionTerminated
// *HistoryEvent_TaskScheduled
// *HistoryEvent_TaskCompleted
// *HistoryEvent_TaskFailed
// *HistoryEvent_ChildWorkflowInstanceCreated
// *HistoryEvent_ChildWorkflowInstanceCompleted
// *HistoryEvent_ChildWorkflowInstanceFailed
// *HistoryEvent_TimerCreated
// *HistoryEvent_TimerFired
// *HistoryEvent_WorkflowStarted
// *HistoryEvent_WorkflowCompleted
// *HistoryEvent_EventSent
// *HistoryEvent_EventRaised
// *HistoryEvent_ContinueAsNew
// *HistoryEvent_ExecutionSuspended
// *HistoryEvent_ExecutionResumed
// *HistoryEvent_ExecutionStalled
// *HistoryEvent_DetachedWorkflowInstanceCreated
EventType isHistoryEvent_EventType `protobuf_oneof:"eventType"`
Router *TaskRouter `protobuf:"bytes,30,opt,name=router,proto3,oneof" json:"router,omitempty"`
// contains filtered or unexported fields
}
func (*HistoryEvent) Descriptor
deprecated
func (*HistoryEvent) Descriptor() ([]byte, []int)
Deprecated: Use HistoryEvent.ProtoReflect.Descriptor instead.
func (*HistoryEvent) GetChildWorkflowInstanceCompleted ¶
func (x *HistoryEvent) GetChildWorkflowInstanceCompleted() *ChildWorkflowInstanceCompletedEvent
func (*HistoryEvent) GetChildWorkflowInstanceCreated ¶
func (x *HistoryEvent) GetChildWorkflowInstanceCreated() *ChildWorkflowInstanceCreatedEvent
func (*HistoryEvent) GetChildWorkflowInstanceFailed ¶
func (x *HistoryEvent) GetChildWorkflowInstanceFailed() *ChildWorkflowInstanceFailedEvent
func (*HistoryEvent) GetContinueAsNew ¶
func (x *HistoryEvent) GetContinueAsNew() *ContinueAsNewEvent
func (*HistoryEvent) GetDetachedWorkflowInstanceCreated ¶
func (x *HistoryEvent) GetDetachedWorkflowInstanceCreated() *DetachedWorkflowInstanceCreatedEvent
func (*HistoryEvent) GetEventId ¶
func (x *HistoryEvent) GetEventId() int32
func (*HistoryEvent) GetEventRaised ¶
func (x *HistoryEvent) GetEventRaised() *EventRaisedEvent
func (*HistoryEvent) GetEventSent ¶
func (x *HistoryEvent) GetEventSent() *EventSentEvent
func (*HistoryEvent) GetEventType ¶
func (m *HistoryEvent) GetEventType() isHistoryEvent_EventType
func (*HistoryEvent) GetExecutionCompleted ¶
func (x *HistoryEvent) GetExecutionCompleted() *ExecutionCompletedEvent
func (*HistoryEvent) GetExecutionResumed ¶
func (x *HistoryEvent) GetExecutionResumed() *ExecutionResumedEvent
func (*HistoryEvent) GetExecutionStalled ¶
func (x *HistoryEvent) GetExecutionStalled() *ExecutionStalledEvent
func (*HistoryEvent) GetExecutionStarted ¶
func (x *HistoryEvent) GetExecutionStarted() *ExecutionStartedEvent
func (*HistoryEvent) GetExecutionSuspended ¶
func (x *HistoryEvent) GetExecutionSuspended() *ExecutionSuspendedEvent
func (*HistoryEvent) GetExecutionTerminated ¶
func (x *HistoryEvent) GetExecutionTerminated() *ExecutionTerminatedEvent
func (*HistoryEvent) GetOrchestratorCompleted
deprecated
func (x *HistoryEvent) GetOrchestratorCompleted() *WorkflowCompletedEvent
Deprecated: Use GetWorkflowCompleted instead.
func (*HistoryEvent) GetOrchestratorStarted
deprecated
func (x *HistoryEvent) GetOrchestratorStarted() *WorkflowStartedEvent
Deprecated: Use GetWorkflowStarted instead.
func (*HistoryEvent) GetRouter ¶
func (x *HistoryEvent) GetRouter() *TaskRouter
func (*HistoryEvent) GetSubOrchestrationInstanceCompleted
deprecated
func (x *HistoryEvent) GetSubOrchestrationInstanceCompleted() *ChildWorkflowInstanceCompletedEvent
Deprecated: Use GetChildWorkflowInstanceCompleted instead.
func (*HistoryEvent) GetSubOrchestrationInstanceCreated
deprecated
func (x *HistoryEvent) GetSubOrchestrationInstanceCreated() *ChildWorkflowInstanceCreatedEvent
Deprecated: Use GetChildWorkflowInstanceCreated instead.
func (*HistoryEvent) GetSubOrchestrationInstanceFailed
deprecated
func (x *HistoryEvent) GetSubOrchestrationInstanceFailed() *ChildWorkflowInstanceFailedEvent
Deprecated: Use GetChildWorkflowInstanceFailed instead.
func (*HistoryEvent) GetTaskCompleted ¶
func (x *HistoryEvent) GetTaskCompleted() *TaskCompletedEvent
func (*HistoryEvent) GetTaskFailed ¶
func (x *HistoryEvent) GetTaskFailed() *TaskFailedEvent
func (*HistoryEvent) GetTaskScheduled ¶
func (x *HistoryEvent) GetTaskScheduled() *TaskScheduledEvent
func (*HistoryEvent) GetTimerCreated ¶
func (x *HistoryEvent) GetTimerCreated() *TimerCreatedEvent
func (*HistoryEvent) GetTimerFired ¶
func (x *HistoryEvent) GetTimerFired() *TimerFiredEvent
func (*HistoryEvent) GetTimestamp ¶
func (x *HistoryEvent) GetTimestamp() *timestamppb.Timestamp
func (*HistoryEvent) GetWorkflowCompleted ¶
func (x *HistoryEvent) GetWorkflowCompleted() *WorkflowCompletedEvent
func (*HistoryEvent) GetWorkflowStarted ¶
func (x *HistoryEvent) GetWorkflowStarted() *WorkflowStartedEvent
func (*HistoryEvent) ProtoMessage ¶
func (*HistoryEvent) ProtoMessage()
func (*HistoryEvent) ProtoReflect ¶
func (x *HistoryEvent) ProtoReflect() protoreflect.Message
func (*HistoryEvent) Reset ¶
func (x *HistoryEvent) Reset()
func (*HistoryEvent) String ¶
func (x *HistoryEvent) String() string
type HistoryEvent_ChildWorkflowInstanceCompleted ¶
type HistoryEvent_ChildWorkflowInstanceCompleted struct {
ChildWorkflowInstanceCompleted *ChildWorkflowInstanceCompletedEvent `protobuf:"bytes,10,opt,name=childWorkflowInstanceCompleted,proto3,oneof"`
}
type HistoryEvent_ChildWorkflowInstanceCreated ¶
type HistoryEvent_ChildWorkflowInstanceCreated struct {
ChildWorkflowInstanceCreated *ChildWorkflowInstanceCreatedEvent `protobuf:"bytes,9,opt,name=childWorkflowInstanceCreated,proto3,oneof"`
}
type HistoryEvent_ChildWorkflowInstanceFailed ¶
type HistoryEvent_ChildWorkflowInstanceFailed struct {
ChildWorkflowInstanceFailed *ChildWorkflowInstanceFailedEvent `protobuf:"bytes,11,opt,name=childWorkflowInstanceFailed,proto3,oneof"`
}
type HistoryEvent_ContinueAsNew ¶
type HistoryEvent_ContinueAsNew struct {
ContinueAsNew *ContinueAsNewEvent `protobuf:"bytes,20,opt,name=continueAsNew,proto3,oneof"`
}
type HistoryEvent_DetachedWorkflowInstanceCreated ¶
type HistoryEvent_DetachedWorkflowInstanceCreated struct {
DetachedWorkflowInstanceCreated *DetachedWorkflowInstanceCreatedEvent `protobuf:"bytes,32,opt,name=detachedWorkflowInstanceCreated,proto3,oneof"`
}
type HistoryEvent_EventRaised ¶
type HistoryEvent_EventRaised struct {
EventRaised *EventRaisedEvent `protobuf:"bytes,17,opt,name=eventRaised,proto3,oneof"`
}
type HistoryEvent_EventSent ¶
type HistoryEvent_EventSent struct {
EventSent *EventSentEvent `protobuf:"bytes,16,opt,name=eventSent,proto3,oneof"`
}
type HistoryEvent_ExecutionCompleted ¶
type HistoryEvent_ExecutionCompleted struct {
ExecutionCompleted *ExecutionCompletedEvent `protobuf:"bytes,4,opt,name=executionCompleted,proto3,oneof"`
}
type HistoryEvent_ExecutionResumed ¶
type HistoryEvent_ExecutionResumed struct {
ExecutionResumed *ExecutionResumedEvent `protobuf:"bytes,22,opt,name=executionResumed,proto3,oneof"`
}
type HistoryEvent_ExecutionStalled ¶
type HistoryEvent_ExecutionStalled struct {
ExecutionStalled *ExecutionStalledEvent `protobuf:"bytes,31,opt,name=executionStalled,proto3,oneof"`
}
type HistoryEvent_ExecutionStarted ¶
type HistoryEvent_ExecutionStarted struct {
ExecutionStarted *ExecutionStartedEvent `protobuf:"bytes,3,opt,name=executionStarted,proto3,oneof"`
}
type HistoryEvent_ExecutionSuspended ¶
type HistoryEvent_ExecutionSuspended struct {
ExecutionSuspended *ExecutionSuspendedEvent `protobuf:"bytes,21,opt,name=executionSuspended,proto3,oneof"`
}
type HistoryEvent_ExecutionTerminated ¶
type HistoryEvent_ExecutionTerminated struct {
ExecutionTerminated *ExecutionTerminatedEvent `protobuf:"bytes,5,opt,name=executionTerminated,proto3,oneof"`
}
type HistoryEvent_OrchestratorCompleted
deprecated
type HistoryEvent_OrchestratorCompleted = HistoryEvent_WorkflowCompleted
Deprecated: Use HistoryEvent_WorkflowCompleted instead.
type HistoryEvent_OrchestratorStarted
deprecated
type HistoryEvent_OrchestratorStarted = HistoryEvent_WorkflowStarted
Deprecated: Use HistoryEvent_WorkflowStarted instead.
type HistoryEvent_SubOrchestrationInstanceCompleted
deprecated
type HistoryEvent_SubOrchestrationInstanceCompleted = HistoryEvent_ChildWorkflowInstanceCompleted
Deprecated: Use HistoryEvent_ChildWorkflowInstanceCompleted instead.
type HistoryEvent_SubOrchestrationInstanceCreated
deprecated
type HistoryEvent_SubOrchestrationInstanceCreated = HistoryEvent_ChildWorkflowInstanceCreated
Deprecated: Use HistoryEvent_ChildWorkflowInstanceCreated instead.
type HistoryEvent_SubOrchestrationInstanceFailed
deprecated
type HistoryEvent_SubOrchestrationInstanceFailed = HistoryEvent_ChildWorkflowInstanceFailed
Deprecated: Use HistoryEvent_ChildWorkflowInstanceFailed instead.
type HistoryEvent_TaskCompleted ¶
type HistoryEvent_TaskCompleted struct {
TaskCompleted *TaskCompletedEvent `protobuf:"bytes,7,opt,name=taskCompleted,proto3,oneof"`
}
type HistoryEvent_TaskFailed ¶
type HistoryEvent_TaskFailed struct {
TaskFailed *TaskFailedEvent `protobuf:"bytes,8,opt,name=taskFailed,proto3,oneof"`
}
type HistoryEvent_TaskScheduled ¶
type HistoryEvent_TaskScheduled struct {
TaskScheduled *TaskScheduledEvent `protobuf:"bytes,6,opt,name=taskScheduled,proto3,oneof"`
}
type HistoryEvent_TimerCreated ¶
type HistoryEvent_TimerCreated struct {
TimerCreated *TimerCreatedEvent `protobuf:"bytes,12,opt,name=timerCreated,proto3,oneof"`
}
type HistoryEvent_TimerFired ¶
type HistoryEvent_TimerFired struct {
TimerFired *TimerFiredEvent `protobuf:"bytes,13,opt,name=timerFired,proto3,oneof"`
}
type HistoryEvent_WorkflowCompleted ¶
type HistoryEvent_WorkflowCompleted struct {
WorkflowCompleted *WorkflowCompletedEvent `protobuf:"bytes,15,opt,name=workflowCompleted,proto3,oneof"`
}
type HistoryEvent_WorkflowStarted ¶
type HistoryEvent_WorkflowStarted struct {
WorkflowStarted *WorkflowStartedEvent `protobuf:"bytes,14,opt,name=workflowStarted,proto3,oneof"`
}
type HistoryPropagationScope ¶
type HistoryPropagationScope int32
HistoryPropagationScope controls how history is propagated to a child workflow or activity
const ( // No propagation. This is the default for an unset/missing field; the // child receives no history from the caller. HistoryPropagationScope_HISTORY_PROPAGATION_SCOPE_NONE HistoryPropagationScope = 0 // Propagate the caller's own history events only. The child does // not see any ancestral history (trust boundary). HistoryPropagationScope_HISTORY_PROPAGATION_SCOPE_OWN_HISTORY HistoryPropagationScope = 1 // Propagate the caller's own history events AND the full ancestral // chain. Any propagated history this workflow received from its // parent is forwarded to the child. HistoryPropagationScope_HISTORY_PROPAGATION_SCOPE_LINEAGE HistoryPropagationScope = 2 )
func (HistoryPropagationScope) Descriptor ¶
func (HistoryPropagationScope) Descriptor() protoreflect.EnumDescriptor
func (HistoryPropagationScope) Enum ¶
func (x HistoryPropagationScope) Enum() *HistoryPropagationScope
func (HistoryPropagationScope) EnumDescriptor
deprecated
func (HistoryPropagationScope) EnumDescriptor() ([]byte, []int)
Deprecated: Use HistoryPropagationScope.Descriptor instead.
func (HistoryPropagationScope) Number ¶
func (x HistoryPropagationScope) Number() protoreflect.EnumNumber
func (HistoryPropagationScope) String ¶
func (x HistoryPropagationScope) String() string
func (HistoryPropagationScope) Type ¶
func (HistoryPropagationScope) Type() protoreflect.EnumType
type ListInstanceIDsRequest ¶
type ListInstanceIDsRequest struct {
// continuationToken is the continuation token to use for pagination. This
// is the token which the next page should start from. If not given, the
// first page will be returned.
ContinuationToken *string `protobuf:"bytes,1,opt,name=continuationToken,proto3,oneof" json:"continuationToken,omitempty"`
// pageSize is the maximum number of instances to return for this page. If
// not given, all instances will be attempted to be returned.
PageSize *uint32 `protobuf:"varint,2,opt,name=pageSize,proto3,oneof" json:"pageSize,omitempty"`
// contains filtered or unexported fields
}
ListInstanceIDsRequest is used to list all workflow instances.
func (*ListInstanceIDsRequest) Descriptor
deprecated
func (*ListInstanceIDsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListInstanceIDsRequest.ProtoReflect.Descriptor instead.
func (*ListInstanceIDsRequest) GetContinuationToken ¶
func (x *ListInstanceIDsRequest) GetContinuationToken() string
func (*ListInstanceIDsRequest) GetPageSize ¶
func (x *ListInstanceIDsRequest) GetPageSize() uint32
func (*ListInstanceIDsRequest) ProtoMessage ¶
func (*ListInstanceIDsRequest) ProtoMessage()
func (*ListInstanceIDsRequest) ProtoReflect ¶
func (x *ListInstanceIDsRequest) ProtoReflect() protoreflect.Message
func (*ListInstanceIDsRequest) Reset ¶
func (x *ListInstanceIDsRequest) Reset()
func (*ListInstanceIDsRequest) String ¶
func (x *ListInstanceIDsRequest) String() string
type ListInstanceIDsResponse ¶
type ListInstanceIDsResponse struct {
// instanceIds is the list of instance IDs returned.
InstanceIds []string `protobuf:"bytes,1,rep,name=instanceIds,proto3" json:"instanceIds,omitempty"`
// continuationToken is the continuation token to use for pagination. If
// there are no more pages, this will be null.
ContinuationToken *string `protobuf:"bytes,2,opt,name=continuationToken,proto3,oneof" json:"continuationToken,omitempty"`
// contains filtered or unexported fields
}
ListInstanceIDsResponse is the response to executing ListInstanceIDs.
func (*ListInstanceIDsResponse) Descriptor
deprecated
func (*ListInstanceIDsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListInstanceIDsResponse.ProtoReflect.Descriptor instead.
func (*ListInstanceIDsResponse) GetContinuationToken ¶
func (x *ListInstanceIDsResponse) GetContinuationToken() string
func (*ListInstanceIDsResponse) GetInstanceIds ¶
func (x *ListInstanceIDsResponse) GetInstanceIds() []string
func (*ListInstanceIDsResponse) ProtoMessage ¶
func (*ListInstanceIDsResponse) ProtoMessage()
func (*ListInstanceIDsResponse) ProtoReflect ¶
func (x *ListInstanceIDsResponse) ProtoReflect() protoreflect.Message
func (*ListInstanceIDsResponse) Reset ¶
func (x *ListInstanceIDsResponse) Reset()
func (*ListInstanceIDsResponse) String ¶
func (x *ListInstanceIDsResponse) String() string
type OrchestrationInstance
deprecated
type OrchestrationInstance = WorkflowInstance
Deprecated: Use WorkflowInstance instead.
type OrchestrationMetadata
deprecated
type OrchestrationMetadata = WorkflowMetadata
Deprecated: Use WorkflowMetadata instead.
type OrchestrationRuntimeState
deprecated
type OrchestrationRuntimeState = WorkflowRuntimeState
Deprecated: Use WorkflowRuntimeState instead.
type OrchestrationRuntimeStateMessage
deprecated
type OrchestrationRuntimeStateMessage = WorkflowRuntimeStateMessage
Deprecated: Use WorkflowRuntimeStateMessage instead.
type OrchestrationState
deprecated
type OrchestrationState = WorkflowState
Deprecated: Use WorkflowState instead.
type OrchestrationStatus ¶
type OrchestrationStatus int32
const ( OrchestrationStatus_ORCHESTRATION_STATUS_RUNNING OrchestrationStatus = 0 OrchestrationStatus_ORCHESTRATION_STATUS_COMPLETED OrchestrationStatus = 1 OrchestrationStatus_ORCHESTRATION_STATUS_CONTINUED_AS_NEW OrchestrationStatus = 2 OrchestrationStatus_ORCHESTRATION_STATUS_FAILED OrchestrationStatus = 3 OrchestrationStatus_ORCHESTRATION_STATUS_CANCELED OrchestrationStatus = 4 OrchestrationStatus_ORCHESTRATION_STATUS_TERMINATED OrchestrationStatus = 5 OrchestrationStatus_ORCHESTRATION_STATUS_PENDING OrchestrationStatus = 6 OrchestrationStatus_ORCHESTRATION_STATUS_SUSPENDED OrchestrationStatus = 7 OrchestrationStatus_ORCHESTRATION_STATUS_STALLED OrchestrationStatus = 8 )
func (OrchestrationStatus) Descriptor ¶
func (OrchestrationStatus) Descriptor() protoreflect.EnumDescriptor
func (OrchestrationStatus) Enum ¶
func (x OrchestrationStatus) Enum() *OrchestrationStatus
func (OrchestrationStatus) EnumDescriptor
deprecated
func (OrchestrationStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use OrchestrationStatus.Descriptor instead.
func (OrchestrationStatus) Number ¶
func (x OrchestrationStatus) Number() protoreflect.EnumNumber
func (OrchestrationStatus) String ¶
func (x OrchestrationStatus) String() string
func (OrchestrationStatus) Type ¶
func (OrchestrationStatus) Type() protoreflect.EnumType
type OrchestratorAction
deprecated
type OrchestratorAction = WorkflowAction
Deprecated: Use WorkflowAction instead.
type OrchestratorAction_CompleteOrchestration
deprecated
type OrchestratorAction_CompleteOrchestration = WorkflowAction_CompleteWorkflow
Deprecated: Use WorkflowAction_CompleteWorkflow instead.
type OrchestratorAction_CreateSubOrchestration
deprecated
type OrchestratorAction_CreateSubOrchestration = WorkflowAction_CreateChildWorkflow
Deprecated: Use WorkflowAction_CreateChildWorkflow instead.
type OrchestratorAction_CreateTimer
deprecated
type OrchestratorAction_CreateTimer = WorkflowAction_CreateTimer
Deprecated: Use WorkflowAction_CreateTimer instead.
type OrchestratorAction_OrchestratorVersionNotAvailable
deprecated
type OrchestratorAction_OrchestratorVersionNotAvailable = WorkflowAction_WorkflowVersionNotAvailable
Deprecated: Use WorkflowAction_WorkflowVersionNotAvailable instead.
type OrchestratorAction_ScheduleTask
deprecated
type OrchestratorAction_ScheduleTask = WorkflowAction_ScheduleTask
Deprecated: Use WorkflowAction_ScheduleTask instead.
type OrchestratorAction_SendEvent
deprecated
type OrchestratorAction_SendEvent = WorkflowAction_SendEvent
Deprecated: Use WorkflowAction_SendEvent instead.
type OrchestratorAction_TerminateOrchestration
deprecated
type OrchestratorAction_TerminateOrchestration = WorkflowAction_TerminateWorkflow
Deprecated: Use WorkflowAction_TerminateWorkflow instead.
type OrchestratorCompletedEvent
deprecated
type OrchestratorCompletedEvent = WorkflowCompletedEvent
Deprecated: Use WorkflowCompletedEvent instead.
type OrchestratorMessage
deprecated
type OrchestratorMessage = WorkflowMessage
Deprecated: Use WorkflowMessage instead.
type OrchestratorRequest
deprecated
type OrchestratorRequest = WorkflowRequest
Deprecated: Use WorkflowRequest instead.
type OrchestratorResponse
deprecated
type OrchestratorResponse = WorkflowResponse
Deprecated: Use WorkflowResponse instead.
type OrchestratorStartedEvent
deprecated
type OrchestratorStartedEvent = WorkflowStartedEvent
Deprecated: Use WorkflowStartedEvent instead.
type OrchestratorVersionNotAvailableAction
deprecated
type OrchestratorVersionNotAvailableAction = WorkflowVersionNotAvailableAction
Deprecated: Use WorkflowVersionNotAvailableAction instead.
type ParentInstanceInfo ¶
type ParentInstanceInfo struct {
TaskScheduledId int32 `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
Name *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Version *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
WorkflowInstance *WorkflowInstance `protobuf:"bytes,4,opt,name=workflowInstance,proto3" json:"workflowInstance,omitempty"`
AppID *string `protobuf:"bytes,5,opt,name=appID,proto3,oneof" json:"appID,omitempty"`
AppNamespace *string `protobuf:"bytes,6,opt,name=appNamespace,proto3,oneof" json:"appNamespace,omitempty"`
// contains filtered or unexported fields
}
func (*ParentInstanceInfo) Descriptor
deprecated
func (*ParentInstanceInfo) Descriptor() ([]byte, []int)
Deprecated: Use ParentInstanceInfo.ProtoReflect.Descriptor instead.
func (*ParentInstanceInfo) GetAppID ¶
func (x *ParentInstanceInfo) GetAppID() string
func (*ParentInstanceInfo) GetAppNamespace ¶
func (x *ParentInstanceInfo) GetAppNamespace() string
func (*ParentInstanceInfo) GetName ¶
func (x *ParentInstanceInfo) GetName() *wrapperspb.StringValue
func (*ParentInstanceInfo) GetOrchestrationInstance
deprecated
func (x *ParentInstanceInfo) GetOrchestrationInstance() *WorkflowInstance
Deprecated: Use GetWorkflowInstance instead.
func (*ParentInstanceInfo) GetTaskScheduledId ¶
func (x *ParentInstanceInfo) GetTaskScheduledId() int32
func (*ParentInstanceInfo) GetVersion ¶
func (x *ParentInstanceInfo) GetVersion() *wrapperspb.StringValue
func (*ParentInstanceInfo) GetWorkflowInstance ¶
func (x *ParentInstanceInfo) GetWorkflowInstance() *WorkflowInstance
func (*ParentInstanceInfo) ProtoMessage ¶
func (*ParentInstanceInfo) ProtoMessage()
func (*ParentInstanceInfo) ProtoReflect ¶
func (x *ParentInstanceInfo) ProtoReflect() protoreflect.Message
func (*ParentInstanceInfo) Reset ¶
func (x *ParentInstanceInfo) Reset()
func (*ParentInstanceInfo) String ¶
func (x *ParentInstanceInfo) String() string
type PropagatedHistory ¶
type PropagatedHistory struct {
// The propagation scope that was used to produce this history.
Scope HistoryPropagationScope `protobuf:"varint,1,opt,name=scope,proto3,enum=HistoryPropagationScope" json:"scope,omitempty"`
// Per-app history chunks. Each chunk owns the raw event bytes its producer
// signed (PropagatedHistoryChunk.rawEvents); receivers digest those bytes
// directly and decode them into typed HistoryEvents on demand. Chunks are
// ordered, non-overlapping, and together describe the full propagated
// event sequence.
Chunks []*PropagatedHistoryChunk `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks,omitempty"`
// contains filtered or unexported fields
}
func (*PropagatedHistory) Descriptor
deprecated
func (*PropagatedHistory) Descriptor() ([]byte, []int)
Deprecated: Use PropagatedHistory.ProtoReflect.Descriptor instead.
func (*PropagatedHistory) GetChunks ¶
func (x *PropagatedHistory) GetChunks() []*PropagatedHistoryChunk
func (*PropagatedHistory) GetScope ¶
func (x *PropagatedHistory) GetScope() HistoryPropagationScope
func (*PropagatedHistory) ProtoMessage ¶
func (*PropagatedHistory) ProtoMessage()
func (*PropagatedHistory) ProtoReflect ¶
func (x *PropagatedHistory) ProtoReflect() protoreflect.Message
func (*PropagatedHistory) Reset ¶
func (x *PropagatedHistory) Reset()
func (*PropagatedHistory) String ¶
func (x *PropagatedHistory) String() string
type PropagatedHistoryChunk ¶
type PropagatedHistoryChunk struct {
// Raw protobuf bytes of each HistoryEvent in this chunk, in execution order.
RawEvents [][]byte `protobuf:"bytes,1,rep,name=rawEvents,proto3" json:"rawEvents,omitempty"`
AppId string `protobuf:"bytes,2,opt,name=appId,proto3" json:"appId,omitempty"`
// The workflow instance ID/name that produced the events in this chunk.
InstanceId string `protobuf:"bytes,3,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
WorkflowName string `protobuf:"bytes,4,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
// contains filtered or unexported fields
}
A self-contained range of events produced by a single app, used when history from multiple workflows is propagated to a downstream workflow or activity. Each chunk owns its raw event bytes, which receivers decode into typed HistoryEvents on demand.
func (*PropagatedHistoryChunk) Descriptor
deprecated
func (*PropagatedHistoryChunk) Descriptor() ([]byte, []int)
Deprecated: Use PropagatedHistoryChunk.ProtoReflect.Descriptor instead.
func (*PropagatedHistoryChunk) GetAppId ¶
func (x *PropagatedHistoryChunk) GetAppId() string
func (*PropagatedHistoryChunk) GetInstanceId ¶
func (x *PropagatedHistoryChunk) GetInstanceId() string
func (*PropagatedHistoryChunk) GetRawEvents ¶
func (x *PropagatedHistoryChunk) GetRawEvents() [][]byte
func (*PropagatedHistoryChunk) GetWorkflowName ¶
func (x *PropagatedHistoryChunk) GetWorkflowName() string
func (*PropagatedHistoryChunk) ProtoMessage ¶
func (*PropagatedHistoryChunk) ProtoMessage()
func (*PropagatedHistoryChunk) ProtoReflect ¶
func (x *PropagatedHistoryChunk) ProtoReflect() protoreflect.Message
func (*PropagatedHistoryChunk) Reset ¶
func (x *PropagatedHistoryChunk) Reset()
func (*PropagatedHistoryChunk) String ¶
func (x *PropagatedHistoryChunk) String() string
type PurgeInstanceFilter ¶
type PurgeInstanceFilter struct {
CreatedTimeFrom *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=createdTimeFrom,proto3" json:"createdTimeFrom,omitempty"`
CreatedTimeTo *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=createdTimeTo,proto3" json:"createdTimeTo,omitempty"`
RuntimeStatus []OrchestrationStatus `protobuf:"varint,3,rep,packed,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
// contains filtered or unexported fields
}
func (*PurgeInstanceFilter) Descriptor
deprecated
func (*PurgeInstanceFilter) Descriptor() ([]byte, []int)
Deprecated: Use PurgeInstanceFilter.ProtoReflect.Descriptor instead.
func (*PurgeInstanceFilter) GetCreatedTimeFrom ¶
func (x *PurgeInstanceFilter) GetCreatedTimeFrom() *timestamppb.Timestamp
func (*PurgeInstanceFilter) GetCreatedTimeTo ¶
func (x *PurgeInstanceFilter) GetCreatedTimeTo() *timestamppb.Timestamp
func (*PurgeInstanceFilter) GetRuntimeStatus ¶
func (x *PurgeInstanceFilter) GetRuntimeStatus() []OrchestrationStatus
func (*PurgeInstanceFilter) ProtoMessage ¶
func (*PurgeInstanceFilter) ProtoMessage()
func (*PurgeInstanceFilter) ProtoReflect ¶
func (x *PurgeInstanceFilter) ProtoReflect() protoreflect.Message
func (*PurgeInstanceFilter) Reset ¶
func (x *PurgeInstanceFilter) Reset()
func (*PurgeInstanceFilter) String ¶
func (x *PurgeInstanceFilter) String() string
type PurgeInstancesRequest ¶
type PurgeInstancesRequest struct {
// Types that are assignable to Request:
//
// *PurgeInstancesRequest_InstanceId
// *PurgeInstancesRequest_PurgeInstanceFilter
Request isPurgeInstancesRequest_Request `protobuf_oneof:"request"`
Recursive bool `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
// force will force a purge of a workflow, regardless of its current
// runtime state, or whether an active worker can process it, the backend
// will attempt to delete it anyway. This neccessarily means the purging is
// executed out side of the workflow state machine, and therefore, can lead
// to corrupt state or broken workflow execution. Usage of this should
// _only_ be used when the client knows the workflow is not being currently
// processed. It is highly recommended to avoid using this flag unless
// absolutely necessary.
// Defaults to false.
Force *bool `protobuf:"varint,4,opt,name=force,proto3,oneof" json:"force,omitempty"`
// router optionally routes this operation to the workflow instance owned
// by another app. Cross-app purges are delegated to the target app in
// full, so they are always recursive on the remote side. sourceAppID is
// stamped by the sidecar, not the client.
Router *TaskRouter `protobuf:"bytes,5,opt,name=router,proto3,oneof" json:"router,omitempty"`
// contains filtered or unexported fields
}
func (*PurgeInstancesRequest) Descriptor
deprecated
func (*PurgeInstancesRequest) Descriptor() ([]byte, []int)
Deprecated: Use PurgeInstancesRequest.ProtoReflect.Descriptor instead.
func (*PurgeInstancesRequest) GetForce ¶
func (x *PurgeInstancesRequest) GetForce() bool
func (*PurgeInstancesRequest) GetInstanceId ¶
func (x *PurgeInstancesRequest) GetInstanceId() string
func (*PurgeInstancesRequest) GetPurgeInstanceFilter ¶
func (x *PurgeInstancesRequest) GetPurgeInstanceFilter() *PurgeInstanceFilter
func (*PurgeInstancesRequest) GetRecursive ¶
func (x *PurgeInstancesRequest) GetRecursive() bool
func (*PurgeInstancesRequest) GetRequest ¶
func (m *PurgeInstancesRequest) GetRequest() isPurgeInstancesRequest_Request
func (*PurgeInstancesRequest) GetRouter ¶
func (x *PurgeInstancesRequest) GetRouter() *TaskRouter
func (*PurgeInstancesRequest) ProtoMessage ¶
func (*PurgeInstancesRequest) ProtoMessage()
func (*PurgeInstancesRequest) ProtoReflect ¶
func (x *PurgeInstancesRequest) ProtoReflect() protoreflect.Message
func (*PurgeInstancesRequest) Reset ¶
func (x *PurgeInstancesRequest) Reset()
func (*PurgeInstancesRequest) String ¶
func (x *PurgeInstancesRequest) String() string
type PurgeInstancesRequest_InstanceId ¶
type PurgeInstancesRequest_InstanceId struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof"`
}
type PurgeInstancesRequest_PurgeInstanceFilter ¶
type PurgeInstancesRequest_PurgeInstanceFilter struct {
PurgeInstanceFilter *PurgeInstanceFilter `protobuf:"bytes,2,opt,name=purgeInstanceFilter,proto3,oneof"`
}
type PurgeInstancesResponse ¶
type PurgeInstancesResponse struct {
DeletedInstanceCount int32 `protobuf:"varint,1,opt,name=deletedInstanceCount,proto3" json:"deletedInstanceCount,omitempty"`
IsComplete *wrapperspb.BoolValue `protobuf:"bytes,2,opt,name=isComplete,proto3" json:"isComplete,omitempty"`
// contains filtered or unexported fields
}
func (*PurgeInstancesResponse) Descriptor
deprecated
func (*PurgeInstancesResponse) Descriptor() ([]byte, []int)
Deprecated: Use PurgeInstancesResponse.ProtoReflect.Descriptor instead.
func (*PurgeInstancesResponse) GetDeletedInstanceCount ¶
func (x *PurgeInstancesResponse) GetDeletedInstanceCount() int32
func (*PurgeInstancesResponse) GetIsComplete ¶
func (x *PurgeInstancesResponse) GetIsComplete() *wrapperspb.BoolValue
func (*PurgeInstancesResponse) ProtoMessage ¶
func (*PurgeInstancesResponse) ProtoMessage()
func (*PurgeInstancesResponse) ProtoReflect ¶
func (x *PurgeInstancesResponse) ProtoReflect() protoreflect.Message
func (*PurgeInstancesResponse) Reset ¶
func (x *PurgeInstancesResponse) Reset()
func (*PurgeInstancesResponse) String ¶
func (x *PurgeInstancesResponse) String() string
type RaiseEventRequest ¶
type RaiseEventRequest struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
// router optionally routes this operation to the workflow instance owned
// by another app. sourceAppID is stamped by the sidecar, not the client.
Router *TaskRouter `protobuf:"bytes,4,opt,name=router,proto3,oneof" json:"router,omitempty"`
// contains filtered or unexported fields
}
func (*RaiseEventRequest) Descriptor
deprecated
func (*RaiseEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use RaiseEventRequest.ProtoReflect.Descriptor instead.
func (*RaiseEventRequest) GetInput ¶
func (x *RaiseEventRequest) GetInput() *wrapperspb.StringValue
func (*RaiseEventRequest) GetInstanceId ¶
func (x *RaiseEventRequest) GetInstanceId() string
func (*RaiseEventRequest) GetName ¶
func (x *RaiseEventRequest) GetName() string
func (*RaiseEventRequest) GetRouter ¶
func (x *RaiseEventRequest) GetRouter() *TaskRouter
func (*RaiseEventRequest) ProtoMessage ¶
func (*RaiseEventRequest) ProtoMessage()
func (*RaiseEventRequest) ProtoReflect ¶
func (x *RaiseEventRequest) ProtoReflect() protoreflect.Message
func (*RaiseEventRequest) Reset ¶
func (x *RaiseEventRequest) Reset()
func (*RaiseEventRequest) String ¶
func (x *RaiseEventRequest) String() string
type RaiseEventResponse ¶
type RaiseEventResponse struct {
// contains filtered or unexported fields
}
func (*RaiseEventResponse) Descriptor
deprecated
func (*RaiseEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use RaiseEventResponse.ProtoReflect.Descriptor instead.
func (*RaiseEventResponse) ProtoMessage ¶
func (*RaiseEventResponse) ProtoMessage()
func (*RaiseEventResponse) ProtoReflect ¶
func (x *RaiseEventResponse) ProtoReflect() protoreflect.Message
func (*RaiseEventResponse) Reset ¶
func (x *RaiseEventResponse) Reset()
func (*RaiseEventResponse) String ¶
func (x *RaiseEventResponse) String() string
type ResumeRequest ¶
type ResumeRequest struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Reason *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
// router optionally routes this operation to the workflow instance owned
// by another app. sourceAppID is stamped by the sidecar, not the client.
Router *TaskRouter `protobuf:"bytes,3,opt,name=router,proto3,oneof" json:"router,omitempty"`
// contains filtered or unexported fields
}
func (*ResumeRequest) Descriptor
deprecated
func (*ResumeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.
func (*ResumeRequest) GetInstanceId ¶
func (x *ResumeRequest) GetInstanceId() string
func (*ResumeRequest) GetReason ¶
func (x *ResumeRequest) GetReason() *wrapperspb.StringValue
func (*ResumeRequest) GetRouter ¶
func (x *ResumeRequest) GetRouter() *TaskRouter
func (*ResumeRequest) ProtoMessage ¶
func (*ResumeRequest) ProtoMessage()
func (*ResumeRequest) ProtoReflect ¶
func (x *ResumeRequest) ProtoReflect() protoreflect.Message
func (*ResumeRequest) Reset ¶
func (x *ResumeRequest) Reset()
func (*ResumeRequest) String ¶
func (x *ResumeRequest) String() string
type ResumeResponse ¶
type ResumeResponse struct {
// contains filtered or unexported fields
}
func (*ResumeResponse) Descriptor
deprecated
func (*ResumeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResumeResponse.ProtoReflect.Descriptor instead.
func (*ResumeResponse) ProtoMessage ¶
func (*ResumeResponse) ProtoMessage()
func (*ResumeResponse) ProtoReflect ¶
func (x *ResumeResponse) ProtoReflect() protoreflect.Message
func (*ResumeResponse) Reset ¶
func (x *ResumeResponse) Reset()
func (*ResumeResponse) String ¶
func (x *ResumeResponse) String() string
type RetryParentInstanceInfo ¶
type RetryParentInstanceInfo struct {
// instanceID is the instance ID of the first attempt in this child-workflow
// retry chain.
InstanceID string `protobuf:"bytes,1,opt,name=instanceID,proto3" json:"instanceID,omitempty"`
// contains filtered or unexported fields
}
RetryParentInstanceInfo correlates a child-workflow retry attempt with the initial attempt that spawned it. When a child workflow is scheduled with a retry policy, each retry executes as a separate child workflow instance with its own auto-generated instance ID. This message provides an explicit, first-class link back to the first attempt so consumers no longer need to reconstruct the relationship from event ordering and timer origins.
Semantics: the first attempt carries no RetryParentInstanceInfo. Retry attempts (2nd onward) carry RetryParentInstanceInfo with instanceID set to the first attempt's instance ID. Consumers group attempts by reading the parent workflow's history; the group key is retryParentInstanceInfo.instanceID when present, otherwise the event's own instanceId.
func (*RetryParentInstanceInfo) Descriptor
deprecated
func (*RetryParentInstanceInfo) Descriptor() ([]byte, []int)
Deprecated: Use RetryParentInstanceInfo.ProtoReflect.Descriptor instead.
func (*RetryParentInstanceInfo) GetInstanceID ¶
func (x *RetryParentInstanceInfo) GetInstanceID() string
func (*RetryParentInstanceInfo) ProtoMessage ¶
func (*RetryParentInstanceInfo) ProtoMessage()
func (*RetryParentInstanceInfo) ProtoReflect ¶
func (x *RetryParentInstanceInfo) ProtoReflect() protoreflect.Message
func (*RetryParentInstanceInfo) Reset ¶
func (x *RetryParentInstanceInfo) Reset()
func (*RetryParentInstanceInfo) String ¶
func (x *RetryParentInstanceInfo) String() string
type RuntimeStateStalled ¶
type RuntimeStateStalled struct {
Reason StalledReason `protobuf:"varint,1,opt,name=reason,proto3,enum=StalledReason" json:"reason,omitempty"`
Description *string `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"`
// contains filtered or unexported fields
}
func (*RuntimeStateStalled) Descriptor
deprecated
func (*RuntimeStateStalled) Descriptor() ([]byte, []int)
Deprecated: Use RuntimeStateStalled.ProtoReflect.Descriptor instead.
func (*RuntimeStateStalled) GetDescription ¶
func (x *RuntimeStateStalled) GetDescription() string
func (*RuntimeStateStalled) GetReason ¶
func (x *RuntimeStateStalled) GetReason() StalledReason
func (*RuntimeStateStalled) ProtoMessage ¶
func (*RuntimeStateStalled) ProtoMessage()
func (*RuntimeStateStalled) ProtoReflect ¶
func (x *RuntimeStateStalled) ProtoReflect() protoreflect.Message
func (*RuntimeStateStalled) Reset ¶
func (x *RuntimeStateStalled) Reset()
func (*RuntimeStateStalled) String ¶
func (x *RuntimeStateStalled) String() string
type ScheduleTaskAction ¶
type ScheduleTaskAction struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Version *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
TaskExecutionId string `protobuf:"bytes,5,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
// History propagation scope. Absent/SCOPE_NONE = no propagation.
HistoryPropagationScope *HistoryPropagationScope `` /* 135-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*ScheduleTaskAction) Descriptor
deprecated
func (*ScheduleTaskAction) Descriptor() ([]byte, []int)
Deprecated: Use ScheduleTaskAction.ProtoReflect.Descriptor instead.
func (*ScheduleTaskAction) GetHistoryPropagationScope ¶
func (x *ScheduleTaskAction) GetHistoryPropagationScope() HistoryPropagationScope
func (*ScheduleTaskAction) GetInput ¶
func (x *ScheduleTaskAction) GetInput() *wrapperspb.StringValue
func (*ScheduleTaskAction) GetName ¶
func (x *ScheduleTaskAction) GetName() string
func (*ScheduleTaskAction) GetTaskExecutionId ¶
func (x *ScheduleTaskAction) GetTaskExecutionId() string
func (*ScheduleTaskAction) GetVersion ¶
func (x *ScheduleTaskAction) GetVersion() *wrapperspb.StringValue
func (*ScheduleTaskAction) ProtoMessage ¶
func (*ScheduleTaskAction) ProtoMessage()
func (*ScheduleTaskAction) ProtoReflect ¶
func (x *ScheduleTaskAction) ProtoReflect() protoreflect.Message
func (*ScheduleTaskAction) Reset ¶
func (x *ScheduleTaskAction) Reset()
func (*ScheduleTaskAction) String ¶
func (x *ScheduleTaskAction) String() string
type SendEventAction ¶
type SendEventAction struct {
Instance *WorkflowInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Data *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
// contains filtered or unexported fields
}
func (*SendEventAction) Descriptor
deprecated
func (*SendEventAction) Descriptor() ([]byte, []int)
Deprecated: Use SendEventAction.ProtoReflect.Descriptor instead.
func (*SendEventAction) GetData ¶
func (x *SendEventAction) GetData() *wrapperspb.StringValue
func (*SendEventAction) GetInstance ¶
func (x *SendEventAction) GetInstance() *WorkflowInstance
func (*SendEventAction) GetName ¶
func (x *SendEventAction) GetName() string
func (*SendEventAction) ProtoMessage ¶
func (*SendEventAction) ProtoMessage()
func (*SendEventAction) ProtoReflect ¶
func (x *SendEventAction) ProtoReflect() protoreflect.Message
func (*SendEventAction) Reset ¶
func (x *SendEventAction) Reset()
func (*SendEventAction) String ¶
func (x *SendEventAction) String() string
type StalledReason ¶
type StalledReason int32
const ( StalledReason_PATCH_MISMATCH StalledReason = 0 StalledReason_VERSION_NOT_AVAILABLE StalledReason = 1 StalledReason_PAYLOAD_SIZE_EXCEEDED StalledReason = 2 )
func (StalledReason) Descriptor ¶
func (StalledReason) Descriptor() protoreflect.EnumDescriptor
func (StalledReason) Enum ¶
func (x StalledReason) Enum() *StalledReason
func (StalledReason) EnumDescriptor
deprecated
func (StalledReason) EnumDescriptor() ([]byte, []int)
Deprecated: Use StalledReason.Descriptor instead.
func (StalledReason) Number ¶
func (x StalledReason) Number() protoreflect.EnumNumber
func (StalledReason) String ¶
func (x StalledReason) String() string
func (StalledReason) Type ¶
func (StalledReason) Type() protoreflect.EnumType
type SubOrchestrationInstanceCompletedEvent
deprecated
type SubOrchestrationInstanceCompletedEvent = ChildWorkflowInstanceCompletedEvent
Deprecated: Use ChildWorkflowInstanceCompletedEvent instead.
type SubOrchestrationInstanceCreatedEvent
deprecated
type SubOrchestrationInstanceCreatedEvent = ChildWorkflowInstanceCreatedEvent
Deprecated: Use ChildWorkflowInstanceCreatedEvent instead.
type SubOrchestrationInstanceFailedEvent
deprecated
type SubOrchestrationInstanceFailedEvent = ChildWorkflowInstanceFailedEvent
Deprecated: Use ChildWorkflowInstanceFailedEvent instead.
type SuspendRequest ¶
type SuspendRequest struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Reason *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
// router optionally routes this operation to the workflow instance owned
// by another app. sourceAppID is stamped by the sidecar, not the client.
Router *TaskRouter `protobuf:"bytes,3,opt,name=router,proto3,oneof" json:"router,omitempty"`
// contains filtered or unexported fields
}
func (*SuspendRequest) Descriptor
deprecated
func (*SuspendRequest) Descriptor() ([]byte, []int)
Deprecated: Use SuspendRequest.ProtoReflect.Descriptor instead.
func (*SuspendRequest) GetInstanceId ¶
func (x *SuspendRequest) GetInstanceId() string
func (*SuspendRequest) GetReason ¶
func (x *SuspendRequest) GetReason() *wrapperspb.StringValue
func (*SuspendRequest) GetRouter ¶
func (x *SuspendRequest) GetRouter() *TaskRouter
func (*SuspendRequest) ProtoMessage ¶
func (*SuspendRequest) ProtoMessage()
func (*SuspendRequest) ProtoReflect ¶
func (x *SuspendRequest) ProtoReflect() protoreflect.Message
func (*SuspendRequest) Reset ¶
func (x *SuspendRequest) Reset()
func (*SuspendRequest) String ¶
func (x *SuspendRequest) String() string
type SuspendResponse ¶
type SuspendResponse struct {
// contains filtered or unexported fields
}
func (*SuspendResponse) Descriptor
deprecated
func (*SuspendResponse) Descriptor() ([]byte, []int)
Deprecated: Use SuspendResponse.ProtoReflect.Descriptor instead.
func (*SuspendResponse) ProtoMessage ¶
func (*SuspendResponse) ProtoMessage()
func (*SuspendResponse) ProtoReflect ¶
func (x *SuspendResponse) ProtoReflect() protoreflect.Message
func (*SuspendResponse) Reset ¶
func (x *SuspendResponse) Reset()
func (*SuspendResponse) String ¶
func (x *SuspendResponse) String() string
type TaskCompletedEvent ¶
type TaskCompletedEvent struct {
TaskScheduledId int32 `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
Result *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
TaskExecutionId string `protobuf:"bytes,3,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
// contains filtered or unexported fields
}
func (*TaskCompletedEvent) Descriptor
deprecated
func (*TaskCompletedEvent) Descriptor() ([]byte, []int)
Deprecated: Use TaskCompletedEvent.ProtoReflect.Descriptor instead.
func (*TaskCompletedEvent) GetResult ¶
func (x *TaskCompletedEvent) GetResult() *wrapperspb.StringValue
func (*TaskCompletedEvent) GetTaskExecutionId ¶
func (x *TaskCompletedEvent) GetTaskExecutionId() string
func (*TaskCompletedEvent) GetTaskScheduledId ¶
func (x *TaskCompletedEvent) GetTaskScheduledId() int32
func (*TaskCompletedEvent) ProtoMessage ¶
func (*TaskCompletedEvent) ProtoMessage()
func (*TaskCompletedEvent) ProtoReflect ¶
func (x *TaskCompletedEvent) ProtoReflect() protoreflect.Message
func (*TaskCompletedEvent) Reset ¶
func (x *TaskCompletedEvent) Reset()
func (*TaskCompletedEvent) String ¶
func (x *TaskCompletedEvent) String() string
type TaskFailedEvent ¶
type TaskFailedEvent struct {
TaskScheduledId int32 `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
FailureDetails *TaskFailureDetails `protobuf:"bytes,2,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
TaskExecutionId string `protobuf:"bytes,3,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
// contains filtered or unexported fields
}
func (*TaskFailedEvent) Descriptor
deprecated
func (*TaskFailedEvent) Descriptor() ([]byte, []int)
Deprecated: Use TaskFailedEvent.ProtoReflect.Descriptor instead.
func (*TaskFailedEvent) GetFailureDetails ¶
func (x *TaskFailedEvent) GetFailureDetails() *TaskFailureDetails
func (*TaskFailedEvent) GetTaskExecutionId ¶
func (x *TaskFailedEvent) GetTaskExecutionId() string
func (*TaskFailedEvent) GetTaskScheduledId ¶
func (x *TaskFailedEvent) GetTaskScheduledId() int32
func (*TaskFailedEvent) ProtoMessage ¶
func (*TaskFailedEvent) ProtoMessage()
func (*TaskFailedEvent) ProtoReflect ¶
func (x *TaskFailedEvent) ProtoReflect() protoreflect.Message
func (*TaskFailedEvent) Reset ¶
func (x *TaskFailedEvent) Reset()
func (*TaskFailedEvent) String ¶
func (x *TaskFailedEvent) String() string
type TaskFailureDetails ¶
type TaskFailureDetails struct {
ErrorType string `protobuf:"bytes,1,opt,name=errorType,proto3" json:"errorType,omitempty"`
ErrorMessage string `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
StackTrace *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=stackTrace,proto3" json:"stackTrace,omitempty"`
InnerFailure *TaskFailureDetails `protobuf:"bytes,4,opt,name=innerFailure,proto3" json:"innerFailure,omitempty"`
IsNonRetriable bool `protobuf:"varint,5,opt,name=isNonRetriable,proto3" json:"isNonRetriable,omitempty"`
// contains filtered or unexported fields
}
func (*TaskFailureDetails) Descriptor
deprecated
func (*TaskFailureDetails) Descriptor() ([]byte, []int)
Deprecated: Use TaskFailureDetails.ProtoReflect.Descriptor instead.
func (*TaskFailureDetails) GetErrorMessage ¶
func (x *TaskFailureDetails) GetErrorMessage() string
func (*TaskFailureDetails) GetErrorType ¶
func (x *TaskFailureDetails) GetErrorType() string
func (*TaskFailureDetails) GetInnerFailure ¶
func (x *TaskFailureDetails) GetInnerFailure() *TaskFailureDetails
func (*TaskFailureDetails) GetIsNonRetriable ¶
func (x *TaskFailureDetails) GetIsNonRetriable() bool
func (*TaskFailureDetails) GetStackTrace ¶
func (x *TaskFailureDetails) GetStackTrace() *wrapperspb.StringValue
func (*TaskFailureDetails) ProtoMessage ¶
func (*TaskFailureDetails) ProtoMessage()
func (*TaskFailureDetails) ProtoReflect ¶
func (x *TaskFailureDetails) ProtoReflect() protoreflect.Message
func (*TaskFailureDetails) Reset ¶
func (x *TaskFailureDetails) Reset()
func (*TaskFailureDetails) String ¶
func (x *TaskFailureDetails) String() string
type TaskHubSidecarServiceClient ¶
type TaskHubSidecarServiceClient interface {
// Sends a hello request to the sidecar service.
Hello(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Starts a new workflow instance.
StartInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
// Gets the status of an existing workflow instance.
GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
// Waits for a workflow instance to reach a running or completion state.
WaitForInstanceStart(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
// Waits for a workflow instance to reach a completion state (completed, failed, terminated, etc.).
WaitForInstanceCompletion(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
// Raises an event to a running workflow instance.
RaiseEvent(ctx context.Context, in *RaiseEventRequest, opts ...grpc.CallOption) (*RaiseEventResponse, error)
// Terminates a running workflow instance.
TerminateInstance(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
// Suspends a running workflow instance.
SuspendInstance(ctx context.Context, in *SuspendRequest, opts ...grpc.CallOption) (*SuspendResponse, error)
// Resumes a suspended workflow instance.
ResumeInstance(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*ResumeResponse, error)
PurgeInstances(ctx context.Context, in *PurgeInstancesRequest, opts ...grpc.CallOption) (*PurgeInstancesResponse, error)
GetWorkItems(ctx context.Context, in *GetWorkItemsRequest, opts ...grpc.CallOption) (TaskHubSidecarService_GetWorkItemsClient, error)
CompleteActivityTask(ctx context.Context, in *ActivityResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
// Deprecated: Do not use.
// Deprecated: Use CompleteWorkflowTask instead.
CompleteOrchestratorTask(ctx context.Context, in *WorkflowResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
// Completes a workflow work item.
CompleteWorkflowTask(ctx context.Context, in *WorkflowResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
ListInstanceIDs(ctx context.Context, in *ListInstanceIDsRequest, opts ...grpc.CallOption) (*ListInstanceIDsResponse, error)
GetInstanceHistory(ctx context.Context, in *GetInstanceHistoryRequest, opts ...grpc.CallOption) (*GetInstanceHistoryResponse, error)
}
TaskHubSidecarServiceClient is the client API for TaskHubSidecarService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTaskHubSidecarServiceClient ¶
func NewTaskHubSidecarServiceClient(cc grpc.ClientConnInterface) TaskHubSidecarServiceClient
type TaskHubSidecarServiceServer ¶
type TaskHubSidecarServiceServer interface {
// Sends a hello request to the sidecar service.
Hello(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
// Starts a new workflow instance.
StartInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
// Gets the status of an existing workflow instance.
GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
// Waits for a workflow instance to reach a running or completion state.
WaitForInstanceStart(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
// Waits for a workflow instance to reach a completion state (completed, failed, terminated, etc.).
WaitForInstanceCompletion(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
// Raises an event to a running workflow instance.
RaiseEvent(context.Context, *RaiseEventRequest) (*RaiseEventResponse, error)
// Terminates a running workflow instance.
TerminateInstance(context.Context, *TerminateRequest) (*TerminateResponse, error)
// Suspends a running workflow instance.
SuspendInstance(context.Context, *SuspendRequest) (*SuspendResponse, error)
// Resumes a suspended workflow instance.
ResumeInstance(context.Context, *ResumeRequest) (*ResumeResponse, error)
PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)
GetWorkItems(*GetWorkItemsRequest, TaskHubSidecarService_GetWorkItemsServer) error
CompleteActivityTask(context.Context, *ActivityResponse) (*CompleteTaskResponse, error)
// Deprecated: Do not use.
// Deprecated: Use CompleteWorkflowTask instead.
CompleteOrchestratorTask(context.Context, *WorkflowResponse) (*CompleteTaskResponse, error)
// Completes a workflow work item.
CompleteWorkflowTask(context.Context, *WorkflowResponse) (*CompleteTaskResponse, error)
ListInstanceIDs(context.Context, *ListInstanceIDsRequest) (*ListInstanceIDsResponse, error)
GetInstanceHistory(context.Context, *GetInstanceHistoryRequest) (*GetInstanceHistoryResponse, error)
// contains filtered or unexported methods
}
TaskHubSidecarServiceServer is the server API for TaskHubSidecarService service. All implementations must embed UnimplementedTaskHubSidecarServiceServer for forward compatibility
type TaskHubSidecarService_GetWorkItemsClient ¶
type TaskHubSidecarService_GetWorkItemsClient interface {
Recv() (*WorkItem, error)
grpc.ClientStream
}
type TaskHubSidecarService_GetWorkItemsServer ¶
type TaskHubSidecarService_GetWorkItemsServer interface {
Send(*WorkItem) error
grpc.ServerStream
}
type TaskRouter ¶
type TaskRouter struct {
SourceAppID string `protobuf:"bytes,1,opt,name=sourceAppID,proto3" json:"sourceAppID,omitempty"`
TargetAppID *string `protobuf:"bytes,2,opt,name=targetAppID,proto3,oneof" json:"targetAppID,omitempty"`
TargetAppNamespace *string `protobuf:"bytes,3,opt,name=targetAppNamespace,proto3,oneof" json:"targetAppNamespace,omitempty"`
// contains filtered or unexported fields
}
func (*TaskRouter) Descriptor
deprecated
func (*TaskRouter) Descriptor() ([]byte, []int)
Deprecated: Use TaskRouter.ProtoReflect.Descriptor instead.
func (*TaskRouter) GetSourceAppID ¶
func (x *TaskRouter) GetSourceAppID() string
func (*TaskRouter) GetTargetAppID ¶
func (x *TaskRouter) GetTargetAppID() string
func (*TaskRouter) GetTargetAppNamespace ¶
func (x *TaskRouter) GetTargetAppNamespace() string
func (*TaskRouter) ProtoMessage ¶
func (*TaskRouter) ProtoMessage()
func (*TaskRouter) ProtoReflect ¶
func (x *TaskRouter) ProtoReflect() protoreflect.Message
func (*TaskRouter) Reset ¶
func (x *TaskRouter) Reset()
func (*TaskRouter) String ¶
func (x *TaskRouter) String() string
type TaskScheduledEvent ¶
type TaskScheduledEvent struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Version *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
ParentTraceContext *TraceContext `protobuf:"bytes,4,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
TaskExecutionId string `protobuf:"bytes,5,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
// History propagation scope used when this task was originally scheduled.
// Persisted on the event so rerun can re-issue the task with the same
// scope after the action has been discarded.
HistoryPropagationScope *HistoryPropagationScope `` /* 135-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*TaskScheduledEvent) Descriptor
deprecated
func (*TaskScheduledEvent) Descriptor() ([]byte, []int)
Deprecated: Use TaskScheduledEvent.ProtoReflect.Descriptor instead.
func (*TaskScheduledEvent) GetHistoryPropagationScope ¶
func (x *TaskScheduledEvent) GetHistoryPropagationScope() HistoryPropagationScope
func (*TaskScheduledEvent) GetInput ¶
func (x *TaskScheduledEvent) GetInput() *wrapperspb.StringValue
func (*TaskScheduledEvent) GetName ¶
func (x *TaskScheduledEvent) GetName() string
func (*TaskScheduledEvent) GetParentTraceContext ¶
func (x *TaskScheduledEvent) GetParentTraceContext() *TraceContext
func (*TaskScheduledEvent) GetTaskExecutionId ¶
func (x *TaskScheduledEvent) GetTaskExecutionId() string
func (*TaskScheduledEvent) GetVersion ¶
func (x *TaskScheduledEvent) GetVersion() *wrapperspb.StringValue
func (*TaskScheduledEvent) ProtoMessage ¶
func (*TaskScheduledEvent) ProtoMessage()
func (*TaskScheduledEvent) ProtoReflect ¶
func (x *TaskScheduledEvent) ProtoReflect() protoreflect.Message
func (*TaskScheduledEvent) Reset ¶
func (x *TaskScheduledEvent) Reset()
func (*TaskScheduledEvent) String ¶
func (x *TaskScheduledEvent) String() string
type TerminateOrchestrationAction
deprecated
type TerminateOrchestrationAction = TerminateWorkflowAction
Deprecated: Use TerminateWorkflowAction instead.
type TerminateRequest ¶
type TerminateRequest struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Output *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
Recursive bool `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
// router optionally routes this operation to the workflow instance owned
// by another app. sourceAppID is stamped by the sidecar, not the client.
Router *TaskRouter `protobuf:"bytes,4,opt,name=router,proto3,oneof" json:"router,omitempty"`
// contains filtered or unexported fields
}
func (*TerminateRequest) Descriptor
deprecated
func (*TerminateRequest) Descriptor() ([]byte, []int)
Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.
func (*TerminateRequest) GetInstanceId ¶
func (x *TerminateRequest) GetInstanceId() string
func (*TerminateRequest) GetOutput ¶
func (x *TerminateRequest) GetOutput() *wrapperspb.StringValue
func (*TerminateRequest) GetRecursive ¶
func (x *TerminateRequest) GetRecursive() bool
func (*TerminateRequest) GetRouter ¶
func (x *TerminateRequest) GetRouter() *TaskRouter
func (*TerminateRequest) ProtoMessage ¶
func (*TerminateRequest) ProtoMessage()
func (*TerminateRequest) ProtoReflect ¶
func (x *TerminateRequest) ProtoReflect() protoreflect.Message
func (*TerminateRequest) Reset ¶
func (x *TerminateRequest) Reset()
func (*TerminateRequest) String ¶
func (x *TerminateRequest) String() string
type TerminateResponse ¶
type TerminateResponse struct {
// contains filtered or unexported fields
}
func (*TerminateResponse) Descriptor
deprecated
func (*TerminateResponse) Descriptor() ([]byte, []int)
Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.
func (*TerminateResponse) ProtoMessage ¶
func (*TerminateResponse) ProtoMessage()
func (*TerminateResponse) ProtoReflect ¶
func (x *TerminateResponse) ProtoReflect() protoreflect.Message
func (*TerminateResponse) Reset ¶
func (x *TerminateResponse) Reset()
func (*TerminateResponse) String ¶
func (x *TerminateResponse) String() string
type TerminateWorkflowAction ¶
type TerminateWorkflowAction struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Reason *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
Recurse bool `protobuf:"varint,3,opt,name=recurse,proto3" json:"recurse,omitempty"`
// contains filtered or unexported fields
}
func (*TerminateWorkflowAction) Descriptor
deprecated
func (*TerminateWorkflowAction) Descriptor() ([]byte, []int)
Deprecated: Use TerminateWorkflowAction.ProtoReflect.Descriptor instead.
func (*TerminateWorkflowAction) GetInstanceId ¶
func (x *TerminateWorkflowAction) GetInstanceId() string
func (*TerminateWorkflowAction) GetReason ¶
func (x *TerminateWorkflowAction) GetReason() *wrapperspb.StringValue
func (*TerminateWorkflowAction) GetRecurse ¶
func (x *TerminateWorkflowAction) GetRecurse() bool
func (*TerminateWorkflowAction) ProtoMessage ¶
func (*TerminateWorkflowAction) ProtoMessage()
func (*TerminateWorkflowAction) ProtoReflect ¶
func (x *TerminateWorkflowAction) ProtoReflect() protoreflect.Message
func (*TerminateWorkflowAction) Reset ¶
func (x *TerminateWorkflowAction) Reset()
func (*TerminateWorkflowAction) String ¶
func (x *TerminateWorkflowAction) String() string
type TimerCreatedEvent ¶
type TimerCreatedEvent struct {
FireAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fireAt,proto3" json:"fireAt,omitempty"`
Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
// If set, provides additional context attached to this timer.
//
// Types that are assignable to Origin:
//
// *TimerCreatedEvent_CreateTimer
// *TimerCreatedEvent_ExternalEvent
// *TimerCreatedEvent_ActivityRetry
// *TimerCreatedEvent_ChildWorkflowRetry
Origin isTimerCreatedEvent_Origin `protobuf_oneof:"origin"`
// contains filtered or unexported fields
}
func (*TimerCreatedEvent) Descriptor
deprecated
func (*TimerCreatedEvent) Descriptor() ([]byte, []int)
Deprecated: Use TimerCreatedEvent.ProtoReflect.Descriptor instead.
func (*TimerCreatedEvent) GetActivityRetry ¶
func (x *TimerCreatedEvent) GetActivityRetry() *TimerOriginActivityRetry
func (*TimerCreatedEvent) GetChildWorkflowRetry ¶
func (x *TimerCreatedEvent) GetChildWorkflowRetry() *TimerOriginChildWorkflowRetry
func (*TimerCreatedEvent) GetCreateTimer ¶
func (x *TimerCreatedEvent) GetCreateTimer() *TimerOriginCreateTimer
func (*TimerCreatedEvent) GetExternalEvent ¶
func (x *TimerCreatedEvent) GetExternalEvent() *TimerOriginExternalEvent
func (*TimerCreatedEvent) GetFireAt ¶
func (x *TimerCreatedEvent) GetFireAt() *timestamppb.Timestamp
func (*TimerCreatedEvent) GetName ¶
func (x *TimerCreatedEvent) GetName() string
func (*TimerCreatedEvent) GetOrigin ¶
func (m *TimerCreatedEvent) GetOrigin() isTimerCreatedEvent_Origin
func (*TimerCreatedEvent) ProtoMessage ¶
func (*TimerCreatedEvent) ProtoMessage()
func (*TimerCreatedEvent) ProtoReflect ¶
func (x *TimerCreatedEvent) ProtoReflect() protoreflect.Message
func (*TimerCreatedEvent) Reset ¶
func (x *TimerCreatedEvent) Reset()
func (*TimerCreatedEvent) String ¶
func (x *TimerCreatedEvent) String() string
type TimerCreatedEvent_ActivityRetry ¶
type TimerCreatedEvent_ActivityRetry struct {
ActivityRetry *TimerOriginActivityRetry `protobuf:"bytes,6,opt,name=activityRetry,proto3,oneof"`
}
type TimerCreatedEvent_ChildWorkflowRetry ¶
type TimerCreatedEvent_ChildWorkflowRetry struct {
ChildWorkflowRetry *TimerOriginChildWorkflowRetry `protobuf:"bytes,7,opt,name=childWorkflowRetry,proto3,oneof"`
}
type TimerCreatedEvent_CreateTimer ¶
type TimerCreatedEvent_CreateTimer struct {
CreateTimer *TimerOriginCreateTimer `protobuf:"bytes,4,opt,name=createTimer,proto3,oneof"`
}
type TimerCreatedEvent_ExternalEvent ¶
type TimerCreatedEvent_ExternalEvent struct {
ExternalEvent *TimerOriginExternalEvent `protobuf:"bytes,5,opt,name=externalEvent,proto3,oneof"`
}
type TimerFiredEvent ¶
type TimerFiredEvent struct {
FireAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fireAt,proto3" json:"fireAt,omitempty"`
TimerId int32 `protobuf:"varint,2,opt,name=timerId,proto3" json:"timerId,omitempty"`
// contains filtered or unexported fields
}
func (*TimerFiredEvent) Descriptor
deprecated
func (*TimerFiredEvent) Descriptor() ([]byte, []int)
Deprecated: Use TimerFiredEvent.ProtoReflect.Descriptor instead.
func (*TimerFiredEvent) GetFireAt ¶
func (x *TimerFiredEvent) GetFireAt() *timestamppb.Timestamp
func (*TimerFiredEvent) GetTimerId ¶
func (x *TimerFiredEvent) GetTimerId() int32
func (*TimerFiredEvent) ProtoMessage ¶
func (*TimerFiredEvent) ProtoMessage()
func (*TimerFiredEvent) ProtoReflect ¶
func (x *TimerFiredEvent) ProtoReflect() protoreflect.Message
func (*TimerFiredEvent) Reset ¶
func (x *TimerFiredEvent) Reset()
func (*TimerFiredEvent) String ¶
func (x *TimerFiredEvent) String() string
type TimerOriginActivityRetry ¶
type TimerOriginActivityRetry struct {
// The task execution ID of the activity being retried.
TaskExecutionId string `protobuf:"bytes,1,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
// contains filtered or unexported fields
}
Indicates the timer was created as a retry delay for an activity execution.
func (*TimerOriginActivityRetry) Descriptor
deprecated
func (*TimerOriginActivityRetry) Descriptor() ([]byte, []int)
Deprecated: Use TimerOriginActivityRetry.ProtoReflect.Descriptor instead.
func (*TimerOriginActivityRetry) GetTaskExecutionId ¶
func (x *TimerOriginActivityRetry) GetTaskExecutionId() string
func (*TimerOriginActivityRetry) ProtoMessage ¶
func (*TimerOriginActivityRetry) ProtoMessage()
func (*TimerOriginActivityRetry) ProtoReflect ¶
func (x *TimerOriginActivityRetry) ProtoReflect() protoreflect.Message
func (*TimerOriginActivityRetry) Reset ¶
func (x *TimerOriginActivityRetry) Reset()
func (*TimerOriginActivityRetry) String ¶
func (x *TimerOriginActivityRetry) String() string
type TimerOriginChildWorkflowRetry ¶
type TimerOriginChildWorkflowRetry struct {
// The instance ID of the workflow being retried.
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
// contains filtered or unexported fields
}
Indicates the timer was created as a retry delay for a child workflow execution.
func (*TimerOriginChildWorkflowRetry) Descriptor
deprecated
func (*TimerOriginChildWorkflowRetry) Descriptor() ([]byte, []int)
Deprecated: Use TimerOriginChildWorkflowRetry.ProtoReflect.Descriptor instead.
func (*TimerOriginChildWorkflowRetry) GetInstanceId ¶
func (x *TimerOriginChildWorkflowRetry) GetInstanceId() string
func (*TimerOriginChildWorkflowRetry) ProtoMessage ¶
func (*TimerOriginChildWorkflowRetry) ProtoMessage()
func (*TimerOriginChildWorkflowRetry) ProtoReflect ¶
func (x *TimerOriginChildWorkflowRetry) ProtoReflect() protoreflect.Message
func (*TimerOriginChildWorkflowRetry) Reset ¶
func (x *TimerOriginChildWorkflowRetry) Reset()
func (*TimerOriginChildWorkflowRetry) String ¶
func (x *TimerOriginChildWorkflowRetry) String() string
type TimerOriginCreateTimer ¶
type TimerOriginCreateTimer struct {
// contains filtered or unexported fields
}
Indicates the timer was created by a createTimer call with no special origin.
func (*TimerOriginCreateTimer) Descriptor
deprecated
func (*TimerOriginCreateTimer) Descriptor() ([]byte, []int)
Deprecated: Use TimerOriginCreateTimer.ProtoReflect.Descriptor instead.
func (*TimerOriginCreateTimer) ProtoMessage ¶
func (*TimerOriginCreateTimer) ProtoMessage()
func (*TimerOriginCreateTimer) ProtoReflect ¶
func (x *TimerOriginCreateTimer) ProtoReflect() protoreflect.Message
func (*TimerOriginCreateTimer) Reset ¶
func (x *TimerOriginCreateTimer) Reset()
func (*TimerOriginCreateTimer) String ¶
func (x *TimerOriginCreateTimer) String() string
type TimerOriginExternalEvent ¶
type TimerOriginExternalEvent struct {
// The name of the external event being waited on, matching EventRaisedEvent.name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Indicates the timer was created as a timeout for a waitForExternalEvent call.
func (*TimerOriginExternalEvent) Descriptor
deprecated
func (*TimerOriginExternalEvent) Descriptor() ([]byte, []int)
Deprecated: Use TimerOriginExternalEvent.ProtoReflect.Descriptor instead.
func (*TimerOriginExternalEvent) GetName ¶
func (x *TimerOriginExternalEvent) GetName() string
func (*TimerOriginExternalEvent) ProtoMessage ¶
func (*TimerOriginExternalEvent) ProtoMessage()
func (*TimerOriginExternalEvent) ProtoReflect ¶
func (x *TimerOriginExternalEvent) ProtoReflect() protoreflect.Message
func (*TimerOriginExternalEvent) Reset ¶
func (x *TimerOriginExternalEvent) Reset()
func (*TimerOriginExternalEvent) String ¶
func (x *TimerOriginExternalEvent) String() string
type TraceContext ¶
type TraceContext struct {
TraceParent string `protobuf:"bytes,1,opt,name=traceParent,proto3" json:"traceParent,omitempty"`
// Deprecated: Marked as deprecated in orchestration.proto.
SpanID string `protobuf:"bytes,2,opt,name=spanID,proto3" json:"spanID,omitempty"`
TraceState *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=traceState,proto3" json:"traceState,omitempty"`
// contains filtered or unexported fields
}
func (*TraceContext) Descriptor
deprecated
func (*TraceContext) Descriptor() ([]byte, []int)
Deprecated: Use TraceContext.ProtoReflect.Descriptor instead.
func (*TraceContext) GetSpanID
deprecated
func (x *TraceContext) GetSpanID() string
Deprecated: Marked as deprecated in orchestration.proto.
func (*TraceContext) GetTraceParent ¶
func (x *TraceContext) GetTraceParent() string
func (*TraceContext) GetTraceState ¶
func (x *TraceContext) GetTraceState() *wrapperspb.StringValue
func (*TraceContext) ProtoMessage ¶
func (*TraceContext) ProtoMessage()
func (*TraceContext) ProtoReflect ¶
func (x *TraceContext) ProtoReflect() protoreflect.Message
func (*TraceContext) Reset ¶
func (x *TraceContext) Reset()
func (*TraceContext) String ¶
func (x *TraceContext) String() string
type UnimplementedTaskHubSidecarServiceServer ¶
type UnimplementedTaskHubSidecarServiceServer struct {
}
UnimplementedTaskHubSidecarServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask ¶
func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask(context.Context, *ActivityResponse) (*CompleteTaskResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) CompleteOrchestratorTask ¶
func (UnimplementedTaskHubSidecarServiceServer) CompleteOrchestratorTask(context.Context, *WorkflowResponse) (*CompleteTaskResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) CompleteWorkflowTask ¶
func (UnimplementedTaskHubSidecarServiceServer) CompleteWorkflowTask(context.Context, *WorkflowResponse) (*CompleteTaskResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) GetInstance ¶
func (UnimplementedTaskHubSidecarServiceServer) GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) GetInstanceHistory ¶
func (UnimplementedTaskHubSidecarServiceServer) GetInstanceHistory(context.Context, *GetInstanceHistoryRequest) (*GetInstanceHistoryResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems ¶
func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems(*GetWorkItemsRequest, TaskHubSidecarService_GetWorkItemsServer) error
func (UnimplementedTaskHubSidecarServiceServer) ListInstanceIDs ¶
func (UnimplementedTaskHubSidecarServiceServer) ListInstanceIDs(context.Context, *ListInstanceIDsRequest) (*ListInstanceIDsResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) PurgeInstances ¶
func (UnimplementedTaskHubSidecarServiceServer) PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) RaiseEvent ¶
func (UnimplementedTaskHubSidecarServiceServer) RaiseEvent(context.Context, *RaiseEventRequest) (*RaiseEventResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) ResumeInstance ¶
func (UnimplementedTaskHubSidecarServiceServer) ResumeInstance(context.Context, *ResumeRequest) (*ResumeResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) StartInstance ¶
func (UnimplementedTaskHubSidecarServiceServer) StartInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) SuspendInstance ¶
func (UnimplementedTaskHubSidecarServiceServer) SuspendInstance(context.Context, *SuspendRequest) (*SuspendResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) TerminateInstance ¶
func (UnimplementedTaskHubSidecarServiceServer) TerminateInstance(context.Context, *TerminateRequest) (*TerminateResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceCompletion ¶
func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceCompletion(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceStart ¶
func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceStart(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
type UnsafeTaskHubSidecarServiceServer ¶
type UnsafeTaskHubSidecarServiceServer interface {
// contains filtered or unexported methods
}
UnsafeTaskHubSidecarServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskHubSidecarServiceServer will result in compilation errors.
type WorkItem ¶
type WorkItem struct {
// Types that are assignable to Request:
//
// *WorkItem_WorkflowRequest
// *WorkItem_ActivityRequest
Request isWorkItem_Request `protobuf_oneof:"request"`
CompletionToken string `protobuf:"bytes,10,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
// contains filtered or unexported fields
}
func (*WorkItem) Descriptor
deprecated
func (*WorkItem) GetActivityRequest ¶
func (x *WorkItem) GetActivityRequest() *ActivityRequest
func (*WorkItem) GetCompletionToken ¶
func (*WorkItem) GetOrchestratorRequest
deprecated
func (x *WorkItem) GetOrchestratorRequest() *WorkflowRequest
Deprecated: Use GetWorkflowRequest instead.
func (*WorkItem) GetRequest ¶
func (m *WorkItem) GetRequest() isWorkItem_Request
func (*WorkItem) GetWorkflowRequest ¶
func (x *WorkItem) GetWorkflowRequest() *WorkflowRequest
func (*WorkItem) ProtoMessage ¶
func (*WorkItem) ProtoMessage()
func (*WorkItem) ProtoReflect ¶
func (x *WorkItem) ProtoReflect() protoreflect.Message
type WorkItem_ActivityRequest ¶
type WorkItem_ActivityRequest struct {
ActivityRequest *ActivityRequest `protobuf:"bytes,2,opt,name=activityRequest,proto3,oneof"`
}
type WorkItem_OrchestratorRequest
deprecated
type WorkItem_OrchestratorRequest = WorkItem_WorkflowRequest
Deprecated: Use WorkItem_WorkflowRequest instead.
type WorkItem_WorkflowRequest ¶
type WorkItem_WorkflowRequest struct {
WorkflowRequest *WorkflowRequest `protobuf:"bytes,1,opt,name=workflowRequest,proto3,oneof"`
}
type WorkerCapability ¶
type WorkerCapability int32
const ( WorkerCapability_WORKER_CAPABILITY_UNSPECIFIED WorkerCapability = 0 // Indicates that the worker retains an instance's accumulated history in // memory between workflow turns on the same work-item stream, so that the // service can send only the new events (the delta) instead of the full // history each turn. When the service has dispatched a turn for an // instance to this stream and believes the stream is still warm for it, it // may set WorkflowRequest.cachedHistory and drop the committed-history // prefix the worker already holds from pastEvents, leaving only the delta // there. On a cache miss the worker recovers the full history via the // GetInstanceHistory RPC, so the optimization never affects correctness. WorkerCapability_WORKER_CAPABILITY_STATEFUL_HISTORY WorkerCapability = 2 )
func (WorkerCapability) Descriptor ¶
func (WorkerCapability) Descriptor() protoreflect.EnumDescriptor
func (WorkerCapability) Enum ¶
func (x WorkerCapability) Enum() *WorkerCapability
func (WorkerCapability) EnumDescriptor
deprecated
func (WorkerCapability) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkerCapability.Descriptor instead.
func (WorkerCapability) Number ¶
func (x WorkerCapability) Number() protoreflect.EnumNumber
func (WorkerCapability) String ¶
func (x WorkerCapability) String() string
func (WorkerCapability) Type ¶
func (WorkerCapability) Type() protoreflect.EnumType
type WorkflowAction ¶
type WorkflowAction struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
// Types that are assignable to WorkflowActionType:
//
// *WorkflowAction_ScheduleTask
// *WorkflowAction_CreateChildWorkflow
// *WorkflowAction_CreateTimer
// *WorkflowAction_SendEvent
// *WorkflowAction_CompleteWorkflow
// *WorkflowAction_TerminateWorkflow
// *WorkflowAction_WorkflowVersionNotAvailable
// *WorkflowAction_CreateDetachedWorkflow
WorkflowActionType isWorkflowAction_WorkflowActionType `protobuf_oneof:"workflowActionType"`
Router *TaskRouter `protobuf:"bytes,9,opt,name=router,proto3,oneof" json:"router,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowAction) Descriptor
deprecated
func (*WorkflowAction) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowAction.ProtoReflect.Descriptor instead.
func (*WorkflowAction) GetCompleteOrchestration
deprecated
func (x *WorkflowAction) GetCompleteOrchestration() *CompleteWorkflowAction
Deprecated: Use GetCompleteWorkflow instead.
func (*WorkflowAction) GetCompleteWorkflow ¶
func (x *WorkflowAction) GetCompleteWorkflow() *CompleteWorkflowAction
func (*WorkflowAction) GetCreateChildWorkflow ¶
func (x *WorkflowAction) GetCreateChildWorkflow() *CreateChildWorkflowAction
func (*WorkflowAction) GetCreateDetachedWorkflow ¶
func (x *WorkflowAction) GetCreateDetachedWorkflow() *CreateDetachedWorkflowAction
func (*WorkflowAction) GetCreateSubOrchestration
deprecated
func (x *WorkflowAction) GetCreateSubOrchestration() *CreateChildWorkflowAction
Deprecated: Use GetCreateChildWorkflow instead.
func (*WorkflowAction) GetCreateTimer ¶
func (x *WorkflowAction) GetCreateTimer() *CreateTimerAction
func (*WorkflowAction) GetId ¶
func (x *WorkflowAction) GetId() int32
func (*WorkflowAction) GetOrchestratorVersionNotAvailable
deprecated
func (x *WorkflowAction) GetOrchestratorVersionNotAvailable() *WorkflowVersionNotAvailableAction
Deprecated: Use GetWorkflowVersionNotAvailable instead.
func (*WorkflowAction) GetRouter ¶
func (x *WorkflowAction) GetRouter() *TaskRouter
func (*WorkflowAction) GetScheduleTask ¶
func (x *WorkflowAction) GetScheduleTask() *ScheduleTaskAction
func (*WorkflowAction) GetSendEvent ¶
func (x *WorkflowAction) GetSendEvent() *SendEventAction
func (*WorkflowAction) GetTerminateOrchestration
deprecated
func (x *WorkflowAction) GetTerminateOrchestration() *TerminateWorkflowAction
Deprecated: Use GetTerminateWorkflow instead.
func (*WorkflowAction) GetTerminateWorkflow ¶
func (x *WorkflowAction) GetTerminateWorkflow() *TerminateWorkflowAction
func (*WorkflowAction) GetWorkflowActionType ¶
func (m *WorkflowAction) GetWorkflowActionType() isWorkflowAction_WorkflowActionType
func (*WorkflowAction) GetWorkflowVersionNotAvailable ¶
func (x *WorkflowAction) GetWorkflowVersionNotAvailable() *WorkflowVersionNotAvailableAction
func (*WorkflowAction) ProtoMessage ¶
func (*WorkflowAction) ProtoMessage()
func (*WorkflowAction) ProtoReflect ¶
func (x *WorkflowAction) ProtoReflect() protoreflect.Message
func (*WorkflowAction) Reset ¶
func (x *WorkflowAction) Reset()
func (*WorkflowAction) String ¶
func (x *WorkflowAction) String() string
type WorkflowAction_CompleteWorkflow ¶
type WorkflowAction_CompleteWorkflow struct {
CompleteWorkflow *CompleteWorkflowAction `protobuf:"bytes,6,opt,name=completeWorkflow,proto3,oneof"`
}
type WorkflowAction_CreateChildWorkflow ¶
type WorkflowAction_CreateChildWorkflow struct {
CreateChildWorkflow *CreateChildWorkflowAction `protobuf:"bytes,3,opt,name=createChildWorkflow,proto3,oneof"`
}
type WorkflowAction_CreateDetachedWorkflow ¶
type WorkflowAction_CreateDetachedWorkflow struct {
CreateDetachedWorkflow *CreateDetachedWorkflowAction `protobuf:"bytes,11,opt,name=createDetachedWorkflow,proto3,oneof"`
}
type WorkflowAction_CreateTimer ¶
type WorkflowAction_CreateTimer struct {
CreateTimer *CreateTimerAction `protobuf:"bytes,4,opt,name=createTimer,proto3,oneof"`
}
type WorkflowAction_ScheduleTask ¶
type WorkflowAction_ScheduleTask struct {
ScheduleTask *ScheduleTaskAction `protobuf:"bytes,2,opt,name=scheduleTask,proto3,oneof"`
}
type WorkflowAction_SendEvent ¶
type WorkflowAction_SendEvent struct {
SendEvent *SendEventAction `protobuf:"bytes,5,opt,name=sendEvent,proto3,oneof"`
}
type WorkflowAction_TerminateWorkflow ¶
type WorkflowAction_TerminateWorkflow struct {
TerminateWorkflow *TerminateWorkflowAction `protobuf:"bytes,7,opt,name=terminateWorkflow,proto3,oneof"`
}
type WorkflowAction_WorkflowVersionNotAvailable ¶
type WorkflowAction_WorkflowVersionNotAvailable struct {
WorkflowVersionNotAvailable *WorkflowVersionNotAvailableAction `protobuf:"bytes,10,opt,name=workflowVersionNotAvailable,proto3,oneof"`
}
type WorkflowCompletedEvent ¶
type WorkflowCompletedEvent struct {
// contains filtered or unexported fields
}
func (*WorkflowCompletedEvent) Descriptor
deprecated
func (*WorkflowCompletedEvent) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowCompletedEvent.ProtoReflect.Descriptor instead.
func (*WorkflowCompletedEvent) ProtoMessage ¶
func (*WorkflowCompletedEvent) ProtoMessage()
func (*WorkflowCompletedEvent) ProtoReflect ¶
func (x *WorkflowCompletedEvent) ProtoReflect() protoreflect.Message
func (*WorkflowCompletedEvent) Reset ¶
func (x *WorkflowCompletedEvent) Reset()
func (*WorkflowCompletedEvent) String ¶
func (x *WorkflowCompletedEvent) String() string
type WorkflowInstance ¶
type WorkflowInstance struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
ExecutionId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowInstance) Descriptor
deprecated
func (*WorkflowInstance) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowInstance.ProtoReflect.Descriptor instead.
func (*WorkflowInstance) GetExecutionId ¶
func (x *WorkflowInstance) GetExecutionId() *wrapperspb.StringValue
func (*WorkflowInstance) GetInstanceId ¶
func (x *WorkflowInstance) GetInstanceId() string
func (*WorkflowInstance) ProtoMessage ¶
func (*WorkflowInstance) ProtoMessage()
func (*WorkflowInstance) ProtoReflect ¶
func (x *WorkflowInstance) ProtoReflect() protoreflect.Message
func (*WorkflowInstance) Reset ¶
func (x *WorkflowInstance) Reset()
func (*WorkflowInstance) String ¶
func (x *WorkflowInstance) String() string
type WorkflowMessage ¶
type WorkflowMessage struct {
// The ID of the workflow instance to receive the message.
Instance *WorkflowInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
// The event payload to be received by the target workflow.
Event *HistoryEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
// contains filtered or unexported fields
}
A message to be delivered to a workflow by the backend.
func (*WorkflowMessage) Descriptor
deprecated
func (*WorkflowMessage) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowMessage.ProtoReflect.Descriptor instead.
func (*WorkflowMessage) GetEvent ¶
func (x *WorkflowMessage) GetEvent() *HistoryEvent
func (*WorkflowMessage) GetInstance ¶
func (x *WorkflowMessage) GetInstance() *WorkflowInstance
func (*WorkflowMessage) ProtoMessage ¶
func (*WorkflowMessage) ProtoMessage()
func (*WorkflowMessage) ProtoReflect ¶
func (x *WorkflowMessage) ProtoReflect() protoreflect.Message
func (*WorkflowMessage) Reset ¶
func (x *WorkflowMessage) Reset()
func (*WorkflowMessage) String ¶
func (x *WorkflowMessage) String() string
type WorkflowMetadata ¶
type WorkflowMetadata struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
RuntimeStatus OrchestrationStatus `protobuf:"varint,3,opt,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
LastUpdatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=lastUpdatedAt,proto3" json:"lastUpdatedAt,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=input,proto3" json:"input,omitempty"`
Output *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=output,proto3" json:"output,omitempty"`
CustomStatus *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
FailureDetails *TaskFailureDetails `protobuf:"bytes,9,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
CompletedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=completedAt,proto3" json:"completedAt,omitempty"`
ParentInstanceId string `protobuf:"bytes,11,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"`
Version *wrapperspb.StringValue `protobuf:"bytes,12,opt,name=version,proto3,oneof" json:"version,omitempty"`
ParentAppId *wrapperspb.StringValue `protobuf:"bytes,13,opt,name=parentAppId,proto3,oneof" json:"parentAppId,omitempty"`
StartedAt *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=startedAt,proto3,oneof" json:"startedAt,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowMetadata) Descriptor
deprecated
func (*WorkflowMetadata) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowMetadata.ProtoReflect.Descriptor instead.
func (*WorkflowMetadata) GetCompletedAt ¶
func (x *WorkflowMetadata) GetCompletedAt() *timestamppb.Timestamp
func (*WorkflowMetadata) GetCreatedAt ¶
func (x *WorkflowMetadata) GetCreatedAt() *timestamppb.Timestamp
func (*WorkflowMetadata) GetCustomStatus ¶
func (x *WorkflowMetadata) GetCustomStatus() *wrapperspb.StringValue
func (*WorkflowMetadata) GetFailureDetails ¶
func (x *WorkflowMetadata) GetFailureDetails() *TaskFailureDetails
func (*WorkflowMetadata) GetInput ¶
func (x *WorkflowMetadata) GetInput() *wrapperspb.StringValue
func (*WorkflowMetadata) GetInstanceId ¶
func (x *WorkflowMetadata) GetInstanceId() string
func (*WorkflowMetadata) GetLastUpdatedAt ¶
func (x *WorkflowMetadata) GetLastUpdatedAt() *timestamppb.Timestamp
func (*WorkflowMetadata) GetName ¶
func (x *WorkflowMetadata) GetName() string
func (*WorkflowMetadata) GetOutput ¶
func (x *WorkflowMetadata) GetOutput() *wrapperspb.StringValue
func (*WorkflowMetadata) GetParentAppId ¶
func (x *WorkflowMetadata) GetParentAppId() *wrapperspb.StringValue
func (*WorkflowMetadata) GetParentInstanceId ¶
func (x *WorkflowMetadata) GetParentInstanceId() string
func (*WorkflowMetadata) GetRuntimeStatus ¶
func (x *WorkflowMetadata) GetRuntimeStatus() OrchestrationStatus
func (*WorkflowMetadata) GetStartedAt ¶
func (x *WorkflowMetadata) GetStartedAt() *timestamppb.Timestamp
func (*WorkflowMetadata) GetVersion ¶
func (x *WorkflowMetadata) GetVersion() *wrapperspb.StringValue
func (*WorkflowMetadata) ProtoMessage ¶
func (*WorkflowMetadata) ProtoMessage()
func (*WorkflowMetadata) ProtoReflect ¶
func (x *WorkflowMetadata) ProtoReflect() protoreflect.Message
func (*WorkflowMetadata) Reset ¶
func (x *WorkflowMetadata) Reset()
func (*WorkflowMetadata) String ¶
func (x *WorkflowMetadata) String() string
type WorkflowRequest ¶
type WorkflowRequest struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
ExecutionId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
PastEvents []*HistoryEvent `protobuf:"bytes,3,rep,name=pastEvents,proto3" json:"pastEvents,omitempty"`
NewEvents []*HistoryEvent `protobuf:"bytes,4,rep,name=newEvents,proto3" json:"newEvents,omitempty"`
RequiresHistoryStreaming bool `protobuf:"varint,6,opt,name=requiresHistoryStreaming,proto3" json:"requiresHistoryStreaming,omitempty"`
Router *TaskRouter `protobuf:"bytes,7,opt,name=router,proto3,oneof" json:"router,omitempty"`
// Propagated history from a parent workflow.
// Delivered via the work item stream to the SDK, so that the
// workflow function can access it via ctx.
PropagatedHistory *PropagatedHistory `protobuf:"bytes,8,opt,name=propagatedHistory,proto3,oneof" json:"propagatedHistory,omitempty"`
// cachedHistory, when present, signals that pastEvents holds only the
// delta and the worker must reconstruct the omitted prefix from its own
// cache (or fetch it via GetInstanceHistory on a miss). Absent for
// full-history sends.
CachedHistory *CachedHistory `protobuf:"bytes,9,opt,name=cachedHistory,proto3,oneof" json:"cachedHistory,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowRequest) Descriptor
deprecated
func (*WorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowRequest.ProtoReflect.Descriptor instead.
func (*WorkflowRequest) GetCachedHistory ¶
func (x *WorkflowRequest) GetCachedHistory() *CachedHistory
func (*WorkflowRequest) GetExecutionId ¶
func (x *WorkflowRequest) GetExecutionId() *wrapperspb.StringValue
func (*WorkflowRequest) GetInstanceId ¶
func (x *WorkflowRequest) GetInstanceId() string
func (*WorkflowRequest) GetNewEvents ¶
func (x *WorkflowRequest) GetNewEvents() []*HistoryEvent
func (*WorkflowRequest) GetPastEvents ¶
func (x *WorkflowRequest) GetPastEvents() []*HistoryEvent
func (*WorkflowRequest) GetPropagatedHistory ¶
func (x *WorkflowRequest) GetPropagatedHistory() *PropagatedHistory
func (*WorkflowRequest) GetRequiresHistoryStreaming ¶
func (x *WorkflowRequest) GetRequiresHistoryStreaming() bool
func (*WorkflowRequest) GetRouter ¶
func (x *WorkflowRequest) GetRouter() *TaskRouter
func (*WorkflowRequest) ProtoMessage ¶
func (*WorkflowRequest) ProtoMessage()
func (*WorkflowRequest) ProtoReflect ¶
func (x *WorkflowRequest) ProtoReflect() protoreflect.Message
func (*WorkflowRequest) Reset ¶
func (x *WorkflowRequest) Reset()
func (*WorkflowRequest) String ¶
func (x *WorkflowRequest) String() string
type WorkflowResponse ¶
type WorkflowResponse struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Actions []*WorkflowAction `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
CustomStatus *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
CompletionToken string `protobuf:"bytes,4,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
// The number of work item events that were processed by the workflow.
// This field is optional. If not set, the service should assume that the workflow processed all events.
NumEventsProcessed *wrapperspb.Int32Value `protobuf:"bytes,5,opt,name=numEventsProcessed,proto3" json:"numEventsProcessed,omitempty"`
Version *WorkflowVersion `protobuf:"bytes,6,opt,name=version,proto3,oneof" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowResponse) Descriptor
deprecated
func (*WorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowResponse.ProtoReflect.Descriptor instead.
func (*WorkflowResponse) GetActions ¶
func (x *WorkflowResponse) GetActions() []*WorkflowAction
func (*WorkflowResponse) GetCompletionToken ¶
func (x *WorkflowResponse) GetCompletionToken() string
func (*WorkflowResponse) GetCustomStatus ¶
func (x *WorkflowResponse) GetCustomStatus() *wrapperspb.StringValue
func (*WorkflowResponse) GetInstanceId ¶
func (x *WorkflowResponse) GetInstanceId() string
func (*WorkflowResponse) GetNumEventsProcessed ¶
func (x *WorkflowResponse) GetNumEventsProcessed() *wrapperspb.Int32Value
func (*WorkflowResponse) GetVersion ¶
func (x *WorkflowResponse) GetVersion() *WorkflowVersion
func (*WorkflowResponse) ProtoMessage ¶
func (*WorkflowResponse) ProtoMessage()
func (*WorkflowResponse) ProtoReflect ¶
func (x *WorkflowResponse) ProtoReflect() protoreflect.Message
func (*WorkflowResponse) Reset ¶
func (x *WorkflowResponse) Reset()
func (*WorkflowResponse) String ¶
func (x *WorkflowResponse) String() string
type WorkflowRuntimeState ¶
type WorkflowRuntimeState struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
NewEvents []*HistoryEvent `protobuf:"bytes,2,rep,name=newEvents,proto3" json:"newEvents,omitempty"`
OldEvents []*HistoryEvent `protobuf:"bytes,3,rep,name=oldEvents,proto3" json:"oldEvents,omitempty"`
PendingTasks []*HistoryEvent `protobuf:"bytes,4,rep,name=pendingTasks,proto3" json:"pendingTasks,omitempty"`
PendingTimers []*HistoryEvent `protobuf:"bytes,5,rep,name=pendingTimers,proto3" json:"pendingTimers,omitempty"`
PendingMessages []*WorkflowRuntimeStateMessage `protobuf:"bytes,6,rep,name=pendingMessages,proto3" json:"pendingMessages,omitempty"`
StartEvent *ExecutionStartedEvent `protobuf:"bytes,7,opt,name=startEvent,proto3" json:"startEvent,omitempty"`
CompletedEvent *ExecutionCompletedEvent `protobuf:"bytes,8,opt,name=completedEvent,proto3" json:"completedEvent,omitempty"`
CreatedTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=createdTime,proto3" json:"createdTime,omitempty"`
LastUpdatedTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=lastUpdatedTime,proto3" json:"lastUpdatedTime,omitempty"`
CompletedTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=completedTime,proto3" json:"completedTime,omitempty"`
ContinuedAsNew bool `protobuf:"varint,12,opt,name=continuedAsNew,proto3" json:"continuedAsNew,omitempty"`
IsSuspended bool `protobuf:"varint,13,opt,name=isSuspended,proto3" json:"isSuspended,omitempty"`
CustomStatus *wrapperspb.StringValue `protobuf:"bytes,14,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
Stalled *RuntimeStateStalled `protobuf:"bytes,15,opt,name=stalled,proto3,oneof" json:"stalled,omitempty"`
// contains filtered or unexported fields
}
WorkflowRuntimeState holds the current state for a workflow.
func (*WorkflowRuntimeState) Descriptor
deprecated
func (*WorkflowRuntimeState) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowRuntimeState.ProtoReflect.Descriptor instead.
func (*WorkflowRuntimeState) GetCompletedEvent ¶
func (x *WorkflowRuntimeState) GetCompletedEvent() *ExecutionCompletedEvent
func (*WorkflowRuntimeState) GetCompletedTime ¶
func (x *WorkflowRuntimeState) GetCompletedTime() *timestamppb.Timestamp
func (*WorkflowRuntimeState) GetContinuedAsNew ¶
func (x *WorkflowRuntimeState) GetContinuedAsNew() bool
func (*WorkflowRuntimeState) GetCreatedTime ¶
func (x *WorkflowRuntimeState) GetCreatedTime() *timestamppb.Timestamp
func (*WorkflowRuntimeState) GetCustomStatus ¶
func (x *WorkflowRuntimeState) GetCustomStatus() *wrapperspb.StringValue
func (*WorkflowRuntimeState) GetInstanceId ¶
func (x *WorkflowRuntimeState) GetInstanceId() string
func (*WorkflowRuntimeState) GetIsSuspended ¶
func (x *WorkflowRuntimeState) GetIsSuspended() bool
func (*WorkflowRuntimeState) GetLastUpdatedTime ¶
func (x *WorkflowRuntimeState) GetLastUpdatedTime() *timestamppb.Timestamp
func (*WorkflowRuntimeState) GetNewEvents ¶
func (x *WorkflowRuntimeState) GetNewEvents() []*HistoryEvent
func (*WorkflowRuntimeState) GetOldEvents ¶
func (x *WorkflowRuntimeState) GetOldEvents() []*HistoryEvent
func (*WorkflowRuntimeState) GetPendingMessages ¶
func (x *WorkflowRuntimeState) GetPendingMessages() []*WorkflowRuntimeStateMessage
func (*WorkflowRuntimeState) GetPendingTasks ¶
func (x *WorkflowRuntimeState) GetPendingTasks() []*HistoryEvent
func (*WorkflowRuntimeState) GetPendingTimers ¶
func (x *WorkflowRuntimeState) GetPendingTimers() []*HistoryEvent
func (*WorkflowRuntimeState) GetStalled ¶
func (x *WorkflowRuntimeState) GetStalled() *RuntimeStateStalled
func (*WorkflowRuntimeState) GetStartEvent ¶
func (x *WorkflowRuntimeState) GetStartEvent() *ExecutionStartedEvent
func (*WorkflowRuntimeState) ProtoMessage ¶
func (*WorkflowRuntimeState) ProtoMessage()
func (*WorkflowRuntimeState) ProtoReflect ¶
func (x *WorkflowRuntimeState) ProtoReflect() protoreflect.Message
func (*WorkflowRuntimeState) Reset ¶
func (x *WorkflowRuntimeState) Reset()
func (*WorkflowRuntimeState) String ¶
func (x *WorkflowRuntimeState) String() string
type WorkflowRuntimeStateMessage ¶
type WorkflowRuntimeStateMessage struct {
HistoryEvent *HistoryEvent `protobuf:"bytes,1,opt,name=historyEvent,proto3" json:"historyEvent,omitempty"`
TargetInstanceId string `protobuf:"bytes,2,opt,name=targetInstanceId,proto3" json:"targetInstanceId,omitempty"`
// Propagated history to deliver to the child workflow.
// This is a transport field used when creating child workflows with
// history propagation enabled. It is NOT stored as part of any
// workflow's history events.
PropagatedHistory *PropagatedHistory `protobuf:"bytes,3,opt,name=propagatedHistory,proto3,oneof" json:"propagatedHistory,omitempty"`
// contains filtered or unexported fields
}
WorkflowRuntimeStateMessage holds a HistoryEvent payload and the target instance ID.
func (*WorkflowRuntimeStateMessage) Descriptor
deprecated
func (*WorkflowRuntimeStateMessage) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowRuntimeStateMessage.ProtoReflect.Descriptor instead.
func (*WorkflowRuntimeStateMessage) GetHistoryEvent ¶
func (x *WorkflowRuntimeStateMessage) GetHistoryEvent() *HistoryEvent
func (*WorkflowRuntimeStateMessage) GetPropagatedHistory ¶
func (x *WorkflowRuntimeStateMessage) GetPropagatedHistory() *PropagatedHistory
func (*WorkflowRuntimeStateMessage) GetTargetInstanceId ¶
func (x *WorkflowRuntimeStateMessage) GetTargetInstanceId() string
func (*WorkflowRuntimeStateMessage) ProtoMessage ¶
func (*WorkflowRuntimeStateMessage) ProtoMessage()
func (*WorkflowRuntimeStateMessage) ProtoReflect ¶
func (x *WorkflowRuntimeStateMessage) ProtoReflect() protoreflect.Message
func (*WorkflowRuntimeStateMessage) Reset ¶
func (x *WorkflowRuntimeStateMessage) Reset()
func (*WorkflowRuntimeStateMessage) String ¶
func (x *WorkflowRuntimeStateMessage) String() string
type WorkflowStartedEvent ¶
type WorkflowStartedEvent struct {
Version *WorkflowVersion `protobuf:"bytes,1,opt,name=version,proto3,oneof" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowStartedEvent) Descriptor
deprecated
func (*WorkflowStartedEvent) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowStartedEvent.ProtoReflect.Descriptor instead.
func (*WorkflowStartedEvent) GetVersion ¶
func (x *WorkflowStartedEvent) GetVersion() *WorkflowVersion
func (*WorkflowStartedEvent) ProtoMessage ¶
func (*WorkflowStartedEvent) ProtoMessage()
func (*WorkflowStartedEvent) ProtoReflect ¶
func (x *WorkflowStartedEvent) ProtoReflect() protoreflect.Message
func (*WorkflowStartedEvent) Reset ¶
func (x *WorkflowStartedEvent) Reset()
func (*WorkflowStartedEvent) String ¶
func (x *WorkflowStartedEvent) String() string
type WorkflowState ¶
type WorkflowState struct {
InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Version *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
WorkflowStatus OrchestrationStatus `protobuf:"varint,4,opt,name=workflowStatus,proto3,enum=OrchestrationStatus" json:"workflowStatus,omitempty"`
ScheduledStartTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
CreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=createdTimestamp,proto3" json:"createdTimestamp,omitempty"`
LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=lastUpdatedTimestamp,proto3" json:"lastUpdatedTimestamp,omitempty"`
Input *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=input,proto3" json:"input,omitempty"`
Output *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=output,proto3" json:"output,omitempty"`
CustomStatus *wrapperspb.StringValue `protobuf:"bytes,10,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
FailureDetails *TaskFailureDetails `protobuf:"bytes,11,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
ExecutionId *wrapperspb.StringValue `protobuf:"bytes,12,opt,name=executionId,proto3" json:"executionId,omitempty"`
CompletedTimestamp *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=completedTimestamp,proto3" json:"completedTimestamp,omitempty"`
ParentInstanceId *wrapperspb.StringValue `protobuf:"bytes,14,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"`
Tags map[string]string `` /* 150-byte string literal not displayed */
ParentAppId *wrapperspb.StringValue `protobuf:"bytes,16,opt,name=parentAppId,proto3" json:"parentAppId,omitempty"`
StartedAt *timestamppb.Timestamp `protobuf:"bytes,17,opt,name=startedAt,proto3,oneof" json:"startedAt,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowState) Descriptor
deprecated
func (*WorkflowState) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowState.ProtoReflect.Descriptor instead.
func (*WorkflowState) GetCompletedTimestamp ¶
func (x *WorkflowState) GetCompletedTimestamp() *timestamppb.Timestamp
func (*WorkflowState) GetCreatedTimestamp ¶
func (x *WorkflowState) GetCreatedTimestamp() *timestamppb.Timestamp
func (*WorkflowState) GetCustomStatus ¶
func (x *WorkflowState) GetCustomStatus() *wrapperspb.StringValue
func (*WorkflowState) GetExecutionId ¶
func (x *WorkflowState) GetExecutionId() *wrapperspb.StringValue
func (*WorkflowState) GetFailureDetails ¶
func (x *WorkflowState) GetFailureDetails() *TaskFailureDetails
func (*WorkflowState) GetInput ¶
func (x *WorkflowState) GetInput() *wrapperspb.StringValue
func (*WorkflowState) GetInstanceId ¶
func (x *WorkflowState) GetInstanceId() string
func (*WorkflowState) GetLastUpdatedTimestamp ¶
func (x *WorkflowState) GetLastUpdatedTimestamp() *timestamppb.Timestamp
func (*WorkflowState) GetName ¶
func (x *WorkflowState) GetName() string
func (*WorkflowState) GetOutput ¶
func (x *WorkflowState) GetOutput() *wrapperspb.StringValue
func (*WorkflowState) GetParentAppId ¶
func (x *WorkflowState) GetParentAppId() *wrapperspb.StringValue
func (*WorkflowState) GetParentInstanceId ¶
func (x *WorkflowState) GetParentInstanceId() *wrapperspb.StringValue
func (*WorkflowState) GetScheduledStartTimestamp ¶
func (x *WorkflowState) GetScheduledStartTimestamp() *timestamppb.Timestamp
func (*WorkflowState) GetStartedAt ¶
func (x *WorkflowState) GetStartedAt() *timestamppb.Timestamp
func (*WorkflowState) GetTags ¶
func (x *WorkflowState) GetTags() map[string]string
func (*WorkflowState) GetVersion ¶
func (x *WorkflowState) GetVersion() *wrapperspb.StringValue
func (*WorkflowState) GetWorkflowStatus ¶
func (x *WorkflowState) GetWorkflowStatus() OrchestrationStatus
func (*WorkflowState) ProtoMessage ¶
func (*WorkflowState) ProtoMessage()
func (*WorkflowState) ProtoReflect ¶
func (x *WorkflowState) ProtoReflect() protoreflect.Message
func (*WorkflowState) Reset ¶
func (x *WorkflowState) Reset()
func (*WorkflowState) String ¶
func (x *WorkflowState) String() string
type WorkflowVersion ¶
type WorkflowVersion struct {
Patches []string `protobuf:"bytes,1,rep,name=patches,proto3" json:"patches,omitempty"`
// The name of the executed workflow
Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowVersion) Descriptor
deprecated
func (*WorkflowVersion) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowVersion.ProtoReflect.Descriptor instead.
func (*WorkflowVersion) GetName ¶
func (x *WorkflowVersion) GetName() string
func (*WorkflowVersion) GetPatches ¶
func (x *WorkflowVersion) GetPatches() []string
func (*WorkflowVersion) ProtoMessage ¶
func (*WorkflowVersion) ProtoMessage()
func (*WorkflowVersion) ProtoReflect ¶
func (x *WorkflowVersion) ProtoReflect() protoreflect.Message
func (*WorkflowVersion) Reset ¶
func (x *WorkflowVersion) Reset()
func (*WorkflowVersion) String ¶
func (x *WorkflowVersion) String() string
type WorkflowVersionNotAvailableAction ¶
type WorkflowVersionNotAvailableAction struct {
// contains filtered or unexported fields
}
func (*WorkflowVersionNotAvailableAction) Descriptor
deprecated
func (*WorkflowVersionNotAvailableAction) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowVersionNotAvailableAction.ProtoReflect.Descriptor instead.
func (*WorkflowVersionNotAvailableAction) ProtoMessage ¶
func (*WorkflowVersionNotAvailableAction) ProtoMessage()
func (*WorkflowVersionNotAvailableAction) ProtoReflect ¶
func (x *WorkflowVersionNotAvailableAction) ProtoReflect() protoreflect.Message
func (*WorkflowVersionNotAvailableAction) Reset ¶
func (x *WorkflowVersionNotAvailableAction) Reset()
func (*WorkflowVersionNotAvailableAction) String ¶
func (x *WorkflowVersionNotAvailableAction) String() string