protos

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2024 License: Apache-2.0 Imports: 12 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_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_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_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"
)

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 (
	CreateOrchestrationAction_name = map[int32]string{
		0: "ERROR",
		1: "IGNORE",
		2: "TERMINATE",
	}
	CreateOrchestrationAction_value = map[string]int32{
		"ERROR":     0,
		"IGNORE":    1,
		"TERMINATE": 2,
	}
)

Enum value maps for CreateOrchestrationAction.

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: "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: "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,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetWorkItems",
			Handler:       _TaskHubSidecarService_GetWorkItems_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "orchestrator_service.proto",
}

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

Functions

func RegisterTaskHubSidecarServiceServer 

func RegisterTaskHubSidecarServiceServer(s grpc.ServiceRegistrar, srv TaskHubSidecarServiceServer)

Types

type ActivityRequest 

type ActivityRequest struct {
	Name                  string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version               *wrappers.StringValue  `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input                 *wrappers.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"`
	// 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() *wrappers.StringValue

func (*ActivityRequest) GetName 

func (x *ActivityRequest) GetName() string

func (*ActivityRequest) GetOrchestrationInstance 

func (x *ActivityRequest) GetOrchestrationInstance() *OrchestrationInstance

func (*ActivityRequest) GetTaskId 

func (x *ActivityRequest) GetTaskId() int32

func (*ActivityRequest) GetVersion 

func (x *ActivityRequest) GetVersion() *wrappers.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         *wrappers.StringValue `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	FailureDetails *TaskFailureDetails   `protobuf:"bytes,4,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityResponse) Descriptor deprecated 

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

Deprecated: Use ActivityResponse.ProtoReflect.Descriptor instead.

func (*ActivityResponse) GetFailureDetails 

func (x *ActivityResponse) GetFailureDetails() *TaskFailureDetails

func (*ActivityResponse) GetInstanceId 

func (x *ActivityResponse) GetInstanceId() string

func (*ActivityResponse) GetResult 

func (x *ActivityResponse) GetResult() *wrappers.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 

type CleanEntityStorageRequest struct {
	ContinuationToken    *wrappers.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 

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

Deprecated: Use CleanEntityStorageRequest.ProtoReflect.Descriptor instead.

func (*CleanEntityStorageRequest) GetContinuationToken 

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

func (*CleanEntityStorageRequest) GetReleaseOrphanedLocks 

func (x *CleanEntityStorageRequest) GetReleaseOrphanedLocks() bool

func (*CleanEntityStorageRequest) GetRemoveEmptyEntities 

func (x *CleanEntityStorageRequest) GetRemoveEmptyEntities() bool

func (*CleanEntityStorageRequest) ProtoMessage 

func (*CleanEntityStorageRequest) ProtoMessage()

func (*CleanEntityStorageRequest) ProtoReflect 

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

func (*CleanEntityStorageRequest) Reset 

func (x *CleanEntityStorageRequest) Reset()

func (*CleanEntityStorageRequest) String 

func (x *CleanEntityStorageRequest) String() string

type CleanEntityStorageResponse 

type CleanEntityStorageResponse struct {
	ContinuationToken     *wrappers.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 

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

Deprecated: Use CleanEntityStorageResponse.ProtoReflect.Descriptor instead.

func (*CleanEntityStorageResponse) GetContinuationToken 

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

func (*CleanEntityStorageResponse) GetEmptyEntitiesRemoved 

func (x *CleanEntityStorageResponse) GetEmptyEntitiesRemoved() int32

func (*CleanEntityStorageResponse) GetOrphanedLocksReleased 

func (x *CleanEntityStorageResponse) GetOrphanedLocksReleased() int32

func (*CleanEntityStorageResponse) ProtoMessage 

func (*CleanEntityStorageResponse) ProtoMessage()

func (*CleanEntityStorageResponse) ProtoReflect 

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

func (*CleanEntityStorageResponse) Reset 

func (x *CleanEntityStorageResponse) Reset()

func (*CleanEntityStorageResponse) String 

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              *wrappers.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Details             *wrappers.StringValue `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	NewVersion          *wrappers.StringValue `protobuf:"bytes,4,opt,name=newVersion,proto3" json:"newVersion,omitempty"`
	CarryoverEvents     []*HistoryEvent       `protobuf:"bytes,5,rep,name=carryoverEvents,proto3" json:"carryoverEvents,omitempty"`
	FailureDetails      *TaskFailureDetails   `protobuf:"bytes,6,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

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

func (*CompleteOrchestrationAction) GetFailureDetails 

func (x *CompleteOrchestrationAction) GetFailureDetails() *TaskFailureDetails

func (*CompleteOrchestrationAction) GetNewVersion 

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

func (*CompleteOrchestrationAction) GetOrchestrationStatus 

func (x *CompleteOrchestrationAction) GetOrchestrationStatus() OrchestrationStatus

func (*CompleteOrchestrationAction) GetResult 

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

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 *wrappers.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() *wrappers.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                    *wrappers.StringValue       `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input                      *wrappers.StringValue       `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledStartTimestamp    *timestamp.Timestamp        `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	OrchestrationIdReusePolicy *OrchestrationIdReusePolicy `protobuf:"bytes,6,opt,name=orchestrationIdReusePolicy,proto3" json:"orchestrationIdReusePolicy,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateInstanceRequest) Descriptor deprecated 

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

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetInput 

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

func (*CreateInstanceRequest) GetInstanceId 

func (x *CreateInstanceRequest) GetInstanceId() string

func (*CreateInstanceRequest) GetName 

func (x *CreateInstanceRequest) GetName() string

func (*CreateInstanceRequest) GetOrchestrationIdReusePolicy 

func (x *CreateInstanceRequest) GetOrchestrationIdReusePolicy() *OrchestrationIdReusePolicy

func (*CreateInstanceRequest) GetScheduledStartTimestamp 

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

func (*CreateInstanceRequest) GetVersion 

func (x *CreateInstanceRequest) GetVersion() *wrappers.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 CreateOrchestrationAction 

type CreateOrchestrationAction int32
const (
	CreateOrchestrationAction_ERROR     CreateOrchestrationAction = 0
	CreateOrchestrationAction_IGNORE    CreateOrchestrationAction = 1
	CreateOrchestrationAction_TERMINATE CreateOrchestrationAction = 2
)

func (CreateOrchestrationAction) Descriptor 

func (CreateOrchestrationAction) Descriptor() protoreflect.EnumDescriptor

func (CreateOrchestrationAction) Enum 

func (x CreateOrchestrationAction) Enum() *CreateOrchestrationAction

func (CreateOrchestrationAction) EnumDescriptor deprecated 

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

Deprecated: Use CreateOrchestrationAction.Descriptor instead.

func (CreateOrchestrationAction) Number 

func (x CreateOrchestrationAction) Number() protoreflect.EnumNumber

func (CreateOrchestrationAction) String 

func (x CreateOrchestrationAction) String() string

func (CreateOrchestrationAction) Type 

func (CreateOrchestrationAction) Type() protoreflect.EnumType

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    *wrappers.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input      *wrappers.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// 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() *wrappers.StringValue

func (*CreateSubOrchestrationAction) GetInstanceId 

func (x *CreateSubOrchestrationAction) GetInstanceId() string

func (*CreateSubOrchestrationAction) GetName 

func (x *CreateSubOrchestrationAction) GetName() string

func (*CreateSubOrchestrationAction) GetVersion 

func (x *CreateSubOrchestrationAction) GetVersion() *wrappers.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 *timestamp.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() *timestamp.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 

type EntityBatchRequest struct {
	InstanceId  string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	EntityState *wrappers.StringValue `protobuf:"bytes,2,opt,name=entityState,proto3" json:"entityState,omitempty"`
	Operations  []*OperationRequest   `protobuf:"bytes,3,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityBatchRequest) Descriptor deprecated 

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

Deprecated: Use EntityBatchRequest.ProtoReflect.Descriptor instead.

func (*EntityBatchRequest) GetEntityState 

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

func (*EntityBatchRequest) GetInstanceId 

func (x *EntityBatchRequest) GetInstanceId() string

func (*EntityBatchRequest) GetOperations 

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

func (*EntityBatchRequest) ProtoMessage 

func (*EntityBatchRequest) ProtoMessage()

func (*EntityBatchRequest) ProtoReflect 

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

func (*EntityBatchRequest) Reset 

func (x *EntityBatchRequest) Reset()

func (*EntityBatchRequest) String 

func (x *EntityBatchRequest) String() string

type EntityBatchResult 

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    *wrappers.StringValue `protobuf:"bytes,3,opt,name=entityState,proto3" json:"entityState,omitempty"`
	FailureDetails *TaskFailureDetails   `protobuf:"bytes,4,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityBatchResult) Descriptor deprecated 

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

Deprecated: Use EntityBatchResult.ProtoReflect.Descriptor instead.

func (*EntityBatchResult) GetActions 

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

func (*EntityBatchResult) GetEntityState 

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

func (*EntityBatchResult) GetFailureDetails 

func (x *EntityBatchResult) GetFailureDetails() *TaskFailureDetails

func (*EntityBatchResult) GetResults 

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

func (*EntityBatchResult) ProtoMessage 

func (*EntityBatchResult) ProtoMessage()

func (*EntityBatchResult) ProtoReflect 

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

func (*EntityBatchResult) Reset 

func (x *EntityBatchResult) Reset()

func (*EntityBatchResult) String 

func (x *EntityBatchResult) String() string

type EntityMetadata 

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

func (*EntityMetadata) Descriptor deprecated 

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

Deprecated: Use EntityMetadata.ProtoReflect.Descriptor instead.

func (*EntityMetadata) GetBacklogQueueSize 

func (x *EntityMetadata) GetBacklogQueueSize() int32

func (*EntityMetadata) GetInstanceId 

func (x *EntityMetadata) GetInstanceId() string

func (*EntityMetadata) GetLastModifiedTime 

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

func (*EntityMetadata) GetLockedBy 

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

func (*EntityMetadata) GetSerializedState 

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

func (*EntityMetadata) ProtoMessage 

func (*EntityMetadata) ProtoMessage()

func (*EntityMetadata) ProtoReflect 

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

func (*EntityMetadata) Reset 

func (x *EntityMetadata) Reset()

func (*EntityMetadata) String 

func (x *EntityMetadata) String() string

type EntityQuery 

type EntityQuery struct {
	InstanceIdStartsWith *wrappers.StringValue `protobuf:"bytes,1,opt,name=instanceIdStartsWith,proto3" json:"instanceIdStartsWith,omitempty"`
	LastModifiedFrom     *timestamp.Timestamp  `protobuf:"bytes,2,opt,name=lastModifiedFrom,proto3" json:"lastModifiedFrom,omitempty"`
	LastModifiedTo       *timestamp.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             *wrappers.Int32Value  `protobuf:"bytes,6,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	ContinuationToken    *wrappers.StringValue `protobuf:"bytes,7,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityQuery) Descriptor deprecated 

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

Deprecated: Use EntityQuery.ProtoReflect.Descriptor instead.

func (*EntityQuery) GetContinuationToken 

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

func (*EntityQuery) GetIncludeState 

func (x *EntityQuery) GetIncludeState() bool

func (*EntityQuery) GetIncludeTransient 

func (x *EntityQuery) GetIncludeTransient() bool

func (*EntityQuery) GetInstanceIdStartsWith 

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

func (*EntityQuery) GetLastModifiedFrom 

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

func (*EntityQuery) GetLastModifiedTo 

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

func (*EntityQuery) GetPageSize 

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

func (*EntityQuery) ProtoMessage 

func (*EntityQuery) ProtoMessage()

func (*EntityQuery) ProtoReflect 

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

func (*EntityQuery) Reset 

func (x *EntityQuery) Reset()

func (*EntityQuery) String 

func (x *EntityQuery) String() string

type EventRaisedEvent 

type EventRaisedEvent struct {
	Name  string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Input *wrappers.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() *wrappers.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      *wrappers.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() *wrappers.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              *wrappers.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() *wrappers.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 

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

func (*ExecutionResumedEvent) Descriptor deprecated 

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

Deprecated: Use ExecutionResumedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionResumedEvent) GetInput 

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

func (*ExecutionResumedEvent) ProtoMessage 

func (*ExecutionResumedEvent) ProtoMessage()

func (*ExecutionResumedEvent) ProtoReflect 

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

func (*ExecutionResumedEvent) Reset 

func (x *ExecutionResumedEvent) Reset()

func (*ExecutionResumedEvent) String 

func (x *ExecutionResumedEvent) String() string

type ExecutionStartedEvent 

type ExecutionStartedEvent struct {
	Name                    string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version                 *wrappers.StringValue  `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input                   *wrappers.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 *timestamp.Timestamp   `protobuf:"bytes,6,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	ParentTraceContext      *TraceContext          `protobuf:"bytes,7,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	OrchestrationSpanID     *wrappers.StringValue  `protobuf:"bytes,8,opt,name=orchestrationSpanID,proto3" json:"orchestrationSpanID,omitempty"`
	// 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() *wrappers.StringValue

func (*ExecutionStartedEvent) GetName 

func (x *ExecutionStartedEvent) GetName() string

func (*ExecutionStartedEvent) GetOrchestrationInstance 

func (x *ExecutionStartedEvent) GetOrchestrationInstance() *OrchestrationInstance

func (*ExecutionStartedEvent) GetOrchestrationSpanID 

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

func (*ExecutionStartedEvent) GetParentInstance 

func (x *ExecutionStartedEvent) GetParentInstance() *ParentInstanceInfo

func (*ExecutionStartedEvent) GetParentTraceContext 

func (x *ExecutionStartedEvent) GetParentTraceContext() *TraceContext

func (*ExecutionStartedEvent) GetScheduledStartTimestamp 

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

func (*ExecutionStartedEvent) GetVersion 

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

func (*ExecutionStartedEvent) ProtoMessage 

func (*ExecutionStartedEvent) ProtoMessage()

func (*ExecutionStartedEvent) ProtoReflect 

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

func (*ExecutionStartedEvent) Reset 

func (x *ExecutionStartedEvent) Reset()

func (*ExecutionStartedEvent) String 

func (x *ExecutionStartedEvent) String() string

type ExecutionSuspendedEvent 

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

func (*ExecutionSuspendedEvent) Descriptor deprecated 

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

Deprecated: Use ExecutionSuspendedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionSuspendedEvent) GetInput 

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

func (*ExecutionSuspendedEvent) ProtoMessage 

func (*ExecutionSuspendedEvent) ProtoMessage()

func (*ExecutionSuspendedEvent) ProtoReflect 

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

func (*ExecutionSuspendedEvent) Reset 

func (x *ExecutionSuspendedEvent) Reset()

func (*ExecutionSuspendedEvent) String 

func (x *ExecutionSuspendedEvent) String() string

type ExecutionTerminatedEvent 

type ExecutionTerminatedEvent struct {
	Input   *wrappers.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() *wrappers.StringValue

func (*ExecutionTerminatedEvent) GetRecurse 

func (x *ExecutionTerminatedEvent) GetRecurse() bool

func (*ExecutionTerminatedEvent) ProtoMessage 

func (*ExecutionTerminatedEvent) ProtoMessage()

func (*ExecutionTerminatedEvent) ProtoReflect 

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

func (*ExecutionTerminatedEvent) Reset 

func (x *ExecutionTerminatedEvent) Reset()

func (*ExecutionTerminatedEvent) String 

func (x *ExecutionTerminatedEvent) String() string

type GenericEvent 

type GenericEvent struct {
	Data *wrappers.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() *wrappers.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 

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 

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

Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.

func (*GetEntityRequest) GetIncludeState 

func (x *GetEntityRequest) GetIncludeState() bool

func (*GetEntityRequest) GetInstanceId 

func (x *GetEntityRequest) GetInstanceId() string

func (*GetEntityRequest) ProtoMessage 

func (*GetEntityRequest) ProtoMessage()

func (*GetEntityRequest) ProtoReflect 

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

func (*GetEntityRequest) Reset 

func (x *GetEntityRequest) Reset()

func (*GetEntityRequest) String 

func (x *GetEntityRequest) String() string

type GetEntityResponse 

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 

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

Deprecated: Use GetEntityResponse.ProtoReflect.Descriptor instead.

func (*GetEntityResponse) GetEntity 

func (x *GetEntityResponse) GetEntity() *EntityMetadata

func (*GetEntityResponse) GetExists 

func (x *GetEntityResponse) GetExists() bool

func (*GetEntityResponse) ProtoMessage 

func (*GetEntityResponse) ProtoMessage()

func (*GetEntityResponse) ProtoReflect 

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

func (*GetEntityResponse) Reset 

func (x *GetEntityResponse) Reset()

func (*GetEntityResponse) String 

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 {
	// contains filtered or unexported fields
}

func (*GetWorkItemsRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkItemsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkItemsRequest) ProtoMessage 

func (*GetWorkItemsRequest) ProtoMessage()

func (*GetWorkItemsRequest) ProtoReflect 

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

func (*GetWorkItemsRequest) Reset 

func (x *GetWorkItemsRequest) Reset()

func (*GetWorkItemsRequest) String 

func (x *GetWorkItemsRequest) String() string

type HistoryEvent 

type HistoryEvent struct {
	EventId   int32                `protobuf:"varint,1,opt,name=eventId,proto3" json:"eventId,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are assignable to EventType:
	//
	//	*HistoryEvent_ExecutionStarted
	//	*HistoryEvent_ExecutionCompleted
	//	*HistoryEvent_ExecutionTerminated
	//	*HistoryEvent_TaskScheduled
	//	*HistoryEvent_TaskCompleted
	//	*HistoryEvent_TaskFailed
	//	*HistoryEvent_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
	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) GetEventId 

func (x *HistoryEvent) GetEventId() int32

func (*HistoryEvent) GetEventRaised 

func (x *HistoryEvent) GetEventRaised() *EventRaisedEvent

func (*HistoryEvent) GetEventSent 

func (x *HistoryEvent) GetEventSent() *EventSentEvent

func (*HistoryEvent) GetEventType 

func (m *HistoryEvent) GetEventType() isHistoryEvent_EventType

func (*HistoryEvent) GetExecutionCompleted 

func (x *HistoryEvent) GetExecutionCompleted() *ExecutionCompletedEvent

func (*HistoryEvent) GetExecutionResumed 

func (x *HistoryEvent) GetExecutionResumed() *ExecutionResumedEvent

func (*HistoryEvent) GetExecutionStarted 

func (x *HistoryEvent) GetExecutionStarted() *ExecutionStartedEvent

func (*HistoryEvent) GetExecutionSuspended 

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() *timestamp.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_EventRaised 

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

type HistoryEvent_EventSent 

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

type HistoryEvent_ExecutionCompleted 

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

type HistoryEvent_ExecutionResumed 

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

type HistoryEvent_ExecutionStarted 

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

type HistoryEvent_ExecutionSuspended 

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

type HistoryEvent_ExecutionTerminated 

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

type HistoryEvent_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 InstanceQuery 

type InstanceQuery struct {
	RuntimeStatus         []OrchestrationStatus   `protobuf:"varint,1,rep,packed,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	CreatedTimeFrom       *timestamp.Timestamp    `protobuf:"bytes,2,opt,name=createdTimeFrom,proto3" json:"createdTimeFrom,omitempty"`
	CreatedTimeTo         *timestamp.Timestamp    `protobuf:"bytes,3,opt,name=createdTimeTo,proto3" json:"createdTimeTo,omitempty"`
	TaskHubNames          []*wrappers.StringValue `protobuf:"bytes,4,rep,name=taskHubNames,proto3" json:"taskHubNames,omitempty"`
	MaxInstanceCount      int32                   `protobuf:"varint,5,opt,name=maxInstanceCount,proto3" json:"maxInstanceCount,omitempty"`
	ContinuationToken     *wrappers.StringValue   `protobuf:"bytes,6,opt,name=continuationToken,proto3" json:"continuationToken,omitempty"`
	InstanceIdPrefix      *wrappers.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() *wrappers.StringValue

func (*InstanceQuery) GetCreatedTimeFrom 

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

func (*InstanceQuery) GetCreatedTimeTo 

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

func (*InstanceQuery) GetFetchInputsAndOutputs 

func (x *InstanceQuery) GetFetchInputsAndOutputs() bool

func (*InstanceQuery) GetInstanceIdPrefix 

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

func (*InstanceQuery) GetMaxInstanceCount 

func (x *InstanceQuery) GetMaxInstanceCount() int32

func (*InstanceQuery) GetRuntimeStatus 

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

func (*InstanceQuery) GetTaskHubNames 

func (x *InstanceQuery) GetTaskHubNames() []*wrappers.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 OperationAction 

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

func (*OperationAction) Descriptor deprecated 

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

Deprecated: Use OperationAction.ProtoReflect.Descriptor instead.

func (*OperationAction) GetId 

func (x *OperationAction) GetId() int32

func (*OperationAction) GetOperationActionType 

func (m *OperationAction) GetOperationActionType() isOperationAction_OperationActionType

func (*OperationAction) GetSendSignal 

func (x *OperationAction) GetSendSignal() *SendSignalAction

func (*OperationAction) GetStartNewOrchestration 

func (x *OperationAction) GetStartNewOrchestration() *StartNewOrchestrationAction

func (*OperationAction) ProtoMessage 

func (*OperationAction) ProtoMessage()

func (*OperationAction) ProtoReflect 

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

func (*OperationAction) Reset 

func (x *OperationAction) Reset()

func (*OperationAction) String 

func (x *OperationAction) String() string

type OperationAction_SendSignal 

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

type OperationAction_StartNewOrchestration 

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

type OperationRequest 

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     *wrappers.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationRequest) Descriptor deprecated 

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

Deprecated: Use OperationRequest.ProtoReflect.Descriptor instead.

func (*OperationRequest) GetInput 

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

func (*OperationRequest) GetOperation 

func (x *OperationRequest) GetOperation() string

func (*OperationRequest) GetRequestId 

func (x *OperationRequest) GetRequestId() string

func (*OperationRequest) ProtoMessage 

func (*OperationRequest) ProtoMessage()

func (*OperationRequest) ProtoReflect 

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

func (*OperationRequest) Reset 

func (x *OperationRequest) Reset()

func (*OperationRequest) String 

func (x *OperationRequest) String() string

type OperationResult 

type OperationResult struct {

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

func (*OperationResult) Descriptor deprecated 

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

Deprecated: Use OperationResult.ProtoReflect.Descriptor instead.

func (*OperationResult) GetFailure 

func (x *OperationResult) GetFailure() *OperationResultFailure

func (*OperationResult) GetResultType 

func (m *OperationResult) GetResultType() isOperationResult_ResultType

func (*OperationResult) GetSuccess 

func (x *OperationResult) GetSuccess() *OperationResultSuccess

func (*OperationResult) ProtoMessage 

func (*OperationResult) ProtoMessage()

func (*OperationResult) ProtoReflect 

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

func (*OperationResult) Reset 

func (x *OperationResult) Reset()

func (*OperationResult) String 

func (x *OperationResult) String() string

type OperationResultFailure 

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

func (*OperationResultFailure) Descriptor deprecated 

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

Deprecated: Use OperationResultFailure.ProtoReflect.Descriptor instead.

func (*OperationResultFailure) GetFailureDetails 

func (x *OperationResultFailure) GetFailureDetails() *TaskFailureDetails

func (*OperationResultFailure) ProtoMessage 

func (*OperationResultFailure) ProtoMessage()

func (*OperationResultFailure) ProtoReflect 

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

func (*OperationResultFailure) Reset 

func (x *OperationResultFailure) Reset()

func (*OperationResultFailure) String 

func (x *OperationResultFailure) String() string

type OperationResultSuccess 

type OperationResultSuccess struct {
	Result *wrappers.StringValue `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationResultSuccess) Descriptor deprecated 

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

Deprecated: Use OperationResultSuccess.ProtoReflect.Descriptor instead.

func (*OperationResultSuccess) GetResult 

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

func (*OperationResultSuccess) ProtoMessage 

func (*OperationResultSuccess) ProtoMessage()

func (*OperationResultSuccess) ProtoReflect 

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

func (*OperationResultSuccess) Reset 

func (x *OperationResultSuccess) Reset()

func (*OperationResultSuccess) String 

func (x *OperationResultSuccess) String() string

type OperationResult_Failure 

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

type OperationResult_Success 

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

type OrchestrationIdReusePolicy 

type OrchestrationIdReusePolicy struct {
	OperationStatus []OrchestrationStatus     `protobuf:"varint,1,rep,packed,name=operationStatus,proto3,enum=OrchestrationStatus" json:"operationStatus,omitempty"`
	Action          CreateOrchestrationAction `protobuf:"varint,2,opt,name=action,proto3,enum=CreateOrchestrationAction" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestrationIdReusePolicy) Descriptor deprecated 

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

Deprecated: Use OrchestrationIdReusePolicy.ProtoReflect.Descriptor instead.

func (*OrchestrationIdReusePolicy) GetAction 

func (x *OrchestrationIdReusePolicy) GetAction() CreateOrchestrationAction

func (*OrchestrationIdReusePolicy) GetOperationStatus 

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

func (*OrchestrationIdReusePolicy) ProtoMessage 

func (*OrchestrationIdReusePolicy) ProtoMessage()

func (*OrchestrationIdReusePolicy) ProtoReflect 

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

func (*OrchestrationIdReusePolicy) Reset 

func (x *OrchestrationIdReusePolicy) Reset()

func (*OrchestrationIdReusePolicy) String 

func (x *OrchestrationIdReusePolicy) String() string

type OrchestrationInstance 

type OrchestrationInstance struct {
	InstanceId  string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId *wrappers.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() *wrappers.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                 *wrappers.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 *timestamp.Timestamp  `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	CreatedTimestamp        *timestamp.Timestamp  `protobuf:"bytes,6,opt,name=createdTimestamp,proto3" json:"createdTimestamp,omitempty"`
	LastUpdatedTimestamp    *timestamp.Timestamp  `protobuf:"bytes,7,opt,name=lastUpdatedTimestamp,proto3" json:"lastUpdatedTimestamp,omitempty"`
	Input                   *wrappers.StringValue `protobuf:"bytes,8,opt,name=input,proto3" json:"input,omitempty"`
	Output                  *wrappers.StringValue `protobuf:"bytes,9,opt,name=output,proto3" json:"output,omitempty"`
	CustomStatus            *wrappers.StringValue `protobuf:"bytes,10,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	FailureDetails          *TaskFailureDetails   `protobuf:"bytes,11,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestrationState) Descriptor deprecated 

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

Deprecated: Use OrchestrationState.ProtoReflect.Descriptor instead.

func (*OrchestrationState) GetCreatedTimestamp 

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

func (*OrchestrationState) GetCustomStatus 

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

func (*OrchestrationState) GetFailureDetails 

func (x *OrchestrationState) GetFailureDetails() *TaskFailureDetails

func (*OrchestrationState) GetInput 

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

func (*OrchestrationState) GetInstanceId 

func (x *OrchestrationState) GetInstanceId() string

func (*OrchestrationState) GetLastUpdatedTimestamp 

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

func (*OrchestrationState) GetName 

func (x *OrchestrationState) GetName() string

func (*OrchestrationState) GetOrchestrationStatus 

func (x *OrchestrationState) GetOrchestrationStatus() OrchestrationStatus

func (*OrchestrationState) GetOutput 

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

func (*OrchestrationState) GetScheduledStartTimestamp 

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

func (*OrchestrationState) GetVersion 

func (x *OrchestrationState) GetVersion() *wrappers.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 OrchestratorAction 

type OrchestratorAction struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to OrchestratorActionType:
	//
	//	*OrchestratorAction_ScheduleTask
	//	*OrchestratorAction_CreateSubOrchestration
	//	*OrchestratorAction_CreateTimer
	//	*OrchestratorAction_SendEvent
	//	*OrchestratorAction_CompleteOrchestration
	//	*OrchestratorAction_TerminateOrchestration
	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 (m *OrchestratorAction) GetOrchestratorActionType() isOrchestratorAction_OrchestratorActionType

func (*OrchestratorAction) GetScheduleTask 

func (x *OrchestratorAction) GetScheduleTask() *ScheduleTaskAction

func (*OrchestratorAction) GetSendEvent 

func (x *OrchestratorAction) GetSendEvent() *SendEventAction

func (*OrchestratorAction) GetTerminateOrchestration 

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_ScheduleTask 

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

type OrchestratorAction_SendEvent 

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

type OrchestratorAction_TerminateOrchestration 

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 

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

func (*OrchestratorEntityParameters) Descriptor deprecated 

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

Deprecated: Use OrchestratorEntityParameters.ProtoReflect.Descriptor instead.

func (*OrchestratorEntityParameters) GetEntityMessageReorderWindow 

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

func (*OrchestratorEntityParameters) ProtoMessage 

func (*OrchestratorEntityParameters) ProtoMessage()

func (*OrchestratorEntityParameters) ProtoReflect 

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

func (*OrchestratorEntityParameters) Reset 

func (x *OrchestratorEntityParameters) Reset()

func (*OrchestratorEntityParameters) String 

func (x *OrchestratorEntityParameters) String() string

type OrchestratorRequest 

type OrchestratorRequest struct {
	InstanceId       string                        `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId      *wrappers.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"`
	// contains filtered or unexported fields
}

func (*OrchestratorRequest) Descriptor deprecated 

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

Deprecated: Use OrchestratorRequest.ProtoReflect.Descriptor instead.

func (*OrchestratorRequest) GetEntityParameters 

func (x *OrchestratorRequest) GetEntityParameters() *OrchestratorEntityParameters

func (*OrchestratorRequest) GetExecutionId 

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

func (*OrchestratorRequest) GetInstanceId 

func (x *OrchestratorRequest) GetInstanceId() string

func (*OrchestratorRequest) GetNewEvents 

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

func (*OrchestratorRequest) GetPastEvents 

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

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 *wrappers.StringValue `protobuf:"bytes,3,opt,name=customStatus,proto3" json:"customStatus,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) GetCustomStatus 

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

func (*OrchestratorResponse) GetInstanceId 

func (x *OrchestratorResponse) GetInstanceId() string

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                  *wrappers.StringValue  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version               *wrappers.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() *wrappers.StringValue

func (*ParentInstanceInfo) GetOrchestrationInstance 

func (x *ParentInstanceInfo) GetOrchestrationInstance() *OrchestrationInstance

func (*ParentInstanceInfo) GetTaskScheduledId 

func (x *ParentInstanceInfo) GetTaskScheduledId() int32

func (*ParentInstanceInfo) GetVersion 

func (x *ParentInstanceInfo) GetVersion() *wrappers.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 *timestamp.Timestamp  `protobuf:"bytes,1,opt,name=createdTimeFrom,proto3" json:"createdTimeFrom,omitempty"`
	CreatedTimeTo   *timestamp.Timestamp  `protobuf:"bytes,2,opt,name=createdTimeTo,proto3" json:"createdTimeTo,omitempty"`
	RuntimeStatus   []OrchestrationStatus `protobuf:"varint,3,rep,packed,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeInstanceFilter) Descriptor deprecated 

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

Deprecated: Use PurgeInstanceFilter.ProtoReflect.Descriptor instead.

func (*PurgeInstanceFilter) GetCreatedTimeFrom 

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

func (*PurgeInstanceFilter) GetCreatedTimeTo 

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

func (*PurgeInstanceFilter) GetRuntimeStatus 

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

func (*PurgeInstanceFilter) ProtoMessage 

func (*PurgeInstanceFilter) ProtoMessage()

func (*PurgeInstanceFilter) ProtoReflect 

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

func (*PurgeInstanceFilter) Reset 

func (x *PurgeInstanceFilter) Reset()

func (*PurgeInstanceFilter) String 

func (x *PurgeInstanceFilter) String() string

type PurgeInstancesRequest 

type PurgeInstancesRequest struct {

	// Types that are assignable to Request:
	//
	//	*PurgeInstancesRequest_InstanceId
	//	*PurgeInstancesRequest_PurgeInstanceFilter
	Request   isPurgeInstancesRequest_Request `protobuf_oneof:"request"`
	Recursive bool                            `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeInstancesRequest) Descriptor deprecated 

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

Deprecated: Use PurgeInstancesRequest.ProtoReflect.Descriptor instead.

func (*PurgeInstancesRequest) GetInstanceId 

func (x *PurgeInstancesRequest) GetInstanceId() string

func (*PurgeInstancesRequest) GetPurgeInstanceFilter 

func (x *PurgeInstancesRequest) GetPurgeInstanceFilter() *PurgeInstanceFilter

func (*PurgeInstancesRequest) GetRecursive 

func (x *PurgeInstancesRequest) GetRecursive() bool

func (*PurgeInstancesRequest) GetRequest 

func (m *PurgeInstancesRequest) GetRequest() isPurgeInstancesRequest_Request

func (*PurgeInstancesRequest) ProtoMessage 

func (*PurgeInstancesRequest) ProtoMessage()

func (*PurgeInstancesRequest) ProtoReflect 

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

func (*PurgeInstancesRequest) Reset 

func (x *PurgeInstancesRequest) Reset()

func (*PurgeInstancesRequest) String 

func (x *PurgeInstancesRequest) String() string

type PurgeInstancesRequest_InstanceId 

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

type PurgeInstancesRequest_PurgeInstanceFilter 

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

type PurgeInstancesResponse 

type PurgeInstancesResponse struct {
	DeletedInstanceCount int32 `protobuf:"varint,1,opt,name=deletedInstanceCount,proto3" json:"deletedInstanceCount,omitempty"`
	// 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) 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 

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

func (*QueryEntitiesRequest) Descriptor deprecated 

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

Deprecated: Use QueryEntitiesRequest.ProtoReflect.Descriptor instead.

func (*QueryEntitiesRequest) GetQuery 

func (x *QueryEntitiesRequest) GetQuery() *EntityQuery

func (*QueryEntitiesRequest) ProtoMessage 

func (*QueryEntitiesRequest) ProtoMessage()

func (*QueryEntitiesRequest) ProtoReflect 

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

func (*QueryEntitiesRequest) Reset 

func (x *QueryEntitiesRequest) Reset()

func (*QueryEntitiesRequest) String 

func (x *QueryEntitiesRequest) String() string

type QueryEntitiesResponse 

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

func (*QueryEntitiesResponse) Descriptor deprecated 

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

Deprecated: Use QueryEntitiesResponse.ProtoReflect.Descriptor instead.

func (*QueryEntitiesResponse) GetContinuationToken 

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

func (*QueryEntitiesResponse) GetEntities 

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

func (*QueryEntitiesResponse) ProtoMessage 

func (*QueryEntitiesResponse) ProtoMessage()

func (*QueryEntitiesResponse) ProtoReflect 

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

func (*QueryEntitiesResponse) Reset 

func (x *QueryEntitiesResponse) Reset()

func (*QueryEntitiesResponse) String 

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  *wrappers.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() *wrappers.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      *wrappers.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() *wrappers.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 ResumeRequest 

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

func (*ResumeRequest) Descriptor deprecated 

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

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetInstanceId 

func (x *ResumeRequest) GetInstanceId() string

func (*ResumeRequest) GetReason 

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

func (*ResumeRequest) ProtoMessage 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect 

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

func (*ResumeRequest) Reset 

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String 

func (x *ResumeRequest) String() string

type ResumeResponse 

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

func (*ResumeResponse) Descriptor deprecated 

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

Deprecated: Use ResumeResponse.ProtoReflect.Descriptor instead.

func (*ResumeResponse) ProtoMessage 

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) ProtoReflect 

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

func (*ResumeResponse) Reset 

func (x *ResumeResponse) Reset()

func (*ResumeResponse) String 

func (x *ResumeResponse) String() string

type RewindInstanceRequest 

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

func (*RewindInstanceRequest) Descriptor deprecated 

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

Deprecated: Use RewindInstanceRequest.ProtoReflect.Descriptor instead.

func (*RewindInstanceRequest) GetInstanceId 

func (x *RewindInstanceRequest) GetInstanceId() string

func (*RewindInstanceRequest) GetReason 

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

func (*RewindInstanceRequest) ProtoMessage 

func (*RewindInstanceRequest) ProtoMessage()

func (*RewindInstanceRequest) ProtoReflect 

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

func (*RewindInstanceRequest) Reset 

func (x *RewindInstanceRequest) Reset()

func (*RewindInstanceRequest) String 

func (x *RewindInstanceRequest) String() string

type RewindInstanceResponse 

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

func (*RewindInstanceResponse) Descriptor deprecated 

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

Deprecated: Use RewindInstanceResponse.ProtoReflect.Descriptor instead.

func (*RewindInstanceResponse) ProtoMessage 

func (*RewindInstanceResponse) ProtoMessage()

func (*RewindInstanceResponse) ProtoReflect 

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

func (*RewindInstanceResponse) Reset 

func (x *RewindInstanceResponse) Reset()

func (*RewindInstanceResponse) String 

func (x *RewindInstanceResponse) String() string

type ScheduleTaskAction 

type ScheduleTaskAction struct {
	Name    string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version *wrappers.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input   *wrappers.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,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() *wrappers.StringValue

func (*ScheduleTaskAction) GetName 

func (x *ScheduleTaskAction) GetName() string

func (*ScheduleTaskAction) GetVersion 

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

func (*ScheduleTaskAction) ProtoMessage 

func (*ScheduleTaskAction) ProtoMessage()

func (*ScheduleTaskAction) ProtoReflect 

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

func (*ScheduleTaskAction) Reset 

func (x *ScheduleTaskAction) Reset()

func (*ScheduleTaskAction) String 

func (x *ScheduleTaskAction) String() string

type SendEventAction 

type SendEventAction struct {
	Instance *OrchestrationInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	Name     string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Data     *wrappers.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() *wrappers.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 

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         *wrappers.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledTime *timestamp.Timestamp  `protobuf:"bytes,4,opt,name=scheduledTime,proto3" json:"scheduledTime,omitempty"`
	// contains filtered or unexported fields
}

func (*SendSignalAction) Descriptor deprecated 

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

Deprecated: Use SendSignalAction.ProtoReflect.Descriptor instead.

func (*SendSignalAction) GetInput 

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

func (*SendSignalAction) GetInstanceId 

func (x *SendSignalAction) GetInstanceId() string

func (*SendSignalAction) GetName 

func (x *SendSignalAction) GetName() string

func (*SendSignalAction) GetScheduledTime 

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

func (*SendSignalAction) ProtoMessage 

func (*SendSignalAction) ProtoMessage()

func (*SendSignalAction) ProtoReflect 

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

func (*SendSignalAction) Reset 

func (x *SendSignalAction) Reset()

func (*SendSignalAction) String 

func (x *SendSignalAction) String() string

type SignalEntityRequest 

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         *wrappers.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	RequestId     string                `protobuf:"bytes,4,opt,name=requestId,proto3" json:"requestId,omitempty"`
	ScheduledTime *timestamp.Timestamp  `protobuf:"bytes,5,opt,name=scheduledTime,proto3" json:"scheduledTime,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalEntityRequest) Descriptor deprecated 

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

Deprecated: Use SignalEntityRequest.ProtoReflect.Descriptor instead.

func (*SignalEntityRequest) GetInput 

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

func (*SignalEntityRequest) GetInstanceId 

func (x *SignalEntityRequest) GetInstanceId() string

func (*SignalEntityRequest) GetName 

func (x *SignalEntityRequest) GetName() string

func (*SignalEntityRequest) GetRequestId 

func (x *SignalEntityRequest) GetRequestId() string

func (*SignalEntityRequest) GetScheduledTime 

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

func (*SignalEntityRequest) ProtoMessage 

func (*SignalEntityRequest) ProtoMessage()

func (*SignalEntityRequest) ProtoReflect 

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

func (*SignalEntityRequest) Reset 

func (x *SignalEntityRequest) Reset()

func (*SignalEntityRequest) String 

func (x *SignalEntityRequest) String() string

type SignalEntityResponse 

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

func (*SignalEntityResponse) Descriptor deprecated 

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

Deprecated: Use SignalEntityResponse.ProtoReflect.Descriptor instead.

func (*SignalEntityResponse) ProtoMessage 

func (*SignalEntityResponse) ProtoMessage()

func (*SignalEntityResponse) ProtoReflect 

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

func (*SignalEntityResponse) Reset 

func (x *SignalEntityResponse) Reset()

func (*SignalEntityResponse) String 

func (x *SignalEntityResponse) String() string

type StartNewOrchestrationAction 

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       *wrappers.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input         *wrappers.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledTime *timestamp.Timestamp  `protobuf:"bytes,5,opt,name=scheduledTime,proto3" json:"scheduledTime,omitempty"`
	// contains filtered or unexported fields
}

func (*StartNewOrchestrationAction) Descriptor deprecated 

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

Deprecated: Use StartNewOrchestrationAction.ProtoReflect.Descriptor instead.

func (*StartNewOrchestrationAction) GetInput 

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

func (*StartNewOrchestrationAction) GetInstanceId 

func (x *StartNewOrchestrationAction) GetInstanceId() string

func (*StartNewOrchestrationAction) GetName 

func (x *StartNewOrchestrationAction) GetName() string

func (*StartNewOrchestrationAction) GetScheduledTime 

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

func (*StartNewOrchestrationAction) GetVersion 

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

func (*StartNewOrchestrationAction) ProtoMessage 

func (*StartNewOrchestrationAction) ProtoMessage()

func (*StartNewOrchestrationAction) ProtoReflect 

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

func (*StartNewOrchestrationAction) Reset 

func (x *StartNewOrchestrationAction) Reset()

func (*StartNewOrchestrationAction) String 

func (x *StartNewOrchestrationAction) String() string

type SubOrchestrationInstanceCompletedEvent 

type SubOrchestrationInstanceCompletedEvent struct {
	TaskScheduledId int32                 `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	Result          *wrappers.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() *wrappers.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            *wrappers.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrappers.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ParentTraceContext *TraceContext         `protobuf:"bytes,5,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	// 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() *wrappers.StringValue

func (*SubOrchestrationInstanceCreatedEvent) GetInstanceId 

func (x *SubOrchestrationInstanceCreatedEvent) GetInstanceId() string

func (*SubOrchestrationInstanceCreatedEvent) GetName 

func (x *SubOrchestrationInstanceCreatedEvent) GetName() string

func (*SubOrchestrationInstanceCreatedEvent) GetParentTraceContext 

func (x *SubOrchestrationInstanceCreatedEvent) GetParentTraceContext() *TraceContext

func (*SubOrchestrationInstanceCreatedEvent) GetVersion 

func (x *SubOrchestrationInstanceCreatedEvent) GetVersion() *wrappers.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 

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

func (*SuspendRequest) Descriptor deprecated 

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

Deprecated: Use SuspendRequest.ProtoReflect.Descriptor instead.

func (*SuspendRequest) GetInstanceId 

func (x *SuspendRequest) GetInstanceId() string

func (*SuspendRequest) GetReason 

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

func (*SuspendRequest) ProtoMessage 

func (*SuspendRequest) ProtoMessage()

func (*SuspendRequest) ProtoReflect 

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

func (*SuspendRequest) Reset 

func (x *SuspendRequest) Reset()

func (*SuspendRequest) String 

func (x *SuspendRequest) String() string

type SuspendResponse 

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

func (*SuspendResponse) Descriptor deprecated 

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

Deprecated: Use SuspendResponse.ProtoReflect.Descriptor instead.

func (*SuspendResponse) ProtoMessage 

func (*SuspendResponse) ProtoMessage()

func (*SuspendResponse) ProtoReflect 

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

func (*SuspendResponse) Reset 

func (x *SuspendResponse) Reset()

func (*SuspendResponse) String 

func (x *SuspendResponse) String() string

type TaskCompletedEvent 

type TaskCompletedEvent struct {
	TaskScheduledId int32                 `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	Result          *wrappers.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() *wrappers.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     *wrappers.StringValue `protobuf:"bytes,3,opt,name=stackTrace,proto3" json:"stackTrace,omitempty"`
	InnerFailure   *TaskFailureDetails   `protobuf:"bytes,4,opt,name=innerFailure,proto3" json:"innerFailure,omitempty"`
	IsNonRetriable bool                  `protobuf:"varint,5,opt,name=isNonRetriable,proto3" json:"isNonRetriable,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskFailureDetails) Descriptor deprecated 

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

Deprecated: Use TaskFailureDetails.ProtoReflect.Descriptor instead.

func (*TaskFailureDetails) GetErrorMessage 

func (x *TaskFailureDetails) GetErrorMessage() string

func (*TaskFailureDetails) GetErrorType 

func (x *TaskFailureDetails) GetErrorType() string

func (*TaskFailureDetails) GetInnerFailure 

func (x *TaskFailureDetails) GetInnerFailure() *TaskFailureDetails

func (*TaskFailureDetails) GetIsNonRetriable 

func (x *TaskFailureDetails) GetIsNonRetriable() bool

func (*TaskFailureDetails) GetStackTrace 

func (x *TaskFailureDetails) GetStackTrace() *wrappers.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 *empty.Empty, opts ...grpc.CallOption) (*empty.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)
	// 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)
	PurgeInstances(ctx context.Context, in *PurgeInstancesRequest, opts ...grpc.CallOption) (*PurgeInstancesResponse, error)
	GetWorkItems(ctx context.Context, in *GetWorkItemsRequest, opts ...grpc.CallOption) (TaskHubSidecarService_GetWorkItemsClient, error)
	CompleteActivityTask(ctx context.Context, in *ActivityResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	CompleteOrchestratorTask(ctx context.Context, in *OrchestratorResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	CompleteEntityTask(ctx context.Context, in *EntityBatchResult, opts ...grpc.CallOption) (*CompleteTaskResponse, 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)
}

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, *empty.Empty) (*empty.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)
	// 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)
	PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)
	GetWorkItems(*GetWorkItemsRequest, TaskHubSidecarService_GetWorkItemsServer) error
	CompleteActivityTask(context.Context, *ActivityResponse) (*CompleteTaskResponse, error)
	CompleteOrchestratorTask(context.Context, *OrchestratorResponse) (*CompleteTaskResponse, error)
	CompleteEntityTask(context.Context, *EntityBatchResult) (*CompleteTaskResponse, 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)
	// contains filtered or unexported methods
}

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

type TaskHubSidecarService_GetWorkItemsClient 

type TaskHubSidecarService_GetWorkItemsClient interface {
	Recv() (*WorkItem, error)
	grpc.ClientStream
}

type TaskHubSidecarService_GetWorkItemsServer 

type TaskHubSidecarService_GetWorkItemsServer interface {
	Send(*WorkItem) error
	grpc.ServerStream
}

type TaskScheduledEvent 

type TaskScheduledEvent struct {
	Name               string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version            *wrappers.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrappers.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	ParentTraceContext *TraceContext         `protobuf:"bytes,4,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	// 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() *wrappers.StringValue

func (*TaskScheduledEvent) GetName 

func (x *TaskScheduledEvent) GetName() string

func (*TaskScheduledEvent) GetParentTraceContext 

func (x *TaskScheduledEvent) GetParentTraceContext() *TraceContext

func (*TaskScheduledEvent) GetVersion 

func (x *TaskScheduledEvent) GetVersion() *wrappers.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 

type TerminateOrchestrationAction struct {
	InstanceId string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Reason     *wrappers.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 

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

Deprecated: Use TerminateOrchestrationAction.ProtoReflect.Descriptor instead.

func (*TerminateOrchestrationAction) GetInstanceId 

func (x *TerminateOrchestrationAction) GetInstanceId() string

func (*TerminateOrchestrationAction) GetReason 

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

func (*TerminateOrchestrationAction) GetRecurse 

func (x *TerminateOrchestrationAction) GetRecurse() bool

func (*TerminateOrchestrationAction) ProtoMessage 

func (*TerminateOrchestrationAction) ProtoMessage()

func (*TerminateOrchestrationAction) ProtoReflect 

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

func (*TerminateOrchestrationAction) Reset 

func (x *TerminateOrchestrationAction) Reset()

func (*TerminateOrchestrationAction) String 

func (x *TerminateOrchestrationAction) String() string

type TerminateRequest 

type TerminateRequest struct {
	InstanceId string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Output     *wrappers.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() *wrappers.StringValue

func (*TerminateRequest) GetRecursive 

func (x *TerminateRequest) GetRecursive() bool

func (*TerminateRequest) ProtoMessage 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) ProtoReflect 

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

func (*TerminateRequest) Reset 

func (x *TerminateRequest) Reset()

func (*TerminateRequest) String 

func (x *TerminateRequest) String() string

type TerminateResponse 

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

func (*TerminateResponse) Descriptor deprecated 

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

Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.

func (*TerminateResponse) ProtoMessage 

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) ProtoReflect 

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

func (*TerminateResponse) Reset 

func (x *TerminateResponse) Reset()

func (*TerminateResponse) String 

func (x *TerminateResponse) String() string

type TimerCreatedEvent 

type TimerCreatedEvent struct {
	FireAt *timestamp.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() *timestamp.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  *timestamp.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() *timestamp.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 

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 *wrappers.StringValue `protobuf:"bytes,3,opt,name=traceState,proto3" json:"traceState,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceContext) Descriptor deprecated 

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

Deprecated: Use TraceContext.ProtoReflect.Descriptor instead.

func (*TraceContext) GetSpanID deprecated 

func (x *TraceContext) GetSpanID() string

Deprecated: Marked as deprecated in orchestrator_service.proto.

func (*TraceContext) GetTraceParent 

func (x *TraceContext) GetTraceParent() string

func (*TraceContext) GetTraceState 

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

func (*TraceContext) ProtoMessage 

func (*TraceContext) ProtoMessage()

func (*TraceContext) ProtoReflect 

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

func (*TraceContext) Reset 

func (x *TraceContext) Reset()

func (*TraceContext) String 

func (x *TraceContext) String() string

type UnimplementedTaskHubSidecarServiceServer 

type UnimplementedTaskHubSidecarServiceServer struct {
}

UnimplementedTaskHubSidecarServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskHubSidecarServiceServer) CleanEntityStorage 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteEntityTask 

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 

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, TaskHubSidecarService_GetWorkItemsServer) error

func (UnimplementedTaskHubSidecarServiceServer) Hello 

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

func (UnimplementedTaskHubSidecarServiceServer) PurgeInstances 

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

func (UnimplementedTaskHubSidecarServiceServer) QueryEntities 

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

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

func (UnimplementedTaskHubSidecarServiceServer) RewindInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) SignalEntity 

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

func (UnimplementedTaskHubSidecarServiceServer) StartInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) SuspendInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) TerminateInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceCompletion 

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

func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceStart 

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

type UnsafeTaskHubSidecarServiceServer 

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

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

type WorkItem 

type WorkItem struct {

	// Types that are assignable to Request:
	//
	//	*WorkItem_OrchestratorRequest
	//	*WorkItem_ActivityRequest
	//	*WorkItem_EntityRequest
	Request isWorkItem_Request `protobuf_oneof:"request"`
	// 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) GetEntityRequest 

func (x *WorkItem) GetEntityRequest() *EntityBatchRequest

func (*WorkItem) GetOrchestratorRequest 

func (x *WorkItem) GetOrchestratorRequest() *OrchestratorRequest

func (*WorkItem) GetRequest 

func (m *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 WorkItem_ActivityRequest 

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

type WorkItem_EntityRequest 

type WorkItem_EntityRequest struct {
	EntityRequest *EntityBatchRequest `protobuf:"bytes,3,opt,name=entityRequest,proto3,oneof"`
}

type WorkItem_OrchestratorRequest 

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

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.