protos

package

Go to main page

Versions in this module

v0

v0.11.0

Jan 30, 2026

Changes in this version

+ const BackendService_GetInstanceHistory_FullMethodName

+ const BackendService_ListInstanceIDs_FullMethodName

+ const TaskHubSidecarService_GetInstanceHistory_FullMethodName

+ const TaskHubSidecarService_ListInstanceIDs_FullMethodName

+ var StalledReason_name = map[int32]string

+ var StalledReason_value = map[string]int32

type BackendServiceClient

+ GetInstanceHistory func(ctx context.Context, in *GetInstanceHistoryRequest, opts ...grpc.CallOption) (*GetInstanceHistoryResponse, error)

+ ListInstanceIDs func(ctx context.Context, in *ListInstanceIDsRequest, opts ...grpc.CallOption) (*ListInstanceIDsResponse, error)

type BackendServiceServer

+ GetInstanceHistory func(context.Context, *GetInstanceHistoryRequest) (*GetInstanceHistoryResponse, error)

+ ListInstanceIDs func(context.Context, *ListInstanceIDsRequest) (*ListInstanceIDsResponse, error)

+ type ExecutionStalledEvent struct

+ Description *string

+ Reason StalledReason

+ func (*ExecutionStalledEvent) Descriptor() ([]byte, []int)

+ func (*ExecutionStalledEvent) ProtoMessage()

+ func (x *ExecutionStalledEvent) GetDescription() string

+ func (x *ExecutionStalledEvent) GetReason() StalledReason

+ func (x *ExecutionStalledEvent) ProtoReflect() protoreflect.Message

+ func (x *ExecutionStalledEvent) Reset()

+ func (x *ExecutionStalledEvent) String() string

+ type GetInstanceHistoryRequest struct

+ InstanceId string

+ func (*GetInstanceHistoryRequest) Descriptor() ([]byte, []int)

+ func (*GetInstanceHistoryRequest) ProtoMessage()

+ func (x *GetInstanceHistoryRequest) GetInstanceId() string

+ func (x *GetInstanceHistoryRequest) ProtoReflect() protoreflect.Message

+ func (x *GetInstanceHistoryRequest) Reset()

+ func (x *GetInstanceHistoryRequest) String() string

+ type GetInstanceHistoryResponse struct

+ Events []*HistoryEvent

+ func (*GetInstanceHistoryResponse) Descriptor() ([]byte, []int)

+ func (*GetInstanceHistoryResponse) ProtoMessage()

+ func (x *GetInstanceHistoryResponse) GetEvents() []*HistoryEvent

+ func (x *GetInstanceHistoryResponse) ProtoReflect() protoreflect.Message

+ func (x *GetInstanceHistoryResponse) Reset()

+ func (x *GetInstanceHistoryResponse) String() string

type HistoryEvent

+ func (x *HistoryEvent) GetExecutionStalled() *ExecutionStalledEvent

+ type HistoryEvent_ExecutionStalled struct

+ ExecutionStalled *ExecutionStalledEvent

+ type ListInstanceIDsRequest struct

+ ContinuationToken *string

+ PageSize *uint32

+ func (*ListInstanceIDsRequest) Descriptor() ([]byte, []int)

+ func (*ListInstanceIDsRequest) ProtoMessage()

+ func (x *ListInstanceIDsRequest) GetContinuationToken() string

+ func (x *ListInstanceIDsRequest) GetPageSize() uint32

+ func (x *ListInstanceIDsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListInstanceIDsRequest) Reset()

+ func (x *ListInstanceIDsRequest) String() string

+ type ListInstanceIDsResponse struct

+ ContinuationToken *string

+ InstanceIds []string

+ func (*ListInstanceIDsResponse) Descriptor() ([]byte, []int)

+ func (*ListInstanceIDsResponse) ProtoMessage()

+ func (x *ListInstanceIDsResponse) GetContinuationToken() string

+ func (x *ListInstanceIDsResponse) GetInstanceIds() []string

+ func (x *ListInstanceIDsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListInstanceIDsResponse) Reset()

+ func (x *ListInstanceIDsResponse) String() string

type OrchestrationRuntimeState

+ Stalled *RuntimeStateStalled

+ func (x *OrchestrationRuntimeState) GetStalled() *RuntimeStateStalled

type OrchestrationStatus

+ const OrchestrationStatus_ORCHESTRATION_STATUS_STALLED

+ type OrchestrationVersion struct

+ Name *string

+ Patches []string

+ func (*OrchestrationVersion) Descriptor() ([]byte, []int)

+ func (*OrchestrationVersion) ProtoMessage()

+ func (x *OrchestrationVersion) GetName() string

+ func (x *OrchestrationVersion) GetPatches() []string

+ func (x *OrchestrationVersion) ProtoReflect() protoreflect.Message

+ func (x *OrchestrationVersion) Reset()

+ func (x *OrchestrationVersion) String() string

type OrchestratorAction

+ func (x *OrchestratorAction) GetOrchestratorVersionNotAvailable() *OrchestratorVersionNotAvailableAction

+ type OrchestratorAction_OrchestratorVersionNotAvailable struct

+ OrchestratorVersionNotAvailable *OrchestratorVersionNotAvailableAction

type OrchestratorResponse

+ Version *OrchestrationVersion

+ func (x *OrchestratorResponse) GetVersion() *OrchestrationVersion

type OrchestratorStartedEvent

+ Version *OrchestrationVersion

+ func (x *OrchestratorStartedEvent) GetVersion() *OrchestrationVersion

+ type OrchestratorVersionNotAvailableAction struct

+ func (*OrchestratorVersionNotAvailableAction) Descriptor() ([]byte, []int)

+ func (*OrchestratorVersionNotAvailableAction) ProtoMessage()

+ func (x *OrchestratorVersionNotAvailableAction) ProtoReflect() protoreflect.Message

+ func (x *OrchestratorVersionNotAvailableAction) Reset()

+ func (x *OrchestratorVersionNotAvailableAction) String() string

type PurgeInstancesRequest

+ Force *bool

+ func (x *PurgeInstancesRequest) GetForce() bool

+ type RerunParentInstanceInfo struct

+ InstanceID string

+ func (*RerunParentInstanceInfo) Descriptor() ([]byte, []int)

+ func (*RerunParentInstanceInfo) ProtoMessage()

+ func (x *RerunParentInstanceInfo) GetInstanceID() string

+ func (x *RerunParentInstanceInfo) ProtoReflect() protoreflect.Message

+ func (x *RerunParentInstanceInfo) Reset()

+ func (x *RerunParentInstanceInfo) String() string

type RerunWorkflowFromEventRequest

+ NewChildWorkflowInstanceID *string

+ func (x *RerunWorkflowFromEventRequest) GetNewChildWorkflowInstanceID() string

+ type RuntimeStateStalled struct

+ Description *string

+ Reason StalledReason

+ func (*RuntimeStateStalled) Descriptor() ([]byte, []int)

+ func (*RuntimeStateStalled) ProtoMessage()

+ func (x *RuntimeStateStalled) GetDescription() string

+ func (x *RuntimeStateStalled) GetReason() StalledReason

+ func (x *RuntimeStateStalled) ProtoReflect() protoreflect.Message

+ func (x *RuntimeStateStalled) Reset()

+ func (x *RuntimeStateStalled) String() string

+ type StalledReason int32

+ const StalledReason_PATCH_MISMATCH

+ const StalledReason_VERSION_NOT_AVAILABLE

+ func (StalledReason) Descriptor() protoreflect.EnumDescriptor

+ func (StalledReason) EnumDescriptor() ([]byte, []int)

+ func (StalledReason) Type() protoreflect.EnumType

+ func (x StalledReason) Enum() *StalledReason

+ func (x StalledReason) Number() protoreflect.EnumNumber

+ func (x StalledReason) String() string

type SubOrchestrationInstanceCreatedEvent

+ RerunParentInstanceInfo *RerunParentInstanceInfo

+ func (x *SubOrchestrationInstanceCreatedEvent) GetRerunParentInstanceInfo() *RerunParentInstanceInfo

type TaskHubSidecarServiceClient

+ GetInstanceHistory func(ctx context.Context, in *GetInstanceHistoryRequest, opts ...grpc.CallOption) (*GetInstanceHistoryResponse, error)

+ ListInstanceIDs func(ctx context.Context, in *ListInstanceIDsRequest, opts ...grpc.CallOption) (*ListInstanceIDsResponse, error)

type TaskHubSidecarServiceServer

+ GetInstanceHistory func(context.Context, *GetInstanceHistoryRequest) (*GetInstanceHistoryResponse, error)

+ ListInstanceIDs func(context.Context, *ListInstanceIDsRequest) (*ListInstanceIDsResponse, error)

type TaskScheduledEvent

+ RerunParentInstanceInfo *RerunParentInstanceInfo

+ func (x *TaskScheduledEvent) GetRerunParentInstanceInfo() *RerunParentInstanceInfo

type TimerCreatedEvent

+ RerunParentInstanceInfo *RerunParentInstanceInfo

+ func (x *TimerCreatedEvent) GetRerunParentInstanceInfo() *RerunParentInstanceInfo

type UnimplementedBackendServiceServer

+ func (UnimplementedBackendServiceServer) GetInstanceHistory(context.Context, *GetInstanceHistoryRequest) (*GetInstanceHistoryResponse, error)

+ func (UnimplementedBackendServiceServer) ListInstanceIDs(context.Context, *ListInstanceIDsRequest) (*ListInstanceIDsResponse, error)

type UnimplementedTaskHubSidecarServiceServer

+ func (UnimplementedTaskHubSidecarServiceServer) GetInstanceHistory(context.Context, *GetInstanceHistoryRequest) (*GetInstanceHistoryResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) ListInstanceIDs(context.Context, *ListInstanceIDsRequest) (*ListInstanceIDsResponse, error)

v0.10.2

Dec 3, 2025

v0.10.1

Oct 3, 2025

v0.10.0

Sep 11, 2025

v0.9.0

Sep 3, 2025

v0.8.3

Aug 28, 2025

v0.8.2

Aug 28, 2025

v0.8.1

Aug 22, 2025

v0.8.0

Aug 21, 2025

Changes in this version

type ActivityRequest

+ TaskExecutionId string

+ func (x *ActivityRequest) GetTaskExecutionId() string

type CreateSubOrchestrationAction

+ Router *TaskRouter

+ func (x *CreateSubOrchestrationAction) GetRouter() *TaskRouter

type HistoryEvent

+ Router *TaskRouter

+ func (x *HistoryEvent) GetRouter() *TaskRouter

type OrchestratorAction

+ Router *TaskRouter

+ func (x *OrchestratorAction) GetRouter() *TaskRouter

type OrchestratorRequest

+ Router *TaskRouter

+ func (x *OrchestratorRequest) GetRouter() *TaskRouter

type ParentInstanceInfo

+ AppID *string

+ func (x *ParentInstanceInfo) GetAppID() string

type ScheduleTaskAction

+ Router *TaskRouter

+ TaskExecutionId string

+ func (x *ScheduleTaskAction) GetRouter() *TaskRouter

+ func (x *ScheduleTaskAction) GetTaskExecutionId() string

type TaskCompletedEvent

+ TaskExecutionId string

+ func (x *TaskCompletedEvent) GetTaskExecutionId() string

type TaskFailedEvent

+ TaskExecutionId string

+ func (x *TaskFailedEvent) GetTaskExecutionId() string

+ type TaskRouter struct

+ SourceAppID string

+ TargetAppID *string

+ func (*TaskRouter) Descriptor() ([]byte, []int)

+ func (*TaskRouter) ProtoMessage()

+ func (x *TaskRouter) GetSourceAppID() string

+ func (x *TaskRouter) GetTargetAppID() string

+ func (x *TaskRouter) ProtoReflect() protoreflect.Message

+ func (x *TaskRouter) Reset()

+ func (x *TaskRouter) String() string

type TaskScheduledEvent

+ TaskExecutionId string

+ func (x *TaskScheduledEvent) GetTaskExecutionId() string

v0.7.2

May 21, 2025

v0.7.1

May 7, 2025

v0.7.0

May 6, 2025

Changes in this version

+ const BackendService_AbandonEntityWorkItem_FullMethodName

+ const BackendService_CleanEntityStorage_FullMethodName

+ const BackendService_CompleteEntityWorkItem_FullMethodName

+ const BackendService_GetEntity_FullMethodName

+ const BackendService_GetMetrics_FullMethodName

+ const BackendService_QueryEntities_FullMethodName

+ const BackendService_StreamInstanceHistory_FullMethodName

+ const TaskHubSidecarService_AbandonTaskActivityWorkItem_FullMethodName

+ const TaskHubSidecarService_AbandonTaskEntityWorkItem_FullMethodName

+ const TaskHubSidecarService_AbandonTaskOrchestratorWorkItem_FullMethodName

+ const TaskHubSidecarService_RerunWorkflowFromEvent_FullMethodName

+ const TaskHubSidecarService_StreamInstanceHistory_FullMethodName

+ var WorkerCapability_name = map[int32]string

+ var WorkerCapability_value = map[string]int32

+ type AbandonActivityTaskRequest struct

+ CompletionToken string

+ func (*AbandonActivityTaskRequest) Descriptor() ([]byte, []int)

+ func (*AbandonActivityTaskRequest) ProtoMessage()

+ func (x *AbandonActivityTaskRequest) GetCompletionToken() string

+ func (x *AbandonActivityTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *AbandonActivityTaskRequest) Reset()

+ func (x *AbandonActivityTaskRequest) String() string

+ type AbandonActivityTaskResponse struct

+ func (*AbandonActivityTaskResponse) Descriptor() ([]byte, []int)

+ func (*AbandonActivityTaskResponse) ProtoMessage()

+ func (x *AbandonActivityTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *AbandonActivityTaskResponse) Reset()

+ func (x *AbandonActivityTaskResponse) String() string

+ type AbandonEntityTaskRequest struct

+ CompletionToken string

+ func (*AbandonEntityTaskRequest) Descriptor() ([]byte, []int)

+ func (*AbandonEntityTaskRequest) ProtoMessage()

+ func (x *AbandonEntityTaskRequest) GetCompletionToken() string

+ func (x *AbandonEntityTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *AbandonEntityTaskRequest) Reset()

+ func (x *AbandonEntityTaskRequest) String() string

+ type AbandonEntityTaskResponse struct

+ func (*AbandonEntityTaskResponse) Descriptor() ([]byte, []int)

+ func (*AbandonEntityTaskResponse) ProtoMessage()

+ func (x *AbandonEntityTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *AbandonEntityTaskResponse) Reset()

+ func (x *AbandonEntityTaskResponse) String() string

+ type AbandonEntityWorkItemRequest struct

+ CompletionToken string

+ Reason string

+ func (*AbandonEntityWorkItemRequest) Descriptor() ([]byte, []int)

+ func (*AbandonEntityWorkItemRequest) ProtoMessage()

+ func (x *AbandonEntityWorkItemRequest) GetCompletionToken() string

+ func (x *AbandonEntityWorkItemRequest) GetReason() string

+ func (x *AbandonEntityWorkItemRequest) ProtoReflect() protoreflect.Message

+ func (x *AbandonEntityWorkItemRequest) Reset()

+ func (x *AbandonEntityWorkItemRequest) String() string

+ type AbandonEntityWorkItemResponse struct

+ func (*AbandonEntityWorkItemResponse) Descriptor() ([]byte, []int)

+ func (*AbandonEntityWorkItemResponse) ProtoMessage()

+ func (x *AbandonEntityWorkItemResponse) ProtoReflect() protoreflect.Message

+ func (x *AbandonEntityWorkItemResponse) Reset()

+ func (x *AbandonEntityWorkItemResponse) String() string

+ type AbandonOrchestrationTaskRequest struct

+ CompletionToken string

+ func (*AbandonOrchestrationTaskRequest) Descriptor() ([]byte, []int)

+ func (*AbandonOrchestrationTaskRequest) ProtoMessage()

+ func (x *AbandonOrchestrationTaskRequest) GetCompletionToken() string

+ func (x *AbandonOrchestrationTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *AbandonOrchestrationTaskRequest) Reset()

+ func (x *AbandonOrchestrationTaskRequest) String() string

+ type AbandonOrchestrationTaskResponse struct

+ func (*AbandonOrchestrationTaskResponse) Descriptor() ([]byte, []int)

+ func (*AbandonOrchestrationTaskResponse) ProtoMessage()

+ func (x *AbandonOrchestrationTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *AbandonOrchestrationTaskResponse) Reset()

+ func (x *AbandonOrchestrationTaskResponse) String() string

type ActivityResponse

+ CompletionToken string

+ func (x *ActivityResponse) GetCompletionToken() string

+ type BackendMetrics struct

+ ActivityWorkItems *WorkItemMetrics

+ ConnectedWorkers *ConnectedWorkerMetrics

+ EntityWorkItems *WorkItemMetrics

+ OrchestratorWorkItems *WorkItemMetrics

+ func (*BackendMetrics) Descriptor() ([]byte, []int)

+ func (*BackendMetrics) ProtoMessage()

+ func (x *BackendMetrics) GetActivityWorkItems() *WorkItemMetrics

+ func (x *BackendMetrics) GetConnectedWorkers() *ConnectedWorkerMetrics

+ func (x *BackendMetrics) GetEntityWorkItems() *WorkItemMetrics

