protos

package
v1.0.0-beta.1 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TaskHubSidecarService_Hello_FullMethodName                                 = "/TaskHubSidecarService/Hello"
	TaskHubSidecarService_StartInstance_FullMethodName                         = "/TaskHubSidecarService/StartInstance"
	TaskHubSidecarService_GetInstance_FullMethodName                           = "/TaskHubSidecarService/GetInstance"
	TaskHubSidecarService_RewindInstance_FullMethodName                        = "/TaskHubSidecarService/RewindInstance"
	TaskHubSidecarService_RestartInstance_FullMethodName                       = "/TaskHubSidecarService/RestartInstance"
	TaskHubSidecarService_WaitForInstanceStart_FullMethodName                  = "/TaskHubSidecarService/WaitForInstanceStart"
	TaskHubSidecarService_WaitForInstanceCompletion_FullMethodName             = "/TaskHubSidecarService/WaitForInstanceCompletion"
	TaskHubSidecarService_RaiseEvent_FullMethodName                            = "/TaskHubSidecarService/RaiseEvent"
	TaskHubSidecarService_TerminateInstance_FullMethodName                     = "/TaskHubSidecarService/TerminateInstance"
	TaskHubSidecarService_SuspendInstance_FullMethodName                       = "/TaskHubSidecarService/SuspendInstance"
	TaskHubSidecarService_ResumeInstance_FullMethodName                        = "/TaskHubSidecarService/ResumeInstance"
	TaskHubSidecarService_QueryInstances_FullMethodName                        = "/TaskHubSidecarService/QueryInstances"
	TaskHubSidecarService_ListInstanceIds_FullMethodName                       = "/TaskHubSidecarService/ListInstanceIds"
	TaskHubSidecarService_PurgeInstances_FullMethodName                        = "/TaskHubSidecarService/PurgeInstances"
	TaskHubSidecarService_GetWorkItems_FullMethodName                          = "/TaskHubSidecarService/GetWorkItems"
	TaskHubSidecarService_CompleteActivityTask_FullMethodName                  = "/TaskHubSidecarService/CompleteActivityTask"
	TaskHubSidecarService_CompleteOrchestratorTask_FullMethodName              = "/TaskHubSidecarService/CompleteOrchestratorTask"
	TaskHubSidecarService_CompleteEntityTask_FullMethodName                    = "/TaskHubSidecarService/CompleteEntityTask"
	TaskHubSidecarService_StreamInstanceHistory_FullMethodName                 = "/TaskHubSidecarService/StreamInstanceHistory"
	TaskHubSidecarService_CreateTaskHub_FullMethodName                         = "/TaskHubSidecarService/CreateTaskHub"
	TaskHubSidecarService_DeleteTaskHub_FullMethodName                         = "/TaskHubSidecarService/DeleteTaskHub"
	TaskHubSidecarService_SignalEntity_FullMethodName                          = "/TaskHubSidecarService/SignalEntity"
	TaskHubSidecarService_GetEntity_FullMethodName                             = "/TaskHubSidecarService/GetEntity"
	TaskHubSidecarService_QueryEntities_FullMethodName                         = "/TaskHubSidecarService/QueryEntities"
	TaskHubSidecarService_CleanEntityStorage_FullMethodName                    = "/TaskHubSidecarService/CleanEntityStorage"
	TaskHubSidecarService_AbandonTaskActivityWorkItem_FullMethodName           = "/TaskHubSidecarService/AbandonTaskActivityWorkItem"
	TaskHubSidecarService_AbandonTaskOrchestratorWorkItem_FullMethodName       = "/TaskHubSidecarService/AbandonTaskOrchestratorWorkItem"
	TaskHubSidecarService_AbandonTaskEntityWorkItem_FullMethodName             = "/TaskHubSidecarService/AbandonTaskEntityWorkItem"
	TaskHubSidecarService_SkipGracefulOrchestrationTerminations_FullMethodName = "/TaskHubSidecarService/SkipGracefulOrchestrationTerminations"
)

Variables

View Source 
var (
	OrchestrationStatus_name = map[int32]string{
		0: "ORCHESTRATION_STATUS_RUNNING",
		1: "ORCHESTRATION_STATUS_COMPLETED",
		2: "ORCHESTRATION_STATUS_CONTINUED_AS_NEW",
		3: "ORCHESTRATION_STATUS_FAILED",
		4: "ORCHESTRATION_STATUS_CANCELED",
		5: "ORCHESTRATION_STATUS_TERMINATED",
		6: "ORCHESTRATION_STATUS_PENDING",
		7: "ORCHESTRATION_STATUS_SUSPENDED",
	}
	OrchestrationStatus_value = map[string]int32{
		"ORCHESTRATION_STATUS_RUNNING":          0,
		"ORCHESTRATION_STATUS_COMPLETED":        1,
		"ORCHESTRATION_STATUS_CONTINUED_AS_NEW": 2,
		"ORCHESTRATION_STATUS_FAILED":           3,
		"ORCHESTRATION_STATUS_CANCELED":         4,
		"ORCHESTRATION_STATUS_TERMINATED":       5,
		"ORCHESTRATION_STATUS_PENDING":          6,
		"ORCHESTRATION_STATUS_SUSPENDED":        7,
	}
)

Enum value maps for OrchestrationStatus.

View Source 
var (
	WorkerCapability_name = map[int32]string{
		0: "WORKER_CAPABILITY_UNSPECIFIED",
		1: "WORKER_CAPABILITY_HISTORY_STREAMING",
		2: "WORKER_CAPABILITY_SCHEDULED_TASKS",
		3: "WORKER_CAPABILITY_LARGE_PAYLOADS",
	}
	WorkerCapability_value = map[string]int32{
		"WORKER_CAPABILITY_UNSPECIFIED":       0,
		"WORKER_CAPABILITY_HISTORY_STREAMING": 1,
		"WORKER_CAPABILITY_SCHEDULED_TASKS":   2,
		"WORKER_CAPABILITY_LARGE_PAYLOADS":    3,
	}
)

Enum value maps for WorkerCapability.

View Source 
var File_orchestrator_service_proto protoreflect.FileDescriptor
View Source 
var TaskHubSidecarService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "TaskHubSidecarService",
	HandlerType: (*TaskHubSidecarServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Hello",
			Handler:    _TaskHubSidecarService_Hello_Handler,
		},
		{
			MethodName: "StartInstance",
			Handler:    _TaskHubSidecarService_StartInstance_Handler,
		},
		{
			MethodName: "GetInstance",
			Handler:    _TaskHubSidecarService_GetInstance_Handler,
		},
		{
			MethodName: "RewindInstance",
			Handler:    _TaskHubSidecarService_RewindInstance_Handler,
		},
		{
			MethodName: "RestartInstance",
			Handler:    _TaskHubSidecarService_RestartInstance_Handler,
		},
		{
			MethodName: "WaitForInstanceStart",
			Handler:    _TaskHubSidecarService_WaitForInstanceStart_Handler,
		},
		{
			MethodName: "WaitForInstanceCompletion",
			Handler:    _TaskHubSidecarService_WaitForInstanceCompletion_Handler,
		},
		{
			MethodName: "RaiseEvent",
			Handler:    _TaskHubSidecarService_RaiseEvent_Handler,
		},
		{
			MethodName: "TerminateInstance",
			Handler:    _TaskHubSidecarService_TerminateInstance_Handler,
		},
		{
			MethodName: "SuspendInstance",
			Handler:    _TaskHubSidecarService_SuspendInstance_Handler,
		},
		{
			MethodName: "ResumeInstance",
			Handler:    _TaskHubSidecarService_ResumeInstance_Handler,
		},
		{
			MethodName: "QueryInstances",
			Handler:    _TaskHubSidecarService_QueryInstances_Handler,
		},
		{
			MethodName: "ListInstanceIds",
			Handler:    _TaskHubSidecarService_ListInstanceIds_Handler,
		},
		{
			MethodName: "PurgeInstances",
			Handler:    _TaskHubSidecarService_PurgeInstances_Handler,
		},
		{
			MethodName: "CompleteActivityTask",
			Handler:    _TaskHubSidecarService_CompleteActivityTask_Handler,
		},
		{
			MethodName: "CompleteOrchestratorTask",
			Handler:    _TaskHubSidecarService_CompleteOrchestratorTask_Handler,
		},
		{
			MethodName: "CompleteEntityTask",
			Handler:    _TaskHubSidecarService_CompleteEntityTask_Handler,
		},
		{
			MethodName: "CreateTaskHub",
			Handler:    _TaskHubSidecarService_CreateTaskHub_Handler,
		},
		{
			MethodName: "DeleteTaskHub",
			Handler:    _TaskHubSidecarService_DeleteTaskHub_Handler,
		},
		{
			MethodName: "SignalEntity",
			Handler:    _TaskHubSidecarService_SignalEntity_Handler,
		},
		{
			MethodName: "GetEntity",
			Handler:    _TaskHubSidecarService_GetEntity_Handler,
		},
		{
			MethodName: "QueryEntities",
			Handler:    _TaskHubSidecarService_QueryEntities_Handler,
		},
		{
			MethodName: "CleanEntityStorage",
			Handler:    _TaskHubSidecarService_CleanEntityStorage_Handler,
		},
		{
			MethodName: "AbandonTaskActivityWorkItem",
			Handler:    _TaskHubSidecarService_AbandonTaskActivityWorkItem_Handler,
		},
		{
			MethodName: "AbandonTaskOrchestratorWorkItem",
			Handler:    _TaskHubSidecarService_AbandonTaskOrchestratorWorkItem_Handler,
		},
		{
			MethodName: "AbandonTaskEntityWorkItem",
			Handler:    _TaskHubSidecarService_AbandonTaskEntityWorkItem_Handler,
		},
		{
			MethodName: "SkipGracefulOrchestrationTerminations",
			Handler:    _TaskHubSidecarService_SkipGracefulOrchestrationTerminations_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetWorkItems",
			Handler:       _TaskHubSidecarService_GetWorkItems_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamInstanceHistory",
			Handler:       _TaskHubSidecarService_StreamInstanceHistory_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "orchestrator_service.proto",
}

TaskHubSidecarService_ServiceDesc is the grpc.ServiceDesc for TaskHubSidecarService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTaskHubSidecarServiceServer 

func RegisterTaskHubSidecarServiceServer(s grpc.ServiceRegistrar, srv TaskHubSidecarServiceServer)

Types

type AbandonActivityTaskRequest 

type AbandonActivityTaskRequest struct {
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// contains filtered or unexported fields
}

func (*AbandonActivityTaskRequest) Descriptor deprecated 

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

Deprecated: Use AbandonActivityTaskRequest.ProtoReflect.Descriptor instead.

func (*AbandonActivityTaskRequest) GetCompletionToken 

func (x *AbandonActivityTaskRequest) GetCompletionToken() string

func (*AbandonActivityTaskRequest) ProtoMessage 

func (*AbandonActivityTaskRequest) ProtoMessage()

func (*AbandonActivityTaskRequest) ProtoReflect 

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

func (*AbandonActivityTaskRequest) Reset 

func (x *AbandonActivityTaskRequest) Reset()

func (*AbandonActivityTaskRequest) String 

func (x *AbandonActivityTaskRequest) String() string

type AbandonActivityTaskResponse 

type AbandonActivityTaskResponse struct {
	// contains filtered or unexported fields
}

func (*AbandonActivityTaskResponse) Descriptor deprecated 

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

Deprecated: Use AbandonActivityTaskResponse.ProtoReflect.Descriptor instead.

func (*AbandonActivityTaskResponse) ProtoMessage 

func (*AbandonActivityTaskResponse) ProtoMessage()

func (*AbandonActivityTaskResponse) ProtoReflect 

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

func (*AbandonActivityTaskResponse) Reset 

func (x *AbandonActivityTaskResponse) Reset()

func (*AbandonActivityTaskResponse) String 

func (x *AbandonActivityTaskResponse) String() string

type AbandonEntityTaskRequest 

type AbandonEntityTaskRequest struct {
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// contains filtered or unexported fields
}

func (*AbandonEntityTaskRequest) Descriptor deprecated 

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

Deprecated: Use AbandonEntityTaskRequest.ProtoReflect.Descriptor instead.

func (*AbandonEntityTaskRequest) GetCompletionToken 

func (x *AbandonEntityTaskRequest) GetCompletionToken() string

func (*AbandonEntityTaskRequest) ProtoMessage 

func (*AbandonEntityTaskRequest) ProtoMessage()

func (*AbandonEntityTaskRequest) ProtoReflect 

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

func (*AbandonEntityTaskRequest) Reset 

func (x *AbandonEntityTaskRequest) Reset()

func (*AbandonEntityTaskRequest) String 

func (x *AbandonEntityTaskRequest) String() string

type AbandonEntityTaskResponse 

type AbandonEntityTaskResponse struct {
	// contains filtered or unexported fields
}

func (*AbandonEntityTaskResponse) Descriptor deprecated 

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

Deprecated: Use AbandonEntityTaskResponse.ProtoReflect.Descriptor instead.

func (*AbandonEntityTaskResponse) ProtoMessage 

func (*AbandonEntityTaskResponse) ProtoMessage()

func (*AbandonEntityTaskResponse) ProtoReflect 

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

func (*AbandonEntityTaskResponse) Reset 

func (x *AbandonEntityTaskResponse) Reset()

func (*AbandonEntityTaskResponse) String 

func (x *AbandonEntityTaskResponse) String() string

type AbandonOrchestrationTaskRequest 

type AbandonOrchestrationTaskRequest struct {
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// contains filtered or unexported fields
}

func (*AbandonOrchestrationTaskRequest) Descriptor deprecated 

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

Deprecated: Use AbandonOrchestrationTaskRequest.ProtoReflect.Descriptor instead.

func (*AbandonOrchestrationTaskRequest) GetCompletionToken 

func (x *AbandonOrchestrationTaskRequest) GetCompletionToken() string

func (*AbandonOrchestrationTaskRequest) ProtoMessage 

func (*AbandonOrchestrationTaskRequest) ProtoMessage()

func (*AbandonOrchestrationTaskRequest) ProtoReflect 

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

func (*AbandonOrchestrationTaskRequest) Reset 

func (x *AbandonOrchestrationTaskRequest) Reset()

func (*AbandonOrchestrationTaskRequest) String 

func (x *AbandonOrchestrationTaskRequest) String() string

type AbandonOrchestrationTaskResponse 

type AbandonOrchestrationTaskResponse struct {
	// contains filtered or unexported fields
}

func (*AbandonOrchestrationTaskResponse) Descriptor deprecated 

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

Deprecated: Use AbandonOrchestrationTaskResponse.ProtoReflect.Descriptor instead.

func (*AbandonOrchestrationTaskResponse) ProtoMessage 

func (*AbandonOrchestrationTaskResponse) ProtoMessage()

func (*AbandonOrchestrationTaskResponse) ProtoReflect 

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

func (*AbandonOrchestrationTaskResponse) Reset 

func (x *AbandonOrchestrationTaskResponse) Reset()

func (*AbandonOrchestrationTaskResponse) String 

func (x *AbandonOrchestrationTaskResponse) String() string

type ActivityFilter 

