protos

package

Go to main page

Versions in this module

v0

v0.6.0

Feb 5, 2025

v0.5.0

Jun 28, 2024

Changes in this version

+ 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

type PurgeInstancesRequest

+ Recursive bool

+ func (x *PurgeInstancesRequest) GetRecursive() bool

v0.4.0

Dec 18, 2023

v0.3.2

Dec 18, 2023

Changes in this version

+ var CreateOrchestrationAction_name = map[int32]string

+ var CreateOrchestrationAction_value = map[string]int32

+ type CleanEntityStorageRequest struct

+ ContinuationToken *wrappers.StringValue

+ ReleaseOrphanedLocks bool

+ RemoveEmptyEntities bool

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

+ func (*CleanEntityStorageRequest) ProtoMessage()

+ func (x *CleanEntityStorageRequest) GetContinuationToken() *wrappers.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 *wrappers.StringValue

+ EmptyEntitiesRemoved int32

+ OrphanedLocksReleased int32

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

+ func (*CleanEntityStorageResponse) ProtoMessage()

+ func (x *CleanEntityStorageResponse) GetContinuationToken() *wrappers.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 CreateInstanceRequest

+ OrchestrationIdReusePolicy *OrchestrationIdReusePolicy

+ func (x *CreateInstanceRequest) GetOrchestrationIdReusePolicy() *OrchestrationIdReusePolicy

+ 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 EntityBatchRequest struct

+ EntityState *wrappers.StringValue

+ InstanceId string

+ Operations []*OperationRequest

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

+ func (*EntityBatchRequest) ProtoMessage()

+ func (x *EntityBatchRequest) GetEntityState() *wrappers.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 *wrappers.StringValue

+ FailureDetails *TaskFailureDetails

+ Results []*OperationResult

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

+ func (*EntityBatchResult) ProtoMessage()

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

+ func (x *EntityBatchResult) GetEntityState() *wrappers.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 *timestamp.Timestamp

+ LockedBy *wrappers.StringValue

+ SerializedState *wrappers.StringValue

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

+ func (*EntityMetadata) ProtoMessage()

+ func (x *EntityMetadata) GetBacklogQueueSize() int32

+ func (x *EntityMetadata) GetInstanceId() string

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

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

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

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

+ func (x *EntityMetadata) Reset()

+ func (x *EntityMetadata) String() string

+ type EntityQuery struct

+ ContinuationToken *wrappers.StringValue

+ IncludeState bool

+ IncludeTransient bool

+ InstanceIdStartsWith *wrappers.StringValue

+ LastModifiedFrom *timestamp.Timestamp

+ LastModifiedTo *timestamp.Timestamp

+ PageSize *wrappers.Int32Value

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

+ func (*EntityQuery) ProtoMessage()

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

+ func (x *EntityQuery) GetIncludeState() bool

+ func (x *EntityQuery) GetIncludeTransient() bool

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

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

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

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

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

+ func (x *EntityQuery) Reset()

+ func (x *EntityQuery) 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 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 *wrappers.StringValue

+ Operation string

+ RequestId string

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

+ func (*OperationRequest) ProtoMessage()

+ func (x *OperationRequest) GetInput() *wrappers.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 *wrappers.StringValue

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

+ func (*OperationResultSuccess) ProtoMessage()

+ func (x *OperationResultSuccess) GetResult() *wrappers.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 OrchestratorEntityParameters struct

+ EntityMessageReorderWindow *duration.Duration

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

+ func (*OrchestratorEntityParameters) ProtoMessage()

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

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

+ func (x *OrchestratorEntityParameters) Reset()

+ func (x *OrchestratorEntityParameters) String() string

type OrchestratorRequest

+ EntityParameters *OrchestratorEntityParameters

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

+ 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 *wrappers.StringValue

+ Entities []*EntityMetadata

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

+ func (*QueryEntitiesResponse) ProtoMessage()

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

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

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

+ func (x *QueryEntitiesResponse) Reset()

+ func (x *QueryEntitiesResponse) String() string

+ type SendSignalAction struct

+ Input *wrappers.StringValue

+ InstanceId string

+ Name string

+ ScheduledTime *timestamp.Timestamp

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

+ func (*SendSignalAction) ProtoMessage()

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