+ func (x *BackendMetrics) GetOrchestratorWorkItems() *WorkItemMetrics

+ func (x *BackendMetrics) ProtoReflect() protoreflect.Message

+ func (x *BackendMetrics) Reset()

+ func (x *BackendMetrics) String() string

type BackendServiceClient

+ AbandonEntityWorkItem func(ctx context.Context, in *AbandonEntityWorkItemRequest, opts ...grpc.CallOption) (*AbandonEntityWorkItemResponse, error)

+ CleanEntityStorage func(ctx context.Context, in *CleanEntityStorageRequest, opts ...grpc.CallOption) (*CleanEntityStorageResponse, error)

+ CompleteEntityWorkItem func(ctx context.Context, in *CompleteEntityWorkItemRequest, ...) (*CompleteEntityWorkItemResponse, error)

+ GetEntity func(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*GetEntityResponse, error)

+ GetMetrics func(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error)

+ QueryEntities func(ctx context.Context, in *QueryEntitiesRequest, opts ...grpc.CallOption) (*QueryEntitiesResponse, error)

+ StreamInstanceHistory func(ctx context.Context, in *StreamInstanceHistoryRequest, opts ...grpc.CallOption) (BackendService_StreamInstanceHistoryClient, error)

type BackendServiceServer

+ AbandonEntityWorkItem func(context.Context, *AbandonEntityWorkItemRequest) (*AbandonEntityWorkItemResponse, error)

+ CleanEntityStorage func(context.Context, *CleanEntityStorageRequest) (*CleanEntityStorageResponse, error)

+ CompleteEntityWorkItem func(context.Context, *CompleteEntityWorkItemRequest) (*CompleteEntityWorkItemResponse, error)

+ GetEntity func(context.Context, *GetEntityRequest) (*GetEntityResponse, error)

+ GetMetrics func(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)

+ QueryEntities func(context.Context, *QueryEntitiesRequest) (*QueryEntitiesResponse, error)

+ StreamInstanceHistory func(*StreamInstanceHistoryRequest, BackendService_StreamInstanceHistoryServer) error

+ type BackendService_StreamInstanceHistoryClient interface

+ Recv func() (*HistoryChunk, error)

+ type BackendService_StreamInstanceHistoryServer interface

+ Send func(*HistoryChunk) error

+ type CompleteEntityWorkItemRequest struct

+ CompletionToken string

+ EntityState *wrapperspb.StringValue

+ ExecutionId string

+ Messages []*OrchestratorMessage

+ NumberOperationsExecuted int32

+ func (*CompleteEntityWorkItemRequest) Descriptor() ([]byte, []int)

+ func (*CompleteEntityWorkItemRequest) ProtoMessage()

+ func (x *CompleteEntityWorkItemRequest) GetCompletionToken() string

+ func (x *CompleteEntityWorkItemRequest) GetEntityState() *wrapperspb.StringValue

+ func (x *CompleteEntityWorkItemRequest) GetExecutionId() string

+ func (x *CompleteEntityWorkItemRequest) GetMessages() []*OrchestratorMessage

+ func (x *CompleteEntityWorkItemRequest) GetNumberOperationsExecuted() int32

+ func (x *CompleteEntityWorkItemRequest) ProtoReflect() protoreflect.Message

+ func (x *CompleteEntityWorkItemRequest) Reset()

+ func (x *CompleteEntityWorkItemRequest) String() string

+ type CompleteEntityWorkItemResponse struct

+ func (*CompleteEntityWorkItemResponse) Descriptor() ([]byte, []int)

+ func (*CompleteEntityWorkItemResponse) ProtoMessage()

+ func (x *CompleteEntityWorkItemResponse) ProtoReflect() protoreflect.Message

+ func (x *CompleteEntityWorkItemResponse) Reset()

+ func (x *CompleteEntityWorkItemResponse) String() string

type CompleteOrchestrationWorkItemRequest

+ Instance *OrchestrationInstance

+ NumEventsProcessed *wrapperspb.Int32Value

+ func (x *CompleteOrchestrationWorkItemRequest) GetInstance() *OrchestrationInstance

+ func (x *CompleteOrchestrationWorkItemRequest) GetNumEventsProcessed() *wrapperspb.Int32Value

+ type ConnectedWorkerMetrics struct

+ Count int32

+ func (*ConnectedWorkerMetrics) Descriptor() ([]byte, []int)

+ func (*ConnectedWorkerMetrics) ProtoMessage()

+ func (x *ConnectedWorkerMetrics) GetCount() int32

+ func (x *ConnectedWorkerMetrics) ProtoReflect() protoreflect.Message

+ func (x *ConnectedWorkerMetrics) Reset()

+ func (x *ConnectedWorkerMetrics) String() string

type CreateInstanceRequest

+ ParentTraceContext *TraceContext

+ func (x *CreateInstanceRequest) GetParentTraceContext() *TraceContext

type CreateTimerAction

+ Name *string

+ func (x *CreateTimerAction) GetName() string

type EntityBatchResult

+ CompletionToken string

+ OperationInfos []*OperationInfo

+ func (x *EntityBatchResult) GetCompletionToken() string

+ func (x *EntityBatchResult) GetOperationInfos() []*OperationInfo

+ type EntityLockGrantedEvent struct

+ CriticalSectionId string

+ func (*EntityLockGrantedEvent) Descriptor() ([]byte, []int)

+ func (*EntityLockGrantedEvent) ProtoMessage()

+ func (x *EntityLockGrantedEvent) GetCriticalSectionId() string

+ func (x *EntityLockGrantedEvent) ProtoReflect() protoreflect.Message

+ func (x *EntityLockGrantedEvent) Reset()

+ func (x *EntityLockGrantedEvent) String() string

+ type EntityLockRequestedEvent struct

+ CriticalSectionId string

+ LockSet []string

+ ParentInstanceId *wrapperspb.StringValue

+ Position int32

+ func (*EntityLockRequestedEvent) Descriptor() ([]byte, []int)

+ func (*EntityLockRequestedEvent) ProtoMessage()

+ func (x *EntityLockRequestedEvent) GetCriticalSectionId() string

+ func (x *EntityLockRequestedEvent) GetLockSet() []string

+ func (x *EntityLockRequestedEvent) GetParentInstanceId() *wrapperspb.StringValue

+ func (x *EntityLockRequestedEvent) GetPosition() int32

+ func (x *EntityLockRequestedEvent) ProtoReflect() protoreflect.Message

+ func (x *EntityLockRequestedEvent) Reset()

+ func (x *EntityLockRequestedEvent) String() string

+ type EntityOperationCalledEvent struct

+ Input *wrapperspb.StringValue

+ Operation string

+ ParentExecutionId *wrapperspb.StringValue

+ ParentInstanceId *wrapperspb.StringValue

+ RequestId string

+ ScheduledTime *timestamppb.Timestamp

+ TargetInstanceId *wrapperspb.StringValue

+ func (*EntityOperationCalledEvent) Descriptor() ([]byte, []int)

+ func (*EntityOperationCalledEvent) ProtoMessage()

+ func (x *EntityOperationCalledEvent) GetInput() *wrapperspb.StringValue

+ func (x *EntityOperationCalledEvent) GetOperation() string

+ func (x *EntityOperationCalledEvent) GetParentExecutionId() *wrapperspb.StringValue

+ func (x *EntityOperationCalledEvent) GetParentInstanceId() *wrapperspb.StringValue

+ func (x *EntityOperationCalledEvent) GetRequestId() string

+ func (x *EntityOperationCalledEvent) GetScheduledTime() *timestamppb.Timestamp

+ func (x *EntityOperationCalledEvent) GetTargetInstanceId() *wrapperspb.StringValue

+ func (x *EntityOperationCalledEvent) ProtoReflect() protoreflect.Message

+ func (x *EntityOperationCalledEvent) Reset()

+ func (x *EntityOperationCalledEvent) String() string

+ type EntityOperationCompletedEvent struct

+ Output *wrapperspb.StringValue

+ RequestId string

+ func (*EntityOperationCompletedEvent) Descriptor() ([]byte, []int)

+ func (*EntityOperationCompletedEvent) ProtoMessage()

+ func (x *EntityOperationCompletedEvent) GetOutput() *wrapperspb.StringValue

+ func (x *EntityOperationCompletedEvent) GetRequestId() string

+ func (x *EntityOperationCompletedEvent) ProtoReflect() protoreflect.Message

+ func (x *EntityOperationCompletedEvent) Reset()

+ func (x *EntityOperationCompletedEvent) String() string

+ type EntityOperationFailedEvent struct

+ FailureDetails *TaskFailureDetails

+ RequestId string

+ func (*EntityOperationFailedEvent) Descriptor() ([]byte, []int)

+ func (*EntityOperationFailedEvent) ProtoMessage()

+ func (x *EntityOperationFailedEvent) GetFailureDetails() *TaskFailureDetails

+ func (x *EntityOperationFailedEvent) GetRequestId() string

+ func (x *EntityOperationFailedEvent) ProtoReflect() protoreflect.Message

+ func (x *EntityOperationFailedEvent) Reset()

+ func (x *EntityOperationFailedEvent) String() string

+ type EntityOperationSignaledEvent struct

+ Input *wrapperspb.StringValue

+ Operation string

+ RequestId string

+ ScheduledTime *timestamppb.Timestamp

+ TargetInstanceId *wrapperspb.StringValue

+ func (*EntityOperationSignaledEvent) Descriptor() ([]byte, []int)

+ func (*EntityOperationSignaledEvent) ProtoMessage()

+ func (x *EntityOperationSignaledEvent) GetInput() *wrapperspb.StringValue

+ func (x *EntityOperationSignaledEvent) GetOperation() string

+ func (x *EntityOperationSignaledEvent) GetRequestId() string

+ func (x *EntityOperationSignaledEvent) GetScheduledTime() *timestamppb.Timestamp

+ func (x *EntityOperationSignaledEvent) GetTargetInstanceId() *wrapperspb.StringValue

+ func (x *EntityOperationSignaledEvent) ProtoReflect() protoreflect.Message

+ func (x *EntityOperationSignaledEvent) Reset()

+ func (x *EntityOperationSignaledEvent) String() string

+ type EntityRequest struct

+ EntityState *wrapperspb.StringValue

+ ExecutionId string

+ InstanceId string

+ OperationRequests []*HistoryEvent

+ func (*EntityRequest) Descriptor() ([]byte, []int)

+ func (*EntityRequest) ProtoMessage()

+ func (x *EntityRequest) GetEntityState() *wrapperspb.StringValue

+ func (x *EntityRequest) GetExecutionId() string

+ func (x *EntityRequest) GetInstanceId() string

+ func (x *EntityRequest) GetOperationRequests() []*HistoryEvent

+ func (x *EntityRequest) ProtoReflect() protoreflect.Message

+ func (x *EntityRequest) Reset()

+ func (x *EntityRequest) String() string

+ type EntityUnlockSentEvent struct

+ CriticalSectionId string

+ ParentInstanceId *wrapperspb.StringValue

+ TargetInstanceId *wrapperspb.StringValue

+ func (*EntityUnlockSentEvent) Descriptor() ([]byte, []int)

+ func (*EntityUnlockSentEvent) ProtoMessage()

+ func (x *EntityUnlockSentEvent) GetCriticalSectionId() string

+ func (x *EntityUnlockSentEvent) GetParentInstanceId() *wrapperspb.StringValue

+ func (x *EntityUnlockSentEvent) GetTargetInstanceId() *wrapperspb.StringValue

+ func (x *EntityUnlockSentEvent) ProtoReflect() protoreflect.Message

+ func (x *EntityUnlockSentEvent) Reset()

+ func (x *EntityUnlockSentEvent) String() string

type ExecutionStartedEvent

+ Tags map[string]string

+ func (x *ExecutionStartedEvent) GetTags() map[string]string

+ type GetMetricsRequest struct

+ func (*GetMetricsRequest) Descriptor() ([]byte, []int)

+ func (*GetMetricsRequest) ProtoMessage()

+ func (x *GetMetricsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetMetricsRequest) Reset()

+ func (x *GetMetricsRequest) String() string

+ type GetMetricsResponse struct

+ Metrics *BackendMetrics

+ func (*GetMetricsResponse) Descriptor() ([]byte, []int)

+ func (*GetMetricsResponse) ProtoMessage()

+ func (x *GetMetricsResponse) GetMetrics() *BackendMetrics

+ func (x *GetMetricsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetMetricsResponse) Reset()

+ func (x *GetMetricsResponse) String() string

type GetWorkItemsRequest

+ Capabilities []WorkerCapability

+ MaxConcurrentActivityWorkItems int32

+ MaxConcurrentEntityWorkItems int32

+ MaxConcurrentOrchestrationWorkItems int32

+ func (x *GetWorkItemsRequest) GetCapabilities() []WorkerCapability

+ func (x *GetWorkItemsRequest) GetMaxConcurrentActivityWorkItems() int32

+ func (x *GetWorkItemsRequest) GetMaxConcurrentEntityWorkItems() int32

+ func (x *GetWorkItemsRequest) GetMaxConcurrentOrchestrationWorkItems() int32

+ type HistoryChunk struct

+ Events []*HistoryEvent

+ func (*HistoryChunk) Descriptor() ([]byte, []int)

+ func (*HistoryChunk) ProtoMessage()

+ func (x *HistoryChunk) GetEvents() []*HistoryEvent

+ func (x *HistoryChunk) ProtoReflect() protoreflect.Message

+ func (x *HistoryChunk) Reset()

+ func (x *HistoryChunk) String() string

type HistoryEvent

+ func (x *HistoryEvent) GetEntityLockGranted() *EntityLockGrantedEvent

+ func (x *HistoryEvent) GetEntityLockRequested() *EntityLockRequestedEvent

+ func (x *HistoryEvent) GetEntityOperationCalled() *EntityOperationCalledEvent

+ func (x *HistoryEvent) GetEntityOperationCompleted() *EntityOperationCompletedEvent

+ func (x *HistoryEvent) GetEntityOperationFailed() *EntityOperationFailedEvent

+ func (x *HistoryEvent) GetEntityOperationSignaled() *EntityOperationSignaledEvent

+ func (x *HistoryEvent) GetEntityUnlockSent() *EntityUnlockSentEvent

+ type HistoryEvent_EntityLockGranted struct

+ EntityLockGranted *EntityLockGrantedEvent

+ type HistoryEvent_EntityLockRequested struct

+ EntityLockRequested *EntityLockRequestedEvent

+ type HistoryEvent_EntityOperationCalled struct

+ EntityOperationCalled *EntityOperationCalledEvent

+ type HistoryEvent_EntityOperationCompleted struct

+ EntityOperationCompleted *EntityOperationCompletedEvent

+ type HistoryEvent_EntityOperationFailed struct

+ EntityOperationFailed *EntityOperationFailedEvent

+ type HistoryEvent_EntityOperationSignaled struct

+ EntityOperationSignaled *EntityOperationSignaledEvent

+ type HistoryEvent_EntityUnlockSent struct

+ EntityUnlockSent *EntityUnlockSentEvent

+ type OperationInfo struct

+ RequestId string

+ ResponseDestination *OrchestrationInstance

+ func (*OperationInfo) Descriptor() ([]byte, []int)

+ func (*OperationInfo) ProtoMessage()

+ func (x *OperationInfo) GetRequestId() string

+ func (x *OperationInfo) GetResponseDestination() *OrchestrationInstance

+ func (x *OperationInfo) ProtoReflect() protoreflect.Message

+ func (x *OperationInfo) Reset()

+ func (x *OperationInfo) String() string

type OrchestrationState

+ Tags map[string]string

+ func (x *OrchestrationState) GetTags() map[string]string

type OrchestratorAction

+ func (x *OrchestratorAction) GetSendEntityMessage() *SendEntityMessageAction

+ type OrchestratorAction_SendEntityMessage struct

+ SendEntityMessage *SendEntityMessageAction

type OrchestratorRequest

+ RequiresHistoryStreaming bool

+ func (x *OrchestratorRequest) GetRequiresHistoryStreaming() bool

type OrchestratorResponse

+ CompletionToken string

+ NumEventsProcessed *wrapperspb.Int32Value

+ func (x *OrchestratorResponse) GetCompletionToken() string

+ func (x *OrchestratorResponse) GetNumEventsProcessed() *wrapperspb.Int32Value

type PurgeInstancesResponse

+ IsComplete *wrapperspb.BoolValue

+ func (x *PurgeInstancesResponse) GetIsComplete() *wrapperspb.BoolValue

+ type RerunWorkflowFromEventRequest struct

+ EventID uint32

+ Input *wrapperspb.StringValue

+ NewInstanceID string

+ OverwriteInput bool

+ SourceInstanceID string

+ func (*RerunWorkflowFromEventRequest) Descriptor() ([]byte, []int)

+ func (*RerunWorkflowFromEventRequest) ProtoMessage()

+ func (x *RerunWorkflowFromEventRequest) GetEventID() uint32

+ func (x *RerunWorkflowFromEventRequest) GetInput() *wrapperspb.StringValue

+ func (x *RerunWorkflowFromEventRequest) GetNewInstanceID() string

+ func (x *RerunWorkflowFromEventRequest) GetOverwriteInput() bool

+ func (x *RerunWorkflowFromEventRequest) GetSourceInstanceID() string

+ func (x *RerunWorkflowFromEventRequest) ProtoReflect() protoreflect.Message

