Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterTaskHubSidecarServiceServer(s grpc.ServiceRegistrar, srv TaskHubSidecarServiceServer)
- type ActivityCompletionAttestation
- func (*ActivityCompletionAttestation) Descriptor() ([]byte, []int)deprecated
- func (x *ActivityCompletionAttestation) GetPayload() []byte
- func (x *ActivityCompletionAttestation) GetSignature() []byte
- func (*ActivityCompletionAttestation) ProtoMessage()
- func (x *ActivityCompletionAttestation) ProtoReflect() protoreflect.Message
- func (x *ActivityCompletionAttestation) Reset()
- func (x *ActivityCompletionAttestation) String() string
- type ActivityCompletionAttestationPayload
- func (*ActivityCompletionAttestationPayload) Descriptor() ([]byte, []int)deprecated
- func (x *ActivityCompletionAttestationPayload) GetActivityName() string
- func (x *ActivityCompletionAttestationPayload) GetCanonicalSpecVersion() uint32
- func (x *ActivityCompletionAttestationPayload) GetIoDigest() []byte
- func (x *ActivityCompletionAttestationPayload) GetParentInstanceId() string
- func (x *ActivityCompletionAttestationPayload) GetParentTaskScheduledId() int32
- func (x *ActivityCompletionAttestationPayload) GetSignerCertDigest() []byte
- func (x *ActivityCompletionAttestationPayload) GetTerminalStatus() ActivityTerminalStatus
- func (*ActivityCompletionAttestationPayload) ProtoMessage()
- func (x *ActivityCompletionAttestationPayload) ProtoReflect() protoreflect.Message
- func (x *ActivityCompletionAttestationPayload) Reset()
- func (x *ActivityCompletionAttestationPayload) String() string
- 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 ActivityTerminalStatus
- func (ActivityTerminalStatus) Descriptor() protoreflect.EnumDescriptor
- func (x ActivityTerminalStatus) Enum() *ActivityTerminalStatus
- func (ActivityTerminalStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x ActivityTerminalStatus) Number() protoreflect.EnumNumber
- func (x ActivityTerminalStatus) String() string
- func (ActivityTerminalStatus) Type() protoreflect.EnumType
- 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) GetExternalSigningCertificateLength() uint64
- func (x *BackendWorkflowStateMetadata) GetGeneration() uint64
- func (x *BackendWorkflowStateMetadata) GetHistoryLength() uint64
- func (x *BackendWorkflowStateMetadata) GetInboxLength() uint64
- func (x *BackendWorkflowStateMetadata) GetSignatureLength() uint64
- func (x *BackendWorkflowStateMetadata) GetSigningCertificateLength() uint64
- func (*BackendWorkflowStateMetadata) ProtoMessage()
- func (x *BackendWorkflowStateMetadata) ProtoReflect() protoreflect.Message
- func (x *BackendWorkflowStateMetadata) Reset()
- func (x *BackendWorkflowStateMetadata) String() string
- type ChildCompletionAttestation
- func (*ChildCompletionAttestation) Descriptor() ([]byte, []int)deprecated
- func (x *ChildCompletionAttestation) GetPayload() []byte
- func (x *ChildCompletionAttestation) GetSignature() []byte
- func (*ChildCompletionAttestation) ProtoMessage()
- func (x *ChildCompletionAttestation) ProtoReflect() protoreflect.Message
- func (x *ChildCompletionAttestation) Reset()
- func (x *ChildCompletionAttestation) String() string
- type ChildCompletionAttestationPayload
- func (*ChildCompletionAttestationPayload) Descriptor() ([]byte, []int)deprecated
- func (x *ChildCompletionAttestationPayload) GetCanonicalSpecVersion() uint32
- func (x *ChildCompletionAttestationPayload) GetIoDigest() []byte
- func (x *ChildCompletionAttestationPayload) GetParentInstanceId() string
- func (x *ChildCompletionAttestationPayload) GetParentTaskScheduledId() int32
- func (x *ChildCompletionAttestationPayload) GetSignerCertDigest() []byte
- func (x *ChildCompletionAttestationPayload) GetTerminalStatus() TerminalStatus
- func (*ChildCompletionAttestationPayload) ProtoMessage()
- func (x *ChildCompletionAttestationPayload) ProtoReflect() protoreflect.Message
- func (x *ChildCompletionAttestationPayload) Reset()
- func (x *ChildCompletionAttestationPayload) String() string
- type ChildWorkflowInstanceCompletedEvent
- func (*ChildWorkflowInstanceCompletedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ChildWorkflowInstanceCompletedEvent) GetAttestation() *ChildCompletionAttestation
- func (x *ChildWorkflowInstanceCompletedEvent) GetResult() *wrapperspb.StringValue
- func (x *ChildWorkflowInstanceCompletedEvent) GetSignerCertificate() []byte
- 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) GetRerunParentInstanceInfo() *RerunParentInstanceInfo
- 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) GetAttestation() *ChildCompletionAttestation
- func (x *ChildWorkflowInstanceFailedEvent) GetFailureDetails() *TaskFailureDetails
- func (x *ChildWorkflowInstanceFailedEvent) GetSignerCertificate() []byte
- 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) GetRouter() *TaskRouter
- 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) GetRouter() *TaskRouter
- 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) 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) 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) 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 ExternalSigningCertificate
- func (*ExternalSigningCertificate) Descriptor() ([]byte, []int)deprecated
- func (x *ExternalSigningCertificate) GetCertificate() []byte
- func (x *ExternalSigningCertificate) GetDigest() []byte
- func (*ExternalSigningCertificate) ProtoMessage()
- func (x *ExternalSigningCertificate) ProtoReflect() protoreflect.Message
- func (x *ExternalSigningCertificate) Reset()
- func (x *ExternalSigningCertificate) 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 (*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
- 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 HistorySignature
- func (*HistorySignature) Descriptor() ([]byte, []int)deprecated
- func (x *HistorySignature) GetCertificateIndex() uint64
- func (x *HistorySignature) GetEventCount() uint64
- func (x *HistorySignature) GetEventsDigest() []byte
- func (x *HistorySignature) GetPreviousSignatureDigest() []byte
- func (x *HistorySignature) GetSignature() []byte
- func (x *HistorySignature) GetStartEventIndex() uint64
- func (*HistorySignature) ProtoMessage()
- func (x *HistorySignature) ProtoReflect() protoreflect.Message
- func (x *HistorySignature) Reset()
- func (x *HistorySignature) String() string
- 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) GetRawSignatures() [][]byte
- func (x *PropagatedHistoryChunk) GetSigningCertChains() [][]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 (*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 (*RaiseEventRequest) ProtoMessage()
- func (x *RaiseEventRequest) ProtoReflect() protoreflect.Message
- func (x *RaiseEventRequest) Reset()
- func (x *RaiseEventRequest) String() string
- type RaiseEventResponse
- type RerunParentInstanceInfo
- func (*RerunParentInstanceInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RerunParentInstanceInfo) GetInstanceID() string
- func (*RerunParentInstanceInfo) ProtoMessage()
- func (x *RerunParentInstanceInfo) ProtoReflect() protoreflect.Message
- func (x *RerunParentInstanceInfo) Reset()
- func (x *RerunParentInstanceInfo) String() string
- type RerunWorkflowFromEventRequest
- func (*RerunWorkflowFromEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RerunWorkflowFromEventRequest) GetEventID() uint32
- func (x *RerunWorkflowFromEventRequest) GetInput() *wrapperspb.StringValue
- func (x *RerunWorkflowFromEventRequest) GetNewChildWorkflowInstanceID() string
- func (x *RerunWorkflowFromEventRequest) GetNewInstanceID() string
- func (x *RerunWorkflowFromEventRequest) GetOverwriteInput() bool
- func (x *RerunWorkflowFromEventRequest) GetSourceInstanceID() string
- func (*RerunWorkflowFromEventRequest) ProtoMessage()
- func (x *RerunWorkflowFromEventRequest) ProtoReflect() protoreflect.Message
- func (x *RerunWorkflowFromEventRequest) Reset()
- func (x *RerunWorkflowFromEventRequest) String() string
- type RerunWorkflowFromEventResponse
- func (*RerunWorkflowFromEventResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RerunWorkflowFromEventResponse) GetNewInstanceID() string
- func (*RerunWorkflowFromEventResponse) ProtoMessage()
- func (x *RerunWorkflowFromEventResponse) ProtoReflect() protoreflect.Message
- func (x *RerunWorkflowFromEventResponse) Reset()
- func (x *RerunWorkflowFromEventResponse) String() string
- type ResumeRequest
- func (*ResumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResumeRequest) GetInstanceId() string
- func (x *ResumeRequest) GetReason() *wrapperspb.StringValue
- func (*ResumeRequest) ProtoMessage()
- func (x *ResumeRequest) ProtoReflect() protoreflect.Message
- func (x *ResumeRequest) Reset()
- func (x *ResumeRequest) String() string
- type ResumeResponse
- 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) GetRouter() *TaskRouter
- 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 SigningCertificate
- func (*SigningCertificate) Descriptor() ([]byte, []int)deprecated
- func (x *SigningCertificate) GetCertificate() []byte
- func (*SigningCertificate) ProtoMessage()
- func (x *SigningCertificate) ProtoReflect() protoreflect.Message
- func (x *SigningCertificate) Reset()
- func (x *SigningCertificate) 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 (*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) GetAttestation() *ActivityCompletionAttestation
- func (x *TaskCompletedEvent) GetResult() *wrapperspb.StringValue
- func (x *TaskCompletedEvent) GetSignerCertificate() []byte
- 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) GetAttestation() *ActivityCompletionAttestation
- func (x *TaskFailedEvent) GetFailureDetails() *TaskFailureDetails
- func (x *TaskFailedEvent) GetSignerCertificate() []byte
- 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) GetRerunParentInstanceInfo() *RerunParentInstanceInfo
- 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 TerminalStatus
- func (TerminalStatus) Descriptor() protoreflect.EnumDescriptor
- func (x TerminalStatus) Enum() *TerminalStatus
- func (TerminalStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x TerminalStatus) Number() protoreflect.EnumNumber
- func (x TerminalStatus) String() string
- func (TerminalStatus) Type() protoreflect.EnumType
- 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 (*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 (x *TimerCreatedEvent) GetRerunParentInstanceInfo() *RerunParentInstanceInfo
- 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) RerunWorkflowFromEvent(context.Context, *RerunWorkflowFromEventRequest) (*RerunWorkflowFromEventResponse, 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) 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_RerunWorkflowFromEvent_FullMethodName = "/TaskHubSidecarService/RerunWorkflowFromEvent" TaskHubSidecarService_ListInstanceIDs_FullMethodName = "/TaskHubSidecarService/ListInstanceIDs" TaskHubSidecarService_GetInstanceHistory_FullMethodName = "/TaskHubSidecarService/GetInstanceHistory" )
Variables ¶
var ( TerminalStatus_name = map[int32]string{ 0: "TERMINAL_STATUS_UNSPECIFIED", 1: "TERMINAL_STATUS_COMPLETED", 2: "TERMINAL_STATUS_FAILED", } TerminalStatus_value = map[string]int32{ "TERMINAL_STATUS_UNSPECIFIED": 0, "TERMINAL_STATUS_COMPLETED": 1, "TERMINAL_STATUS_FAILED": 2, } )
Enum value maps for TerminalStatus.
var ( ActivityTerminalStatus_name = map[int32]string{ 0: "ACTIVITY_TERMINAL_STATUS_UNSPECIFIED", 1: "ACTIVITY_TERMINAL_STATUS_COMPLETED", 2: "ACTIVITY_TERMINAL_STATUS_FAILED", } ActivityTerminalStatus_value = map[string]int32{ "ACTIVITY_TERMINAL_STATUS_UNSPECIFIED": 0, "ACTIVITY_TERMINAL_STATUS_COMPLETED": 1, "ACTIVITY_TERMINAL_STATUS_FAILED": 2, } )
Enum value maps for ActivityTerminalStatus.
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", 1: "WORKER_CAPABILITY_HISTORY_STREAMING", } WorkerCapability_value = map[string]int32{ "WORKER_CAPABILITY_UNSPECIFIED": 0, "WORKER_CAPABILITY_HISTORY_STREAMING": 1, } )
Enum value maps for WorkerCapability.
var File_attestation_proto protoreflect.FileDescriptor
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: "RerunWorkflowFromEvent", Handler: _TaskHubSidecarService_RerunWorkflowFromEvent_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 ActivityCompletionAttestation ¶ added in v0.12.0
type ActivityCompletionAttestation struct {
// Deterministically serialized form of
// ActivityCompletionAttestationPayload produced once by the signer.
// Opaque bytes thereafter; receivers, storage layers, and verifiers
// never re-marshal.
Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
// Cryptographic signature over sha256(payload).
Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
// contains filtered or unexported fields
}
Signed wrapper around ActivityCompletionAttestationPayload.
func (*ActivityCompletionAttestation) Descriptor
deprecated
added in
v0.12.0
func (*ActivityCompletionAttestation) Descriptor() ([]byte, []int)
Deprecated: Use ActivityCompletionAttestation.ProtoReflect.Descriptor instead.
func (*ActivityCompletionAttestation) GetPayload ¶ added in v0.12.0
func (x *ActivityCompletionAttestation) GetPayload() []byte
func (*ActivityCompletionAttestation) GetSignature ¶ added in v0.12.0
func (x *ActivityCompletionAttestation) GetSignature() []byte
func (*ActivityCompletionAttestation) ProtoMessage ¶ added in v0.12.0
func (*ActivityCompletionAttestation) ProtoMessage()
func (*ActivityCompletionAttestation) ProtoReflect ¶ added in v0.12.0
func (x *ActivityCompletionAttestation) ProtoReflect() protoreflect.Message
func (*ActivityCompletionAttestation) Reset ¶ added in v0.12.0
func (x *ActivityCompletionAttestation) Reset()
func (*ActivityCompletionAttestation) String ¶ added in v0.12.0
func (x *ActivityCompletionAttestation) String() string
type ActivityCompletionAttestationPayload ¶ added in v0.12.0
type ActivityCompletionAttestationPayload struct {
// Parent workflow instance ID that scheduled the activity.
ParentInstanceId string `protobuf:"bytes,1,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"`
// taskScheduledId from the parent's TaskScheduledEvent. Unique within
// the parent instance.
ParentTaskScheduledId int32 `protobuf:"varint,2,opt,name=parentTaskScheduledId,proto3" json:"parentTaskScheduledId,omitempty"`
// Activity name from the parent's TaskScheduledEvent. Explicit because
// no separate creation event binds it in the parent's history the way
// ChildWorkflowInstanceCreatedEvent does for child workflows.
ActivityName string `protobuf:"bytes,3,opt,name=activityName,proto3" json:"activityName,omitempty"`
// sha256 commitment to this invocation's input and output. See the
// canonical byte serialization spec at the top of this file. Use
// terminalStatus (ACTIVITY_TERMINAL_STATUS_COMPLETED or _FAILED) to
// select the output serialization rule.
IoDigest []byte `protobuf:"bytes,4,opt,name=ioDigest,proto3" json:"ioDigest,omitempty"`
// sha256 of the DER-encoded X.509 certificate chain bytes of the
// activity executor's signer. Same semantics and storage behavior as
// ChildCompletionAttestationPayload.signerCertDigest.
SignerCertDigest []byte `protobuf:"bytes,5,opt,name=signerCertDigest,proto3" json:"signerCertDigest,omitempty"`
// Terminal state of the activity at the moment of attestation.
TerminalStatus ActivityTerminalStatus `protobuf:"varint,6,opt,name=terminalStatus,proto3,enum=ActivityTerminalStatus" json:"terminalStatus,omitempty"`
// Version of the canonical byte serialization spec used to compute
// ioDigest. See the "Versioning" section of the spec block at the top
// of this file. Verifiers that don't recognize the value reject the
// attestation rather than risk a silent digest mismatch. Current
// value: 1.
CanonicalSpecVersion uint32 `protobuf:"varint,7,opt,name=canonicalSpecVersion,proto3" json:"canonicalSpecVersion,omitempty"`
// contains filtered or unexported fields
}
Inner signed payload for an activity completion attestation. Activities have no signed history chain of their own (unlike child workflows), so there is no finalSignatureDigest field. Activity identity is the hosting app's SPIFFE identity; a compromised app can attest only to activities it hosts, not to activities hosted on other apps.
func (*ActivityCompletionAttestationPayload) Descriptor
deprecated
added in
v0.12.0
func (*ActivityCompletionAttestationPayload) Descriptor() ([]byte, []int)
Deprecated: Use ActivityCompletionAttestationPayload.ProtoReflect.Descriptor instead.
func (*ActivityCompletionAttestationPayload) GetActivityName ¶ added in v0.12.0
func (x *ActivityCompletionAttestationPayload) GetActivityName() string
func (*ActivityCompletionAttestationPayload) GetCanonicalSpecVersion ¶ added in v0.12.0
func (x *ActivityCompletionAttestationPayload) GetCanonicalSpecVersion() uint32
func (*ActivityCompletionAttestationPayload) GetIoDigest ¶ added in v0.12.0
func (x *ActivityCompletionAttestationPayload) GetIoDigest() []byte
func (*ActivityCompletionAttestationPayload) GetParentInstanceId ¶ added in v0.12.0
func (x *ActivityCompletionAttestationPayload) GetParentInstanceId() string
func (*ActivityCompletionAttestationPayload) GetParentTaskScheduledId ¶ added in v0.12.0
func (x *ActivityCompletionAttestationPayload) GetParentTaskScheduledId() int32
func (*ActivityCompletionAttestationPayload) GetSignerCertDigest ¶ added in v0.12.0
func (x *ActivityCompletionAttestationPayload) GetSignerCertDigest() []byte
func (*ActivityCompletionAttestationPayload) GetTerminalStatus ¶ added in v0.12.0
func (x *ActivityCompletionAttestationPayload) GetTerminalStatus() ActivityTerminalStatus
func (*ActivityCompletionAttestationPayload) ProtoMessage ¶ added in v0.12.0
func (*ActivityCompletionAttestationPayload) ProtoMessage()
func (*ActivityCompletionAttestationPayload) ProtoReflect ¶ added in v0.12.0
func (x *ActivityCompletionAttestationPayload) ProtoReflect() protoreflect.Message
func (*ActivityCompletionAttestationPayload) Reset ¶ added in v0.12.0
func (x *ActivityCompletionAttestationPayload) Reset()
func (*ActivityCompletionAttestationPayload) String ¶ added in v0.12.0
func (x *ActivityCompletionAttestationPayload) String() string
type ActivityInvocation ¶ added in v0.12.0
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
added in
v0.12.0
func (*ActivityInvocation) Descriptor() ([]byte, []int)
Deprecated: Use ActivityInvocation.ProtoReflect.Descriptor instead.
func (*ActivityInvocation) GetHistoryEvent ¶ added in v0.12.0
func (x *ActivityInvocation) GetHistoryEvent() *HistoryEvent
func (*ActivityInvocation) GetPropagatedHistory ¶ added in v0.12.0
func (x *ActivityInvocation) GetPropagatedHistory() *PropagatedHistory
func (*ActivityInvocation) ProtoMessage ¶ added in v0.12.0
func (*ActivityInvocation) ProtoMessage()
func (*ActivityInvocation) ProtoReflect ¶ added in v0.12.0
func (x *ActivityInvocation) ProtoReflect() protoreflect.Message
func (*ActivityInvocation) Reset ¶ added in v0.12.0
func (x *ActivityInvocation) Reset()
func (*ActivityInvocation) String ¶ added in v0.12.0
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 ¶ added in v0.12.0
func (x *ActivityRequest) GetPropagatedHistory() *PropagatedHistory
func (*ActivityRequest) GetTaskExecutionId ¶ added in v0.8.0
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 ¶ added in v0.12.0
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 ¶ added in v0.7.0
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 ActivityTerminalStatus ¶ added in v0.12.0
type ActivityTerminalStatus int32
Terminal state of an activity task at the moment of attestation. Activities have no "terminate" operation, so the space is smaller than TerminalStatus.
const ( ActivityTerminalStatus_ACTIVITY_TERMINAL_STATUS_UNSPECIFIED ActivityTerminalStatus = 0 ActivityTerminalStatus_ACTIVITY_TERMINAL_STATUS_COMPLETED ActivityTerminalStatus = 1 ActivityTerminalStatus_ACTIVITY_TERMINAL_STATUS_FAILED ActivityTerminalStatus = 2 )
func (ActivityTerminalStatus) Descriptor ¶ added in v0.12.0
func (ActivityTerminalStatus) Descriptor() protoreflect.EnumDescriptor
func (ActivityTerminalStatus) Enum ¶ added in v0.12.0
func (x ActivityTerminalStatus) Enum() *ActivityTerminalStatus
func (ActivityTerminalStatus) EnumDescriptor
deprecated
added in
v0.12.0
func (ActivityTerminalStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ActivityTerminalStatus.Descriptor instead.
func (ActivityTerminalStatus) Number ¶ added in v0.12.0
func (x ActivityTerminalStatus) Number() protoreflect.EnumNumber
func (ActivityTerminalStatus) String ¶ added in v0.12.0
func (x ActivityTerminalStatus) String() string
func (ActivityTerminalStatus) Type ¶ added in v0.12.0
func (ActivityTerminalStatus) Type() protoreflect.EnumType
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 ¶ added in v0.12.0
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
added in
v0.12.0
func (*BackendWorkflowState) Descriptor() ([]byte, []int)
Deprecated: Use BackendWorkflowState.ProtoReflect.Descriptor instead.
func (*BackendWorkflowState) GetCustomStatus ¶ added in v0.12.0
func (x *BackendWorkflowState) GetCustomStatus() *wrapperspb.StringValue
func (*BackendWorkflowState) GetGeneration ¶ added in v0.12.0
func (x *BackendWorkflowState) GetGeneration() uint64
func (*BackendWorkflowState) GetHistory ¶ added in v0.12.0
func (x *BackendWorkflowState) GetHistory() []*HistoryEvent
func (*BackendWorkflowState) GetInbox ¶ added in v0.12.0
func (x *BackendWorkflowState) GetInbox() []*HistoryEvent
func (*BackendWorkflowState) ProtoMessage ¶ added in v0.12.0
func (*BackendWorkflowState) ProtoMessage()
func (*BackendWorkflowState) ProtoReflect ¶ added in v0.12.0
func (x *BackendWorkflowState) ProtoReflect() protoreflect.Message
func (*BackendWorkflowState) Reset ¶ added in v0.12.0
func (x *BackendWorkflowState) Reset()
func (*BackendWorkflowState) String ¶ added in v0.12.0
func (x *BackendWorkflowState) String() string
type BackendWorkflowStateMetadata ¶ added in v0.12.0
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"`
// Number of HistorySignature entries stored (signature-NNNNNN keys).
SignatureLength uint64 `protobuf:"varint,4,opt,name=signatureLength,proto3" json:"signatureLength,omitempty"`
// Number of SigningCertificate entries stored (sigcert-NNNNNN keys).
SigningCertificateLength uint64 `protobuf:"varint,5,opt,name=signingCertificateLength,proto3" json:"signingCertificateLength,omitempty"`
// Number of ExternalSigningCertificate entries stored
// (ext-sigcert-NNNNNN keys). Same lifecycle as signingCertificateLength:
// monotonically grows within a run as new foreign signer certificates
// are absorbed from incoming attestations, zeroed on ContinueAsNew,
// cleared on instance purge. Subject to the same maxStateEntries
// tampering bound.
ExternalSigningCertificateLength uint64 `protobuf:"varint,6,opt,name=externalSigningCertificateLength,proto3" json:"externalSigningCertificateLength,omitempty"`
// contains filtered or unexported fields
}
func (*BackendWorkflowStateMetadata) Descriptor
deprecated
added in
v0.12.0
func (*BackendWorkflowStateMetadata) Descriptor() ([]byte, []int)
Deprecated: Use BackendWorkflowStateMetadata.ProtoReflect.Descriptor instead.
func (*BackendWorkflowStateMetadata) GetExternalSigningCertificateLength ¶ added in v0.12.0
func (x *BackendWorkflowStateMetadata) GetExternalSigningCertificateLength() uint64
func (*BackendWorkflowStateMetadata) GetGeneration ¶ added in v0.12.0
func (x *BackendWorkflowStateMetadata) GetGeneration() uint64
func (*BackendWorkflowStateMetadata) GetHistoryLength ¶ added in v0.12.0
func (x *BackendWorkflowStateMetadata) GetHistoryLength() uint64
func (*BackendWorkflowStateMetadata) GetInboxLength ¶ added in v0.12.0
func (x *BackendWorkflowStateMetadata) GetInboxLength() uint64
func (*BackendWorkflowStateMetadata) GetSignatureLength ¶ added in v0.12.0
func (x *BackendWorkflowStateMetadata) GetSignatureLength() uint64
func (*BackendWorkflowStateMetadata) GetSigningCertificateLength ¶ added in v0.12.0
func (x *BackendWorkflowStateMetadata) GetSigningCertificateLength() uint64
func (*BackendWorkflowStateMetadata) ProtoMessage ¶ added in v0.12.0
func (*BackendWorkflowStateMetadata) ProtoMessage()
func (*BackendWorkflowStateMetadata) ProtoReflect ¶ added in v0.12.0
func (x *BackendWorkflowStateMetadata) ProtoReflect() protoreflect.Message
func (*BackendWorkflowStateMetadata) Reset ¶ added in v0.12.0
func (x *BackendWorkflowStateMetadata) Reset()
func (*BackendWorkflowStateMetadata) String ¶ added in v0.12.0
func (x *BackendWorkflowStateMetadata) String() string
type ChildCompletionAttestation ¶ added in v0.12.0
type ChildCompletionAttestation struct {
// Deterministically serialized form of ChildCompletionAttestationPayload
// produced once by the signer. Opaque bytes thereafter; receivers,
// storage layers, and verifiers never re-marshal.
Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
// Cryptographic signature over sha256(payload) using the private key
// corresponding to the certificate whose digest is in the payload's
// signerCertDigest field. Signature format follows the same rules as
// HistorySignature.signature.
Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
// contains filtered or unexported fields
}
Signed wrapper around ChildCompletionAttestationPayload.
func (*ChildCompletionAttestation) Descriptor
deprecated
added in
v0.12.0
func (*ChildCompletionAttestation) Descriptor() ([]byte, []int)
Deprecated: Use ChildCompletionAttestation.ProtoReflect.Descriptor instead.
func (*ChildCompletionAttestation) GetPayload ¶ added in v0.12.0
func (x *ChildCompletionAttestation) GetPayload() []byte
func (*ChildCompletionAttestation) GetSignature ¶ added in v0.12.0
func (x *ChildCompletionAttestation) GetSignature() []byte
func (*ChildCompletionAttestation) ProtoMessage ¶ added in v0.12.0
func (*ChildCompletionAttestation) ProtoMessage()
func (*ChildCompletionAttestation) ProtoReflect ¶ added in v0.12.0
func (x *ChildCompletionAttestation) ProtoReflect() protoreflect.Message
func (*ChildCompletionAttestation) Reset ¶ added in v0.12.0
func (x *ChildCompletionAttestation) Reset()
func (*ChildCompletionAttestation) String ¶ added in v0.12.0
func (x *ChildCompletionAttestation) String() string
type ChildCompletionAttestationPayload ¶ added in v0.12.0
type ChildCompletionAttestationPayload struct {
// Parent workflow instance ID. Binds the attestation to a single parent
// run, preventing replay by other instances of the same parent workflow
// that share a signing key.
ParentInstanceId string `protobuf:"bytes,1,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"`
// taskScheduledId from the parent's ChildWorkflowInstanceCreatedEvent.
// Unique within the parent instance; distinguishes multiple invocations
// of the same child workflow.
ParentTaskScheduledId int32 `protobuf:"varint,2,opt,name=parentTaskScheduledId,proto3" json:"parentTaskScheduledId,omitempty"`
// sha256 commitment to this invocation's input and output. The bytes
// fed into the digest are produced by the canonical byte serialization
// spec at the top of this file — not by any protobuf marshaler — so
// the digest is stable across proto versions, implementations, and
// languages. Use terminalStatus to select the output serialization rule
// (COMPLETED or FAILED).
IoDigest []byte `protobuf:"bytes,3,opt,name=ioDigest,proto3" json:"ioDigest,omitempty"`
// sha256 of the DER-encoded X.509 certificate chain bytes of the
// signer (leaf first, intermediates concatenated; same byte format
// as the `certificate` field of SigningCertificate). Computed directly
// over the DER bytes rather than any protobuf envelope, so the digest
// is stable across protobuf version changes. The certificate itself
// is carried as a companion field on the enclosing event on first
// delivery and stored once in the receiver's external certificate
// table (ext-sigcert-NNNNNN), looked up by this digest.
SignerCertDigest []byte `protobuf:"bytes,4,opt,name=signerCertDigest,proto3" json:"signerCertDigest,omitempty"`
// Terminal state of the child workflow at the moment of attestation.
// Signed so that a verifier reading the attestation from propagated
// history can tell whether the child succeeded without relying on the
// enclosing event type (Completed vs Failed), which may not be
// visible or trustworthy when the attestation is inspected in
// isolation.
TerminalStatus TerminalStatus `protobuf:"varint,5,opt,name=terminalStatus,proto3,enum=TerminalStatus" json:"terminalStatus,omitempty"`
// Version of the canonical byte serialization spec used to compute
// ioDigest. See the "Versioning" section of the spec block at the top
// of this file. Verifiers that don't recognize the value reject the
// attestation rather than risk a silent digest mismatch. Current
// value: 1.
CanonicalSpecVersion uint32 `protobuf:"varint,6,opt,name=canonicalSpecVersion,proto3" json:"canonicalSpecVersion,omitempty"`
// contains filtered or unexported fields
}
Inner signed payload for a child workflow completion attestation. The deterministically serialized form of this message is what the signer signs over and what receivers verify against; the bytes are produced once and never re-marshaled.
func (*ChildCompletionAttestationPayload) Descriptor
deprecated
added in
v0.12.0
func (*ChildCompletionAttestationPayload) Descriptor() ([]byte, []int)
Deprecated: Use ChildCompletionAttestationPayload.ProtoReflect.Descriptor instead.
func (*ChildCompletionAttestationPayload) GetCanonicalSpecVersion ¶ added in v0.12.0
func (x *ChildCompletionAttestationPayload) GetCanonicalSpecVersion() uint32
func (*ChildCompletionAttestationPayload) GetIoDigest ¶ added in v0.12.0
func (x *ChildCompletionAttestationPayload) GetIoDigest() []byte
func (*ChildCompletionAttestationPayload) GetParentInstanceId ¶ added in v0.12.0
func (x *ChildCompletionAttestationPayload) GetParentInstanceId() string
func (*ChildCompletionAttestationPayload) GetParentTaskScheduledId ¶ added in v0.12.0
func (x *ChildCompletionAttestationPayload) GetParentTaskScheduledId() int32
func (*ChildCompletionAttestationPayload) GetSignerCertDigest ¶ added in v0.12.0
func (x *ChildCompletionAttestationPayload) GetSignerCertDigest() []byte
func (*ChildCompletionAttestationPayload) GetTerminalStatus ¶ added in v0.12.0
func (x *ChildCompletionAttestationPayload) GetTerminalStatus() TerminalStatus
func (*ChildCompletionAttestationPayload) ProtoMessage ¶ added in v0.12.0
func (*ChildCompletionAttestationPayload) ProtoMessage()
func (*ChildCompletionAttestationPayload) ProtoReflect ¶ added in v0.12.0
func (x *ChildCompletionAttestationPayload) ProtoReflect() protoreflect.Message
func (*ChildCompletionAttestationPayload) Reset ¶ added in v0.12.0
func (x *ChildCompletionAttestationPayload) Reset()
func (*ChildCompletionAttestationPayload) String ¶ added in v0.12.0
func (x *ChildCompletionAttestationPayload) String() string
type ChildWorkflowInstanceCompletedEvent ¶ added in v0.12.0
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"`
// Attestation signed by the completing child workflow's SPIFFE
// identity. Present when the child was executed under a signing-enabled
// configuration. Verified on inbox ingestion against the companion
// signerCertificate and preserved in stored history for future audit
// and forwarding via provenance bundles.
Attestation *ChildCompletionAttestation `protobuf:"bytes,3,opt,name=attestation,proto3,oneof" json:"attestation,omitempty"`
// Companion: DER-encoded X.509 certificate chain of the child's signing
// identity (leaf first, intermediates concatenated; same format as
// SigningCertificate.certificate in backend_service.proto). Wire-only;
// stripped by the receiver before the event is written to
// history-NNNNNN. The certificate lives once in ext-sigcert-NNNNNN,
// referenced by attestation payload's signerCertDigest.
SignerCertificate []byte `protobuf:"bytes,4,opt,name=signerCertificate,proto3,oneof" json:"signerCertificate,omitempty"`
// contains filtered or unexported fields
}
func (*ChildWorkflowInstanceCompletedEvent) Descriptor
deprecated
added in
v0.12.0
func (*ChildWorkflowInstanceCompletedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowInstanceCompletedEvent.ProtoReflect.Descriptor instead.
func (*ChildWorkflowInstanceCompletedEvent) GetAttestation ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCompletedEvent) GetAttestation() *ChildCompletionAttestation
func (*ChildWorkflowInstanceCompletedEvent) GetResult ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCompletedEvent) GetResult() *wrapperspb.StringValue
func (*ChildWorkflowInstanceCompletedEvent) GetSignerCertificate ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCompletedEvent) GetSignerCertificate() []byte
func (*ChildWorkflowInstanceCompletedEvent) GetTaskScheduledId ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCompletedEvent) GetTaskScheduledId() int32
func (*ChildWorkflowInstanceCompletedEvent) ProtoMessage ¶ added in v0.12.0
func (*ChildWorkflowInstanceCompletedEvent) ProtoMessage()
func (*ChildWorkflowInstanceCompletedEvent) ProtoReflect ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCompletedEvent) ProtoReflect() protoreflect.Message
func (*ChildWorkflowInstanceCompletedEvent) Reset ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCompletedEvent) Reset()
func (*ChildWorkflowInstanceCompletedEvent) String ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCompletedEvent) String() string
type ChildWorkflowInstanceCreatedEvent ¶ added in v0.12.0
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"`
// If defined, indicates that this task was the starting point of a new
// workflow execution as the result of a rerun operation.
RerunParentInstanceInfo *RerunParentInstanceInfo `protobuf:"bytes,6,opt,name=rerunParentInstanceInfo,proto3,oneof" json:"rerunParentInstanceInfo,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 */
// contains filtered or unexported fields
}
func (*ChildWorkflowInstanceCreatedEvent) Descriptor
deprecated
added in
v0.12.0
func (*ChildWorkflowInstanceCreatedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowInstanceCreatedEvent.ProtoReflect.Descriptor instead.
func (*ChildWorkflowInstanceCreatedEvent) GetHistoryPropagationScope ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCreatedEvent) GetHistoryPropagationScope() HistoryPropagationScope
func (*ChildWorkflowInstanceCreatedEvent) GetInput ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCreatedEvent) GetInput() *wrapperspb.StringValue
func (*ChildWorkflowInstanceCreatedEvent) GetInstanceId ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCreatedEvent) GetInstanceId() string
func (*ChildWorkflowInstanceCreatedEvent) GetName ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCreatedEvent) GetName() string
func (*ChildWorkflowInstanceCreatedEvent) GetParentTraceContext ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCreatedEvent) GetParentTraceContext() *TraceContext
func (*ChildWorkflowInstanceCreatedEvent) GetRerunParentInstanceInfo ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCreatedEvent) GetRerunParentInstanceInfo() *RerunParentInstanceInfo
func (*ChildWorkflowInstanceCreatedEvent) GetVersion ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCreatedEvent) GetVersion() *wrapperspb.StringValue
func (*ChildWorkflowInstanceCreatedEvent) ProtoMessage ¶ added in v0.12.0
func (*ChildWorkflowInstanceCreatedEvent) ProtoMessage()
func (*ChildWorkflowInstanceCreatedEvent) ProtoReflect ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCreatedEvent) ProtoReflect() protoreflect.Message
func (*ChildWorkflowInstanceCreatedEvent) Reset ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCreatedEvent) Reset()
func (*ChildWorkflowInstanceCreatedEvent) String ¶ added in v0.12.0
func (x *ChildWorkflowInstanceCreatedEvent) String() string
type ChildWorkflowInstanceFailedEvent ¶ added in v0.12.0
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"`
// See ChildWorkflowInstanceCompletedEvent.attestation.
Attestation *ChildCompletionAttestation `protobuf:"bytes,3,opt,name=attestation,proto3,oneof" json:"attestation,omitempty"`
// Wire-only companion; see
// ChildWorkflowInstanceCompletedEvent.signerCertificate.
SignerCertificate []byte `protobuf:"bytes,4,opt,name=signerCertificate,proto3,oneof" json:"signerCertificate,omitempty"`
// contains filtered or unexported fields
}
func (*ChildWorkflowInstanceFailedEvent) Descriptor
deprecated
added in
v0.12.0
func (*ChildWorkflowInstanceFailedEvent) Descriptor() ([]byte, []int)
Deprecated: Use ChildWorkflowInstanceFailedEvent.ProtoReflect.Descriptor instead.
func (*ChildWorkflowInstanceFailedEvent) GetAttestation ¶ added in v0.12.0
func (x *ChildWorkflowInstanceFailedEvent) GetAttestation() *ChildCompletionAttestation
func (*ChildWorkflowInstanceFailedEvent) GetFailureDetails ¶ added in v0.12.0
func (x *ChildWorkflowInstanceFailedEvent) GetFailureDetails() *TaskFailureDetails
func (*ChildWorkflowInstanceFailedEvent) GetSignerCertificate ¶ added in v0.12.0
func (x *ChildWorkflowInstanceFailedEvent) GetSignerCertificate() []byte
func (*ChildWorkflowInstanceFailedEvent) GetTaskScheduledId ¶ added in v0.12.0
func (x *ChildWorkflowInstanceFailedEvent) GetTaskScheduledId() int32
func (*ChildWorkflowInstanceFailedEvent) ProtoMessage ¶ added in v0.12.0
func (*ChildWorkflowInstanceFailedEvent) ProtoMessage()
func (*ChildWorkflowInstanceFailedEvent) ProtoReflect ¶ added in v0.12.0
func (x *ChildWorkflowInstanceFailedEvent) ProtoReflect() protoreflect.Message
func (*ChildWorkflowInstanceFailedEvent) Reset ¶ added in v0.12.0
func (x *ChildWorkflowInstanceFailedEvent) Reset()
func (*ChildWorkflowInstanceFailedEvent) String ¶ added in v0.12.0
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 ¶ added in v0.12.0
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
added in
v0.12.0
func (*CompleteWorkflowAction) Descriptor() ([]byte, []int)
Deprecated: Use CompleteWorkflowAction.ProtoReflect.Descriptor instead.
func (*CompleteWorkflowAction) GetCarryoverEvents ¶ added in v0.12.0
func (x *CompleteWorkflowAction) GetCarryoverEvents() []*HistoryEvent
func (*CompleteWorkflowAction) GetDetails ¶ added in v0.12.0
func (x *CompleteWorkflowAction) GetDetails() *wrapperspb.StringValue
func (*CompleteWorkflowAction) GetFailureDetails ¶ added in v0.12.0
func (x *CompleteWorkflowAction) GetFailureDetails() *TaskFailureDetails
func (*CompleteWorkflowAction) GetNewVersion ¶ added in v0.12.0
func (x *CompleteWorkflowAction) GetNewVersion() *wrapperspb.StringValue
func (*CompleteWorkflowAction) GetOrchestrationStatus
deprecated
added in
v0.12.0
func (x *CompleteWorkflowAction) GetOrchestrationStatus() OrchestrationStatus
Deprecated: Use GetWorkflowStatus on CompleteWorkflowAction instead.
func (*CompleteWorkflowAction) GetResult ¶ added in v0.12.0
func (x *CompleteWorkflowAction) GetResult() *wrapperspb.StringValue
func (*CompleteWorkflowAction) GetWorkflowStatus ¶ added in v0.12.0
func (x *CompleteWorkflowAction) GetWorkflowStatus() OrchestrationStatus
func (*CompleteWorkflowAction) ProtoMessage ¶ added in v0.12.0
func (*CompleteWorkflowAction) ProtoMessage()
func (*CompleteWorkflowAction) ProtoReflect ¶ added in v0.12.0
func (x *CompleteWorkflowAction) ProtoReflect() protoreflect.Message
func (*CompleteWorkflowAction) Reset ¶ added in v0.12.0
func (x *CompleteWorkflowAction) Reset()
func (*CompleteWorkflowAction) String ¶ added in v0.12.0
func (x *CompleteWorkflowAction) String() string
type CompleteWorkflowWorkItemRequest ¶ added in v0.12.0
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
added in
v0.12.0
func (*CompleteWorkflowWorkItemRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompleteWorkflowWorkItemRequest.ProtoReflect.Descriptor instead.
func (*CompleteWorkflowWorkItemRequest) GetCompletionToken ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) GetCompletionToken() string
func (*CompleteWorkflowWorkItemRequest) GetCustomStatus ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) GetCustomStatus() *wrapperspb.StringValue
func (*CompleteWorkflowWorkItemRequest) GetInstance ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) GetInstance() *WorkflowInstance
func (*CompleteWorkflowWorkItemRequest) GetNewHistory ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) GetNewHistory() []*HistoryEvent
func (*CompleteWorkflowWorkItemRequest) GetNewMessages ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) GetNewMessages() []*WorkflowMessage
func (*CompleteWorkflowWorkItemRequest) GetNewTasks ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) GetNewTasks() []*HistoryEvent
func (*CompleteWorkflowWorkItemRequest) GetNewTimers ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) GetNewTimers() []*HistoryEvent
func (*CompleteWorkflowWorkItemRequest) GetNumEventsProcessed ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) GetNumEventsProcessed() *wrapperspb.Int32Value
func (*CompleteWorkflowWorkItemRequest) GetRuntimeStatus ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) GetRuntimeStatus() OrchestrationStatus
func (*CompleteWorkflowWorkItemRequest) ProtoMessage ¶ added in v0.12.0
func (*CompleteWorkflowWorkItemRequest) ProtoMessage()
func (*CompleteWorkflowWorkItemRequest) ProtoReflect ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) ProtoReflect() protoreflect.Message
func (*CompleteWorkflowWorkItemRequest) Reset ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) Reset()
func (*CompleteWorkflowWorkItemRequest) String ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemRequest) String() string
type CompleteWorkflowWorkItemResponse ¶ added in v0.12.0
type CompleteWorkflowWorkItemResponse struct {
// contains filtered or unexported fields
}
Response payload for completing a workflow work item.
func (*CompleteWorkflowWorkItemResponse) Descriptor
deprecated
added in
v0.12.0
func (*CompleteWorkflowWorkItemResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompleteWorkflowWorkItemResponse.ProtoReflect.Descriptor instead.
func (*CompleteWorkflowWorkItemResponse) ProtoMessage ¶ added in v0.12.0
func (*CompleteWorkflowWorkItemResponse) ProtoMessage()
func (*CompleteWorkflowWorkItemResponse) ProtoReflect ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemResponse) ProtoReflect() protoreflect.Message
func (*CompleteWorkflowWorkItemResponse) Reset ¶ added in v0.12.0
func (x *CompleteWorkflowWorkItemResponse) Reset()
func (*CompleteWorkflowWorkItemResponse) String ¶ added in v0.12.0
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 ¶ added in v0.12.0
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"`
Router *TaskRouter `protobuf:"bytes,5,opt,name=router,proto3,oneof" json:"router,omitempty"`
// History propagation scope. Absent/SCOPE_NONE = no propagation.
HistoryPropagationScope *HistoryPropagationScope `` /* 135-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*CreateChildWorkflowAction) Descriptor
deprecated
added in
v0.12.0
func (*CreateChildWorkflowAction) Descriptor() ([]byte, []int)
Deprecated: Use CreateChildWorkflowAction.ProtoReflect.Descriptor instead.
func (*CreateChildWorkflowAction) GetHistoryPropagationScope ¶ added in v0.12.0
func (x *CreateChildWorkflowAction) GetHistoryPropagationScope() HistoryPropagationScope
func (*CreateChildWorkflowAction) GetInput ¶ added in v0.12.0
func (x *CreateChildWorkflowAction) GetInput() *wrapperspb.StringValue
func (*CreateChildWorkflowAction) GetInstanceId ¶ added in v0.12.0
func (x *CreateChildWorkflowAction) GetInstanceId() string
func (*CreateChildWorkflowAction) GetName ¶ added in v0.12.0
func (x *CreateChildWorkflowAction) GetName() string
func (*CreateChildWorkflowAction) GetRouter ¶ added in v0.12.0
func (x *CreateChildWorkflowAction) GetRouter() *TaskRouter
func (*CreateChildWorkflowAction) GetVersion ¶ added in v0.12.0
func (x *CreateChildWorkflowAction) GetVersion() *wrapperspb.StringValue
func (*CreateChildWorkflowAction) ProtoMessage ¶ added in v0.12.0
func (*CreateChildWorkflowAction) ProtoMessage()
func (*CreateChildWorkflowAction) ProtoReflect ¶ added in v0.12.0
func (x *CreateChildWorkflowAction) ProtoReflect() protoreflect.Message
func (*CreateChildWorkflowAction) Reset ¶ added in v0.12.0
func (x *CreateChildWorkflowAction) Reset()
func (*CreateChildWorkflowAction) String ¶ added in v0.12.0
func (x *CreateChildWorkflowAction) String() string
type CreateDetachedWorkflowAction ¶ added in v0.12.0
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"`
Router *TaskRouter `protobuf:"bytes,9,opt,name=router,proto3,oneof" json:"router,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
added in
v0.12.0
func (*CreateDetachedWorkflowAction) Descriptor() ([]byte, []int)
Deprecated: Use CreateDetachedWorkflowAction.ProtoReflect.Descriptor instead.
func (*CreateDetachedWorkflowAction) GetExecutionId ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) GetExecutionId() *wrapperspb.StringValue
func (*CreateDetachedWorkflowAction) GetInput ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) GetInput() *wrapperspb.StringValue
func (*CreateDetachedWorkflowAction) GetInstanceId ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) GetInstanceId() string
func (*CreateDetachedWorkflowAction) GetName ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) GetName() string
func (*CreateDetachedWorkflowAction) GetParentTraceContext ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) GetParentTraceContext() *TraceContext
func (*CreateDetachedWorkflowAction) GetRouter ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) GetRouter() *TaskRouter
func (*CreateDetachedWorkflowAction) GetScheduledStartTimestamp ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) GetScheduledStartTimestamp() *timestamppb.Timestamp
func (*CreateDetachedWorkflowAction) GetTags ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) GetTags() map[string]string
func (*CreateDetachedWorkflowAction) GetVersion ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) GetVersion() *wrapperspb.StringValue
func (*CreateDetachedWorkflowAction) ProtoMessage ¶ added in v0.12.0
func (*CreateDetachedWorkflowAction) ProtoMessage()
func (*CreateDetachedWorkflowAction) ProtoReflect ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) ProtoReflect() protoreflect.Message
func (*CreateDetachedWorkflowAction) Reset ¶ added in v0.12.0
func (x *CreateDetachedWorkflowAction) Reset()
func (*CreateDetachedWorkflowAction) String ¶ added in v0.12.0
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"`
// contains filtered or unexported fields
}
func (*CreateInstanceRequest) Descriptor
deprecated
func (*CreateInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.
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 ¶ added in v0.7.0
func (x *CreateInstanceRequest) GetParentTraceContext() *TraceContext
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 ¶ added in v0.12.0
func (x *CreateTimerAction) GetActivityRetry() *TimerOriginActivityRetry
func (*CreateTimerAction) GetChildWorkflowRetry ¶ added in v0.12.0
func (x *CreateTimerAction) GetChildWorkflowRetry() *TimerOriginChildWorkflowRetry
func (*CreateTimerAction) GetCreateTimer ¶ added in v0.12.0
func (x *CreateTimerAction) GetCreateTimer() *TimerOriginCreateTimer
func (*CreateTimerAction) GetExternalEvent ¶ added in v0.12.0
func (x *CreateTimerAction) GetExternalEvent() *TimerOriginExternalEvent
func (*CreateTimerAction) GetFireAt ¶
func (x *CreateTimerAction) GetFireAt() *timestamppb.Timestamp
func (*CreateTimerAction) GetName ¶ added in v0.7.0
func (x *CreateTimerAction) GetName() string
func (*CreateTimerAction) GetOrigin ¶ added in v0.12.0
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 ¶ added in v0.12.0
type CreateTimerAction_ActivityRetry struct {
ActivityRetry *TimerOriginActivityRetry `protobuf:"bytes,5,opt,name=activityRetry,proto3,oneof"`
}
type CreateTimerAction_ChildWorkflowRetry ¶ added in v0.12.0
type CreateTimerAction_ChildWorkflowRetry struct {
ChildWorkflowRetry *TimerOriginChildWorkflowRetry `protobuf:"bytes,6,opt,name=childWorkflowRetry,proto3,oneof"`
}
type CreateTimerAction_CreateTimer ¶ added in v0.12.0
type CreateTimerAction_CreateTimer struct {
CreateTimer *TimerOriginCreateTimer `protobuf:"bytes,3,opt,name=createTimer,proto3,oneof"`
}
type CreateTimerAction_ExternalEvent ¶ added in v0.12.0
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"`
// contains filtered or unexported fields
}
func (*CreateWorkflowInstanceRequest) Descriptor
deprecated
func (*CreateWorkflowInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateWorkflowInstanceRequest.ProtoReflect.Descriptor instead.
func (*CreateWorkflowInstanceRequest) GetPropagatedHistory ¶ added in v0.12.0
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 ¶ added in v0.12.0
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
added in
v0.12.0
func (*DetachedWorkflowInstanceCreatedEvent) Descriptor() ([]byte, []int)
Deprecated: Use DetachedWorkflowInstanceCreatedEvent.ProtoReflect.Descriptor instead.
func (*DetachedWorkflowInstanceCreatedEvent) GetInstanceId ¶ added in v0.12.0
func (x *DetachedWorkflowInstanceCreatedEvent) GetInstanceId() string
func (*DetachedWorkflowInstanceCreatedEvent) ProtoMessage ¶ added in v0.12.0
func (*DetachedWorkflowInstanceCreatedEvent) ProtoMessage()
func (*DetachedWorkflowInstanceCreatedEvent) ProtoReflect ¶ added in v0.12.0
func (x *DetachedWorkflowInstanceCreatedEvent) ProtoReflect() protoreflect.Message
func (*DetachedWorkflowInstanceCreatedEvent) Reset ¶ added in v0.12.0
func (x *DetachedWorkflowInstanceCreatedEvent) Reset()
func (*DetachedWorkflowInstanceCreatedEvent) String ¶ added in v0.12.0
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 ¶ added in v0.12.0
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 ¶ added in v0.11.0
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
added in
v0.11.0
func (*ExecutionStalledEvent) Descriptor() ([]byte, []int)
Deprecated: Use ExecutionStalledEvent.ProtoReflect.Descriptor instead.
func (*ExecutionStalledEvent) GetDescription ¶ added in v0.11.0
func (x *ExecutionStalledEvent) GetDescription() string
func (*ExecutionStalledEvent) GetReason ¶ added in v0.11.0
func (x *ExecutionStalledEvent) GetReason() StalledReason
func (*ExecutionStalledEvent) ProtoMessage ¶ added in v0.11.0
func (*ExecutionStalledEvent) ProtoMessage()
func (*ExecutionStalledEvent) ProtoReflect ¶ added in v0.11.0
func (x *ExecutionStalledEvent) ProtoReflect() protoreflect.Message
func (*ExecutionStalledEvent) Reset ¶ added in v0.11.0
func (x *ExecutionStalledEvent) Reset()
func (*ExecutionStalledEvent) String ¶ added in v0.11.0
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 ¶ added in v0.7.0
func (x *ExecutionStartedEvent) GetTags() map[string]string
func (*ExecutionStartedEvent) GetVersion ¶
func (x *ExecutionStartedEvent) GetVersion() *wrapperspb.StringValue
func (*ExecutionStartedEvent) GetWorkflowInstance ¶ added in v0.12.0
func (x *ExecutionStartedEvent) GetWorkflowInstance() *WorkflowInstance
func (*ExecutionStartedEvent) GetWorkflowSpanID ¶ added in v0.12.0
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 ExternalSigningCertificate ¶ added in v0.12.0
type ExternalSigningCertificate struct {
// sha256 of the DER-encoded X.509 certificate chain bytes (the value
// in `certificate` below). Also the primary lookup key used by
// attestations' signerCertDigest fields. Stored explicitly so
// load-time index construction and post-load integrity checks do not
// have to re-hash every entry.
Digest []byte `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
// Same byte format as SigningCertificate.certificate: DER-encoded
// X.509 chain, leaf first, intermediates concatenated.
Certificate []byte `protobuf:"bytes,2,opt,name=certificate,proto3" json:"certificate,omitempty"`
// contains filtered or unexported fields
}
A foreign signer's X.509 certificate; one belonging to another workflow instance or activity executor whose attestations this workflow has received. Stored once per unique digest and referenced by digest from any attestation embedded in history. Stored as individual actor state keys: ext-sigcert-000000, ext-sigcert-000001, etc.
Lifecycle mirrors SigningCertificate (monotonically appended within a run, cleared on ContinueAsNew and instance purge, tracked by BackendWorkflowStateMetadata.externalSigningCertificateLength). Dedup within a run is performed by in-memory digest→index lookup built at load time.
func (*ExternalSigningCertificate) Descriptor
deprecated
added in
v0.12.0
func (*ExternalSigningCertificate) Descriptor() ([]byte, []int)
Deprecated: Use ExternalSigningCertificate.ProtoReflect.Descriptor instead.
func (*ExternalSigningCertificate) GetCertificate ¶ added in v0.12.0
func (x *ExternalSigningCertificate) GetCertificate() []byte
func (*ExternalSigningCertificate) GetDigest ¶ added in v0.12.0
func (x *ExternalSigningCertificate) GetDigest() []byte
func (*ExternalSigningCertificate) ProtoMessage ¶ added in v0.12.0
func (*ExternalSigningCertificate) ProtoMessage()
func (*ExternalSigningCertificate) ProtoReflect ¶ added in v0.12.0
func (x *ExternalSigningCertificate) ProtoReflect() protoreflect.Message
func (*ExternalSigningCertificate) Reset ¶ added in v0.12.0
func (x *ExternalSigningCertificate) Reset()
func (*ExternalSigningCertificate) String ¶ added in v0.12.0
func (x *ExternalSigningCertificate) String() string
type GetInstanceHistoryRequest ¶ added in v0.11.0
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
added in
v0.11.0
func (*GetInstanceHistoryRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetInstanceHistoryRequest.ProtoReflect.Descriptor instead.
func (*GetInstanceHistoryRequest) GetInstanceId ¶ added in v0.11.0
func (x *GetInstanceHistoryRequest) GetInstanceId() string
func (*GetInstanceHistoryRequest) ProtoMessage ¶ added in v0.11.0
func (*GetInstanceHistoryRequest) ProtoMessage()
func (*GetInstanceHistoryRequest) ProtoReflect ¶ added in v0.11.0
func (x *GetInstanceHistoryRequest) ProtoReflect() protoreflect.Message
func (*GetInstanceHistoryRequest) Reset ¶ added in v0.11.0
func (x *GetInstanceHistoryRequest) Reset()
func (*GetInstanceHistoryRequest) String ¶ added in v0.11.0
func (x *GetInstanceHistoryRequest) String() string
type GetInstanceHistoryResponse ¶ added in v0.11.0
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
added in
v0.11.0
func (*GetInstanceHistoryResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetInstanceHistoryResponse.ProtoReflect.Descriptor instead.
func (*GetInstanceHistoryResponse) GetEvents ¶ added in v0.11.0
func (x *GetInstanceHistoryResponse) GetEvents() []*HistoryEvent
func (*GetInstanceHistoryResponse) ProtoMessage ¶ added in v0.11.0
func (*GetInstanceHistoryResponse) ProtoMessage()
func (*GetInstanceHistoryResponse) ProtoReflect ¶ added in v0.11.0
func (x *GetInstanceHistoryResponse) ProtoReflect() protoreflect.Message
func (*GetInstanceHistoryResponse) Reset ¶ added in v0.11.0
func (x *GetInstanceHistoryResponse) Reset()
func (*GetInstanceHistoryResponse) String ¶ added in v0.11.0
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"`
// 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) 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 ¶ added in v0.12.0
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 {
// contains filtered or unexported fields
}
func (*GetWorkItemsRequest) Descriptor
deprecated
func (*GetWorkItemsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkItemsRequest.ProtoReflect.Descriptor instead.
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 ¶ added in v0.12.0
func (x *HistoryEvent) GetChildWorkflowInstanceCompleted() *ChildWorkflowInstanceCompletedEvent
func (*HistoryEvent) GetChildWorkflowInstanceCreated ¶ added in v0.12.0
func (x *HistoryEvent) GetChildWorkflowInstanceCreated() *ChildWorkflowInstanceCreatedEvent
func (*HistoryEvent) GetChildWorkflowInstanceFailed ¶ added in v0.12.0
func (x *HistoryEvent) GetChildWorkflowInstanceFailed() *ChildWorkflowInstanceFailedEvent
func (*HistoryEvent) GetContinueAsNew ¶
func (x *HistoryEvent) GetContinueAsNew() *ContinueAsNewEvent
func (*HistoryEvent) GetDetachedWorkflowInstanceCreated ¶ added in v0.12.0
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 ¶ added in v0.11.0
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 ¶ added in v0.8.0
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 ¶ added in v0.12.0
func (x *HistoryEvent) GetWorkflowCompleted() *WorkflowCompletedEvent
func (*HistoryEvent) GetWorkflowStarted ¶ added in v0.12.0
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 ¶ added in v0.12.0
type HistoryEvent_ChildWorkflowInstanceCompleted struct {
ChildWorkflowInstanceCompleted *ChildWorkflowInstanceCompletedEvent `protobuf:"bytes,10,opt,name=childWorkflowInstanceCompleted,proto3,oneof"`
}
type HistoryEvent_ChildWorkflowInstanceCreated ¶ added in v0.12.0
type HistoryEvent_ChildWorkflowInstanceCreated struct {
ChildWorkflowInstanceCreated *ChildWorkflowInstanceCreatedEvent `protobuf:"bytes,9,opt,name=childWorkflowInstanceCreated,proto3,oneof"`
}
type HistoryEvent_ChildWorkflowInstanceFailed ¶ added in v0.12.0
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 ¶ added in v0.12.0
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 ¶ added in v0.11.0
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 ¶ added in v0.12.0
type HistoryEvent_WorkflowCompleted struct {
WorkflowCompleted *WorkflowCompletedEvent `protobuf:"bytes,15,opt,name=workflowCompleted,proto3,oneof"`
}
type HistoryEvent_WorkflowStarted ¶ added in v0.12.0
type HistoryEvent_WorkflowStarted struct {
WorkflowStarted *WorkflowStartedEvent `protobuf:"bytes,14,opt,name=workflowStarted,proto3,oneof"`
}
type HistoryPropagationScope ¶ added in v0.12.0
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 ¶ added in v0.12.0
func (HistoryPropagationScope) Descriptor() protoreflect.EnumDescriptor
func (HistoryPropagationScope) Enum ¶ added in v0.12.0
func (x HistoryPropagationScope) Enum() *HistoryPropagationScope
func (HistoryPropagationScope) EnumDescriptor
deprecated
added in
v0.12.0
func (HistoryPropagationScope) EnumDescriptor() ([]byte, []int)
Deprecated: Use HistoryPropagationScope.Descriptor instead.
func (HistoryPropagationScope) Number ¶ added in v0.12.0
func (x HistoryPropagationScope) Number() protoreflect.EnumNumber
func (HistoryPropagationScope) String ¶ added in v0.12.0
func (x HistoryPropagationScope) String() string
func (HistoryPropagationScope) Type ¶ added in v0.12.0
func (HistoryPropagationScope) Type() protoreflect.EnumType
type HistorySignature ¶ added in v0.12.0
type HistorySignature struct {
// Index of the first event covered by this signature (inclusive).
StartEventIndex uint64 `protobuf:"varint,1,opt,name=startEventIndex,proto3" json:"startEventIndex,omitempty"`
// Number of events covered by this signature.
EventCount uint64 `protobuf:"varint,2,opt,name=eventCount,proto3" json:"eventCount,omitempty"`
// SHA-256 digest of the previous HistorySignature message (the entire
// deterministically serialized protobuf message). Absent for the first
// signature in the chain (no predecessor). When computing the signature
// input for the root case, this value is treated as empty (zero-length).
PreviousSignatureDigest []byte `protobuf:"bytes,3,opt,name=previousSignatureDigest,proto3,oneof" json:"previousSignatureDigest,omitempty"`
// SHA-256 digest over the concatenation of the raw serialized bytes of each
// history event in this range, in order. The bytes are the exact values
// persisted to the state store (one per history-NNNNNN key).
EventsDigest []byte `protobuf:"bytes,4,opt,name=eventsDigest,proto3" json:"eventsDigest,omitempty"`
// Index into the SigningCertificate table (sigcert-NNNNNN keys).
// Multiple signatures from the same identity share the same index.
// A new entry is appended only when the certificate rotates.
CertificateIndex uint64 `protobuf:"varint,5,opt,name=certificateIndex,proto3" json:"certificateIndex,omitempty"`
// Cryptographic signature over
// SHA-256(previousSignatureDigest || eventsDigest)
// using the private key corresponding to the referenced certificate.
// The algorithm is determined by the certificate's key type:
//
// Ed25519: raw Ed25519 signature over the input bytes
// ECDSA: fixed-size r||s over SHA-256(input), each component
// zero-padded to the curve byte length
// RSA: PKCS#1 v1.5 with SHA-256
Signature []byte `protobuf:"bytes,6,opt,name=signature,proto3" json:"signature,omitempty"`
// contains filtered or unexported fields
}
Signing metadata for a contiguous range of history events. This is metadata-only — it does NOT contain the events themselves. Events are stored once in history-NNNNNN keys; this message references them by index range and stores only the signing artifacts. Stored as individual actor state keys: signature-000000, signature-000001, etc.
func (*HistorySignature) Descriptor
deprecated
added in
v0.12.0
func (*HistorySignature) Descriptor() ([]byte, []int)
Deprecated: Use HistorySignature.ProtoReflect.Descriptor instead.
func (*HistorySignature) GetCertificateIndex ¶ added in v0.12.0
func (x *HistorySignature) GetCertificateIndex() uint64
func (*HistorySignature) GetEventCount ¶ added in v0.12.0
func (x *HistorySignature) GetEventCount() uint64
func (*HistorySignature) GetEventsDigest ¶ added in v0.12.0
func (x *HistorySignature) GetEventsDigest() []byte
func (*HistorySignature) GetPreviousSignatureDigest ¶ added in v0.12.0
func (x *HistorySignature) GetPreviousSignatureDigest() []byte
func (*HistorySignature) GetSignature ¶ added in v0.12.0
func (x *HistorySignature) GetSignature() []byte
func (*HistorySignature) GetStartEventIndex ¶ added in v0.12.0
func (x *HistorySignature) GetStartEventIndex() uint64
func (*HistorySignature) ProtoMessage ¶ added in v0.12.0
func (*HistorySignature) ProtoMessage()
func (*HistorySignature) ProtoReflect ¶ added in v0.12.0
func (x *HistorySignature) ProtoReflect() protoreflect.Message
func (*HistorySignature) Reset ¶ added in v0.12.0
func (x *HistorySignature) Reset()
func (*HistorySignature) String ¶ added in v0.12.0
func (x *HistorySignature) String() string
type ListInstanceIDsRequest ¶ added in v0.11.0
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
added in
v0.11.0
func (*ListInstanceIDsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListInstanceIDsRequest.ProtoReflect.Descriptor instead.
func (*ListInstanceIDsRequest) GetContinuationToken ¶ added in v0.11.0
func (x *ListInstanceIDsRequest) GetContinuationToken() string
func (*ListInstanceIDsRequest) GetPageSize ¶ added in v0.11.0
func (x *ListInstanceIDsRequest) GetPageSize() uint32
func (*ListInstanceIDsRequest) ProtoMessage ¶ added in v0.11.0
func (*ListInstanceIDsRequest) ProtoMessage()
func (*ListInstanceIDsRequest) ProtoReflect ¶ added in v0.11.0
func (x *ListInstanceIDsRequest) ProtoReflect() protoreflect.Message
func (*ListInstanceIDsRequest) Reset ¶ added in v0.11.0
func (x *ListInstanceIDsRequest) Reset()
func (*ListInstanceIDsRequest) String ¶ added in v0.11.0
func (x *ListInstanceIDsRequest) String() string
type ListInstanceIDsResponse ¶ added in v0.11.0
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
added in
v0.11.0
func (*ListInstanceIDsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListInstanceIDsResponse.ProtoReflect.Descriptor instead.
func (*ListInstanceIDsResponse) GetContinuationToken ¶ added in v0.11.0
func (x *ListInstanceIDsResponse) GetContinuationToken() string
func (*ListInstanceIDsResponse) GetInstanceIds ¶ added in v0.11.0
func (x *ListInstanceIDsResponse) GetInstanceIds() []string
func (*ListInstanceIDsResponse) ProtoMessage ¶ added in v0.11.0
func (*ListInstanceIDsResponse) ProtoMessage()
func (*ListInstanceIDsResponse) ProtoReflect ¶ added in v0.11.0
func (x *ListInstanceIDsResponse) ProtoReflect() protoreflect.Message
func (*ListInstanceIDsResponse) Reset ¶ added in v0.11.0
func (x *ListInstanceIDsResponse) Reset()
func (*ListInstanceIDsResponse) String ¶ added in v0.11.0
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
added in
v0.11.0
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
added in
v0.11.0
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 ¶ added in v0.8.0
func (x *ParentInstanceInfo) GetAppID() string
func (*ParentInstanceInfo) GetAppNamespace ¶ added in v0.12.0
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 ¶ added in v0.12.0
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 ¶ added in v0.12.0
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
added in
v0.12.0
func (*PropagatedHistory) Descriptor() ([]byte, []int)
Deprecated: Use PropagatedHistory.ProtoReflect.Descriptor instead.
func (*PropagatedHistory) GetChunks ¶ added in v0.12.0
func (x *PropagatedHistory) GetChunks() []*PropagatedHistoryChunk
func (*PropagatedHistory) GetScope ¶ added in v0.12.0
func (x *PropagatedHistory) GetScope() HistoryPropagationScope
func (*PropagatedHistory) ProtoMessage ¶ added in v0.12.0
func (*PropagatedHistory) ProtoMessage()
func (*PropagatedHistory) ProtoReflect ¶ added in v0.12.0
func (x *PropagatedHistory) ProtoReflect() protoreflect.Message
func (*PropagatedHistory) Reset ¶ added in v0.12.0
func (x *PropagatedHistory) Reset()
func (*PropagatedHistory) String ¶ added in v0.12.0
func (x *PropagatedHistory) String() string
type PropagatedHistoryChunk ¶ added in v0.12.0
type PropagatedHistoryChunk struct {
// Raw deterministic bytes of each HistoryEvent in this chunk, in execution
// order. The producer marshals each event once and signs over these exact
// bytes; receivers digest them directly and never re-marshal, so chunk
// verification is independent of protobuf marshaler-version stability
// across producer and receiver. This mirrors the approach attestations use
// for ioDigest: signed bytes travel verbatim end-to-end. The chunk's
// length is len(rawEvents).
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"`
// Raw deterministic bytes of each HistorySignature message produced by the
// chunk's app at dispatch time, covering rawEvents in order. Receivers
// unmarshal these on demand to verify the chain. Raw bytes are required
// because HistorySignature.previousSignatureDigest commits to the exact
// persisted serialization; re-marshaling on the wire would break chain
// linkage. See backend_service.proto: HistorySignature.
RawSignatures [][]byte `protobuf:"bytes,5,rep,name=rawSignatures,proto3" json:"rawSignatures,omitempty"`
// X.509 certificate chains of the chunk app's signing identities,
// DER-concatenated leaf-first then intermediates (same encoding as
// backend_service.proto: SigningCertificate.certificate). Each
// HistorySignature in rawSignatures has a certificateIndex that indexes
// into this list, scoped to the chunk's producer app. Raw bytes here avoid
// a circular import on backend_service.proto's SigningCertificate type.
SigningCertChains [][]byte `protobuf:"bytes,6,rep,name=signingCertChains,proto3" json:"signingCertChains,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 the raw event bytes its producer signed; receivers digest those bytes directly and decode them into typed HistoryEvents on demand.
func (*PropagatedHistoryChunk) Descriptor
deprecated
added in
v0.12.0
func (*PropagatedHistoryChunk) Descriptor() ([]byte, []int)
Deprecated: Use PropagatedHistoryChunk.ProtoReflect.Descriptor instead.
func (*PropagatedHistoryChunk) GetAppId ¶ added in v0.12.0
func (x *PropagatedHistoryChunk) GetAppId() string
func (*PropagatedHistoryChunk) GetInstanceId ¶ added in v0.12.0
func (x *PropagatedHistoryChunk) GetInstanceId() string
func (*PropagatedHistoryChunk) GetRawEvents ¶ added in v0.12.0
func (x *PropagatedHistoryChunk) GetRawEvents() [][]byte
func (*PropagatedHistoryChunk) GetRawSignatures ¶ added in v0.12.0
func (x *PropagatedHistoryChunk) GetRawSignatures() [][]byte
func (*PropagatedHistoryChunk) GetSigningCertChains ¶ added in v0.12.0
func (x *PropagatedHistoryChunk) GetSigningCertChains() [][]byte
func (*PropagatedHistoryChunk) GetWorkflowName ¶ added in v0.12.0
func (x *PropagatedHistoryChunk) GetWorkflowName() string
func (*PropagatedHistoryChunk) ProtoMessage ¶ added in v0.12.0
func (*PropagatedHistoryChunk) ProtoMessage()
func (*PropagatedHistoryChunk) ProtoReflect ¶ added in v0.12.0
func (x *PropagatedHistoryChunk) ProtoReflect() protoreflect.Message
func (*PropagatedHistoryChunk) Reset ¶ added in v0.12.0
func (x *PropagatedHistoryChunk) Reset()
func (*PropagatedHistoryChunk) String ¶ added in v0.12.0
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"`
// contains filtered or unexported fields
}
func (*PurgeInstancesRequest) Descriptor
deprecated
func (*PurgeInstancesRequest) Descriptor() ([]byte, []int)
Deprecated: Use PurgeInstancesRequest.ProtoReflect.Descriptor instead.
func (*PurgeInstancesRequest) GetForce ¶ added in v0.11.0
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) 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 ¶ added in v0.7.0
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"`
// 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) 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 RerunParentInstanceInfo ¶ added in v0.11.0
type RerunParentInstanceInfo struct {
// instanceID is the workflow instance ID this workflow has been
// rerun from.
InstanceID string `protobuf:"bytes,1,opt,name=instanceID,proto3" json:"instanceID,omitempty"`
// contains filtered or unexported fields
}
RerunParentInstanceInfo is used to indicate that this workflow was started as part of a rerun operation. Contains information about the parent workflow instance which was rerun.
func (*RerunParentInstanceInfo) Descriptor
deprecated
added in
v0.11.0
func (*RerunParentInstanceInfo) Descriptor() ([]byte, []int)
Deprecated: Use RerunParentInstanceInfo.ProtoReflect.Descriptor instead.
func (*RerunParentInstanceInfo) GetInstanceID ¶ added in v0.11.0
func (x *RerunParentInstanceInfo) GetInstanceID() string
func (*RerunParentInstanceInfo) ProtoMessage ¶ added in v0.11.0
func (*RerunParentInstanceInfo) ProtoMessage()
func (*RerunParentInstanceInfo) ProtoReflect ¶ added in v0.11.0
func (x *RerunParentInstanceInfo) ProtoReflect() protoreflect.Message
func (*RerunParentInstanceInfo) Reset ¶ added in v0.11.0
func (x *RerunParentInstanceInfo) Reset()
func (*RerunParentInstanceInfo) String ¶ added in v0.11.0
func (x *RerunParentInstanceInfo) String() string
type RerunWorkflowFromEventRequest ¶ added in v0.7.0
type RerunWorkflowFromEventRequest struct {
// sourceInstanceID is the workflow instance ID to rerun. Can be a top
// level instance, or child workflow instance.
SourceInstanceID string `protobuf:"bytes,1,opt,name=sourceInstanceID,proto3" json:"sourceInstanceID,omitempty"`
// the event id to start the new workflow instance from.
EventID uint32 `protobuf:"varint,2,opt,name=eventID,proto3" json:"eventID,omitempty"`
// newInstanceID is the new instance ID to use for the new workflow instance.
// If not given, a random instance ID will be given.
NewInstanceID *string `protobuf:"bytes,3,opt,name=newInstanceID,proto3,oneof" json:"newInstanceID,omitempty"`
// input can optionally given to give the new instance a different input to
// the next Activity event.
Input *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
// overwrite_input signals that the input to the rerun activity should be
// written with input. This is required because of the incorrect typing of
// inputs being `StringValue` which cannot be optional, and therefore no nil
// value can be signalled or overwritten.
OverwriteInput bool `protobuf:"varint,5,opt,name=overwriteInput,proto3" json:"overwriteInput,omitempty"`
// newChildWorkflowInstanceID is an optional instance ID to use when
// rerunning from a child workflow. Only accepted if the event ID given is
// targeting a child workflow creation event.
NewChildWorkflowInstanceID *string `protobuf:"bytes,6,opt,name=newChildWorkflowInstanceID,proto3,oneof" json:"newChildWorkflowInstanceID,omitempty"`
// contains filtered or unexported fields
}
RerunWorkflowFromEventRequest is used to rerun a workflow instance from a specific event ID.
func (*RerunWorkflowFromEventRequest) Descriptor
deprecated
added in
v0.7.0
func (*RerunWorkflowFromEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use RerunWorkflowFromEventRequest.ProtoReflect.Descriptor instead.
func (*RerunWorkflowFromEventRequest) GetEventID ¶ added in v0.7.0
func (x *RerunWorkflowFromEventRequest) GetEventID() uint32
func (*RerunWorkflowFromEventRequest) GetInput ¶ added in v0.7.0
func (x *RerunWorkflowFromEventRequest) GetInput() *wrapperspb.StringValue
func (*RerunWorkflowFromEventRequest) GetNewChildWorkflowInstanceID ¶ added in v0.11.0
func (x *RerunWorkflowFromEventRequest) GetNewChildWorkflowInstanceID() string
func (*RerunWorkflowFromEventRequest) GetNewInstanceID ¶ added in v0.7.0
func (x *RerunWorkflowFromEventRequest) GetNewInstanceID() string
func (*RerunWorkflowFromEventRequest) GetOverwriteInput ¶ added in v0.7.0
func (x *RerunWorkflowFromEventRequest) GetOverwriteInput() bool
func (*RerunWorkflowFromEventRequest) GetSourceInstanceID ¶ added in v0.7.0
func (x *RerunWorkflowFromEventRequest) GetSourceInstanceID() string
func (*RerunWorkflowFromEventRequest) ProtoMessage ¶ added in v0.7.0
func (*RerunWorkflowFromEventRequest) ProtoMessage()
func (*RerunWorkflowFromEventRequest) ProtoReflect ¶ added in v0.7.0
func (x *RerunWorkflowFromEventRequest) ProtoReflect() protoreflect.Message
func (*RerunWorkflowFromEventRequest) Reset ¶ added in v0.7.0
func (x *RerunWorkflowFromEventRequest) Reset()
func (*RerunWorkflowFromEventRequest) String ¶ added in v0.7.0
func (x *RerunWorkflowFromEventRequest) String() string
type RerunWorkflowFromEventResponse ¶ added in v0.7.0
type RerunWorkflowFromEventResponse struct {
NewInstanceID string `protobuf:"bytes,1,opt,name=newInstanceID,proto3" json:"newInstanceID,omitempty"`
// contains filtered or unexported fields
}
RerunWorkflowFromEventResponse is the response to executing RerunWorkflowFromEvent.
func (*RerunWorkflowFromEventResponse) Descriptor
deprecated
added in
v0.7.0
func (*RerunWorkflowFromEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use RerunWorkflowFromEventResponse.ProtoReflect.Descriptor instead.
func (*RerunWorkflowFromEventResponse) GetNewInstanceID ¶ added in v0.7.0
func (x *RerunWorkflowFromEventResponse) GetNewInstanceID() string
func (*RerunWorkflowFromEventResponse) ProtoMessage ¶ added in v0.7.0
func (*RerunWorkflowFromEventResponse) ProtoMessage()
func (*RerunWorkflowFromEventResponse) ProtoReflect ¶ added in v0.7.0
func (x *RerunWorkflowFromEventResponse) ProtoReflect() protoreflect.Message
func (*RerunWorkflowFromEventResponse) Reset ¶ added in v0.7.0
func (x *RerunWorkflowFromEventResponse) Reset()
func (*RerunWorkflowFromEventResponse) String ¶ added in v0.7.0
func (x *RerunWorkflowFromEventResponse) 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"`
// 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) 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 RuntimeStateStalled ¶ added in v0.11.0
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
added in
v0.11.0
func (*RuntimeStateStalled) Descriptor() ([]byte, []int)
Deprecated: Use RuntimeStateStalled.ProtoReflect.Descriptor instead.
func (*RuntimeStateStalled) GetDescription ¶ added in v0.11.0
func (x *RuntimeStateStalled) GetDescription() string
func (*RuntimeStateStalled) GetReason ¶ added in v0.11.0
func (x *RuntimeStateStalled) GetReason() StalledReason
func (*RuntimeStateStalled) ProtoMessage ¶ added in v0.11.0
func (*RuntimeStateStalled) ProtoMessage()
func (*RuntimeStateStalled) ProtoReflect ¶ added in v0.11.0
func (x *RuntimeStateStalled) ProtoReflect() protoreflect.Message
func (*RuntimeStateStalled) Reset ¶ added in v0.11.0
func (x *RuntimeStateStalled) Reset()
func (*RuntimeStateStalled) String ¶ added in v0.11.0
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"`
Router *TaskRouter `protobuf:"bytes,4,opt,name=router,proto3,oneof" json:"router,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 ¶ added in v0.12.0
func (x *ScheduleTaskAction) GetHistoryPropagationScope() HistoryPropagationScope
func (*ScheduleTaskAction) GetInput ¶
func (x *ScheduleTaskAction) GetInput() *wrapperspb.StringValue
func (*ScheduleTaskAction) GetName ¶
func (x *ScheduleTaskAction) GetName() string
func (*ScheduleTaskAction) GetRouter ¶ added in v0.8.0
func (x *ScheduleTaskAction) GetRouter() *TaskRouter
func (*ScheduleTaskAction) GetTaskExecutionId ¶ added in v0.8.0
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 SigningCertificate ¶ added in v0.12.0
type SigningCertificate struct {
// X.509 certificate chain of the signing identity. Certificates are
// DER-encoded and concatenated directly in order: leaf first, followed by
// intermediates. Each certificate is a self-delimiting ASN.1 SEQUENCE,
// so the chain can be parsed by reading consecutive DER structures.
Certificate []byte `protobuf:"bytes,1,opt,name=certificate,proto3" json:"certificate,omitempty"`
// contains filtered or unexported fields
}
A signing identity's X.509 certificate, stored once and referenced by index from HistorySignature entries. This avoids duplicating the certificate across every signature from the same identity. Stored as individual actor state keys: sigcert-000000, sigcert-000001, etc.
func (*SigningCertificate) Descriptor
deprecated
added in
v0.12.0
func (*SigningCertificate) Descriptor() ([]byte, []int)
Deprecated: Use SigningCertificate.ProtoReflect.Descriptor instead.
func (*SigningCertificate) GetCertificate ¶ added in v0.12.0
func (x *SigningCertificate) GetCertificate() []byte
func (*SigningCertificate) ProtoMessage ¶ added in v0.12.0
func (*SigningCertificate) ProtoMessage()
func (*SigningCertificate) ProtoReflect ¶ added in v0.12.0
func (x *SigningCertificate) ProtoReflect() protoreflect.Message
func (*SigningCertificate) Reset ¶ added in v0.12.0
func (x *SigningCertificate) Reset()
func (*SigningCertificate) String ¶ added in v0.12.0
func (x *SigningCertificate) String() string
type StalledReason ¶ added in v0.11.0
type StalledReason int32
const ( StalledReason_PATCH_MISMATCH StalledReason = 0 StalledReason_VERSION_NOT_AVAILABLE StalledReason = 1 StalledReason_PAYLOAD_SIZE_EXCEEDED StalledReason = 2 )
func (StalledReason) Descriptor ¶ added in v0.11.0
func (StalledReason) Descriptor() protoreflect.EnumDescriptor
func (StalledReason) Enum ¶ added in v0.11.0
func (x StalledReason) Enum() *StalledReason
func (StalledReason) EnumDescriptor
deprecated
added in
v0.11.0
func (StalledReason) EnumDescriptor() ([]byte, []int)
Deprecated: Use StalledReason.Descriptor instead.
func (StalledReason) Number ¶ added in v0.11.0
func (x StalledReason) Number() protoreflect.EnumNumber
func (StalledReason) String ¶ added in v0.11.0
func (x StalledReason) String() string
func (StalledReason) Type ¶ added in v0.11.0
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"`
// 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) 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"`
// Attestation signed by the activity executor's SPIFFE identity.
// Present when the activity was executed under a signing-enabled
// configuration. Verified on inbox ingestion against the companion
// signerCertificate and preserved in stored history for future audit
// and forwarding via provenance bundles.
Attestation *ActivityCompletionAttestation `protobuf:"bytes,4,opt,name=attestation,proto3,oneof" json:"attestation,omitempty"`
// Companion: DER-encoded X.509 certificate chain of the executor's
// signing identity (leaf first, intermediates concatenated; same
// format as SigningCertificate.certificate in backend_service.proto).
// Wire-only; stripped by the receiver before the event is written to
// history-NNNNNN. The certificate lives once in ext-sigcert-NNNNNN,
// referenced by attestation payload's signerCertDigest.
SignerCertificate []byte `protobuf:"bytes,5,opt,name=signerCertificate,proto3,oneof" json:"signerCertificate,omitempty"`
// contains filtered or unexported fields
}
func (*TaskCompletedEvent) Descriptor
deprecated
func (*TaskCompletedEvent) Descriptor() ([]byte, []int)
Deprecated: Use TaskCompletedEvent.ProtoReflect.Descriptor instead.
func (*TaskCompletedEvent) GetAttestation ¶ added in v0.12.0
func (x *TaskCompletedEvent) GetAttestation() *ActivityCompletionAttestation
func (*TaskCompletedEvent) GetResult ¶
func (x *TaskCompletedEvent) GetResult() *wrapperspb.StringValue
func (*TaskCompletedEvent) GetSignerCertificate ¶ added in v0.12.0
func (x *TaskCompletedEvent) GetSignerCertificate() []byte
func (*TaskCompletedEvent) GetTaskExecutionId ¶ added in v0.8.0
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"`
// See TaskCompletedEvent.attestation.
Attestation *ActivityCompletionAttestation `protobuf:"bytes,4,opt,name=attestation,proto3,oneof" json:"attestation,omitempty"`
// Wire-only companion; see TaskCompletedEvent.signerCertificate.
SignerCertificate []byte `protobuf:"bytes,5,opt,name=signerCertificate,proto3,oneof" json:"signerCertificate,omitempty"`
// contains filtered or unexported fields
}
func (*TaskFailedEvent) Descriptor
deprecated
func (*TaskFailedEvent) Descriptor() ([]byte, []int)
Deprecated: Use TaskFailedEvent.ProtoReflect.Descriptor instead.
func (*TaskFailedEvent) GetAttestation ¶ added in v0.12.0
func (x *TaskFailedEvent) GetAttestation() *ActivityCompletionAttestation
func (*TaskFailedEvent) GetFailureDetails ¶
func (x *TaskFailedEvent) GetFailureDetails() *TaskFailureDetails
func (*TaskFailedEvent) GetSignerCertificate ¶ added in v0.12.0
func (x *TaskFailedEvent) GetSignerCertificate() []byte
func (*TaskFailedEvent) GetTaskExecutionId ¶ added in v0.8.0
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)
// Rerun a Workflow from a specific event ID of a workflow instance.
RerunWorkflowFromEvent(ctx context.Context, in *RerunWorkflowFromEventRequest, opts ...grpc.CallOption) (*RerunWorkflowFromEventResponse, 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)
// Rerun a Workflow from a specific event ID of a workflow instance.
RerunWorkflowFromEvent(context.Context, *RerunWorkflowFromEventRequest) (*RerunWorkflowFromEventResponse, 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 ¶ added in v0.8.0
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
added in
v0.8.0
func (*TaskRouter) Descriptor() ([]byte, []int)
Deprecated: Use TaskRouter.ProtoReflect.Descriptor instead.
func (*TaskRouter) GetSourceAppID ¶ added in v0.8.0
func (x *TaskRouter) GetSourceAppID() string
func (*TaskRouter) GetTargetAppID ¶ added in v0.8.0
func (x *TaskRouter) GetTargetAppID() string
func (*TaskRouter) GetTargetAppNamespace ¶ added in v0.12.0
func (x *TaskRouter) GetTargetAppNamespace() string
func (*TaskRouter) ProtoMessage ¶ added in v0.8.0
func (*TaskRouter) ProtoMessage()
func (*TaskRouter) ProtoReflect ¶ added in v0.8.0
func (x *TaskRouter) ProtoReflect() protoreflect.Message
func (*TaskRouter) Reset ¶ added in v0.8.0
func (x *TaskRouter) Reset()
func (*TaskRouter) String ¶ added in v0.8.0
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"`
// If defined, indicates that this task was the starting point of a new
// workflow execution as the result of a rerun operation.
RerunParentInstanceInfo *RerunParentInstanceInfo `protobuf:"bytes,6,opt,name=rerunParentInstanceInfo,proto3,oneof" json:"rerunParentInstanceInfo,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 ¶ added in v0.12.0
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) GetRerunParentInstanceInfo ¶ added in v0.11.0
func (x *TaskScheduledEvent) GetRerunParentInstanceInfo() *RerunParentInstanceInfo
func (*TaskScheduledEvent) GetTaskExecutionId ¶ added in v0.8.0
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 TerminalStatus ¶ added in v0.12.0
type TerminalStatus int32
Terminal state of a child workflow at the moment of attestation.
const ( TerminalStatus_TERMINAL_STATUS_UNSPECIFIED TerminalStatus = 0 TerminalStatus_TERMINAL_STATUS_COMPLETED TerminalStatus = 1 TerminalStatus_TERMINAL_STATUS_FAILED TerminalStatus = 2 )
func (TerminalStatus) Descriptor ¶ added in v0.12.0
func (TerminalStatus) Descriptor() protoreflect.EnumDescriptor
func (TerminalStatus) Enum ¶ added in v0.12.0
func (x TerminalStatus) Enum() *TerminalStatus
func (TerminalStatus) EnumDescriptor
deprecated
added in
v0.12.0
func (TerminalStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use TerminalStatus.Descriptor instead.
func (TerminalStatus) Number ¶ added in v0.12.0
func (x TerminalStatus) Number() protoreflect.EnumNumber
func (TerminalStatus) String ¶ added in v0.12.0
func (x TerminalStatus) String() string
func (TerminalStatus) Type ¶ added in v0.12.0
func (TerminalStatus) Type() protoreflect.EnumType
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"`
// 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) 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 ¶ added in v0.12.0
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
added in
v0.12.0
func (*TerminateWorkflowAction) Descriptor() ([]byte, []int)
Deprecated: Use TerminateWorkflowAction.ProtoReflect.Descriptor instead.
func (*TerminateWorkflowAction) GetInstanceId ¶ added in v0.12.0
func (x *TerminateWorkflowAction) GetInstanceId() string
func (*TerminateWorkflowAction) GetReason ¶ added in v0.12.0
func (x *TerminateWorkflowAction) GetReason() *wrapperspb.StringValue
func (*TerminateWorkflowAction) GetRecurse ¶ added in v0.12.0
func (x *TerminateWorkflowAction) GetRecurse() bool
func (*TerminateWorkflowAction) ProtoMessage ¶ added in v0.12.0
func (*TerminateWorkflowAction) ProtoMessage()
func (*TerminateWorkflowAction) ProtoReflect ¶ added in v0.12.0
func (x *TerminateWorkflowAction) ProtoReflect() protoreflect.Message
func (*TerminateWorkflowAction) Reset ¶ added in v0.12.0
func (x *TerminateWorkflowAction) Reset()
func (*TerminateWorkflowAction) String ¶ added in v0.12.0
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 defined, indicates that this task was the starting point of a new
// workflow execution as the result of a rerun operation.
RerunParentInstanceInfo *RerunParentInstanceInfo `protobuf:"bytes,3,opt,name=rerunParentInstanceInfo,proto3,oneof" json:"rerunParentInstanceInfo,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 ¶ added in v0.12.0
func (x *TimerCreatedEvent) GetActivityRetry() *TimerOriginActivityRetry
func (*TimerCreatedEvent) GetChildWorkflowRetry ¶ added in v0.12.0
func (x *TimerCreatedEvent) GetChildWorkflowRetry() *TimerOriginChildWorkflowRetry
func (*TimerCreatedEvent) GetCreateTimer ¶ added in v0.12.0
func (x *TimerCreatedEvent) GetCreateTimer() *TimerOriginCreateTimer
func (*TimerCreatedEvent) GetExternalEvent ¶ added in v0.12.0
func (x *TimerCreatedEvent) GetExternalEvent() *TimerOriginExternalEvent
func (*TimerCreatedEvent) GetFireAt ¶
func (x *TimerCreatedEvent) GetFireAt() *timestamppb.Timestamp
func (*TimerCreatedEvent) GetName ¶ added in v0.7.0
func (x *TimerCreatedEvent) GetName() string
func (*TimerCreatedEvent) GetOrigin ¶ added in v0.12.0
func (m *TimerCreatedEvent) GetOrigin() isTimerCreatedEvent_Origin
func (*TimerCreatedEvent) GetRerunParentInstanceInfo ¶ added in v0.11.0
func (x *TimerCreatedEvent) GetRerunParentInstanceInfo() *RerunParentInstanceInfo
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 ¶ added in v0.12.0
type TimerCreatedEvent_ActivityRetry struct {
ActivityRetry *TimerOriginActivityRetry `protobuf:"bytes,6,opt,name=activityRetry,proto3,oneof"`
}
type TimerCreatedEvent_ChildWorkflowRetry ¶ added in v0.12.0
type TimerCreatedEvent_ChildWorkflowRetry struct {
ChildWorkflowRetry *TimerOriginChildWorkflowRetry `protobuf:"bytes,7,opt,name=childWorkflowRetry,proto3,oneof"`
}
type TimerCreatedEvent_CreateTimer ¶ added in v0.12.0
type TimerCreatedEvent_CreateTimer struct {
CreateTimer *TimerOriginCreateTimer `protobuf:"bytes,4,opt,name=createTimer,proto3,oneof"`
}
type TimerCreatedEvent_ExternalEvent ¶ added in v0.12.0
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 ¶ added in v0.12.0
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
added in
v0.12.0
func (*TimerOriginActivityRetry) Descriptor() ([]byte, []int)
Deprecated: Use TimerOriginActivityRetry.ProtoReflect.Descriptor instead.
func (*TimerOriginActivityRetry) GetTaskExecutionId ¶ added in v0.12.0
func (x *TimerOriginActivityRetry) GetTaskExecutionId() string
func (*TimerOriginActivityRetry) ProtoMessage ¶ added in v0.12.0
func (*TimerOriginActivityRetry) ProtoMessage()
func (*TimerOriginActivityRetry) ProtoReflect ¶ added in v0.12.0
func (x *TimerOriginActivityRetry) ProtoReflect() protoreflect.Message
func (*TimerOriginActivityRetry) Reset ¶ added in v0.12.0
func (x *TimerOriginActivityRetry) Reset()
func (*TimerOriginActivityRetry) String ¶ added in v0.12.0
func (x *TimerOriginActivityRetry) String() string
type TimerOriginChildWorkflowRetry ¶ added in v0.12.0
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
added in
v0.12.0
func (*TimerOriginChildWorkflowRetry) Descriptor() ([]byte, []int)
Deprecated: Use TimerOriginChildWorkflowRetry.ProtoReflect.Descriptor instead.
func (*TimerOriginChildWorkflowRetry) GetInstanceId ¶ added in v0.12.0
func (x *TimerOriginChildWorkflowRetry) GetInstanceId() string
func (*TimerOriginChildWorkflowRetry) ProtoMessage ¶ added in v0.12.0
func (*TimerOriginChildWorkflowRetry) ProtoMessage()
func (*TimerOriginChildWorkflowRetry) ProtoReflect ¶ added in v0.12.0
func (x *TimerOriginChildWorkflowRetry) ProtoReflect() protoreflect.Message
func (*TimerOriginChildWorkflowRetry) Reset ¶ added in v0.12.0
func (x *TimerOriginChildWorkflowRetry) Reset()
func (*TimerOriginChildWorkflowRetry) String ¶ added in v0.12.0
func (x *TimerOriginChildWorkflowRetry) String() string
type TimerOriginCreateTimer ¶ added in v0.12.0
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
added in
v0.12.0
func (*TimerOriginCreateTimer) Descriptor() ([]byte, []int)
Deprecated: Use TimerOriginCreateTimer.ProtoReflect.Descriptor instead.
func (*TimerOriginCreateTimer) ProtoMessage ¶ added in v0.12.0
func (*TimerOriginCreateTimer) ProtoMessage()
func (*TimerOriginCreateTimer) ProtoReflect ¶ added in v0.12.0
func (x *TimerOriginCreateTimer) ProtoReflect() protoreflect.Message
func (*TimerOriginCreateTimer) Reset ¶ added in v0.12.0
func (x *TimerOriginCreateTimer) Reset()
func (*TimerOriginCreateTimer) String ¶ added in v0.12.0
func (x *TimerOriginCreateTimer) String() string
type TimerOriginExternalEvent ¶ added in v0.12.0
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
added in
v0.12.0
func (*TimerOriginExternalEvent) Descriptor() ([]byte, []int)
Deprecated: Use TimerOriginExternalEvent.ProtoReflect.Descriptor instead.
func (*TimerOriginExternalEvent) GetName ¶ added in v0.12.0
func (x *TimerOriginExternalEvent) GetName() string
func (*TimerOriginExternalEvent) ProtoMessage ¶ added in v0.12.0
func (*TimerOriginExternalEvent) ProtoMessage()
func (*TimerOriginExternalEvent) ProtoReflect ¶ added in v0.12.0
func (x *TimerOriginExternalEvent) ProtoReflect() protoreflect.Message
func (*TimerOriginExternalEvent) Reset ¶ added in v0.12.0
func (x *TimerOriginExternalEvent) Reset()
func (*TimerOriginExternalEvent) String ¶ added in v0.12.0
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 ¶ added in v0.12.0
func (UnimplementedTaskHubSidecarServiceServer) CompleteWorkflowTask(context.Context, *WorkflowResponse) (*CompleteTaskResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) GetInstance ¶
func (UnimplementedTaskHubSidecarServiceServer) GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) GetInstanceHistory ¶ added in v0.11.0
func (UnimplementedTaskHubSidecarServiceServer) GetInstanceHistory(context.Context, *GetInstanceHistoryRequest) (*GetInstanceHistoryResponse, error)
func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems ¶
func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems(*GetWorkItemsRequest, TaskHubSidecarService_GetWorkItemsServer) error
func (UnimplementedTaskHubSidecarServiceServer) ListInstanceIDs ¶ added in v0.11.0
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) RerunWorkflowFromEvent ¶ added in v0.7.0
func (UnimplementedTaskHubSidecarServiceServer) RerunWorkflowFromEvent(context.Context, *RerunWorkflowFromEventRequest) (*RerunWorkflowFromEventResponse, 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 ¶ added in v0.12.0
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 ¶ added in v0.12.0
type WorkItem_WorkflowRequest struct {
WorkflowRequest *WorkflowRequest `protobuf:"bytes,1,opt,name=workflowRequest,proto3,oneof"`
}
type WorkerCapability ¶ added in v0.7.0
type WorkerCapability int32
const ( WorkerCapability_WORKER_CAPABILITY_UNSPECIFIED WorkerCapability = 0 // Indicates that the worker is capable of streaming instance history as a more optimized // alternative to receiving the full history embedded in the workflow work-item. // When set, the service may return work items without any history events as an optimization. // It is strongly recommended that all SDKs support this capability. WorkerCapability_WORKER_CAPABILITY_HISTORY_STREAMING WorkerCapability = 1 )
func (WorkerCapability) Descriptor ¶ added in v0.7.0
func (WorkerCapability) Descriptor() protoreflect.EnumDescriptor
func (WorkerCapability) Enum ¶ added in v0.7.0
func (x WorkerCapability) Enum() *WorkerCapability
func (WorkerCapability) EnumDescriptor
deprecated
added in
v0.7.0
func (WorkerCapability) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkerCapability.Descriptor instead.
func (WorkerCapability) Number ¶ added in v0.7.0
func (x WorkerCapability) Number() protoreflect.EnumNumber
func (WorkerCapability) String ¶ added in v0.7.0
func (x WorkerCapability) String() string
func (WorkerCapability) Type ¶ added in v0.7.0
func (WorkerCapability) Type() protoreflect.EnumType
type WorkflowAction ¶ added in v0.12.0
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
added in
v0.12.0
func (*WorkflowAction) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowAction.ProtoReflect.Descriptor instead.
func (*WorkflowAction) GetCompleteOrchestration
deprecated
added in
v0.12.0
func (x *WorkflowAction) GetCompleteOrchestration() *CompleteWorkflowAction
Deprecated: Use GetCompleteWorkflow instead.
func (*WorkflowAction) GetCompleteWorkflow ¶ added in v0.12.0
func (x *WorkflowAction) GetCompleteWorkflow() *CompleteWorkflowAction
func (*WorkflowAction) GetCreateChildWorkflow ¶ added in v0.12.0
func (x *WorkflowAction) GetCreateChildWorkflow() *CreateChildWorkflowAction
func (*WorkflowAction) GetCreateDetachedWorkflow ¶ added in v0.12.0
func (x *WorkflowAction) GetCreateDetachedWorkflow() *CreateDetachedWorkflowAction
func (*WorkflowAction) GetCreateSubOrchestration
deprecated
added in
v0.12.0
func (x *WorkflowAction) GetCreateSubOrchestration() *CreateChildWorkflowAction
Deprecated: Use GetCreateChildWorkflow instead.
func (*WorkflowAction) GetCreateTimer ¶ added in v0.12.0
func (x *WorkflowAction) GetCreateTimer() *CreateTimerAction
func (*WorkflowAction) GetId ¶ added in v0.12.0
func (x *WorkflowAction) GetId() int32
func (*WorkflowAction) GetOrchestratorVersionNotAvailable
deprecated
added in
v0.12.0
func (x *WorkflowAction) GetOrchestratorVersionNotAvailable() *WorkflowVersionNotAvailableAction
Deprecated: Use GetWorkflowVersionNotAvailable instead.
func (*WorkflowAction) GetRouter ¶ added in v0.12.0
func (x *WorkflowAction) GetRouter() *TaskRouter
func (*WorkflowAction) GetScheduleTask ¶ added in v0.12.0
func (x *WorkflowAction) GetScheduleTask() *ScheduleTaskAction
func (*WorkflowAction) GetSendEvent ¶ added in v0.12.0
func (x *WorkflowAction) GetSendEvent() *SendEventAction
func (*WorkflowAction) GetTerminateOrchestration
deprecated
added in
v0.12.0
func (x *WorkflowAction) GetTerminateOrchestration() *TerminateWorkflowAction
Deprecated: Use GetTerminateWorkflow instead.
func (*WorkflowAction) GetTerminateWorkflow ¶ added in v0.12.0
func (x *WorkflowAction) GetTerminateWorkflow() *TerminateWorkflowAction
func (*WorkflowAction) GetWorkflowActionType ¶ added in v0.12.0
func (m *WorkflowAction) GetWorkflowActionType() isWorkflowAction_WorkflowActionType
func (*WorkflowAction) GetWorkflowVersionNotAvailable ¶ added in v0.12.0
func (x *WorkflowAction) GetWorkflowVersionNotAvailable() *WorkflowVersionNotAvailableAction
func (*WorkflowAction) ProtoMessage ¶ added in v0.12.0
func (*WorkflowAction) ProtoMessage()
func (*WorkflowAction) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowAction) ProtoReflect() protoreflect.Message
func (*WorkflowAction) Reset ¶ added in v0.12.0
func (x *WorkflowAction) Reset()
func (*WorkflowAction) String ¶ added in v0.12.0
func (x *WorkflowAction) String() string
type WorkflowAction_CompleteWorkflow ¶ added in v0.12.0
type WorkflowAction_CompleteWorkflow struct {
CompleteWorkflow *CompleteWorkflowAction `protobuf:"bytes,6,opt,name=completeWorkflow,proto3,oneof"`
}
type WorkflowAction_CreateChildWorkflow ¶ added in v0.12.0
type WorkflowAction_CreateChildWorkflow struct {
CreateChildWorkflow *CreateChildWorkflowAction `protobuf:"bytes,3,opt,name=createChildWorkflow,proto3,oneof"`
}
type WorkflowAction_CreateDetachedWorkflow ¶ added in v0.12.0
type WorkflowAction_CreateDetachedWorkflow struct {
CreateDetachedWorkflow *CreateDetachedWorkflowAction `protobuf:"bytes,11,opt,name=createDetachedWorkflow,proto3,oneof"`
}
type WorkflowAction_CreateTimer ¶ added in v0.12.0
type WorkflowAction_CreateTimer struct {
CreateTimer *CreateTimerAction `protobuf:"bytes,4,opt,name=createTimer,proto3,oneof"`
}
type WorkflowAction_ScheduleTask ¶ added in v0.12.0
type WorkflowAction_ScheduleTask struct {
ScheduleTask *ScheduleTaskAction `protobuf:"bytes,2,opt,name=scheduleTask,proto3,oneof"`
}
type WorkflowAction_SendEvent ¶ added in v0.12.0
type WorkflowAction_SendEvent struct {
SendEvent *SendEventAction `protobuf:"bytes,5,opt,name=sendEvent,proto3,oneof"`
}
type WorkflowAction_TerminateWorkflow ¶ added in v0.12.0
type WorkflowAction_TerminateWorkflow struct {
TerminateWorkflow *TerminateWorkflowAction `protobuf:"bytes,7,opt,name=terminateWorkflow,proto3,oneof"`
}
type WorkflowAction_WorkflowVersionNotAvailable ¶ added in v0.12.0
type WorkflowAction_WorkflowVersionNotAvailable struct {
WorkflowVersionNotAvailable *WorkflowVersionNotAvailableAction `protobuf:"bytes,10,opt,name=workflowVersionNotAvailable,proto3,oneof"`
}
type WorkflowCompletedEvent ¶ added in v0.12.0
type WorkflowCompletedEvent struct {
// contains filtered or unexported fields
}
func (*WorkflowCompletedEvent) Descriptor
deprecated
added in
v0.12.0
func (*WorkflowCompletedEvent) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowCompletedEvent.ProtoReflect.Descriptor instead.
func (*WorkflowCompletedEvent) ProtoMessage ¶ added in v0.12.0
func (*WorkflowCompletedEvent) ProtoMessage()
func (*WorkflowCompletedEvent) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowCompletedEvent) ProtoReflect() protoreflect.Message
func (*WorkflowCompletedEvent) Reset ¶ added in v0.12.0
func (x *WorkflowCompletedEvent) Reset()
func (*WorkflowCompletedEvent) String ¶ added in v0.12.0
func (x *WorkflowCompletedEvent) String() string
type WorkflowInstance ¶ added in v0.12.0
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
added in
v0.12.0
func (*WorkflowInstance) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowInstance.ProtoReflect.Descriptor instead.
func (*WorkflowInstance) GetExecutionId ¶ added in v0.12.0
func (x *WorkflowInstance) GetExecutionId() *wrapperspb.StringValue
func (*WorkflowInstance) GetInstanceId ¶ added in v0.12.0
func (x *WorkflowInstance) GetInstanceId() string
func (*WorkflowInstance) ProtoMessage ¶ added in v0.12.0
func (*WorkflowInstance) ProtoMessage()
func (*WorkflowInstance) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowInstance) ProtoReflect() protoreflect.Message
func (*WorkflowInstance) Reset ¶ added in v0.12.0
func (x *WorkflowInstance) Reset()
func (*WorkflowInstance) String ¶ added in v0.12.0
func (x *WorkflowInstance) String() string
type WorkflowMessage ¶ added in v0.12.0
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
added in
v0.12.0
func (*WorkflowMessage) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowMessage.ProtoReflect.Descriptor instead.
func (*WorkflowMessage) GetEvent ¶ added in v0.12.0
func (x *WorkflowMessage) GetEvent() *HistoryEvent
func (*WorkflowMessage) GetInstance ¶ added in v0.12.0
func (x *WorkflowMessage) GetInstance() *WorkflowInstance
func (*WorkflowMessage) ProtoMessage ¶ added in v0.12.0
func (*WorkflowMessage) ProtoMessage()
func (*WorkflowMessage) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowMessage) ProtoReflect() protoreflect.Message
func (*WorkflowMessage) Reset ¶ added in v0.12.0
func (x *WorkflowMessage) Reset()
func (*WorkflowMessage) String ¶ added in v0.12.0
func (x *WorkflowMessage) String() string
type WorkflowMetadata ¶ added in v0.12.0
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
added in
v0.12.0
func (*WorkflowMetadata) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowMetadata.ProtoReflect.Descriptor instead.
func (*WorkflowMetadata) GetCompletedAt ¶ added in v0.12.0
func (x *WorkflowMetadata) GetCompletedAt() *timestamppb.Timestamp
func (*WorkflowMetadata) GetCreatedAt ¶ added in v0.12.0
func (x *WorkflowMetadata) GetCreatedAt() *timestamppb.Timestamp
func (*WorkflowMetadata) GetCustomStatus ¶ added in v0.12.0
func (x *WorkflowMetadata) GetCustomStatus() *wrapperspb.StringValue
func (*WorkflowMetadata) GetFailureDetails ¶ added in v0.12.0
func (x *WorkflowMetadata) GetFailureDetails() *TaskFailureDetails
func (*WorkflowMetadata) GetInput ¶ added in v0.12.0
func (x *WorkflowMetadata) GetInput() *wrapperspb.StringValue
func (*WorkflowMetadata) GetInstanceId ¶ added in v0.12.0
func (x *WorkflowMetadata) GetInstanceId() string
func (*WorkflowMetadata) GetLastUpdatedAt ¶ added in v0.12.0
func (x *WorkflowMetadata) GetLastUpdatedAt() *timestamppb.Timestamp
func (*WorkflowMetadata) GetName ¶ added in v0.12.0
func (x *WorkflowMetadata) GetName() string
func (*WorkflowMetadata) GetOutput ¶ added in v0.12.0
func (x *WorkflowMetadata) GetOutput() *wrapperspb.StringValue
func (*WorkflowMetadata) GetParentAppId ¶ added in v0.12.0
func (x *WorkflowMetadata) GetParentAppId() *wrapperspb.StringValue
func (*WorkflowMetadata) GetParentInstanceId ¶ added in v0.12.0
func (x *WorkflowMetadata) GetParentInstanceId() string
func (*WorkflowMetadata) GetRuntimeStatus ¶ added in v0.12.0
func (x *WorkflowMetadata) GetRuntimeStatus() OrchestrationStatus
func (*WorkflowMetadata) GetStartedAt ¶ added in v0.12.0
func (x *WorkflowMetadata) GetStartedAt() *timestamppb.Timestamp
func (*WorkflowMetadata) GetVersion ¶ added in v0.12.0
func (x *WorkflowMetadata) GetVersion() *wrapperspb.StringValue
func (*WorkflowMetadata) ProtoMessage ¶ added in v0.12.0
func (*WorkflowMetadata) ProtoMessage()
func (*WorkflowMetadata) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowMetadata) ProtoReflect() protoreflect.Message
func (*WorkflowMetadata) Reset ¶ added in v0.12.0
func (x *WorkflowMetadata) Reset()
func (*WorkflowMetadata) String ¶ added in v0.12.0
func (x *WorkflowMetadata) String() string
type WorkflowRequest ¶ added in v0.12.0
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"`
// contains filtered or unexported fields
}
func (*WorkflowRequest) Descriptor
deprecated
added in
v0.12.0
func (*WorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowRequest.ProtoReflect.Descriptor instead.
func (*WorkflowRequest) GetExecutionId ¶ added in v0.12.0
func (x *WorkflowRequest) GetExecutionId() *wrapperspb.StringValue
func (*WorkflowRequest) GetInstanceId ¶ added in v0.12.0
func (x *WorkflowRequest) GetInstanceId() string
func (*WorkflowRequest) GetNewEvents ¶ added in v0.12.0
func (x *WorkflowRequest) GetNewEvents() []*HistoryEvent
func (*WorkflowRequest) GetPastEvents ¶ added in v0.12.0
func (x *WorkflowRequest) GetPastEvents() []*HistoryEvent
func (*WorkflowRequest) GetPropagatedHistory ¶ added in v0.12.0
func (x *WorkflowRequest) GetPropagatedHistory() *PropagatedHistory
func (*WorkflowRequest) GetRequiresHistoryStreaming ¶ added in v0.12.0
func (x *WorkflowRequest) GetRequiresHistoryStreaming() bool
func (*WorkflowRequest) GetRouter ¶ added in v0.12.0
func (x *WorkflowRequest) GetRouter() *TaskRouter
func (*WorkflowRequest) ProtoMessage ¶ added in v0.12.0
func (*WorkflowRequest) ProtoMessage()
func (*WorkflowRequest) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowRequest) ProtoReflect() protoreflect.Message
func (*WorkflowRequest) Reset ¶ added in v0.12.0
func (x *WorkflowRequest) Reset()
func (*WorkflowRequest) String ¶ added in v0.12.0
func (x *WorkflowRequest) String() string
type WorkflowResponse ¶ added in v0.12.0
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
added in
v0.12.0
func (*WorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowResponse.ProtoReflect.Descriptor instead.
func (*WorkflowResponse) GetActions ¶ added in v0.12.0
func (x *WorkflowResponse) GetActions() []*WorkflowAction
func (*WorkflowResponse) GetCompletionToken ¶ added in v0.12.0
func (x *WorkflowResponse) GetCompletionToken() string
func (*WorkflowResponse) GetCustomStatus ¶ added in v0.12.0
func (x *WorkflowResponse) GetCustomStatus() *wrapperspb.StringValue
func (*WorkflowResponse) GetInstanceId ¶ added in v0.12.0
func (x *WorkflowResponse) GetInstanceId() string
func (*WorkflowResponse) GetNumEventsProcessed ¶ added in v0.12.0
func (x *WorkflowResponse) GetNumEventsProcessed() *wrapperspb.Int32Value
func (*WorkflowResponse) GetVersion ¶ added in v0.12.0
func (x *WorkflowResponse) GetVersion() *WorkflowVersion
func (*WorkflowResponse) ProtoMessage ¶ added in v0.12.0
func (*WorkflowResponse) ProtoMessage()
func (*WorkflowResponse) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowResponse) ProtoReflect() protoreflect.Message
func (*WorkflowResponse) Reset ¶ added in v0.12.0
func (x *WorkflowResponse) Reset()
func (*WorkflowResponse) String ¶ added in v0.12.0
func (x *WorkflowResponse) String() string
type WorkflowRuntimeState ¶ added in v0.12.0
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
added in
v0.12.0
func (*WorkflowRuntimeState) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowRuntimeState.ProtoReflect.Descriptor instead.
func (*WorkflowRuntimeState) GetCompletedEvent ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetCompletedEvent() *ExecutionCompletedEvent
func (*WorkflowRuntimeState) GetCompletedTime ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetCompletedTime() *timestamppb.Timestamp
func (*WorkflowRuntimeState) GetContinuedAsNew ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetContinuedAsNew() bool
func (*WorkflowRuntimeState) GetCreatedTime ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetCreatedTime() *timestamppb.Timestamp
func (*WorkflowRuntimeState) GetCustomStatus ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetCustomStatus() *wrapperspb.StringValue
func (*WorkflowRuntimeState) GetInstanceId ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetInstanceId() string
func (*WorkflowRuntimeState) GetIsSuspended ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetIsSuspended() bool
func (*WorkflowRuntimeState) GetLastUpdatedTime ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetLastUpdatedTime() *timestamppb.Timestamp
func (*WorkflowRuntimeState) GetNewEvents ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetNewEvents() []*HistoryEvent
func (*WorkflowRuntimeState) GetOldEvents ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetOldEvents() []*HistoryEvent
func (*WorkflowRuntimeState) GetPendingMessages ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetPendingMessages() []*WorkflowRuntimeStateMessage
func (*WorkflowRuntimeState) GetPendingTasks ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetPendingTasks() []*HistoryEvent
func (*WorkflowRuntimeState) GetPendingTimers ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetPendingTimers() []*HistoryEvent
func (*WorkflowRuntimeState) GetStalled ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetStalled() *RuntimeStateStalled
func (*WorkflowRuntimeState) GetStartEvent ¶ added in v0.12.0
func (x *WorkflowRuntimeState) GetStartEvent() *ExecutionStartedEvent
func (*WorkflowRuntimeState) ProtoMessage ¶ added in v0.12.0
func (*WorkflowRuntimeState) ProtoMessage()
func (*WorkflowRuntimeState) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowRuntimeState) ProtoReflect() protoreflect.Message
func (*WorkflowRuntimeState) Reset ¶ added in v0.12.0
func (x *WorkflowRuntimeState) Reset()
func (*WorkflowRuntimeState) String ¶ added in v0.12.0
func (x *WorkflowRuntimeState) String() string
type WorkflowRuntimeStateMessage ¶ added in v0.12.0
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
added in
v0.12.0
func (*WorkflowRuntimeStateMessage) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowRuntimeStateMessage.ProtoReflect.Descriptor instead.
func (*WorkflowRuntimeStateMessage) GetHistoryEvent ¶ added in v0.12.0
func (x *WorkflowRuntimeStateMessage) GetHistoryEvent() *HistoryEvent
func (*WorkflowRuntimeStateMessage) GetPropagatedHistory ¶ added in v0.12.0
func (x *WorkflowRuntimeStateMessage) GetPropagatedHistory() *PropagatedHistory
func (*WorkflowRuntimeStateMessage) GetTargetInstanceId ¶ added in v0.12.0
func (x *WorkflowRuntimeStateMessage) GetTargetInstanceId() string
func (*WorkflowRuntimeStateMessage) ProtoMessage ¶ added in v0.12.0
func (*WorkflowRuntimeStateMessage) ProtoMessage()
func (*WorkflowRuntimeStateMessage) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowRuntimeStateMessage) ProtoReflect() protoreflect.Message
func (*WorkflowRuntimeStateMessage) Reset ¶ added in v0.12.0
func (x *WorkflowRuntimeStateMessage) Reset()
func (*WorkflowRuntimeStateMessage) String ¶ added in v0.12.0
func (x *WorkflowRuntimeStateMessage) String() string
type WorkflowStartedEvent ¶ added in v0.12.0
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
added in
v0.12.0
func (*WorkflowStartedEvent) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowStartedEvent.ProtoReflect.Descriptor instead.
func (*WorkflowStartedEvent) GetVersion ¶ added in v0.12.0
func (x *WorkflowStartedEvent) GetVersion() *WorkflowVersion
func (*WorkflowStartedEvent) ProtoMessage ¶ added in v0.12.0
func (*WorkflowStartedEvent) ProtoMessage()
func (*WorkflowStartedEvent) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowStartedEvent) ProtoReflect() protoreflect.Message
func (*WorkflowStartedEvent) Reset ¶ added in v0.12.0
func (x *WorkflowStartedEvent) Reset()
func (*WorkflowStartedEvent) String ¶ added in v0.12.0
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 ¶ added in v0.12.0
func (x *WorkflowState) GetCompletedTimestamp() *timestamppb.Timestamp
func (*WorkflowState) GetCreatedTimestamp ¶ added in v0.12.0
func (x *WorkflowState) GetCreatedTimestamp() *timestamppb.Timestamp
func (*WorkflowState) GetCustomStatus ¶
func (x *WorkflowState) GetCustomStatus() *wrapperspb.StringValue
func (*WorkflowState) GetExecutionId ¶ added in v0.12.0
func (x *WorkflowState) GetExecutionId() *wrapperspb.StringValue
func (*WorkflowState) GetFailureDetails ¶ added in v0.12.0
func (x *WorkflowState) GetFailureDetails() *TaskFailureDetails
func (*WorkflowState) GetInput ¶ added in v0.12.0
func (x *WorkflowState) GetInput() *wrapperspb.StringValue
func (*WorkflowState) GetInstanceId ¶ added in v0.12.0
func (x *WorkflowState) GetInstanceId() string
func (*WorkflowState) GetLastUpdatedTimestamp ¶ added in v0.12.0
func (x *WorkflowState) GetLastUpdatedTimestamp() *timestamppb.Timestamp
func (*WorkflowState) GetName ¶ added in v0.12.0
func (x *WorkflowState) GetName() string
func (*WorkflowState) GetOutput ¶ added in v0.12.0
func (x *WorkflowState) GetOutput() *wrapperspb.StringValue
func (*WorkflowState) GetParentAppId ¶ added in v0.12.0
func (x *WorkflowState) GetParentAppId() *wrapperspb.StringValue
func (*WorkflowState) GetParentInstanceId ¶ added in v0.12.0
func (x *WorkflowState) GetParentInstanceId() *wrapperspb.StringValue
func (*WorkflowState) GetScheduledStartTimestamp ¶ added in v0.12.0
func (x *WorkflowState) GetScheduledStartTimestamp() *timestamppb.Timestamp
func (*WorkflowState) GetStartedAt ¶ added in v0.12.0
func (x *WorkflowState) GetStartedAt() *timestamppb.Timestamp
func (*WorkflowState) GetTags ¶ added in v0.12.0
func (x *WorkflowState) GetTags() map[string]string
func (*WorkflowState) GetVersion ¶ added in v0.12.0
func (x *WorkflowState) GetVersion() *wrapperspb.StringValue
func (*WorkflowState) GetWorkflowStatus ¶ added in v0.12.0
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 ¶ added in v0.12.0
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
added in
v0.12.0
func (*WorkflowVersion) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowVersion.ProtoReflect.Descriptor instead.
func (*WorkflowVersion) GetName ¶ added in v0.12.0
func (x *WorkflowVersion) GetName() string
func (*WorkflowVersion) GetPatches ¶ added in v0.12.0
func (x *WorkflowVersion) GetPatches() []string
func (*WorkflowVersion) ProtoMessage ¶ added in v0.12.0
func (*WorkflowVersion) ProtoMessage()
func (*WorkflowVersion) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowVersion) ProtoReflect() protoreflect.Message
func (*WorkflowVersion) Reset ¶ added in v0.12.0
func (x *WorkflowVersion) Reset()
func (*WorkflowVersion) String ¶ added in v0.12.0
func (x *WorkflowVersion) String() string
type WorkflowVersionNotAvailableAction ¶ added in v0.12.0
type WorkflowVersionNotAvailableAction struct {
// contains filtered or unexported fields
}
func (*WorkflowVersionNotAvailableAction) Descriptor
deprecated
added in
v0.12.0
func (*WorkflowVersionNotAvailableAction) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowVersionNotAvailableAction.ProtoReflect.Descriptor instead.
func (*WorkflowVersionNotAvailableAction) ProtoMessage ¶ added in v0.12.0
func (*WorkflowVersionNotAvailableAction) ProtoMessage()
func (*WorkflowVersionNotAvailableAction) ProtoReflect ¶ added in v0.12.0
func (x *WorkflowVersionNotAvailableAction) ProtoReflect() protoreflect.Message
func (*WorkflowVersionNotAvailableAction) Reset ¶ added in v0.12.0
func (x *WorkflowVersionNotAvailableAction) Reset()
func (*WorkflowVersionNotAvailableAction) String ¶ added in v0.12.0
func (x *WorkflowVersionNotAvailableAction) String() string