+ func (x *SendSignalAction) GetInstanceId() string

+ func (x *SendSignalAction) GetName() string

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

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

+ func (x *SendSignalAction) Reset()

+ func (x *SendSignalAction) String() string

+ type SignalEntityRequest struct

+ Input *wrappers.StringValue

+ InstanceId string

+ Name string

+ RequestId string

+ ScheduledTime *timestamp.Timestamp

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

+ func (*SignalEntityRequest) ProtoMessage()

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

+ func (x *SignalEntityRequest) GetInstanceId() string

+ func (x *SignalEntityRequest) GetName() string

+ func (x *SignalEntityRequest) GetRequestId() string

+ func (x *SignalEntityRequest) GetScheduledTime() *timestamp.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 *wrappers.StringValue

+ InstanceId string

+ Name string

+ ScheduledTime *timestamp.Timestamp

+ Version *wrappers.StringValue

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

+ func (*StartNewOrchestrationAction) ProtoMessage()

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

+ func (x *StartNewOrchestrationAction) GetInstanceId() string

+ func (x *StartNewOrchestrationAction) GetName() string

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

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

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

+ func (x *StartNewOrchestrationAction) Reset()

+ func (x *StartNewOrchestrationAction) String() string

type TaskHubSidecarServiceClient

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

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

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

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

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

type TaskHubSidecarServiceServer

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

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

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

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

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

type TraceContext

+ TraceParent string

+ func (x *TraceContext) GetTraceParent() string

type UnimplementedTaskHubSidecarServiceServer

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

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

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

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

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

type WorkItem

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

+ type WorkItem_EntityRequest struct

+ EntityRequest *EntityBatchRequest

v0.3.1

Sep 8, 2023

v0.3.0

Jul 13, 2023

Changes in this version

type ExecutionTerminatedEvent

+ Recurse bool

+ func (x *ExecutionTerminatedEvent) GetRecurse() bool

type OrchestratorAction

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

+ type OrchestratorAction_TerminateOrchestration struct

+ TerminateOrchestration *TerminateOrchestrationAction

+ 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

+ Recursive bool

+ func (x *TerminateRequest) GetRecursive() bool

v0.2.4

May 26, 2023

v0.2.3

May 23, 2023

v0.2.2

May 19, 2023

v0.2.1

May 1, 2023

v0.2.0

Mar 30, 2023

v0.1.4

Feb 23, 2023

v0.1.3

Jan 27, 2023

v0.1.2

Jan 25, 2023

v0.1.1

Jan 20, 2023

Changes in this version

+ var File_orchestrator_service_proto protoreflect.FileDescriptor

+ 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

+ OrchestrationSpanID *wrapperspb.StringValue

+ ParentTraceContext *TraceContext

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

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

+ 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 HistoryEvent

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

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

+ type HistoryEvent_ExecutionResumed struct

+ ExecutionResumed *ExecutionResumedEvent

+ type HistoryEvent_ExecutionSuspended struct

+ ExecutionSuspended *ExecutionSuspendedEvent

type OrchestrationStatus

+ const OrchestrationStatus_ORCHESTRATION_STATUS_SUSPENDED

+ 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 SubOrchestrationInstanceCreatedEvent

+ ParentTraceContext *TraceContext

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

+ 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 TaskHubSidecarServiceClient

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

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

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

type TaskHubSidecarServiceServer

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

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

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

type TaskScheduledEvent

+ ParentTraceContext *TraceContext

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

type TimerFiredEvent

+ ParentTraceContext *TraceContext

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

+ type TraceContext struct

+ SpanID string

+ TraceID string

+ TraceState *wrapperspb.StringValue

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

+ func (*TraceContext) ProtoMessage()

+ func (x *TraceContext) GetSpanID() string

+ func (x *TraceContext) GetTraceID() string

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

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

+ func (x *TraceContext) Reset()

+ func (x *TraceContext) String() string

type UnimplementedTaskHubSidecarServiceServer

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

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

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

v0.1.0

Sep 15, 2022

Changes in this version

+ var File_submodules_durabletask_protobuf_protos_orchestrator_service_proto protoreflect.FileDescriptor

+ var OrchestrationStatus_name = map[int32]string