+ func (x *RerunWorkflowFromEventRequest) Reset()

+ func (x *RerunWorkflowFromEventRequest) String() string

+ type RerunWorkflowFromEventResponse struct

+ NewInstanceID string

+ func (*RerunWorkflowFromEventResponse) Descriptor() ([]byte, []int)

+ func (*RerunWorkflowFromEventResponse) ProtoMessage()

+ func (x *RerunWorkflowFromEventResponse) GetNewInstanceID() string

+ func (x *RerunWorkflowFromEventResponse) ProtoReflect() protoreflect.Message

+ func (x *RerunWorkflowFromEventResponse) Reset()

+ func (x *RerunWorkflowFromEventResponse) String() string

+ type SendEntityMessageAction struct

+ EntityMessageType isSendEntityMessageAction_EntityMessageType

+ func (*SendEntityMessageAction) Descriptor() ([]byte, []int)

+ func (*SendEntityMessageAction) ProtoMessage()

+ func (m *SendEntityMessageAction) GetEntityMessageType() isSendEntityMessageAction_EntityMessageType

+ func (x *SendEntityMessageAction) GetEntityLockRequested() *EntityLockRequestedEvent

+ func (x *SendEntityMessageAction) GetEntityOperationCalled() *EntityOperationCalledEvent

+ func (x *SendEntityMessageAction) GetEntityOperationSignaled() *EntityOperationSignaledEvent

+ func (x *SendEntityMessageAction) GetEntityUnlockSent() *EntityUnlockSentEvent

+ func (x *SendEntityMessageAction) ProtoReflect() protoreflect.Message

+ func (x *SendEntityMessageAction) Reset()

+ func (x *SendEntityMessageAction) String() string

+ type SendEntityMessageAction_EntityLockRequested struct

+ EntityLockRequested *EntityLockRequestedEvent

+ type SendEntityMessageAction_EntityOperationCalled struct

+ EntityOperationCalled *EntityOperationCalledEvent

+ type SendEntityMessageAction_EntityOperationSignaled struct

+ EntityOperationSignaled *EntityOperationSignaledEvent

+ type SendEntityMessageAction_EntityUnlockSent struct

+ EntityUnlockSent *EntityUnlockSentEvent

+ type StreamInstanceHistoryRequest struct

+ ExecutionId *wrapperspb.StringValue

+ ForWorkItemProcessing bool

+ InstanceId string

+ func (*StreamInstanceHistoryRequest) Descriptor() ([]byte, []int)

+ func (*StreamInstanceHistoryRequest) ProtoMessage()

+ func (x *StreamInstanceHistoryRequest) GetExecutionId() *wrapperspb.StringValue

+ func (x *StreamInstanceHistoryRequest) GetForWorkItemProcessing() bool

+ func (x *StreamInstanceHistoryRequest) GetInstanceId() string

+ func (x *StreamInstanceHistoryRequest) ProtoReflect() protoreflect.Message

+ func (x *StreamInstanceHistoryRequest) Reset()

+ func (x *StreamInstanceHistoryRequest) String() string

type TaskHubSidecarServiceClient

+ AbandonTaskActivityWorkItem func(ctx context.Context, in *AbandonActivityTaskRequest, opts ...grpc.CallOption) (*AbandonActivityTaskResponse, error)

+ AbandonTaskEntityWorkItem func(ctx context.Context, in *AbandonEntityTaskRequest, opts ...grpc.CallOption) (*AbandonEntityTaskResponse, error)

+ AbandonTaskOrchestratorWorkItem func(ctx context.Context, in *AbandonOrchestrationTaskRequest, ...) (*AbandonOrchestrationTaskResponse, error)

+ RerunWorkflowFromEvent func(ctx context.Context, in *RerunWorkflowFromEventRequest, ...) (*RerunWorkflowFromEventResponse, error)

+ StreamInstanceHistory func(ctx context.Context, in *StreamInstanceHistoryRequest, opts ...grpc.CallOption) (TaskHubSidecarService_StreamInstanceHistoryClient, error)

type TaskHubSidecarServiceServer

+ AbandonTaskActivityWorkItem func(context.Context, *AbandonActivityTaskRequest) (*AbandonActivityTaskResponse, error)

+ AbandonTaskEntityWorkItem func(context.Context, *AbandonEntityTaskRequest) (*AbandonEntityTaskResponse, error)

+ AbandonTaskOrchestratorWorkItem func(context.Context, *AbandonOrchestrationTaskRequest) (*AbandonOrchestrationTaskResponse, error)

+ RerunWorkflowFromEvent func(context.Context, *RerunWorkflowFromEventRequest) (*RerunWorkflowFromEventResponse, error)

+ StreamInstanceHistory func(*StreamInstanceHistoryRequest, ...) error

+ type TaskHubSidecarService_StreamInstanceHistoryClient interface

+ Recv func() (*HistoryChunk, error)

+ type TaskHubSidecarService_StreamInstanceHistoryServer interface

+ Send func(*HistoryChunk) error

type TimerCreatedEvent

+ Name *string

+ func (x *TimerCreatedEvent) GetName() string

type UnimplementedBackendServiceServer

+ func (UnimplementedBackendServiceServer) AbandonEntityWorkItem(context.Context, *AbandonEntityWorkItemRequest) (*AbandonEntityWorkItemResponse, error)

+ func (UnimplementedBackendServiceServer) CleanEntityStorage(context.Context, *CleanEntityStorageRequest) (*CleanEntityStorageResponse, error)

+ func (UnimplementedBackendServiceServer) CompleteEntityWorkItem(context.Context, *CompleteEntityWorkItemRequest) (*CompleteEntityWorkItemResponse, error)

+ func (UnimplementedBackendServiceServer) GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)

+ func (UnimplementedBackendServiceServer) GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)

+ func (UnimplementedBackendServiceServer) QueryEntities(context.Context, *QueryEntitiesRequest) (*QueryEntitiesResponse, error)

+ func (UnimplementedBackendServiceServer) StreamInstanceHistory(*StreamInstanceHistoryRequest, BackendService_StreamInstanceHistoryServer) error

type UnimplementedTaskHubSidecarServiceServer

+ func (UnimplementedTaskHubSidecarServiceServer) AbandonTaskActivityWorkItem(context.Context, *AbandonActivityTaskRequest) (*AbandonActivityTaskResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) AbandonTaskEntityWorkItem(context.Context, *AbandonEntityTaskRequest) (*AbandonEntityTaskResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) AbandonTaskOrchestratorWorkItem(context.Context, *AbandonOrchestrationTaskRequest) (*AbandonOrchestrationTaskResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) RerunWorkflowFromEvent(context.Context, *RerunWorkflowFromEventRequest) (*RerunWorkflowFromEventResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) StreamInstanceHistory(*StreamInstanceHistoryRequest, ...) error

type WorkItem

+ func (x *WorkItem) GetEntityRequestV2() *EntityRequest

+ type WorkItemMetrics struct

+ Active int32

+ OldestAgeInSeconds int32

+ Pending int32

+ func (*WorkItemMetrics) Descriptor() ([]byte, []int)

+ func (*WorkItemMetrics) ProtoMessage()

+ func (x *WorkItemMetrics) GetActive() int32

+ func (x *WorkItemMetrics) GetOldestAgeInSeconds() int32

+ func (x *WorkItemMetrics) GetPending() int32

+ func (x *WorkItemMetrics) ProtoReflect() protoreflect.Message

+ func (x *WorkItemMetrics) Reset()

+ func (x *WorkItemMetrics) String() string

+ type WorkItem_EntityRequestV2 struct

+ EntityRequestV2 *EntityRequest

+ type WorkerCapability int32

+ const WorkerCapability_WORKER_CAPABILITY_HISTORY_STREAMING

+ const WorkerCapability_WORKER_CAPABILITY_UNSPECIFIED

+ func (WorkerCapability) Descriptor() protoreflect.EnumDescriptor

+ func (WorkerCapability) EnumDescriptor() ([]byte, []int)

+ func (WorkerCapability) Type() protoreflect.EnumType

+ func (x WorkerCapability) Enum() *WorkerCapability

+ func (x WorkerCapability) Number() protoreflect.EnumNumber

+ func (x WorkerCapability) String() string

v0.6.8

Aug 28, 2025

v0.6.7

Jul 29, 2025

v0.6.6

Jul 9, 2025

v0.6.5

Feb 24, 2025

v0.6.4

Feb 20, 2025

Changes in this version

type OrchestrationMetadata

+ CompletedAt *timestamppb.Timestamp

+ ParentInstanceId string

+ func (x *OrchestrationMetadata) GetCompletedAt() *timestamppb.Timestamp

+ func (x *OrchestrationMetadata) GetParentInstanceId() string

v0.6.3

Feb 12, 2025

v0.6.2

Feb 7, 2025

v0.6.1

Feb 4, 2025

v0.6.0

Jan 24, 2025

Changes in this version

+ const BackendService_AbandonActivityWorkItem_FullMethodName

+ const BackendService_AbandonOrchestrationWorkItem_FullMethodName

+ const BackendService_AddEvent_FullMethodName

+ const BackendService_CompleteActivityWorkItem_FullMethodName

+ const BackendService_CompleteOrchestrationWorkItem_FullMethodName

+ const BackendService_CreateInstance_FullMethodName

+ const BackendService_GetInstance_FullMethodName

+ const BackendService_GetOrchestrationRuntimeState_FullMethodName

+ const BackendService_GetWorkItems_FullMethodName

+ const BackendService_Ping_FullMethodName

+ const BackendService_PurgeInstances_FullMethodName

+ const BackendService_QueryInstances_FullMethodName

+ const BackendService_WaitForInstance_FullMethodName

+ const TaskHubSidecarService_CleanEntityStorage_FullMethodName

+ const TaskHubSidecarService_CompleteActivityTask_FullMethodName

+ const TaskHubSidecarService_CompleteEntityTask_FullMethodName

+ const TaskHubSidecarService_CompleteOrchestratorTask_FullMethodName

+ const TaskHubSidecarService_CreateTaskHub_FullMethodName

+ const TaskHubSidecarService_DeleteTaskHub_FullMethodName

+ const TaskHubSidecarService_GetEntity_FullMethodName

+ const TaskHubSidecarService_GetInstance_FullMethodName

+ const TaskHubSidecarService_GetWorkItems_FullMethodName

+ const TaskHubSidecarService_Hello_FullMethodName

+ const TaskHubSidecarService_PurgeInstances_FullMethodName

+ const TaskHubSidecarService_QueryEntities_FullMethodName

+ const TaskHubSidecarService_QueryInstances_FullMethodName

+ const TaskHubSidecarService_RaiseEvent_FullMethodName

+ const TaskHubSidecarService_ResumeInstance_FullMethodName

+ const TaskHubSidecarService_RewindInstance_FullMethodName

+ const TaskHubSidecarService_SignalEntity_FullMethodName

+ const TaskHubSidecarService_StartInstance_FullMethodName

+ const TaskHubSidecarService_SuspendInstance_FullMethodName

+ const TaskHubSidecarService_TerminateInstance_FullMethodName

+ const TaskHubSidecarService_WaitForInstanceCompletion_FullMethodName

+ const TaskHubSidecarService_WaitForInstanceStart_FullMethodName

+ var BackendService_ServiceDesc = grpc.ServiceDesc

+ var CreateOrchestrationAction_name = map[int32]string

+ var CreateOrchestrationAction_value = map[string]int32

+ var File_backend_service_proto protoreflect.FileDescriptor

+ var File_orchestrator_service_proto protoreflect.FileDescriptor

+ var File_runtime_state_proto protoreflect.FileDescriptor

+ var OrchestrationStatus_name = map[int32]string

+ var OrchestrationStatus_value = map[string]int32

+ var TaskHubSidecarService_ServiceDesc = grpc.ServiceDesc

+ func RegisterBackendServiceServer(s grpc.ServiceRegistrar, srv BackendServiceServer)

+ func RegisterTaskHubSidecarServiceServer(s grpc.ServiceRegistrar, srv TaskHubSidecarServiceServer)

+ type AbandonActivityWorkItemRequest struct

+ CompletionToken string

+ func (*AbandonActivityWorkItemRequest) Descriptor() ([]byte, []int)

+ func (*AbandonActivityWorkItemRequest) ProtoMessage()

+ func (x *AbandonActivityWorkItemRequest) GetCompletionToken() string

+ func (x *AbandonActivityWorkItemRequest) ProtoReflect() protoreflect.Message

+ func (x *AbandonActivityWorkItemRequest) Reset()

+ func (x *AbandonActivityWorkItemRequest) String() string

+ type AbandonActivityWorkItemResponse struct

+ func (*AbandonActivityWorkItemResponse) Descriptor() ([]byte, []int)

+ func (*AbandonActivityWorkItemResponse) ProtoMessage()

+ func (x *AbandonActivityWorkItemResponse) ProtoReflect() protoreflect.Message

+ func (x *AbandonActivityWorkItemResponse) Reset()

+ func (x *AbandonActivityWorkItemResponse) String() string

+ type AbandonOrchestrationWorkItemRequest struct

+ CompletionToken string

+ func (*AbandonOrchestrationWorkItemRequest) Descriptor() ([]byte, []int)

+ func (*AbandonOrchestrationWorkItemRequest) ProtoMessage()

+ func (x *AbandonOrchestrationWorkItemRequest) GetCompletionToken() string

+ func (x *AbandonOrchestrationWorkItemRequest) ProtoReflect() protoreflect.Message

+ func (x *AbandonOrchestrationWorkItemRequest) Reset()

+ func (x *AbandonOrchestrationWorkItemRequest) String() string

+ type AbandonOrchestrationWorkItemResponse struct

+ func (*AbandonOrchestrationWorkItemResponse) Descriptor() ([]byte, []int)

+ func (*AbandonOrchestrationWorkItemResponse) ProtoMessage()

+ func (x *AbandonOrchestrationWorkItemResponse) ProtoReflect() protoreflect.Message

+ func (x *AbandonOrchestrationWorkItemResponse) Reset()

+ func (x *AbandonOrchestrationWorkItemResponse) String() string

+ type ActivityRequest struct

+ Input *wrapperspb.StringValue

+ Name string

+ OrchestrationInstance *OrchestrationInstance

+ ParentTraceContext *TraceContext

+ TaskId int32

+ Version *wrapperspb.StringValue

+ func (*ActivityRequest) Descriptor() ([]byte, []int)

+ func (*ActivityRequest) ProtoMessage()

+ func (x *ActivityRequest) GetInput() *wrapperspb.StringValue

+ func (x *ActivityRequest) GetName() string

+ func (x *ActivityRequest) GetOrchestrationInstance() *OrchestrationInstance

+ func (x *ActivityRequest) GetParentTraceContext() *TraceContext

+ func (x *ActivityRequest) GetTaskId() int32

+ func (x *ActivityRequest) GetVersion() *wrapperspb.StringValue

+ func (x *ActivityRequest) ProtoReflect() protoreflect.Message

+ func (x *ActivityRequest) Reset()

+ func (x *ActivityRequest) String() string

+ type ActivityResponse struct

+ FailureDetails *TaskFailureDetails

+ InstanceId string

+ Result *wrapperspb.StringValue

+ TaskId int32

+ func (*ActivityResponse) Descriptor() ([]byte, []int)

+ func (*ActivityResponse) ProtoMessage()

+ func (x *ActivityResponse) GetFailureDetails() *TaskFailureDetails

+ func (x *ActivityResponse) GetInstanceId() string

+ func (x *ActivityResponse) GetResult() *wrapperspb.StringValue

+ func (x *ActivityResponse) GetTaskId() int32

+ func (x *ActivityResponse) ProtoReflect() protoreflect.Message

+ func (x *ActivityResponse) Reset()

+ func (x *ActivityResponse) String() string

+ type AddEventRequest struct

+ Event *HistoryEvent

+ Instance *OrchestrationInstance

+ func (*AddEventRequest) Descriptor() ([]byte, []int)

+ func (*AddEventRequest) ProtoMessage()

+ func (x *AddEventRequest) GetEvent() *HistoryEvent

+ func (x *AddEventRequest) GetInstance() *OrchestrationInstance

+ func (x *AddEventRequest) ProtoReflect() protoreflect.Message

+ func (x *AddEventRequest) Reset()

+ func (x *AddEventRequest) String() string

+ type AddEventResponse struct

+ func (*AddEventResponse) Descriptor() ([]byte, []int)

+ func (*AddEventResponse) ProtoMessage()

+ func (x *AddEventResponse) ProtoReflect() protoreflect.Message

+ func (x *AddEventResponse) Reset()

+ func (x *AddEventResponse) String() string

+ type BackendServiceClient interface

+ AbandonActivityWorkItem func(ctx context.Context, in *AbandonActivityWorkItemRequest, ...) (*AbandonActivityWorkItemResponse, error)

+ AbandonOrchestrationWorkItem func(ctx context.Context, in *AbandonOrchestrationWorkItemRequest, ...) (*AbandonOrchestrationWorkItemResponse, error)

+ AddEvent func(ctx context.Context, in *AddEventRequest, opts ...grpc.CallOption) (*AddEventResponse, error)

+ CompleteActivityWorkItem func(ctx context.Context, in *CompleteActivityWorkItemRequest, ...) (*CompleteActivityWorkItemResponse, error)

+ CompleteOrchestrationWorkItem func(ctx context.Context, in *CompleteOrchestrationWorkItemRequest, ...) (*CompleteOrchestrationWorkItemResponse, error)

