protos

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jun 28, 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 added in v0.3.2 

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 added in v0.3.2 

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

Deprecated: Use CleanEntityStorageRequest.ProtoReflect.Descriptor instead.

func (*CleanEntityStorageRequest) GetContinuationToken added in v0.3.2 

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

func (*CleanEntityStorageRequest) GetReleaseOrphanedLocks added in v0.3.2 

func (x *CleanEntityStorageRequest) GetReleaseOrphanedLocks() bool

func (*CleanEntityStorageRequest) GetRemoveEmptyEntities added in v0.3.2 

func (x *CleanEntityStorageRequest) GetRemoveEmptyEntities() bool

func (*CleanEntityStorageRequest) ProtoMessage added in v0.3.2 

func (*CleanEntityStorageRequest) ProtoMessage()

func (*CleanEntityStorageRequest) ProtoReflect added in v0.3.2 

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

func (*CleanEntityStorageRequest) Reset added in v0.3.2 

func (x *CleanEntityStorageRequest) Reset()

func (*CleanEntityStorageRequest) String added in v0.3.2 

func (x *CleanEntityStorageRequest) String() string

type CleanEntityStorageResponse added in v0.3.2 

type CleanEntityStorageResponse struct {
	ContinuationToken     *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 added in v0.3.2 

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

Deprecated: Use CleanEntityStorageResponse.ProtoReflect.Descriptor instead.

func (*CleanEntityStorageResponse) GetContinuationToken added in v0.3.2 

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

func (*CleanEntityStorageResponse) GetEmptyEntitiesRemoved added in v0.3.2 

func (x *CleanEntityStorageResponse) GetEmptyEntitiesRemoved() int32

func (*CleanEntityStorageResponse) GetOrphanedLocksReleased added in v0.3.2 

func (x *CleanEntityStorageResponse) GetOrphanedLocksReleased() int32

func (*CleanEntityStorageResponse) ProtoMessage added in v0.3.2 

func (*CleanEntityStorageResponse) ProtoMessage()

func (*CleanEntityStorageResponse) ProtoReflect added in v0.3.2 

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

func (*CleanEntityStorageResponse) Reset added in v0.3.2 

func (x *CleanEntityStorageResponse) Reset()

func (*CleanEntityStorageResponse) String added in v0.3.2 

func (x *CleanEntityStorageResponse) String() string

type CompleteOrchestrationAction 

type CompleteOrchestrationAction struct {
	OrchestrationStatus OrchestrationStatus   `protobuf:"varint,1,opt,name=orchestrationStatus,proto3,enum=OrchestrationStatus" json:"orchestrationStatus,omitempty"`
	Result              *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 added in v0.3.2 

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 added in v0.3.2 

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

func (CreateOrchestrationAction) Descriptor added in v0.3.2 

func (CreateOrchestrationAction) Descriptor() protoreflect.EnumDescriptor

func (CreateOrchestrationAction) Enum added in v0.3.2 

func (x CreateOrchestrationAction) Enum() *CreateOrchestrationAction

func (CreateOrchestrationAction) EnumDescriptor deprecated added in v0.3.2 

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

Deprecated: Use CreateOrchestrationAction.Descriptor instead.

func (CreateOrchestrationAction) Number added in v0.3.2 

func (x CreateOrchestrationAction) Number() protoreflect.EnumNumber

func (CreateOrchestrationAction) String added in v0.3.2 

func (x CreateOrchestrationAction) String() string

func (CreateOrchestrationAction) Type added in v0.3.2 

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 added in v0.3.2 

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 added in v0.3.2 

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

Deprecated: Use EntityBatchRequest.ProtoReflect.Descriptor instead.

func (*EntityBatchRequest) GetEntityState added in v0.3.2 

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

func (*EntityBatchRequest) GetInstanceId added in v0.3.2 

func (x *EntityBatchRequest) GetInstanceId() string

func (*EntityBatchRequest) GetOperations added in v0.3.2 

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

func (*EntityBatchRequest) ProtoMessage added in v0.3.2 

func (*EntityBatchRequest) ProtoMessage()

func (*EntityBatchRequest) ProtoReflect added in v0.3.2 

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

func (*EntityBatchRequest) Reset added in v0.3.2 

func (x *EntityBatchRequest) Reset()

func (*EntityBatchRequest) String added in v0.3.2 

func (x *EntityBatchRequest) String() string

type EntityBatchResult added in v0.3.2 

type EntityBatchResult struct {
	Results        []*OperationResult    `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	Actions        []*OperationAction    `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	EntityState    *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 added in v0.3.2 

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

Deprecated: Use EntityBatchResult.ProtoReflect.Descriptor instead.

func (*EntityBatchResult) GetActions added in v0.3.2 

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

func (*EntityBatchResult) GetEntityState added in v0.3.2 

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

func (*EntityBatchResult) GetFailureDetails added in v0.3.2 

func (x *EntityBatchResult) GetFailureDetails() *TaskFailureDetails

func (*EntityBatchResult) GetResults added in v0.3.2 

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

func (*EntityBatchResult) ProtoMessage added in v0.3.2 

func (*EntityBatchResult) ProtoMessage()

func (*EntityBatchResult) ProtoReflect added in v0.3.2 

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

func (*EntityBatchResult) Reset added in v0.3.2 

func (x *EntityBatchResult) Reset()

func (*EntityBatchResult) String added in v0.3.2 

func (x *EntityBatchResult) String() string

type EntityMetadata added in v0.3.2 

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 added in v0.3.2 

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

Deprecated: Use EntityMetadata.ProtoReflect.Descriptor instead.

func (*EntityMetadata) GetBacklogQueueSize added in v0.3.2 

func (x *EntityMetadata) GetBacklogQueueSize() int32

func (*EntityMetadata) GetInstanceId added in v0.3.2 

func (x *EntityMetadata) GetInstanceId() string

func (*EntityMetadata) GetLastModifiedTime added in v0.3.2 

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

func (*EntityMetadata) GetLockedBy added in v0.3.2 

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

func (*EntityMetadata) GetSerializedState added in v0.3.2 

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

func (*EntityMetadata) ProtoMessage added in v0.3.2 

func (*EntityMetadata) ProtoMessage()

func (*EntityMetadata) ProtoReflect added in v0.3.2 

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

func (*EntityMetadata) Reset added in v0.3.2 

func (x *EntityMetadata) Reset()

func (*EntityMetadata) String added in v0.3.2 

func (x *EntityMetadata) String() string

type EntityQuery added in v0.3.2 

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 added in v0.3.2 

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

Deprecated: Use EntityQuery.ProtoReflect.Descriptor instead.

func (*EntityQuery) GetContinuationToken added in v0.3.2 

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

func (*EntityQuery) GetIncludeState added in v0.3.2 

func (x *EntityQuery) GetIncludeState() bool

func (*EntityQuery) GetIncludeTransient added in v0.3.2 

func (x *EntityQuery) GetIncludeTransient() bool

func (*EntityQuery) GetInstanceIdStartsWith added in v0.3.2 

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

func (*EntityQuery) GetLastModifiedFrom added in v0.3.2 

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

func (*EntityQuery) GetLastModifiedTo added in v0.3.2 

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

func (*EntityQuery) GetPageSize added in v0.3.2 

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

func (*EntityQuery) ProtoMessage added in v0.3.2 

func (*EntityQuery) ProtoMessage()

func (*EntityQuery) ProtoReflect added in v0.3.2 

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

func (*EntityQuery) Reset added in v0.3.2 

func (x *EntityQuery) Reset()

func (*EntityQuery) String added in v0.3.2 

func (x *EntityQuery) String() string

type 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 added in v0.1.1 

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 added in v0.1.1 

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

Deprecated: Use ExecutionResumedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionResumedEvent) GetInput added in v0.1.1 

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

func (*ExecutionResumedEvent) ProtoMessage added in v0.1.1 

func (*ExecutionResumedEvent) ProtoMessage()

func (*ExecutionResumedEvent) ProtoReflect added in v0.1.1 

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

func (*ExecutionResumedEvent) Reset added in v0.1.1 

func (x *ExecutionResumedEvent) Reset()

func (*ExecutionResumedEvent) String added in v0.1.1 

func (x *ExecutionResumedEvent) String() string

type 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 added in v0.1.1 

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

func (*ExecutionStartedEvent) GetParentInstance 

func (x *ExecutionStartedEvent) GetParentInstance() *ParentInstanceInfo

func (*ExecutionStartedEvent) GetParentTraceContext added in v0.1.1 

func (x *ExecutionStartedEvent) GetParentTraceContext() *TraceContext

func (*ExecutionStartedEvent) GetScheduledStartTimestamp 

func (x *ExecutionStartedEvent) GetScheduledStartTimestamp() *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 added in v0.1.1 

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 added in v0.1.1 

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

Deprecated: Use ExecutionSuspendedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionSuspendedEvent) GetInput added in v0.1.1 

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

func (*ExecutionSuspendedEvent) ProtoMessage added in v0.1.1 

func (*ExecutionSuspendedEvent) ProtoMessage()

func (*ExecutionSuspendedEvent) ProtoReflect added in v0.1.1 

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

func (*ExecutionSuspendedEvent) Reset added in v0.1.1 

func (x *ExecutionSuspendedEvent) Reset()

func (*ExecutionSuspendedEvent) String added in v0.1.1 

func (x *ExecutionSuspendedEvent) String() string

type ExecutionTerminatedEvent 

type ExecutionTerminatedEvent struct {
	Input   *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 added in v0.3.0 

func (x *ExecutionTerminatedEvent) GetRecurse() bool

func (*ExecutionTerminatedEvent) ProtoMessage 

func (*ExecutionTerminatedEvent) ProtoMessage()

func (*ExecutionTerminatedEvent) ProtoReflect 

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

func (*ExecutionTerminatedEvent) Reset 

func (x *ExecutionTerminatedEvent) Reset()

func (*ExecutionTerminatedEvent) String 

func (x *ExecutionTerminatedEvent) String() string

type GenericEvent 

type GenericEvent struct {
	Data *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 added in v0.3.2 

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

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

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

Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.

func (*GetEntityRequest) GetIncludeState added in v0.3.2 

func (x *GetEntityRequest) GetIncludeState() bool

func (*GetEntityRequest) GetInstanceId added in v0.3.2 

func (x *GetEntityRequest) GetInstanceId() string

func (*GetEntityRequest) ProtoMessage added in v0.3.2 

func (*GetEntityRequest) ProtoMessage()

func (*GetEntityRequest) ProtoReflect added in v0.3.2 

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

func (*GetEntityRequest) Reset added in v0.3.2 

func (x *GetEntityRequest) Reset()

func (*GetEntityRequest) String added in v0.3.2 

func (x *GetEntityRequest) String() string

type GetEntityResponse added in v0.3.2 

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

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

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

Deprecated: Use GetEntityResponse.ProtoReflect.Descriptor instead.

func (*GetEntityResponse) GetEntity added in v0.3.2 

func (x *GetEntityResponse) GetEntity() *EntityMetadata

func (*GetEntityResponse) GetExists added in v0.3.2 

func (x *GetEntityResponse) GetExists() bool

func (*GetEntityResponse) ProtoMessage added in v0.3.2 

func (*GetEntityResponse) ProtoMessage()

func (*GetEntityResponse) ProtoReflect added in v0.3.2 

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

func (*GetEntityResponse) Reset added in v0.3.2 

func (x *GetEntityResponse) Reset()

func (*GetEntityResponse) String added in v0.3.2 

func (x *GetEntityResponse) String() string

type GetInstanceRequest 

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

func (*GetInstanceRequest) Descriptor deprecated 

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

Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceRequest) GetGetInputsAndOutputs 

func (x *GetInstanceRequest) GetGetInputsAndOutputs() bool

func (*GetInstanceRequest) GetInstanceId 

func (x *GetInstanceRequest) GetInstanceId() string

func (*GetInstanceRequest) ProtoMessage 

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) ProtoReflect 

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

func (*GetInstanceRequest) Reset 

func (x *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String 

func (x *GetInstanceRequest) String() string

type GetInstanceResponse 

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

func (*GetInstanceResponse) Descriptor deprecated 

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

Deprecated: Use GetInstanceResponse.ProtoReflect.Descriptor instead.

func (*GetInstanceResponse) GetExists 

func (x *GetInstanceResponse) GetExists() bool

func (*GetInstanceResponse) GetOrchestrationState 

func (x *GetInstanceResponse) GetOrchestrationState() *OrchestrationState

func (*GetInstanceResponse) ProtoMessage 

func (*GetInstanceResponse) ProtoMessage()

func (*GetInstanceResponse) ProtoReflect 

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

func (*GetInstanceResponse) Reset 

func (x *GetInstanceResponse) Reset()

func (*GetInstanceResponse) String 

func (x *GetInstanceResponse) String() string

type GetWorkItemsRequest 

type GetWorkItemsRequest struct {
	// 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 added in v0.1.1 

func (x *HistoryEvent) GetExecutionResumed() *ExecutionResumedEvent

func (*HistoryEvent) GetExecutionStarted 

func (x *HistoryEvent) GetExecutionStarted() *ExecutionStartedEvent

func (*HistoryEvent) GetExecutionSuspended added in v0.1.1 

func (x *HistoryEvent) GetExecutionSuspended() *ExecutionSuspendedEvent

func (*HistoryEvent) GetExecutionTerminated 

func (x *HistoryEvent) GetExecutionTerminated() *ExecutionTerminatedEvent

func (*HistoryEvent) GetGenericEvent 

func (x *HistoryEvent) GetGenericEvent() *GenericEvent

func (*HistoryEvent) GetHistoryState 

func (x *HistoryEvent) GetHistoryState() *HistoryStateEvent

func (*HistoryEvent) GetOrchestratorCompleted 

func (x *HistoryEvent) GetOrchestratorCompleted() *OrchestratorCompletedEvent

func (*HistoryEvent) GetOrchestratorStarted 

func (x *HistoryEvent) GetOrchestratorStarted() *OrchestratorStartedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceCompleted 

func (x *HistoryEvent) GetSubOrchestrationInstanceCompleted() *SubOrchestrationInstanceCompletedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceCreated 

func (x *HistoryEvent) GetSubOrchestrationInstanceCreated() *SubOrchestrationInstanceCreatedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceFailed 

func (x *HistoryEvent) GetSubOrchestrationInstanceFailed() *SubOrchestrationInstanceFailedEvent

func (*HistoryEvent) GetTaskCompleted 

func (x *HistoryEvent) GetTaskCompleted() *TaskCompletedEvent

func (*HistoryEvent) GetTaskFailed 

func (x *HistoryEvent) GetTaskFailed() *TaskFailedEvent

func (*HistoryEvent) GetTaskScheduled 

func (x *HistoryEvent) GetTaskScheduled() *TaskScheduledEvent

func (*HistoryEvent) GetTimerCreated 

func (x *HistoryEvent) GetTimerCreated() *TimerCreatedEvent

func (*HistoryEvent) GetTimerFired 

func (x *HistoryEvent) GetTimerFired() *TimerFiredEvent

func (*HistoryEvent) GetTimestamp 

func (x *HistoryEvent) GetTimestamp() *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 added in v0.1.1 

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 added in v0.1.1 

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

type HistoryEvent_ExecutionTerminated 

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

type HistoryEvent_GenericEvent 

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

type HistoryEvent_HistoryState 

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

type HistoryEvent_OrchestratorCompleted 

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

type HistoryEvent_OrchestratorStarted 

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

type HistoryEvent_SubOrchestrationInstanceCompleted 

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

type HistoryEvent_SubOrchestrationInstanceCreated 

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

type HistoryEvent_SubOrchestrationInstanceFailed 

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

type HistoryEvent_TaskCompleted 

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

type HistoryEvent_TaskFailed 

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

type HistoryEvent_TaskScheduled 

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

type HistoryEvent_TimerCreated 

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

type HistoryEvent_TimerFired 

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

type HistoryStateEvent 

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

func (*HistoryStateEvent) Descriptor deprecated 

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

Deprecated: Use HistoryStateEvent.ProtoReflect.Descriptor instead.

func (*HistoryStateEvent) GetOrchestrationState 

func (x *HistoryStateEvent) GetOrchestrationState() *OrchestrationState

func (*HistoryStateEvent) ProtoMessage 

func (*HistoryStateEvent) ProtoMessage()

func (*HistoryStateEvent) ProtoReflect 

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

func (*HistoryStateEvent) Reset 

func (x *HistoryStateEvent) Reset()

func (*HistoryStateEvent) String 

func (x *HistoryStateEvent) String() string

type 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 added in v0.3.2 

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 added in v0.3.2 

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

Deprecated: Use OperationAction.ProtoReflect.Descriptor instead.

func (*OperationAction) GetId added in v0.3.2 

func (x *OperationAction) GetId() int32

func (*OperationAction) GetOperationActionType added in v0.3.2 

func (m *OperationAction) GetOperationActionType() isOperationAction_OperationActionType

func (*OperationAction) GetSendSignal added in v0.3.2 

func (x *OperationAction) GetSendSignal() *SendSignalAction

func (*OperationAction) GetStartNewOrchestration added in v0.3.2 

func (x *OperationAction) GetStartNewOrchestration() *StartNewOrchestrationAction

func (*OperationAction) ProtoMessage added in v0.3.2 

func (*OperationAction) ProtoMessage()

func (*OperationAction) ProtoReflect added in v0.3.2 

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

func (*OperationAction) Reset added in v0.3.2 

func (x *OperationAction) Reset()

func (*OperationAction) String added in v0.3.2 

func (x *OperationAction) String() string

type OperationAction_SendSignal added in v0.3.2 

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

type OperationAction_StartNewOrchestration added in v0.3.2 

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

type OperationRequest added in v0.3.2 

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

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

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

Deprecated: Use OperationRequest.ProtoReflect.Descriptor instead.

func (*OperationRequest) GetInput added in v0.3.2 

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

func (*OperationRequest) GetOperation added in v0.3.2 

func (x *OperationRequest) GetOperation() string

func (*OperationRequest) GetRequestId added in v0.3.2 

func (x *OperationRequest) GetRequestId() string

func (*OperationRequest) ProtoMessage added in v0.3.2 

func (*OperationRequest) ProtoMessage()

func (*OperationRequest) ProtoReflect added in v0.3.2 

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

func (*OperationRequest) Reset added in v0.3.2 

func (x *OperationRequest) Reset()

func (*OperationRequest) String added in v0.3.2 

func (x *OperationRequest) String() string

type OperationResult added in v0.3.2 

type OperationResult struct {

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

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

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

Deprecated: Use OperationResult.ProtoReflect.Descriptor instead.

func (*OperationResult) GetFailure added in v0.3.2 

func (x *OperationResult) GetFailure() *OperationResultFailure

func (*OperationResult) GetResultType added in v0.3.2 

func (m *OperationResult) GetResultType() isOperationResult_ResultType

func (*OperationResult) GetSuccess added in v0.3.2 

func (x *OperationResult) GetSuccess() *OperationResultSuccess

func (*OperationResult) ProtoMessage added in v0.3.2 

func (*OperationResult) ProtoMessage()

func (*OperationResult) ProtoReflect added in v0.3.2 

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

func (*OperationResult) Reset added in v0.3.2 

func (x *OperationResult) Reset()

func (*OperationResult) String added in v0.3.2 

func (x *OperationResult) String() string

type OperationResultFailure added in v0.3.2 

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

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

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

Deprecated: Use OperationResultFailure.ProtoReflect.Descriptor instead.

func (*OperationResultFailure) GetFailureDetails added in v0.3.2 

func (x *OperationResultFailure) GetFailureDetails() *TaskFailureDetails

func (*OperationResultFailure) ProtoMessage added in v0.3.2 

func (*OperationResultFailure) ProtoMessage()

func (*OperationResultFailure) ProtoReflect added in v0.3.2 

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

func (*OperationResultFailure) Reset added in v0.3.2 

func (x *OperationResultFailure) Reset()

func (*OperationResultFailure) String added in v0.3.2 

func (x *OperationResultFailure) String() string

type OperationResultSuccess added in v0.3.2 

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

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

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

Deprecated: Use OperationResultSuccess.ProtoReflect.Descriptor instead.

func (*OperationResultSuccess) GetResult added in v0.3.2 

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

func (*OperationResultSuccess) ProtoMessage added in v0.3.2 

func (*OperationResultSuccess) ProtoMessage()

func (*OperationResultSuccess) ProtoReflect added in v0.3.2 

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

func (*OperationResultSuccess) Reset added in v0.3.2 

func (x *OperationResultSuccess) Reset()

func (*OperationResultSuccess) String added in v0.3.2 

func (x *OperationResultSuccess) String() string

type OperationResult_Failure added in v0.3.2 

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

type OperationResult_Success added in v0.3.2 

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

type OrchestrationIdReusePolicy added in v0.3.2 

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 added in v0.3.2 

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

Deprecated: Use OrchestrationIdReusePolicy.ProtoReflect.Descriptor instead.

func (*OrchestrationIdReusePolicy) GetAction added in v0.3.2 

func (x *OrchestrationIdReusePolicy) GetAction() CreateOrchestrationAction

func (*OrchestrationIdReusePolicy) GetOperationStatus added in v0.3.2 

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

func (*OrchestrationIdReusePolicy) ProtoMessage added in v0.3.2 

func (*OrchestrationIdReusePolicy) ProtoMessage()

func (*OrchestrationIdReusePolicy) ProtoReflect added in v0.3.2 

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

func (*OrchestrationIdReusePolicy) Reset added in v0.3.2 

func (x *OrchestrationIdReusePolicy) Reset()

func (*OrchestrationIdReusePolicy) String added in v0.3.2 

func (x *OrchestrationIdReusePolicy) String() string

type OrchestrationInstance 

type OrchestrationInstance struct {
	InstanceId  string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId *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 added in v0.3.0 

func (x *OrchestratorAction) GetTerminateOrchestration() *TerminateOrchestrationAction

func (*OrchestratorAction) ProtoMessage 

func (*OrchestratorAction) ProtoMessage()

func (*OrchestratorAction) ProtoReflect 

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

func (*OrchestratorAction) Reset 

func (x *OrchestratorAction) Reset()

func (*OrchestratorAction) String 

func (x *OrchestratorAction) String() string

type OrchestratorAction_CompleteOrchestration 

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

type OrchestratorAction_CreateSubOrchestration 

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

type OrchestratorAction_CreateTimer 

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

type OrchestratorAction_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 added in v0.3.0 

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

type OrchestratorCompletedEvent 

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

func (*OrchestratorCompletedEvent) Descriptor deprecated 

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

Deprecated: Use OrchestratorCompletedEvent.ProtoReflect.Descriptor instead.

func (*OrchestratorCompletedEvent) ProtoMessage 

func (*OrchestratorCompletedEvent) ProtoMessage()

func (*OrchestratorCompletedEvent) ProtoReflect 

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

func (*OrchestratorCompletedEvent) Reset 

func (x *OrchestratorCompletedEvent) Reset()

func (*OrchestratorCompletedEvent) String 

func (x *OrchestratorCompletedEvent) String() string

type OrchestratorEntityParameters added in v0.3.2 

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

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

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

Deprecated: Use OrchestratorEntityParameters.ProtoReflect.Descriptor instead.

func (*OrchestratorEntityParameters) GetEntityMessageReorderWindow added in v0.3.2 

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

func (*OrchestratorEntityParameters) ProtoMessage added in v0.3.2 

func (*OrchestratorEntityParameters) ProtoMessage()

func (*OrchestratorEntityParameters) ProtoReflect added in v0.3.2 

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

func (*OrchestratorEntityParameters) Reset added in v0.3.2 

func (x *OrchestratorEntityParameters) Reset()

func (*OrchestratorEntityParameters) String added in v0.3.2 

func (x *OrchestratorEntityParameters) String() string

type OrchestratorRequest 

type OrchestratorRequest struct {
	InstanceId       string                        `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId      *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 added in v0.3.2 

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 added in v0.5.0 

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 added in v0.3.2 

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

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

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

Deprecated: Use QueryEntitiesRequest.ProtoReflect.Descriptor instead.

func (*QueryEntitiesRequest) GetQuery added in v0.3.2 

func (x *QueryEntitiesRequest) GetQuery() *EntityQuery

func (*QueryEntitiesRequest) ProtoMessage added in v0.3.2 

func (*QueryEntitiesRequest) ProtoMessage()

func (*QueryEntitiesRequest) ProtoReflect added in v0.3.2 

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

func (*QueryEntitiesRequest) Reset added in v0.3.2 

func (x *QueryEntitiesRequest) Reset()

func (*QueryEntitiesRequest) String added in v0.3.2 

func (x *QueryEntitiesRequest) String() string

type QueryEntitiesResponse added in v0.3.2 

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

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

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

Deprecated: Use QueryEntitiesResponse.ProtoReflect.Descriptor instead.

func (*QueryEntitiesResponse) GetContinuationToken added in v0.3.2 

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

func (*QueryEntitiesResponse) GetEntities added in v0.3.2 

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

func (*QueryEntitiesResponse) ProtoMessage added in v0.3.2 

func (*QueryEntitiesResponse) ProtoMessage()

func (*QueryEntitiesResponse) ProtoReflect added in v0.3.2 

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

func (*QueryEntitiesResponse) Reset added in v0.3.2 

func (x *QueryEntitiesResponse) Reset()

func (*QueryEntitiesResponse) String added in v0.3.2 

func (x *QueryEntitiesResponse) String() string

type QueryInstancesRequest 

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

func (*QueryInstancesRequest) Descriptor deprecated 

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

Deprecated: Use QueryInstancesRequest.ProtoReflect.Descriptor instead.

func (*QueryInstancesRequest) GetQuery 

func (x *QueryInstancesRequest) GetQuery() *InstanceQuery

func (*QueryInstancesRequest) ProtoMessage 

func (*QueryInstancesRequest) ProtoMessage()

func (*QueryInstancesRequest) ProtoReflect 

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

func (*QueryInstancesRequest) Reset 

func (x *QueryInstancesRequest) Reset()

func (*QueryInstancesRequest) String 

func (x *QueryInstancesRequest) String() string

type QueryInstancesResponse 

type QueryInstancesResponse struct {
	OrchestrationState []*OrchestrationState `protobuf:"bytes,1,rep,name=orchestrationState,proto3" json:"orchestrationState,omitempty"`
	ContinuationToken  *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 added in v0.1.1 

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 added in v0.1.1 

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

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetInstanceId added in v0.1.1 

func (x *ResumeRequest) GetInstanceId() string

func (*ResumeRequest) GetReason added in v0.1.1 

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

func (*ResumeRequest) ProtoMessage added in v0.1.1 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect added in v0.1.1 

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

func (*ResumeRequest) Reset added in v0.1.1 

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String added in v0.1.1 

func (x *ResumeRequest) String() string

type ResumeResponse added in v0.1.1 

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

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

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

Deprecated: Use ResumeResponse.ProtoReflect.Descriptor instead.

func (*ResumeResponse) ProtoMessage added in v0.1.1 

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) ProtoReflect added in v0.1.1 

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

func (*ResumeResponse) Reset added in v0.1.1 

func (x *ResumeResponse) Reset()

func (*ResumeResponse) String added in v0.1.1 

func (x *ResumeResponse) String() string

type RewindInstanceRequest added in v0.1.1 

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

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

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

Deprecated: Use RewindInstanceRequest.ProtoReflect.Descriptor instead.

func (*RewindInstanceRequest) GetInstanceId added in v0.1.1 

func (x *RewindInstanceRequest) GetInstanceId() string

func (*RewindInstanceRequest) GetReason added in v0.1.1 

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

func (*RewindInstanceRequest) ProtoMessage added in v0.1.1 

func (*RewindInstanceRequest) ProtoMessage()

func (*RewindInstanceRequest) ProtoReflect added in v0.1.1 

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

func (*RewindInstanceRequest) Reset added in v0.1.1 

func (x *RewindInstanceRequest) Reset()

func (*RewindInstanceRequest) String added in v0.1.1 

func (x *RewindInstanceRequest) String() string

type RewindInstanceResponse added in v0.1.1 

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

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

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

Deprecated: Use RewindInstanceResponse.ProtoReflect.Descriptor instead.

func (*RewindInstanceResponse) ProtoMessage added in v0.1.1 

func (*RewindInstanceResponse) ProtoMessage()

func (*RewindInstanceResponse) ProtoReflect added in v0.1.1 

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

func (*RewindInstanceResponse) Reset added in v0.1.1 

func (x *RewindInstanceResponse) Reset()

func (*RewindInstanceResponse) String added in v0.1.1 

func (x *RewindInstanceResponse) String() string

type 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 added in v0.3.2 

type SendSignalAction struct {
	InstanceId    string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name          string                `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Input         *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 added in v0.3.2 

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

Deprecated: Use SendSignalAction.ProtoReflect.Descriptor instead.

func (*SendSignalAction) GetInput added in v0.3.2 

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

func (*SendSignalAction) GetInstanceId added in v0.3.2 

func (x *SendSignalAction) GetInstanceId() string

func (*SendSignalAction) GetName added in v0.3.2 

func (x *SendSignalAction) GetName() string

func (*SendSignalAction) GetScheduledTime added in v0.3.2 

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

func (*SendSignalAction) ProtoMessage added in v0.3.2 

func (*SendSignalAction) ProtoMessage()

func (*SendSignalAction) ProtoReflect added in v0.3.2 

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

func (*SendSignalAction) Reset added in v0.3.2 

func (x *SendSignalAction) Reset()

func (*SendSignalAction) String added in v0.3.2 

func (x *SendSignalAction) String() string

type SignalEntityRequest added in v0.3.2 

type SignalEntityRequest struct {
	InstanceId    string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name          string                `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Input         *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 added in v0.3.2 

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

Deprecated: Use SignalEntityRequest.ProtoReflect.Descriptor instead.

func (*SignalEntityRequest) GetInput added in v0.3.2 

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

func (*SignalEntityRequest) GetInstanceId added in v0.3.2 

func (x *SignalEntityRequest) GetInstanceId() string

func (*SignalEntityRequest) GetName added in v0.3.2 

func (x *SignalEntityRequest) GetName() string

func (*SignalEntityRequest) GetRequestId added in v0.3.2 

func (x *SignalEntityRequest) GetRequestId() string

func (*SignalEntityRequest) GetScheduledTime added in v0.3.2 

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

func (*SignalEntityRequest) ProtoMessage added in v0.3.2 

func (*SignalEntityRequest) ProtoMessage()

func (*SignalEntityRequest) ProtoReflect added in v0.3.2 

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

func (*SignalEntityRequest) Reset added in v0.3.2 

func (x *SignalEntityRequest) Reset()

func (*SignalEntityRequest) String added in v0.3.2 

func (x *SignalEntityRequest) String() string

type SignalEntityResponse added in v0.3.2 

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

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

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

Deprecated: Use SignalEntityResponse.ProtoReflect.Descriptor instead.

func (*SignalEntityResponse) ProtoMessage added in v0.3.2 

func (*SignalEntityResponse) ProtoMessage()

func (*SignalEntityResponse) ProtoReflect added in v0.3.2 

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

func (*SignalEntityResponse) Reset added in v0.3.2 

func (x *SignalEntityResponse) Reset()

func (*SignalEntityResponse) String added in v0.3.2 

func (x *SignalEntityResponse) String() string

type StartNewOrchestrationAction added in v0.3.2 

type StartNewOrchestrationAction struct {
	InstanceId    string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name          string                `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version       *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 added in v0.3.2 

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

Deprecated: Use StartNewOrchestrationAction.ProtoReflect.Descriptor instead.

func (*StartNewOrchestrationAction) GetInput added in v0.3.2 

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

func (*StartNewOrchestrationAction) GetInstanceId added in v0.3.2 

func (x *StartNewOrchestrationAction) GetInstanceId() string

func (*StartNewOrchestrationAction) GetName added in v0.3.2 

func (x *StartNewOrchestrationAction) GetName() string

func (*StartNewOrchestrationAction) GetScheduledTime added in v0.3.2 

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

func (*StartNewOrchestrationAction) GetVersion added in v0.3.2 

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

func (*StartNewOrchestrationAction) ProtoMessage added in v0.3.2 

func (*StartNewOrchestrationAction) ProtoMessage()

func (*StartNewOrchestrationAction) ProtoReflect added in v0.3.2 

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

func (*StartNewOrchestrationAction) Reset added in v0.3.2 

func (x *StartNewOrchestrationAction) Reset()

func (*StartNewOrchestrationAction) String added in v0.3.2 

func (x *StartNewOrchestrationAction) String() string

type 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 added in v0.1.1 

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 added in v0.1.1 

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 added in v0.1.1 

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

Deprecated: Use SuspendRequest.ProtoReflect.Descriptor instead.

func (*SuspendRequest) GetInstanceId added in v0.1.1 

func (x *SuspendRequest) GetInstanceId() string

func (*SuspendRequest) GetReason added in v0.1.1 

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

func (*SuspendRequest) ProtoMessage added in v0.1.1 

func (*SuspendRequest) ProtoMessage()

func (*SuspendRequest) ProtoReflect added in v0.1.1 

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

func (*SuspendRequest) Reset added in v0.1.1 

func (x *SuspendRequest) Reset()

func (*SuspendRequest) String added in v0.1.1 

func (x *SuspendRequest) String() string

type SuspendResponse added in v0.1.1 

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

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

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

Deprecated: Use SuspendResponse.ProtoReflect.Descriptor instead.

func (*SuspendResponse) ProtoMessage added in v0.1.1 

func (*SuspendResponse) ProtoMessage()

func (*SuspendResponse) ProtoReflect added in v0.1.1 

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

func (*SuspendResponse) Reset added in v0.1.1 

func (x *SuspendResponse) Reset()

func (*SuspendResponse) String added in v0.1.1 

func (x *SuspendResponse) String() string

type TaskCompletedEvent 

type TaskCompletedEvent struct {
	TaskScheduledId int32                 `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	Result          *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 added in v0.1.1 

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 added in v0.3.0 

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 added in v0.3.0 

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

Deprecated: Use TerminateOrchestrationAction.ProtoReflect.Descriptor instead.

func (*TerminateOrchestrationAction) GetInstanceId added in v0.3.0 

func (x *TerminateOrchestrationAction) GetInstanceId() string

func (*TerminateOrchestrationAction) GetReason added in v0.3.0 

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

func (*TerminateOrchestrationAction) GetRecurse added in v0.3.0 

func (x *TerminateOrchestrationAction) GetRecurse() bool

func (*TerminateOrchestrationAction) ProtoMessage added in v0.3.0 

func (*TerminateOrchestrationAction) ProtoMessage()

func (*TerminateOrchestrationAction) ProtoReflect added in v0.3.0 

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

func (*TerminateOrchestrationAction) Reset added in v0.3.0 

func (x *TerminateOrchestrationAction) Reset()

func (*TerminateOrchestrationAction) String added in v0.3.0 

func (x *TerminateOrchestrationAction) String() string

type TerminateRequest 

type TerminateRequest struct {
	InstanceId string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Output     *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 added in v0.3.0 

func (x *TerminateRequest) GetRecursive() bool

func (*TerminateRequest) ProtoMessage 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) ProtoReflect 

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

func (*TerminateRequest) Reset 

func (x *TerminateRequest) Reset()

func (*TerminateRequest) String 

func (x *TerminateRequest) String() string

type TerminateResponse 

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

func (*TerminateResponse) Descriptor deprecated 

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

Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.

func (*TerminateResponse) ProtoMessage 

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) ProtoReflect 

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

func (*TerminateResponse) Reset 

func (x *TerminateResponse) Reset()

func (*TerminateResponse) String 

func (x *TerminateResponse) String() string

type TimerCreatedEvent 

type TimerCreatedEvent struct {
	FireAt *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 added in v0.1.1 

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

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

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

Deprecated: Use TraceContext.ProtoReflect.Descriptor instead.

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

func (x *TraceContext) GetSpanID() string

Deprecated: Marked as deprecated in orchestrator_service.proto.

func (*TraceContext) GetTraceParent added in v0.3.2 

func (x *TraceContext) GetTraceParent() string

func (*TraceContext) GetTraceState added in v0.1.1 

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

func (*TraceContext) ProtoMessage added in v0.1.1 

func (*TraceContext) ProtoMessage()

func (*TraceContext) ProtoReflect added in v0.1.1 

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

func (*TraceContext) Reset added in v0.1.1 

func (x *TraceContext) Reset()

func (*TraceContext) String added in v0.1.1 

func (x *TraceContext) String() string

type UnimplementedTaskHubSidecarServiceServer 

type UnimplementedTaskHubSidecarServiceServer struct {
}

UnimplementedTaskHubSidecarServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskHubSidecarServiceServer) CleanEntityStorage added in v0.3.2 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteEntityTask added in v0.3.2 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteOrchestratorTask 

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

func (UnimplementedTaskHubSidecarServiceServer) CreateTaskHub 

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

func (UnimplementedTaskHubSidecarServiceServer) DeleteTaskHub 

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

func (UnimplementedTaskHubSidecarServiceServer) GetEntity added in v0.3.2 

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

func (UnimplementedTaskHubSidecarServiceServer) GetInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems 

func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems(*GetWorkItemsRequest, 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 added in v0.3.2 

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

func (UnimplementedTaskHubSidecarServiceServer) QueryInstances 

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

func (UnimplementedTaskHubSidecarServiceServer) RaiseEvent 

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

func (UnimplementedTaskHubSidecarServiceServer) ResumeInstance added in v0.1.1 

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

func (UnimplementedTaskHubSidecarServiceServer) RewindInstance added in v0.1.1 

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

func (UnimplementedTaskHubSidecarServiceServer) SignalEntity added in v0.3.2 

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

func (UnimplementedTaskHubSidecarServiceServer) StartInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) SuspendInstance added in v0.1.1 

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

func (UnimplementedTaskHubSidecarServiceServer) TerminateInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceCompletion 

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

func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceStart 

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

type UnsafeTaskHubSidecarServiceServer 

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

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

type WorkItem 

type WorkItem struct {

	// Types that are 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 added in v0.3.2 

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 added in v0.3.2 

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.