+ var OrchestrationStatus_value = map[string]int32

+ var TaskHubSidecarService_ServiceDesc = grpc.ServiceDesc

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

+ type ActivityRequest struct

+ Input *wrapperspb.StringValue

+ Name string

+ OrchestrationInstance *OrchestrationInstance

+ 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) 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 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 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

+ Input *wrapperspb.StringValue

+ InstanceId string

+ Name string

+ ScheduledStartTimestamp *timestamppb.Timestamp

+ Version *wrapperspb.StringValue

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

+ func (*CreateInstanceRequest) ProtoMessage()

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

+ func (x *CreateInstanceRequest) GetInstanceId() string

+ func (x *CreateInstanceRequest) GetName() string

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

+ 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 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 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 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 ExecutionStartedEvent struct

+ CorrelationData *wrapperspb.StringValue

+ Input *wrapperspb.StringValue

+ Name string

+ OrchestrationInstance *OrchestrationInstance

+ ParentInstance *ParentInstanceInfo

+ ScheduledStartTimestamp *timestamppb.Timestamp

+ Version *wrapperspb.StringValue

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

+ func (*ExecutionStartedEvent) ProtoMessage()

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

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

+ func (x *ExecutionStartedEvent) GetName() string

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

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

+ 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 ExecutionTerminatedEvent struct

+ Input *wrapperspb.StringValue

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

+ func (*ExecutionTerminatedEvent) ProtoMessage()

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

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

+ func (x *ExecutionTerminatedEvent) Reset()

+ func (x *ExecutionTerminatedEvent) String() string

+ type GenericEvent struct

+ Data string

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

+ func (*GenericEvent) ProtoMessage()

+ func (x *GenericEvent) GetData() string

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

+ func (x *GenericEvent) Reset()

+ func (x *GenericEvent) 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 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 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) GetExecutionStarted() *ExecutionStartedEvent

+ 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_ExecutionStarted struct

+ ExecutionStarted *ExecutionStartedEvent

+ 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 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 OrchestrationState struct

+ CreatedTimestamp *timestamppb.Timestamp

+ CustomStatus *wrapperspb.StringValue

+ FailureDetails *TaskFailureDetails

+ Input *wrapperspb.StringValue

+ InstanceId string

+ LastUpdatedTimestamp *timestamppb.Timestamp

+ Name string

+ OrchestrationStatus OrchestrationStatus

+ Output *wrapperspb.StringValue

+ ScheduledStartTimestamp *timestamppb.Timestamp

+ Version *wrapperspb.StringValue

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

+ func (*OrchestrationState) ProtoMessage()

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

+ func (x *OrchestrationState) GetCustomStatus() *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) 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_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) 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 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 OrchestratorRequest struct

+ ExecutionId *wrapperspb.StringValue

+ InstanceId string

+ NewEvents []*HistoryEvent

+ PastEvents []*HistoryEvent

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

+ func (*OrchestratorRequest) ProtoMessage()

+ 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 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

+ 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) 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 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 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 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

+ 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) 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 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

+ CompleteActivityTask func(ctx context.Context, in *ActivityResponse, 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)

+ 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)

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

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

+ StartInstance func(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, 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

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

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

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

+ DeleteTaskHub func(context.Context, *DeleteTaskHubRequest) (*DeleteTaskHubResponse, 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)

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

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

+ StartInstance func(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, 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

+ 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) GetVersion() *wrapperspb.StringValue

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

+ func (x *TaskScheduledEvent) Reset()

+ func (x *TaskScheduledEvent) String() string

+ type TerminateRequest struct

+ InstanceId string

+ Output *wrapperspb.StringValue

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

+ func (*TerminateRequest) ProtoMessage()

+ func (x *TerminateRequest) GetInstanceId() string

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

+ 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 UnimplementedTaskHubSidecarServiceServer struct

+ func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask(context.Context, *ActivityResponse) (*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) 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) QueryInstances(context.Context, *QueryInstancesRequest) (*QueryInstancesResponse, error)

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

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

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

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

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

+ type UnsafeTaskHubSidecarServiceServer interface

+ type WorkItem struct

+ 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) 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_OrchestratorRequest struct

+ OrchestratorRequest *OrchestratorRequest

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