+ CreateInstance func(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)

+ GetInstance func(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)

+ GetOrchestrationRuntimeState func(ctx context.Context, in *GetOrchestrationRuntimeStateRequest, ...) (*GetOrchestrationRuntimeStateResponse, error)

+ GetWorkItems func(ctx context.Context, in *GetWorkItemsRequest, opts ...grpc.CallOption) (BackendService_GetWorkItemsClient, error)

+ Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)

+ PurgeInstances func(ctx context.Context, in *PurgeInstancesRequest, opts ...grpc.CallOption) (*PurgeInstancesResponse, error)

+ QueryInstances func(ctx context.Context, in *QueryInstancesRequest, opts ...grpc.CallOption) (*QueryInstancesResponse, error)

+ WaitForInstance func(ctx context.Context, in *WaitForInstanceRequest, opts ...grpc.CallOption) (*WaitForInstanceResponse, error)

+ func NewBackendServiceClient(cc grpc.ClientConnInterface) BackendServiceClient

+ type BackendServiceServer interface

+ AbandonActivityWorkItem func(context.Context, *AbandonActivityWorkItemRequest) (*AbandonActivityWorkItemResponse, error)

+ AbandonOrchestrationWorkItem func(context.Context, *AbandonOrchestrationWorkItemRequest) (*AbandonOrchestrationWorkItemResponse, error)

+ AddEvent func(context.Context, *AddEventRequest) (*AddEventResponse, error)

+ CompleteActivityWorkItem func(context.Context, *CompleteActivityWorkItemRequest) (*CompleteActivityWorkItemResponse, error)

+ CompleteOrchestrationWorkItem func(context.Context, *CompleteOrchestrationWorkItemRequest) (*CompleteOrchestrationWorkItemResponse, error)

+ CreateInstance func(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)

+ GetInstance func(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)

+ GetOrchestrationRuntimeState func(context.Context, *GetOrchestrationRuntimeStateRequest) (*GetOrchestrationRuntimeStateResponse, error)

+ GetWorkItems func(*GetWorkItemsRequest, BackendService_GetWorkItemsServer) error

+ Ping func(context.Context, *PingRequest) (*PingResponse, error)

+ PurgeInstances func(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)

+ QueryInstances func(context.Context, *QueryInstancesRequest) (*QueryInstancesResponse, error)

+ WaitForInstance func(context.Context, *WaitForInstanceRequest) (*WaitForInstanceResponse, error)

+ type BackendService_GetWorkItemsClient interface

+ Recv func() (*WorkItem, error)

+ type BackendService_GetWorkItemsServer interface

+ Send func(*WorkItem) error

+ type CleanEntityStorageRequest struct

+ ContinuationToken *wrapperspb.StringValue

+ ReleaseOrphanedLocks bool

+ RemoveEmptyEntities bool

+ func (*CleanEntityStorageRequest) Descriptor() ([]byte, []int)

+ func (*CleanEntityStorageRequest) ProtoMessage()

+ func (x *CleanEntityStorageRequest) GetContinuationToken() *wrapperspb.StringValue

+ func (x *CleanEntityStorageRequest) GetReleaseOrphanedLocks() bool

+ func (x *CleanEntityStorageRequest) GetRemoveEmptyEntities() bool

+ func (x *CleanEntityStorageRequest) ProtoReflect() protoreflect.Message

+ func (x *CleanEntityStorageRequest) Reset()

+ func (x *CleanEntityStorageRequest) String() string

+ type CleanEntityStorageResponse struct

+ ContinuationToken *wrapperspb.StringValue

+ EmptyEntitiesRemoved int32

+ OrphanedLocksReleased int32

+ func (*CleanEntityStorageResponse) Descriptor() ([]byte, []int)

+ func (*CleanEntityStorageResponse) ProtoMessage()

+ func (x *CleanEntityStorageResponse) GetContinuationToken() *wrapperspb.StringValue

+ func (x *CleanEntityStorageResponse) GetEmptyEntitiesRemoved() int32

+ func (x *CleanEntityStorageResponse) GetOrphanedLocksReleased() int32

+ func (x *CleanEntityStorageResponse) ProtoReflect() protoreflect.Message

+ func (x *CleanEntityStorageResponse) Reset()

+ func (x *CleanEntityStorageResponse) String() string

+ type CompleteActivityWorkItemRequest struct

+ CompletionToken string

+ ResponseEvent *HistoryEvent

+ func (*CompleteActivityWorkItemRequest) Descriptor() ([]byte, []int)

+ func (*CompleteActivityWorkItemRequest) ProtoMessage()

+ func (x *CompleteActivityWorkItemRequest) GetCompletionToken() string

+ func (x *CompleteActivityWorkItemRequest) GetResponseEvent() *HistoryEvent

+ func (x *CompleteActivityWorkItemRequest) ProtoReflect() protoreflect.Message

+ func (x *CompleteActivityWorkItemRequest) Reset()

+ func (x *CompleteActivityWorkItemRequest) String() string

+ type CompleteActivityWorkItemResponse struct

+ func (*CompleteActivityWorkItemResponse) Descriptor() ([]byte, []int)

+ func (*CompleteActivityWorkItemResponse) ProtoMessage()

+ func (x *CompleteActivityWorkItemResponse) ProtoReflect() protoreflect.Message

+ func (x *CompleteActivityWorkItemResponse) Reset()

+ func (x *CompleteActivityWorkItemResponse) String() string

+ type CompleteOrchestrationAction struct

+ CarryoverEvents []*HistoryEvent

+ Details *wrapperspb.StringValue

+ FailureDetails *TaskFailureDetails

+ NewVersion *wrapperspb.StringValue

+ OrchestrationStatus OrchestrationStatus

+ Result *wrapperspb.StringValue

+ func (*CompleteOrchestrationAction) Descriptor() ([]byte, []int)

+ func (*CompleteOrchestrationAction) ProtoMessage()

+ func (x *CompleteOrchestrationAction) GetCarryoverEvents() []*HistoryEvent

+ func (x *CompleteOrchestrationAction) GetDetails() *wrapperspb.StringValue

+ func (x *CompleteOrchestrationAction) GetFailureDetails() *TaskFailureDetails

+ func (x *CompleteOrchestrationAction) GetNewVersion() *wrapperspb.StringValue

+ func (x *CompleteOrchestrationAction) GetOrchestrationStatus() OrchestrationStatus

+ func (x *CompleteOrchestrationAction) GetResult() *wrapperspb.StringValue

+ func (x *CompleteOrchestrationAction) ProtoReflect() protoreflect.Message

+ func (x *CompleteOrchestrationAction) Reset()

+ func (x *CompleteOrchestrationAction) String() string

+ type CompleteOrchestrationWorkItemRequest struct

+ CompletionToken string

+ CustomStatus *wrapperspb.StringValue

+ NewExecutionId *wrapperspb.StringValue

+ NewHistory []*HistoryEvent

+ NewMessages []*OrchestratorMessage

+ NewTasks []*HistoryEvent

+ NewTimers []*HistoryEvent

+ RuntimeStatus OrchestrationStatus

+ func (*CompleteOrchestrationWorkItemRequest) Descriptor() ([]byte, []int)

+ func (*CompleteOrchestrationWorkItemRequest) ProtoMessage()

+ func (x *CompleteOrchestrationWorkItemRequest) GetCompletionToken() string

+ func (x *CompleteOrchestrationWorkItemRequest) GetCustomStatus() *wrapperspb.StringValue

+ func (x *CompleteOrchestrationWorkItemRequest) GetNewExecutionId() *wrapperspb.StringValue

+ func (x *CompleteOrchestrationWorkItemRequest) GetNewHistory() []*HistoryEvent

+ func (x *CompleteOrchestrationWorkItemRequest) GetNewMessages() []*OrchestratorMessage

+ func (x *CompleteOrchestrationWorkItemRequest) GetNewTasks() []*HistoryEvent

+ func (x *CompleteOrchestrationWorkItemRequest) GetNewTimers() []*HistoryEvent

+ func (x *CompleteOrchestrationWorkItemRequest) GetRuntimeStatus() OrchestrationStatus

+ func (x *CompleteOrchestrationWorkItemRequest) ProtoReflect() protoreflect.Message

+ func (x *CompleteOrchestrationWorkItemRequest) Reset()

+ func (x *CompleteOrchestrationWorkItemRequest) String() string

+ type CompleteOrchestrationWorkItemResponse struct

+ func (*CompleteOrchestrationWorkItemResponse) Descriptor() ([]byte, []int)

+ func (*CompleteOrchestrationWorkItemResponse) ProtoMessage()

+ func (x *CompleteOrchestrationWorkItemResponse) ProtoReflect() protoreflect.Message

+ func (x *CompleteOrchestrationWorkItemResponse) Reset()

+ func (x *CompleteOrchestrationWorkItemResponse) String() string

+ type CompleteTaskResponse struct

+ func (*CompleteTaskResponse) Descriptor() ([]byte, []int)

+ func (*CompleteTaskResponse) ProtoMessage()

+ func (x *CompleteTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *CompleteTaskResponse) Reset()

+ func (x *CompleteTaskResponse) String() string

+ type ContinueAsNewEvent struct

+ Input *wrapperspb.StringValue

+ func (*ContinueAsNewEvent) Descriptor() ([]byte, []int)

+ func (*ContinueAsNewEvent) ProtoMessage()

+ func (x *ContinueAsNewEvent) GetInput() *wrapperspb.StringValue

+ func (x *ContinueAsNewEvent) ProtoReflect() protoreflect.Message

+ func (x *ContinueAsNewEvent) Reset()

+ func (x *ContinueAsNewEvent) String() string

+ type CreateInstanceRequest struct

+ ExecutionId *wrapperspb.StringValue

+ Input *wrapperspb.StringValue

+ InstanceId string

+ Name string

+ OrchestrationIdReusePolicy *OrchestrationIdReusePolicy

+ ScheduledStartTimestamp *timestamppb.Timestamp

+ Tags map[string]string

+ Version *wrapperspb.StringValue

+ func (*CreateInstanceRequest) Descriptor() ([]byte, []int)

+ func (*CreateInstanceRequest) ProtoMessage()

+ 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) GetOrchestrationIdReusePolicy() *OrchestrationIdReusePolicy

+ func (x *CreateInstanceRequest) GetScheduledStartTimestamp() *timestamppb.Timestamp

+ func (x *CreateInstanceRequest) GetTags() map[string]string

+ func (x *CreateInstanceRequest) GetVersion() *wrapperspb.StringValue

+ func (x *CreateInstanceRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateInstanceRequest) Reset()

+ func (x *CreateInstanceRequest) String() string

+ type CreateInstanceResponse struct

+ InstanceId string

+ func (*CreateInstanceResponse) Descriptor() ([]byte, []int)

+ func (*CreateInstanceResponse) ProtoMessage()

+ func (x *CreateInstanceResponse) GetInstanceId() string

+ func (x *CreateInstanceResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateInstanceResponse) Reset()

+ func (x *CreateInstanceResponse) String() string

+ type CreateOrchestrationAction int32

+ const CreateOrchestrationAction_ERROR

+ const CreateOrchestrationAction_IGNORE

+ const CreateOrchestrationAction_TERMINATE

+ func (CreateOrchestrationAction) Descriptor() protoreflect.EnumDescriptor

+ func (CreateOrchestrationAction) EnumDescriptor() ([]byte, []int)

+ func (CreateOrchestrationAction) Type() protoreflect.EnumType

+ func (x CreateOrchestrationAction) Enum() *CreateOrchestrationAction

+ func (x CreateOrchestrationAction) Number() protoreflect.EnumNumber

+ func (x CreateOrchestrationAction) String() string

+ type CreateSubOrchestrationAction struct

+ Input *wrapperspb.StringValue

+ InstanceId string

+ Name string

+ Version *wrapperspb.StringValue

+ func (*CreateSubOrchestrationAction) Descriptor() ([]byte, []int)

+ func (*CreateSubOrchestrationAction) ProtoMessage()

+ func (x *CreateSubOrchestrationAction) GetInput() *wrapperspb.StringValue

+ func (x *CreateSubOrchestrationAction) GetInstanceId() string

+ func (x *CreateSubOrchestrationAction) GetName() string

+ func (x *CreateSubOrchestrationAction) GetVersion() *wrapperspb.StringValue

+ func (x *CreateSubOrchestrationAction) ProtoReflect() protoreflect.Message

+ func (x *CreateSubOrchestrationAction) Reset()

+ func (x *CreateSubOrchestrationAction) String() string

+ type CreateTaskHubRequest struct

+ RecreateIfExists bool

+ func (*CreateTaskHubRequest) Descriptor() ([]byte, []int)

+ func (*CreateTaskHubRequest) ProtoMessage()

+ func (x *CreateTaskHubRequest) GetRecreateIfExists() bool

+ func (x *CreateTaskHubRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateTaskHubRequest) Reset()

+ func (x *CreateTaskHubRequest) String() string

+ type CreateTaskHubResponse struct

+ func (*CreateTaskHubResponse) Descriptor() ([]byte, []int)

+ func (*CreateTaskHubResponse) ProtoMessage()

+ func (x *CreateTaskHubResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateTaskHubResponse) Reset()

+ func (x *CreateTaskHubResponse) String() string

+ type CreateTimerAction struct

+ FireAt *timestamppb.Timestamp

+ func (*CreateTimerAction) Descriptor() ([]byte, []int)

+ func (*CreateTimerAction) ProtoMessage()

+ func (x *CreateTimerAction) GetFireAt() *timestamppb.Timestamp

+ func (x *CreateTimerAction) ProtoReflect() protoreflect.Message

+ func (x *CreateTimerAction) Reset()

+ func (x *CreateTimerAction) String() string

+ type CreateWorkflowInstanceRequest struct

+ Policy *OrchestrationIdReusePolicy

+ StartEvent *HistoryEvent

+ func (*CreateWorkflowInstanceRequest) Descriptor() ([]byte, []int)

+ func (*CreateWorkflowInstanceRequest) ProtoMessage()

+ func (x *CreateWorkflowInstanceRequest) GetPolicy() *OrchestrationIdReusePolicy

+ func (x *CreateWorkflowInstanceRequest) GetStartEvent() *HistoryEvent

+ func (x *CreateWorkflowInstanceRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateWorkflowInstanceRequest) Reset()

+ func (x *CreateWorkflowInstanceRequest) String() string

+ type DeleteTaskHubRequest struct

+ func (*DeleteTaskHubRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTaskHubRequest) ProtoMessage()

+ func (x *DeleteTaskHubRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteTaskHubRequest) Reset()

+ func (x *DeleteTaskHubRequest) String() string

+ type DeleteTaskHubResponse struct

+ func (*DeleteTaskHubResponse) Descriptor() ([]byte, []int)

+ func (*DeleteTaskHubResponse) ProtoMessage()

+ func (x *DeleteTaskHubResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteTaskHubResponse) Reset()

+ func (x *DeleteTaskHubResponse) String() string

+ type DurableTimer struct

+ Generation uint64

+ TimerEvent *HistoryEvent

+ func (*DurableTimer) Descriptor() ([]byte, []int)

+ func (*DurableTimer) ProtoMessage()

+ func (x *DurableTimer) GetGeneration() uint64

+ func (x *DurableTimer) GetTimerEvent() *HistoryEvent

+ func (x *DurableTimer) ProtoReflect() protoreflect.Message

+ func (x *DurableTimer) Reset()

+ func (x *DurableTimer) String() string

+ type EntityBatchRequest struct

+ EntityState *wrapperspb.StringValue

+ InstanceId string

+ Operations []*OperationRequest

+ func (*EntityBatchRequest) Descriptor() ([]byte, []int)

+ func (*EntityBatchRequest) ProtoMessage()

+ func (x *EntityBatchRequest) GetEntityState() *wrapperspb.StringValue

+ func (x *EntityBatchRequest) GetInstanceId() string

+ func (x *EntityBatchRequest) GetOperations() []*OperationRequest

+ func (x *EntityBatchRequest) ProtoReflect() protoreflect.Message

+ func (x *EntityBatchRequest) Reset()

+ func (x *EntityBatchRequest) String() string

+ type EntityBatchResult struct

+ Actions []*OperationAction

+ EntityState *wrapperspb.StringValue

+ FailureDetails *TaskFailureDetails

+ Results []*OperationResult

+ func (*EntityBatchResult) Descriptor() ([]byte, []int)

+ func (*EntityBatchResult) ProtoMessage()

+ func (x *EntityBatchResult) GetActions() []*OperationAction

+ func (x *EntityBatchResult) GetEntityState() *wrapperspb.StringValue

+ func (x *EntityBatchResult) GetFailureDetails() *TaskFailureDetails

+ func (x *EntityBatchResult) GetResults() []*OperationResult

+ func (x *EntityBatchResult) ProtoReflect() protoreflect.Message

+ func (x *EntityBatchResult) Reset()

+ func (x *EntityBatchResult) String() string

+ type EntityMetadata struct

+ BacklogQueueSize int32

+ InstanceId string

+ LastModifiedTime *timestamppb.Timestamp

+ LockedBy *wrapperspb.StringValue

+ SerializedState *wrapperspb.StringValue

+ func (*EntityMetadata) Descriptor() ([]byte, []int)

+ func (*EntityMetadata) ProtoMessage()