type ActivityFilter struct {
	Name     string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Versions []string `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityFilter) Descriptor deprecated 

func (*ActivityFilter) Descriptor() ([]byte, []int)

Deprecated: Use ActivityFilter.ProtoReflect.Descriptor instead.

func (*ActivityFilter) GetName 

func (x *ActivityFilter) GetName() string

func (*ActivityFilter) GetVersions 

func (x *ActivityFilter) GetVersions() []string

func (*ActivityFilter) ProtoMessage 

func (*ActivityFilter) ProtoMessage()

func (*ActivityFilter) ProtoReflect 

func (x *ActivityFilter) ProtoReflect() protoreflect.Message

func (*ActivityFilter) Reset 

func (x *ActivityFilter) Reset()

func (*ActivityFilter) String 

func (x *ActivityFilter) String() string

type ActivityRequest 

type ActivityRequest struct {
	Name                  string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version               *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input                 *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	OrchestrationInstance *OrchestrationInstance  `protobuf:"bytes,4,opt,name=orchestrationInstance,proto3" json:"orchestrationInstance,omitempty"`
	TaskId                int32                   `protobuf:"varint,5,opt,name=taskId,proto3" json:"taskId,omitempty"`
	ParentTraceContext    *TraceContext           `protobuf:"bytes,6,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	Tags                  map[string]string       `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ActivityRequest) Descriptor deprecated 

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

Deprecated: Use ActivityRequest.ProtoReflect.Descriptor instead.

func (*ActivityRequest) GetInput 

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

func (*ActivityRequest) GetName 

func (x *ActivityRequest) GetName() string

func (*ActivityRequest) GetOrchestrationInstance 

func (x *ActivityRequest) GetOrchestrationInstance() *OrchestrationInstance

func (*ActivityRequest) GetParentTraceContext 

func (x *ActivityRequest) GetParentTraceContext() *TraceContext

func (*ActivityRequest) GetTags 

func (x *ActivityRequest) GetTags() map[string]string

func (*ActivityRequest) GetTaskId 

func (x *ActivityRequest) GetTaskId() int32

func (*ActivityRequest) GetVersion 

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

func (*ActivityRequest) ProtoMessage 

func (*ActivityRequest) ProtoMessage()

func (*ActivityRequest) ProtoReflect 

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

func (*ActivityRequest) Reset 

func (x *ActivityRequest) Reset()

func (*ActivityRequest) String 

func (x *ActivityRequest) String() string

type ActivityResponse 

type ActivityResponse struct {
	InstanceId      string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	TaskId          int32                   `protobuf:"varint,2,opt,name=taskId,proto3" json:"taskId,omitempty"`
	Result          *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	FailureDetails  *TaskFailureDetails     `protobuf:"bytes,4,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	CompletionToken string                  `protobuf:"bytes,5,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityResponse) Descriptor deprecated 

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

Deprecated: Use ActivityResponse.ProtoReflect.Descriptor instead.

func (*ActivityResponse) GetCompletionToken 

func (x *ActivityResponse) GetCompletionToken() string

func (*ActivityResponse) GetFailureDetails 

func (x *ActivityResponse) GetFailureDetails() *TaskFailureDetails

func (*ActivityResponse) GetInstanceId 

func (x *ActivityResponse) GetInstanceId() string

func (*ActivityResponse) GetResult 

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

func (*ActivityResponse) GetTaskId 

func (x *ActivityResponse) GetTaskId() int32

func (*ActivityResponse) ProtoMessage 

func (*ActivityResponse) ProtoMessage()

func (*ActivityResponse) ProtoReflect 

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

func (*ActivityResponse) Reset 

func (x *ActivityResponse) Reset()

func (*ActivityResponse) String 

func (x *ActivityResponse) String() string

type CleanEntityStorageRequest added in v0.3.2 

type CleanEntityStorageRequest struct {
	ContinuationToken    *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	RemoveEmptyEntities  bool                    `protobuf:"varint,2,opt,name=removeEmptyEntities,proto3" json:"removeEmptyEntities,omitempty"`
	ReleaseOrphanedLocks bool                    `protobuf:"varint,3,opt,name=releaseOrphanedLocks,proto3" json:"releaseOrphanedLocks,omitempty"`
	// contains filtered or unexported fields
}

func (*CleanEntityStorageRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use CleanEntityStorageRequest.ProtoReflect.Descriptor instead.

func (*CleanEntityStorageRequest) GetContinuationToken added in v0.3.2 

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

func (*CleanEntityStorageRequest) GetReleaseOrphanedLocks added in v0.3.2 

func (x *CleanEntityStorageRequest) GetReleaseOrphanedLocks() bool

func (*CleanEntityStorageRequest) GetRemoveEmptyEntities added in v0.3.2 

func (x *CleanEntityStorageRequest) GetRemoveEmptyEntities() bool

func (*CleanEntityStorageRequest) ProtoMessage added in v0.3.2 

func (*CleanEntityStorageRequest) ProtoMessage()

func (*CleanEntityStorageRequest) ProtoReflect added in v0.3.2 

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

func (*CleanEntityStorageRequest) Reset added in v0.3.2 

func (x *CleanEntityStorageRequest) Reset()

func (*CleanEntityStorageRequest) String added in v0.3.2 

func (x *CleanEntityStorageRequest) String() string

type CleanEntityStorageResponse added in v0.3.2 

type CleanEntityStorageResponse struct {
	ContinuationToken     *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	EmptyEntitiesRemoved  int32                   `protobuf:"varint,2,opt,name=emptyEntitiesRemoved,proto3" json:"emptyEntitiesRemoved,omitempty"`
	OrphanedLocksReleased int32                   `protobuf:"varint,3,opt,name=orphanedLocksReleased,proto3" json:"orphanedLocksReleased,omitempty"`
	// contains filtered or unexported fields
}

func (*CleanEntityStorageResponse) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use CleanEntityStorageResponse.ProtoReflect.Descriptor instead.

func (*CleanEntityStorageResponse) GetContinuationToken added in v0.3.2 

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

func (*CleanEntityStorageResponse) GetEmptyEntitiesRemoved added in v0.3.2 

func (x *CleanEntityStorageResponse) GetEmptyEntitiesRemoved() int32

func (*CleanEntityStorageResponse) GetOrphanedLocksReleased added in v0.3.2 

func (x *CleanEntityStorageResponse) GetOrphanedLocksReleased() int32

func (*CleanEntityStorageResponse) ProtoMessage added in v0.3.2 

func (*CleanEntityStorageResponse) ProtoMessage()

func (*CleanEntityStorageResponse) ProtoReflect added in v0.3.2 

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

func (*CleanEntityStorageResponse) Reset added in v0.3.2 

func (x *CleanEntityStorageResponse) Reset()

func (*CleanEntityStorageResponse) String added in v0.3.2 

func (x *CleanEntityStorageResponse) String() string

type CompleteOrchestrationAction 

type CompleteOrchestrationAction struct {
	OrchestrationStatus OrchestrationStatus     `protobuf:"varint,1,opt,name=orchestrationStatus,proto3,enum=OrchestrationStatus" json:"orchestrationStatus,omitempty"`
	Result              *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Details             *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	NewVersion          *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=newVersion,proto3" json:"newVersion,omitempty"`
	CarryoverEvents     []*HistoryEvent         `protobuf:"bytes,5,rep,name=carryoverEvents,proto3" json:"carryoverEvents,omitempty"`
	FailureDetails      *TaskFailureDetails     `protobuf:"bytes,6,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	Tags                map[string]string       `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CompleteOrchestrationAction) Descriptor deprecated 

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

Deprecated: Use CompleteOrchestrationAction.ProtoReflect.Descriptor instead.

func (*CompleteOrchestrationAction) GetCarryoverEvents 

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

func (*CompleteOrchestrationAction) GetDetails 

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

func (*CompleteOrchestrationAction) GetFailureDetails 

func (x *CompleteOrchestrationAction) GetFailureDetails() *TaskFailureDetails

func (*CompleteOrchestrationAction) GetNewVersion 

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

func (*CompleteOrchestrationAction) GetOrchestrationStatus 

func (x *CompleteOrchestrationAction) GetOrchestrationStatus() OrchestrationStatus

func (*CompleteOrchestrationAction) GetResult 

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

func (*CompleteOrchestrationAction) GetTags 

func (x *CompleteOrchestrationAction) GetTags() map[string]string

func (*CompleteOrchestrationAction) ProtoMessage 

func (*CompleteOrchestrationAction) ProtoMessage()

func (*CompleteOrchestrationAction) ProtoReflect 

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

func (*CompleteOrchestrationAction) Reset 

func (x *CompleteOrchestrationAction) Reset()

func (*CompleteOrchestrationAction) String 

func (x *CompleteOrchestrationAction) String() string

type CompleteTaskResponse 

type CompleteTaskResponse struct {
	// contains filtered or unexported fields
}

func (*CompleteTaskResponse) Descriptor deprecated 

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

Deprecated: Use CompleteTaskResponse.ProtoReflect.Descriptor instead.

func (*CompleteTaskResponse) ProtoMessage 

func (*CompleteTaskResponse) ProtoMessage()

func (*CompleteTaskResponse) ProtoReflect 

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

func (*CompleteTaskResponse) Reset 

func (x *CompleteTaskResponse) Reset()

func (*CompleteTaskResponse) String 

func (x *CompleteTaskResponse) String() string

type ContinueAsNewEvent 

type ContinueAsNewEvent struct {
	Input *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinueAsNewEvent) Descriptor deprecated 

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

Deprecated: Use ContinueAsNewEvent.ProtoReflect.Descriptor instead.

func (*ContinueAsNewEvent) GetInput 

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

func (*ContinueAsNewEvent) ProtoMessage 

func (*ContinueAsNewEvent) ProtoMessage()

func (*ContinueAsNewEvent) ProtoReflect 

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

func (*ContinueAsNewEvent) Reset 

func (x *ContinueAsNewEvent) Reset()

func (*ContinueAsNewEvent) String 

func (x *ContinueAsNewEvent) String() string

type CreateInstanceRequest 

type CreateInstanceRequest struct {
	InstanceId                 string                      `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name                       string                      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version                    *wrapperspb.StringValue     `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input                      *wrapperspb.StringValue     `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledStartTimestamp    *timestamppb.Timestamp      `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	OrchestrationIdReusePolicy *OrchestrationIdReusePolicy `protobuf:"bytes,6,opt,name=orchestrationIdReusePolicy,proto3" json:"orchestrationIdReusePolicy,omitempty"`
	ExecutionId                *wrapperspb.StringValue     `protobuf:"bytes,7,opt,name=executionId,proto3" json:"executionId,omitempty"`
	Tags                       map[string]string           `` /* 135-byte string literal not displayed */
	ParentTraceContext         *TraceContext               `protobuf:"bytes,9,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	RequestTime                *timestamppb.Timestamp      `protobuf:"bytes,10,opt,name=requestTime,proto3" json:"requestTime,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateInstanceRequest) Descriptor deprecated 

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

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetExecutionId 

func (x *CreateInstanceRequest) GetExecutionId() *wrapperspb.StringValue

func (*CreateInstanceRequest) GetInput 

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

func (*CreateInstanceRequest) GetInstanceId 

func (x *CreateInstanceRequest) GetInstanceId() string

func (*CreateInstanceRequest) GetName 

func (x *CreateInstanceRequest) GetName() string

func (*CreateInstanceRequest) GetOrchestrationIdReusePolicy added in v0.3.2 

func (x *CreateInstanceRequest) GetOrchestrationIdReusePolicy() *OrchestrationIdReusePolicy

func (*CreateInstanceRequest) GetParentTraceContext 

func (x *CreateInstanceRequest) GetParentTraceContext() *TraceContext

func (*CreateInstanceRequest) GetRequestTime 

func (x *CreateInstanceRequest) GetRequestTime() *timestamppb.Timestamp

func (*CreateInstanceRequest) GetScheduledStartTimestamp 

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

func (*CreateInstanceRequest) GetTags 

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

func (*CreateInstanceRequest) GetVersion 

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

func (*CreateInstanceRequest) ProtoMessage 

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) ProtoReflect 

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

func (*CreateInstanceRequest) Reset 

func (x *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String 

func (x *CreateInstanceRequest) String() string

type CreateInstanceResponse 

type CreateInstanceResponse struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateInstanceResponse) Descriptor deprecated 

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

Deprecated: Use CreateInstanceResponse.ProtoReflect.Descriptor instead.

func (*CreateInstanceResponse) GetInstanceId 

func (x *CreateInstanceResponse) GetInstanceId() string

func (*CreateInstanceResponse) ProtoMessage 

func (*CreateInstanceResponse) ProtoMessage()

func (*CreateInstanceResponse) ProtoReflect 

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

func (*CreateInstanceResponse) Reset 

func (x *CreateInstanceResponse) Reset()

func (*CreateInstanceResponse) String 

func (x *CreateInstanceResponse) String() string

type CreateSubOrchestrationAction 

type CreateSubOrchestrationAction struct {
	InstanceId         string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name               string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version            *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ParentTraceContext *TraceContext           `protobuf:"bytes,5,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	Tags               map[string]string       `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateSubOrchestrationAction) Descriptor deprecated 

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

Deprecated: Use CreateSubOrchestrationAction.ProtoReflect.Descriptor instead.

func (*CreateSubOrchestrationAction) GetInput 

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

func (*CreateSubOrchestrationAction) GetInstanceId 

func (x *CreateSubOrchestrationAction) GetInstanceId() string

func (*CreateSubOrchestrationAction) GetName 

func (x *CreateSubOrchestrationAction) GetName() string

func (*CreateSubOrchestrationAction) GetParentTraceContext 

func (x *CreateSubOrchestrationAction) GetParentTraceContext() *TraceContext

func (*CreateSubOrchestrationAction) GetTags 

func (x *CreateSubOrchestrationAction) GetTags() map[string]string

func (*CreateSubOrchestrationAction) GetVersion 

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

func (*CreateSubOrchestrationAction) ProtoMessage 

func (*CreateSubOrchestrationAction) ProtoMessage()

func (*CreateSubOrchestrationAction) ProtoReflect 

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

func (*CreateSubOrchestrationAction) Reset 

func (x *CreateSubOrchestrationAction) Reset()

func (*CreateSubOrchestrationAction) String 

func (x *CreateSubOrchestrationAction) String() string

type CreateTaskHubRequest 

type CreateTaskHubRequest struct {
	RecreateIfExists bool `protobuf:"varint,1,opt,name=recreateIfExists,proto3" json:"recreateIfExists,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTaskHubRequest) Descriptor deprecated 

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

Deprecated: Use CreateTaskHubRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskHubRequest) GetRecreateIfExists 

func (x *CreateTaskHubRequest) GetRecreateIfExists() bool

func (*CreateTaskHubRequest) ProtoMessage 

func (*CreateTaskHubRequest) ProtoMessage()

func (*CreateTaskHubRequest) ProtoReflect 

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

func (*CreateTaskHubRequest) Reset 

func (x *CreateTaskHubRequest) Reset()

func (*CreateTaskHubRequest) String 

func (x *CreateTaskHubRequest) String() string

type CreateTaskHubResponse 

type CreateTaskHubResponse struct {
	// contains filtered or unexported fields
}

func (*CreateTaskHubResponse) Descriptor deprecated 

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

Deprecated: Use CreateTaskHubResponse.ProtoReflect.Descriptor instead.

func (*CreateTaskHubResponse) ProtoMessage 

func (*CreateTaskHubResponse) ProtoMessage()

func (*CreateTaskHubResponse) ProtoReflect 

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

func (*CreateTaskHubResponse) Reset 

func (x *CreateTaskHubResponse) Reset()

func (*CreateTaskHubResponse) String 

func (x *CreateTaskHubResponse) String() string

type CreateTimerAction 

type CreateTimerAction struct {
	FireAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fireAt,proto3" json:"fireAt,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTimerAction) Descriptor deprecated 

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

Deprecated: Use CreateTimerAction.ProtoReflect.Descriptor instead.

func (*CreateTimerAction) GetFireAt 

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

func (*CreateTimerAction) ProtoMessage 

func (*CreateTimerAction) ProtoMessage()

func (*CreateTimerAction) ProtoReflect 

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

func (*CreateTimerAction) Reset 

func (x *CreateTimerAction) Reset()

func (*CreateTimerAction) String 

func (x *CreateTimerAction) String() string

type DeleteTaskHubRequest 

type DeleteTaskHubRequest struct {
	// contains filtered or unexported fields
}

func (*DeleteTaskHubRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTaskHubRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskHubRequest) ProtoMessage 

func (*DeleteTaskHubRequest) ProtoMessage()

func (*DeleteTaskHubRequest) ProtoReflect 

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

func (*DeleteTaskHubRequest) Reset 

func (x *DeleteTaskHubRequest) Reset()

func (*DeleteTaskHubRequest) String 

func (x *DeleteTaskHubRequest) String() string

type DeleteTaskHubResponse 

type DeleteTaskHubResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteTaskHubResponse) Descriptor deprecated 

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

Deprecated: Use DeleteTaskHubResponse.ProtoReflect.Descriptor instead.

func (*DeleteTaskHubResponse) ProtoMessage 

func (*DeleteTaskHubResponse) ProtoMessage()

func (*DeleteTaskHubResponse) ProtoReflect 

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

func (*DeleteTaskHubResponse) Reset 

func (x *DeleteTaskHubResponse) Reset()

func (*DeleteTaskHubResponse) String 

func (x *DeleteTaskHubResponse) String() string

type EntityBatchRequest added in v0.3.2 

type EntityBatchRequest struct {
	InstanceId  string                     `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	EntityState *wrapperspb.StringValue    `protobuf:"bytes,2,opt,name=entityState,proto3" json:"entityState,omitempty"`
	Operations  []*OperationRequest        `protobuf:"bytes,3,rep,name=operations,proto3" json:"operations,omitempty"`
	Properties  map[string]*structpb.Value `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EntityBatchRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use EntityBatchRequest.ProtoReflect.Descriptor instead.

func (*EntityBatchRequest) GetEntityState added in v0.3.2 

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

func (*EntityBatchRequest) GetInstanceId added in v0.3.2 

func (x *EntityBatchRequest) GetInstanceId() string

func (*EntityBatchRequest) GetOperations added in v0.3.2 

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

func (*EntityBatchRequest) GetProperties 

func (x *EntityBatchRequest) GetProperties() map[string]*structpb.Value

func (*EntityBatchRequest) ProtoMessage added in v0.3.2 

func (*EntityBatchRequest) ProtoMessage()

func (*EntityBatchRequest) ProtoReflect added in v0.3.2 

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

func (*EntityBatchRequest) Reset added in v0.3.2 

func (x *EntityBatchRequest) Reset()

func (*EntityBatchRequest) String added in v0.3.2 

func (x *EntityBatchRequest) String() string

type EntityBatchResult added in v0.3.2 

type EntityBatchResult struct {
	Results         []*OperationResult      `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	Actions         []*OperationAction      `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	EntityState     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=entityState,proto3" json:"entityState,omitempty"`
	FailureDetails  *TaskFailureDetails     `protobuf:"bytes,4,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	CompletionToken string                  `protobuf:"bytes,5,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	OperationInfos  []*OperationInfo        `protobuf:"bytes,6,rep,name=operationInfos,proto3" json:"operationInfos,omitempty"` // used only with DTS
	// Whether or not an entity state is required to complete the original EntityBatchRequest and none was provided.
	RequiresState bool `protobuf:"varint,7,opt,name=requiresState,proto3" json:"requiresState,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityBatchResult) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use EntityBatchResult.ProtoReflect.Descriptor instead.

func (*EntityBatchResult) GetActions added in v0.3.2 

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

func (*EntityBatchResult) GetCompletionToken 

func (x *EntityBatchResult) GetCompletionToken() string

func (*EntityBatchResult) GetEntityState added in v0.3.2 

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

func (*EntityBatchResult) GetFailureDetails added in v0.3.2 

func (x *EntityBatchResult) GetFailureDetails() *TaskFailureDetails

func (*EntityBatchResult) GetOperationInfos 

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

func (*EntityBatchResult) GetRequiresState 

func (x *EntityBatchResult) GetRequiresState() bool

func (*EntityBatchResult) GetResults added in v0.3.2 

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

func (*EntityBatchResult) ProtoMessage added in v0.3.2 

func (*EntityBatchResult) ProtoMessage()

func (*EntityBatchResult) ProtoReflect added in v0.3.2 

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

func (*EntityBatchResult) Reset added in v0.3.2 

func (x *EntityBatchResult) Reset()

func (*EntityBatchResult) String added in v0.3.2 

func (x *EntityBatchResult) String() string

type EntityFilter 

type EntityFilter struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityFilter) Descriptor deprecated 

func (*EntityFilter) Descriptor() ([]byte, []int)

Deprecated: Use EntityFilter.ProtoReflect.Descriptor instead.

func (*EntityFilter) GetName 

func (x *EntityFilter) GetName() string

func (*EntityFilter) ProtoMessage 

func (*EntityFilter) ProtoMessage()

func (*EntityFilter) ProtoReflect 

func (x *EntityFilter) ProtoReflect() protoreflect.Message

func (*EntityFilter) Reset 

func (x *EntityFilter) Reset()

func (*EntityFilter) String 

func (x *EntityFilter) String() string

type EntityLockGrantedEvent 

type EntityLockGrantedEvent struct {
	CriticalSectionId string `protobuf:"bytes,1,opt,name=criticalSectionId,proto3" json:"criticalSectionId,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityLockGrantedEvent) Descriptor deprecated 

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

Deprecated: Use EntityLockGrantedEvent.ProtoReflect.Descriptor instead.

func (*EntityLockGrantedEvent) GetCriticalSectionId 

func (x *EntityLockGrantedEvent) GetCriticalSectionId() string

func (*EntityLockGrantedEvent) ProtoMessage 

func (*EntityLockGrantedEvent) ProtoMessage()

func (*EntityLockGrantedEvent) ProtoReflect 

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

func (*EntityLockGrantedEvent) Reset 

func (x *EntityLockGrantedEvent) Reset()

func (*EntityLockGrantedEvent) String 

func (x *EntityLockGrantedEvent) String() string

type EntityLockRequestedEvent 

type EntityLockRequestedEvent struct {
	CriticalSectionId string                  `protobuf:"bytes,1,opt,name=criticalSectionId,proto3" json:"criticalSectionId,omitempty"`
	LockSet           []string                `protobuf:"bytes,2,rep,name=lockSet,proto3" json:"lockSet,omitempty"`
	Position          int32                   `protobuf:"varint,3,opt,name=position,proto3" json:"position,omitempty"`
	ParentInstanceId  *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"` // used only within messages, null in histories
	// contains filtered or unexported fields
}

func (*EntityLockRequestedEvent) Descriptor deprecated 

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

Deprecated: Use EntityLockRequestedEvent.ProtoReflect.Descriptor instead.

func (*EntityLockRequestedEvent) GetCriticalSectionId 

func (x *EntityLockRequestedEvent) GetCriticalSectionId() string

func (*EntityLockRequestedEvent) GetLockSet 

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

func (*EntityLockRequestedEvent) GetParentInstanceId 

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

func (*EntityLockRequestedEvent) GetPosition 

func (x *EntityLockRequestedEvent) GetPosition() int32

func (*EntityLockRequestedEvent) ProtoMessage 

func (*EntityLockRequestedEvent) ProtoMessage()

func (*EntityLockRequestedEvent) ProtoReflect 

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

func (*EntityLockRequestedEvent) Reset 

func (x *EntityLockRequestedEvent) Reset()

func (*EntityLockRequestedEvent) String 

func (x *EntityLockRequestedEvent) String() string

type EntityMetadata added in v0.3.2 

type EntityMetadata struct {
	InstanceId       string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	LastModifiedTime *timestamppb.Timestamp  `protobuf:"bytes,2,opt,name=lastModifiedTime,proto3" json:"lastModifiedTime,omitempty"`
	BacklogQueueSize int32                   `protobuf:"varint,3,opt,name=backlogQueueSize,proto3" json:"backlogQueueSize,omitempty"`
	LockedBy         *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=lockedBy,proto3" json:"lockedBy,omitempty"`
	SerializedState  *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=serializedState,proto3" json:"serializedState,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityMetadata) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use EntityMetadata.ProtoReflect.Descriptor instead.

func (*EntityMetadata) GetBacklogQueueSize added in v0.3.2 

func (x *EntityMetadata) GetBacklogQueueSize() int32

func (*EntityMetadata) GetInstanceId added in v0.3.2 

func (x *EntityMetadata) GetInstanceId() string

func (*EntityMetadata) GetLastModifiedTime added in v0.3.2 

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

func (*EntityMetadata) GetLockedBy added in v0.3.2 

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

func (*EntityMetadata) GetSerializedState added in v0.3.2 

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

func (*EntityMetadata) ProtoMessage added in v0.3.2 

func (*EntityMetadata) ProtoMessage()

func (*EntityMetadata) ProtoReflect added in v0.3.2 

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

func (*EntityMetadata) Reset added in v0.3.2 

func (x *EntityMetadata) Reset()

func (*EntityMetadata) String added in v0.3.2 

func (x *EntityMetadata) String() string

type EntityOperationCalledEvent 

type EntityOperationCalledEvent struct {
	RequestId         string                  `protobuf:"bytes,1,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Operation         string                  `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	ScheduledTime     *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=scheduledTime,proto3" json:"scheduledTime,omitempty"`
	Input             *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ParentInstanceId  *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"`   // used only within messages, null in histories
	ParentExecutionId *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=parentExecutionId,proto3" json:"parentExecutionId,omitempty"` // used only within messages, null in histories
	TargetInstanceId  *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=targetInstanceId,proto3" json:"targetInstanceId,omitempty"`   // used only within histories, null in messages
	// contains filtered or unexported fields
}

func (*EntityOperationCalledEvent) Descriptor deprecated 

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

Deprecated: Use EntityOperationCalledEvent.ProtoReflect.Descriptor instead.

func (*EntityOperationCalledEvent) GetInput 

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

func (*EntityOperationCalledEvent) GetOperation 

func (x *EntityOperationCalledEvent) GetOperation() string

func (*EntityOperationCalledEvent) GetParentExecutionId 

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

func (*EntityOperationCalledEvent) GetParentInstanceId 

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

func (*EntityOperationCalledEvent) GetRequestId 

func (x *EntityOperationCalledEvent) GetRequestId() string

func (*EntityOperationCalledEvent) GetScheduledTime 

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

func (*EntityOperationCalledEvent) GetTargetInstanceId 

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

func (*EntityOperationCalledEvent) ProtoMessage 

func (*EntityOperationCalledEvent) ProtoMessage()

func (*EntityOperationCalledEvent) ProtoReflect 

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

func (*EntityOperationCalledEvent) Reset 

func (x *EntityOperationCalledEvent) Reset()

func (*EntityOperationCalledEvent) String 

func (x *EntityOperationCalledEvent) String() string

type EntityOperationCompletedEvent 

type EntityOperationCompletedEvent struct {
	RequestId string                  `protobuf:"bytes,1,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Output    *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityOperationCompletedEvent) Descriptor deprecated 

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

Deprecated: Use EntityOperationCompletedEvent.ProtoReflect.Descriptor instead.

func (*EntityOperationCompletedEvent) GetOutput 

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

func (*EntityOperationCompletedEvent) GetRequestId 

func (x *EntityOperationCompletedEvent) GetRequestId() string

func (*EntityOperationCompletedEvent) ProtoMessage 

func (*EntityOperationCompletedEvent) ProtoMessage()

func (*EntityOperationCompletedEvent) ProtoReflect 

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

func (*EntityOperationCompletedEvent) Reset 

func (x *EntityOperationCompletedEvent) Reset()

func (*EntityOperationCompletedEvent) String 

func (x *EntityOperationCompletedEvent) String() string

type EntityOperationFailedEvent 

type EntityOperationFailedEvent struct {
	RequestId      string              `protobuf:"bytes,1,opt,name=requestId,proto3" json:"requestId,omitempty"`
	FailureDetails *TaskFailureDetails `protobuf:"bytes,2,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityOperationFailedEvent) Descriptor deprecated 

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

Deprecated: Use EntityOperationFailedEvent.ProtoReflect.Descriptor instead.

func (*EntityOperationFailedEvent) GetFailureDetails 

func (x *EntityOperationFailedEvent) GetFailureDetails() *TaskFailureDetails

func (*EntityOperationFailedEvent) GetRequestId 

func (x *EntityOperationFailedEvent) GetRequestId() string

func (*EntityOperationFailedEvent) ProtoMessage 

func (*EntityOperationFailedEvent) ProtoMessage()

func (*EntityOperationFailedEvent) ProtoReflect 

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

func (*EntityOperationFailedEvent) Reset 

func (x *EntityOperationFailedEvent) Reset()

func (*EntityOperationFailedEvent) String 

func (x *EntityOperationFailedEvent) String() string

type EntityOperationSignaledEvent 

type EntityOperationSignaledEvent struct {
	RequestId        string                  `protobuf:"bytes,1,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Operation        string                  `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	ScheduledTime    *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=scheduledTime,proto3" json:"scheduledTime,omitempty"`
	Input            *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	TargetInstanceId *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=targetInstanceId,proto3" json:"targetInstanceId,omitempty"` // used only within histories, null in messages
	// contains filtered or unexported fields
}

func (*EntityOperationSignaledEvent) Descriptor deprecated 

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

Deprecated: Use EntityOperationSignaledEvent.ProtoReflect.Descriptor instead.

func (*EntityOperationSignaledEvent) GetInput 

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

func (*EntityOperationSignaledEvent) GetOperation 

func (x *EntityOperationSignaledEvent) GetOperation() string

func (*EntityOperationSignaledEvent) GetRequestId 

func (x *EntityOperationSignaledEvent) GetRequestId() string

func (*EntityOperationSignaledEvent) GetScheduledTime 

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

func (*EntityOperationSignaledEvent) GetTargetInstanceId 

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

func (*EntityOperationSignaledEvent) ProtoMessage 

func (*EntityOperationSignaledEvent) ProtoMessage()

func (*EntityOperationSignaledEvent) ProtoReflect 

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

func (*EntityOperationSignaledEvent) Reset 

func (x *EntityOperationSignaledEvent) Reset()

func (*EntityOperationSignaledEvent) String 

func (x *EntityOperationSignaledEvent) String() string

type EntityQuery added in v0.3.2 

type EntityQuery struct {
	InstanceIdStartsWith *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=instanceIdStartsWith,proto3" json:"instanceIdStartsWith,omitempty"`
	LastModifiedFrom     *timestamppb.Timestamp  `protobuf:"bytes,2,opt,name=lastModifiedFrom,proto3" json:"lastModifiedFrom,omitempty"`
	LastModifiedTo       *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=lastModifiedTo,proto3" json:"lastModifiedTo,omitempty"`
	IncludeState         bool                    `protobuf:"varint,4,opt,name=includeState,proto3" json:"includeState,omitempty"`
	IncludeTransient     bool                    `protobuf:"varint,5,opt,name=includeTransient,proto3" json:"includeTransient,omitempty"`
	PageSize             *wrapperspb.Int32Value  `protobuf:"bytes,6,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	ContinuationToken    *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityQuery) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use EntityQuery.ProtoReflect.Descriptor instead.

func (*EntityQuery) GetContinuationToken added in v0.3.2 

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

func (*EntityQuery) GetIncludeState added in v0.3.2 

func (x *EntityQuery) GetIncludeState() bool

func (*EntityQuery) GetIncludeTransient added in v0.3.2 

func (x *EntityQuery) GetIncludeTransient() bool

func (*EntityQuery) GetInstanceIdStartsWith added in v0.3.2 

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

func (*EntityQuery) GetLastModifiedFrom added in v0.3.2 

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

func (*EntityQuery) GetLastModifiedTo added in v0.3.2 

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

func (*EntityQuery) GetPageSize added in v0.3.2 

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

func (*EntityQuery) ProtoMessage added in v0.3.2 

func (*EntityQuery) ProtoMessage()

func (*EntityQuery) ProtoReflect added in v0.3.2 

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

func (*EntityQuery) Reset added in v0.3.2 

func (x *EntityQuery) Reset()

func (*EntityQuery) String added in v0.3.2 

func (x *EntityQuery) String() string

type EntityRequest 

type EntityRequest struct {
	InstanceId        string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId       string                  `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	EntityState       *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=entityState,proto3" json:"entityState,omitempty"` // null if entity does not exist
	OperationRequests []*HistoryEvent         `protobuf:"bytes,4,rep,name=operationRequests,proto3" json:"operationRequests,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityRequest) Descriptor deprecated 

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

Deprecated: Use EntityRequest.ProtoReflect.Descriptor instead.

func (*EntityRequest) GetEntityState 

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

func (*EntityRequest) GetExecutionId 

func (x *EntityRequest) GetExecutionId() string

func (*EntityRequest) GetInstanceId 

func (x *EntityRequest) GetInstanceId() string

func (*EntityRequest) GetOperationRequests 

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

func (*EntityRequest) ProtoMessage 

func (*EntityRequest) ProtoMessage()

func (*EntityRequest) ProtoReflect 

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

func (*EntityRequest) Reset 

func (x *EntityRequest) Reset()

func (*EntityRequest) String 

func (x *EntityRequest) String() string

type EntityUnlockSentEvent 

type EntityUnlockSentEvent struct {
	CriticalSectionId string                  `protobuf:"bytes,1,opt,name=criticalSectionId,proto3" json:"criticalSectionId,omitempty"`
	ParentInstanceId  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"` // used only within messages, null in histories
	TargetInstanceId  *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=targetInstanceId,proto3" json:"targetInstanceId,omitempty"` // used only within histories, null in messages
	// contains filtered or unexported fields
}

func (*EntityUnlockSentEvent) Descriptor deprecated 

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

Deprecated: Use EntityUnlockSentEvent.ProtoReflect.Descriptor instead.

func (*EntityUnlockSentEvent) GetCriticalSectionId 

func (x *EntityUnlockSentEvent) GetCriticalSectionId() string

func (*EntityUnlockSentEvent) GetParentInstanceId 

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

func (*EntityUnlockSentEvent) GetTargetInstanceId 

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

func (*EntityUnlockSentEvent) ProtoMessage 

func (*EntityUnlockSentEvent) ProtoMessage()

func (*EntityUnlockSentEvent) ProtoReflect 

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

func (*EntityUnlockSentEvent) Reset 

func (x *EntityUnlockSentEvent) Reset()

func (*EntityUnlockSentEvent) String 

func (x *EntityUnlockSentEvent) String() string

type EventRaisedEvent 

type EventRaisedEvent struct {
	Name  string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Input *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*EventRaisedEvent) Descriptor deprecated 

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

Deprecated: Use EventRaisedEvent.ProtoReflect.Descriptor instead.

func (*EventRaisedEvent) GetInput 

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

func (*EventRaisedEvent) GetName 

func (x *EventRaisedEvent) GetName() string

func (*EventRaisedEvent) ProtoMessage 

func (*EventRaisedEvent) ProtoMessage()

func (*EventRaisedEvent) ProtoReflect 

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

func (*EventRaisedEvent) Reset 

func (x *EventRaisedEvent) Reset()

func (*EventRaisedEvent) String 

func (x *EventRaisedEvent) String() string

type EventSentEvent 

type EventSentEvent struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name       string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Input      *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*EventSentEvent) Descriptor deprecated 

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

Deprecated: Use EventSentEvent.ProtoReflect.Descriptor instead.

func (*EventSentEvent) GetInput 

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

func (*EventSentEvent) GetInstanceId 

func (x *EventSentEvent) GetInstanceId() string

func (*EventSentEvent) GetName 

func (x *EventSentEvent) GetName() string

func (*EventSentEvent) ProtoMessage 

func (*EventSentEvent) ProtoMessage()

func (*EventSentEvent) ProtoReflect 

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

func (*EventSentEvent) Reset 

func (x *EventSentEvent) Reset()

func (*EventSentEvent) String 

func (x *EventSentEvent) String() string

type ExecutionCompletedEvent 

type ExecutionCompletedEvent struct {
	OrchestrationStatus OrchestrationStatus     `protobuf:"varint,1,opt,name=orchestrationStatus,proto3,enum=OrchestrationStatus" json:"orchestrationStatus,omitempty"`
	Result              *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	FailureDetails      *TaskFailureDetails     `protobuf:"bytes,3,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionCompletedEvent) Descriptor deprecated 

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

Deprecated: Use ExecutionCompletedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionCompletedEvent) GetFailureDetails 

func (x *ExecutionCompletedEvent) GetFailureDetails() *TaskFailureDetails

func (*ExecutionCompletedEvent) GetOrchestrationStatus 

func (x *ExecutionCompletedEvent) GetOrchestrationStatus() OrchestrationStatus

func (*ExecutionCompletedEvent) GetResult 

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

func (*ExecutionCompletedEvent) ProtoMessage 

func (*ExecutionCompletedEvent) ProtoMessage()

func (*ExecutionCompletedEvent) ProtoReflect 

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

func (*ExecutionCompletedEvent) Reset 

func (x *ExecutionCompletedEvent) Reset()

func (*ExecutionCompletedEvent) String 

func (x *ExecutionCompletedEvent) String() string

type ExecutionResumedEvent added in v0.1.1 

type ExecutionResumedEvent struct {
	Input *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionResumedEvent) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use ExecutionResumedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionResumedEvent) GetInput added in v0.1.1 

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

func (*ExecutionResumedEvent) ProtoMessage added in v0.1.1 

func (*ExecutionResumedEvent) ProtoMessage()

func (*ExecutionResumedEvent) ProtoReflect added in v0.1.1 

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

func (*ExecutionResumedEvent) Reset added in v0.1.1 

func (x *ExecutionResumedEvent) Reset()

func (*ExecutionResumedEvent) String added in v0.1.1 

func (x *ExecutionResumedEvent) String() string

type ExecutionRewoundEvent 

type ExecutionRewoundEvent struct {
	Reason             *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	ParentExecutionId  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=parentExecutionId,proto3" json:"parentExecutionId,omitempty"`   // used only for rewinding suborchestrations, null otherwise
	InstanceId         *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=instanceId,proto3" json:"instanceId,omitempty"`                 // used only for rewinding suborchestrations, null otherwise
	ParentTraceContext *TraceContext           `protobuf:"bytes,4,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"` // used only for rewinding suborchestrations, null otherwise
	Name               *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`                             // used by DTS backend only
	Version            *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`                       // used by DTS backend only
	Input              *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=input,proto3" json:"input,omitempty"`                           // used by DTS backend only
	ParentInstance     *ParentInstanceInfo     `protobuf:"bytes,8,opt,name=parentInstance,proto3" json:"parentInstance,omitempty"`         // used by DTS backend only
	Tags               map[string]string       ``                                                                                          // used by DTS backend only
	/* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecutionRewoundEvent) Descriptor deprecated 

func (*ExecutionRewoundEvent) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionRewoundEvent.ProtoReflect.Descriptor instead.

func (*ExecutionRewoundEvent) GetInput 

func (x *ExecutionRewoundEvent) GetInput() *wrapperspb.StringValue

func (*ExecutionRewoundEvent) GetInstanceId 

func (x *ExecutionRewoundEvent) GetInstanceId() *wrapperspb.StringValue

func (*ExecutionRewoundEvent) GetName 

func (x *ExecutionRewoundEvent) GetName() *wrapperspb.StringValue

func (*ExecutionRewoundEvent) GetParentExecutionId 

func (x *ExecutionRewoundEvent) GetParentExecutionId() *wrapperspb.StringValue

func (*ExecutionRewoundEvent) GetParentInstance 

func (x *ExecutionRewoundEvent) GetParentInstance() *ParentInstanceInfo

func (*ExecutionRewoundEvent) GetParentTraceContext 

func (x *ExecutionRewoundEvent) GetParentTraceContext() *TraceContext

func (*ExecutionRewoundEvent) GetReason 

func (x *ExecutionRewoundEvent) GetReason() *wrapperspb.StringValue

func (*ExecutionRewoundEvent) GetTags 

func (x *ExecutionRewoundEvent) GetTags() map[string]string

func (*ExecutionRewoundEvent) GetVersion 

func (x *ExecutionRewoundEvent) GetVersion() *wrapperspb.StringValue

func (*ExecutionRewoundEvent) ProtoMessage 

func (*ExecutionRewoundEvent) ProtoMessage()

func (*ExecutionRewoundEvent) ProtoReflect 

func (x *ExecutionRewoundEvent) ProtoReflect() protoreflect.Message

func (*ExecutionRewoundEvent) Reset 

func (x *ExecutionRewoundEvent) Reset()

func (*ExecutionRewoundEvent) String 

func (x *ExecutionRewoundEvent) String() string

type ExecutionStartedEvent 

type ExecutionStartedEvent struct {
	Name                    string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version                 *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input                   *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	OrchestrationInstance   *OrchestrationInstance  `protobuf:"bytes,4,opt,name=orchestrationInstance,proto3" json:"orchestrationInstance,omitempty"`
	ParentInstance          *ParentInstanceInfo     `protobuf:"bytes,5,opt,name=parentInstance,proto3" json:"parentInstance,omitempty"`
	ScheduledStartTimestamp *timestamppb.Timestamp  `protobuf:"bytes,6,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	ParentTraceContext      *TraceContext           `protobuf:"bytes,7,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	OrchestrationSpanID     *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=orchestrationSpanID,proto3" json:"orchestrationSpanID,omitempty"`
	Tags                    map[string]string       `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecutionStartedEvent) Descriptor deprecated 

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

Deprecated: Use ExecutionStartedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionStartedEvent) GetInput 

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

func (*ExecutionStartedEvent) GetName 

func (x *ExecutionStartedEvent) GetName() string

func (*ExecutionStartedEvent) GetOrchestrationInstance 

func (x *ExecutionStartedEvent) GetOrchestrationInstance() *OrchestrationInstance

func (*ExecutionStartedEvent) GetOrchestrationSpanID added in v0.1.1 

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

func (*ExecutionStartedEvent) GetParentInstance 

func (x *ExecutionStartedEvent) GetParentInstance() *ParentInstanceInfo

func (*ExecutionStartedEvent) GetParentTraceContext added in v0.1.1 

func (x *ExecutionStartedEvent) GetParentTraceContext() *TraceContext

func (*ExecutionStartedEvent) GetScheduledStartTimestamp 

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

func (*ExecutionStartedEvent) GetTags 

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

func (*ExecutionStartedEvent) GetVersion 

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

func (*ExecutionStartedEvent) ProtoMessage 

func (*ExecutionStartedEvent) ProtoMessage()

func (*ExecutionStartedEvent) ProtoReflect 

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

func (*ExecutionStartedEvent) Reset 

func (x *ExecutionStartedEvent) Reset()

func (*ExecutionStartedEvent) String 

func (x *ExecutionStartedEvent) String() string

type ExecutionSuspendedEvent added in v0.1.1 

type ExecutionSuspendedEvent struct {
	Input *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionSuspendedEvent) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use ExecutionSuspendedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionSuspendedEvent) GetInput added in v0.1.1 

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

func (*ExecutionSuspendedEvent) ProtoMessage added in v0.1.1 

func (*ExecutionSuspendedEvent) ProtoMessage()

func (*ExecutionSuspendedEvent) ProtoReflect added in v0.1.1 

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

func (*ExecutionSuspendedEvent) Reset added in v0.1.1 

func (x *ExecutionSuspendedEvent) Reset()

func (*ExecutionSuspendedEvent) String added in v0.1.1 

func (x *ExecutionSuspendedEvent) String() string

type ExecutionTerminatedEvent 

type ExecutionTerminatedEvent struct {
	Input   *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	Recurse bool                    `protobuf:"varint,2,opt,name=recurse,proto3" json:"recurse,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionTerminatedEvent) Descriptor deprecated 

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

Deprecated: Use ExecutionTerminatedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionTerminatedEvent) GetInput 

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

func (*ExecutionTerminatedEvent) GetRecurse added in v0.3.0 

func (x *ExecutionTerminatedEvent) GetRecurse() bool

func (*ExecutionTerminatedEvent) ProtoMessage 

func (*ExecutionTerminatedEvent) ProtoMessage()

func (*ExecutionTerminatedEvent) ProtoReflect 

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

func (*ExecutionTerminatedEvent) Reset 

func (x *ExecutionTerminatedEvent) Reset()

func (*ExecutionTerminatedEvent) String 

func (x *ExecutionTerminatedEvent) String() string

type GenericEvent 

type GenericEvent struct {
	Data *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GenericEvent) Descriptor deprecated 

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

Deprecated: Use GenericEvent.ProtoReflect.Descriptor instead.

func (*GenericEvent) GetData 

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

func (*GenericEvent) ProtoMessage 

func (*GenericEvent) ProtoMessage()

func (*GenericEvent) ProtoReflect 

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

func (*GenericEvent) Reset 

func (x *GenericEvent) Reset()

func (*GenericEvent) String 

func (x *GenericEvent) String() string

type GetEntityRequest added in v0.3.2 

type GetEntityRequest struct {
	InstanceId   string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	IncludeState bool   `protobuf:"varint,2,opt,name=includeState,proto3" json:"includeState,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEntityRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.

func (*GetEntityRequest) GetIncludeState added in v0.3.2 

func (x *GetEntityRequest) GetIncludeState() bool

func (*GetEntityRequest) GetInstanceId added in v0.3.2 

func (x *GetEntityRequest) GetInstanceId() string

func (*GetEntityRequest) ProtoMessage added in v0.3.2 

func (*GetEntityRequest) ProtoMessage()

func (*GetEntityRequest) ProtoReflect added in v0.3.2 

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

func (*GetEntityRequest) Reset added in v0.3.2 

func (x *GetEntityRequest) Reset()

func (*GetEntityRequest) String added in v0.3.2 

func (x *GetEntityRequest) String() string

type GetEntityResponse added in v0.3.2 

type GetEntityResponse struct {
	Exists bool            `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	Entity *EntityMetadata `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEntityResponse) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use GetEntityResponse.ProtoReflect.Descriptor instead.

func (*GetEntityResponse) GetEntity added in v0.3.2 

func (x *GetEntityResponse) GetEntity() *EntityMetadata

func (*GetEntityResponse) GetExists added in v0.3.2 

func (x *GetEntityResponse) GetExists() bool

func (*GetEntityResponse) ProtoMessage added in v0.3.2 

func (*GetEntityResponse) ProtoMessage()

func (*GetEntityResponse) ProtoReflect added in v0.3.2 

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

func (*GetEntityResponse) Reset added in v0.3.2 

func (x *GetEntityResponse) Reset()

func (*GetEntityResponse) String added in v0.3.2 

func (x *GetEntityResponse) String() string

type GetInstanceRequest 

type GetInstanceRequest struct {
	InstanceId          string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	GetInputsAndOutputs bool   `protobuf:"varint,2,opt,name=getInputsAndOutputs,proto3" json:"getInputsAndOutputs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInstanceRequest) Descriptor deprecated 

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

Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceRequest) GetGetInputsAndOutputs 

func (x *GetInstanceRequest) GetGetInputsAndOutputs() bool

func (*GetInstanceRequest) GetInstanceId 

func (x *GetInstanceRequest) GetInstanceId() string

func (*GetInstanceRequest) ProtoMessage 

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) ProtoReflect 

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

func (*GetInstanceRequest) Reset 

func (x *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String 

func (x *GetInstanceRequest) String() string

type GetInstanceResponse 

type GetInstanceResponse struct {
	Exists             bool                `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	OrchestrationState *OrchestrationState `protobuf:"bytes,2,opt,name=orchestrationState,proto3" json:"orchestrationState,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInstanceResponse) Descriptor deprecated 

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

Deprecated: Use GetInstanceResponse.ProtoReflect.Descriptor instead.

func (*GetInstanceResponse) GetExists 

func (x *GetInstanceResponse) GetExists() bool

func (*GetInstanceResponse) GetOrchestrationState 

func (x *GetInstanceResponse) GetOrchestrationState() *OrchestrationState

func (*GetInstanceResponse) ProtoMessage 

func (*GetInstanceResponse) ProtoMessage()

func (*GetInstanceResponse) ProtoReflect 

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

func (*GetInstanceResponse) Reset 

func (x *GetInstanceResponse) Reset()

func (*GetInstanceResponse) String 

func (x *GetInstanceResponse) String() string

type GetWorkItemsRequest 

type GetWorkItemsRequest struct {
	MaxConcurrentOrchestrationWorkItems int32              `protobuf:"varint,1,opt,name=maxConcurrentOrchestrationWorkItems,proto3" json:"maxConcurrentOrchestrationWorkItems,omitempty"`
	MaxConcurrentActivityWorkItems      int32              `protobuf:"varint,2,opt,name=maxConcurrentActivityWorkItems,proto3" json:"maxConcurrentActivityWorkItems,omitempty"`
	MaxConcurrentEntityWorkItems        int32              `protobuf:"varint,3,opt,name=maxConcurrentEntityWorkItems,proto3" json:"maxConcurrentEntityWorkItems,omitempty"`
	Capabilities                        []WorkerCapability `protobuf:"varint,10,rep,packed,name=capabilities,proto3,enum=WorkerCapability" json:"capabilities,omitempty"`
	WorkItemFilters                     *WorkItemFilters   `protobuf:"bytes,11,opt,name=workItemFilters,proto3" json:"workItemFilters,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkItemsRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkItemsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkItemsRequest) GetCapabilities 

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

func (*GetWorkItemsRequest) GetMaxConcurrentActivityWorkItems 

func (x *GetWorkItemsRequest) GetMaxConcurrentActivityWorkItems() int32

func (*GetWorkItemsRequest) GetMaxConcurrentEntityWorkItems 

func (x *GetWorkItemsRequest) GetMaxConcurrentEntityWorkItems() int32

func (*GetWorkItemsRequest) GetMaxConcurrentOrchestrationWorkItems 

func (x *GetWorkItemsRequest) GetMaxConcurrentOrchestrationWorkItems() int32

func (*GetWorkItemsRequest) GetWorkItemFilters 

func (x *GetWorkItemsRequest) GetWorkItemFilters() *WorkItemFilters

func (*GetWorkItemsRequest) ProtoMessage 

func (*GetWorkItemsRequest) ProtoMessage()

func (*GetWorkItemsRequest) ProtoReflect 

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

func (*GetWorkItemsRequest) Reset 

func (x *GetWorkItemsRequest) Reset()

func (*GetWorkItemsRequest) String 

func (x *GetWorkItemsRequest) String() string

type HealthPing 

type HealthPing struct {
	// contains filtered or unexported fields
}

func (*HealthPing) Descriptor deprecated 

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

Deprecated: Use HealthPing.ProtoReflect.Descriptor instead.

func (*HealthPing) ProtoMessage 

func (*HealthPing) ProtoMessage()

func (*HealthPing) ProtoReflect 

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

func (*HealthPing) Reset 

func (x *HealthPing) Reset()

func (*HealthPing) String 

func (x *HealthPing) String() string

type HistoryChunk 

type HistoryChunk struct {
	Events []*HistoryEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryChunk) Descriptor deprecated 

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

Deprecated: Use HistoryChunk.ProtoReflect.Descriptor instead.

func (*HistoryChunk) GetEvents 

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

func (*HistoryChunk) ProtoMessage 

func (*HistoryChunk) ProtoMessage()

func (*HistoryChunk) ProtoReflect 

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

func (*HistoryChunk) Reset 

func (x *HistoryChunk) Reset()

func (*HistoryChunk) String 

func (x *HistoryChunk) String() string

type HistoryEvent 

type HistoryEvent struct {
	EventId   int32                  `protobuf:"varint,1,opt,name=eventId,proto3" json:"eventId,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are valid to be assigned to EventType:
	//
	//	*HistoryEvent_ExecutionStarted
	//	*HistoryEvent_ExecutionCompleted
	//	*HistoryEvent_ExecutionTerminated
	//	*HistoryEvent_TaskScheduled
	//	*HistoryEvent_TaskCompleted
	//	*HistoryEvent_TaskFailed
	//	*HistoryEvent_SubOrchestrationInstanceCreated
	//	*HistoryEvent_SubOrchestrationInstanceCompleted
	//	*HistoryEvent_SubOrchestrationInstanceFailed
	//	*HistoryEvent_TimerCreated
	//	*HistoryEvent_TimerFired
	//	*HistoryEvent_OrchestratorStarted
	//	*HistoryEvent_OrchestratorCompleted
	//	*HistoryEvent_EventSent
	//	*HistoryEvent_EventRaised
	//	*HistoryEvent_GenericEvent
	//	*HistoryEvent_HistoryState
	//	*HistoryEvent_ContinueAsNew
	//	*HistoryEvent_ExecutionSuspended
	//	*HistoryEvent_ExecutionResumed
	//	*HistoryEvent_EntityOperationSignaled
	//	*HistoryEvent_EntityOperationCalled
	//	*HistoryEvent_EntityOperationCompleted
	//	*HistoryEvent_EntityOperationFailed
	//	*HistoryEvent_EntityLockRequested
	//	*HistoryEvent_EntityLockGranted
	//	*HistoryEvent_EntityUnlockSent
	//	*HistoryEvent_ExecutionRewound
	EventType isHistoryEvent_EventType `protobuf_oneof:"eventType"`
	// contains filtered or unexported fields
}

func (*HistoryEvent) Descriptor deprecated 

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

Deprecated: Use HistoryEvent.ProtoReflect.Descriptor instead.

func (*HistoryEvent) GetContinueAsNew 

func (x *HistoryEvent) GetContinueAsNew() *ContinueAsNewEvent

func (*HistoryEvent) GetEntityLockGranted 

func (x *HistoryEvent) GetEntityLockGranted() *EntityLockGrantedEvent

func (*HistoryEvent) GetEntityLockRequested 

func (x *HistoryEvent) GetEntityLockRequested() *EntityLockRequestedEvent

func (*HistoryEvent) GetEntityOperationCalled 

func (x *HistoryEvent) GetEntityOperationCalled() *EntityOperationCalledEvent

func (*HistoryEvent) GetEntityOperationCompleted 

func (x *HistoryEvent) GetEntityOperationCompleted() *EntityOperationCompletedEvent

func (*HistoryEvent) GetEntityOperationFailed 

func (x *HistoryEvent) GetEntityOperationFailed() *EntityOperationFailedEvent

func (*HistoryEvent) GetEntityOperationSignaled 

func (x *HistoryEvent) GetEntityOperationSignaled() *EntityOperationSignaledEvent

func (*HistoryEvent) GetEntityUnlockSent 

func (x *HistoryEvent) GetEntityUnlockSent() *EntityUnlockSentEvent

func (*HistoryEvent) GetEventId 

func (x *HistoryEvent) GetEventId() int32

func (*HistoryEvent) GetEventRaised 

func (x *HistoryEvent) GetEventRaised() *EventRaisedEvent

func (*HistoryEvent) GetEventSent 

func (x *HistoryEvent) GetEventSent() *EventSentEvent

func (*HistoryEvent) GetEventType 

func (x *HistoryEvent) GetEventType() isHistoryEvent_EventType

func (*HistoryEvent) GetExecutionCompleted 

func (x *HistoryEvent) GetExecutionCompleted() *ExecutionCompletedEvent

func (*HistoryEvent) GetExecutionResumed added in v0.1.1 

func (x *HistoryEvent) GetExecutionResumed() *ExecutionResumedEvent

func (*HistoryEvent) GetExecutionRewound 

func (x *HistoryEvent) GetExecutionRewound() *ExecutionRewoundEvent

func (*HistoryEvent) GetExecutionStarted 

func (x *HistoryEvent) GetExecutionStarted() *ExecutionStartedEvent

func (*HistoryEvent) GetExecutionSuspended added in v0.1.1 

func (x *HistoryEvent) GetExecutionSuspended() *ExecutionSuspendedEvent

func (*HistoryEvent) GetExecutionTerminated 

func (x *HistoryEvent) GetExecutionTerminated() *ExecutionTerminatedEvent

func (*HistoryEvent) GetGenericEvent 

func (x *HistoryEvent) GetGenericEvent() *GenericEvent

func (*HistoryEvent) GetHistoryState 

func (x *HistoryEvent) GetHistoryState() *HistoryStateEvent

func (*HistoryEvent) GetOrchestratorCompleted 

func (x *HistoryEvent) GetOrchestratorCompleted() *OrchestratorCompletedEvent

func (*HistoryEvent) GetOrchestratorStarted 

func (x *HistoryEvent) GetOrchestratorStarted() *OrchestratorStartedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceCompleted 

func (x *HistoryEvent) GetSubOrchestrationInstanceCompleted() *SubOrchestrationInstanceCompletedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceCreated 

func (x *HistoryEvent) GetSubOrchestrationInstanceCreated() *SubOrchestrationInstanceCreatedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceFailed 

func (x *HistoryEvent) GetSubOrchestrationInstanceFailed() *SubOrchestrationInstanceFailedEvent

func (*HistoryEvent) GetTaskCompleted 

func (x *HistoryEvent) GetTaskCompleted() *TaskCompletedEvent

func (*HistoryEvent) GetTaskFailed 

func (x *HistoryEvent) GetTaskFailed() *TaskFailedEvent

func (*HistoryEvent) GetTaskScheduled 

func (x *HistoryEvent) GetTaskScheduled() *TaskScheduledEvent

func (*HistoryEvent) GetTimerCreated 

func (x *HistoryEvent) GetTimerCreated() *TimerCreatedEvent

func (*HistoryEvent) GetTimerFired 

func (x *HistoryEvent) GetTimerFired() *TimerFiredEvent

func (*HistoryEvent) GetTimestamp 

func (x *HistoryEvent) GetTimestamp() *timestamppb.Timestamp

func (*HistoryEvent) ProtoMessage 

func (*HistoryEvent) ProtoMessage()

func (*HistoryEvent) ProtoReflect 

func (x *HistoryEvent) ProtoReflect() protoreflect.Message

func (*HistoryEvent) Reset 

func (x *HistoryEvent) Reset()

func (*HistoryEvent) String 

func (x *HistoryEvent) String() string

type HistoryEvent_ContinueAsNew 

type HistoryEvent_ContinueAsNew struct {
	ContinueAsNew *ContinueAsNewEvent `protobuf:"bytes,20,opt,name=continueAsNew,proto3,oneof"`
}

type HistoryEvent_EntityLockGranted 

type HistoryEvent_EntityLockGranted struct {
	EntityLockGranted *EntityLockGrantedEvent `protobuf:"bytes,28,opt,name=entityLockGranted,proto3,oneof"`
}

type HistoryEvent_EntityLockRequested 

type HistoryEvent_EntityLockRequested struct {
	EntityLockRequested *EntityLockRequestedEvent `protobuf:"bytes,27,opt,name=entityLockRequested,proto3,oneof"`
}

type HistoryEvent_EntityOperationCalled 

type HistoryEvent_EntityOperationCalled struct {
	EntityOperationCalled *EntityOperationCalledEvent `protobuf:"bytes,24,opt,name=entityOperationCalled,proto3,oneof"`
}

type HistoryEvent_EntityOperationCompleted 

type HistoryEvent_EntityOperationCompleted struct {
	EntityOperationCompleted *EntityOperationCompletedEvent `protobuf:"bytes,25,opt,name=entityOperationCompleted,proto3,oneof"`
}

type HistoryEvent_EntityOperationFailed 

type HistoryEvent_EntityOperationFailed struct {
	EntityOperationFailed *EntityOperationFailedEvent `protobuf:"bytes,26,opt,name=entityOperationFailed,proto3,oneof"`
}

type HistoryEvent_EntityOperationSignaled 

type HistoryEvent_EntityOperationSignaled struct {
	EntityOperationSignaled *EntityOperationSignaledEvent `protobuf:"bytes,23,opt,name=entityOperationSignaled,proto3,oneof"`
}

type HistoryEvent_EntityUnlockSent 

type HistoryEvent_EntityUnlockSent struct {
	EntityUnlockSent *EntityUnlockSentEvent `protobuf:"bytes,29,opt,name=entityUnlockSent,proto3,oneof"`
}

type HistoryEvent_EventRaised 

type HistoryEvent_EventRaised struct {
	EventRaised *EventRaisedEvent `protobuf:"bytes,17,opt,name=eventRaised,proto3,oneof"`
}

type HistoryEvent_EventSent 

type HistoryEvent_EventSent struct {
	EventSent *EventSentEvent `protobuf:"bytes,16,opt,name=eventSent,proto3,oneof"`
}

type HistoryEvent_ExecutionCompleted 

type HistoryEvent_ExecutionCompleted struct {
	ExecutionCompleted *ExecutionCompletedEvent `protobuf:"bytes,4,opt,name=executionCompleted,proto3,oneof"`
}

type HistoryEvent_ExecutionResumed added in v0.1.1 

type HistoryEvent_ExecutionResumed struct {
	ExecutionResumed *ExecutionResumedEvent `protobuf:"bytes,22,opt,name=executionResumed,proto3,oneof"`
}

type HistoryEvent_ExecutionRewound 

type HistoryEvent_ExecutionRewound struct {
	ExecutionRewound *ExecutionRewoundEvent `protobuf:"bytes,30,opt,name=executionRewound,proto3,oneof"`
}

type HistoryEvent_ExecutionStarted 

type HistoryEvent_ExecutionStarted struct {
	ExecutionStarted *ExecutionStartedEvent `protobuf:"bytes,3,opt,name=executionStarted,proto3,oneof"`
}

type HistoryEvent_ExecutionSuspended added in v0.1.1 

type HistoryEvent_ExecutionSuspended struct {
	ExecutionSuspended *ExecutionSuspendedEvent `protobuf:"bytes,21,opt,name=executionSuspended,proto3,oneof"`
}

type HistoryEvent_ExecutionTerminated 

type HistoryEvent_ExecutionTerminated struct {
	ExecutionTerminated *ExecutionTerminatedEvent `protobuf:"bytes,5,opt,name=executionTerminated,proto3,oneof"`
}

type HistoryEvent_GenericEvent 

type HistoryEvent_GenericEvent struct {
	GenericEvent *GenericEvent `protobuf:"bytes,18,opt,name=genericEvent,proto3,oneof"`
}

type HistoryEvent_HistoryState 

type HistoryEvent_HistoryState struct {
	HistoryState *HistoryStateEvent `protobuf:"bytes,19,opt,name=historyState,proto3,oneof"`
}

type HistoryEvent_OrchestratorCompleted 

type HistoryEvent_OrchestratorCompleted struct {
	OrchestratorCompleted *OrchestratorCompletedEvent `protobuf:"bytes,15,opt,name=orchestratorCompleted,proto3,oneof"`
}

type HistoryEvent_OrchestratorStarted 

type HistoryEvent_OrchestratorStarted struct {
	OrchestratorStarted *OrchestratorStartedEvent `protobuf:"bytes,14,opt,name=orchestratorStarted,proto3,oneof"`
}

type HistoryEvent_SubOrchestrationInstanceCompleted 

type HistoryEvent_SubOrchestrationInstanceCompleted struct {
	SubOrchestrationInstanceCompleted *SubOrchestrationInstanceCompletedEvent `protobuf:"bytes,10,opt,name=subOrchestrationInstanceCompleted,proto3,oneof"`
}

type HistoryEvent_SubOrchestrationInstanceCreated 

type HistoryEvent_SubOrchestrationInstanceCreated struct {
	SubOrchestrationInstanceCreated *SubOrchestrationInstanceCreatedEvent `protobuf:"bytes,9,opt,name=subOrchestrationInstanceCreated,proto3,oneof"`
}

type HistoryEvent_SubOrchestrationInstanceFailed 

type HistoryEvent_SubOrchestrationInstanceFailed struct {
	SubOrchestrationInstanceFailed *SubOrchestrationInstanceFailedEvent `protobuf:"bytes,11,opt,name=subOrchestrationInstanceFailed,proto3,oneof"`
}

type HistoryEvent_TaskCompleted 

type HistoryEvent_TaskCompleted struct {
	TaskCompleted *TaskCompletedEvent `protobuf:"bytes,7,opt,name=taskCompleted,proto3,oneof"`
}

type HistoryEvent_TaskFailed 

type HistoryEvent_TaskFailed struct {
	TaskFailed *TaskFailedEvent `protobuf:"bytes,8,opt,name=taskFailed,proto3,oneof"`
}

type HistoryEvent_TaskScheduled 

type HistoryEvent_TaskScheduled struct {
	TaskScheduled *TaskScheduledEvent `protobuf:"bytes,6,opt,name=taskScheduled,proto3,oneof"`
}

type HistoryEvent_TimerCreated 

type HistoryEvent_TimerCreated struct {
	TimerCreated *TimerCreatedEvent `protobuf:"bytes,12,opt,name=timerCreated,proto3,oneof"`
}

type HistoryEvent_TimerFired 

type HistoryEvent_TimerFired struct {
	TimerFired *TimerFiredEvent `protobuf:"bytes,13,opt,name=timerFired,proto3,oneof"`
}

type HistoryStateEvent 

type HistoryStateEvent struct {
	OrchestrationState *OrchestrationState `protobuf:"bytes,1,opt,name=orchestrationState,proto3" json:"orchestrationState,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryStateEvent) Descriptor deprecated 

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

Deprecated: Use HistoryStateEvent.ProtoReflect.Descriptor instead.

func (*HistoryStateEvent) GetOrchestrationState 

func (x *HistoryStateEvent) GetOrchestrationState() *OrchestrationState

func (*HistoryStateEvent) ProtoMessage 

func (*HistoryStateEvent) ProtoMessage()

func (*HistoryStateEvent) ProtoReflect 

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

func (*HistoryStateEvent) Reset 

func (x *HistoryStateEvent) Reset()

func (*HistoryStateEvent) String 

func (x *HistoryStateEvent) String() string

type InstanceBatch 

type InstanceBatch struct {

	// A maximum of 500 instance IDs can be provided in this list.
	InstanceIds []string `protobuf:"bytes,1,rep,name=instanceIds,proto3" json:"instanceIds,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceBatch) Descriptor deprecated 

func (*InstanceBatch) Descriptor() ([]byte, []int)

Deprecated: Use InstanceBatch.ProtoReflect.Descriptor instead.

func (*InstanceBatch) GetInstanceIds 

func (x *InstanceBatch) GetInstanceIds() []string

func (*InstanceBatch) ProtoMessage 

func (*InstanceBatch) ProtoMessage()

func (*InstanceBatch) ProtoReflect 

func (x *InstanceBatch) ProtoReflect() protoreflect.Message

func (*InstanceBatch) Reset 

func (x *InstanceBatch) Reset()

func (*InstanceBatch) String 

func (x *InstanceBatch) String() string

type InstanceQuery 

type InstanceQuery struct {
	RuntimeStatus         []OrchestrationStatus     `protobuf:"varint,1,rep,packed,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	CreatedTimeFrom       *timestamppb.Timestamp    `protobuf:"bytes,2,opt,name=createdTimeFrom,proto3" json:"createdTimeFrom,omitempty"`
	CreatedTimeTo         *timestamppb.Timestamp    `protobuf:"bytes,3,opt,name=createdTimeTo,proto3" json:"createdTimeTo,omitempty"`
	TaskHubNames          []*wrapperspb.StringValue `protobuf:"bytes,4,rep,name=taskHubNames,proto3" json:"taskHubNames,omitempty"`
	MaxInstanceCount      int32                     `protobuf:"varint,5,opt,name=maxInstanceCount,proto3" json:"maxInstanceCount,omitempty"`
	ContinuationToken     *wrapperspb.StringValue   `protobuf:"bytes,6,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	InstanceIdPrefix      *wrapperspb.StringValue   `protobuf:"bytes,7,opt,name=instanceIdPrefix,proto3" json:"instanceIdPrefix,omitempty"`
	FetchInputsAndOutputs bool                      `protobuf:"varint,8,opt,name=fetchInputsAndOutputs,proto3" json:"fetchInputsAndOutputs,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceQuery) Descriptor deprecated 

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

Deprecated: Use InstanceQuery.ProtoReflect.Descriptor instead.

func (*InstanceQuery) GetContinuationToken 

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

func (*InstanceQuery) GetCreatedTimeFrom 

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

func (*InstanceQuery) GetCreatedTimeTo 

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

func (*InstanceQuery) GetFetchInputsAndOutputs 

func (x *InstanceQuery) GetFetchInputsAndOutputs() bool

func (*InstanceQuery) GetInstanceIdPrefix 

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

func (*InstanceQuery) GetMaxInstanceCount 

func (x *InstanceQuery) GetMaxInstanceCount() int32

func (*InstanceQuery) GetRuntimeStatus 

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

func (*InstanceQuery) GetTaskHubNames 

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

func (*InstanceQuery) ProtoMessage 

func (*InstanceQuery) ProtoMessage()

func (*InstanceQuery) ProtoReflect 

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

func (*InstanceQuery) Reset 

func (x *InstanceQuery) Reset()

func (*InstanceQuery) String 

func (x *InstanceQuery) String() string

type ListInstanceIdsRequest 

type ListInstanceIdsRequest struct {
	RuntimeStatus     []OrchestrationStatus   `protobuf:"varint,1,rep,packed,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	CompletedTimeFrom *timestamppb.Timestamp  `protobuf:"bytes,2,opt,name=completedTimeFrom,proto3" json:"completedTimeFrom,omitempty"`
	CompletedTimeTo   *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=completedTimeTo,proto3" json:"completedTimeTo,omitempty"`
	PageSize          int32                   `protobuf:"varint,4,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	LastInstanceKey   *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=lastInstanceKey,proto3" json:"lastInstanceKey,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInstanceIdsRequest) Descriptor deprecated 

func (*ListInstanceIdsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListInstanceIdsRequest.ProtoReflect.Descriptor instead.

func (*ListInstanceIdsRequest) GetCompletedTimeFrom 

func (x *ListInstanceIdsRequest) GetCompletedTimeFrom() *timestamppb.Timestamp

func (*ListInstanceIdsRequest) GetCompletedTimeTo 

func (x *ListInstanceIdsRequest) GetCompletedTimeTo() *timestamppb.Timestamp

func (*ListInstanceIdsRequest) GetLastInstanceKey 

func (x *ListInstanceIdsRequest) GetLastInstanceKey() *wrapperspb.StringValue

func (*ListInstanceIdsRequest) GetPageSize 

func (x *ListInstanceIdsRequest) GetPageSize() int32

func (*ListInstanceIdsRequest) GetRuntimeStatus 

func (x *ListInstanceIdsRequest) GetRuntimeStatus() []OrchestrationStatus

func (*ListInstanceIdsRequest) ProtoMessage 

func (*ListInstanceIdsRequest) ProtoMessage()

func (*ListInstanceIdsRequest) ProtoReflect 

func (x *ListInstanceIdsRequest) ProtoReflect() protoreflect.Message

func (*ListInstanceIdsRequest) Reset 

func (x *ListInstanceIdsRequest) Reset()

func (*ListInstanceIdsRequest) String 

func (x *ListInstanceIdsRequest) String() string

type ListInstanceIdsResponse 

type ListInstanceIdsResponse struct {
	InstanceIds     []string                `protobuf:"bytes,1,rep,name=instanceIds,proto3" json:"instanceIds,omitempty"`
	LastInstanceKey *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=lastInstanceKey,proto3" json:"lastInstanceKey,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInstanceIdsResponse) Descriptor deprecated 

func (*ListInstanceIdsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListInstanceIdsResponse.ProtoReflect.Descriptor instead.

func (*ListInstanceIdsResponse) GetInstanceIds 

func (x *ListInstanceIdsResponse) GetInstanceIds() []string

func (*ListInstanceIdsResponse) GetLastInstanceKey 

func (x *ListInstanceIdsResponse) GetLastInstanceKey() *wrapperspb.StringValue

func (*ListInstanceIdsResponse) ProtoMessage 

func (*ListInstanceIdsResponse) ProtoMessage()

func (*ListInstanceIdsResponse) ProtoReflect 

func (x *ListInstanceIdsResponse) ProtoReflect() protoreflect.Message

func (*ListInstanceIdsResponse) Reset 

func (x *ListInstanceIdsResponse) Reset()

func (*ListInstanceIdsResponse) String 

func (x *ListInstanceIdsResponse) String() string

type OperationAction added in v0.3.2 

type OperationAction struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to OperationActionType:
	//
	//	*OperationAction_SendSignal
	//	*OperationAction_StartNewOrchestration
	OperationActionType isOperationAction_OperationActionType `protobuf_oneof:"operationActionType"`
	// contains filtered or unexported fields
}

func (*OperationAction) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use OperationAction.ProtoReflect.Descriptor instead.

func (*OperationAction) GetId added in v0.3.2 

func (x *OperationAction) GetId() int32

func (*OperationAction) GetOperationActionType added in v0.3.2 

func (x *OperationAction) GetOperationActionType() isOperationAction_OperationActionType

func (*OperationAction) GetSendSignal added in v0.3.2 

func (x *OperationAction) GetSendSignal() *SendSignalAction

func (*OperationAction) GetStartNewOrchestration added in v0.3.2 

func (x *OperationAction) GetStartNewOrchestration() *StartNewOrchestrationAction

func (*OperationAction) ProtoMessage added in v0.3.2 

func (*OperationAction) ProtoMessage()

func (*OperationAction) ProtoReflect added in v0.3.2 

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

func (*OperationAction) Reset added in v0.3.2 

func (x *OperationAction) Reset()

func (*OperationAction) String added in v0.3.2 

func (x *OperationAction) String() string

type OperationAction_SendSignal added in v0.3.2 

type OperationAction_SendSignal struct {
	SendSignal *SendSignalAction `protobuf:"bytes,2,opt,name=sendSignal,proto3,oneof"`
}

type OperationAction_StartNewOrchestration added in v0.3.2 

type OperationAction_StartNewOrchestration struct {
	StartNewOrchestration *StartNewOrchestrationAction `protobuf:"bytes,3,opt,name=startNewOrchestration,proto3,oneof"`
}

type OperationInfo 

type OperationInfo struct {
	RequestId           string                 `protobuf:"bytes,1,opt,name=requestId,proto3" json:"requestId,omitempty"`
	ResponseDestination *OrchestrationInstance `protobuf:"bytes,2,opt,name=responseDestination,proto3" json:"responseDestination,omitempty"` // null for signals
	// contains filtered or unexported fields
}

func (*OperationInfo) Descriptor deprecated 

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

Deprecated: Use OperationInfo.ProtoReflect.Descriptor instead.

func (*OperationInfo) GetRequestId 

func (x *OperationInfo) GetRequestId() string

func (*OperationInfo) GetResponseDestination 

func (x *OperationInfo) GetResponseDestination() *OrchestrationInstance

func (*OperationInfo) ProtoMessage 

func (*OperationInfo) ProtoMessage()

func (*OperationInfo) ProtoReflect 

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

func (*OperationInfo) Reset 

func (x *OperationInfo) Reset()

func (*OperationInfo) String 

func (x *OperationInfo) String() string

type OperationRequest added in v0.3.2 

type OperationRequest struct {
	Operation    string                  `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	RequestId    string                  `protobuf:"bytes,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Input        *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	TraceContext *TraceContext           `protobuf:"bytes,4,opt,name=traceContext,proto3" json:"traceContext,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use OperationRequest.ProtoReflect.Descriptor instead.

func (*OperationRequest) GetInput added in v0.3.2 

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

func (*OperationRequest) GetOperation added in v0.3.2 

func (x *OperationRequest) GetOperation() string

func (*OperationRequest) GetRequestId added in v0.3.2 

func (x *OperationRequest) GetRequestId() string

func (*OperationRequest) GetTraceContext 

func (x *OperationRequest) GetTraceContext() *TraceContext

func (*OperationRequest) ProtoMessage added in v0.3.2 

func (*OperationRequest) ProtoMessage()

func (*OperationRequest) ProtoReflect added in v0.3.2 

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

func (*OperationRequest) Reset added in v0.3.2 

func (x *OperationRequest) Reset()

func (*OperationRequest) String added in v0.3.2 

func (x *OperationRequest) String() string

type OperationResult added in v0.3.2 

type OperationResult struct {

	// Types that are valid to be assigned to ResultType:
	//
	//	*OperationResult_Success
	//	*OperationResult_Failure
	ResultType isOperationResult_ResultType `protobuf_oneof:"resultType"`
	// contains filtered or unexported fields
}

func (*OperationResult) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use OperationResult.ProtoReflect.Descriptor instead.

func (*OperationResult) GetFailure added in v0.3.2 

func (x *OperationResult) GetFailure() *OperationResultFailure

func (*OperationResult) GetResultType added in v0.3.2 

func (x *OperationResult) GetResultType() isOperationResult_ResultType

func (*OperationResult) GetSuccess added in v0.3.2 

func (x *OperationResult) GetSuccess() *OperationResultSuccess

func (*OperationResult) ProtoMessage added in v0.3.2 

func (*OperationResult) ProtoMessage()

func (*OperationResult) ProtoReflect added in v0.3.2 

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

func (*OperationResult) Reset added in v0.3.2 

func (x *OperationResult) Reset()

func (*OperationResult) String added in v0.3.2 

func (x *OperationResult) String() string

type OperationResultFailure added in v0.3.2 

type OperationResultFailure struct {
	FailureDetails *TaskFailureDetails    `protobuf:"bytes,1,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	StartTimeUtc   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=startTimeUtc,proto3" json:"startTimeUtc,omitempty"`
	EndTimeUtc     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=endTimeUtc,proto3" json:"endTimeUtc,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationResultFailure) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use OperationResultFailure.ProtoReflect.Descriptor instead.

func (*OperationResultFailure) GetEndTimeUtc 

func (x *OperationResultFailure) GetEndTimeUtc() *timestamppb.Timestamp

func (*OperationResultFailure) GetFailureDetails added in v0.3.2 

func (x *OperationResultFailure) GetFailureDetails() *TaskFailureDetails

func (*OperationResultFailure) GetStartTimeUtc 

func (x *OperationResultFailure) GetStartTimeUtc() *timestamppb.Timestamp

func (*OperationResultFailure) ProtoMessage added in v0.3.2 

func (*OperationResultFailure) ProtoMessage()

func (*OperationResultFailure) ProtoReflect added in v0.3.2 

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

func (*OperationResultFailure) Reset added in v0.3.2 

func (x *OperationResultFailure) Reset()

func (*OperationResultFailure) String added in v0.3.2 

func (x *OperationResultFailure) String() string

type OperationResultSuccess added in v0.3.2 

type OperationResultSuccess struct {
	Result       *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	StartTimeUtc *timestamppb.Timestamp  `protobuf:"bytes,2,opt,name=startTimeUtc,proto3" json:"startTimeUtc,omitempty"`
	EndTimeUtc   *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=endTimeUtc,proto3" json:"endTimeUtc,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationResultSuccess) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use OperationResultSuccess.ProtoReflect.Descriptor instead.

func (*OperationResultSuccess) GetEndTimeUtc 

func (x *OperationResultSuccess) GetEndTimeUtc() *timestamppb.Timestamp

func (*OperationResultSuccess) GetResult added in v0.3.2 

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

func (*OperationResultSuccess) GetStartTimeUtc 

func (x *OperationResultSuccess) GetStartTimeUtc() *timestamppb.Timestamp

func (*OperationResultSuccess) ProtoMessage added in v0.3.2 

func (*OperationResultSuccess) ProtoMessage()

func (*OperationResultSuccess) ProtoReflect added in v0.3.2 

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

func (*OperationResultSuccess) Reset added in v0.3.2 

func (x *OperationResultSuccess) Reset()

func (*OperationResultSuccess) String added in v0.3.2 

func (x *OperationResultSuccess) String() string

type OperationResult_Failure added in v0.3.2 

type OperationResult_Failure struct {
	Failure *OperationResultFailure `protobuf:"bytes,2,opt,name=failure,proto3,oneof"`
}

type OperationResult_Success added in v0.3.2 

type OperationResult_Success struct {
	Success *OperationResultSuccess `protobuf:"bytes,1,opt,name=success,proto3,oneof"`
}

type OrchestrationFilter 

type OrchestrationFilter struct {
	Name     string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Versions []string `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestrationFilter) Descriptor deprecated 

func (*OrchestrationFilter) Descriptor() ([]byte, []int)

Deprecated: Use OrchestrationFilter.ProtoReflect.Descriptor instead.

func (*OrchestrationFilter) GetName 

func (x *OrchestrationFilter) GetName() string

func (*OrchestrationFilter) GetVersions 

func (x *OrchestrationFilter) GetVersions() []string

func (*OrchestrationFilter) ProtoMessage 

func (*OrchestrationFilter) ProtoMessage()

func (*OrchestrationFilter) ProtoReflect 

func (x *OrchestrationFilter) ProtoReflect() protoreflect.Message

func (*OrchestrationFilter) Reset 

func (x *OrchestrationFilter) Reset()

func (*OrchestrationFilter) String 

func (x *OrchestrationFilter) String() string

type OrchestrationIdReusePolicy added in v0.3.2 

type OrchestrationIdReusePolicy struct {
	ReplaceableStatus []OrchestrationStatus `protobuf:"varint,1,rep,packed,name=replaceableStatus,proto3,enum=OrchestrationStatus" json:"replaceableStatus,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestrationIdReusePolicy) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use OrchestrationIdReusePolicy.ProtoReflect.Descriptor instead.

func (*OrchestrationIdReusePolicy) GetReplaceableStatus 

func (x *OrchestrationIdReusePolicy) GetReplaceableStatus() []OrchestrationStatus

func (*OrchestrationIdReusePolicy) ProtoMessage added in v0.3.2 

func (*OrchestrationIdReusePolicy) ProtoMessage()

func (*OrchestrationIdReusePolicy) ProtoReflect added in v0.3.2 

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

func (*OrchestrationIdReusePolicy) Reset added in v0.3.2 

func (x *OrchestrationIdReusePolicy) Reset()

func (*OrchestrationIdReusePolicy) String added in v0.3.2 

func (x *OrchestrationIdReusePolicy) String() string

type OrchestrationInstance 

type OrchestrationInstance struct {
	InstanceId  string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestrationInstance) Descriptor deprecated 

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

Deprecated: Use OrchestrationInstance.ProtoReflect.Descriptor instead.

func (*OrchestrationInstance) GetExecutionId 

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

func (*OrchestrationInstance) GetInstanceId 

func (x *OrchestrationInstance) GetInstanceId() string

func (*OrchestrationInstance) ProtoMessage 

func (*OrchestrationInstance) ProtoMessage()

func (*OrchestrationInstance) ProtoReflect 

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

func (*OrchestrationInstance) Reset 

func (x *OrchestrationInstance) Reset()

func (*OrchestrationInstance) String 

func (x *OrchestrationInstance) String() string

type OrchestrationState 

type OrchestrationState struct {
	InstanceId              string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name                    string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version                 *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	OrchestrationStatus     OrchestrationStatus     `protobuf:"varint,4,opt,name=orchestrationStatus,proto3,enum=OrchestrationStatus" json:"orchestrationStatus,omitempty"`
	ScheduledStartTimestamp *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	CreatedTimestamp        *timestamppb.Timestamp  `protobuf:"bytes,6,opt,name=createdTimestamp,proto3" json:"createdTimestamp,omitempty"`
	LastUpdatedTimestamp    *timestamppb.Timestamp  `protobuf:"bytes,7,opt,name=lastUpdatedTimestamp,proto3" json:"lastUpdatedTimestamp,omitempty"`
	Input                   *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=input,proto3" json:"input,omitempty"`
	Output                  *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=output,proto3" json:"output,omitempty"`
	CustomStatus            *wrapperspb.StringValue `protobuf:"bytes,10,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	FailureDetails          *TaskFailureDetails     `protobuf:"bytes,11,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	ExecutionId             *wrapperspb.StringValue `protobuf:"bytes,12,opt,name=executionId,proto3" json:"executionId,omitempty"`
	CompletedTimestamp      *timestamppb.Timestamp  `protobuf:"bytes,13,opt,name=completedTimestamp,proto3" json:"completedTimestamp,omitempty"`
	ParentInstanceId        *wrapperspb.StringValue `protobuf:"bytes,14,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"`
	Tags                    map[string]string       `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OrchestrationState) Descriptor deprecated 

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

Deprecated: Use OrchestrationState.ProtoReflect.Descriptor instead.

func (*OrchestrationState) GetCompletedTimestamp 

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

func (*OrchestrationState) GetCreatedTimestamp 

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

func (*OrchestrationState) GetCustomStatus 

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

func (*OrchestrationState) GetExecutionId 

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

func (*OrchestrationState) GetFailureDetails 

func (x *OrchestrationState) GetFailureDetails() *TaskFailureDetails

func (*OrchestrationState) GetInput 

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

func (*OrchestrationState) GetInstanceId 

func (x *OrchestrationState) GetInstanceId() string

func (*OrchestrationState) GetLastUpdatedTimestamp 

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

func (*OrchestrationState) GetName 

func (x *OrchestrationState) GetName() string

func (*OrchestrationState) GetOrchestrationStatus 

func (x *OrchestrationState) GetOrchestrationStatus() OrchestrationStatus

func (*OrchestrationState) GetOutput 

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

func (*OrchestrationState) GetParentInstanceId 

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

func (*OrchestrationState) GetScheduledStartTimestamp 

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

func (*OrchestrationState) GetTags 

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

func (*OrchestrationState) GetVersion 

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

func (*OrchestrationState) ProtoMessage 

func (*OrchestrationState) ProtoMessage()

func (*OrchestrationState) ProtoReflect 

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

func (*OrchestrationState) Reset 

func (x *OrchestrationState) Reset()

func (*OrchestrationState) String 

func (x *OrchestrationState) String() string

type OrchestrationStatus 

type OrchestrationStatus int32
const (
	OrchestrationStatus_ORCHESTRATION_STATUS_RUNNING          OrchestrationStatus = 0
	OrchestrationStatus_ORCHESTRATION_STATUS_COMPLETED        OrchestrationStatus = 1
	OrchestrationStatus_ORCHESTRATION_STATUS_CONTINUED_AS_NEW OrchestrationStatus = 2
	OrchestrationStatus_ORCHESTRATION_STATUS_FAILED           OrchestrationStatus = 3
	OrchestrationStatus_ORCHESTRATION_STATUS_CANCELED         OrchestrationStatus = 4
	OrchestrationStatus_ORCHESTRATION_STATUS_TERMINATED       OrchestrationStatus = 5
	OrchestrationStatus_ORCHESTRATION_STATUS_PENDING          OrchestrationStatus = 6
	OrchestrationStatus_ORCHESTRATION_STATUS_SUSPENDED        OrchestrationStatus = 7
)

func (OrchestrationStatus) Descriptor 

func (OrchestrationStatus) Descriptor() protoreflect.EnumDescriptor

func (OrchestrationStatus) Enum 

func (x OrchestrationStatus) Enum() *OrchestrationStatus

func (OrchestrationStatus) EnumDescriptor deprecated 

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

Deprecated: Use OrchestrationStatus.Descriptor instead.

func (OrchestrationStatus) Number 

func (x OrchestrationStatus) Number() protoreflect.EnumNumber

func (OrchestrationStatus) String 

func (x OrchestrationStatus) String() string

func (OrchestrationStatus) Type 

func (OrchestrationStatus) Type() protoreflect.EnumType

type OrchestrationTraceContext 

type OrchestrationTraceContext struct {
	SpanID        *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=spanID,proto3" json:"spanID,omitempty"`
	SpanStartTime *timestamppb.Timestamp  `protobuf:"bytes,2,opt,name=spanStartTime,proto3" json:"spanStartTime,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestrationTraceContext) Descriptor deprecated 

func (*OrchestrationTraceContext) Descriptor() ([]byte, []int)

Deprecated: Use OrchestrationTraceContext.ProtoReflect.Descriptor instead.

func (*OrchestrationTraceContext) GetSpanID 

func (x *OrchestrationTraceContext) GetSpanID() *wrapperspb.StringValue

func (*OrchestrationTraceContext) GetSpanStartTime 

func (x *OrchestrationTraceContext) GetSpanStartTime() *timestamppb.Timestamp

func (*OrchestrationTraceContext) ProtoMessage 

func (*OrchestrationTraceContext) ProtoMessage()

func (*OrchestrationTraceContext) ProtoReflect 

func (x *OrchestrationTraceContext) ProtoReflect() protoreflect.Message

func (*OrchestrationTraceContext) Reset 

func (x *OrchestrationTraceContext) Reset()

func (*OrchestrationTraceContext) String 

func (x *OrchestrationTraceContext) String() string

type OrchestratorAction 

type OrchestratorAction struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to OrchestratorActionType:
	//
	//	*OrchestratorAction_ScheduleTask
	//	*OrchestratorAction_CreateSubOrchestration
	//	*OrchestratorAction_CreateTimer
	//	*OrchestratorAction_SendEvent
	//	*OrchestratorAction_CompleteOrchestration
	//	*OrchestratorAction_TerminateOrchestration
	//	*OrchestratorAction_SendEntityMessage
	//	*OrchestratorAction_RewindOrchestration
	OrchestratorActionType isOrchestratorAction_OrchestratorActionType `protobuf_oneof:"orchestratorActionType"`
	// contains filtered or unexported fields
}

func (*OrchestratorAction) Descriptor deprecated 

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

Deprecated: Use OrchestratorAction.ProtoReflect.Descriptor instead.

func (*OrchestratorAction) GetCompleteOrchestration 

func (x *OrchestratorAction) GetCompleteOrchestration() *CompleteOrchestrationAction

func (*OrchestratorAction) GetCreateSubOrchestration 

func (x *OrchestratorAction) GetCreateSubOrchestration() *CreateSubOrchestrationAction

func (*OrchestratorAction) GetCreateTimer 

func (x *OrchestratorAction) GetCreateTimer() *CreateTimerAction

func (*OrchestratorAction) GetId 

func (x *OrchestratorAction) GetId() int32

func (*OrchestratorAction) GetOrchestratorActionType 

func (x *OrchestratorAction) GetOrchestratorActionType() isOrchestratorAction_OrchestratorActionType

func (*OrchestratorAction) GetRewindOrchestration 

func (x *OrchestratorAction) GetRewindOrchestration() *RewindOrchestrationAction

func (*OrchestratorAction) GetScheduleTask 

func (x *OrchestratorAction) GetScheduleTask() *ScheduleTaskAction

func (*OrchestratorAction) GetSendEntityMessage 

func (x *OrchestratorAction) GetSendEntityMessage() *SendEntityMessageAction

func (*OrchestratorAction) GetSendEvent 

func (x *OrchestratorAction) GetSendEvent() *SendEventAction

func (*OrchestratorAction) GetTerminateOrchestration added in v0.3.0 

func (x *OrchestratorAction) GetTerminateOrchestration() *TerminateOrchestrationAction

func (*OrchestratorAction) ProtoMessage 

func (*OrchestratorAction) ProtoMessage()

func (*OrchestratorAction) ProtoReflect 

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

func (*OrchestratorAction) Reset 

func (x *OrchestratorAction) Reset()

func (*OrchestratorAction) String 

func (x *OrchestratorAction) String() string

type OrchestratorAction_CompleteOrchestration 

type OrchestratorAction_CompleteOrchestration struct {
	CompleteOrchestration *CompleteOrchestrationAction `protobuf:"bytes,6,opt,name=completeOrchestration,proto3,oneof"`
}

type OrchestratorAction_CreateSubOrchestration 

type OrchestratorAction_CreateSubOrchestration struct {
	CreateSubOrchestration *CreateSubOrchestrationAction `protobuf:"bytes,3,opt,name=createSubOrchestration,proto3,oneof"`
}

type OrchestratorAction_CreateTimer 

type OrchestratorAction_CreateTimer struct {
	CreateTimer *CreateTimerAction `protobuf:"bytes,4,opt,name=createTimer,proto3,oneof"`
}

type OrchestratorAction_RewindOrchestration 

type OrchestratorAction_RewindOrchestration struct {
	RewindOrchestration *RewindOrchestrationAction `protobuf:"bytes,9,opt,name=rewindOrchestration,proto3,oneof"`
}

type OrchestratorAction_ScheduleTask 

type OrchestratorAction_ScheduleTask struct {
	ScheduleTask *ScheduleTaskAction `protobuf:"bytes,2,opt,name=scheduleTask,proto3,oneof"`
}

type OrchestratorAction_SendEntityMessage 

type OrchestratorAction_SendEntityMessage struct {
	SendEntityMessage *SendEntityMessageAction `protobuf:"bytes,8,opt,name=sendEntityMessage,proto3,oneof"`
}

type OrchestratorAction_SendEvent 

type OrchestratorAction_SendEvent struct {
	SendEvent *SendEventAction `protobuf:"bytes,5,opt,name=sendEvent,proto3,oneof"`
}

type OrchestratorAction_TerminateOrchestration added in v0.3.0 

type OrchestratorAction_TerminateOrchestration struct {
	TerminateOrchestration *TerminateOrchestrationAction `protobuf:"bytes,7,opt,name=terminateOrchestration,proto3,oneof"`
}

type OrchestratorCompletedEvent 

type OrchestratorCompletedEvent struct {
	// contains filtered or unexported fields
}

func (*OrchestratorCompletedEvent) Descriptor deprecated 

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

Deprecated: Use OrchestratorCompletedEvent.ProtoReflect.Descriptor instead.

func (*OrchestratorCompletedEvent) ProtoMessage 

func (*OrchestratorCompletedEvent) ProtoMessage()

func (*OrchestratorCompletedEvent) ProtoReflect 

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

func (*OrchestratorCompletedEvent) Reset 

func (x *OrchestratorCompletedEvent) Reset()

func (*OrchestratorCompletedEvent) String 

func (x *OrchestratorCompletedEvent) String() string

type OrchestratorEntityParameters added in v0.3.2 

type OrchestratorEntityParameters struct {
	EntityMessageReorderWindow *durationpb.Duration `protobuf:"bytes,1,opt,name=entityMessageReorderWindow,proto3" json:"entityMessageReorderWindow,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestratorEntityParameters) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use OrchestratorEntityParameters.ProtoReflect.Descriptor instead.

func (*OrchestratorEntityParameters) GetEntityMessageReorderWindow added in v0.3.2 

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

func (*OrchestratorEntityParameters) ProtoMessage added in v0.3.2 

func (*OrchestratorEntityParameters) ProtoMessage()

func (*OrchestratorEntityParameters) ProtoReflect added in v0.3.2 

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

func (*OrchestratorEntityParameters) Reset added in v0.3.2 

func (x *OrchestratorEntityParameters) Reset()

func (*OrchestratorEntityParameters) String added in v0.3.2 

func (x *OrchestratorEntityParameters) String() string

type OrchestratorRequest 

type OrchestratorRequest struct {
	InstanceId                string                        `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId               *wrapperspb.StringValue       `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	PastEvents                []*HistoryEvent               `protobuf:"bytes,3,rep,name=pastEvents,proto3" json:"pastEvents,omitempty"`
	NewEvents                 []*HistoryEvent               `protobuf:"bytes,4,rep,name=newEvents,proto3" json:"newEvents,omitempty"`
	EntityParameters          *OrchestratorEntityParameters `protobuf:"bytes,5,opt,name=entityParameters,proto3" json:"entityParameters,omitempty"`
	RequiresHistoryStreaming  bool                          `protobuf:"varint,6,opt,name=requiresHistoryStreaming,proto3" json:"requiresHistoryStreaming,omitempty"`
	Properties                map[string]*structpb.Value    `` /* 147-byte string literal not displayed */
	OrchestrationTraceContext *OrchestrationTraceContext    `protobuf:"bytes,8,opt,name=orchestrationTraceContext,proto3" json:"orchestrationTraceContext,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestratorRequest) Descriptor deprecated 

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

Deprecated: Use OrchestratorRequest.ProtoReflect.Descriptor instead.

func (*OrchestratorRequest) GetEntityParameters added in v0.3.2 

func (x *OrchestratorRequest) GetEntityParameters() *OrchestratorEntityParameters

func (*OrchestratorRequest) GetExecutionId 

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

func (*OrchestratorRequest) GetInstanceId 

func (x *OrchestratorRequest) GetInstanceId() string

func (*OrchestratorRequest) GetNewEvents 

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

func (*OrchestratorRequest) GetOrchestrationTraceContext 

func (x *OrchestratorRequest) GetOrchestrationTraceContext() *OrchestrationTraceContext

func (*OrchestratorRequest) GetPastEvents 

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

func (*OrchestratorRequest) GetProperties 

func (x *OrchestratorRequest) GetProperties() map[string]*structpb.Value

func (*OrchestratorRequest) GetRequiresHistoryStreaming 

func (x *OrchestratorRequest) GetRequiresHistoryStreaming() bool

func (*OrchestratorRequest) ProtoMessage 

func (*OrchestratorRequest) ProtoMessage()

func (*OrchestratorRequest) ProtoReflect 

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

func (*OrchestratorRequest) Reset 

func (x *OrchestratorRequest) Reset()

func (*OrchestratorRequest) String 

func (x *OrchestratorRequest) String() string

type OrchestratorResponse 

type OrchestratorResponse struct {
	InstanceId      string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Actions         []*OrchestratorAction   `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	CustomStatus    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	CompletionToken string                  `protobuf:"bytes,4,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// The number of work item events that were processed by the orchestrator.
	// This field is optional. If not set, the service should assume that the orchestrator processed all events.
	NumEventsProcessed        *wrapperspb.Int32Value     `protobuf:"bytes,5,opt,name=numEventsProcessed,proto3" json:"numEventsProcessed,omitempty"`
	OrchestrationTraceContext *OrchestrationTraceContext `protobuf:"bytes,6,opt,name=orchestrationTraceContext,proto3" json:"orchestrationTraceContext,omitempty"`
	// Whether or not a history is required to complete the original OrchestratorRequest and none was provided.
	RequiresHistory bool `protobuf:"varint,7,opt,name=requiresHistory,proto3" json:"requiresHistory,omitempty"`
	// True if this is a partial (chunked) completion. The backend must keep the work item open until the final chunk (isPartial=false).
	//
	// Deprecated: Marked as deprecated in orchestrator_service.proto.
	IsPartial bool `protobuf:"varint,8,opt,name=isPartial,proto3" json:"isPartial,omitempty"`
	// Zero-based position of the current chunk within a chunked completion sequence.
	// This field is omitted for non-chunked completions.
	//
	// Deprecated: Marked as deprecated in orchestrator_service.proto.
	ChunkIndex *wrapperspb.Int32Value `protobuf:"bytes,9,opt,name=chunkIndex,proto3" json:"chunkIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestratorResponse) Descriptor deprecated 

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

Deprecated: Use OrchestratorResponse.ProtoReflect.Descriptor instead.

func (*OrchestratorResponse) GetActions 

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

func (*OrchestratorResponse) GetChunkIndex deprecated 

func (x *OrchestratorResponse) GetChunkIndex() *wrapperspb.Int32Value

Deprecated: Marked as deprecated in orchestrator_service.proto.

func (*OrchestratorResponse) GetCompletionToken 

func (x *OrchestratorResponse) GetCompletionToken() string

func (*OrchestratorResponse) GetCustomStatus 

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

func (*OrchestratorResponse) GetInstanceId 

func (x *OrchestratorResponse) GetInstanceId() string

func (*OrchestratorResponse) GetIsPartial deprecated 

func (x *OrchestratorResponse) GetIsPartial() bool

Deprecated: Marked as deprecated in orchestrator_service.proto.

func (*OrchestratorResponse) GetNumEventsProcessed 

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

func (*OrchestratorResponse) GetOrchestrationTraceContext 

func (x *OrchestratorResponse) GetOrchestrationTraceContext() *OrchestrationTraceContext

func (*OrchestratorResponse) GetRequiresHistory 

func (x *OrchestratorResponse) GetRequiresHistory() bool

func (*OrchestratorResponse) ProtoMessage 

func (*OrchestratorResponse) ProtoMessage()

func (*OrchestratorResponse) ProtoReflect 

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

func (*OrchestratorResponse) Reset 

func (x *OrchestratorResponse) Reset()

func (*OrchestratorResponse) String 

func (x *OrchestratorResponse) String() string

type OrchestratorStartedEvent 

type OrchestratorStartedEvent struct {
	// contains filtered or unexported fields
}

func (*OrchestratorStartedEvent) Descriptor deprecated 

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

Deprecated: Use OrchestratorStartedEvent.ProtoReflect.Descriptor instead.

func (*OrchestratorStartedEvent) ProtoMessage 

func (*OrchestratorStartedEvent) ProtoMessage()

func (*OrchestratorStartedEvent) ProtoReflect 

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

func (*OrchestratorStartedEvent) Reset 

func (x *OrchestratorStartedEvent) Reset()

func (*OrchestratorStartedEvent) String 

func (x *OrchestratorStartedEvent) String() string

type ParentInstanceInfo 

type ParentInstanceInfo struct {
	TaskScheduledId       int32                   `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	Name                  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version               *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	OrchestrationInstance *OrchestrationInstance  `protobuf:"bytes,4,opt,name=orchestrationInstance,proto3" json:"orchestrationInstance,omitempty"`
	// contains filtered or unexported fields
}

func (*ParentInstanceInfo) Descriptor deprecated 

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

Deprecated: Use ParentInstanceInfo.ProtoReflect.Descriptor instead.

func (*ParentInstanceInfo) GetName 

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

func (*ParentInstanceInfo) GetOrchestrationInstance 

func (x *ParentInstanceInfo) GetOrchestrationInstance() *OrchestrationInstance

func (*ParentInstanceInfo) GetTaskScheduledId 

func (x *ParentInstanceInfo) GetTaskScheduledId() int32

func (*ParentInstanceInfo) GetVersion 

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

func (*ParentInstanceInfo) ProtoMessage 

func (*ParentInstanceInfo) ProtoMessage()

func (*ParentInstanceInfo) ProtoReflect 

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

func (*ParentInstanceInfo) Reset 

func (x *ParentInstanceInfo) Reset()

func (*ParentInstanceInfo) String 

func (x *ParentInstanceInfo) String() string

type PurgeInstanceFilter 

type PurgeInstanceFilter struct {
	CreatedTimeFrom *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=createdTimeFrom,proto3" json:"createdTimeFrom,omitempty"`
	CreatedTimeTo   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=createdTimeTo,proto3" json:"createdTimeTo,omitempty"`
	RuntimeStatus   []OrchestrationStatus  `protobuf:"varint,3,rep,packed,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	Timeout         *durationpb.Duration   `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeInstanceFilter) Descriptor deprecated 

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

Deprecated: Use PurgeInstanceFilter.ProtoReflect.Descriptor instead.

func (*PurgeInstanceFilter) GetCreatedTimeFrom 

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

func (*PurgeInstanceFilter) GetCreatedTimeTo 

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

func (*PurgeInstanceFilter) GetRuntimeStatus 

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

func (*PurgeInstanceFilter) GetTimeout 

func (x *PurgeInstanceFilter) GetTimeout() *durationpb.Duration

func (*PurgeInstanceFilter) ProtoMessage 

func (*PurgeInstanceFilter) ProtoMessage()

func (*PurgeInstanceFilter) ProtoReflect 

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

func (*PurgeInstanceFilter) Reset 

func (x *PurgeInstanceFilter) Reset()

func (*PurgeInstanceFilter) String 

func (x *PurgeInstanceFilter) String() string

type PurgeInstancesRequest 

type PurgeInstancesRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*PurgeInstancesRequest_InstanceId
	//	*PurgeInstancesRequest_PurgeInstanceFilter
	//	*PurgeInstancesRequest_InstanceBatch
	Request   isPurgeInstancesRequest_Request `protobuf_oneof:"request"`
	Recursive bool                            `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// used in the case when an instanceId is specified to determine if the purge request is for an orchestration (as opposed to an entity)
	IsOrchestration bool `protobuf:"varint,5,opt,name=isOrchestration,proto3" json:"isOrchestration,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeInstancesRequest) Descriptor deprecated 

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

Deprecated: Use PurgeInstancesRequest.ProtoReflect.Descriptor instead.

func (*PurgeInstancesRequest) GetInstanceBatch 

func (x *PurgeInstancesRequest) GetInstanceBatch() *InstanceBatch

func (*PurgeInstancesRequest) GetInstanceId 

func (x *PurgeInstancesRequest) GetInstanceId() string

func (*PurgeInstancesRequest) GetIsOrchestration 

func (x *PurgeInstancesRequest) GetIsOrchestration() bool

func (*PurgeInstancesRequest) GetPurgeInstanceFilter 

func (x *PurgeInstancesRequest) GetPurgeInstanceFilter() *PurgeInstanceFilter

func (*PurgeInstancesRequest) GetRecursive added in v0.5.0 

func (x *PurgeInstancesRequest) GetRecursive() bool

func (*PurgeInstancesRequest) GetRequest 

func (x *PurgeInstancesRequest) GetRequest() isPurgeInstancesRequest_Request

func (*PurgeInstancesRequest) ProtoMessage 

func (*PurgeInstancesRequest) ProtoMessage()

func (*PurgeInstancesRequest) ProtoReflect 

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

func (*PurgeInstancesRequest) Reset 

func (x *PurgeInstancesRequest) Reset()

func (*PurgeInstancesRequest) String 

func (x *PurgeInstancesRequest) String() string

type PurgeInstancesRequest_InstanceBatch 

type PurgeInstancesRequest_InstanceBatch struct {
	InstanceBatch *InstanceBatch `protobuf:"bytes,4,opt,name=instanceBatch,proto3,oneof"`
}

type PurgeInstancesRequest_InstanceId 

type PurgeInstancesRequest_InstanceId struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3,oneof"`
}

type PurgeInstancesRequest_PurgeInstanceFilter 

type PurgeInstancesRequest_PurgeInstanceFilter struct {
	PurgeInstanceFilter *PurgeInstanceFilter `protobuf:"bytes,2,opt,name=purgeInstanceFilter,proto3,oneof"`
}

type PurgeInstancesResponse 

type PurgeInstancesResponse struct {
	DeletedInstanceCount int32                 `protobuf:"varint,1,opt,name=deletedInstanceCount,proto3" json:"deletedInstanceCount,omitempty"`
	IsComplete           *wrapperspb.BoolValue `protobuf:"bytes,2,opt,name=isComplete,proto3" json:"isComplete,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeInstancesResponse) Descriptor deprecated 

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

Deprecated: Use PurgeInstancesResponse.ProtoReflect.Descriptor instead.

func (*PurgeInstancesResponse) GetDeletedInstanceCount 

func (x *PurgeInstancesResponse) GetDeletedInstanceCount() int32

func (*PurgeInstancesResponse) GetIsComplete 

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

func (*PurgeInstancesResponse) ProtoMessage 

func (*PurgeInstancesResponse) ProtoMessage()

func (*PurgeInstancesResponse) ProtoReflect 

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

func (*PurgeInstancesResponse) Reset 

func (x *PurgeInstancesResponse) Reset()

func (*PurgeInstancesResponse) String 

func (x *PurgeInstancesResponse) String() string

type QueryEntitiesRequest added in v0.3.2 

type QueryEntitiesRequest struct {
	Query *EntityQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryEntitiesRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use QueryEntitiesRequest.ProtoReflect.Descriptor instead.

func (*QueryEntitiesRequest) GetQuery added in v0.3.2 

func (x *QueryEntitiesRequest) GetQuery() *EntityQuery

func (*QueryEntitiesRequest) ProtoMessage added in v0.3.2 

func (*QueryEntitiesRequest) ProtoMessage()

func (*QueryEntitiesRequest) ProtoReflect added in v0.3.2 

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

func (*QueryEntitiesRequest) Reset added in v0.3.2 

func (x *QueryEntitiesRequest) Reset()

func (*QueryEntitiesRequest) String added in v0.3.2 

func (x *QueryEntitiesRequest) String() string

type QueryEntitiesResponse added in v0.3.2 

type QueryEntitiesResponse struct {
	Entities          []*EntityMetadata       `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	ContinuationToken *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryEntitiesResponse) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use QueryEntitiesResponse.ProtoReflect.Descriptor instead.

func (*QueryEntitiesResponse) GetContinuationToken added in v0.3.2 

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

func (*QueryEntitiesResponse) GetEntities added in v0.3.2 

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

func (*QueryEntitiesResponse) ProtoMessage added in v0.3.2 

func (*QueryEntitiesResponse) ProtoMessage()

func (*QueryEntitiesResponse) ProtoReflect added in v0.3.2 

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

func (*QueryEntitiesResponse) Reset added in v0.3.2 

func (x *QueryEntitiesResponse) Reset()

func (*QueryEntitiesResponse) String added in v0.3.2 

func (x *QueryEntitiesResponse) String() string

type QueryInstancesRequest 

type QueryInstancesRequest struct {
	Query *InstanceQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryInstancesRequest) Descriptor deprecated 

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

Deprecated: Use QueryInstancesRequest.ProtoReflect.Descriptor instead.

func (*QueryInstancesRequest) GetQuery 

func (x *QueryInstancesRequest) GetQuery() *InstanceQuery

func (*QueryInstancesRequest) ProtoMessage 

func (*QueryInstancesRequest) ProtoMessage()

func (*QueryInstancesRequest) ProtoReflect 

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

func (*QueryInstancesRequest) Reset 

func (x *QueryInstancesRequest) Reset()

func (*QueryInstancesRequest) String 

func (x *QueryInstancesRequest) String() string

type QueryInstancesResponse 

type QueryInstancesResponse struct {
	OrchestrationState []*OrchestrationState   `protobuf:"bytes,1,rep,name=orchestrationState,proto3" json:"orchestrationState,omitempty"`
	ContinuationToken  *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryInstancesResponse) Descriptor deprecated 

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

Deprecated: Use QueryInstancesResponse.ProtoReflect.Descriptor instead.

func (*QueryInstancesResponse) GetContinuationToken 

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

func (*QueryInstancesResponse) GetOrchestrationState 

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

func (*QueryInstancesResponse) ProtoMessage 

func (*QueryInstancesResponse) ProtoMessage()

func (*QueryInstancesResponse) ProtoReflect 

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

func (*QueryInstancesResponse) Reset 

func (x *QueryInstancesResponse) Reset()

func (*QueryInstancesResponse) String 

func (x *QueryInstancesResponse) String() string

type RaiseEventRequest 

type RaiseEventRequest struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name       string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Input      *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*RaiseEventRequest) Descriptor deprecated 

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

Deprecated: Use RaiseEventRequest.ProtoReflect.Descriptor instead.

func (*RaiseEventRequest) GetInput 

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

func (*RaiseEventRequest) GetInstanceId 

func (x *RaiseEventRequest) GetInstanceId() string

func (*RaiseEventRequest) GetName 

func (x *RaiseEventRequest) GetName() string

func (*RaiseEventRequest) ProtoMessage 

func (*RaiseEventRequest) ProtoMessage()

func (*RaiseEventRequest) ProtoReflect 

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

func (*RaiseEventRequest) Reset 

func (x *RaiseEventRequest) Reset()

func (*RaiseEventRequest) String 

func (x *RaiseEventRequest) String() string

type RaiseEventResponse 

type RaiseEventResponse struct {
	// contains filtered or unexported fields
}

func (*RaiseEventResponse) Descriptor deprecated 

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

Deprecated: Use RaiseEventResponse.ProtoReflect.Descriptor instead.

func (*RaiseEventResponse) ProtoMessage 

func (*RaiseEventResponse) ProtoMessage()

func (*RaiseEventResponse) ProtoReflect 

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

func (*RaiseEventResponse) Reset 

func (x *RaiseEventResponse) Reset()

func (*RaiseEventResponse) String 

func (x *RaiseEventResponse) String() string

type RestartInstanceRequest 

type RestartInstanceRequest struct {
	InstanceId               string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	RestartWithNewInstanceId bool   `protobuf:"varint,2,opt,name=restartWithNewInstanceId,proto3" json:"restartWithNewInstanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartInstanceRequest) Descriptor deprecated 

func (*RestartInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use RestartInstanceRequest.ProtoReflect.Descriptor instead.

func (*RestartInstanceRequest) GetInstanceId 

func (x *RestartInstanceRequest) GetInstanceId() string

func (*RestartInstanceRequest) GetRestartWithNewInstanceId 

func (x *RestartInstanceRequest) GetRestartWithNewInstanceId() bool

func (*RestartInstanceRequest) ProtoMessage 

func (*RestartInstanceRequest) ProtoMessage()

func (*RestartInstanceRequest) ProtoReflect 

func (x *RestartInstanceRequest) ProtoReflect() protoreflect.Message

func (*RestartInstanceRequest) Reset 

func (x *RestartInstanceRequest) Reset()

func (*RestartInstanceRequest) String 

func (x *RestartInstanceRequest) String() string

type RestartInstanceResponse 

type RestartInstanceResponse struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartInstanceResponse) Descriptor deprecated 

func (*RestartInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use RestartInstanceResponse.ProtoReflect.Descriptor instead.

func (*RestartInstanceResponse) GetInstanceId 

func (x *RestartInstanceResponse) GetInstanceId() string

func (*RestartInstanceResponse) ProtoMessage 

func (*RestartInstanceResponse) ProtoMessage()

func (*RestartInstanceResponse) ProtoReflect 

func (x *RestartInstanceResponse) ProtoReflect() protoreflect.Message

func (*RestartInstanceResponse) Reset 

func (x *RestartInstanceResponse) Reset()

func (*RestartInstanceResponse) String 

func (x *RestartInstanceResponse) String() string

type ResumeRequest added in v0.1.1 

type ResumeRequest struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Reason     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeRequest) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetInstanceId added in v0.1.1 

func (x *ResumeRequest) GetInstanceId() string

func (*ResumeRequest) GetReason added in v0.1.1 

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

func (*ResumeRequest) ProtoMessage added in v0.1.1 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect added in v0.1.1 

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

func (*ResumeRequest) Reset added in v0.1.1 

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String added in v0.1.1 

func (x *ResumeRequest) String() string

type ResumeResponse added in v0.1.1 

type ResumeResponse struct {
	// contains filtered or unexported fields
}

func (*ResumeResponse) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use ResumeResponse.ProtoReflect.Descriptor instead.

func (*ResumeResponse) ProtoMessage added in v0.1.1 

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) ProtoReflect added in v0.1.1 

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

func (*ResumeResponse) Reset added in v0.1.1 

func (x *ResumeResponse) Reset()

func (*ResumeResponse) String added in v0.1.1 

func (x *ResumeResponse) String() string

type RewindInstanceRequest added in v0.1.1 

type RewindInstanceRequest struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Reason     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*RewindInstanceRequest) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use RewindInstanceRequest.ProtoReflect.Descriptor instead.

func (*RewindInstanceRequest) GetInstanceId added in v0.1.1 

func (x *RewindInstanceRequest) GetInstanceId() string

func (*RewindInstanceRequest) GetReason added in v0.1.1 

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

func (*RewindInstanceRequest) ProtoMessage added in v0.1.1 

func (*RewindInstanceRequest) ProtoMessage()

func (*RewindInstanceRequest) ProtoReflect added in v0.1.1 

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

func (*RewindInstanceRequest) Reset added in v0.1.1 

func (x *RewindInstanceRequest) Reset()

func (*RewindInstanceRequest) String added in v0.1.1 

func (x *RewindInstanceRequest) String() string

type RewindInstanceResponse added in v0.1.1 

type RewindInstanceResponse struct {
	// contains filtered or unexported fields
}

func (*RewindInstanceResponse) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use RewindInstanceResponse.ProtoReflect.Descriptor instead.

func (*RewindInstanceResponse) ProtoMessage added in v0.1.1 

func (*RewindInstanceResponse) ProtoMessage()

func (*RewindInstanceResponse) ProtoReflect added in v0.1.1 

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

func (*RewindInstanceResponse) Reset added in v0.1.1 

func (x *RewindInstanceResponse) Reset()

func (*RewindInstanceResponse) String added in v0.1.1 

func (x *RewindInstanceResponse) String() string

type RewindOrchestrationAction 

type RewindOrchestrationAction struct {
	NewHistory []*HistoryEvent `protobuf:"bytes,1,rep,name=newHistory,proto3" json:"newHistory,omitempty"`
	// contains filtered or unexported fields
}

func (*RewindOrchestrationAction) Descriptor deprecated 

func (*RewindOrchestrationAction) Descriptor() ([]byte, []int)

Deprecated: Use RewindOrchestrationAction.ProtoReflect.Descriptor instead.

func (*RewindOrchestrationAction) GetNewHistory 

func (x *RewindOrchestrationAction) GetNewHistory() []*HistoryEvent

func (*RewindOrchestrationAction) ProtoMessage 

func (*RewindOrchestrationAction) ProtoMessage()

func (*RewindOrchestrationAction) ProtoReflect 

func (x *RewindOrchestrationAction) ProtoReflect() protoreflect.Message

func (*RewindOrchestrationAction) Reset 

func (x *RewindOrchestrationAction) Reset()

func (*RewindOrchestrationAction) String 

func (x *RewindOrchestrationAction) String() string

type ScheduleTaskAction 

type ScheduleTaskAction struct {
	Name               string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version            *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	Tags               map[string]string       `` /* 135-byte string literal not displayed */
	ParentTraceContext *TraceContext           `protobuf:"bytes,5,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleTaskAction) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskAction.ProtoReflect.Descriptor instead.

func (*ScheduleTaskAction) GetInput 

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

func (*ScheduleTaskAction) GetName 

func (x *ScheduleTaskAction) GetName() string

func (*ScheduleTaskAction) GetParentTraceContext 

func (x *ScheduleTaskAction) GetParentTraceContext() *TraceContext

func (*ScheduleTaskAction) GetTags 

func (x *ScheduleTaskAction) GetTags() map[string]string

func (*ScheduleTaskAction) GetVersion 

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

func (*ScheduleTaskAction) ProtoMessage 

func (*ScheduleTaskAction) ProtoMessage()

func (*ScheduleTaskAction) ProtoReflect 

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

func (*ScheduleTaskAction) Reset 

func (x *ScheduleTaskAction) Reset()

func (*ScheduleTaskAction) String 

func (x *ScheduleTaskAction) String() string

type SendEntityMessageAction 

type SendEntityMessageAction struct {

	// Types that are valid to be assigned to EntityMessageType:
	//
	//	*SendEntityMessageAction_EntityOperationSignaled
	//	*SendEntityMessageAction_EntityOperationCalled
	//	*SendEntityMessageAction_EntityLockRequested
	//	*SendEntityMessageAction_EntityUnlockSent
	EntityMessageType isSendEntityMessageAction_EntityMessageType `protobuf_oneof:"EntityMessageType"`
	// contains filtered or unexported fields
}

func (*SendEntityMessageAction) Descriptor deprecated 

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

Deprecated: Use SendEntityMessageAction.ProtoReflect.Descriptor instead.

func (*SendEntityMessageAction) GetEntityLockRequested 

func (x *SendEntityMessageAction) GetEntityLockRequested() *EntityLockRequestedEvent

func (*SendEntityMessageAction) GetEntityMessageType 

func (x *SendEntityMessageAction) GetEntityMessageType() isSendEntityMessageAction_EntityMessageType

func (*SendEntityMessageAction) GetEntityOperationCalled 

func (x *SendEntityMessageAction) GetEntityOperationCalled() *EntityOperationCalledEvent

func (*SendEntityMessageAction) GetEntityOperationSignaled 

func (x *SendEntityMessageAction) GetEntityOperationSignaled() *EntityOperationSignaledEvent

func (*SendEntityMessageAction) GetEntityUnlockSent 

func (x *SendEntityMessageAction) GetEntityUnlockSent() *EntityUnlockSentEvent

func (*SendEntityMessageAction) ProtoMessage 

func (*SendEntityMessageAction) ProtoMessage()

func (*SendEntityMessageAction) ProtoReflect 

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

func (*SendEntityMessageAction) Reset 

func (x *SendEntityMessageAction) Reset()

func (*SendEntityMessageAction) String 

func (x *SendEntityMessageAction) String() string

type SendEntityMessageAction_EntityLockRequested 

type SendEntityMessageAction_EntityLockRequested struct {
	EntityLockRequested *EntityLockRequestedEvent `protobuf:"bytes,3,opt,name=entityLockRequested,proto3,oneof"`
}

type SendEntityMessageAction_EntityOperationCalled 

type SendEntityMessageAction_EntityOperationCalled struct {
	EntityOperationCalled *EntityOperationCalledEvent `protobuf:"bytes,2,opt,name=entityOperationCalled,proto3,oneof"`
}

type SendEntityMessageAction_EntityOperationSignaled 

type SendEntityMessageAction_EntityOperationSignaled struct {
	EntityOperationSignaled *EntityOperationSignaledEvent `protobuf:"bytes,1,opt,name=entityOperationSignaled,proto3,oneof"`
}

type SendEntityMessageAction_EntityUnlockSent 

type SendEntityMessageAction_EntityUnlockSent struct {
	EntityUnlockSent *EntityUnlockSentEvent `protobuf:"bytes,4,opt,name=entityUnlockSent,proto3,oneof"`
}

type SendEventAction 

type SendEventAction struct {
	Instance *OrchestrationInstance  `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	Name     string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Data     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SendEventAction) Descriptor deprecated 

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

Deprecated: Use SendEventAction.ProtoReflect.Descriptor instead.

func (*SendEventAction) GetData 

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

func (*SendEventAction) GetInstance 

func (x *SendEventAction) GetInstance() *OrchestrationInstance

func (*SendEventAction) GetName 

func (x *SendEventAction) GetName() string

func (*SendEventAction) ProtoMessage 

func (*SendEventAction) ProtoMessage()

func (*SendEventAction) ProtoReflect 

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

func (*SendEventAction) Reset 

func (x *SendEventAction) Reset()

func (*SendEventAction) String 

func (x *SendEventAction) String() string

type SendSignalAction added in v0.3.2 

type SendSignalAction struct {
	InstanceId         string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name               string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledTime      *timestamppb.Timestamp  `protobuf:"bytes,4,opt,name=scheduledTime,proto3" json:"scheduledTime,omitempty"`
	RequestTime        *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=requestTime,proto3" json:"requestTime,omitempty"`
	ParentTraceContext *TraceContext           `protobuf:"bytes,6,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	// contains filtered or unexported fields
}

func (*SendSignalAction) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use SendSignalAction.ProtoReflect.Descriptor instead.

func (*SendSignalAction) GetInput added in v0.3.2 

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

func (*SendSignalAction) GetInstanceId added in v0.3.2 

func (x *SendSignalAction) GetInstanceId() string

func (*SendSignalAction) GetName added in v0.3.2 

func (x *SendSignalAction) GetName() string

func (*SendSignalAction) GetParentTraceContext 

func (x *SendSignalAction) GetParentTraceContext() *TraceContext

func (*SendSignalAction) GetRequestTime 

func (x *SendSignalAction) GetRequestTime() *timestamppb.Timestamp

func (*SendSignalAction) GetScheduledTime added in v0.3.2 

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

func (*SendSignalAction) ProtoMessage added in v0.3.2 

func (*SendSignalAction) ProtoMessage()

func (*SendSignalAction) ProtoReflect added in v0.3.2 

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

func (*SendSignalAction) Reset added in v0.3.2 

func (x *SendSignalAction) Reset()

func (*SendSignalAction) String added in v0.3.2 

func (x *SendSignalAction) String() string

type SignalEntityRequest added in v0.3.2 

type SignalEntityRequest struct {
	InstanceId         string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name               string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	RequestId          string                  `protobuf:"bytes,4,opt,name=requestId,proto3" json:"requestId,omitempty"`
	ScheduledTime      *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=scheduledTime,proto3" json:"scheduledTime,omitempty"`
	ParentTraceContext *TraceContext           `protobuf:"bytes,6,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	RequestTime        *timestamppb.Timestamp  `protobuf:"bytes,7,opt,name=requestTime,proto3" json:"requestTime,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalEntityRequest) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use SignalEntityRequest.ProtoReflect.Descriptor instead.

func (*SignalEntityRequest) GetInput added in v0.3.2 

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

func (*SignalEntityRequest) GetInstanceId added in v0.3.2 

func (x *SignalEntityRequest) GetInstanceId() string

func (*SignalEntityRequest) GetName added in v0.3.2 

func (x *SignalEntityRequest) GetName() string

func (*SignalEntityRequest) GetParentTraceContext 

func (x *SignalEntityRequest) GetParentTraceContext() *TraceContext

func (*SignalEntityRequest) GetRequestId added in v0.3.2 

func (x *SignalEntityRequest) GetRequestId() string

func (*SignalEntityRequest) GetRequestTime 

func (x *SignalEntityRequest) GetRequestTime() *timestamppb.Timestamp

func (*SignalEntityRequest) GetScheduledTime added in v0.3.2 

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

func (*SignalEntityRequest) ProtoMessage added in v0.3.2 

func (*SignalEntityRequest) ProtoMessage()

func (*SignalEntityRequest) ProtoReflect added in v0.3.2 

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

func (*SignalEntityRequest) Reset added in v0.3.2 

func (x *SignalEntityRequest) Reset()

func (*SignalEntityRequest) String added in v0.3.2 

func (x *SignalEntityRequest) String() string

type SignalEntityResponse added in v0.3.2 

type SignalEntityResponse struct {
	// contains filtered or unexported fields
}

func (*SignalEntityResponse) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use SignalEntityResponse.ProtoReflect.Descriptor instead.

func (*SignalEntityResponse) ProtoMessage added in v0.3.2 

func (*SignalEntityResponse) ProtoMessage()

func (*SignalEntityResponse) ProtoReflect added in v0.3.2 

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

func (*SignalEntityResponse) Reset added in v0.3.2 

func (x *SignalEntityResponse) Reset()

func (*SignalEntityResponse) String added in v0.3.2 

func (x *SignalEntityResponse) String() string

type SkipGracefulOrchestrationTerminationsRequest 

type SkipGracefulOrchestrationTerminationsRequest struct {
	InstanceBatch *InstanceBatch          `protobuf:"bytes,1,opt,name=instanceBatch,proto3" json:"instanceBatch,omitempty"`
	Reason        *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*SkipGracefulOrchestrationTerminationsRequest) Descriptor deprecated 

func (*SkipGracefulOrchestrationTerminationsRequest) Descriptor() ([]byte, []int)

Deprecated: Use SkipGracefulOrchestrationTerminationsRequest.ProtoReflect.Descriptor instead.

func (*SkipGracefulOrchestrationTerminationsRequest) GetInstanceBatch 

func (x *SkipGracefulOrchestrationTerminationsRequest) GetInstanceBatch() *InstanceBatch

func (*SkipGracefulOrchestrationTerminationsRequest) GetReason 

func (x *SkipGracefulOrchestrationTerminationsRequest) GetReason() *wrapperspb.StringValue

func (*SkipGracefulOrchestrationTerminationsRequest) ProtoMessage 

func (*SkipGracefulOrchestrationTerminationsRequest) ProtoMessage()

func (*SkipGracefulOrchestrationTerminationsRequest) ProtoReflect 

func (x *SkipGracefulOrchestrationTerminationsRequest) ProtoReflect() protoreflect.Message

func (*SkipGracefulOrchestrationTerminationsRequest) Reset 

func (x *SkipGracefulOrchestrationTerminationsRequest) Reset()

func (*SkipGracefulOrchestrationTerminationsRequest) String 

func (x *SkipGracefulOrchestrationTerminationsRequest) String() string

type SkipGracefulOrchestrationTerminationsResponse 

type SkipGracefulOrchestrationTerminationsResponse struct {

	// Those instances which could not be terminated because they had locked entities at the time of this termination call,
	// are already in a terminal state (completed, failed, terminated, etc.), are not orchestrations, or do not exist (i.e. have been purged)
	UnterminatedInstanceIds []string `protobuf:"bytes,1,rep,name=unterminatedInstanceIds,proto3" json:"unterminatedInstanceIds,omitempty"`
	// contains filtered or unexported fields
}

func (*SkipGracefulOrchestrationTerminationsResponse) Descriptor deprecated 

func (*SkipGracefulOrchestrationTerminationsResponse) Descriptor() ([]byte, []int)

Deprecated: Use SkipGracefulOrchestrationTerminationsResponse.ProtoReflect.Descriptor instead.

func (*SkipGracefulOrchestrationTerminationsResponse) GetUnterminatedInstanceIds 

func (x *SkipGracefulOrchestrationTerminationsResponse) GetUnterminatedInstanceIds() []string

func (*SkipGracefulOrchestrationTerminationsResponse) ProtoMessage 

func (*SkipGracefulOrchestrationTerminationsResponse) ProtoMessage()

func (*SkipGracefulOrchestrationTerminationsResponse) ProtoReflect 

func (x *SkipGracefulOrchestrationTerminationsResponse) ProtoReflect() protoreflect.Message

func (*SkipGracefulOrchestrationTerminationsResponse) Reset 

func (x *SkipGracefulOrchestrationTerminationsResponse) Reset()

func (*SkipGracefulOrchestrationTerminationsResponse) String 

func (x *SkipGracefulOrchestrationTerminationsResponse) String() string

type StartNewOrchestrationAction added in v0.3.2 

type StartNewOrchestrationAction struct {
	InstanceId         string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name               string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version            *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledTime      *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=scheduledTime,proto3" json:"scheduledTime,omitempty"`
	RequestTime        *timestamppb.Timestamp  `protobuf:"bytes,6,opt,name=requestTime,proto3" json:"requestTime,omitempty"`
	ParentTraceContext *TraceContext           `protobuf:"bytes,7,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	// contains filtered or unexported fields
}

func (*StartNewOrchestrationAction) Descriptor deprecated added in v0.3.2 

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

Deprecated: Use StartNewOrchestrationAction.ProtoReflect.Descriptor instead.

func (*StartNewOrchestrationAction) GetInput added in v0.3.2 

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

func (*StartNewOrchestrationAction) GetInstanceId added in v0.3.2 

func (x *StartNewOrchestrationAction) GetInstanceId() string

func (*StartNewOrchestrationAction) GetName added in v0.3.2 

func (x *StartNewOrchestrationAction) GetName() string

func (*StartNewOrchestrationAction) GetParentTraceContext 

func (x *StartNewOrchestrationAction) GetParentTraceContext() *TraceContext

func (*StartNewOrchestrationAction) GetRequestTime 

func (x *StartNewOrchestrationAction) GetRequestTime() *timestamppb.Timestamp

func (*StartNewOrchestrationAction) GetScheduledTime added in v0.3.2 

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

func (*StartNewOrchestrationAction) GetVersion added in v0.3.2 

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

func (*StartNewOrchestrationAction) ProtoMessage added in v0.3.2 

func (*StartNewOrchestrationAction) ProtoMessage()

func (*StartNewOrchestrationAction) ProtoReflect added in v0.3.2 

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

func (*StartNewOrchestrationAction) Reset added in v0.3.2 

func (x *StartNewOrchestrationAction) Reset()

func (*StartNewOrchestrationAction) String added in v0.3.2 

func (x *StartNewOrchestrationAction) String() string

type StreamInstanceHistoryRequest 

type StreamInstanceHistoryRequest struct {
	InstanceId  string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	// When set to true, the service may return a more optimized response suitable for workers.
	ForWorkItemProcessing bool `protobuf:"varint,3,opt,name=forWorkItemProcessing,proto3" json:"forWorkItemProcessing,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamInstanceHistoryRequest) Descriptor deprecated 

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

Deprecated: Use StreamInstanceHistoryRequest.ProtoReflect.Descriptor instead.

func (*StreamInstanceHistoryRequest) GetExecutionId 

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

func (*StreamInstanceHistoryRequest) GetForWorkItemProcessing 

func (x *StreamInstanceHistoryRequest) GetForWorkItemProcessing() bool

func (*StreamInstanceHistoryRequest) GetInstanceId 

func (x *StreamInstanceHistoryRequest) GetInstanceId() string

func (*StreamInstanceHistoryRequest) ProtoMessage 

func (*StreamInstanceHistoryRequest) ProtoMessage()

func (*StreamInstanceHistoryRequest) ProtoReflect 

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

func (*StreamInstanceHistoryRequest) Reset 

func (x *StreamInstanceHistoryRequest) Reset()

func (*StreamInstanceHistoryRequest) String 

func (x *StreamInstanceHistoryRequest) String() string

type SubOrchestrationInstanceCompletedEvent 

type SubOrchestrationInstanceCompletedEvent struct {
	TaskScheduledId int32                   `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	Result          *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*SubOrchestrationInstanceCompletedEvent) Descriptor deprecated 

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

Deprecated: Use SubOrchestrationInstanceCompletedEvent.ProtoReflect.Descriptor instead.

func (*SubOrchestrationInstanceCompletedEvent) GetResult 

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

func (*SubOrchestrationInstanceCompletedEvent) GetTaskScheduledId 

func (x *SubOrchestrationInstanceCompletedEvent) GetTaskScheduledId() int32

func (*SubOrchestrationInstanceCompletedEvent) ProtoMessage 

func (*SubOrchestrationInstanceCompletedEvent) ProtoMessage()

func (*SubOrchestrationInstanceCompletedEvent) ProtoReflect 

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

func (*SubOrchestrationInstanceCompletedEvent) Reset 

func (x *SubOrchestrationInstanceCompletedEvent) Reset()

func (*SubOrchestrationInstanceCompletedEvent) String 

func (x *SubOrchestrationInstanceCompletedEvent) String() string

type SubOrchestrationInstanceCreatedEvent 

type SubOrchestrationInstanceCreatedEvent struct {
	InstanceId         string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name               string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version            *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ParentTraceContext *TraceContext           `protobuf:"bytes,5,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	Tags               map[string]string       `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SubOrchestrationInstanceCreatedEvent) Descriptor deprecated 

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

Deprecated: Use SubOrchestrationInstanceCreatedEvent.ProtoReflect.Descriptor instead.

func (*SubOrchestrationInstanceCreatedEvent) GetInput 

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

func (*SubOrchestrationInstanceCreatedEvent) GetInstanceId 

func (x *SubOrchestrationInstanceCreatedEvent) GetInstanceId() string

func (*SubOrchestrationInstanceCreatedEvent) GetName 

func (x *SubOrchestrationInstanceCreatedEvent) GetName() string

func (*SubOrchestrationInstanceCreatedEvent) GetParentTraceContext added in v0.1.1 

func (x *SubOrchestrationInstanceCreatedEvent) GetParentTraceContext() *TraceContext

func (*SubOrchestrationInstanceCreatedEvent) GetTags 

func (x *SubOrchestrationInstanceCreatedEvent) GetTags() map[string]string

func (*SubOrchestrationInstanceCreatedEvent) GetVersion 

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

func (*SubOrchestrationInstanceCreatedEvent) ProtoMessage 

func (*SubOrchestrationInstanceCreatedEvent) ProtoMessage()

func (*SubOrchestrationInstanceCreatedEvent) ProtoReflect 

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

func (*SubOrchestrationInstanceCreatedEvent) Reset 

func (x *SubOrchestrationInstanceCreatedEvent) Reset()

func (*SubOrchestrationInstanceCreatedEvent) String 

func (x *SubOrchestrationInstanceCreatedEvent) String() string

type SubOrchestrationInstanceFailedEvent 

type SubOrchestrationInstanceFailedEvent struct {
	TaskScheduledId int32               `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	FailureDetails  *TaskFailureDetails `protobuf:"bytes,2,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*SubOrchestrationInstanceFailedEvent) Descriptor deprecated 

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

Deprecated: Use SubOrchestrationInstanceFailedEvent.ProtoReflect.Descriptor instead.

func (*SubOrchestrationInstanceFailedEvent) GetFailureDetails 

func (x *SubOrchestrationInstanceFailedEvent) GetFailureDetails() *TaskFailureDetails

func (*SubOrchestrationInstanceFailedEvent) GetTaskScheduledId 

func (x *SubOrchestrationInstanceFailedEvent) GetTaskScheduledId() int32

func (*SubOrchestrationInstanceFailedEvent) ProtoMessage 

func (*SubOrchestrationInstanceFailedEvent) ProtoMessage()

func (*SubOrchestrationInstanceFailedEvent) ProtoReflect 

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

func (*SubOrchestrationInstanceFailedEvent) Reset 

func (x *SubOrchestrationInstanceFailedEvent) Reset()

func (*SubOrchestrationInstanceFailedEvent) String 

func (x *SubOrchestrationInstanceFailedEvent) String() string

type SuspendRequest added in v0.1.1 

type SuspendRequest struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Reason     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*SuspendRequest) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use SuspendRequest.ProtoReflect.Descriptor instead.

func (*SuspendRequest) GetInstanceId added in v0.1.1 

func (x *SuspendRequest) GetInstanceId() string

func (*SuspendRequest) GetReason added in v0.1.1 

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

func (*SuspendRequest) ProtoMessage added in v0.1.1 

func (*SuspendRequest) ProtoMessage()

func (*SuspendRequest) ProtoReflect added in v0.1.1 

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

func (*SuspendRequest) Reset added in v0.1.1 

func (x *SuspendRequest) Reset()

func (*SuspendRequest) String added in v0.1.1 

func (x *SuspendRequest) String() string

type SuspendResponse added in v0.1.1 

type SuspendResponse struct {
	// contains filtered or unexported fields
}

func (*SuspendResponse) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use SuspendResponse.ProtoReflect.Descriptor instead.

func (*SuspendResponse) ProtoMessage added in v0.1.1 

func (*SuspendResponse) ProtoMessage()

func (*SuspendResponse) ProtoReflect added in v0.1.1 

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

func (*SuspendResponse) Reset added in v0.1.1 

func (x *SuspendResponse) Reset()

func (*SuspendResponse) String added in v0.1.1 

func (x *SuspendResponse) String() string

type TaskCompletedEvent 

type TaskCompletedEvent struct {
	TaskScheduledId int32                   `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	Result          *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskCompletedEvent) Descriptor deprecated 

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

Deprecated: Use TaskCompletedEvent.ProtoReflect.Descriptor instead.

func (*TaskCompletedEvent) GetResult 

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

func (*TaskCompletedEvent) GetTaskScheduledId 

func (x *TaskCompletedEvent) GetTaskScheduledId() int32

func (*TaskCompletedEvent) ProtoMessage 

func (*TaskCompletedEvent) ProtoMessage()

func (*TaskCompletedEvent) ProtoReflect 

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

func (*TaskCompletedEvent) Reset 

func (x *TaskCompletedEvent) Reset()

func (*TaskCompletedEvent) String 

func (x *TaskCompletedEvent) String() string

type TaskFailedEvent 

type TaskFailedEvent struct {
	TaskScheduledId int32               `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	FailureDetails  *TaskFailureDetails `protobuf:"bytes,2,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskFailedEvent) Descriptor deprecated 

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

Deprecated: Use TaskFailedEvent.ProtoReflect.Descriptor instead.

func (*TaskFailedEvent) GetFailureDetails 

func (x *TaskFailedEvent) GetFailureDetails() *TaskFailureDetails

func (*TaskFailedEvent) GetTaskScheduledId 

func (x *TaskFailedEvent) GetTaskScheduledId() int32

func (*TaskFailedEvent) ProtoMessage 

func (*TaskFailedEvent) ProtoMessage()

func (*TaskFailedEvent) ProtoReflect 

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

func (*TaskFailedEvent) Reset 

func (x *TaskFailedEvent) Reset()

func (*TaskFailedEvent) String 

func (x *TaskFailedEvent) String() string

type TaskFailureDetails 

type TaskFailureDetails struct {
	ErrorType      string                     `protobuf:"bytes,1,opt,name=errorType,proto3" json:"errorType,omitempty"`
	ErrorMessage   string                     `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	StackTrace     *wrapperspb.StringValue    `protobuf:"bytes,3,opt,name=stackTrace,proto3" json:"stackTrace,omitempty"`
	InnerFailure   *TaskFailureDetails        `protobuf:"bytes,4,opt,name=innerFailure,proto3" json:"innerFailure,omitempty"`
	IsNonRetriable bool                       `protobuf:"varint,5,opt,name=isNonRetriable,proto3" json:"isNonRetriable,omitempty"`
	Properties     map[string]*structpb.Value `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskFailureDetails) Descriptor deprecated 

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

Deprecated: Use TaskFailureDetails.ProtoReflect.Descriptor instead.

func (*TaskFailureDetails) GetErrorMessage 

func (x *TaskFailureDetails) GetErrorMessage() string

func (*TaskFailureDetails) GetErrorType 

func (x *TaskFailureDetails) GetErrorType() string

func (*TaskFailureDetails) GetInnerFailure 

func (x *TaskFailureDetails) GetInnerFailure() *TaskFailureDetails

func (*TaskFailureDetails) GetIsNonRetriable 

func (x *TaskFailureDetails) GetIsNonRetriable() bool

func (*TaskFailureDetails) GetProperties 

func (x *TaskFailureDetails) GetProperties() map[string]*structpb.Value

func (*TaskFailureDetails) GetStackTrace 

func (x *TaskFailureDetails) GetStackTrace() *wrapperspb.StringValue

func (*TaskFailureDetails) ProtoMessage 

func (*TaskFailureDetails) ProtoMessage()

func (*TaskFailureDetails) ProtoReflect 

func (x *TaskFailureDetails) ProtoReflect() protoreflect.Message

func (*TaskFailureDetails) Reset 

func (x *TaskFailureDetails) Reset()

func (*TaskFailureDetails) String 

func (x *TaskFailureDetails) String() string

type TaskHubSidecarServiceClient 

type TaskHubSidecarServiceClient interface {
	// Sends a hello request to the sidecar service.
	Hello(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Starts a new orchestration instance.
	StartInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// Gets the status of an existing orchestration instance.
	GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Rewinds an orchestration instance to last known good state and replays from there.
	RewindInstance(ctx context.Context, in *RewindInstanceRequest, opts ...grpc.CallOption) (*RewindInstanceResponse, error)
	// Restarts an orchestration instance.
	RestartInstance(ctx context.Context, in *RestartInstanceRequest, opts ...grpc.CallOption) (*RestartInstanceResponse, error)
	// Waits for an orchestration instance to reach a running or completion state.
	WaitForInstanceStart(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
	WaitForInstanceCompletion(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Raises an event to a running orchestration instance.
	RaiseEvent(ctx context.Context, in *RaiseEventRequest, opts ...grpc.CallOption) (*RaiseEventResponse, error)
	// Terminates a running orchestration instance.
	TerminateInstance(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
	// Suspends a running orchestration instance.
	SuspendInstance(ctx context.Context, in *SuspendRequest, opts ...grpc.CallOption) (*SuspendResponse, error)
	// Resumes a suspended orchestration instance.
	ResumeInstance(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*ResumeResponse, error)
	QueryInstances(ctx context.Context, in *QueryInstancesRequest, opts ...grpc.CallOption) (*QueryInstancesResponse, error)
	ListInstanceIds(ctx context.Context, in *ListInstanceIdsRequest, opts ...grpc.CallOption) (*ListInstanceIdsResponse, error)
	PurgeInstances(ctx context.Context, in *PurgeInstancesRequest, opts ...grpc.CallOption) (*PurgeInstancesResponse, error)
	GetWorkItems(ctx context.Context, in *GetWorkItemsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[WorkItem], error)
	CompleteActivityTask(ctx context.Context, in *ActivityResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	CompleteOrchestratorTask(ctx context.Context, in *OrchestratorResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	CompleteEntityTask(ctx context.Context, in *EntityBatchResult, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	// Gets the history of an orchestration instance as a stream of events.
	StreamInstanceHistory(ctx context.Context, in *StreamInstanceHistoryRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[HistoryChunk], error)
	// Deletes and Creates the necessary resources for the orchestration service and the instance store
	CreateTaskHub(ctx context.Context, in *CreateTaskHubRequest, opts ...grpc.CallOption) (*CreateTaskHubResponse, error)
	// Deletes the resources for the orchestration service and optionally the instance store
	DeleteTaskHub(ctx context.Context, in *DeleteTaskHubRequest, opts ...grpc.CallOption) (*DeleteTaskHubResponse, error)
	// sends a signal to an entity
	SignalEntity(ctx context.Context, in *SignalEntityRequest, opts ...grpc.CallOption) (*SignalEntityResponse, error)
	// get information about a specific entity
	GetEntity(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*GetEntityResponse, error)
	// query entities
	QueryEntities(ctx context.Context, in *QueryEntitiesRequest, opts ...grpc.CallOption) (*QueryEntitiesResponse, error)
	// clean entity storage
	CleanEntityStorage(ctx context.Context, in *CleanEntityStorageRequest, opts ...grpc.CallOption) (*CleanEntityStorageResponse, error)
	// Abandons a single work item
	AbandonTaskActivityWorkItem(ctx context.Context, in *AbandonActivityTaskRequest, opts ...grpc.CallOption) (*AbandonActivityTaskResponse, error)
	// Abandon an orchestration work item
	AbandonTaskOrchestratorWorkItem(ctx context.Context, in *AbandonOrchestrationTaskRequest, opts ...grpc.CallOption) (*AbandonOrchestrationTaskResponse, error)
	// Abandon an entity work item
	AbandonTaskEntityWorkItem(ctx context.Context, in *AbandonEntityTaskRequest, opts ...grpc.CallOption) (*AbandonEntityTaskResponse, error)
	// "Skip" graceful termination of orchestrations by immediately changing their status in storage to "terminated".
	// Note that a maximum of 500 orchestrations can be terminated at a time using this method.
	SkipGracefulOrchestrationTerminations(ctx context.Context, in *SkipGracefulOrchestrationTerminationsRequest, opts ...grpc.CallOption) (*SkipGracefulOrchestrationTerminationsResponse, error)
}

TaskHubSidecarServiceClient is the client API for TaskHubSidecarService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTaskHubSidecarServiceClient 

func NewTaskHubSidecarServiceClient(cc grpc.ClientConnInterface) TaskHubSidecarServiceClient

type TaskHubSidecarServiceServer 

type TaskHubSidecarServiceServer interface {
	// Sends a hello request to the sidecar service.
	Hello(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// Starts a new orchestration instance.
	StartInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// Gets the status of an existing orchestration instance.
	GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Rewinds an orchestration instance to last known good state and replays from there.
	RewindInstance(context.Context, *RewindInstanceRequest) (*RewindInstanceResponse, error)
	// Restarts an orchestration instance.
	RestartInstance(context.Context, *RestartInstanceRequest) (*RestartInstanceResponse, error)
	// Waits for an orchestration instance to reach a running or completion state.
	WaitForInstanceStart(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
	WaitForInstanceCompletion(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Raises an event to a running orchestration instance.
	RaiseEvent(context.Context, *RaiseEventRequest) (*RaiseEventResponse, error)
	// Terminates a running orchestration instance.
	TerminateInstance(context.Context, *TerminateRequest) (*TerminateResponse, error)
	// Suspends a running orchestration instance.
	SuspendInstance(context.Context, *SuspendRequest) (*SuspendResponse, error)
	// Resumes a suspended orchestration instance.
	ResumeInstance(context.Context, *ResumeRequest) (*ResumeResponse, error)
	QueryInstances(context.Context, *QueryInstancesRequest) (*QueryInstancesResponse, error)
	ListInstanceIds(context.Context, *ListInstanceIdsRequest) (*ListInstanceIdsResponse, error)
	PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)
	GetWorkItems(*GetWorkItemsRequest, grpc.ServerStreamingServer[WorkItem]) error
	CompleteActivityTask(context.Context, *ActivityResponse) (*CompleteTaskResponse, error)
	CompleteOrchestratorTask(context.Context, *OrchestratorResponse) (*CompleteTaskResponse, error)
	CompleteEntityTask(context.Context, *EntityBatchResult) (*CompleteTaskResponse, error)
	// Gets the history of an orchestration instance as a stream of events.
	StreamInstanceHistory(*StreamInstanceHistoryRequest, grpc.ServerStreamingServer[HistoryChunk]) error
	// Deletes and Creates the necessary resources for the orchestration service and the instance store
	CreateTaskHub(context.Context, *CreateTaskHubRequest) (*CreateTaskHubResponse, error)
	// Deletes the resources for the orchestration service and optionally the instance store
	DeleteTaskHub(context.Context, *DeleteTaskHubRequest) (*DeleteTaskHubResponse, error)
	// sends a signal to an entity
	SignalEntity(context.Context, *SignalEntityRequest) (*SignalEntityResponse, error)
	// get information about a specific entity
	GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)
	// query entities
	QueryEntities(context.Context, *QueryEntitiesRequest) (*QueryEntitiesResponse, error)
	// clean entity storage
	CleanEntityStorage(context.Context, *CleanEntityStorageRequest) (*CleanEntityStorageResponse, error)
	// Abandons a single work item
	AbandonTaskActivityWorkItem(context.Context, *AbandonActivityTaskRequest) (*AbandonActivityTaskResponse, error)
	// Abandon an orchestration work item
	AbandonTaskOrchestratorWorkItem(context.Context, *AbandonOrchestrationTaskRequest) (*AbandonOrchestrationTaskResponse, error)
	// Abandon an entity work item
	AbandonTaskEntityWorkItem(context.Context, *AbandonEntityTaskRequest) (*AbandonEntityTaskResponse, error)
	// "Skip" graceful termination of orchestrations by immediately changing their status in storage to "terminated".
	// Note that a maximum of 500 orchestrations can be terminated at a time using this method.
	SkipGracefulOrchestrationTerminations(context.Context, *SkipGracefulOrchestrationTerminationsRequest) (*SkipGracefulOrchestrationTerminationsResponse, error)
	// contains filtered or unexported methods
}

TaskHubSidecarServiceServer is the server API for TaskHubSidecarService service. All implementations must embed UnimplementedTaskHubSidecarServiceServer for forward compatibility.

type TaskHubSidecarService_GetWorkItemsClient 

type TaskHubSidecarService_GetWorkItemsClient = grpc.ServerStreamingClient[WorkItem]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskHubSidecarService_GetWorkItemsServer 

type TaskHubSidecarService_GetWorkItemsServer = grpc.ServerStreamingServer[WorkItem]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskHubSidecarService_StreamInstanceHistoryClient 

type TaskHubSidecarService_StreamInstanceHistoryClient = grpc.ServerStreamingClient[HistoryChunk]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskHubSidecarService_StreamInstanceHistoryServer 

type TaskHubSidecarService_StreamInstanceHistoryServer = grpc.ServerStreamingServer[HistoryChunk]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskScheduledEvent 

type TaskScheduledEvent struct {
	Name               string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version            *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	ParentTraceContext *TraceContext           `protobuf:"bytes,4,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	Tags               map[string]string       `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskScheduledEvent) Descriptor deprecated 

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

Deprecated: Use TaskScheduledEvent.ProtoReflect.Descriptor instead.

func (*TaskScheduledEvent) GetInput 

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

func (*TaskScheduledEvent) GetName 

func (x *TaskScheduledEvent) GetName() string

func (*TaskScheduledEvent) GetParentTraceContext added in v0.1.1 

func (x *TaskScheduledEvent) GetParentTraceContext() *TraceContext

func (*TaskScheduledEvent) GetTags 

func (x *TaskScheduledEvent) GetTags() map[string]string

func (*TaskScheduledEvent) GetVersion 

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

func (*TaskScheduledEvent) ProtoMessage 

func (*TaskScheduledEvent) ProtoMessage()

func (*TaskScheduledEvent) ProtoReflect 

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

func (*TaskScheduledEvent) Reset 

func (x *TaskScheduledEvent) Reset()

func (*TaskScheduledEvent) String 

func (x *TaskScheduledEvent) String() string

type TerminateOrchestrationAction added in v0.3.0 

type TerminateOrchestrationAction struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Reason     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Recurse    bool                    `protobuf:"varint,3,opt,name=recurse,proto3" json:"recurse,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateOrchestrationAction) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use TerminateOrchestrationAction.ProtoReflect.Descriptor instead.

func (*TerminateOrchestrationAction) GetInstanceId added in v0.3.0 

func (x *TerminateOrchestrationAction) GetInstanceId() string

func (*TerminateOrchestrationAction) GetReason added in v0.3.0 

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

func (*TerminateOrchestrationAction) GetRecurse added in v0.3.0 

func (x *TerminateOrchestrationAction) GetRecurse() bool

func (*TerminateOrchestrationAction) ProtoMessage added in v0.3.0 

func (*TerminateOrchestrationAction) ProtoMessage()

func (*TerminateOrchestrationAction) ProtoReflect added in v0.3.0 

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

func (*TerminateOrchestrationAction) Reset added in v0.3.0 

func (x *TerminateOrchestrationAction) Reset()

func (*TerminateOrchestrationAction) String added in v0.3.0 

func (x *TerminateOrchestrationAction) String() string

type TerminateRequest 

type TerminateRequest struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Output     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	Recursive  bool                    `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateRequest) Descriptor deprecated 

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

Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.

func (*TerminateRequest) GetInstanceId 

func (x *TerminateRequest) GetInstanceId() string

func (*TerminateRequest) GetOutput 

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

func (*TerminateRequest) GetRecursive added in v0.3.0 

func (x *TerminateRequest) GetRecursive() bool

func (*TerminateRequest) ProtoMessage 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) ProtoReflect 

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

func (*TerminateRequest) Reset 

func (x *TerminateRequest) Reset()

func (*TerminateRequest) String 

func (x *TerminateRequest) String() string

type TerminateResponse 

type TerminateResponse struct {
	// contains filtered or unexported fields
}

func (*TerminateResponse) Descriptor deprecated 

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

Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.

func (*TerminateResponse) ProtoMessage 

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) ProtoReflect 

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

func (*TerminateResponse) Reset 

func (x *TerminateResponse) Reset()

func (*TerminateResponse) String 

func (x *TerminateResponse) String() string

type TimerCreatedEvent 

type TimerCreatedEvent struct {
	FireAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fireAt,proto3" json:"fireAt,omitempty"`
	// contains filtered or unexported fields
}

func (*TimerCreatedEvent) Descriptor deprecated 

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

Deprecated: Use TimerCreatedEvent.ProtoReflect.Descriptor instead.

func (*TimerCreatedEvent) GetFireAt 

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

func (*TimerCreatedEvent) ProtoMessage 

func (*TimerCreatedEvent) ProtoMessage()

func (*TimerCreatedEvent) ProtoReflect 

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

func (*TimerCreatedEvent) Reset 

func (x *TimerCreatedEvent) Reset()

func (*TimerCreatedEvent) String 

func (x *TimerCreatedEvent) String() string

type TimerFiredEvent 

type TimerFiredEvent struct {
	FireAt  *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fireAt,proto3" json:"fireAt,omitempty"`
	TimerId int32                  `protobuf:"varint,2,opt,name=timerId,proto3" json:"timerId,omitempty"`
	// contains filtered or unexported fields
}

func (*TimerFiredEvent) Descriptor deprecated 

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

Deprecated: Use TimerFiredEvent.ProtoReflect.Descriptor instead.

func (*TimerFiredEvent) GetFireAt 

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

func (*TimerFiredEvent) GetTimerId 

func (x *TimerFiredEvent) GetTimerId() int32

func (*TimerFiredEvent) ProtoMessage 

func (*TimerFiredEvent) ProtoMessage()

func (*TimerFiredEvent) ProtoReflect 

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

func (*TimerFiredEvent) Reset 

func (x *TimerFiredEvent) Reset()

func (*TimerFiredEvent) String 

func (x *TimerFiredEvent) String() string

type TraceContext added in v0.1.1 

type TraceContext struct {
	TraceParent string `protobuf:"bytes,1,opt,name=traceParent,proto3" json:"traceParent,omitempty"`
	// Deprecated: Marked as deprecated in orchestrator_service.proto.
	SpanID     string                  `protobuf:"bytes,2,opt,name=spanID,proto3" json:"spanID,omitempty"`
	TraceState *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=traceState,proto3" json:"traceState,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceContext) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use TraceContext.ProtoReflect.Descriptor instead.

func (*TraceContext) GetSpanID deprecated added in v0.1.1 

func (x *TraceContext) GetSpanID() string

Deprecated: Marked as deprecated in orchestrator_service.proto.

func (*TraceContext) GetTraceParent added in v0.3.2 

func (x *TraceContext) GetTraceParent() string

func (*TraceContext) GetTraceState added in v0.1.1 

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

func (*TraceContext) ProtoMessage added in v0.1.1 

func (*TraceContext) ProtoMessage()

func (*TraceContext) ProtoReflect added in v0.1.1 

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

func (*TraceContext) Reset added in v0.1.1 

func (x *TraceContext) Reset()

func (*TraceContext) String added in v0.1.1 

func (x *TraceContext) String() string

type UnimplementedTaskHubSidecarServiceServer 

type UnimplementedTaskHubSidecarServiceServer struct{}

UnimplementedTaskHubSidecarServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTaskHubSidecarServiceServer) AbandonTaskActivityWorkItem 

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

func (UnimplementedTaskHubSidecarServiceServer) AbandonTaskEntityWorkItem 

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

func (UnimplementedTaskHubSidecarServiceServer) AbandonTaskOrchestratorWorkItem 

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

func (UnimplementedTaskHubSidecarServiceServer) CleanEntityStorage added in v0.3.2 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteEntityTask added in v0.3.2 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteOrchestratorTask 

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

func (UnimplementedTaskHubSidecarServiceServer) CreateTaskHub 

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

func (UnimplementedTaskHubSidecarServiceServer) DeleteTaskHub 

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

func (UnimplementedTaskHubSidecarServiceServer) GetEntity added in v0.3.2 

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

func (UnimplementedTaskHubSidecarServiceServer) GetInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems 

func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems(*GetWorkItemsRequest, grpc.ServerStreamingServer[WorkItem]) error

func (UnimplementedTaskHubSidecarServiceServer) Hello 

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

func (UnimplementedTaskHubSidecarServiceServer) ListInstanceIds 

func (UnimplementedTaskHubSidecarServiceServer) ListInstanceIds(context.Context, *ListInstanceIdsRequest) (*ListInstanceIdsResponse, error)

func (UnimplementedTaskHubSidecarServiceServer) PurgeInstances 

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

func (UnimplementedTaskHubSidecarServiceServer) QueryEntities added in v0.3.2 

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

func (UnimplementedTaskHubSidecarServiceServer) QueryInstances 

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

func (UnimplementedTaskHubSidecarServiceServer) RaiseEvent 

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

func (UnimplementedTaskHubSidecarServiceServer) RestartInstance 

func (UnimplementedTaskHubSidecarServiceServer) RestartInstance(context.Context, *RestartInstanceRequest) (*RestartInstanceResponse, error)

func (UnimplementedTaskHubSidecarServiceServer) ResumeInstance added in v0.1.1 

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

func (UnimplementedTaskHubSidecarServiceServer) RewindInstance added in v0.1.1 

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

func (UnimplementedTaskHubSidecarServiceServer) SignalEntity added in v0.3.2 

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

func (UnimplementedTaskHubSidecarServiceServer) SkipGracefulOrchestrationTerminations 

func (UnimplementedTaskHubSidecarServiceServer) SkipGracefulOrchestrationTerminations(context.Context, *SkipGracefulOrchestrationTerminationsRequest) (*SkipGracefulOrchestrationTerminationsResponse, error)

func (UnimplementedTaskHubSidecarServiceServer) StartInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) StreamInstanceHistory 

func (UnimplementedTaskHubSidecarServiceServer) StreamInstanceHistory(*StreamInstanceHistoryRequest, grpc.ServerStreamingServer[HistoryChunk]) error

func (UnimplementedTaskHubSidecarServiceServer) SuspendInstance added in v0.1.1 

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

func (UnimplementedTaskHubSidecarServiceServer) TerminateInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceCompletion 

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

func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceStart 

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

type UnsafeTaskHubSidecarServiceServer 

type UnsafeTaskHubSidecarServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTaskHubSidecarServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskHubSidecarServiceServer will result in compilation errors.

type WorkItem 

type WorkItem struct {

	// Types that are valid to be assigned to Request:
	//
	//	*WorkItem_OrchestratorRequest
	//	*WorkItem_ActivityRequest
	//	*WorkItem_EntityRequest
	//	*WorkItem_HealthPing
	//	*WorkItem_EntityRequestV2
	Request         isWorkItem_Request `protobuf_oneof:"request"`
	CompletionToken string             `protobuf:"bytes,10,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkItem) Descriptor deprecated 

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

Deprecated: Use WorkItem.ProtoReflect.Descriptor instead.

func (*WorkItem) GetActivityRequest 

func (x *WorkItem) GetActivityRequest() *ActivityRequest

func (*WorkItem) GetCompletionToken 

func (x *WorkItem) GetCompletionToken() string

func (*WorkItem) GetEntityRequest added in v0.3.2 

func (x *WorkItem) GetEntityRequest() *EntityBatchRequest

func (*WorkItem) GetEntityRequestV2 

func (x *WorkItem) GetEntityRequestV2() *EntityRequest

func (*WorkItem) GetHealthPing 

func (x *WorkItem) GetHealthPing() *HealthPing

func (*WorkItem) GetOrchestratorRequest 

func (x *WorkItem) GetOrchestratorRequest() *OrchestratorRequest

func (*WorkItem) GetRequest 

func (x *WorkItem) GetRequest() isWorkItem_Request

func (*WorkItem) ProtoMessage 

func (*WorkItem) ProtoMessage()

func (*WorkItem) ProtoReflect 

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

func (*WorkItem) Reset 

func (x *WorkItem) Reset()

func (*WorkItem) String 

func (x *WorkItem) String() string

type WorkItemFilters 

type WorkItemFilters struct {
	Orchestrations []*OrchestrationFilter `protobuf:"bytes,1,rep,name=orchestrations,proto3" json:"orchestrations,omitempty"`
	Activities     []*ActivityFilter      `protobuf:"bytes,2,rep,name=activities,proto3" json:"activities,omitempty"`
	Entities       []*EntityFilter        `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkItemFilters) Descriptor deprecated 

func (*WorkItemFilters) Descriptor() ([]byte, []int)

Deprecated: Use WorkItemFilters.ProtoReflect.Descriptor instead.

func (*WorkItemFilters) GetActivities 

func (x *WorkItemFilters) GetActivities() []*ActivityFilter

func (*WorkItemFilters) GetEntities 

func (x *WorkItemFilters) GetEntities() []*EntityFilter

func (*WorkItemFilters) GetOrchestrations 

func (x *WorkItemFilters) GetOrchestrations() []*OrchestrationFilter

func (*WorkItemFilters) ProtoMessage 

func (*WorkItemFilters) ProtoMessage()

func (*WorkItemFilters) ProtoReflect 

func (x *WorkItemFilters) ProtoReflect() protoreflect.Message

func (*WorkItemFilters) Reset 

func (x *WorkItemFilters) Reset()

func (*WorkItemFilters) String 

func (x *WorkItemFilters) String() string

type WorkItem_ActivityRequest 

type WorkItem_ActivityRequest struct {
	ActivityRequest *ActivityRequest `protobuf:"bytes,2,opt,name=activityRequest,proto3,oneof"`
}

type WorkItem_EntityRequest added in v0.3.2 

type WorkItem_EntityRequest struct {
	EntityRequest *EntityBatchRequest `protobuf:"bytes,3,opt,name=entityRequest,proto3,oneof"` // (older) used by orchestration services implementations
}

type WorkItem_EntityRequestV2 

type WorkItem_EntityRequestV2 struct {
	EntityRequestV2 *EntityRequest `protobuf:"bytes,5,opt,name=entityRequestV2,proto3,oneof"` // (newer) used by backend service implementations
}

type WorkItem_HealthPing 

type WorkItem_HealthPing struct {
	HealthPing *HealthPing `protobuf:"bytes,4,opt,name=healthPing,proto3,oneof"`
}

type WorkItem_OrchestratorRequest 

type WorkItem_OrchestratorRequest struct {
	OrchestratorRequest *OrchestratorRequest `protobuf:"bytes,1,opt,name=orchestratorRequest,proto3,oneof"`
}

type WorkerCapability 

type WorkerCapability int32
const (
	WorkerCapability_WORKER_CAPABILITY_UNSPECIFIED WorkerCapability = 0
	// Indicates that the worker is capable of streaming instance history as a more optimized
	// alternative to receiving the full history embedded in the orchestrator work-item.
	// When set, the service may return work items without any history events as an optimization.
	// It is strongly recommended that all SDKs support this capability.
	WorkerCapability_WORKER_CAPABILITY_HISTORY_STREAMING WorkerCapability = 1
	// Indicates that the worker supports scheduled tasks.
	// The service may send schedule-triggered orchestration work items,
	// and the worker must handle them, including the scheduledTime field.
	WorkerCapability_WORKER_CAPABILITY_SCHEDULED_TASKS WorkerCapability = 2
	// Signals that the worker can handle large payloads stored externally (e.g., Blob Storage).
	// Work items may contain URI references instead of inline data, and the worker must fetch them.
	// This avoids message size limits and reduces network overhead.
	WorkerCapability_WORKER_CAPABILITY_LARGE_PAYLOADS WorkerCapability = 3
)

func (WorkerCapability) Descriptor 

func (WorkerCapability) Descriptor() protoreflect.EnumDescriptor

func (WorkerCapability) Enum 

func (x WorkerCapability) Enum() *WorkerCapability

func (WorkerCapability) EnumDescriptor deprecated 

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

Deprecated: Use WorkerCapability.Descriptor instead.

func (WorkerCapability) Number 

func (x WorkerCapability) Number() protoreflect.EnumNumber

func (WorkerCapability) String 

func (x WorkerCapability) String() string

func (WorkerCapability) Type 

func (WorkerCapability) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.