+ func (x *EntityMetadata) GetBacklogQueueSize() int32

+ func (x *EntityMetadata) GetInstanceId() string

+ func (x *EntityMetadata) GetLastModifiedTime() *timestamppb.Timestamp

+ func (x *EntityMetadata) GetLockedBy() *wrapperspb.StringValue

+ func (x *EntityMetadata) GetSerializedState() *wrapperspb.StringValue

+ func (x *EntityMetadata) ProtoReflect() protoreflect.Message

+ func (x *EntityMetadata) Reset()

+ func (x *EntityMetadata) String() string

+ type EntityQuery struct

+ ContinuationToken *wrapperspb.StringValue

+ IncludeState bool

+ IncludeTransient bool

+ InstanceIdStartsWith *wrapperspb.StringValue

+ LastModifiedFrom *timestamppb.Timestamp

+ LastModifiedTo *timestamppb.Timestamp

+ PageSize *wrapperspb.Int32Value

+ func (*EntityQuery) Descriptor() ([]byte, []int)

+ func (*EntityQuery) ProtoMessage()

+ func (x *EntityQuery) GetContinuationToken() *wrapperspb.StringValue

+ func (x *EntityQuery) GetIncludeState() bool

+ func (x *EntityQuery) GetIncludeTransient() bool

+ func (x *EntityQuery) GetInstanceIdStartsWith() *wrapperspb.StringValue

+ func (x *EntityQuery) GetLastModifiedFrom() *timestamppb.Timestamp

+ func (x *EntityQuery) GetLastModifiedTo() *timestamppb.Timestamp

+ func (x *EntityQuery) GetPageSize() *wrapperspb.Int32Value

+ func (x *EntityQuery) ProtoReflect() protoreflect.Message

+ func (x *EntityQuery) Reset()

+ func (x *EntityQuery) String() string

+ type EventRaisedEvent struct

+ Input *wrapperspb.StringValue

+ Name string

+ func (*EventRaisedEvent) Descriptor() ([]byte, []int)

+ func (*EventRaisedEvent) ProtoMessage()

+ func (x *EventRaisedEvent) GetInput() *wrapperspb.StringValue

+ func (x *EventRaisedEvent) GetName() string

+ func (x *EventRaisedEvent) ProtoReflect() protoreflect.Message

+ func (x *EventRaisedEvent) Reset()

+ func (x *EventRaisedEvent) String() string

+ type EventSentEvent struct

+ Input *wrapperspb.StringValue

+ InstanceId string

+ Name string

+ func (*EventSentEvent) Descriptor() ([]byte, []int)

+ func (*EventSentEvent) ProtoMessage()

+ func (x *EventSentEvent) GetInput() *wrapperspb.StringValue

+ func (x *EventSentEvent) GetInstanceId() string

+ func (x *EventSentEvent) GetName() string

+ func (x *EventSentEvent) ProtoReflect() protoreflect.Message

+ func (x *EventSentEvent) Reset()

+ func (x *EventSentEvent) String() string

+ type ExecutionCompletedEvent struct

+ FailureDetails *TaskFailureDetails

+ OrchestrationStatus OrchestrationStatus

+ Result *wrapperspb.StringValue

+ func (*ExecutionCompletedEvent) Descriptor() ([]byte, []int)

+ func (*ExecutionCompletedEvent) ProtoMessage()

+ func (x *ExecutionCompletedEvent) GetFailureDetails() *TaskFailureDetails

+ func (x *ExecutionCompletedEvent) GetOrchestrationStatus() OrchestrationStatus

+ func (x *ExecutionCompletedEvent) GetResult() *wrapperspb.StringValue

+ func (x *ExecutionCompletedEvent) ProtoReflect() protoreflect.Message

+ func (x *ExecutionCompletedEvent) Reset()

+ func (x *ExecutionCompletedEvent) String() string

+ type ExecutionResumedEvent struct

+ Input *wrapperspb.StringValue

+ func (*ExecutionResumedEvent) Descriptor() ([]byte, []int)

+ func (*ExecutionResumedEvent) ProtoMessage()

+ func (x *ExecutionResumedEvent) GetInput() *wrapperspb.StringValue

+ func (x *ExecutionResumedEvent) ProtoReflect() protoreflect.Message

+ func (x *ExecutionResumedEvent) Reset()

+ func (x *ExecutionResumedEvent) String() string

+ type ExecutionStartedEvent struct

+ Input *wrapperspb.StringValue

+ Name string

+ OrchestrationInstance *OrchestrationInstance

+ OrchestrationSpanID *wrapperspb.StringValue

+ ParentInstance *ParentInstanceInfo

+ ParentTraceContext *TraceContext

+ ScheduledStartTimestamp *timestamppb.Timestamp

+ Version *wrapperspb.StringValue

+ func (*ExecutionStartedEvent) Descriptor() ([]byte, []int)

+ func (*ExecutionStartedEvent) ProtoMessage()

+ func (x *ExecutionStartedEvent) GetInput() *wrapperspb.StringValue

+ func (x *ExecutionStartedEvent) GetName() string

+ func (x *ExecutionStartedEvent) GetOrchestrationInstance() *OrchestrationInstance

+ func (x *ExecutionStartedEvent) GetOrchestrationSpanID() *wrapperspb.StringValue

+ func (x *ExecutionStartedEvent) GetParentInstance() *ParentInstanceInfo

+ func (x *ExecutionStartedEvent) GetParentTraceContext() *TraceContext

+ func (x *ExecutionStartedEvent) GetScheduledStartTimestamp() *timestamppb.Timestamp

+ func (x *ExecutionStartedEvent) GetVersion() *wrapperspb.StringValue

+ func (x *ExecutionStartedEvent) ProtoReflect() protoreflect.Message

+ func (x *ExecutionStartedEvent) Reset()

+ func (x *ExecutionStartedEvent) String() string

+ type ExecutionSuspendedEvent struct

+ Input *wrapperspb.StringValue

+ func (*ExecutionSuspendedEvent) Descriptor() ([]byte, []int)

+ func (*ExecutionSuspendedEvent) ProtoMessage()

+ func (x *ExecutionSuspendedEvent) GetInput() *wrapperspb.StringValue

+ func (x *ExecutionSuspendedEvent) ProtoReflect() protoreflect.Message

+ func (x *ExecutionSuspendedEvent) Reset()

+ func (x *ExecutionSuspendedEvent) String() string

+ type ExecutionTerminatedEvent struct

+ Input *wrapperspb.StringValue

+ Recurse bool

+ func (*ExecutionTerminatedEvent) Descriptor() ([]byte, []int)

+ func (*ExecutionTerminatedEvent) ProtoMessage()

+ func (x *ExecutionTerminatedEvent) GetInput() *wrapperspb.StringValue

+ func (x *ExecutionTerminatedEvent) GetRecurse() bool

+ func (x *ExecutionTerminatedEvent) ProtoReflect() protoreflect.Message

+ func (x *ExecutionTerminatedEvent) Reset()

+ func (x *ExecutionTerminatedEvent) String() string

+ type GenericEvent struct

+ Data *wrapperspb.StringValue

+ func (*GenericEvent) Descriptor() ([]byte, []int)

+ func (*GenericEvent) ProtoMessage()

+ func (x *GenericEvent) GetData() *wrapperspb.StringValue

+ func (x *GenericEvent) ProtoReflect() protoreflect.Message

+ func (x *GenericEvent) Reset()

+ func (x *GenericEvent) String() string

+ type GetEntityRequest struct

+ IncludeState bool

+ InstanceId string

+ func (*GetEntityRequest) Descriptor() ([]byte, []int)

+ func (*GetEntityRequest) ProtoMessage()

+ func (x *GetEntityRequest) GetIncludeState() bool

+ func (x *GetEntityRequest) GetInstanceId() string

+ func (x *GetEntityRequest) ProtoReflect() protoreflect.Message

+ func (x *GetEntityRequest) Reset()

+ func (x *GetEntityRequest) String() string

+ type GetEntityResponse struct

+ Entity *EntityMetadata

+ Exists bool

+ func (*GetEntityResponse) Descriptor() ([]byte, []int)

+ func (*GetEntityResponse) ProtoMessage()

+ func (x *GetEntityResponse) GetEntity() *EntityMetadata

+ func (x *GetEntityResponse) GetExists() bool

+ func (x *GetEntityResponse) ProtoReflect() protoreflect.Message

+ func (x *GetEntityResponse) Reset()

+ func (x *GetEntityResponse) String() string

+ type GetInstanceRequest struct

+ GetInputsAndOutputs bool

+ InstanceId string

+ func (*GetInstanceRequest) Descriptor() ([]byte, []int)

+ func (*GetInstanceRequest) ProtoMessage()

+ func (x *GetInstanceRequest) GetGetInputsAndOutputs() bool

+ func (x *GetInstanceRequest) GetInstanceId() string

+ func (x *GetInstanceRequest) ProtoReflect() protoreflect.Message

+ func (x *GetInstanceRequest) Reset()

+ func (x *GetInstanceRequest) String() string

+ type GetInstanceResponse struct

+ Exists bool

+ OrchestrationState *OrchestrationState

+ func (*GetInstanceResponse) Descriptor() ([]byte, []int)

+ func (*GetInstanceResponse) ProtoMessage()

+ func (x *GetInstanceResponse) GetExists() bool

+ func (x *GetInstanceResponse) GetOrchestrationState() *OrchestrationState

+ func (x *GetInstanceResponse) ProtoReflect() protoreflect.Message

+ func (x *GetInstanceResponse) Reset()

+ func (x *GetInstanceResponse) String() string

+ type GetOrchestrationRuntimeStateRequest struct

+ Instance *OrchestrationInstance

+ func (*GetOrchestrationRuntimeStateRequest) Descriptor() ([]byte, []int)

+ func (*GetOrchestrationRuntimeStateRequest) ProtoMessage()

+ func (x *GetOrchestrationRuntimeStateRequest) GetInstance() *OrchestrationInstance

+ func (x *GetOrchestrationRuntimeStateRequest) ProtoReflect() protoreflect.Message

+ func (x *GetOrchestrationRuntimeStateRequest) Reset()

+ func (x *GetOrchestrationRuntimeStateRequest) String() string

+ type GetOrchestrationRuntimeStateResponse struct

+ History []*HistoryEvent

+ func (*GetOrchestrationRuntimeStateResponse) Descriptor() ([]byte, []int)

+ func (*GetOrchestrationRuntimeStateResponse) ProtoMessage()

+ func (x *GetOrchestrationRuntimeStateResponse) GetHistory() []*HistoryEvent

+ func (x *GetOrchestrationRuntimeStateResponse) ProtoReflect() protoreflect.Message

+ func (x *GetOrchestrationRuntimeStateResponse) Reset()

+ func (x *GetOrchestrationRuntimeStateResponse) String() string

+ type GetWorkItemsRequest struct

+ func (*GetWorkItemsRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkItemsRequest) ProtoMessage()

+ func (x *GetWorkItemsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetWorkItemsRequest) Reset()

+ func (x *GetWorkItemsRequest) String() string

+ type HealthPing struct

+ func (*HealthPing) Descriptor() ([]byte, []int)

+ func (*HealthPing) ProtoMessage()

+ func (x *HealthPing) ProtoReflect() protoreflect.Message

+ func (x *HealthPing) Reset()

+ func (x *HealthPing) String() string

+ type HistoryEvent struct

+ EventId int32

+ EventType isHistoryEvent_EventType

+ Timestamp *timestamppb.Timestamp

+ func (*HistoryEvent) Descriptor() ([]byte, []int)

+ func (*HistoryEvent) ProtoMessage()

+ func (m *HistoryEvent) GetEventType() isHistoryEvent_EventType

+ func (x *HistoryEvent) GetContinueAsNew() *ContinueAsNewEvent

+ func (x *HistoryEvent) GetEventId() int32

+ func (x *HistoryEvent) GetEventRaised() *EventRaisedEvent

+ func (x *HistoryEvent) GetEventSent() *EventSentEvent

+ func (x *HistoryEvent) GetExecutionCompleted() *ExecutionCompletedEvent

+ func (x *HistoryEvent) GetExecutionResumed() *ExecutionResumedEvent

+ func (x *HistoryEvent) GetExecutionStarted() *ExecutionStartedEvent

+ func (x *HistoryEvent) GetExecutionSuspended() *ExecutionSuspendedEvent

+ func (x *HistoryEvent) GetExecutionTerminated() *ExecutionTerminatedEvent

+ func (x *HistoryEvent) GetGenericEvent() *GenericEvent

+ func (x *HistoryEvent) GetHistoryState() *HistoryStateEvent

+ func (x *HistoryEvent) GetOrchestratorCompleted() *OrchestratorCompletedEvent

+ func (x *HistoryEvent) GetOrchestratorStarted() *OrchestratorStartedEvent

+ func (x *HistoryEvent) GetSubOrchestrationInstanceCompleted() *SubOrchestrationInstanceCompletedEvent

+ func (x *HistoryEvent) GetSubOrchestrationInstanceCreated() *SubOrchestrationInstanceCreatedEvent

+ func (x *HistoryEvent) GetSubOrchestrationInstanceFailed() *SubOrchestrationInstanceFailedEvent

+ 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) ProtoReflect() protoreflect.Message

+ func (x *HistoryEvent) Reset()

+ func (x *HistoryEvent) String() string

+ type HistoryEvent_ContinueAsNew struct

+ ContinueAsNew *ContinueAsNewEvent

+ type HistoryEvent_EventRaised struct

+ EventRaised *EventRaisedEvent

+ type HistoryEvent_EventSent struct

+ EventSent *EventSentEvent

+ type HistoryEvent_ExecutionCompleted struct

+ ExecutionCompleted *ExecutionCompletedEvent

+ type HistoryEvent_ExecutionResumed struct

+ ExecutionResumed *ExecutionResumedEvent

+ type HistoryEvent_ExecutionStarted struct

+ ExecutionStarted *ExecutionStartedEvent

+ type HistoryEvent_ExecutionSuspended struct

+ ExecutionSuspended *ExecutionSuspendedEvent

+ type HistoryEvent_ExecutionTerminated struct

+ ExecutionTerminated *ExecutionTerminatedEvent

+ type HistoryEvent_GenericEvent struct

+ GenericEvent *GenericEvent

+ type HistoryEvent_HistoryState struct

+ HistoryState *HistoryStateEvent

+ type HistoryEvent_OrchestratorCompleted struct

+ OrchestratorCompleted *OrchestratorCompletedEvent

+ type HistoryEvent_OrchestratorStarted struct

+ OrchestratorStarted *OrchestratorStartedEvent

+ type HistoryEvent_SubOrchestrationInstanceCompleted struct

+ SubOrchestrationInstanceCompleted *SubOrchestrationInstanceCompletedEvent

+ type HistoryEvent_SubOrchestrationInstanceCreated struct

+ SubOrchestrationInstanceCreated *SubOrchestrationInstanceCreatedEvent

+ type HistoryEvent_SubOrchestrationInstanceFailed struct

+ SubOrchestrationInstanceFailed *SubOrchestrationInstanceFailedEvent

+ type HistoryEvent_TaskCompleted struct

+ TaskCompleted *TaskCompletedEvent

+ type HistoryEvent_TaskFailed struct

+ TaskFailed *TaskFailedEvent

+ type HistoryEvent_TaskScheduled struct

+ TaskScheduled *TaskScheduledEvent

+ type HistoryEvent_TimerCreated struct

+ TimerCreated *TimerCreatedEvent

+ type HistoryEvent_TimerFired struct

+ TimerFired *TimerFiredEvent

+ type HistoryStateEvent struct

+ OrchestrationState *OrchestrationState

+ func (*HistoryStateEvent) Descriptor() ([]byte, []int)

+ func (*HistoryStateEvent) ProtoMessage()

+ func (x *HistoryStateEvent) GetOrchestrationState() *OrchestrationState

+ func (x *HistoryStateEvent) ProtoReflect() protoreflect.Message

+ func (x *HistoryStateEvent) Reset()

+ func (x *HistoryStateEvent) String() string

+ type InstanceQuery struct

+ ContinuationToken *wrapperspb.StringValue

+ CreatedTimeFrom *timestamppb.Timestamp

+ CreatedTimeTo *timestamppb.Timestamp

+ FetchInputsAndOutputs bool

+ InstanceIdPrefix *wrapperspb.StringValue

+ MaxInstanceCount int32

+ RuntimeStatus []OrchestrationStatus

+ TaskHubNames []*wrapperspb.StringValue

+ func (*InstanceQuery) Descriptor() ([]byte, []int)

+ func (*InstanceQuery) ProtoMessage()

+ func (x *InstanceQuery) GetContinuationToken() *wrapperspb.StringValue

+ func (x *InstanceQuery) GetCreatedTimeFrom() *timestamppb.Timestamp

+ func (x *InstanceQuery) GetCreatedTimeTo() *timestamppb.Timestamp

+ func (x *InstanceQuery) GetFetchInputsAndOutputs() bool

+ func (x *InstanceQuery) GetInstanceIdPrefix() *wrapperspb.StringValue

+ func (x *InstanceQuery) GetMaxInstanceCount() int32

+ func (x *InstanceQuery) GetRuntimeStatus() []OrchestrationStatus

+ func (x *InstanceQuery) GetTaskHubNames() []*wrapperspb.StringValue

+ func (x *InstanceQuery) ProtoReflect() protoreflect.Message

+ func (x *InstanceQuery) Reset()

+ func (x *InstanceQuery) String() string

+ type OperationAction struct

+ Id int32

+ OperationActionType isOperationAction_OperationActionType

+ func (*OperationAction) Descriptor() ([]byte, []int)

+ func (*OperationAction) ProtoMessage()

+ func (m *OperationAction) GetOperationActionType() isOperationAction_OperationActionType

+ func (x *OperationAction) GetId() int32

+ func (x *OperationAction) GetSendSignal() *SendSignalAction

+ func (x *OperationAction) GetStartNewOrchestration() *StartNewOrchestrationAction

+ func (x *OperationAction) ProtoReflect() protoreflect.Message

+ func (x *OperationAction) Reset()

+ func (x *OperationAction) String() string

+ type OperationAction_SendSignal struct

+ SendSignal *SendSignalAction

+ type OperationAction_StartNewOrchestration struct

+ StartNewOrchestration *StartNewOrchestrationAction

+ type OperationRequest struct

+ Input *wrapperspb.StringValue

+ Operation string

+ RequestId string

+ func (*OperationRequest) Descriptor() ([]byte, []int)

+ func (*OperationRequest) ProtoMessage()

+ func (x *OperationRequest) GetInput() *wrapperspb.StringValue

+ func (x *OperationRequest) GetOperation() string

+ func (x *OperationRequest) GetRequestId() string

+ func (x *OperationRequest) ProtoReflect() protoreflect.Message

+ func (x *OperationRequest) Reset()

+ func (x *OperationRequest) String() string

+ type OperationResult struct

+ ResultType isOperationResult_ResultType

+ func (*OperationResult) Descriptor() ([]byte, []int)

+ func (*OperationResult) ProtoMessage()

+ func (m *OperationResult) GetResultType() isOperationResult_ResultType

+ func (x *OperationResult) GetFailure() *OperationResultFailure

+ func (x *OperationResult) GetSuccess() *OperationResultSuccess

+ func (x *OperationResult) ProtoReflect() protoreflect.Message

+ func (x *OperationResult) Reset()

+ func (x *OperationResult) String() string

+ type OperationResultFailure struct

+ FailureDetails *TaskFailureDetails

+ func (*OperationResultFailure) Descriptor() ([]byte, []int)

+ func (*OperationResultFailure) ProtoMessage()

+ func (x *OperationResultFailure) GetFailureDetails() *TaskFailureDetails

+ func (x *OperationResultFailure) ProtoReflect() protoreflect.Message

+ func (x *OperationResultFailure) Reset()

+ func (x *OperationResultFailure) String() string

+ type OperationResultSuccess struct

+ Result *wrapperspb.StringValue

+ func (*OperationResultSuccess) Descriptor() ([]byte, []int)

+ func (*OperationResultSuccess) ProtoMessage()

+ func (x *OperationResultSuccess) GetResult() *wrapperspb.StringValue

+ func (x *OperationResultSuccess) ProtoReflect() protoreflect.Message

+ func (x *OperationResultSuccess) Reset()

+ func (x *OperationResultSuccess) String() string

+ type OperationResult_Failure struct

+ Failure *OperationResultFailure

+ type OperationResult_Success struct

+ Success *OperationResultSuccess

+ type OrchestrationIdReusePolicy struct

+ Action CreateOrchestrationAction

+ OperationStatus []OrchestrationStatus

+ func (*OrchestrationIdReusePolicy) Descriptor() ([]byte, []int)

+ func (*OrchestrationIdReusePolicy) ProtoMessage()

+ func (x *OrchestrationIdReusePolicy) GetAction() CreateOrchestrationAction

+ func (x *OrchestrationIdReusePolicy) GetOperationStatus() []OrchestrationStatus

+ func (x *OrchestrationIdReusePolicy) ProtoReflect() protoreflect.Message

+ func (x *OrchestrationIdReusePolicy) Reset()

+ func (x *OrchestrationIdReusePolicy) String() string

+ type OrchestrationInstance struct

+ ExecutionId *wrapperspb.StringValue

+ InstanceId string

+ func (*OrchestrationInstance) Descriptor() ([]byte, []int)

+ func (*OrchestrationInstance) ProtoMessage()

+ func (x *OrchestrationInstance) GetExecutionId() *wrapperspb.StringValue

+ func (x *OrchestrationInstance) GetInstanceId() string

+ func (x *OrchestrationInstance) ProtoReflect() protoreflect.Message

+ func (x *OrchestrationInstance) Reset()

+ func (x *OrchestrationInstance) String() string

+ type OrchestrationMetadata struct

+ CreatedAt *timestamppb.Timestamp

+ CustomStatus *wrapperspb.StringValue

+ FailureDetails *TaskFailureDetails

+ Input *wrapperspb.StringValue

+ InstanceId string

+ LastUpdatedAt *timestamppb.Timestamp

+ Name string

+ Output *wrapperspb.StringValue

+ RuntimeStatus OrchestrationStatus

+ func (*OrchestrationMetadata) Descriptor() ([]byte, []int)

+ func (*OrchestrationMetadata) ProtoMessage()

+ func (x *OrchestrationMetadata) GetCreatedAt() *timestamppb.Timestamp

+ func (x *OrchestrationMetadata) GetCustomStatus() *wrapperspb.StringValue

+ func (x *OrchestrationMetadata) GetFailureDetails() *TaskFailureDetails

+ func (x *OrchestrationMetadata) GetInput() *wrapperspb.StringValue

+ func (x *OrchestrationMetadata) GetInstanceId() string

+ func (x *OrchestrationMetadata) GetLastUpdatedAt() *timestamppb.Timestamp

+ func (x *OrchestrationMetadata) GetName() string

+ func (x *OrchestrationMetadata) GetOutput() *wrapperspb.StringValue

+ func (x *OrchestrationMetadata) GetRuntimeStatus() OrchestrationStatus

+ func (x *OrchestrationMetadata) ProtoReflect() protoreflect.Message

+ func (x *OrchestrationMetadata) Reset()

+ func (x *OrchestrationMetadata) String() string

+ type OrchestrationRuntimeState struct

+ CompletedEvent *ExecutionCompletedEvent

+ CompletedTime *timestamppb.Timestamp

+ ContinuedAsNew bool

+ CreatedTime *timestamppb.Timestamp

+ CustomStatus *wrapperspb.StringValue

+ InstanceId string

+ IsSuspended bool

+ LastUpdatedTime *timestamppb.Timestamp

+ NewEvents []*HistoryEvent

+ OldEvents []*HistoryEvent

+ PendingMessages []*OrchestrationRuntimeStateMessage

+ PendingTasks []*HistoryEvent

+ PendingTimers []*HistoryEvent

+ StartEvent *ExecutionStartedEvent

+ func (*OrchestrationRuntimeState) Descriptor() ([]byte, []int)

+ func (*OrchestrationRuntimeState) ProtoMessage()

+ func (x *OrchestrationRuntimeState) GetCompletedEvent() *ExecutionCompletedEvent

+ func (x *OrchestrationRuntimeState) GetCompletedTime() *timestamppb.Timestamp

+ func (x *OrchestrationRuntimeState) GetContinuedAsNew() bool

+ func (x *OrchestrationRuntimeState) GetCreatedTime() *timestamppb.Timestamp

+ func (x *OrchestrationRuntimeState) GetCustomStatus() *wrapperspb.StringValue

+ func (x *OrchestrationRuntimeState) GetInstanceId() string

+ func (x *OrchestrationRuntimeState) GetIsSuspended() bool

+ func (x *OrchestrationRuntimeState) GetLastUpdatedTime() *timestamppb.Timestamp

+ func (x *OrchestrationRuntimeState) GetNewEvents() []*HistoryEvent

+ func (x *OrchestrationRuntimeState) GetOldEvents() []*HistoryEvent

+ func (x *OrchestrationRuntimeState) GetPendingMessages() []*OrchestrationRuntimeStateMessage

+ func (x *OrchestrationRuntimeState) GetPendingTasks() []*HistoryEvent

+ func (x *OrchestrationRuntimeState) GetPendingTimers() []*HistoryEvent

+ func (x *OrchestrationRuntimeState) GetStartEvent() *ExecutionStartedEvent

+ func (x *OrchestrationRuntimeState) ProtoReflect() protoreflect.Message

+ func (x *OrchestrationRuntimeState) Reset()

+ func (x *OrchestrationRuntimeState) String() string

+ type OrchestrationRuntimeStateMessage struct

+ HistoryEvent *HistoryEvent

+ TargetInstanceID string

+ func (*OrchestrationRuntimeStateMessage) Descriptor() ([]byte, []int)

+ func (*OrchestrationRuntimeStateMessage) ProtoMessage()

+ func (x *OrchestrationRuntimeStateMessage) GetHistoryEvent() *HistoryEvent

+ func (x *OrchestrationRuntimeStateMessage) GetTargetInstanceID() string

+ func (x *OrchestrationRuntimeStateMessage) ProtoReflect() protoreflect.Message

+ func (x *OrchestrationRuntimeStateMessage) Reset()

+ func (x *OrchestrationRuntimeStateMessage) String() string

+ type OrchestrationState struct

+ CompletedTimestamp *timestamppb.Timestamp

+ CreatedTimestamp *timestamppb.Timestamp

+ CustomStatus *wrapperspb.StringValue

+ ExecutionId *wrapperspb.StringValue

+ FailureDetails *TaskFailureDetails

+ Input *wrapperspb.StringValue

+ InstanceId string

+ LastUpdatedTimestamp *timestamppb.Timestamp

+ Name string

+ OrchestrationStatus OrchestrationStatus

+ Output *wrapperspb.StringValue

+ ParentInstanceId *wrapperspb.StringValue

+ ScheduledStartTimestamp *timestamppb.Timestamp

+ Version *wrapperspb.StringValue

+ func (*OrchestrationState) Descriptor() ([]byte, []int)

+ func (*OrchestrationState) ProtoMessage()

+ func (x *OrchestrationState) GetCompletedTimestamp() *timestamppb.Timestamp

+ func (x *OrchestrationState) GetCreatedTimestamp() *timestamppb.Timestamp

+ func (x *OrchestrationState) GetCustomStatus() *wrapperspb.StringValue

+ func (x *OrchestrationState) GetExecutionId() *wrapperspb.StringValue

+ func (x *OrchestrationState) GetFailureDetails() *TaskFailureDetails

+ func (x *OrchestrationState) GetInput() *wrapperspb.StringValue

+ func (x *OrchestrationState) GetInstanceId() string

+ func (x *OrchestrationState) GetLastUpdatedTimestamp() *timestamppb.Timestamp

+ func (x *OrchestrationState) GetName() string

+ func (x *OrchestrationState) GetOrchestrationStatus() OrchestrationStatus

+ func (x *OrchestrationState) GetOutput() *wrapperspb.StringValue

+ func (x *OrchestrationState) GetParentInstanceId() *wrapperspb.StringValue

+ func (x *OrchestrationState) GetScheduledStartTimestamp() *timestamppb.Timestamp

+ func (x *OrchestrationState) GetVersion() *wrapperspb.StringValue

+ func (x *OrchestrationState) ProtoReflect() protoreflect.Message

+ func (x *OrchestrationState) Reset()

+ func (x *OrchestrationState) String() string

+ type OrchestrationStatus int32

+ const OrchestrationStatus_ORCHESTRATION_STATUS_CANCELED

+ const OrchestrationStatus_ORCHESTRATION_STATUS_COMPLETED

+ const OrchestrationStatus_ORCHESTRATION_STATUS_CONTINUED_AS_NEW

+ const OrchestrationStatus_ORCHESTRATION_STATUS_FAILED

+ const OrchestrationStatus_ORCHESTRATION_STATUS_PENDING

+ const OrchestrationStatus_ORCHESTRATION_STATUS_RUNNING

+ const OrchestrationStatus_ORCHESTRATION_STATUS_SUSPENDED

+ const OrchestrationStatus_ORCHESTRATION_STATUS_TERMINATED

+ func (OrchestrationStatus) Descriptor() protoreflect.EnumDescriptor

+ func (OrchestrationStatus) EnumDescriptor() ([]byte, []int)

+ func (OrchestrationStatus) Type() protoreflect.EnumType

+ func (x OrchestrationStatus) Enum() *OrchestrationStatus

+ func (x OrchestrationStatus) Number() protoreflect.EnumNumber

+ func (x OrchestrationStatus) String() string

+ type OrchestratorAction struct

+ Id int32

+ OrchestratorActionType isOrchestratorAction_OrchestratorActionType

+ func (*OrchestratorAction) Descriptor() ([]byte, []int)

+ func (*OrchestratorAction) ProtoMessage()

+ func (m *OrchestratorAction) GetOrchestratorActionType() isOrchestratorAction_OrchestratorActionType

+ func (x *OrchestratorAction) GetCompleteOrchestration() *CompleteOrchestrationAction

+ func (x *OrchestratorAction) GetCreateSubOrchestration() *CreateSubOrchestrationAction

+ func (x *OrchestratorAction) GetCreateTimer() *CreateTimerAction

+ func (x *OrchestratorAction) GetId() int32

+ func (x *OrchestratorAction) GetScheduleTask() *ScheduleTaskAction

+ func (x *OrchestratorAction) GetSendEvent() *SendEventAction

+ func (x *OrchestratorAction) GetTerminateOrchestration() *TerminateOrchestrationAction

+ func (x *OrchestratorAction) ProtoReflect() protoreflect.Message

+ func (x *OrchestratorAction) Reset()

+ func (x *OrchestratorAction) String() string

+ type OrchestratorAction_CompleteOrchestration struct

+ CompleteOrchestration *CompleteOrchestrationAction

+ type OrchestratorAction_CreateSubOrchestration struct

+ CreateSubOrchestration *CreateSubOrchestrationAction

+ type OrchestratorAction_CreateTimer struct

+ CreateTimer *CreateTimerAction

+ type OrchestratorAction_ScheduleTask struct

+ ScheduleTask *ScheduleTaskAction

+ type OrchestratorAction_SendEvent struct

+ SendEvent *SendEventAction

+ type OrchestratorAction_TerminateOrchestration struct

+ TerminateOrchestration *TerminateOrchestrationAction

+ type OrchestratorCompletedEvent struct

+ func (*OrchestratorCompletedEvent) Descriptor() ([]byte, []int)

+ func (*OrchestratorCompletedEvent) ProtoMessage()

+ func (x *OrchestratorCompletedEvent) ProtoReflect() protoreflect.Message

+ func (x *OrchestratorCompletedEvent) Reset()

+ func (x *OrchestratorCompletedEvent) String() string

+ type OrchestratorEntityParameters struct

+ EntityMessageReorderWindow *durationpb.Duration

+ func (*OrchestratorEntityParameters) Descriptor() ([]byte, []int)

+ func (*OrchestratorEntityParameters) ProtoMessage()

+ func (x *OrchestratorEntityParameters) GetEntityMessageReorderWindow() *durationpb.Duration

+ func (x *OrchestratorEntityParameters) ProtoReflect() protoreflect.Message

+ func (x *OrchestratorEntityParameters) Reset()

+ func (x *OrchestratorEntityParameters) String() string

+ type OrchestratorMessage struct

+ Event *HistoryEvent

+ Instance *OrchestrationInstance

+ func (*OrchestratorMessage) Descriptor() ([]byte, []int)

+ func (*OrchestratorMessage) ProtoMessage()

+ func (x *OrchestratorMessage) GetEvent() *HistoryEvent

+ func (x *OrchestratorMessage) GetInstance() *OrchestrationInstance

+ func (x *OrchestratorMessage) ProtoReflect() protoreflect.Message

+ func (x *OrchestratorMessage) Reset()

+ func (x *OrchestratorMessage) String() string

+ type OrchestratorRequest struct

+ EntityParameters *OrchestratorEntityParameters

+ ExecutionId *wrapperspb.StringValue

+ InstanceId string

+ NewEvents []*HistoryEvent

+ PastEvents []*HistoryEvent

+ func (*OrchestratorRequest) Descriptor() ([]byte, []int)

+ func (*OrchestratorRequest) ProtoMessage()

+ func (x *OrchestratorRequest) GetEntityParameters() *OrchestratorEntityParameters

+ func (x *OrchestratorRequest) GetExecutionId() *wrapperspb.StringValue

+ func (x *OrchestratorRequest) GetInstanceId() string

+ func (x *OrchestratorRequest) GetNewEvents() []*HistoryEvent

+ func (x *OrchestratorRequest) GetPastEvents() []*HistoryEvent

+ func (x *OrchestratorRequest) ProtoReflect() protoreflect.Message

+ func (x *OrchestratorRequest) Reset()

+ func (x *OrchestratorRequest) String() string

+ type OrchestratorResponse struct

+ Actions []*OrchestratorAction

+ CustomStatus *wrapperspb.StringValue

+ InstanceId string

+ func (*OrchestratorResponse) Descriptor() ([]byte, []int)

+ func (*OrchestratorResponse) ProtoMessage()

+ func (x *OrchestratorResponse) GetActions() []*OrchestratorAction

+ func (x *OrchestratorResponse) GetCustomStatus() *wrapperspb.StringValue

+ func (x *OrchestratorResponse) GetInstanceId() string

+ func (x *OrchestratorResponse) ProtoReflect() protoreflect.Message

+ func (x *OrchestratorResponse) Reset()

+ func (x *OrchestratorResponse) String() string

+ type OrchestratorStartedEvent struct

+ func (*OrchestratorStartedEvent) Descriptor() ([]byte, []int)

+ func (*OrchestratorStartedEvent) ProtoMessage()

+ func (x *OrchestratorStartedEvent) ProtoReflect() protoreflect.Message

+ func (x *OrchestratorStartedEvent) Reset()

+ func (x *OrchestratorStartedEvent) String() string

+ type ParentInstanceInfo struct

+ Name *wrapperspb.StringValue

+ OrchestrationInstance *OrchestrationInstance

+ TaskScheduledId int32

+ Version *wrapperspb.StringValue

+ func (*ParentInstanceInfo) Descriptor() ([]byte, []int)

+ func (*ParentInstanceInfo) ProtoMessage()

+ func (x *ParentInstanceInfo) GetName() *wrapperspb.StringValue

+ func (x *ParentInstanceInfo) GetOrchestrationInstance() *OrchestrationInstance

+ func (x *ParentInstanceInfo) GetTaskScheduledId() int32

+ func (x *ParentInstanceInfo) GetVersion() *wrapperspb.StringValue

+ func (x *ParentInstanceInfo) ProtoReflect() protoreflect.Message

+ func (x *ParentInstanceInfo) Reset()

+ func (x *ParentInstanceInfo) String() string

+ type PingRequest struct

+ func (*PingRequest) Descriptor() ([]byte, []int)

+ func (*PingRequest) ProtoMessage()

+ func (x *PingRequest) ProtoReflect() protoreflect.Message

+ func (x *PingRequest) Reset()

+ func (x *PingRequest) String() string

+ type PingResponse struct

+ func (*PingResponse) Descriptor() ([]byte, []int)

+ func (*PingResponse) ProtoMessage()

+ func (x *PingResponse) ProtoReflect() protoreflect.Message

+ func (x *PingResponse) Reset()

+ func (x *PingResponse) String() string

+ type PurgeInstanceFilter struct

+ CreatedTimeFrom *timestamppb.Timestamp

+ CreatedTimeTo *timestamppb.Timestamp

+ RuntimeStatus []OrchestrationStatus

+ func (*PurgeInstanceFilter) Descriptor() ([]byte, []int)

+ func (*PurgeInstanceFilter) ProtoMessage()

+ func (x *PurgeInstanceFilter) GetCreatedTimeFrom() *timestamppb.Timestamp

+ func (x *PurgeInstanceFilter) GetCreatedTimeTo() *timestamppb.Timestamp

+ func (x *PurgeInstanceFilter) GetRuntimeStatus() []OrchestrationStatus

+ func (x *PurgeInstanceFilter) ProtoReflect() protoreflect.Message

+ func (x *PurgeInstanceFilter) Reset()

+ func (x *PurgeInstanceFilter) String() string

+ type PurgeInstancesRequest struct

+ Recursive bool

+ Request isPurgeInstancesRequest_Request

+ func (*PurgeInstancesRequest) Descriptor() ([]byte, []int)

+ func (*PurgeInstancesRequest) ProtoMessage()

+ func (m *PurgeInstancesRequest) GetRequest() isPurgeInstancesRequest_Request

+ func (x *PurgeInstancesRequest) GetInstanceId() string

+ func (x *PurgeInstancesRequest) GetPurgeInstanceFilter() *PurgeInstanceFilter

+ func (x *PurgeInstancesRequest) GetRecursive() bool

+ func (x *PurgeInstancesRequest) ProtoReflect() protoreflect.Message

+ func (x *PurgeInstancesRequest) Reset()

+ func (x *PurgeInstancesRequest) String() string

+ type PurgeInstancesRequest_InstanceId struct

+ InstanceId string

+ type PurgeInstancesRequest_PurgeInstanceFilter struct

+ PurgeInstanceFilter *PurgeInstanceFilter

+ type PurgeInstancesResponse struct

+ DeletedInstanceCount int32

+ func (*PurgeInstancesResponse) Descriptor() ([]byte, []int)

+ func (*PurgeInstancesResponse) ProtoMessage()

+ func (x *PurgeInstancesResponse) GetDeletedInstanceCount() int32

+ func (x *PurgeInstancesResponse) ProtoReflect() protoreflect.Message

+ func (x *PurgeInstancesResponse) Reset()

+ func (x *PurgeInstancesResponse) String() string

+ type QueryEntitiesRequest struct

+ Query *EntityQuery

+ func (*QueryEntitiesRequest) Descriptor() ([]byte, []int)

+ func (*QueryEntitiesRequest) ProtoMessage()

+ func (x *QueryEntitiesRequest) GetQuery() *EntityQuery

+ func (x *QueryEntitiesRequest) ProtoReflect() protoreflect.Message

+ func (x *QueryEntitiesRequest) Reset()

+ func (x *QueryEntitiesRequest) String() string

+ type QueryEntitiesResponse struct

+ ContinuationToken *wrapperspb.StringValue

+ Entities []*EntityMetadata

+ func (*QueryEntitiesResponse) Descriptor() ([]byte, []int)

+ func (*QueryEntitiesResponse) ProtoMessage()

+ func (x *QueryEntitiesResponse) GetContinuationToken() *wrapperspb.StringValue

+ func (x *QueryEntitiesResponse) GetEntities() []*EntityMetadata

+ func (x *QueryEntitiesResponse) ProtoReflect() protoreflect.Message

+ func (x *QueryEntitiesResponse) Reset()

+ func (x *QueryEntitiesResponse) String() string

+ type QueryInstancesRequest struct

+ Query *InstanceQuery

+ func (*QueryInstancesRequest) Descriptor() ([]byte, []int)

+ func (*QueryInstancesRequest) ProtoMessage()

+ func (x *QueryInstancesRequest) GetQuery() *InstanceQuery

+ func (x *QueryInstancesRequest) ProtoReflect() protoreflect.Message

+ func (x *QueryInstancesRequest) Reset()

+ func (x *QueryInstancesRequest) String() string

+ type QueryInstancesResponse struct

+ ContinuationToken *wrapperspb.StringValue

+ OrchestrationState []*OrchestrationState

+ func (*QueryInstancesResponse) Descriptor() ([]byte, []int)

+ func (*QueryInstancesResponse) ProtoMessage()

+ func (x *QueryInstancesResponse) GetContinuationToken() *wrapperspb.StringValue

+ func (x *QueryInstancesResponse) GetOrchestrationState() []*OrchestrationState

+ func (x *QueryInstancesResponse) ProtoReflect() protoreflect.Message

+ func (x *QueryInstancesResponse) Reset()

+ func (x *QueryInstancesResponse) String() string

+ type RaiseEventRequest struct

+ Input *wrapperspb.StringValue

+ InstanceId string

+ Name string

+ func (*RaiseEventRequest) Descriptor() ([]byte, []int)

+ func (*RaiseEventRequest) ProtoMessage()

+ func (x *RaiseEventRequest) GetInput() *wrapperspb.StringValue

+ func (x *RaiseEventRequest) GetInstanceId() string

+ func (x *RaiseEventRequest) GetName() string

+ func (x *RaiseEventRequest) ProtoReflect() protoreflect.Message

+ func (x *RaiseEventRequest) Reset()

+ func (x *RaiseEventRequest) String() string

+ type RaiseEventResponse struct

+ func (*RaiseEventResponse) Descriptor() ([]byte, []int)

+ func (*RaiseEventResponse) ProtoMessage()

+ func (x *RaiseEventResponse) ProtoReflect() protoreflect.Message

+ func (x *RaiseEventResponse) Reset()

+ func (x *RaiseEventResponse) String() string

+ type ResumeRequest struct

+ InstanceId string

+ Reason *wrapperspb.StringValue

+ func (*ResumeRequest) Descriptor() ([]byte, []int)

+ func (*ResumeRequest) ProtoMessage()

+ func (x *ResumeRequest) GetInstanceId() string

+ func (x *ResumeRequest) GetReason() *wrapperspb.StringValue

+ func (x *ResumeRequest) ProtoReflect() protoreflect.Message

+ func (x *ResumeRequest) Reset()

+ func (x *ResumeRequest) String() string

+ type ResumeResponse struct

+ func (*ResumeResponse) Descriptor() ([]byte, []int)

+ func (*ResumeResponse) ProtoMessage()

+ func (x *ResumeResponse) ProtoReflect() protoreflect.Message

+ func (x *ResumeResponse) Reset()

+ func (x *ResumeResponse) String() string

+ type RewindInstanceRequest struct

+ InstanceId string

+ Reason *wrapperspb.StringValue

+ func (*RewindInstanceRequest) Descriptor() ([]byte, []int)

+ func (*RewindInstanceRequest) ProtoMessage()

+ func (x *RewindInstanceRequest) GetInstanceId() string

+ func (x *RewindInstanceRequest) GetReason() *wrapperspb.StringValue

+ func (x *RewindInstanceRequest) ProtoReflect() protoreflect.Message

+ func (x *RewindInstanceRequest) Reset()

+ func (x *RewindInstanceRequest) String() string

+ type RewindInstanceResponse struct

+ func (*RewindInstanceResponse) Descriptor() ([]byte, []int)

+ func (*RewindInstanceResponse) ProtoMessage()

+ func (x *RewindInstanceResponse) ProtoReflect() protoreflect.Message

+ func (x *RewindInstanceResponse) Reset()

+ func (x *RewindInstanceResponse) String() string

+ type ScheduleTaskAction struct

+ Input *wrapperspb.StringValue

+ Name string

+ Version *wrapperspb.StringValue

+ func (*ScheduleTaskAction) Descriptor() ([]byte, []int)

+ func (*ScheduleTaskAction) ProtoMessage()

+ func (x *ScheduleTaskAction) GetInput() *wrapperspb.StringValue

+ func (x *ScheduleTaskAction) GetName() string

+ func (x *ScheduleTaskAction) GetVersion() *wrapperspb.StringValue

+ func (x *ScheduleTaskAction) ProtoReflect() protoreflect.Message

+ func (x *ScheduleTaskAction) Reset()

+ func (x *ScheduleTaskAction) String() string

+ type SendEventAction struct

+ Data *wrapperspb.StringValue

+ Instance *OrchestrationInstance

+ Name string

+ func (*SendEventAction) Descriptor() ([]byte, []int)

+ func (*SendEventAction) ProtoMessage()

+ func (x *SendEventAction) GetData() *wrapperspb.StringValue

+ func (x *SendEventAction) GetInstance() *OrchestrationInstance

+ func (x *SendEventAction) GetName() string

+ func (x *SendEventAction) ProtoReflect() protoreflect.Message

+ func (x *SendEventAction) Reset()

+ func (x *SendEventAction) String() string

+ type SendSignalAction struct

+ Input *wrapperspb.StringValue

+ InstanceId string

+ Name string

+ ScheduledTime *timestamppb.Timestamp

+ func (*SendSignalAction) Descriptor() ([]byte, []int)

+ func (*SendSignalAction) ProtoMessage()

+ func (x *SendSignalAction) GetInput() *wrapperspb.StringValue

+ func (x *SendSignalAction) GetInstanceId() string

+ func (x *SendSignalAction) GetName() string

+ func (x *SendSignalAction) GetScheduledTime() *timestamppb.Timestamp

+ func (x *SendSignalAction) ProtoReflect() protoreflect.Message

+ func (x *SendSignalAction) Reset()

+ func (x *SendSignalAction) String() string

+ type SignalEntityRequest struct

+ Input *wrapperspb.StringValue

+ InstanceId string

+ Name string

+ RequestId string

+ ScheduledTime *timestamppb.Timestamp

+ func (*SignalEntityRequest) Descriptor() ([]byte, []int)

+ func (*SignalEntityRequest) ProtoMessage()

+ func (x *SignalEntityRequest) GetInput() *wrapperspb.StringValue

+ func (x *SignalEntityRequest) GetInstanceId() string

+ func (x *SignalEntityRequest) GetName() string

+ func (x *SignalEntityRequest) GetRequestId() string

+ func (x *SignalEntityRequest) GetScheduledTime() *timestamppb.Timestamp

+ func (x *SignalEntityRequest) ProtoReflect() protoreflect.Message

+ func (x *SignalEntityRequest) Reset()

+ func (x *SignalEntityRequest) String() string

+ type SignalEntityResponse struct

+ func (*SignalEntityResponse) Descriptor() ([]byte, []int)

+ func (*SignalEntityResponse) ProtoMessage()

+ func (x *SignalEntityResponse) ProtoReflect() protoreflect.Message

+ func (x *SignalEntityResponse) Reset()

+ func (x *SignalEntityResponse) String() string

+ type StartNewOrchestrationAction struct

+ Input *wrapperspb.StringValue

+ InstanceId string

+ Name string

+ ScheduledTime *timestamppb.Timestamp

+ Version *wrapperspb.StringValue

+ func (*StartNewOrchestrationAction) Descriptor() ([]byte, []int)

+ func (*StartNewOrchestrationAction) ProtoMessage()

+ func (x *StartNewOrchestrationAction) GetInput() *wrapperspb.StringValue

+ func (x *StartNewOrchestrationAction) GetInstanceId() string

+ func (x *StartNewOrchestrationAction) GetName() string

+ func (x *StartNewOrchestrationAction) GetScheduledTime() *timestamppb.Timestamp

+ func (x *StartNewOrchestrationAction) GetVersion() *wrapperspb.StringValue

+ func (x *StartNewOrchestrationAction) ProtoReflect() protoreflect.Message

+ func (x *StartNewOrchestrationAction) Reset()

+ func (x *StartNewOrchestrationAction) String() string

+ type SubOrchestrationInstanceCompletedEvent struct

+ Result *wrapperspb.StringValue

+ TaskScheduledId int32

+ func (*SubOrchestrationInstanceCompletedEvent) Descriptor() ([]byte, []int)

+ func (*SubOrchestrationInstanceCompletedEvent) ProtoMessage()

+ func (x *SubOrchestrationInstanceCompletedEvent) GetResult() *wrapperspb.StringValue

+ func (x *SubOrchestrationInstanceCompletedEvent) GetTaskScheduledId() int32

+ func (x *SubOrchestrationInstanceCompletedEvent) ProtoReflect() protoreflect.Message

+ func (x *SubOrchestrationInstanceCompletedEvent) Reset()

+ func (x *SubOrchestrationInstanceCompletedEvent) String() string

+ type SubOrchestrationInstanceCreatedEvent struct

+ Input *wrapperspb.StringValue

+ InstanceId string

+ Name string

+ ParentTraceContext *TraceContext

+ Version *wrapperspb.StringValue

+ func (*SubOrchestrationInstanceCreatedEvent) Descriptor() ([]byte, []int)

+ func (*SubOrchestrationInstanceCreatedEvent) ProtoMessage()

+ func (x *SubOrchestrationInstanceCreatedEvent) GetInput() *wrapperspb.StringValue

+ func (x *SubOrchestrationInstanceCreatedEvent) GetInstanceId() string

+ func (x *SubOrchestrationInstanceCreatedEvent) GetName() string

+ func (x *SubOrchestrationInstanceCreatedEvent) GetParentTraceContext() *TraceContext

+ func (x *SubOrchestrationInstanceCreatedEvent) GetVersion() *wrapperspb.StringValue

+ func (x *SubOrchestrationInstanceCreatedEvent) ProtoReflect() protoreflect.Message

+ func (x *SubOrchestrationInstanceCreatedEvent) Reset()

+ func (x *SubOrchestrationInstanceCreatedEvent) String() string

+ type SubOrchestrationInstanceFailedEvent struct

+ FailureDetails *TaskFailureDetails

+ TaskScheduledId int32

+ func (*SubOrchestrationInstanceFailedEvent) Descriptor() ([]byte, []int)

+ func (*SubOrchestrationInstanceFailedEvent) ProtoMessage()

+ func (x *SubOrchestrationInstanceFailedEvent) GetFailureDetails() *TaskFailureDetails

+ func (x *SubOrchestrationInstanceFailedEvent) GetTaskScheduledId() int32

+ func (x *SubOrchestrationInstanceFailedEvent) ProtoReflect() protoreflect.Message

+ func (x *SubOrchestrationInstanceFailedEvent) Reset()

+ func (x *SubOrchestrationInstanceFailedEvent) String() string

+ type SuspendRequest struct

+ InstanceId string

+ Reason *wrapperspb.StringValue

+ func (*SuspendRequest) Descriptor() ([]byte, []int)

+ func (*SuspendRequest) ProtoMessage()

+ func (x *SuspendRequest) GetInstanceId() string

+ func (x *SuspendRequest) GetReason() *wrapperspb.StringValue

+ func (x *SuspendRequest) ProtoReflect() protoreflect.Message

+ func (x *SuspendRequest) Reset()

+ func (x *SuspendRequest) String() string

+ type SuspendResponse struct

+ func (*SuspendResponse) Descriptor() ([]byte, []int)

+ func (*SuspendResponse) ProtoMessage()

+ func (x *SuspendResponse) ProtoReflect() protoreflect.Message

+ func (x *SuspendResponse) Reset()

+ func (x *SuspendResponse) String() string

+ type TaskCompletedEvent struct

+ Result *wrapperspb.StringValue

+ TaskScheduledId int32

+ func (*TaskCompletedEvent) Descriptor() ([]byte, []int)

+ func (*TaskCompletedEvent) ProtoMessage()

+ func (x *TaskCompletedEvent) GetResult() *wrapperspb.StringValue

+ func (x *TaskCompletedEvent) GetTaskScheduledId() int32

+ func (x *TaskCompletedEvent) ProtoReflect() protoreflect.Message

+ func (x *TaskCompletedEvent) Reset()

+ func (x *TaskCompletedEvent) String() string

+ type TaskFailedEvent struct

+ FailureDetails *TaskFailureDetails

+ TaskScheduledId int32

+ func (*TaskFailedEvent) Descriptor() ([]byte, []int)

+ func (*TaskFailedEvent) ProtoMessage()

+ func (x *TaskFailedEvent) GetFailureDetails() *TaskFailureDetails

+ func (x *TaskFailedEvent) GetTaskScheduledId() int32

+ func (x *TaskFailedEvent) ProtoReflect() protoreflect.Message

+ func (x *TaskFailedEvent) Reset()

+ func (x *TaskFailedEvent) String() string

+ type TaskFailureDetails struct

+ ErrorMessage string

+ ErrorType string

+ InnerFailure *TaskFailureDetails

+ IsNonRetriable bool

+ StackTrace *wrapperspb.StringValue

+ func (*TaskFailureDetails) Descriptor() ([]byte, []int)

+ func (*TaskFailureDetails) ProtoMessage()

+ 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 (x *TaskFailureDetails) ProtoReflect() protoreflect.Message

+ func (x *TaskFailureDetails) Reset()

+ func (x *TaskFailureDetails) String() string

+ type TaskHubSidecarServiceClient interface

+ CleanEntityStorage func(ctx context.Context, in *CleanEntityStorageRequest, opts ...grpc.CallOption) (*CleanEntityStorageResponse, error)

+ CompleteActivityTask func(ctx context.Context, in *ActivityResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)

+ CompleteEntityTask func(ctx context.Context, in *EntityBatchResult, opts ...grpc.CallOption) (*CompleteTaskResponse, error)

+ CompleteOrchestratorTask func(ctx context.Context, in *OrchestratorResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)

+ CreateTaskHub func(ctx context.Context, in *CreateTaskHubRequest, opts ...grpc.CallOption) (*CreateTaskHubResponse, error)

+ DeleteTaskHub func(ctx context.Context, in *DeleteTaskHubRequest, opts ...grpc.CallOption) (*DeleteTaskHubResponse, error)

+ GetEntity func(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*GetEntityResponse, error)

+ GetInstance func(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)

+ GetWorkItems func(ctx context.Context, in *GetWorkItemsRequest, opts ...grpc.CallOption) (TaskHubSidecarService_GetWorkItemsClient, error)

+ Hello func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ PurgeInstances func(ctx context.Context, in *PurgeInstancesRequest, opts ...grpc.CallOption) (*PurgeInstancesResponse, error)

+ QueryEntities func(ctx context.Context, in *QueryEntitiesRequest, opts ...grpc.CallOption) (*QueryEntitiesResponse, error)

+ QueryInstances func(ctx context.Context, in *QueryInstancesRequest, opts ...grpc.CallOption) (*QueryInstancesResponse, error)

+ RaiseEvent func(ctx context.Context, in *RaiseEventRequest, opts ...grpc.CallOption) (*RaiseEventResponse, error)

+ ResumeInstance func(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*ResumeResponse, error)

+ RewindInstance func(ctx context.Context, in *RewindInstanceRequest, opts ...grpc.CallOption) (*RewindInstanceResponse, error)

+ SignalEntity func(ctx context.Context, in *SignalEntityRequest, opts ...grpc.CallOption) (*SignalEntityResponse, error)

+ StartInstance func(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)

+ SuspendInstance func(ctx context.Context, in *SuspendRequest, opts ...grpc.CallOption) (*SuspendResponse, error)

+ TerminateInstance func(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)

+ WaitForInstanceCompletion func(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)

+ WaitForInstanceStart func(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)

+ func NewTaskHubSidecarServiceClient(cc grpc.ClientConnInterface) TaskHubSidecarServiceClient

+ type TaskHubSidecarServiceServer interface

+ CleanEntityStorage func(context.Context, *CleanEntityStorageRequest) (*CleanEntityStorageResponse, error)

+ CompleteActivityTask func(context.Context, *ActivityResponse) (*CompleteTaskResponse, error)

+ CompleteEntityTask func(context.Context, *EntityBatchResult) (*CompleteTaskResponse, error)

+ CompleteOrchestratorTask func(context.Context, *OrchestratorResponse) (*CompleteTaskResponse, error)

+ CreateTaskHub func(context.Context, *CreateTaskHubRequest) (*CreateTaskHubResponse, error)

+ DeleteTaskHub func(context.Context, *DeleteTaskHubRequest) (*DeleteTaskHubResponse, error)

+ GetEntity func(context.Context, *GetEntityRequest) (*GetEntityResponse, error)

+ GetInstance func(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)

+ GetWorkItems func(*GetWorkItemsRequest, TaskHubSidecarService_GetWorkItemsServer) error

+ Hello func(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ PurgeInstances func(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)

+ QueryEntities func(context.Context, *QueryEntitiesRequest) (*QueryEntitiesResponse, error)

+ QueryInstances func(context.Context, *QueryInstancesRequest) (*QueryInstancesResponse, error)

+ RaiseEvent func(context.Context, *RaiseEventRequest) (*RaiseEventResponse, error)

+ ResumeInstance func(context.Context, *ResumeRequest) (*ResumeResponse, error)

+ RewindInstance func(context.Context, *RewindInstanceRequest) (*RewindInstanceResponse, error)

+ SignalEntity func(context.Context, *SignalEntityRequest) (*SignalEntityResponse, error)

+ StartInstance func(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)

+ SuspendInstance func(context.Context, *SuspendRequest) (*SuspendResponse, error)

+ TerminateInstance func(context.Context, *TerminateRequest) (*TerminateResponse, error)

+ WaitForInstanceCompletion func(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)

+ WaitForInstanceStart func(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)

+ type TaskHubSidecarService_GetWorkItemsClient interface

+ Recv func() (*WorkItem, error)

+ type TaskHubSidecarService_GetWorkItemsServer interface

+ Send func(*WorkItem) error

+ type TaskScheduledEvent struct

+ Input *wrapperspb.StringValue

+ Name string

+ ParentTraceContext *TraceContext

+ Version *wrapperspb.StringValue

+ func (*TaskScheduledEvent) Descriptor() ([]byte, []int)

+ func (*TaskScheduledEvent) ProtoMessage()

+ func (x *TaskScheduledEvent) GetInput() *wrapperspb.StringValue

+ func (x *TaskScheduledEvent) GetName() string

+ func (x *TaskScheduledEvent) GetParentTraceContext() *TraceContext

+ func (x *TaskScheduledEvent) GetVersion() *wrapperspb.StringValue

+ func (x *TaskScheduledEvent) ProtoReflect() protoreflect.Message

+ func (x *TaskScheduledEvent) Reset()

+ func (x *TaskScheduledEvent) String() string

+ type TerminateOrchestrationAction struct

+ InstanceId string

+ Reason *wrapperspb.StringValue

+ Recurse bool

+ func (*TerminateOrchestrationAction) Descriptor() ([]byte, []int)

+ func (*TerminateOrchestrationAction) ProtoMessage()

+ func (x *TerminateOrchestrationAction) GetInstanceId() string

+ func (x *TerminateOrchestrationAction) GetReason() *wrapperspb.StringValue

+ func (x *TerminateOrchestrationAction) GetRecurse() bool

+ func (x *TerminateOrchestrationAction) ProtoReflect() protoreflect.Message

+ func (x *TerminateOrchestrationAction) Reset()

+ func (x *TerminateOrchestrationAction) String() string

+ type TerminateRequest struct

+ InstanceId string

+ Output *wrapperspb.StringValue

+ Recursive bool

+ func (*TerminateRequest) Descriptor() ([]byte, []int)

+ func (*TerminateRequest) ProtoMessage()

+ func (x *TerminateRequest) GetInstanceId() string

+ func (x *TerminateRequest) GetOutput() *wrapperspb.StringValue

+ func (x *TerminateRequest) GetRecursive() bool

+ func (x *TerminateRequest) ProtoReflect() protoreflect.Message

+ func (x *TerminateRequest) Reset()

+ func (x *TerminateRequest) String() string

+ type TerminateResponse struct

+ func (*TerminateResponse) Descriptor() ([]byte, []int)

+ func (*TerminateResponse) ProtoMessage()

+ func (x *TerminateResponse) ProtoReflect() protoreflect.Message

+ func (x *TerminateResponse) Reset()

+ func (x *TerminateResponse) String() string

+ type TimerCreatedEvent struct

+ FireAt *timestamppb.Timestamp

+ func (*TimerCreatedEvent) Descriptor() ([]byte, []int)

+ func (*TimerCreatedEvent) ProtoMessage()

+ func (x *TimerCreatedEvent) GetFireAt() *timestamppb.Timestamp

+ func (x *TimerCreatedEvent) ProtoReflect() protoreflect.Message

+ func (x *TimerCreatedEvent) Reset()

+ func (x *TimerCreatedEvent) String() string

+ type TimerFiredEvent struct

+ FireAt *timestamppb.Timestamp

+ TimerId int32

+ func (*TimerFiredEvent) Descriptor() ([]byte, []int)

+ func (*TimerFiredEvent) ProtoMessage()

+ func (x *TimerFiredEvent) GetFireAt() *timestamppb.Timestamp

+ func (x *TimerFiredEvent) GetTimerId() int32

+ func (x *TimerFiredEvent) ProtoReflect() protoreflect.Message

+ func (x *TimerFiredEvent) Reset()

+ func (x *TimerFiredEvent) String() string

+ type TraceContext struct

+ SpanID string

+ TraceParent string

+ TraceState *wrapperspb.StringValue

+ func (*TraceContext) Descriptor() ([]byte, []int)

+ func (*TraceContext) ProtoMessage()

+ func (x *TraceContext) GetSpanID() string

+ func (x *TraceContext) GetTraceParent() string

+ func (x *TraceContext) GetTraceState() *wrapperspb.StringValue

+ func (x *TraceContext) ProtoReflect() protoreflect.Message

+ func (x *TraceContext) Reset()

+ func (x *TraceContext) String() string

+ type UnimplementedBackendServiceServer struct

+ func (UnimplementedBackendServiceServer) AbandonActivityWorkItem(context.Context, *AbandonActivityWorkItemRequest) (*AbandonActivityWorkItemResponse, error)

+ func (UnimplementedBackendServiceServer) AbandonOrchestrationWorkItem(context.Context, *AbandonOrchestrationWorkItemRequest) (*AbandonOrchestrationWorkItemResponse, error)

+ func (UnimplementedBackendServiceServer) AddEvent(context.Context, *AddEventRequest) (*AddEventResponse, error)

+ func (UnimplementedBackendServiceServer) CompleteActivityWorkItem(context.Context, *CompleteActivityWorkItemRequest) (*CompleteActivityWorkItemResponse, error)

+ func (UnimplementedBackendServiceServer) CompleteOrchestrationWorkItem(context.Context, *CompleteOrchestrationWorkItemRequest) (*CompleteOrchestrationWorkItemResponse, error)

+ func (UnimplementedBackendServiceServer) CreateInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)

+ func (UnimplementedBackendServiceServer) GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)

+ func (UnimplementedBackendServiceServer) GetOrchestrationRuntimeState(context.Context, *GetOrchestrationRuntimeStateRequest) (*GetOrchestrationRuntimeStateResponse, error)

+ func (UnimplementedBackendServiceServer) GetWorkItems(*GetWorkItemsRequest, BackendService_GetWorkItemsServer) error

+ func (UnimplementedBackendServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

+ func (UnimplementedBackendServiceServer) PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)

+ func (UnimplementedBackendServiceServer) QueryInstances(context.Context, *QueryInstancesRequest) (*QueryInstancesResponse, error)

+ func (UnimplementedBackendServiceServer) WaitForInstance(context.Context, *WaitForInstanceRequest) (*WaitForInstanceResponse, error)

+ type UnimplementedTaskHubSidecarServiceServer struct

+ func (UnimplementedTaskHubSidecarServiceServer) CleanEntityStorage(context.Context, *CleanEntityStorageRequest) (*CleanEntityStorageResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask(context.Context, *ActivityResponse) (*CompleteTaskResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) CompleteEntityTask(context.Context, *EntityBatchResult) (*CompleteTaskResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) CompleteOrchestratorTask(context.Context, *OrchestratorResponse) (*CompleteTaskResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) CreateTaskHub(context.Context, *CreateTaskHubRequest) (*CreateTaskHubResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) DeleteTaskHub(context.Context, *DeleteTaskHubRequest) (*DeleteTaskHubResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems(*GetWorkItemsRequest, TaskHubSidecarService_GetWorkItemsServer) error

+ func (UnimplementedTaskHubSidecarServiceServer) Hello(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

+ func (UnimplementedTaskHubSidecarServiceServer) PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) QueryEntities(context.Context, *QueryEntitiesRequest) (*QueryEntitiesResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) QueryInstances(context.Context, *QueryInstancesRequest) (*QueryInstancesResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) RaiseEvent(context.Context, *RaiseEventRequest) (*RaiseEventResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) ResumeInstance(context.Context, *ResumeRequest) (*ResumeResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) RewindInstance(context.Context, *RewindInstanceRequest) (*RewindInstanceResponse, error)

+ func (UnimplementedTaskHubSidecarServiceServer) SignalEntity(context.Context, *SignalEntityRequest) (*SignalEntityResponse, 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 UnsafeBackendServiceServer interface

+ type UnsafeTaskHubSidecarServiceServer interface

+ type WaitForInstanceRequest struct

+ GetInputsAndOutputs bool

+ InstanceId string

+ func (*WaitForInstanceRequest) Descriptor() ([]byte, []int)

+ func (*WaitForInstanceRequest) ProtoMessage()

+ func (x *WaitForInstanceRequest) GetGetInputsAndOutputs() bool

+ func (x *WaitForInstanceRequest) GetInstanceId() string

+ func (x *WaitForInstanceRequest) ProtoReflect() protoreflect.Message

+ func (x *WaitForInstanceRequest) Reset()

+ func (x *WaitForInstanceRequest) String() string

+ type WaitForInstanceResponse struct

+ Exists bool

+ OrchestrationState *OrchestrationState

+ func (*WaitForInstanceResponse) Descriptor() ([]byte, []int)

+ func (*WaitForInstanceResponse) ProtoMessage()

+ func (x *WaitForInstanceResponse) GetExists() bool

+ func (x *WaitForInstanceResponse) GetOrchestrationState() *OrchestrationState

+ func (x *WaitForInstanceResponse) ProtoReflect() protoreflect.Message

+ func (x *WaitForInstanceResponse) Reset()

+ func (x *WaitForInstanceResponse) String() string

+ type WorkItem struct

+ CompletionToken string

+ Request isWorkItem_Request

+ func (*WorkItem) Descriptor() ([]byte, []int)

+ func (*WorkItem) ProtoMessage()

+ func (m *WorkItem) GetRequest() isWorkItem_Request

+ func (x *WorkItem) GetActivityRequest() *ActivityRequest

+ func (x *WorkItem) GetCompletionToken() string

+ func (x *WorkItem) GetEntityRequest() *EntityBatchRequest

+ func (x *WorkItem) GetHealthPing() *HealthPing

+ func (x *WorkItem) GetOrchestratorRequest() *OrchestratorRequest

+ func (x *WorkItem) ProtoReflect() protoreflect.Message

+ func (x *WorkItem) Reset()

+ func (x *WorkItem) String() string

+ type WorkItem_ActivityRequest struct

+ ActivityRequest *ActivityRequest

+ type WorkItem_EntityRequest struct

+ EntityRequest *EntityBatchRequest

+ type WorkItem_HealthPing struct

+ HealthPing *HealthPing

+ type WorkItem_OrchestratorRequest struct

+ OrchestratorRequest *OrchestratorRequest

+ type WorkflowState struct

+ CustomStatus *wrapperspb.StringValue

+ Generation uint64

+ History []*HistoryEvent

+ Inbox []*HistoryEvent

+ func (*WorkflowState) Descriptor() ([]byte, []int)

+ func (*WorkflowState) ProtoMessage()

+ func (x *WorkflowState) GetCustomStatus() *wrapperspb.StringValue

+ func (x *WorkflowState) GetGeneration() uint64

+ func (x *WorkflowState) GetHistory() []*HistoryEvent

+ func (x *WorkflowState) GetInbox() []*HistoryEvent

+ func (x *WorkflowState) ProtoReflect() protoreflect.Message

+ func (x *WorkflowState) Reset()

+ func (x *WorkflowState) String() string

+ type WorkflowStateMetadata struct

+ Generation uint64

+ HistoryLength uint64

+ InboxLength uint64

+ func (*WorkflowStateMetadata) Descriptor() ([]byte, []int)

+ func (*WorkflowStateMetadata) ProtoMessage()

+ func (x *WorkflowStateMetadata) GetGeneration() uint64

+ func (x *WorkflowStateMetadata) GetHistoryLength() uint64

+ func (x *WorkflowStateMetadata) GetInboxLength() uint64

+ func (x *WorkflowStateMetadata) ProtoReflect() protoreflect.Message

+ func (x *WorkflowStateMetadata) Reset()

+ func (x *WorkflowStateMetadata) String() string

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