protos

package
v0.10.0 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2025 License: Apache-2.0 Imports: 12 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	BackendService_CreateInstance_FullMethodName                = "/durabletask.protos.backend.v1.BackendService/CreateInstance"
	BackendService_AddEvent_FullMethodName                      = "/durabletask.protos.backend.v1.BackendService/AddEvent"
	BackendService_GetInstance_FullMethodName                   = "/durabletask.protos.backend.v1.BackendService/GetInstance"
	BackendService_GetEntity_FullMethodName                     = "/durabletask.protos.backend.v1.BackendService/GetEntity"
	BackendService_QueryInstances_FullMethodName                = "/durabletask.protos.backend.v1.BackendService/QueryInstances"
	BackendService_QueryEntities_FullMethodName                 = "/durabletask.protos.backend.v1.BackendService/QueryEntities"
	BackendService_WaitForInstance_FullMethodName               = "/durabletask.protos.backend.v1.BackendService/WaitForInstance"
	BackendService_PurgeInstances_FullMethodName                = "/durabletask.protos.backend.v1.BackendService/PurgeInstances"
	BackendService_CleanEntityStorage_FullMethodName            = "/durabletask.protos.backend.v1.BackendService/CleanEntityStorage"
	BackendService_GetWorkItems_FullMethodName                  = "/durabletask.protos.backend.v1.BackendService/GetWorkItems"
	BackendService_GetOrchestrationRuntimeState_FullMethodName  = "/durabletask.protos.backend.v1.BackendService/GetOrchestrationRuntimeState"
	BackendService_StreamInstanceHistory_FullMethodName         = "/durabletask.protos.backend.v1.BackendService/StreamInstanceHistory"
	BackendService_CompleteActivityWorkItem_FullMethodName      = "/durabletask.protos.backend.v1.BackendService/CompleteActivityWorkItem"
	BackendService_AbandonActivityWorkItem_FullMethodName       = "/durabletask.protos.backend.v1.BackendService/AbandonActivityWorkItem"
	BackendService_CompleteOrchestrationWorkItem_FullMethodName = "/durabletask.protos.backend.v1.BackendService/CompleteOrchestrationWorkItem"
	BackendService_AbandonOrchestrationWorkItem_FullMethodName  = "/durabletask.protos.backend.v1.BackendService/AbandonOrchestrationWorkItem"
	BackendService_CompleteEntityWorkItem_FullMethodName        = "/durabletask.protos.backend.v1.BackendService/CompleteEntityWorkItem"
	BackendService_AbandonEntityWorkItem_FullMethodName         = "/durabletask.protos.backend.v1.BackendService/AbandonEntityWorkItem"
	BackendService_Ping_FullMethodName                          = "/durabletask.protos.backend.v1.BackendService/Ping"
	BackendService_GetMetrics_FullMethodName                    = "/durabletask.protos.backend.v1.BackendService/GetMetrics"
)
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_StreamInstanceHistory_FullMethodName           = "/TaskHubSidecarService/StreamInstanceHistory"
	TaskHubSidecarService_CreateTaskHub_FullMethodName                   = "/TaskHubSidecarService/CreateTaskHub"
	TaskHubSidecarService_DeleteTaskHub_FullMethodName                   = "/TaskHubSidecarService/DeleteTaskHub"
	TaskHubSidecarService_SignalEntity_FullMethodName                    = "/TaskHubSidecarService/SignalEntity"
	TaskHubSidecarService_GetEntity_FullMethodName                       = "/TaskHubSidecarService/GetEntity"
	TaskHubSidecarService_QueryEntities_FullMethodName                   = "/TaskHubSidecarService/QueryEntities"
	TaskHubSidecarService_CleanEntityStorage_FullMethodName              = "/TaskHubSidecarService/CleanEntityStorage"
	TaskHubSidecarService_AbandonTaskActivityWorkItem_FullMethodName     = "/TaskHubSidecarService/AbandonTaskActivityWorkItem"
	TaskHubSidecarService_AbandonTaskOrchestratorWorkItem_FullMethodName = "/TaskHubSidecarService/AbandonTaskOrchestratorWorkItem"
	TaskHubSidecarService_AbandonTaskEntityWorkItem_FullMethodName       = "/TaskHubSidecarService/AbandonTaskEntityWorkItem"
	TaskHubSidecarService_RerunWorkflowFromEvent_FullMethodName          = "/TaskHubSidecarService/RerunWorkflowFromEvent"
)

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 (
	WorkerCapability_name = map[int32]string{
		0: "WORKER_CAPABILITY_UNSPECIFIED",
		1: "WORKER_CAPABILITY_HISTORY_STREAMING",
	}
	WorkerCapability_value = map[string]int32{
		"WORKER_CAPABILITY_UNSPECIFIED":       0,
		"WORKER_CAPABILITY_HISTORY_STREAMING": 1,
	}
)

Enum value maps for WorkerCapability.

View Source 
var BackendService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "durabletask.protos.backend.v1.BackendService",
	HandlerType: (*BackendServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateInstance",
			Handler:    _BackendService_CreateInstance_Handler,
		},
		{
			MethodName: "AddEvent",
			Handler:    _BackendService_AddEvent_Handler,
		},
		{
			MethodName: "GetInstance",
			Handler:    _BackendService_GetInstance_Handler,
		},
		{
			MethodName: "GetEntity",
			Handler:    _BackendService_GetEntity_Handler,
		},
		{
			MethodName: "QueryInstances",
			Handler:    _BackendService_QueryInstances_Handler,
		},
		{
			MethodName: "QueryEntities",
			Handler:    _BackendService_QueryEntities_Handler,
		},
		{
			MethodName: "WaitForInstance",
			Handler:    _BackendService_WaitForInstance_Handler,
		},
		{
			MethodName: "PurgeInstances",
			Handler:    _BackendService_PurgeInstances_Handler,
		},
		{
			MethodName: "CleanEntityStorage",
			Handler:    _BackendService_CleanEntityStorage_Handler,
		},
		{
			MethodName: "GetOrchestrationRuntimeState",
			Handler:    _BackendService_GetOrchestrationRuntimeState_Handler,
		},
		{
			MethodName: "CompleteActivityWorkItem",
			Handler:    _BackendService_CompleteActivityWorkItem_Handler,
		},
		{
			MethodName: "AbandonActivityWorkItem",
			Handler:    _BackendService_AbandonActivityWorkItem_Handler,
		},
		{
			MethodName: "CompleteOrchestrationWorkItem",
			Handler:    _BackendService_CompleteOrchestrationWorkItem_Handler,
		},
		{
			MethodName: "AbandonOrchestrationWorkItem",
			Handler:    _BackendService_AbandonOrchestrationWorkItem_Handler,
		},
		{
			MethodName: "CompleteEntityWorkItem",
			Handler:    _BackendService_CompleteEntityWorkItem_Handler,
		},
		{
			MethodName: "AbandonEntityWorkItem",
			Handler:    _BackendService_AbandonEntityWorkItem_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _BackendService_Ping_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _BackendService_GetMetrics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetWorkItems",
			Handler:       _BackendService_GetWorkItems_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamInstanceHistory",
			Handler:       _BackendService_StreamInstanceHistory_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "backend_service.proto",
}

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

View Source 
var File_backend_service_proto protoreflect.FileDescriptor
View Source 
var File_orchestrator_service_proto protoreflect.FileDescriptor
View Source 
var File_runtime_state_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,
		},
		{
			MethodName: "AbandonTaskActivityWorkItem",
			Handler:    _TaskHubSidecarService_AbandonTaskActivityWorkItem_Handler,
		},
		{
			MethodName: "AbandonTaskOrchestratorWorkItem",
			Handler:    _TaskHubSidecarService_AbandonTaskOrchestratorWorkItem_Handler,
		},
		{
			MethodName: "AbandonTaskEntityWorkItem",
			Handler:    _TaskHubSidecarService_AbandonTaskEntityWorkItem_Handler,
		},
		{
			MethodName: "RerunWorkflowFromEvent",
			Handler:    _TaskHubSidecarService_RerunWorkflowFromEvent_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetWorkItems",
			Handler:       _TaskHubSidecarService_GetWorkItems_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamInstanceHistory",
			Handler:       _TaskHubSidecarService_StreamInstanceHistory_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "orchestrator_service.proto",
}

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

Functions

func RegisterBackendServiceServer 

func RegisterBackendServiceServer(s grpc.ServiceRegistrar, srv BackendServiceServer)

func RegisterTaskHubSidecarServiceServer 

func RegisterTaskHubSidecarServiceServer(s grpc.ServiceRegistrar, srv TaskHubSidecarServiceServer)

Types

type AbandonActivityTaskRequest added in v0.7.0 

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

func (*AbandonActivityTaskRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use AbandonActivityTaskRequest.ProtoReflect.Descriptor instead.

func (*AbandonActivityTaskRequest) GetCompletionToken added in v0.7.0 

func (x *AbandonActivityTaskRequest) GetCompletionToken() string

func (*AbandonActivityTaskRequest) ProtoMessage added in v0.7.0 

func (*AbandonActivityTaskRequest) ProtoMessage()

func (*AbandonActivityTaskRequest) ProtoReflect added in v0.7.0 

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

func (*AbandonActivityTaskRequest) Reset added in v0.7.0 

func (x *AbandonActivityTaskRequest) Reset()

func (*AbandonActivityTaskRequest) String added in v0.7.0 

func (x *AbandonActivityTaskRequest) String() string

type AbandonActivityTaskResponse added in v0.7.0 

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

func (*AbandonActivityTaskResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use AbandonActivityTaskResponse.ProtoReflect.Descriptor instead.

func (*AbandonActivityTaskResponse) ProtoMessage added in v0.7.0 

func (*AbandonActivityTaskResponse) ProtoMessage()

func (*AbandonActivityTaskResponse) ProtoReflect added in v0.7.0 

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

func (*AbandonActivityTaskResponse) Reset added in v0.7.0 

func (x *AbandonActivityTaskResponse) Reset()

func (*AbandonActivityTaskResponse) String added in v0.7.0 

func (x *AbandonActivityTaskResponse) String() string

type AbandonActivityWorkItemRequest 

type AbandonActivityWorkItemRequest struct {

	// The completion token that was provided when the work item was fetched.
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// contains filtered or unexported fields
}

Request payload for abandoning an activity work item.

func (*AbandonActivityWorkItemRequest) Descriptor deprecated 

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

Deprecated: Use AbandonActivityWorkItemRequest.ProtoReflect.Descriptor instead.

func (*AbandonActivityWorkItemRequest) GetCompletionToken 

func (x *AbandonActivityWorkItemRequest) GetCompletionToken() string

func (*AbandonActivityWorkItemRequest) ProtoMessage 

func (*AbandonActivityWorkItemRequest) ProtoMessage()

func (*AbandonActivityWorkItemRequest) ProtoReflect 

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

func (*AbandonActivityWorkItemRequest) Reset 

func (x *AbandonActivityWorkItemRequest) Reset()

func (*AbandonActivityWorkItemRequest) String 

func (x *AbandonActivityWorkItemRequest) String() string

type AbandonActivityWorkItemResponse 

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

Response payload for abandoning an activity work item.

func (*AbandonActivityWorkItemResponse) Descriptor deprecated 

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

Deprecated: Use AbandonActivityWorkItemResponse.ProtoReflect.Descriptor instead.

func (*AbandonActivityWorkItemResponse) ProtoMessage 

func (*AbandonActivityWorkItemResponse) ProtoMessage()

func (*AbandonActivityWorkItemResponse) ProtoReflect 

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

func (*AbandonActivityWorkItemResponse) Reset 

func (x *AbandonActivityWorkItemResponse) Reset()

func (*AbandonActivityWorkItemResponse) String 

func (x *AbandonActivityWorkItemResponse) String() string

type AbandonEntityTaskRequest added in v0.7.0 

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

func (*AbandonEntityTaskRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use AbandonEntityTaskRequest.ProtoReflect.Descriptor instead.

func (*AbandonEntityTaskRequest) GetCompletionToken added in v0.7.0 

func (x *AbandonEntityTaskRequest) GetCompletionToken() string

func (*AbandonEntityTaskRequest) ProtoMessage added in v0.7.0 

func (*AbandonEntityTaskRequest) ProtoMessage()

func (*AbandonEntityTaskRequest) ProtoReflect added in v0.7.0 

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

func (*AbandonEntityTaskRequest) Reset added in v0.7.0 

func (x *AbandonEntityTaskRequest) Reset()

func (*AbandonEntityTaskRequest) String added in v0.7.0 

func (x *AbandonEntityTaskRequest) String() string

type AbandonEntityTaskResponse added in v0.7.0 

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

func (*AbandonEntityTaskResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use AbandonEntityTaskResponse.ProtoReflect.Descriptor instead.

func (*AbandonEntityTaskResponse) ProtoMessage added in v0.7.0 

func (*AbandonEntityTaskResponse) ProtoMessage()

func (*AbandonEntityTaskResponse) ProtoReflect added in v0.7.0 

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

func (*AbandonEntityTaskResponse) Reset added in v0.7.0 

func (x *AbandonEntityTaskResponse) Reset()

func (*AbandonEntityTaskResponse) String added in v0.7.0 

func (x *AbandonEntityTaskResponse) String() string

type AbandonEntityWorkItemRequest added in v0.7.0 

type AbandonEntityWorkItemRequest struct {

	// The completion token that was provided when the work item was fetched.
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	Reason          string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

Request payload for abandoning an entity work item.

func (*AbandonEntityWorkItemRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use AbandonEntityWorkItemRequest.ProtoReflect.Descriptor instead.

func (*AbandonEntityWorkItemRequest) GetCompletionToken added in v0.7.0 

func (x *AbandonEntityWorkItemRequest) GetCompletionToken() string

func (*AbandonEntityWorkItemRequest) GetReason added in v0.7.0 

func (x *AbandonEntityWorkItemRequest) GetReason() string

func (*AbandonEntityWorkItemRequest) ProtoMessage added in v0.7.0 

func (*AbandonEntityWorkItemRequest) ProtoMessage()

func (*AbandonEntityWorkItemRequest) ProtoReflect added in v0.7.0 

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

func (*AbandonEntityWorkItemRequest) Reset added in v0.7.0 

func (x *AbandonEntityWorkItemRequest) Reset()

func (*AbandonEntityWorkItemRequest) String added in v0.7.0 

func (x *AbandonEntityWorkItemRequest) String() string

type AbandonEntityWorkItemResponse added in v0.7.0 

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

Response payload for abandoning an entity work item.

func (*AbandonEntityWorkItemResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use AbandonEntityWorkItemResponse.ProtoReflect.Descriptor instead.

func (*AbandonEntityWorkItemResponse) ProtoMessage added in v0.7.0 

func (*AbandonEntityWorkItemResponse) ProtoMessage()

func (*AbandonEntityWorkItemResponse) ProtoReflect added in v0.7.0 

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

func (*AbandonEntityWorkItemResponse) Reset added in v0.7.0 

func (x *AbandonEntityWorkItemResponse) Reset()

func (*AbandonEntityWorkItemResponse) String added in v0.7.0 

func (x *AbandonEntityWorkItemResponse) String() string

type AbandonOrchestrationTaskRequest added in v0.7.0 

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

func (*AbandonOrchestrationTaskRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use AbandonOrchestrationTaskRequest.ProtoReflect.Descriptor instead.

func (*AbandonOrchestrationTaskRequest) GetCompletionToken added in v0.7.0 

func (x *AbandonOrchestrationTaskRequest) GetCompletionToken() string

func (*AbandonOrchestrationTaskRequest) ProtoMessage added in v0.7.0 

func (*AbandonOrchestrationTaskRequest) ProtoMessage()

func (*AbandonOrchestrationTaskRequest) ProtoReflect added in v0.7.0 

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

func (*AbandonOrchestrationTaskRequest) Reset added in v0.7.0 

func (x *AbandonOrchestrationTaskRequest) Reset()

func (*AbandonOrchestrationTaskRequest) String added in v0.7.0 

func (x *AbandonOrchestrationTaskRequest) String() string

type AbandonOrchestrationTaskResponse added in v0.7.0 

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

func (*AbandonOrchestrationTaskResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use AbandonOrchestrationTaskResponse.ProtoReflect.Descriptor instead.

func (*AbandonOrchestrationTaskResponse) ProtoMessage added in v0.7.0 

func (*AbandonOrchestrationTaskResponse) ProtoMessage()

func (*AbandonOrchestrationTaskResponse) ProtoReflect added in v0.7.0 

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

func (*AbandonOrchestrationTaskResponse) Reset added in v0.7.0 

func (x *AbandonOrchestrationTaskResponse) Reset()

func (*AbandonOrchestrationTaskResponse) String added in v0.7.0 

func (x *AbandonOrchestrationTaskResponse) String() string

type AbandonOrchestrationWorkItemRequest 

type AbandonOrchestrationWorkItemRequest struct {

	// The completion token that was provided when the work item was fetched.
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// contains filtered or unexported fields
}

Request payload for abandoning an orchestration work item.

func (*AbandonOrchestrationWorkItemRequest) Descriptor deprecated 

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

Deprecated: Use AbandonOrchestrationWorkItemRequest.ProtoReflect.Descriptor instead.

func (*AbandonOrchestrationWorkItemRequest) GetCompletionToken 

func (x *AbandonOrchestrationWorkItemRequest) GetCompletionToken() string

func (*AbandonOrchestrationWorkItemRequest) ProtoMessage 

func (*AbandonOrchestrationWorkItemRequest) ProtoMessage()

func (*AbandonOrchestrationWorkItemRequest) ProtoReflect 

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

func (*AbandonOrchestrationWorkItemRequest) Reset 

func (x *AbandonOrchestrationWorkItemRequest) Reset()

func (*AbandonOrchestrationWorkItemRequest) String 

func (x *AbandonOrchestrationWorkItemRequest) String() string

type AbandonOrchestrationWorkItemResponse 

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

Response payload for abandoning an orchestration work item.

func (*AbandonOrchestrationWorkItemResponse) Descriptor deprecated 

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

Deprecated: Use AbandonOrchestrationWorkItemResponse.ProtoReflect.Descriptor instead.

func (*AbandonOrchestrationWorkItemResponse) ProtoMessage 

func (*AbandonOrchestrationWorkItemResponse) ProtoMessage()

func (*AbandonOrchestrationWorkItemResponse) ProtoReflect 

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

func (*AbandonOrchestrationWorkItemResponse) Reset 

func (x *AbandonOrchestrationWorkItemResponse) Reset()

func (*AbandonOrchestrationWorkItemResponse) String 

func (x *AbandonOrchestrationWorkItemResponse) String() string

type ActivityRequest 

type ActivityRequest struct {
	Name                  string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version               *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input                 *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	OrchestrationInstance *OrchestrationInstance  `protobuf:"bytes,4,opt,name=orchestrationInstance,proto3" json:"orchestrationInstance,omitempty"`
	TaskId                int32                   `protobuf:"varint,5,opt,name=taskId,proto3" json:"taskId,omitempty"`
	ParentTraceContext    *TraceContext           `protobuf:"bytes,6,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	TaskExecutionId       string                  `protobuf:"bytes,7,opt,name=taskExecutionId,proto3" json:"taskExecutionId,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() *wrapperspb.StringValue

func (*ActivityRequest) GetName 

func (x *ActivityRequest) GetName() string

func (*ActivityRequest) GetOrchestrationInstance 

func (x *ActivityRequest) GetOrchestrationInstance() *OrchestrationInstance

func (*ActivityRequest) GetParentTraceContext 

func (x *ActivityRequest) GetParentTraceContext() *TraceContext

func (*ActivityRequest) GetTaskExecutionId added in v0.8.0 

func (x *ActivityRequest) GetTaskExecutionId() string

func (*ActivityRequest) GetTaskId 

func (x *ActivityRequest) GetTaskId() int32

func (*ActivityRequest) GetVersion 

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

func (*ActivityRequest) ProtoMessage 

func (*ActivityRequest) ProtoMessage()

func (*ActivityRequest) ProtoReflect 

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

func (*ActivityRequest) Reset 

func (x *ActivityRequest) Reset()

func (*ActivityRequest) String 

func (x *ActivityRequest) String() string

type ActivityResponse 

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

func (*ActivityResponse) Descriptor deprecated 

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

Deprecated: Use ActivityResponse.ProtoReflect.Descriptor instead.

func (*ActivityResponse) GetCompletionToken added in v0.7.0 

func (x *ActivityResponse) GetCompletionToken() string

func (*ActivityResponse) GetFailureDetails 

func (x *ActivityResponse) GetFailureDetails() *TaskFailureDetails

func (*ActivityResponse) GetInstanceId 

func (x *ActivityResponse) GetInstanceId() string

func (*ActivityResponse) GetResult 

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

func (*ActivityResponse) GetTaskId 

func (x *ActivityResponse) GetTaskId() int32

func (*ActivityResponse) ProtoMessage 

func (*ActivityResponse) ProtoMessage()

func (*ActivityResponse) ProtoReflect 

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

func (*ActivityResponse) Reset 

func (x *ActivityResponse) Reset()

func (*ActivityResponse) String 

func (x *ActivityResponse) String() string

type AddEventRequest 

type AddEventRequest struct {

	// The ID of the orchestration to send an event to.
	Instance *OrchestrationInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// The event to send to the orchestration.
	Event *HistoryEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

Request payload for adding new orchestration events.

func (*AddEventRequest) Descriptor deprecated 

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

Deprecated: Use AddEventRequest.ProtoReflect.Descriptor instead.

func (*AddEventRequest) GetEvent 

func (x *AddEventRequest) GetEvent() *HistoryEvent

func (*AddEventRequest) GetInstance 

func (x *AddEventRequest) GetInstance() *OrchestrationInstance

func (*AddEventRequest) ProtoMessage 

func (*AddEventRequest) ProtoMessage()

func (*AddEventRequest) ProtoReflect 

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

func (*AddEventRequest) Reset 

func (x *AddEventRequest) Reset()

func (*AddEventRequest) String 

func (x *AddEventRequest) String() string

type AddEventResponse 

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

Response payload for adding new orchestration events.

func (*AddEventResponse) Descriptor deprecated 

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

Deprecated: Use AddEventResponse.ProtoReflect.Descriptor instead.

func (*AddEventResponse) ProtoMessage 

func (*AddEventResponse) ProtoMessage()

func (*AddEventResponse) ProtoReflect 

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

func (*AddEventResponse) Reset 

func (x *AddEventResponse) Reset()

func (*AddEventResponse) String 

func (x *AddEventResponse) String() string

type BackendMetrics added in v0.7.0 

type BackendMetrics struct {

	// Activity work item metrics
	ActivityWorkItems *WorkItemMetrics `protobuf:"bytes,1,opt,name=activityWorkItems,proto3" json:"activityWorkItems,omitempty"`
	// Orchestrator work item metrics
	OrchestratorWorkItems *WorkItemMetrics `protobuf:"bytes,2,opt,name=orchestratorWorkItems,proto3" json:"orchestratorWorkItems,omitempty"`
	// Entity work item metrics
	EntityWorkItems *WorkItemMetrics `protobuf:"bytes,3,opt,name=entityWorkItems,proto3" json:"entityWorkItems,omitempty"`
	// Metrics related to workers currently connected to the backend
	ConnectedWorkers *ConnectedWorkerMetrics `protobuf:"bytes,4,opt,name=connectedWorkers,proto3" json:"connectedWorkers,omitempty"`
	// contains filtered or unexported fields
}

Metrics for the backend service.

func (*BackendMetrics) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use BackendMetrics.ProtoReflect.Descriptor instead.

func (*BackendMetrics) GetActivityWorkItems added in v0.7.0 

func (x *BackendMetrics) GetActivityWorkItems() *WorkItemMetrics

func (*BackendMetrics) GetConnectedWorkers added in v0.7.0 

func (x *BackendMetrics) GetConnectedWorkers() *ConnectedWorkerMetrics

func (*BackendMetrics) GetEntityWorkItems added in v0.7.0 

func (x *BackendMetrics) GetEntityWorkItems() *WorkItemMetrics

func (*BackendMetrics) GetOrchestratorWorkItems added in v0.7.0 

func (x *BackendMetrics) GetOrchestratorWorkItems() *WorkItemMetrics

func (*BackendMetrics) ProtoMessage added in v0.7.0 

func (*BackendMetrics) ProtoMessage()

func (*BackendMetrics) ProtoReflect added in v0.7.0 

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

func (*BackendMetrics) Reset added in v0.7.0 

func (x *BackendMetrics) Reset()

func (*BackendMetrics) String added in v0.7.0 

func (x *BackendMetrics) String() string

type BackendServiceClient 

type BackendServiceClient interface {
	// Creates a new orchestration instance.
	CreateInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// Sends an event to an orchestration instance. This RPC is used for raising external events to orchestrations
	// and for sending orchestration lifecycle events, such as terminate, suspend, resume, etc.
	AddEvent(ctx context.Context, in *AddEventRequest, opts ...grpc.CallOption) (*AddEventResponse, error)
	// Returns metadata about an orchestration instance.
	GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Returns metadata about an entity instance.
	GetEntity(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*GetEntityResponse, error)
	// Returns metadata about multiple orchestration instances using a query.
	QueryInstances(ctx context.Context, in *QueryInstancesRequest, opts ...grpc.CallOption) (*QueryInstancesResponse, error)
	// Returns metadata for multiple entities using a query.
	QueryEntities(ctx context.Context, in *QueryEntitiesRequest, opts ...grpc.CallOption) (*QueryEntitiesResponse, error)
	// Waits for an orchestration to reach a terminal state and then returns metadata for that orchestration.
	WaitForInstance(ctx context.Context, in *WaitForInstanceRequest, opts ...grpc.CallOption) (*WaitForInstanceResponse, error)
	// Purges the state of one or more orchestration instances.
	PurgeInstances(ctx context.Context, in *PurgeInstancesRequest, opts ...grpc.CallOption) (*PurgeInstancesResponse, error)
	// Cleans entity storage.
	CleanEntityStorage(ctx context.Context, in *CleanEntityStorageRequest, opts ...grpc.CallOption) (*CleanEntityStorageResponse, error)
	// Starts a server stream for receiving work items
	GetWorkItems(ctx context.Context, in *GetWorkItemsRequest, opts ...grpc.CallOption) (BackendService_GetWorkItemsClient, error)
	// Gets orchestration runtime state (history, etc.) for a given orchestration instance.
	GetOrchestrationRuntimeState(ctx context.Context, in *GetOrchestrationRuntimeStateRequest, opts ...grpc.CallOption) (*GetOrchestrationRuntimeStateResponse, error)
	// Gets the history of an orchestration instance as a stream of events.
	StreamInstanceHistory(ctx context.Context, in *StreamInstanceHistoryRequest, opts ...grpc.CallOption) (BackendService_StreamInstanceHistoryClient, error)
	// Completes an outstanding activity work item and adds a new event to the target orchestration's inbox.
	CompleteActivityWorkItem(ctx context.Context, in *CompleteActivityWorkItemRequest, opts ...grpc.CallOption) (*CompleteActivityWorkItemResponse, error)
	// Abandons an outstanding activity work item. Abandoned work items will be delivered again after some delay.
	AbandonActivityWorkItem(ctx context.Context, in *AbandonActivityWorkItemRequest, opts ...grpc.CallOption) (*AbandonActivityWorkItemResponse, error)
	// Completes an outstanding orchestrator work item, and adds a new event to the target orchestration's inbox.
	CompleteOrchestrationWorkItem(ctx context.Context, in *CompleteOrchestrationWorkItemRequest, opts ...grpc.CallOption) (*CompleteOrchestrationWorkItemResponse, error)
	// Abandons an outstanding orchestrator work item. Abandoned work items will be delivered again after some delay.
	AbandonOrchestrationWorkItem(ctx context.Context, in *AbandonOrchestrationWorkItemRequest, opts ...grpc.CallOption) (*AbandonOrchestrationWorkItemResponse, error)
	// Completes an outstanding entity work item.
	CompleteEntityWorkItem(ctx context.Context, in *CompleteEntityWorkItemRequest, opts ...grpc.CallOption) (*CompleteEntityWorkItemResponse, error)
	// Abandons an outstanding entity work item. Abandoned work items will be delivered again after some delay.
	AbandonEntityWorkItem(ctx context.Context, in *AbandonEntityWorkItemRequest, opts ...grpc.CallOption) (*AbandonEntityWorkItemResponse, error)
	// Sends a health check ping to the backend service.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// Returns the current metrics for the backend service.
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error)
}

BackendServiceClient is the client API for BackendService 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 NewBackendServiceClient 

func NewBackendServiceClient(cc grpc.ClientConnInterface) BackendServiceClient

type BackendServiceServer 

type BackendServiceServer interface {
	// Creates a new orchestration instance.
	CreateInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// Sends an event to an orchestration instance. This RPC is used for raising external events to orchestrations
	// and for sending orchestration lifecycle events, such as terminate, suspend, resume, etc.
	AddEvent(context.Context, *AddEventRequest) (*AddEventResponse, error)
	// Returns metadata about an orchestration instance.
	GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Returns metadata about an entity instance.
	GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)
	// Returns metadata about multiple orchestration instances using a query.
	QueryInstances(context.Context, *QueryInstancesRequest) (*QueryInstancesResponse, error)
	// Returns metadata for multiple entities using a query.
	QueryEntities(context.Context, *QueryEntitiesRequest) (*QueryEntitiesResponse, error)
	// Waits for an orchestration to reach a terminal state and then returns metadata for that orchestration.
	WaitForInstance(context.Context, *WaitForInstanceRequest) (*WaitForInstanceResponse, error)
	// Purges the state of one or more orchestration instances.
	PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)
	// Cleans entity storage.
	CleanEntityStorage(context.Context, *CleanEntityStorageRequest) (*CleanEntityStorageResponse, error)
	// Starts a server stream for receiving work items
	GetWorkItems(*GetWorkItemsRequest, BackendService_GetWorkItemsServer) error
	// Gets orchestration runtime state (history, etc.) for a given orchestration instance.
	GetOrchestrationRuntimeState(context.Context, *GetOrchestrationRuntimeStateRequest) (*GetOrchestrationRuntimeStateResponse, error)
	// Gets the history of an orchestration instance as a stream of events.
	StreamInstanceHistory(*StreamInstanceHistoryRequest, BackendService_StreamInstanceHistoryServer) error
	// Completes an outstanding activity work item and adds a new event to the target orchestration's inbox.
	CompleteActivityWorkItem(context.Context, *CompleteActivityWorkItemRequest) (*CompleteActivityWorkItemResponse, error)
	// Abandons an outstanding activity work item. Abandoned work items will be delivered again after some delay.
	AbandonActivityWorkItem(context.Context, *AbandonActivityWorkItemRequest) (*AbandonActivityWorkItemResponse, error)
	// Completes an outstanding orchestrator work item, and adds a new event to the target orchestration's inbox.
	CompleteOrchestrationWorkItem(context.Context, *CompleteOrchestrationWorkItemRequest) (*CompleteOrchestrationWorkItemResponse, error)
	// Abandons an outstanding orchestrator work item. Abandoned work items will be delivered again after some delay.
	AbandonOrchestrationWorkItem(context.Context, *AbandonOrchestrationWorkItemRequest) (*AbandonOrchestrationWorkItemResponse, error)
	// Completes an outstanding entity work item.
	CompleteEntityWorkItem(context.Context, *CompleteEntityWorkItemRequest) (*CompleteEntityWorkItemResponse, error)
	// Abandons an outstanding entity work item. Abandoned work items will be delivered again after some delay.
	AbandonEntityWorkItem(context.Context, *AbandonEntityWorkItemRequest) (*AbandonEntityWorkItemResponse, error)
	// Sends a health check ping to the backend service.
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// Returns the current metrics for the backend service.
	GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)
	// contains filtered or unexported methods
}

BackendServiceServer is the server API for BackendService service. All implementations must embed UnimplementedBackendServiceServer for forward compatibility

type BackendService_GetWorkItemsClient 

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

type BackendService_GetWorkItemsServer 

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

type BackendService_StreamInstanceHistoryClient added in v0.7.0 

type BackendService_StreamInstanceHistoryClient interface {
	Recv() (*HistoryChunk, error)
	grpc.ClientStream
}

type BackendService_StreamInstanceHistoryServer added in v0.7.0 

type BackendService_StreamInstanceHistoryServer interface {
	Send(*HistoryChunk) error
	grpc.ServerStream
}

type CleanEntityStorageRequest 

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

func (*CleanEntityStorageRequest) Descriptor deprecated 

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

Deprecated: Use CleanEntityStorageRequest.ProtoReflect.Descriptor instead.

func (*CleanEntityStorageRequest) GetContinuationToken 

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

func (*CleanEntityStorageRequest) GetReleaseOrphanedLocks 

func (x *CleanEntityStorageRequest) GetReleaseOrphanedLocks() bool

func (*CleanEntityStorageRequest) GetRemoveEmptyEntities 

func (x *CleanEntityStorageRequest) GetRemoveEmptyEntities() bool

func (*CleanEntityStorageRequest) ProtoMessage 

func (*CleanEntityStorageRequest) ProtoMessage()

func (*CleanEntityStorageRequest) ProtoReflect 

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

func (*CleanEntityStorageRequest) Reset 

func (x *CleanEntityStorageRequest) Reset()

func (*CleanEntityStorageRequest) String 

func (x *CleanEntityStorageRequest) String() string

type CleanEntityStorageResponse 

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

func (*CleanEntityStorageResponse) Descriptor deprecated 

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

Deprecated: Use CleanEntityStorageResponse.ProtoReflect.Descriptor instead.

func (*CleanEntityStorageResponse) GetContinuationToken 

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

func (*CleanEntityStorageResponse) GetEmptyEntitiesRemoved 

func (x *CleanEntityStorageResponse) GetEmptyEntitiesRemoved() int32

func (*CleanEntityStorageResponse) GetOrphanedLocksReleased 

func (x *CleanEntityStorageResponse) GetOrphanedLocksReleased() int32

func (*CleanEntityStorageResponse) ProtoMessage 

func (*CleanEntityStorageResponse) ProtoMessage()

func (*CleanEntityStorageResponse) ProtoReflect 

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

func (*CleanEntityStorageResponse) Reset 

func (x *CleanEntityStorageResponse) Reset()

func (*CleanEntityStorageResponse) String 

func (x *CleanEntityStorageResponse) String() string

type CompleteActivityWorkItemRequest 

type CompleteActivityWorkItemRequest struct {

	// The completion token that was provided when the work item was fetched.
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// The response event that will be sent to the orchestrator.
	// This must be either a TaskCompleted event or a TaskFailed event.
	ResponseEvent *HistoryEvent `protobuf:"bytes,2,opt,name=responseEvent,proto3" json:"responseEvent,omitempty"`
	// contains filtered or unexported fields
}

Request payload for completing an activity work item.

func (*CompleteActivityWorkItemRequest) Descriptor deprecated 

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

Deprecated: Use CompleteActivityWorkItemRequest.ProtoReflect.Descriptor instead.

func (*CompleteActivityWorkItemRequest) GetCompletionToken 

func (x *CompleteActivityWorkItemRequest) GetCompletionToken() string

func (*CompleteActivityWorkItemRequest) GetResponseEvent 

func (x *CompleteActivityWorkItemRequest) GetResponseEvent() *HistoryEvent

func (*CompleteActivityWorkItemRequest) ProtoMessage 

func (*CompleteActivityWorkItemRequest) ProtoMessage()

func (*CompleteActivityWorkItemRequest) ProtoReflect 

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

func (*CompleteActivityWorkItemRequest) Reset 

func (x *CompleteActivityWorkItemRequest) Reset()

func (*CompleteActivityWorkItemRequest) String 

func (x *CompleteActivityWorkItemRequest) String() string

type CompleteActivityWorkItemResponse 

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

Response payload for completing an activity work item.

func (*CompleteActivityWorkItemResponse) Descriptor deprecated 

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

Deprecated: Use CompleteActivityWorkItemResponse.ProtoReflect.Descriptor instead.

func (*CompleteActivityWorkItemResponse) ProtoMessage 

func (*CompleteActivityWorkItemResponse) ProtoMessage()

func (*CompleteActivityWorkItemResponse) ProtoReflect 

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

func (*CompleteActivityWorkItemResponse) Reset 

func (x *CompleteActivityWorkItemResponse) Reset()

func (*CompleteActivityWorkItemResponse) String 

func (x *CompleteActivityWorkItemResponse) String() string

type CompleteEntityWorkItemRequest added in v0.7.0 

type CompleteEntityWorkItemRequest struct {

	// The completion token that was provided when the work item was fetched.
	CompletionToken string `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// The execution id of the scheduler.
	ExecutionId string `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	// The number of requests that were executed.
	// If this is smaller than the number of operations in the work item,
	// any left-over operations will be sent again with the next work item.
	NumberOperationsExecuted int32 `protobuf:"varint,3,opt,name=numberOperationsExecuted,proto3" json:"numberOperationsExecuted,omitempty"`
	// The state of the entity after the executed operations, or null if none
	EntityState *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=entityState,proto3" json:"entityState,omitempty"`
	// The messages that were sent by the executed operations. This must
	// include any responses to the operation calls.
	Messages []*OrchestratorMessage `protobuf:"bytes,5,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

Request payload for completing an entity work item.

func (*CompleteEntityWorkItemRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use CompleteEntityWorkItemRequest.ProtoReflect.Descriptor instead.

func (*CompleteEntityWorkItemRequest) GetCompletionToken added in v0.7.0 

func (x *CompleteEntityWorkItemRequest) GetCompletionToken() string

func (*CompleteEntityWorkItemRequest) GetEntityState added in v0.7.0 

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

func (*CompleteEntityWorkItemRequest) GetExecutionId added in v0.7.0 

func (x *CompleteEntityWorkItemRequest) GetExecutionId() string

func (*CompleteEntityWorkItemRequest) GetMessages added in v0.7.0 

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

func (*CompleteEntityWorkItemRequest) GetNumberOperationsExecuted added in v0.7.0 

func (x *CompleteEntityWorkItemRequest) GetNumberOperationsExecuted() int32

func (*CompleteEntityWorkItemRequest) ProtoMessage added in v0.7.0 

func (*CompleteEntityWorkItemRequest) ProtoMessage()

func (*CompleteEntityWorkItemRequest) ProtoReflect added in v0.7.0 

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

func (*CompleteEntityWorkItemRequest) Reset added in v0.7.0 

func (x *CompleteEntityWorkItemRequest) Reset()

func (*CompleteEntityWorkItemRequest) String added in v0.7.0 

func (x *CompleteEntityWorkItemRequest) String() string

type CompleteEntityWorkItemResponse added in v0.7.0 

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

Response payload for completing an entity work item.

func (*CompleteEntityWorkItemResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use CompleteEntityWorkItemResponse.ProtoReflect.Descriptor instead.

func (*CompleteEntityWorkItemResponse) ProtoMessage added in v0.7.0 

func (*CompleteEntityWorkItemResponse) ProtoMessage()

func (*CompleteEntityWorkItemResponse) ProtoReflect added in v0.7.0 

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

func (*CompleteEntityWorkItemResponse) Reset added in v0.7.0 

func (x *CompleteEntityWorkItemResponse) Reset()

func (*CompleteEntityWorkItemResponse) String added in v0.7.0 

func (x *CompleteEntityWorkItemResponse) String() string

type CompleteOrchestrationAction 

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

func (*CompleteOrchestrationAction) Descriptor deprecated 

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

Deprecated: Use CompleteOrchestrationAction.ProtoReflect.Descriptor instead.

func (*CompleteOrchestrationAction) GetCarryoverEvents 

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

func (*CompleteOrchestrationAction) GetDetails 

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

func (*CompleteOrchestrationAction) GetFailureDetails 

func (x *CompleteOrchestrationAction) GetFailureDetails() *TaskFailureDetails

func (*CompleteOrchestrationAction) GetNewVersion 

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

func (*CompleteOrchestrationAction) GetOrchestrationStatus 

func (x *CompleteOrchestrationAction) GetOrchestrationStatus() OrchestrationStatus

func (*CompleteOrchestrationAction) GetResult 

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

func (*CompleteOrchestrationAction) 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 CompleteOrchestrationWorkItemRequest 

type CompleteOrchestrationWorkItemRequest struct {

	// The completion token that was provided when the work item was fetched.
	CompletionToken string                  `protobuf:"bytes,1,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	Instance        *OrchestrationInstance  `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	RuntimeStatus   OrchestrationStatus     `protobuf:"varint,3,opt,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	CustomStatus    *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	NewHistory      []*HistoryEvent         `protobuf:"bytes,5,rep,name=newHistory,proto3" json:"newHistory,omitempty"`
	NewTasks        []*HistoryEvent         `protobuf:"bytes,6,rep,name=newTasks,proto3" json:"newTasks,omitempty"`
	NewTimers       []*HistoryEvent         `protobuf:"bytes,7,rep,name=newTimers,proto3" json:"newTimers,omitempty"`
	NewMessages     []*OrchestratorMessage  `protobuf:"bytes,8,rep,name=newMessages,proto3" json:"newMessages,omitempty"`
	// The number of work item events that were processed by the orchestrator.
	// This field is optional. If not set, the service should assume that the orchestrator processed all events.
	NumEventsProcessed *wrapperspb.Int32Value `protobuf:"bytes,9,opt,name=numEventsProcessed,proto3" json:"numEventsProcessed,omitempty"`
	// contains filtered or unexported fields
}

Request payload for completing an orchestration work item.

func (*CompleteOrchestrationWorkItemRequest) Descriptor deprecated 

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

Deprecated: Use CompleteOrchestrationWorkItemRequest.ProtoReflect.Descriptor instead.

func (*CompleteOrchestrationWorkItemRequest) GetCompletionToken 

func (x *CompleteOrchestrationWorkItemRequest) GetCompletionToken() string

func (*CompleteOrchestrationWorkItemRequest) GetCustomStatus 

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

func (*CompleteOrchestrationWorkItemRequest) GetInstance added in v0.7.0 

func (x *CompleteOrchestrationWorkItemRequest) GetInstance() *OrchestrationInstance

func (*CompleteOrchestrationWorkItemRequest) GetNewHistory 

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

func (*CompleteOrchestrationWorkItemRequest) GetNewMessages 

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

func (*CompleteOrchestrationWorkItemRequest) GetNewTasks 

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

func (*CompleteOrchestrationWorkItemRequest) GetNewTimers 

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

func (*CompleteOrchestrationWorkItemRequest) GetNumEventsProcessed added in v0.7.0 

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

func (*CompleteOrchestrationWorkItemRequest) GetRuntimeStatus 

func (x *CompleteOrchestrationWorkItemRequest) GetRuntimeStatus() OrchestrationStatus

func (*CompleteOrchestrationWorkItemRequest) ProtoMessage 

func (*CompleteOrchestrationWorkItemRequest) ProtoMessage()

func (*CompleteOrchestrationWorkItemRequest) ProtoReflect 

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

func (*CompleteOrchestrationWorkItemRequest) Reset 

func (x *CompleteOrchestrationWorkItemRequest) Reset()

func (*CompleteOrchestrationWorkItemRequest) String 

func (x *CompleteOrchestrationWorkItemRequest) String() string

type CompleteOrchestrationWorkItemResponse 

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

Response payload for completing an orchestration work item.

func (*CompleteOrchestrationWorkItemResponse) Descriptor deprecated 

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

Deprecated: Use CompleteOrchestrationWorkItemResponse.ProtoReflect.Descriptor instead.

func (*CompleteOrchestrationWorkItemResponse) ProtoMessage 

func (*CompleteOrchestrationWorkItemResponse) ProtoMessage()

func (*CompleteOrchestrationWorkItemResponse) ProtoReflect 

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

func (*CompleteOrchestrationWorkItemResponse) Reset 

func (x *CompleteOrchestrationWorkItemResponse) Reset()

func (*CompleteOrchestrationWorkItemResponse) String 

func (x *CompleteOrchestrationWorkItemResponse) 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 ConnectedWorkerMetrics added in v0.7.0 

type ConnectedWorkerMetrics struct {

	// Number of worker instances that are currently connected to the backend
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

Metrics related to workers currently connected to the backend

func (*ConnectedWorkerMetrics) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ConnectedWorkerMetrics.ProtoReflect.Descriptor instead.

func (*ConnectedWorkerMetrics) GetCount added in v0.7.0 

func (x *ConnectedWorkerMetrics) GetCount() int32

func (*ConnectedWorkerMetrics) ProtoMessage added in v0.7.0 

func (*ConnectedWorkerMetrics) ProtoMessage()

func (*ConnectedWorkerMetrics) ProtoReflect added in v0.7.0 

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

func (*ConnectedWorkerMetrics) Reset added in v0.7.0 

func (x *ConnectedWorkerMetrics) Reset()

func (*ConnectedWorkerMetrics) String added in v0.7.0 

func (x *ConnectedWorkerMetrics) String() string

type ContinueAsNewEvent 

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

func (*ContinueAsNewEvent) Descriptor deprecated 

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

Deprecated: Use ContinueAsNewEvent.ProtoReflect.Descriptor instead.

func (*ContinueAsNewEvent) GetInput 

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

func (*ContinueAsNewEvent) ProtoMessage 

func (*ContinueAsNewEvent) ProtoMessage()

func (*ContinueAsNewEvent) ProtoReflect 

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

func (*ContinueAsNewEvent) Reset 

func (x *ContinueAsNewEvent) Reset()

func (*ContinueAsNewEvent) String 

func (x *ContinueAsNewEvent) String() string

type CreateInstanceRequest 

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

func (*CreateInstanceRequest) Descriptor deprecated 

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

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetExecutionId 

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

func (*CreateInstanceRequest) GetInput 

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

func (*CreateInstanceRequest) GetInstanceId 

func (x *CreateInstanceRequest) GetInstanceId() string

func (*CreateInstanceRequest) GetName 

func (x *CreateInstanceRequest) GetName() string

func (*CreateInstanceRequest) GetOrchestrationIdReusePolicy 

func (x *CreateInstanceRequest) GetOrchestrationIdReusePolicy() *OrchestrationIdReusePolicy

func (*CreateInstanceRequest) GetParentTraceContext added in v0.7.0 

func (x *CreateInstanceRequest) GetParentTraceContext() *TraceContext

func (*CreateInstanceRequest) GetScheduledStartTimestamp 

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

func (*CreateInstanceRequest) GetTags 

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

func (*CreateInstanceRequest) GetVersion 

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

func (*CreateInstanceRequest) ProtoMessage 

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) ProtoReflect 

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

func (*CreateInstanceRequest) Reset 

func (x *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String 

func (x *CreateInstanceRequest) String() string

type CreateInstanceResponse 

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

func (*CreateInstanceResponse) Descriptor deprecated 

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

Deprecated: Use CreateInstanceResponse.ProtoReflect.Descriptor instead.

func (*CreateInstanceResponse) GetInstanceId 

func (x *CreateInstanceResponse) GetInstanceId() string

func (*CreateInstanceResponse) ProtoMessage 

func (*CreateInstanceResponse) ProtoMessage()

func (*CreateInstanceResponse) ProtoReflect 

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

func (*CreateInstanceResponse) Reset 

func (x *CreateInstanceResponse) Reset()

func (*CreateInstanceResponse) String 

func (x *CreateInstanceResponse) String() string

type CreateOrchestrationAction 

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

func (CreateOrchestrationAction) Descriptor 

func (CreateOrchestrationAction) Descriptor() protoreflect.EnumDescriptor

func (CreateOrchestrationAction) Enum 

func (x CreateOrchestrationAction) Enum() *CreateOrchestrationAction

func (CreateOrchestrationAction) EnumDescriptor deprecated 

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

Deprecated: Use CreateOrchestrationAction.Descriptor instead.

func (CreateOrchestrationAction) Number 

func (x CreateOrchestrationAction) Number() protoreflect.EnumNumber

func (CreateOrchestrationAction) String 

func (x CreateOrchestrationAction) String() string

func (CreateOrchestrationAction) Type 

func (CreateOrchestrationAction) Type() protoreflect.EnumType

type CreateSubOrchestrationAction 

type CreateSubOrchestrationAction struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name       string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input      *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	Router     *TaskRouter             `protobuf:"bytes,5,opt,name=router,proto3,oneof" json:"router,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() *wrapperspb.StringValue

func (*CreateSubOrchestrationAction) GetInstanceId 

func (x *CreateSubOrchestrationAction) GetInstanceId() string

func (*CreateSubOrchestrationAction) GetName 

func (x *CreateSubOrchestrationAction) GetName() string

func (*CreateSubOrchestrationAction) GetRouter added in v0.8.0 

func (x *CreateSubOrchestrationAction) GetRouter() *TaskRouter

func (*CreateSubOrchestrationAction) GetVersion 

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

func (*CreateSubOrchestrationAction) ProtoMessage 

func (*CreateSubOrchestrationAction) ProtoMessage()

func (*CreateSubOrchestrationAction) ProtoReflect 

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

func (*CreateSubOrchestrationAction) Reset 

func (x *CreateSubOrchestrationAction) Reset()

func (*CreateSubOrchestrationAction) String 

func (x *CreateSubOrchestrationAction) String() string

type CreateTaskHubRequest 

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

func (*CreateTaskHubRequest) Descriptor deprecated 

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

Deprecated: Use CreateTaskHubRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskHubRequest) GetRecreateIfExists 

func (x *CreateTaskHubRequest) GetRecreateIfExists() bool

func (*CreateTaskHubRequest) ProtoMessage 

func (*CreateTaskHubRequest) ProtoMessage()

func (*CreateTaskHubRequest) ProtoReflect 

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

func (*CreateTaskHubRequest) Reset 

func (x *CreateTaskHubRequest) Reset()

func (*CreateTaskHubRequest) String 

func (x *CreateTaskHubRequest) String() string

type CreateTaskHubResponse 

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

func (*CreateTaskHubResponse) Descriptor deprecated 

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

Deprecated: Use CreateTaskHubResponse.ProtoReflect.Descriptor instead.

func (*CreateTaskHubResponse) ProtoMessage 

func (*CreateTaskHubResponse) ProtoMessage()

func (*CreateTaskHubResponse) ProtoReflect 

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

func (*CreateTaskHubResponse) Reset 

func (x *CreateTaskHubResponse) Reset()

func (*CreateTaskHubResponse) String 

func (x *CreateTaskHubResponse) String() string

type CreateTimerAction 

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

func (*CreateTimerAction) Descriptor deprecated 

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

Deprecated: Use CreateTimerAction.ProtoReflect.Descriptor instead.

func (*CreateTimerAction) GetFireAt 

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

func (*CreateTimerAction) GetName added in v0.7.0 

func (x *CreateTimerAction) GetName() string

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 CreateWorkflowInstanceRequest 

type CreateWorkflowInstanceRequest struct {
	StartEvent *HistoryEvent               `protobuf:"bytes,1,opt,name=startEvent,proto3" json:"startEvent,omitempty"`
	Policy     *OrchestrationIdReusePolicy `protobuf:"bytes,2,opt,name=policy,proto3,oneof" json:"policy,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateWorkflowInstanceRequest) Descriptor deprecated 

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

Deprecated: Use CreateWorkflowInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateWorkflowInstanceRequest) GetPolicy 

func (x *CreateWorkflowInstanceRequest) GetPolicy() *OrchestrationIdReusePolicy

func (*CreateWorkflowInstanceRequest) GetStartEvent 

func (x *CreateWorkflowInstanceRequest) GetStartEvent() *HistoryEvent

func (*CreateWorkflowInstanceRequest) ProtoMessage 

func (*CreateWorkflowInstanceRequest) ProtoMessage()

func (*CreateWorkflowInstanceRequest) ProtoReflect 

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

func (*CreateWorkflowInstanceRequest) Reset 

func (x *CreateWorkflowInstanceRequest) Reset()

func (*CreateWorkflowInstanceRequest) String 

func (x *CreateWorkflowInstanceRequest) 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 DurableTimer 

type DurableTimer struct {
	TimerEvent *HistoryEvent `protobuf:"bytes,1,opt,name=timerEvent,proto3" json:"timerEvent,omitempty"`
	Generation uint64        `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

func (*DurableTimer) Descriptor deprecated 

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

Deprecated: Use DurableTimer.ProtoReflect.Descriptor instead.

func (*DurableTimer) GetGeneration 

func (x *DurableTimer) GetGeneration() uint64

func (*DurableTimer) GetTimerEvent 

func (x *DurableTimer) GetTimerEvent() *HistoryEvent

func (*DurableTimer) ProtoMessage 

func (*DurableTimer) ProtoMessage()

func (*DurableTimer) ProtoReflect 

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

func (*DurableTimer) Reset 

func (x *DurableTimer) Reset()

func (*DurableTimer) String 

func (x *DurableTimer) String() string

type EntityBatchRequest 

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

func (*EntityBatchRequest) Descriptor deprecated 

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

Deprecated: Use EntityBatchRequest.ProtoReflect.Descriptor instead.

func (*EntityBatchRequest) GetEntityState 

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

func (*EntityBatchRequest) GetInstanceId 

func (x *EntityBatchRequest) GetInstanceId() string

func (*EntityBatchRequest) GetOperations 

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

func (*EntityBatchRequest) ProtoMessage 

func (*EntityBatchRequest) ProtoMessage()

func (*EntityBatchRequest) ProtoReflect 

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

func (*EntityBatchRequest) Reset 

func (x *EntityBatchRequest) Reset()

func (*EntityBatchRequest) String 

func (x *EntityBatchRequest) String() string

type EntityBatchResult 

type EntityBatchResult struct {
	Results         []*OperationResult      `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	Actions         []*OperationAction      `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	EntityState     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=entityState,proto3" json:"entityState,omitempty"`
	FailureDetails  *TaskFailureDetails     `protobuf:"bytes,4,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	CompletionToken string                  `protobuf:"bytes,5,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	OperationInfos  []*OperationInfo        `protobuf:"bytes,6,rep,name=operationInfos,proto3" json:"operationInfos,omitempty"` // used only with DTS
	// contains filtered or unexported fields
}

func (*EntityBatchResult) Descriptor deprecated 

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

Deprecated: Use EntityBatchResult.ProtoReflect.Descriptor instead.

func (*EntityBatchResult) GetActions 

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

func (*EntityBatchResult) GetCompletionToken added in v0.7.0 

func (x *EntityBatchResult) GetCompletionToken() string

func (*EntityBatchResult) GetEntityState 

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

func (*EntityBatchResult) GetFailureDetails 

func (x *EntityBatchResult) GetFailureDetails() *TaskFailureDetails

func (*EntityBatchResult) GetOperationInfos added in v0.7.0 

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

func (*EntityBatchResult) GetResults 

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

func (*EntityBatchResult) ProtoMessage 

func (*EntityBatchResult) ProtoMessage()

func (*EntityBatchResult) ProtoReflect 

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

func (*EntityBatchResult) Reset 

func (x *EntityBatchResult) Reset()

func (*EntityBatchResult) String 

func (x *EntityBatchResult) String() string

type EntityLockGrantedEvent added in v0.7.0 

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

func (*EntityLockGrantedEvent) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use EntityLockGrantedEvent.ProtoReflect.Descriptor instead.

func (*EntityLockGrantedEvent) GetCriticalSectionId added in v0.7.0 

func (x *EntityLockGrantedEvent) GetCriticalSectionId() string

func (*EntityLockGrantedEvent) ProtoMessage added in v0.7.0 

func (*EntityLockGrantedEvent) ProtoMessage()

func (*EntityLockGrantedEvent) ProtoReflect added in v0.7.0 

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

func (*EntityLockGrantedEvent) Reset added in v0.7.0 

func (x *EntityLockGrantedEvent) Reset()

func (*EntityLockGrantedEvent) String added in v0.7.0 

func (x *EntityLockGrantedEvent) String() string

type EntityLockRequestedEvent added in v0.7.0 

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

func (*EntityLockRequestedEvent) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use EntityLockRequestedEvent.ProtoReflect.Descriptor instead.

func (*EntityLockRequestedEvent) GetCriticalSectionId added in v0.7.0 

func (x *EntityLockRequestedEvent) GetCriticalSectionId() string

func (*EntityLockRequestedEvent) GetLockSet added in v0.7.0 

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

func (*EntityLockRequestedEvent) GetParentInstanceId added in v0.7.0 

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

func (*EntityLockRequestedEvent) GetPosition added in v0.7.0 

func (x *EntityLockRequestedEvent) GetPosition() int32

func (*EntityLockRequestedEvent) ProtoMessage added in v0.7.0 

func (*EntityLockRequestedEvent) ProtoMessage()

func (*EntityLockRequestedEvent) ProtoReflect added in v0.7.0 

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

func (*EntityLockRequestedEvent) Reset added in v0.7.0 

func (x *EntityLockRequestedEvent) Reset()

func (*EntityLockRequestedEvent) String added in v0.7.0 

func (x *EntityLockRequestedEvent) String() string

type EntityMetadata 

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

func (*EntityMetadata) Descriptor deprecated 

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

Deprecated: Use EntityMetadata.ProtoReflect.Descriptor instead.

func (*EntityMetadata) GetBacklogQueueSize 

func (x *EntityMetadata) GetBacklogQueueSize() int32

func (*EntityMetadata) GetInstanceId 

func (x *EntityMetadata) GetInstanceId() string

func (*EntityMetadata) GetLastModifiedTime 

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

func (*EntityMetadata) GetLockedBy 

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

func (*EntityMetadata) GetSerializedState 

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

func (*EntityMetadata) ProtoMessage 

func (*EntityMetadata) ProtoMessage()

func (*EntityMetadata) ProtoReflect 

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

func (*EntityMetadata) Reset 

func (x *EntityMetadata) Reset()

func (*EntityMetadata) String 

func (x *EntityMetadata) String() string

type EntityOperationCalledEvent added in v0.7.0 

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

func (*EntityOperationCalledEvent) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use EntityOperationCalledEvent.ProtoReflect.Descriptor instead.

func (*EntityOperationCalledEvent) GetInput added in v0.7.0 

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

func (*EntityOperationCalledEvent) GetOperation added in v0.7.0 

func (x *EntityOperationCalledEvent) GetOperation() string

func (*EntityOperationCalledEvent) GetParentExecutionId added in v0.7.0 

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

func (*EntityOperationCalledEvent) GetParentInstanceId added in v0.7.0 

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

func (*EntityOperationCalledEvent) GetRequestId added in v0.7.0 

func (x *EntityOperationCalledEvent) GetRequestId() string

func (*EntityOperationCalledEvent) GetScheduledTime added in v0.7.0 

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

func (*EntityOperationCalledEvent) GetTargetInstanceId added in v0.7.0 

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

func (*EntityOperationCalledEvent) ProtoMessage added in v0.7.0 

func (*EntityOperationCalledEvent) ProtoMessage()

func (*EntityOperationCalledEvent) ProtoReflect added in v0.7.0 

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

func (*EntityOperationCalledEvent) Reset added in v0.7.0 

func (x *EntityOperationCalledEvent) Reset()

func (*EntityOperationCalledEvent) String added in v0.7.0 

func (x *EntityOperationCalledEvent) String() string

type EntityOperationCompletedEvent added in v0.7.0 

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

func (*EntityOperationCompletedEvent) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use EntityOperationCompletedEvent.ProtoReflect.Descriptor instead.

func (*EntityOperationCompletedEvent) GetOutput added in v0.7.0 

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

func (*EntityOperationCompletedEvent) GetRequestId added in v0.7.0 

func (x *EntityOperationCompletedEvent) GetRequestId() string

func (*EntityOperationCompletedEvent) ProtoMessage added in v0.7.0 

func (*EntityOperationCompletedEvent) ProtoMessage()

func (*EntityOperationCompletedEvent) ProtoReflect added in v0.7.0 

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

func (*EntityOperationCompletedEvent) Reset added in v0.7.0 

func (x *EntityOperationCompletedEvent) Reset()

func (*EntityOperationCompletedEvent) String added in v0.7.0 

func (x *EntityOperationCompletedEvent) String() string

type EntityOperationFailedEvent added in v0.7.0 

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

func (*EntityOperationFailedEvent) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use EntityOperationFailedEvent.ProtoReflect.Descriptor instead.

func (*EntityOperationFailedEvent) GetFailureDetails added in v0.7.0 

func (x *EntityOperationFailedEvent) GetFailureDetails() *TaskFailureDetails

func (*EntityOperationFailedEvent) GetRequestId added in v0.7.0 

func (x *EntityOperationFailedEvent) GetRequestId() string

func (*EntityOperationFailedEvent) ProtoMessage added in v0.7.0 

func (*EntityOperationFailedEvent) ProtoMessage()

func (*EntityOperationFailedEvent) ProtoReflect added in v0.7.0 

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

func (*EntityOperationFailedEvent) Reset added in v0.7.0 

func (x *EntityOperationFailedEvent) Reset()

func (*EntityOperationFailedEvent) String added in v0.7.0 

func (x *EntityOperationFailedEvent) String() string

type EntityOperationSignaledEvent added in v0.7.0 

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

func (*EntityOperationSignaledEvent) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use EntityOperationSignaledEvent.ProtoReflect.Descriptor instead.

func (*EntityOperationSignaledEvent) GetInput added in v0.7.0 

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

func (*EntityOperationSignaledEvent) GetOperation added in v0.7.0 

func (x *EntityOperationSignaledEvent) GetOperation() string

func (*EntityOperationSignaledEvent) GetRequestId added in v0.7.0 

func (x *EntityOperationSignaledEvent) GetRequestId() string

func (*EntityOperationSignaledEvent) GetScheduledTime added in v0.7.0 

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

func (*EntityOperationSignaledEvent) GetTargetInstanceId added in v0.7.0 

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

func (*EntityOperationSignaledEvent) ProtoMessage added in v0.7.0 

func (*EntityOperationSignaledEvent) ProtoMessage()

func (*EntityOperationSignaledEvent) ProtoReflect added in v0.7.0 

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

func (*EntityOperationSignaledEvent) Reset added in v0.7.0 

func (x *EntityOperationSignaledEvent) Reset()

func (*EntityOperationSignaledEvent) String added in v0.7.0 

func (x *EntityOperationSignaledEvent) String() string

type EntityQuery 

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

func (*EntityQuery) Descriptor deprecated 

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

Deprecated: Use EntityQuery.ProtoReflect.Descriptor instead.

func (*EntityQuery) GetContinuationToken 

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

func (*EntityQuery) GetIncludeState 

func (x *EntityQuery) GetIncludeState() bool

func (*EntityQuery) GetIncludeTransient 

func (x *EntityQuery) GetIncludeTransient() bool

func (*EntityQuery) GetInstanceIdStartsWith 

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

func (*EntityQuery) GetLastModifiedFrom 

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

func (*EntityQuery) GetLastModifiedTo 

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

func (*EntityQuery) GetPageSize 

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

func (*EntityQuery) ProtoMessage 

func (*EntityQuery) ProtoMessage()

func (*EntityQuery) ProtoReflect 

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

func (*EntityQuery) Reset 

func (x *EntityQuery) Reset()

func (*EntityQuery) String 

func (x *EntityQuery) String() string

type EntityRequest added in v0.7.0 

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

func (*EntityRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use EntityRequest.ProtoReflect.Descriptor instead.

func (*EntityRequest) GetEntityState added in v0.7.0 

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

func (*EntityRequest) GetExecutionId added in v0.7.0 

func (x *EntityRequest) GetExecutionId() string

func (*EntityRequest) GetInstanceId added in v0.7.0 

func (x *EntityRequest) GetInstanceId() string

func (*EntityRequest) GetOperationRequests added in v0.7.0 

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

func (*EntityRequest) ProtoMessage added in v0.7.0 

func (*EntityRequest) ProtoMessage()

func (*EntityRequest) ProtoReflect added in v0.7.0 

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

func (*EntityRequest) Reset added in v0.7.0 

func (x *EntityRequest) Reset()

func (*EntityRequest) String added in v0.7.0 

func (x *EntityRequest) String() string

type EntityUnlockSentEvent added in v0.7.0 

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

func (*EntityUnlockSentEvent) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use EntityUnlockSentEvent.ProtoReflect.Descriptor instead.

func (*EntityUnlockSentEvent) GetCriticalSectionId added in v0.7.0 

func (x *EntityUnlockSentEvent) GetCriticalSectionId() string

func (*EntityUnlockSentEvent) GetParentInstanceId added in v0.7.0 

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

func (*EntityUnlockSentEvent) GetTargetInstanceId added in v0.7.0 

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

func (*EntityUnlockSentEvent) ProtoMessage added in v0.7.0 

func (*EntityUnlockSentEvent) ProtoMessage()

func (*EntityUnlockSentEvent) ProtoReflect added in v0.7.0 

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

func (*EntityUnlockSentEvent) Reset added in v0.7.0 

func (x *EntityUnlockSentEvent) Reset()

func (*EntityUnlockSentEvent) String added in v0.7.0 

func (x *EntityUnlockSentEvent) String() string

type EventRaisedEvent 

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

func (*EventRaisedEvent) Descriptor deprecated 

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

Deprecated: Use EventRaisedEvent.ProtoReflect.Descriptor instead.

func (*EventRaisedEvent) GetInput 

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

func (*EventRaisedEvent) GetName 

func (x *EventRaisedEvent) GetName() string

func (*EventRaisedEvent) ProtoMessage 

func (*EventRaisedEvent) ProtoMessage()

func (*EventRaisedEvent) ProtoReflect 

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

func (*EventRaisedEvent) Reset 

func (x *EventRaisedEvent) Reset()

func (*EventRaisedEvent) String 

func (x *EventRaisedEvent) String() string

type EventSentEvent 

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

func (*EventSentEvent) Descriptor deprecated 

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

Deprecated: Use EventSentEvent.ProtoReflect.Descriptor instead.

func (*EventSentEvent) GetInput 

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

func (*EventSentEvent) GetInstanceId 

func (x *EventSentEvent) GetInstanceId() string

func (*EventSentEvent) GetName 

func (x *EventSentEvent) GetName() string

func (*EventSentEvent) ProtoMessage 

func (*EventSentEvent) ProtoMessage()

func (*EventSentEvent) ProtoReflect 

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

func (*EventSentEvent) Reset 

func (x *EventSentEvent) Reset()

func (*EventSentEvent) String 

func (x *EventSentEvent) String() string

type ExecutionCompletedEvent 

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

func (*ExecutionCompletedEvent) Descriptor deprecated 

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

Deprecated: Use ExecutionCompletedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionCompletedEvent) GetFailureDetails 

func (x *ExecutionCompletedEvent) GetFailureDetails() *TaskFailureDetails

func (*ExecutionCompletedEvent) GetOrchestrationStatus 

func (x *ExecutionCompletedEvent) GetOrchestrationStatus() OrchestrationStatus

func (*ExecutionCompletedEvent) GetResult 

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

func (*ExecutionCompletedEvent) ProtoMessage 

func (*ExecutionCompletedEvent) ProtoMessage()

func (*ExecutionCompletedEvent) ProtoReflect 

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

func (*ExecutionCompletedEvent) Reset 

func (x *ExecutionCompletedEvent) Reset()

func (*ExecutionCompletedEvent) String 

func (x *ExecutionCompletedEvent) String() string

type ExecutionResumedEvent 

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

func (*ExecutionResumedEvent) Descriptor deprecated 

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

Deprecated: Use ExecutionResumedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionResumedEvent) GetInput 

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

func (*ExecutionResumedEvent) ProtoMessage 

func (*ExecutionResumedEvent) ProtoMessage()

func (*ExecutionResumedEvent) ProtoReflect 

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

func (*ExecutionResumedEvent) Reset 

func (x *ExecutionResumedEvent) Reset()

func (*ExecutionResumedEvent) String 

func (x *ExecutionResumedEvent) String() string

type ExecutionStartedEvent 

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

func (*ExecutionStartedEvent) Descriptor deprecated 

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

Deprecated: Use ExecutionStartedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionStartedEvent) GetInput 

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

func (*ExecutionStartedEvent) GetName 

func (x *ExecutionStartedEvent) GetName() string

func (*ExecutionStartedEvent) GetOrchestrationInstance 

func (x *ExecutionStartedEvent) GetOrchestrationInstance() *OrchestrationInstance

func (*ExecutionStartedEvent) GetOrchestrationSpanID 

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

func (*ExecutionStartedEvent) GetParentInstance 

func (x *ExecutionStartedEvent) GetParentInstance() *ParentInstanceInfo

func (*ExecutionStartedEvent) GetParentTraceContext 

func (x *ExecutionStartedEvent) GetParentTraceContext() *TraceContext

func (*ExecutionStartedEvent) GetScheduledStartTimestamp 

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

func (*ExecutionStartedEvent) GetTags added in v0.7.0 

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

func (*ExecutionStartedEvent) GetVersion 

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

func (*ExecutionStartedEvent) ProtoMessage 

func (*ExecutionStartedEvent) ProtoMessage()

func (*ExecutionStartedEvent) ProtoReflect 

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

func (*ExecutionStartedEvent) Reset 

func (x *ExecutionStartedEvent) Reset()

func (*ExecutionStartedEvent) String 

func (x *ExecutionStartedEvent) String() string

type ExecutionSuspendedEvent 

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

func (*ExecutionSuspendedEvent) Descriptor deprecated 

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

Deprecated: Use ExecutionSuspendedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionSuspendedEvent) GetInput 

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

func (*ExecutionSuspendedEvent) ProtoMessage 

func (*ExecutionSuspendedEvent) ProtoMessage()

func (*ExecutionSuspendedEvent) ProtoReflect 

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

func (*ExecutionSuspendedEvent) Reset 

func (x *ExecutionSuspendedEvent) Reset()

func (*ExecutionSuspendedEvent) String 

func (x *ExecutionSuspendedEvent) String() string

type ExecutionTerminatedEvent 

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

func (*ExecutionTerminatedEvent) Descriptor deprecated 

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

Deprecated: Use ExecutionTerminatedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionTerminatedEvent) GetInput 

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

func (*ExecutionTerminatedEvent) GetRecurse 

func (x *ExecutionTerminatedEvent) GetRecurse() bool

func (*ExecutionTerminatedEvent) ProtoMessage 

func (*ExecutionTerminatedEvent) ProtoMessage()

func (*ExecutionTerminatedEvent) ProtoReflect 

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

func (*ExecutionTerminatedEvent) Reset 

func (x *ExecutionTerminatedEvent) Reset()

func (*ExecutionTerminatedEvent) String 

func (x *ExecutionTerminatedEvent) String() string

type GenericEvent 

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

func (*GenericEvent) Descriptor deprecated 

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

Deprecated: Use GenericEvent.ProtoReflect.Descriptor instead.

func (*GenericEvent) GetData 

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

func (*GenericEvent) ProtoMessage 

func (*GenericEvent) ProtoMessage()

func (*GenericEvent) ProtoReflect 

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

func (*GenericEvent) Reset 

func (x *GenericEvent) Reset()

func (*GenericEvent) String 

func (x *GenericEvent) String() string

type GetEntityRequest 

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

func (*GetEntityRequest) Descriptor deprecated 

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

Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.

func (*GetEntityRequest) GetIncludeState 

func (x *GetEntityRequest) GetIncludeState() bool

func (*GetEntityRequest) GetInstanceId 

func (x *GetEntityRequest) GetInstanceId() string

func (*GetEntityRequest) ProtoMessage 

func (*GetEntityRequest) ProtoMessage()

func (*GetEntityRequest) ProtoReflect 

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

func (*GetEntityRequest) Reset 

func (x *GetEntityRequest) Reset()

func (*GetEntityRequest) String 

func (x *GetEntityRequest) String() string

type GetEntityResponse 

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

func (*GetEntityResponse) Descriptor deprecated 

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

Deprecated: Use GetEntityResponse.ProtoReflect.Descriptor instead.

func (*GetEntityResponse) GetEntity 

func (x *GetEntityResponse) GetEntity() *EntityMetadata

func (*GetEntityResponse) GetExists 

func (x *GetEntityResponse) GetExists() bool

func (*GetEntityResponse) ProtoMessage 

func (*GetEntityResponse) ProtoMessage()

func (*GetEntityResponse) ProtoReflect 

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

func (*GetEntityResponse) Reset 

func (x *GetEntityResponse) Reset()

func (*GetEntityResponse) String 

func (x *GetEntityResponse) String() string

type GetInstanceRequest 

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

func (*GetInstanceRequest) Descriptor deprecated 

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

Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceRequest) GetGetInputsAndOutputs 

func (x *GetInstanceRequest) GetGetInputsAndOutputs() bool

func (*GetInstanceRequest) GetInstanceId 

func (x *GetInstanceRequest) GetInstanceId() string

func (*GetInstanceRequest) ProtoMessage 

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) ProtoReflect 

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

func (*GetInstanceRequest) Reset 

func (x *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String 

func (x *GetInstanceRequest) String() string

type GetInstanceResponse 

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

func (*GetInstanceResponse) Descriptor deprecated 

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

Deprecated: Use GetInstanceResponse.ProtoReflect.Descriptor instead.

func (*GetInstanceResponse) GetExists 

func (x *GetInstanceResponse) GetExists() bool

func (*GetInstanceResponse) GetOrchestrationState 

func (x *GetInstanceResponse) GetOrchestrationState() *OrchestrationState

func (*GetInstanceResponse) ProtoMessage 

func (*GetInstanceResponse) ProtoMessage()

func (*GetInstanceResponse) ProtoReflect 

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

func (*GetInstanceResponse) Reset 

func (x *GetInstanceResponse) Reset()

func (*GetInstanceResponse) String 

func (x *GetInstanceResponse) String() string

type GetMetricsRequest added in v0.7.0 

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

Request payload for fetching backend metrics.

func (*GetMetricsRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetMetricsRequest) ProtoMessage added in v0.7.0 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) ProtoReflect added in v0.7.0 

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

func (*GetMetricsRequest) Reset added in v0.7.0 

func (x *GetMetricsRequest) Reset()

func (*GetMetricsRequest) String added in v0.7.0 

func (x *GetMetricsRequest) String() string

type GetMetricsResponse added in v0.7.0 

type GetMetricsResponse struct {

	// The current metrics for the backend service.
	Metrics *BackendMetrics `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

Response payload for fetching backend metrics

func (*GetMetricsResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use GetMetricsResponse.ProtoReflect.Descriptor instead.

func (*GetMetricsResponse) GetMetrics added in v0.7.0 

func (x *GetMetricsResponse) GetMetrics() *BackendMetrics

func (*GetMetricsResponse) ProtoMessage added in v0.7.0 

func (*GetMetricsResponse) ProtoMessage()

func (*GetMetricsResponse) ProtoReflect added in v0.7.0 

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

func (*GetMetricsResponse) Reset added in v0.7.0 

func (x *GetMetricsResponse) Reset()

func (*GetMetricsResponse) String added in v0.7.0 

func (x *GetMetricsResponse) String() string

type GetOrchestrationRuntimeStateRequest 

type GetOrchestrationRuntimeStateRequest struct {

	// The ID of the target orchestration instance.
	Instance *OrchestrationInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

Request parameters for fetching orchestration runtime state.

func (*GetOrchestrationRuntimeStateRequest) Descriptor deprecated 

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

Deprecated: Use GetOrchestrationRuntimeStateRequest.ProtoReflect.Descriptor instead.

func (*GetOrchestrationRuntimeStateRequest) GetInstance 

func (x *GetOrchestrationRuntimeStateRequest) GetInstance() *OrchestrationInstance

func (*GetOrchestrationRuntimeStateRequest) ProtoMessage 

func (*GetOrchestrationRuntimeStateRequest) ProtoMessage()

func (*GetOrchestrationRuntimeStateRequest) ProtoReflect 

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

func (*GetOrchestrationRuntimeStateRequest) Reset 

func (x *GetOrchestrationRuntimeStateRequest) Reset()

func (*GetOrchestrationRuntimeStateRequest) String 

func (x *GetOrchestrationRuntimeStateRequest) String() string

type GetOrchestrationRuntimeStateResponse 

type GetOrchestrationRuntimeStateResponse struct {

	// The existing history events for the target orchestration instance.
	History []*HistoryEvent `protobuf:"bytes,1,rep,name=history,proto3" json:"history,omitempty"`
	// contains filtered or unexported fields
}

Response payload returned when fetching orchestration runtime state.

func (*GetOrchestrationRuntimeStateResponse) Descriptor deprecated 

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

Deprecated: Use GetOrchestrationRuntimeStateResponse.ProtoReflect.Descriptor instead.

func (*GetOrchestrationRuntimeStateResponse) GetHistory 

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

func (*GetOrchestrationRuntimeStateResponse) ProtoMessage 

func (*GetOrchestrationRuntimeStateResponse) ProtoMessage()

func (*GetOrchestrationRuntimeStateResponse) ProtoReflect 

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

func (*GetOrchestrationRuntimeStateResponse) Reset 

func (x *GetOrchestrationRuntimeStateResponse) Reset()

func (*GetOrchestrationRuntimeStateResponse) String 

func (x *GetOrchestrationRuntimeStateResponse) String() string

type GetWorkItemsRequest 

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

func (*GetWorkItemsRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkItemsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkItemsRequest) GetCapabilities added in v0.7.0 

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

func (*GetWorkItemsRequest) GetMaxConcurrentActivityWorkItems added in v0.7.0 

func (x *GetWorkItemsRequest) GetMaxConcurrentActivityWorkItems() int32

func (*GetWorkItemsRequest) GetMaxConcurrentEntityWorkItems added in v0.7.0 

func (x *GetWorkItemsRequest) GetMaxConcurrentEntityWorkItems() int32

func (*GetWorkItemsRequest) GetMaxConcurrentOrchestrationWorkItems added in v0.7.0 

func (x *GetWorkItemsRequest) GetMaxConcurrentOrchestrationWorkItems() int32

func (*GetWorkItemsRequest) ProtoMessage 

func (*GetWorkItemsRequest) ProtoMessage()

func (*GetWorkItemsRequest) ProtoReflect 

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

func (*GetWorkItemsRequest) Reset 

func (x *GetWorkItemsRequest) Reset()

func (*GetWorkItemsRequest) String 

func (x *GetWorkItemsRequest) String() string

type HealthPing 

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

func (*HealthPing) Descriptor deprecated 

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

Deprecated: Use HealthPing.ProtoReflect.Descriptor instead.

func (*HealthPing) ProtoMessage 

func (*HealthPing) ProtoMessage()

func (*HealthPing) ProtoReflect 

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

func (*HealthPing) Reset 

func (x *HealthPing) Reset()

func (*HealthPing) String 

func (x *HealthPing) String() string

type HistoryChunk added in v0.7.0 

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

func (*HistoryChunk) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use HistoryChunk.ProtoReflect.Descriptor instead.

func (*HistoryChunk) GetEvents added in v0.7.0 

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

func (*HistoryChunk) ProtoMessage added in v0.7.0 

func (*HistoryChunk) ProtoMessage()

func (*HistoryChunk) ProtoReflect added in v0.7.0 

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

func (*HistoryChunk) Reset added in v0.7.0 

func (x *HistoryChunk) Reset()

func (*HistoryChunk) String added in v0.7.0 

func (x *HistoryChunk) String() string

type HistoryEvent 

type HistoryEvent struct {
	EventId   int32                  `protobuf:"varint,1,opt,name=eventId,proto3" json:"eventId,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are 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
	//	*HistoryEvent_EntityOperationSignaled
	//	*HistoryEvent_EntityOperationCalled
	//	*HistoryEvent_EntityOperationCompleted
	//	*HistoryEvent_EntityOperationFailed
	//	*HistoryEvent_EntityLockRequested
	//	*HistoryEvent_EntityLockGranted
	//	*HistoryEvent_EntityUnlockSent
	EventType isHistoryEvent_EventType `protobuf_oneof:"eventType"`
	Router    *TaskRouter              `protobuf:"bytes,30,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryEvent) Descriptor deprecated 

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

Deprecated: Use HistoryEvent.ProtoReflect.Descriptor instead.

func (*HistoryEvent) GetContinueAsNew 

func (x *HistoryEvent) GetContinueAsNew() *ContinueAsNewEvent

func (*HistoryEvent) GetEntityLockGranted added in v0.7.0 

func (x *HistoryEvent) GetEntityLockGranted() *EntityLockGrantedEvent

func (*HistoryEvent) GetEntityLockRequested added in v0.7.0 

func (x *HistoryEvent) GetEntityLockRequested() *EntityLockRequestedEvent

func (*HistoryEvent) GetEntityOperationCalled added in v0.7.0 

func (x *HistoryEvent) GetEntityOperationCalled() *EntityOperationCalledEvent

func (*HistoryEvent) GetEntityOperationCompleted added in v0.7.0 

func (x *HistoryEvent) GetEntityOperationCompleted() *EntityOperationCompletedEvent

func (*HistoryEvent) GetEntityOperationFailed added in v0.7.0 

func (x *HistoryEvent) GetEntityOperationFailed() *EntityOperationFailedEvent

func (*HistoryEvent) GetEntityOperationSignaled added in v0.7.0 

func (x *HistoryEvent) GetEntityOperationSignaled() *EntityOperationSignaledEvent

func (*HistoryEvent) GetEntityUnlockSent added in v0.7.0 

func (x *HistoryEvent) GetEntityUnlockSent() *EntityUnlockSentEvent

func (*HistoryEvent) GetEventId 

func (x *HistoryEvent) GetEventId() int32

func (*HistoryEvent) GetEventRaised 

func (x *HistoryEvent) GetEventRaised() *EventRaisedEvent

func (*HistoryEvent) GetEventSent 

func (x *HistoryEvent) GetEventSent() *EventSentEvent

func (*HistoryEvent) GetEventType 

func (m *HistoryEvent) GetEventType() isHistoryEvent_EventType

func (*HistoryEvent) GetExecutionCompleted 

func (x *HistoryEvent) GetExecutionCompleted() *ExecutionCompletedEvent

func (*HistoryEvent) GetExecutionResumed 

func (x *HistoryEvent) GetExecutionResumed() *ExecutionResumedEvent

func (*HistoryEvent) GetExecutionStarted 

func (x *HistoryEvent) GetExecutionStarted() *ExecutionStartedEvent

func (*HistoryEvent) GetExecutionSuspended 

func (x *HistoryEvent) GetExecutionSuspended() *ExecutionSuspendedEvent

func (*HistoryEvent) GetExecutionTerminated 

func (x *HistoryEvent) GetExecutionTerminated() *ExecutionTerminatedEvent

func (*HistoryEvent) GetGenericEvent 

func (x *HistoryEvent) GetGenericEvent() *GenericEvent

func (*HistoryEvent) GetHistoryState 

func (x *HistoryEvent) GetHistoryState() *HistoryStateEvent

func (*HistoryEvent) GetOrchestratorCompleted 

func (x *HistoryEvent) GetOrchestratorCompleted() *OrchestratorCompletedEvent

func (*HistoryEvent) GetOrchestratorStarted 

func (x *HistoryEvent) GetOrchestratorStarted() *OrchestratorStartedEvent

func (*HistoryEvent) GetRouter added in v0.8.0 

func (x *HistoryEvent) GetRouter() *TaskRouter

func (*HistoryEvent) GetSubOrchestrationInstanceCompleted 

func (x *HistoryEvent) GetSubOrchestrationInstanceCompleted() *SubOrchestrationInstanceCompletedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceCreated 

func (x *HistoryEvent) GetSubOrchestrationInstanceCreated() *SubOrchestrationInstanceCreatedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceFailed 

func (x *HistoryEvent) GetSubOrchestrationInstanceFailed() *SubOrchestrationInstanceFailedEvent

func (*HistoryEvent) GetTaskCompleted 

func (x *HistoryEvent) GetTaskCompleted() *TaskCompletedEvent

func (*HistoryEvent) GetTaskFailed 

func (x *HistoryEvent) GetTaskFailed() *TaskFailedEvent

func (*HistoryEvent) GetTaskScheduled 

func (x *HistoryEvent) GetTaskScheduled() *TaskScheduledEvent

func (*HistoryEvent) GetTimerCreated 

func (x *HistoryEvent) GetTimerCreated() *TimerCreatedEvent

func (*HistoryEvent) GetTimerFired 

func (x *HistoryEvent) GetTimerFired() *TimerFiredEvent

func (*HistoryEvent) GetTimestamp 

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

func (*HistoryEvent) ProtoMessage 

func (*HistoryEvent) ProtoMessage()

func (*HistoryEvent) ProtoReflect 

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

func (*HistoryEvent) Reset 

func (x *HistoryEvent) Reset()

func (*HistoryEvent) String 

func (x *HistoryEvent) String() string

type HistoryEvent_ContinueAsNew 

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

type HistoryEvent_EntityLockGranted added in v0.7.0 

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

type HistoryEvent_EntityLockRequested added in v0.7.0 

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

type HistoryEvent_EntityOperationCalled added in v0.7.0 

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

type HistoryEvent_EntityOperationCompleted added in v0.7.0 

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

type HistoryEvent_EntityOperationFailed added in v0.7.0 

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

type HistoryEvent_EntityOperationSignaled added in v0.7.0 

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

type HistoryEvent_EntityUnlockSent added in v0.7.0 

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

type HistoryEvent_EventRaised 

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

type HistoryEvent_EventSent 

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

type HistoryEvent_ExecutionCompleted 

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

type HistoryEvent_ExecutionResumed 

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

type HistoryEvent_ExecutionStarted 

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

type HistoryEvent_ExecutionSuspended 

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

type HistoryEvent_ExecutionTerminated 

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

type HistoryEvent_GenericEvent 

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

type HistoryEvent_HistoryState 

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

type HistoryEvent_OrchestratorCompleted 

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

type HistoryEvent_OrchestratorStarted 

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

type HistoryEvent_SubOrchestrationInstanceCompleted 

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

type HistoryEvent_SubOrchestrationInstanceCreated 

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

type HistoryEvent_SubOrchestrationInstanceFailed 

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

type HistoryEvent_TaskCompleted 

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

type HistoryEvent_TaskFailed 

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

type HistoryEvent_TaskScheduled 

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

type HistoryEvent_TimerCreated 

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

type HistoryEvent_TimerFired 

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

type HistoryStateEvent 

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

func (*HistoryStateEvent) Descriptor deprecated 

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

Deprecated: Use HistoryStateEvent.ProtoReflect.Descriptor instead.

func (*HistoryStateEvent) GetOrchestrationState 

func (x *HistoryStateEvent) GetOrchestrationState() *OrchestrationState

func (*HistoryStateEvent) ProtoMessage 

func (*HistoryStateEvent) ProtoMessage()

func (*HistoryStateEvent) ProtoReflect 

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

func (*HistoryStateEvent) Reset 

func (x *HistoryStateEvent) Reset()

func (*HistoryStateEvent) String 

func (x *HistoryStateEvent) String() string

type InstanceQuery 

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

func (*InstanceQuery) Descriptor deprecated 

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

Deprecated: Use InstanceQuery.ProtoReflect.Descriptor instead.

func (*InstanceQuery) GetContinuationToken 

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

func (*InstanceQuery) GetCreatedTimeFrom 

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

func (*InstanceQuery) GetCreatedTimeTo 

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

func (*InstanceQuery) GetFetchInputsAndOutputs 

func (x *InstanceQuery) GetFetchInputsAndOutputs() bool

func (*InstanceQuery) GetInstanceIdPrefix 

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

func (*InstanceQuery) GetMaxInstanceCount 

func (x *InstanceQuery) GetMaxInstanceCount() int32

func (*InstanceQuery) GetRuntimeStatus 

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

func (*InstanceQuery) GetTaskHubNames 

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

func (*InstanceQuery) ProtoMessage 

func (*InstanceQuery) ProtoMessage()

func (*InstanceQuery) ProtoReflect 

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

func (*InstanceQuery) Reset 

func (x *InstanceQuery) Reset()

func (*InstanceQuery) String 

func (x *InstanceQuery) String() string

type OperationAction 

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

func (*OperationAction) Descriptor deprecated 

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

Deprecated: Use OperationAction.ProtoReflect.Descriptor instead.

func (*OperationAction) GetId 

func (x *OperationAction) GetId() int32

func (*OperationAction) GetOperationActionType 

func (m *OperationAction) GetOperationActionType() isOperationAction_OperationActionType

func (*OperationAction) GetSendSignal 

func (x *OperationAction) GetSendSignal() *SendSignalAction

func (*OperationAction) GetStartNewOrchestration 

func (x *OperationAction) GetStartNewOrchestration() *StartNewOrchestrationAction

func (*OperationAction) ProtoMessage 

func (*OperationAction) ProtoMessage()

func (*OperationAction) ProtoReflect 

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

func (*OperationAction) Reset 

func (x *OperationAction) Reset()

func (*OperationAction) String 

func (x *OperationAction) String() string

type OperationAction_SendSignal 

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

type OperationAction_StartNewOrchestration 

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

type OperationInfo added in v0.7.0 

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

func (*OperationInfo) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use OperationInfo.ProtoReflect.Descriptor instead.

func (*OperationInfo) GetRequestId added in v0.7.0 

func (x *OperationInfo) GetRequestId() string

func (*OperationInfo) GetResponseDestination added in v0.7.0 

func (x *OperationInfo) GetResponseDestination() *OrchestrationInstance

func (*OperationInfo) ProtoMessage added in v0.7.0 

func (*OperationInfo) ProtoMessage()

func (*OperationInfo) ProtoReflect added in v0.7.0 

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

func (*OperationInfo) Reset added in v0.7.0 

func (x *OperationInfo) Reset()

func (*OperationInfo) String added in v0.7.0 

func (x *OperationInfo) String() string

type OperationRequest 

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

func (*OperationRequest) Descriptor deprecated 

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

Deprecated: Use OperationRequest.ProtoReflect.Descriptor instead.

func (*OperationRequest) GetInput 

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

func (*OperationRequest) GetOperation 

func (x *OperationRequest) GetOperation() string

func (*OperationRequest) GetRequestId 

func (x *OperationRequest) GetRequestId() string

func (*OperationRequest) ProtoMessage 

func (*OperationRequest) ProtoMessage()

func (*OperationRequest) ProtoReflect 

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

func (*OperationRequest) Reset 

func (x *OperationRequest) Reset()

func (*OperationRequest) String 

func (x *OperationRequest) String() string

type OperationResult 

type OperationResult struct {

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

func (*OperationResult) Descriptor deprecated 

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

Deprecated: Use OperationResult.ProtoReflect.Descriptor instead.

func (*OperationResult) GetFailure 

func (x *OperationResult) GetFailure() *OperationResultFailure

func (*OperationResult) GetResultType 

func (m *OperationResult) GetResultType() isOperationResult_ResultType

func (*OperationResult) GetSuccess 

func (x *OperationResult) GetSuccess() *OperationResultSuccess

func (*OperationResult) ProtoMessage 

func (*OperationResult) ProtoMessage()

func (*OperationResult) ProtoReflect 

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

func (*OperationResult) Reset 

func (x *OperationResult) Reset()

func (*OperationResult) String 

func (x *OperationResult) String() string

type OperationResultFailure 

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

func (*OperationResultFailure) Descriptor deprecated 

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

Deprecated: Use OperationResultFailure.ProtoReflect.Descriptor instead.

func (*OperationResultFailure) GetFailureDetails 

func (x *OperationResultFailure) GetFailureDetails() *TaskFailureDetails

func (*OperationResultFailure) ProtoMessage 

func (*OperationResultFailure) ProtoMessage()

func (*OperationResultFailure) ProtoReflect 

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

func (*OperationResultFailure) Reset 

func (x *OperationResultFailure) Reset()

func (*OperationResultFailure) String 

func (x *OperationResultFailure) String() string

type OperationResultSuccess 

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

func (*OperationResultSuccess) Descriptor deprecated 

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

Deprecated: Use OperationResultSuccess.ProtoReflect.Descriptor instead.

func (*OperationResultSuccess) GetResult 

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

func (*OperationResultSuccess) ProtoMessage 

func (*OperationResultSuccess) ProtoMessage()

func (*OperationResultSuccess) ProtoReflect 

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

func (*OperationResultSuccess) Reset 

func (x *OperationResultSuccess) Reset()

func (*OperationResultSuccess) String 

func (x *OperationResultSuccess) String() string

type OperationResult_Failure 

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

type OperationResult_Success 

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

type OrchestrationIdReusePolicy 

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

func (*OrchestrationIdReusePolicy) Descriptor deprecated 

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

Deprecated: Use OrchestrationIdReusePolicy.ProtoReflect.Descriptor instead.

func (*OrchestrationIdReusePolicy) GetAction 

func (x *OrchestrationIdReusePolicy) GetAction() CreateOrchestrationAction

func (*OrchestrationIdReusePolicy) GetOperationStatus 

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

func (*OrchestrationIdReusePolicy) ProtoMessage 

func (*OrchestrationIdReusePolicy) ProtoMessage()

func (*OrchestrationIdReusePolicy) ProtoReflect 

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

func (*OrchestrationIdReusePolicy) Reset 

func (x *OrchestrationIdReusePolicy) Reset()

func (*OrchestrationIdReusePolicy) String 

func (x *OrchestrationIdReusePolicy) String() string

type OrchestrationInstance 

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

func (*OrchestrationInstance) Descriptor deprecated 

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

Deprecated: Use OrchestrationInstance.ProtoReflect.Descriptor instead.

func (*OrchestrationInstance) GetExecutionId 

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

func (*OrchestrationInstance) GetInstanceId 

func (x *OrchestrationInstance) GetInstanceId() string

func (*OrchestrationInstance) ProtoMessage 

func (*OrchestrationInstance) ProtoMessage()

func (*OrchestrationInstance) ProtoReflect 

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

func (*OrchestrationInstance) Reset 

func (x *OrchestrationInstance) Reset()

func (*OrchestrationInstance) String 

func (x *OrchestrationInstance) String() string

type OrchestrationMetadata 

type OrchestrationMetadata 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"`
	RuntimeStatus    OrchestrationStatus     `protobuf:"varint,3,opt,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	CreatedAt        *timestamppb.Timestamp  `protobuf:"bytes,4,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	LastUpdatedAt    *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=lastUpdatedAt,proto3" json:"lastUpdatedAt,omitempty"`
	Input            *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=input,proto3" json:"input,omitempty"`
	Output           *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=output,proto3" json:"output,omitempty"`
	CustomStatus     *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	FailureDetails   *TaskFailureDetails     `protobuf:"bytes,9,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	CompletedAt      *timestamppb.Timestamp  `protobuf:"bytes,10,opt,name=completedAt,proto3" json:"completedAt,omitempty"`
	ParentInstanceId string                  `protobuf:"bytes,11,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestrationMetadata) Descriptor deprecated 

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

Deprecated: Use OrchestrationMetadata.ProtoReflect.Descriptor instead.

func (*OrchestrationMetadata) GetCompletedAt added in v0.6.4 

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

func (*OrchestrationMetadata) GetCreatedAt 

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

func (*OrchestrationMetadata) GetCustomStatus 

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

func (*OrchestrationMetadata) GetFailureDetails 

func (x *OrchestrationMetadata) GetFailureDetails() *TaskFailureDetails

func (*OrchestrationMetadata) GetInput 

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

func (*OrchestrationMetadata) GetInstanceId 

func (x *OrchestrationMetadata) GetInstanceId() string

func (*OrchestrationMetadata) GetLastUpdatedAt 

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

func (*OrchestrationMetadata) GetName 

func (x *OrchestrationMetadata) GetName() string

func (*OrchestrationMetadata) GetOutput 

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

func (*OrchestrationMetadata) GetParentInstanceId added in v0.6.4 

func (x *OrchestrationMetadata) GetParentInstanceId() string

func (*OrchestrationMetadata) GetRuntimeStatus 

func (x *OrchestrationMetadata) GetRuntimeStatus() OrchestrationStatus

func (*OrchestrationMetadata) ProtoMessage 

func (*OrchestrationMetadata) ProtoMessage()

func (*OrchestrationMetadata) ProtoReflect 

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

func (*OrchestrationMetadata) Reset 

func (x *OrchestrationMetadata) Reset()

func (*OrchestrationMetadata) String 

func (x *OrchestrationMetadata) String() string

type OrchestrationRuntimeState 

type OrchestrationRuntimeState struct {
	InstanceId      string                              `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	NewEvents       []*HistoryEvent                     `protobuf:"bytes,2,rep,name=newEvents,proto3" json:"newEvents,omitempty"`
	OldEvents       []*HistoryEvent                     `protobuf:"bytes,3,rep,name=oldEvents,proto3" json:"oldEvents,omitempty"`
	PendingTasks    []*HistoryEvent                     `protobuf:"bytes,4,rep,name=pendingTasks,proto3" json:"pendingTasks,omitempty"`
	PendingTimers   []*HistoryEvent                     `protobuf:"bytes,5,rep,name=pendingTimers,proto3" json:"pendingTimers,omitempty"`
	PendingMessages []*OrchestrationRuntimeStateMessage `protobuf:"bytes,6,rep,name=pendingMessages,proto3" json:"pendingMessages,omitempty"`
	StartEvent      *ExecutionStartedEvent              `protobuf:"bytes,7,opt,name=startEvent,proto3" json:"startEvent,omitempty"`
	CompletedEvent  *ExecutionCompletedEvent            `protobuf:"bytes,8,opt,name=completedEvent,proto3" json:"completedEvent,omitempty"`
	CreatedTime     *timestamppb.Timestamp              `protobuf:"bytes,9,opt,name=createdTime,proto3" json:"createdTime,omitempty"`
	LastUpdatedTime *timestamppb.Timestamp              `protobuf:"bytes,10,opt,name=lastUpdatedTime,proto3" json:"lastUpdatedTime,omitempty"`
	CompletedTime   *timestamppb.Timestamp              `protobuf:"bytes,11,opt,name=completedTime,proto3" json:"completedTime,omitempty"`
	ContinuedAsNew  bool                                `protobuf:"varint,12,opt,name=continuedAsNew,proto3" json:"continuedAsNew,omitempty"`
	IsSuspended     bool                                `protobuf:"varint,13,opt,name=isSuspended,proto3" json:"isSuspended,omitempty"`
	CustomStatus    *wrapperspb.StringValue             `protobuf:"bytes,14,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	// contains filtered or unexported fields
}

OrchestrationRuntimeState holds the current state for an orchestration.

func (*OrchestrationRuntimeState) Descriptor deprecated 

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

Deprecated: Use OrchestrationRuntimeState.ProtoReflect.Descriptor instead.

func (*OrchestrationRuntimeState) GetCompletedEvent 

func (x *OrchestrationRuntimeState) GetCompletedEvent() *ExecutionCompletedEvent

func (*OrchestrationRuntimeState) GetCompletedTime 

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

func (*OrchestrationRuntimeState) GetContinuedAsNew 

func (x *OrchestrationRuntimeState) GetContinuedAsNew() bool

func (*OrchestrationRuntimeState) GetCreatedTime 

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

func (*OrchestrationRuntimeState) GetCustomStatus 

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

func (*OrchestrationRuntimeState) GetInstanceId 

func (x *OrchestrationRuntimeState) GetInstanceId() string

func (*OrchestrationRuntimeState) GetIsSuspended 

func (x *OrchestrationRuntimeState) GetIsSuspended() bool

func (*OrchestrationRuntimeState) GetLastUpdatedTime 

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

func (*OrchestrationRuntimeState) GetNewEvents 

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

func (*OrchestrationRuntimeState) GetOldEvents 

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

func (*OrchestrationRuntimeState) GetPendingMessages 

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

func (*OrchestrationRuntimeState) GetPendingTasks 

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

func (*OrchestrationRuntimeState) GetPendingTimers 

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

func (*OrchestrationRuntimeState) GetStartEvent 

func (x *OrchestrationRuntimeState) GetStartEvent() *ExecutionStartedEvent

func (*OrchestrationRuntimeState) ProtoMessage 

func (*OrchestrationRuntimeState) ProtoMessage()

func (*OrchestrationRuntimeState) ProtoReflect 

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

func (*OrchestrationRuntimeState) Reset 

func (x *OrchestrationRuntimeState) Reset()

func (*OrchestrationRuntimeState) String 

func (x *OrchestrationRuntimeState) String() string

type OrchestrationRuntimeStateMessage 

type OrchestrationRuntimeStateMessage struct {
	HistoryEvent     *HistoryEvent `protobuf:"bytes,1,opt,name=historyEvent,proto3" json:"historyEvent,omitempty"`
	TargetInstanceID string        `protobuf:"bytes,2,opt,name=TargetInstanceID,proto3" json:"TargetInstanceID,omitempty"`
	// contains filtered or unexported fields
}

OrchestrationRuntimeStateMessage holds an OrchestratorMessage and the target instance ID.

func (*OrchestrationRuntimeStateMessage) Descriptor deprecated 

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

Deprecated: Use OrchestrationRuntimeStateMessage.ProtoReflect.Descriptor instead.

func (*OrchestrationRuntimeStateMessage) GetHistoryEvent 

func (x *OrchestrationRuntimeStateMessage) GetHistoryEvent() *HistoryEvent

func (*OrchestrationRuntimeStateMessage) GetTargetInstanceID 

func (x *OrchestrationRuntimeStateMessage) GetTargetInstanceID() string

func (*OrchestrationRuntimeStateMessage) ProtoMessage 

func (*OrchestrationRuntimeStateMessage) ProtoMessage()

func (*OrchestrationRuntimeStateMessage) ProtoReflect 

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

func (*OrchestrationRuntimeStateMessage) Reset 

func (x *OrchestrationRuntimeStateMessage) Reset()

func (*OrchestrationRuntimeStateMessage) String 

func (x *OrchestrationRuntimeStateMessage) String() string

type OrchestrationState 

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

func (*OrchestrationState) Descriptor deprecated 

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

Deprecated: Use OrchestrationState.ProtoReflect.Descriptor instead.

func (*OrchestrationState) GetCompletedTimestamp 

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

func (*OrchestrationState) GetCreatedTimestamp 

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

func (*OrchestrationState) GetCustomStatus 

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

func (*OrchestrationState) GetExecutionId 

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

func (*OrchestrationState) GetFailureDetails 

func (x *OrchestrationState) GetFailureDetails() *TaskFailureDetails

func (*OrchestrationState) GetInput 

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

func (*OrchestrationState) GetInstanceId 

func (x *OrchestrationState) GetInstanceId() string

func (*OrchestrationState) GetLastUpdatedTimestamp 

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

func (*OrchestrationState) GetName 

func (x *OrchestrationState) GetName() string

func (*OrchestrationState) GetOrchestrationStatus 

func (x *OrchestrationState) GetOrchestrationStatus() OrchestrationStatus

func (*OrchestrationState) GetOutput 

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

func (*OrchestrationState) GetParentInstanceId 

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

func (*OrchestrationState) GetScheduledStartTimestamp 

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

func (*OrchestrationState) GetTags added in v0.7.0 

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

func (*OrchestrationState) GetVersion 

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

func (*OrchestrationState) ProtoMessage 

func (*OrchestrationState) ProtoMessage()

func (*OrchestrationState) ProtoReflect 

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

func (*OrchestrationState) Reset 

func (x *OrchestrationState) Reset()

func (*OrchestrationState) String 

func (x *OrchestrationState) String() string

type OrchestrationStatus 

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

func (OrchestrationStatus) Descriptor 

func (OrchestrationStatus) Descriptor() protoreflect.EnumDescriptor

func (OrchestrationStatus) Enum 

func (x OrchestrationStatus) Enum() *OrchestrationStatus

func (OrchestrationStatus) EnumDescriptor deprecated 

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

Deprecated: Use OrchestrationStatus.Descriptor instead.

func (OrchestrationStatus) Number 

func (x OrchestrationStatus) Number() protoreflect.EnumNumber

func (OrchestrationStatus) String 

func (x OrchestrationStatus) String() string

func (OrchestrationStatus) Type 

func (OrchestrationStatus) Type() protoreflect.EnumType

type 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
	//	*OrchestratorAction_SendEntityMessage
	OrchestratorActionType isOrchestratorAction_OrchestratorActionType `protobuf_oneof:"orchestratorActionType"`
	Router                 *TaskRouter                                 `protobuf:"bytes,9,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// 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) GetRouter added in v0.8.0 

func (x *OrchestratorAction) GetRouter() *TaskRouter

func (*OrchestratorAction) GetScheduleTask 

func (x *OrchestratorAction) GetScheduleTask() *ScheduleTaskAction

func (*OrchestratorAction) GetSendEntityMessage added in v0.7.0 

func (x *OrchestratorAction) GetSendEntityMessage() *SendEntityMessageAction

func (*OrchestratorAction) GetSendEvent 

func (x *OrchestratorAction) GetSendEvent() *SendEventAction

func (*OrchestratorAction) GetTerminateOrchestration 

func (x *OrchestratorAction) GetTerminateOrchestration() *TerminateOrchestrationAction

func (*OrchestratorAction) ProtoMessage 

func (*OrchestratorAction) ProtoMessage()

func (*OrchestratorAction) ProtoReflect 

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

func (*OrchestratorAction) Reset 

func (x *OrchestratorAction) Reset()

func (*OrchestratorAction) String 

func (x *OrchestratorAction) String() string

type OrchestratorAction_CompleteOrchestration 

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

type OrchestratorAction_CreateSubOrchestration 

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

type OrchestratorAction_CreateTimer 

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

type OrchestratorAction_ScheduleTask 

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

type OrchestratorAction_SendEntityMessage added in v0.7.0 

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

type OrchestratorAction_SendEvent 

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

type OrchestratorAction_TerminateOrchestration 

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

type OrchestratorCompletedEvent 

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

func (*OrchestratorCompletedEvent) Descriptor deprecated 

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

Deprecated: Use OrchestratorCompletedEvent.ProtoReflect.Descriptor instead.

func (*OrchestratorCompletedEvent) ProtoMessage 

func (*OrchestratorCompletedEvent) ProtoMessage()

func (*OrchestratorCompletedEvent) ProtoReflect 

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

func (*OrchestratorCompletedEvent) Reset 

func (x *OrchestratorCompletedEvent) Reset()

func (*OrchestratorCompletedEvent) String 

func (x *OrchestratorCompletedEvent) String() string

type OrchestratorEntityParameters 

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

func (*OrchestratorEntityParameters) Descriptor deprecated 

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

Deprecated: Use OrchestratorEntityParameters.ProtoReflect.Descriptor instead.

func (*OrchestratorEntityParameters) GetEntityMessageReorderWindow 

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

func (*OrchestratorEntityParameters) ProtoMessage 

func (*OrchestratorEntityParameters) ProtoMessage()

func (*OrchestratorEntityParameters) ProtoReflect 

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

func (*OrchestratorEntityParameters) Reset 

func (x *OrchestratorEntityParameters) Reset()

func (*OrchestratorEntityParameters) String 

func (x *OrchestratorEntityParameters) String() string

type OrchestratorMessage 

type OrchestratorMessage struct {

	// The ID of the orchestration instance to receive the message.
	Instance *OrchestrationInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
	// The event payload to be received by the target orchestration.
	Event *HistoryEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

A message to be delivered to an orchestration by the backend.

func (*OrchestratorMessage) Descriptor deprecated 

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

Deprecated: Use OrchestratorMessage.ProtoReflect.Descriptor instead.

func (*OrchestratorMessage) GetEvent 

func (x *OrchestratorMessage) GetEvent() *HistoryEvent

func (*OrchestratorMessage) GetInstance 

func (x *OrchestratorMessage) GetInstance() *OrchestrationInstance

func (*OrchestratorMessage) ProtoMessage 

func (*OrchestratorMessage) ProtoMessage()

func (*OrchestratorMessage) ProtoReflect 

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

func (*OrchestratorMessage) Reset 

func (x *OrchestratorMessage) Reset()

func (*OrchestratorMessage) String 

func (x *OrchestratorMessage) String() string

type OrchestratorRequest 

type OrchestratorRequest struct {
	InstanceId               string                        `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId              *wrapperspb.StringValue       `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	PastEvents               []*HistoryEvent               `protobuf:"bytes,3,rep,name=pastEvents,proto3" json:"pastEvents,omitempty"`
	NewEvents                []*HistoryEvent               `protobuf:"bytes,4,rep,name=newEvents,proto3" json:"newEvents,omitempty"`
	EntityParameters         *OrchestratorEntityParameters `protobuf:"bytes,5,opt,name=entityParameters,proto3" json:"entityParameters,omitempty"`
	RequiresHistoryStreaming bool                          `protobuf:"varint,6,opt,name=requiresHistoryStreaming,proto3" json:"requiresHistoryStreaming,omitempty"`
	Router                   *TaskRouter                   `protobuf:"bytes,7,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestratorRequest) Descriptor deprecated 

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

Deprecated: Use OrchestratorRequest.ProtoReflect.Descriptor instead.

func (*OrchestratorRequest) GetEntityParameters 

func (x *OrchestratorRequest) GetEntityParameters() *OrchestratorEntityParameters

func (*OrchestratorRequest) GetExecutionId 

func (x *OrchestratorRequest) GetExecutionId() *wrapperspb.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) GetRequiresHistoryStreaming added in v0.7.0 

func (x *OrchestratorRequest) GetRequiresHistoryStreaming() bool

func (*OrchestratorRequest) GetRouter added in v0.8.0 

func (x *OrchestratorRequest) GetRouter() *TaskRouter

func (*OrchestratorRequest) ProtoMessage 

func (*OrchestratorRequest) ProtoMessage()

func (*OrchestratorRequest) ProtoReflect 

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

func (*OrchestratorRequest) Reset 

func (x *OrchestratorRequest) Reset()

func (*OrchestratorRequest) String 

func (x *OrchestratorRequest) String() string

type OrchestratorResponse 

type OrchestratorResponse struct {
	InstanceId      string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Actions         []*OrchestratorAction   `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	CustomStatus    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	CompletionToken string                  `protobuf:"bytes,4,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// The number of work item events that were processed by the orchestrator.
	// This field is optional. If not set, the service should assume that the orchestrator processed all events.
	NumEventsProcessed *wrapperspb.Int32Value `protobuf:"bytes,5,opt,name=numEventsProcessed,proto3" json:"numEventsProcessed,omitempty"`
	// 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) GetCompletionToken added in v0.7.0 

func (x *OrchestratorResponse) GetCompletionToken() string

func (*OrchestratorResponse) GetCustomStatus 

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

func (*OrchestratorResponse) GetInstanceId 

func (x *OrchestratorResponse) GetInstanceId() string

func (*OrchestratorResponse) GetNumEventsProcessed added in v0.7.0 

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

func (*OrchestratorResponse) ProtoMessage 

func (*OrchestratorResponse) ProtoMessage()

func (*OrchestratorResponse) ProtoReflect 

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

func (*OrchestratorResponse) Reset 

func (x *OrchestratorResponse) Reset()

func (*OrchestratorResponse) String 

func (x *OrchestratorResponse) String() string

type OrchestratorStartedEvent 

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

func (*OrchestratorStartedEvent) Descriptor deprecated 

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

Deprecated: Use OrchestratorStartedEvent.ProtoReflect.Descriptor instead.

func (*OrchestratorStartedEvent) ProtoMessage 

func (*OrchestratorStartedEvent) ProtoMessage()

func (*OrchestratorStartedEvent) ProtoReflect 

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

func (*OrchestratorStartedEvent) Reset 

func (x *OrchestratorStartedEvent) Reset()

func (*OrchestratorStartedEvent) String 

func (x *OrchestratorStartedEvent) String() string

type ParentInstanceInfo 

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

func (*ParentInstanceInfo) Descriptor deprecated 

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

Deprecated: Use ParentInstanceInfo.ProtoReflect.Descriptor instead.

func (*ParentInstanceInfo) GetAppID added in v0.8.0 

func (x *ParentInstanceInfo) GetAppID() string

func (*ParentInstanceInfo) GetName 

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

func (*ParentInstanceInfo) GetOrchestrationInstance 

func (x *ParentInstanceInfo) GetOrchestrationInstance() *OrchestrationInstance

func (*ParentInstanceInfo) GetTaskScheduledId 

func (x *ParentInstanceInfo) GetTaskScheduledId() int32

func (*ParentInstanceInfo) GetVersion 

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

func (*ParentInstanceInfo) ProtoMessage 

func (*ParentInstanceInfo) ProtoMessage()

func (*ParentInstanceInfo) ProtoReflect 

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

func (*ParentInstanceInfo) Reset 

func (x *ParentInstanceInfo) Reset()

func (*ParentInstanceInfo) String 

func (x *ParentInstanceInfo) String() string

type PingRequest 

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

Request payload for ping operations.

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

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

Response payload for ping operations.

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type PurgeInstanceFilter 

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

func (*PurgeInstanceFilter) Descriptor deprecated 

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

Deprecated: Use PurgeInstanceFilter.ProtoReflect.Descriptor instead.

func (*PurgeInstanceFilter) GetCreatedTimeFrom 

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

func (*PurgeInstanceFilter) GetCreatedTimeTo 

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

func (*PurgeInstanceFilter) GetRuntimeStatus 

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

func (*PurgeInstanceFilter) ProtoMessage 

func (*PurgeInstanceFilter) ProtoMessage()

func (*PurgeInstanceFilter) ProtoReflect 

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

func (*PurgeInstanceFilter) Reset 

func (x *PurgeInstanceFilter) Reset()

func (*PurgeInstanceFilter) String 

func (x *PurgeInstanceFilter) String() string

type PurgeInstancesRequest 

type PurgeInstancesRequest struct {

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

func (*PurgeInstancesRequest) Descriptor deprecated 

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

Deprecated: Use PurgeInstancesRequest.ProtoReflect.Descriptor instead.

func (*PurgeInstancesRequest) GetInstanceId 

func (x *PurgeInstancesRequest) GetInstanceId() string

func (*PurgeInstancesRequest) GetPurgeInstanceFilter 

func (x *PurgeInstancesRequest) GetPurgeInstanceFilter() *PurgeInstanceFilter

func (*PurgeInstancesRequest) GetRecursive 

func (x *PurgeInstancesRequest) GetRecursive() bool

func (*PurgeInstancesRequest) GetRequest 

func (m *PurgeInstancesRequest) GetRequest() isPurgeInstancesRequest_Request

func (*PurgeInstancesRequest) ProtoMessage 

func (*PurgeInstancesRequest) ProtoMessage()

func (*PurgeInstancesRequest) ProtoReflect 

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

func (*PurgeInstancesRequest) Reset 

func (x *PurgeInstancesRequest) Reset()

func (*PurgeInstancesRequest) String 

func (x *PurgeInstancesRequest) String() string

type PurgeInstancesRequest_InstanceId 

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

type PurgeInstancesRequest_PurgeInstanceFilter 

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

type PurgeInstancesResponse 

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

func (*PurgeInstancesResponse) Descriptor deprecated 

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

Deprecated: Use PurgeInstancesResponse.ProtoReflect.Descriptor instead.

func (*PurgeInstancesResponse) GetDeletedInstanceCount 

func (x *PurgeInstancesResponse) GetDeletedInstanceCount() int32

func (*PurgeInstancesResponse) GetIsComplete added in v0.7.0 

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

func (*PurgeInstancesResponse) ProtoMessage 

func (*PurgeInstancesResponse) ProtoMessage()

func (*PurgeInstancesResponse) ProtoReflect 

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

func (*PurgeInstancesResponse) Reset 

func (x *PurgeInstancesResponse) Reset()

func (*PurgeInstancesResponse) String 

func (x *PurgeInstancesResponse) String() string

type QueryEntitiesRequest 

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

func (*QueryEntitiesRequest) Descriptor deprecated 

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

Deprecated: Use QueryEntitiesRequest.ProtoReflect.Descriptor instead.

func (*QueryEntitiesRequest) GetQuery 

func (x *QueryEntitiesRequest) GetQuery() *EntityQuery

func (*QueryEntitiesRequest) ProtoMessage 

func (*QueryEntitiesRequest) ProtoMessage()

func (*QueryEntitiesRequest) ProtoReflect 

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

func (*QueryEntitiesRequest) Reset 

func (x *QueryEntitiesRequest) Reset()

func (*QueryEntitiesRequest) String 

func (x *QueryEntitiesRequest) String() string

type QueryEntitiesResponse 

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

func (*QueryEntitiesResponse) Descriptor deprecated 

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

Deprecated: Use QueryEntitiesResponse.ProtoReflect.Descriptor instead.

func (*QueryEntitiesResponse) GetContinuationToken 

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

func (*QueryEntitiesResponse) GetEntities 

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

func (*QueryEntitiesResponse) ProtoMessage 

func (*QueryEntitiesResponse) ProtoMessage()

func (*QueryEntitiesResponse) ProtoReflect 

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

func (*QueryEntitiesResponse) Reset 

func (x *QueryEntitiesResponse) Reset()

func (*QueryEntitiesResponse) String 

func (x *QueryEntitiesResponse) String() string

type QueryInstancesRequest 

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

func (*QueryInstancesRequest) Descriptor deprecated 

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

Deprecated: Use QueryInstancesRequest.ProtoReflect.Descriptor instead.

func (*QueryInstancesRequest) GetQuery 

func (x *QueryInstancesRequest) GetQuery() *InstanceQuery

func (*QueryInstancesRequest) ProtoMessage 

func (*QueryInstancesRequest) ProtoMessage()

func (*QueryInstancesRequest) ProtoReflect 

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

func (*QueryInstancesRequest) Reset 

func (x *QueryInstancesRequest) Reset()

func (*QueryInstancesRequest) String 

func (x *QueryInstancesRequest) String() string

type QueryInstancesResponse 

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

func (*QueryInstancesResponse) Descriptor deprecated 

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

Deprecated: Use QueryInstancesResponse.ProtoReflect.Descriptor instead.

func (*QueryInstancesResponse) GetContinuationToken 

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

func (*QueryInstancesResponse) GetOrchestrationState 

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

func (*QueryInstancesResponse) ProtoMessage 

func (*QueryInstancesResponse) ProtoMessage()

func (*QueryInstancesResponse) ProtoReflect 

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

func (*QueryInstancesResponse) Reset 

func (x *QueryInstancesResponse) Reset()

func (*QueryInstancesResponse) String 

func (x *QueryInstancesResponse) String() string

type RaiseEventRequest 

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

func (*RaiseEventRequest) Descriptor deprecated 

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

Deprecated: Use RaiseEventRequest.ProtoReflect.Descriptor instead.

func (*RaiseEventRequest) GetInput 

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

func (*RaiseEventRequest) GetInstanceId 

func (x *RaiseEventRequest) GetInstanceId() string

func (*RaiseEventRequest) GetName 

func (x *RaiseEventRequest) GetName() string

func (*RaiseEventRequest) ProtoMessage 

func (*RaiseEventRequest) ProtoMessage()

func (*RaiseEventRequest) ProtoReflect 

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

func (*RaiseEventRequest) Reset 

func (x *RaiseEventRequest) Reset()

func (*RaiseEventRequest) String 

func (x *RaiseEventRequest) String() string

type RaiseEventResponse 

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

func (*RaiseEventResponse) Descriptor deprecated 

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

Deprecated: Use RaiseEventResponse.ProtoReflect.Descriptor instead.

func (*RaiseEventResponse) ProtoMessage 

func (*RaiseEventResponse) ProtoMessage()

func (*RaiseEventResponse) ProtoReflect 

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

func (*RaiseEventResponse) Reset 

func (x *RaiseEventResponse) Reset()

func (*RaiseEventResponse) String 

func (x *RaiseEventResponse) String() string

type RerunWorkflowFromEventRequest added in v0.7.0 

type RerunWorkflowFromEventRequest struct {

	// sourceInstanceID is the orchestration instance ID to rerun. Can be a top
	// level instance, or sub-orchestration instance.
	SourceInstanceID string `protobuf:"bytes,1,opt,name=sourceInstanceID,proto3" json:"sourceInstanceID,omitempty"`
	// the event id to start the new workflow instance from.
	EventID uint32 `protobuf:"varint,2,opt,name=eventID,proto3" json:"eventID,omitempty"`
	// newInstanceID is the new instance ID to use for the new workflow instance.
	// If not given, a random instance ID will be given.
	NewInstanceID *string `protobuf:"bytes,3,opt,name=newInstanceID,proto3,oneof" json:"newInstanceID,omitempty"`
	// input can optionally given to give the new instance a different input to
	// the next Activity event.
	Input *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// overwrite_input signals that the input to the rerun activity should be
	// written with input. This is required because of the incorrect typing of
	// inputs being `StringValue` which cannot be optional, and therefore no nil
	// value can be signalled or overwritten.
	OverwriteInput bool `protobuf:"varint,5,opt,name=overwriteInput,proto3" json:"overwriteInput,omitempty"`
	// contains filtered or unexported fields
}

RerunWorkflowFromEventRequest is used to rerun a workflow instance from a specific event ID.

func (*RerunWorkflowFromEventRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use RerunWorkflowFromEventRequest.ProtoReflect.Descriptor instead.

func (*RerunWorkflowFromEventRequest) GetEventID added in v0.7.0 

func (x *RerunWorkflowFromEventRequest) GetEventID() uint32

func (*RerunWorkflowFromEventRequest) GetInput added in v0.7.0 

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

func (*RerunWorkflowFromEventRequest) GetNewInstanceID added in v0.7.0 

func (x *RerunWorkflowFromEventRequest) GetNewInstanceID() string

func (*RerunWorkflowFromEventRequest) GetOverwriteInput added in v0.7.0 

func (x *RerunWorkflowFromEventRequest) GetOverwriteInput() bool

func (*RerunWorkflowFromEventRequest) GetSourceInstanceID added in v0.7.0 

func (x *RerunWorkflowFromEventRequest) GetSourceInstanceID() string

func (*RerunWorkflowFromEventRequest) ProtoMessage added in v0.7.0 

func (*RerunWorkflowFromEventRequest) ProtoMessage()

func (*RerunWorkflowFromEventRequest) ProtoReflect added in v0.7.0 

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

func (*RerunWorkflowFromEventRequest) Reset added in v0.7.0 

func (x *RerunWorkflowFromEventRequest) Reset()

func (*RerunWorkflowFromEventRequest) String added in v0.7.0 

func (x *RerunWorkflowFromEventRequest) String() string

type RerunWorkflowFromEventResponse added in v0.7.0 

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

RerunWorkflowFromEventResponse is the response to executing RerunWorkflowFromEvent.

func (*RerunWorkflowFromEventResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use RerunWorkflowFromEventResponse.ProtoReflect.Descriptor instead.

func (*RerunWorkflowFromEventResponse) GetNewInstanceID added in v0.7.0 

func (x *RerunWorkflowFromEventResponse) GetNewInstanceID() string

func (*RerunWorkflowFromEventResponse) ProtoMessage added in v0.7.0 

func (*RerunWorkflowFromEventResponse) ProtoMessage()

func (*RerunWorkflowFromEventResponse) ProtoReflect added in v0.7.0 

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

func (*RerunWorkflowFromEventResponse) Reset added in v0.7.0 

func (x *RerunWorkflowFromEventResponse) Reset()

func (*RerunWorkflowFromEventResponse) String added in v0.7.0 

func (x *RerunWorkflowFromEventResponse) String() string

type ResumeRequest 

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

func (*ResumeRequest) Descriptor deprecated 

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

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetInstanceId 

func (x *ResumeRequest) GetInstanceId() string

func (*ResumeRequest) GetReason 

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

func (*ResumeRequest) ProtoMessage 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect 

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

func (*ResumeRequest) Reset 

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String 

func (x *ResumeRequest) String() string

type ResumeResponse 

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

func (*ResumeResponse) Descriptor deprecated 

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

Deprecated: Use ResumeResponse.ProtoReflect.Descriptor instead.

func (*ResumeResponse) ProtoMessage 

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) ProtoReflect 

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

func (*ResumeResponse) Reset 

func (x *ResumeResponse) Reset()

func (*ResumeResponse) String 

func (x *ResumeResponse) String() string

type RewindInstanceRequest 

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

func (*RewindInstanceRequest) Descriptor deprecated 

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

Deprecated: Use RewindInstanceRequest.ProtoReflect.Descriptor instead.

func (*RewindInstanceRequest) GetInstanceId 

func (x *RewindInstanceRequest) GetInstanceId() string

func (*RewindInstanceRequest) GetReason 

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

func (*RewindInstanceRequest) ProtoMessage 

func (*RewindInstanceRequest) ProtoMessage()

func (*RewindInstanceRequest) ProtoReflect 

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

func (*RewindInstanceRequest) Reset 

func (x *RewindInstanceRequest) Reset()

func (*RewindInstanceRequest) String 

func (x *RewindInstanceRequest) String() string

type RewindInstanceResponse 

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

func (*RewindInstanceResponse) Descriptor deprecated 

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

Deprecated: Use RewindInstanceResponse.ProtoReflect.Descriptor instead.

func (*RewindInstanceResponse) ProtoMessage 

func (*RewindInstanceResponse) ProtoMessage()

func (*RewindInstanceResponse) ProtoReflect 

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

func (*RewindInstanceResponse) Reset 

func (x *RewindInstanceResponse) Reset()

func (*RewindInstanceResponse) String 

func (x *RewindInstanceResponse) String() string

type ScheduleTaskAction 

type ScheduleTaskAction struct {
	Name            string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version         *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input           *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	Router          *TaskRouter             `protobuf:"bytes,4,opt,name=router,proto3,oneof" json:"router,omitempty"`
	TaskExecutionId string                  `protobuf:"bytes,5,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleTaskAction) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskAction.ProtoReflect.Descriptor instead.

func (*ScheduleTaskAction) GetInput 

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

func (*ScheduleTaskAction) GetName 

func (x *ScheduleTaskAction) GetName() string

func (*ScheduleTaskAction) GetRouter added in v0.8.0 

func (x *ScheduleTaskAction) GetRouter() *TaskRouter

func (*ScheduleTaskAction) GetTaskExecutionId added in v0.8.0 

func (x *ScheduleTaskAction) GetTaskExecutionId() string

func (*ScheduleTaskAction) GetVersion 

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

func (*ScheduleTaskAction) ProtoMessage 

func (*ScheduleTaskAction) ProtoMessage()

func (*ScheduleTaskAction) ProtoReflect 

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

func (*ScheduleTaskAction) Reset 

func (x *ScheduleTaskAction) Reset()

func (*ScheduleTaskAction) String 

func (x *ScheduleTaskAction) String() string

type SendEntityMessageAction added in v0.7.0 

type SendEntityMessageAction struct {

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

func (*SendEntityMessageAction) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use SendEntityMessageAction.ProtoReflect.Descriptor instead.

func (*SendEntityMessageAction) GetEntityLockRequested added in v0.7.0 

func (x *SendEntityMessageAction) GetEntityLockRequested() *EntityLockRequestedEvent

func (*SendEntityMessageAction) GetEntityMessageType added in v0.7.0 

func (m *SendEntityMessageAction) GetEntityMessageType() isSendEntityMessageAction_EntityMessageType

func (*SendEntityMessageAction) GetEntityOperationCalled added in v0.7.0 

func (x *SendEntityMessageAction) GetEntityOperationCalled() *EntityOperationCalledEvent

func (*SendEntityMessageAction) GetEntityOperationSignaled added in v0.7.0 

func (x *SendEntityMessageAction) GetEntityOperationSignaled() *EntityOperationSignaledEvent

func (*SendEntityMessageAction) GetEntityUnlockSent added in v0.7.0 

func (x *SendEntityMessageAction) GetEntityUnlockSent() *EntityUnlockSentEvent

func (*SendEntityMessageAction) ProtoMessage added in v0.7.0 

func (*SendEntityMessageAction) ProtoMessage()

func (*SendEntityMessageAction) ProtoReflect added in v0.7.0 

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

func (*SendEntityMessageAction) Reset added in v0.7.0 

func (x *SendEntityMessageAction) Reset()

func (*SendEntityMessageAction) String added in v0.7.0 

func (x *SendEntityMessageAction) String() string

type SendEntityMessageAction_EntityLockRequested added in v0.7.0 

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

type SendEntityMessageAction_EntityOperationCalled added in v0.7.0 

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

type SendEntityMessageAction_EntityOperationSignaled added in v0.7.0 

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

type SendEntityMessageAction_EntityUnlockSent added in v0.7.0 

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

type SendEventAction 

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

func (*SendEventAction) Descriptor deprecated 

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

Deprecated: Use SendEventAction.ProtoReflect.Descriptor instead.

func (*SendEventAction) GetData 

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

func (*SendEventAction) GetInstance 

func (x *SendEventAction) GetInstance() *OrchestrationInstance

func (*SendEventAction) GetName 

func (x *SendEventAction) GetName() string

func (*SendEventAction) ProtoMessage 

func (*SendEventAction) ProtoMessage()

func (*SendEventAction) ProtoReflect 

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

func (*SendEventAction) Reset 

func (x *SendEventAction) Reset()

func (*SendEventAction) String 

func (x *SendEventAction) String() string

type SendSignalAction 

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

func (*SendSignalAction) Descriptor deprecated 

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

Deprecated: Use SendSignalAction.ProtoReflect.Descriptor instead.

func (*SendSignalAction) GetInput 

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

func (*SendSignalAction) GetInstanceId 

func (x *SendSignalAction) GetInstanceId() string

func (*SendSignalAction) GetName 

func (x *SendSignalAction) GetName() string

func (*SendSignalAction) GetScheduledTime 

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

func (*SendSignalAction) ProtoMessage 

func (*SendSignalAction) ProtoMessage()

func (*SendSignalAction) ProtoReflect 

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

func (*SendSignalAction) Reset 

func (x *SendSignalAction) Reset()

func (*SendSignalAction) String 

func (x *SendSignalAction) String() string

type SignalEntityRequest 

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

func (*SignalEntityRequest) Descriptor deprecated 

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

Deprecated: Use SignalEntityRequest.ProtoReflect.Descriptor instead.

func (*SignalEntityRequest) GetInput 

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

func (*SignalEntityRequest) GetInstanceId 

func (x *SignalEntityRequest) GetInstanceId() string

func (*SignalEntityRequest) GetName 

func (x *SignalEntityRequest) GetName() string

func (*SignalEntityRequest) GetRequestId 

func (x *SignalEntityRequest) GetRequestId() string

func (*SignalEntityRequest) GetScheduledTime 

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

func (*SignalEntityRequest) ProtoMessage 

func (*SignalEntityRequest) ProtoMessage()

func (*SignalEntityRequest) ProtoReflect 

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

func (*SignalEntityRequest) Reset 

func (x *SignalEntityRequest) Reset()

func (*SignalEntityRequest) String 

func (x *SignalEntityRequest) String() string

type SignalEntityResponse 

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

func (*SignalEntityResponse) Descriptor deprecated 

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

Deprecated: Use SignalEntityResponse.ProtoReflect.Descriptor instead.

func (*SignalEntityResponse) ProtoMessage 

func (*SignalEntityResponse) ProtoMessage()

func (*SignalEntityResponse) ProtoReflect 

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

func (*SignalEntityResponse) Reset 

func (x *SignalEntityResponse) Reset()

func (*SignalEntityResponse) String 

func (x *SignalEntityResponse) String() string

type StartNewOrchestrationAction 

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

func (*StartNewOrchestrationAction) Descriptor deprecated 

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

Deprecated: Use StartNewOrchestrationAction.ProtoReflect.Descriptor instead.

func (*StartNewOrchestrationAction) GetInput 

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

func (*StartNewOrchestrationAction) GetInstanceId 

func (x *StartNewOrchestrationAction) GetInstanceId() string

func (*StartNewOrchestrationAction) GetName 

func (x *StartNewOrchestrationAction) GetName() string

func (*StartNewOrchestrationAction) GetScheduledTime 

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

func (*StartNewOrchestrationAction) GetVersion 

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

func (*StartNewOrchestrationAction) ProtoMessage 

func (*StartNewOrchestrationAction) ProtoMessage()

func (*StartNewOrchestrationAction) ProtoReflect 

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

func (*StartNewOrchestrationAction) Reset 

func (x *StartNewOrchestrationAction) Reset()

func (*StartNewOrchestrationAction) String 

func (x *StartNewOrchestrationAction) String() string

type StreamInstanceHistoryRequest added in v0.7.0 

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

func (*StreamInstanceHistoryRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use StreamInstanceHistoryRequest.ProtoReflect.Descriptor instead.

func (*StreamInstanceHistoryRequest) GetExecutionId added in v0.7.0 

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

func (*StreamInstanceHistoryRequest) GetForWorkItemProcessing added in v0.7.0 

func (x *StreamInstanceHistoryRequest) GetForWorkItemProcessing() bool

func (*StreamInstanceHistoryRequest) GetInstanceId added in v0.7.0 

func (x *StreamInstanceHistoryRequest) GetInstanceId() string

func (*StreamInstanceHistoryRequest) ProtoMessage added in v0.7.0 

func (*StreamInstanceHistoryRequest) ProtoMessage()

func (*StreamInstanceHistoryRequest) ProtoReflect added in v0.7.0 

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

func (*StreamInstanceHistoryRequest) Reset added in v0.7.0 

func (x *StreamInstanceHistoryRequest) Reset()

func (*StreamInstanceHistoryRequest) String added in v0.7.0 

func (x *StreamInstanceHistoryRequest) String() string

type SubOrchestrationInstanceCompletedEvent 

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

func (*SubOrchestrationInstanceCompletedEvent) Descriptor deprecated 

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

Deprecated: Use SubOrchestrationInstanceCompletedEvent.ProtoReflect.Descriptor instead.

func (*SubOrchestrationInstanceCompletedEvent) GetResult 

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

func (*SubOrchestrationInstanceCompletedEvent) GetTaskScheduledId 

func (x *SubOrchestrationInstanceCompletedEvent) GetTaskScheduledId() int32

func (*SubOrchestrationInstanceCompletedEvent) ProtoMessage 

func (*SubOrchestrationInstanceCompletedEvent) ProtoMessage()

func (*SubOrchestrationInstanceCompletedEvent) ProtoReflect 

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

func (*SubOrchestrationInstanceCompletedEvent) Reset 

func (x *SubOrchestrationInstanceCompletedEvent) Reset()

func (*SubOrchestrationInstanceCompletedEvent) String 

func (x *SubOrchestrationInstanceCompletedEvent) String() string

type SubOrchestrationInstanceCreatedEvent 

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

func (*SubOrchestrationInstanceCreatedEvent) Descriptor deprecated 

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

Deprecated: Use SubOrchestrationInstanceCreatedEvent.ProtoReflect.Descriptor instead.

func (*SubOrchestrationInstanceCreatedEvent) GetInput 

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

func (*SubOrchestrationInstanceCreatedEvent) GetInstanceId 

func (x *SubOrchestrationInstanceCreatedEvent) GetInstanceId() string

func (*SubOrchestrationInstanceCreatedEvent) GetName 

func (x *SubOrchestrationInstanceCreatedEvent) GetName() string

func (*SubOrchestrationInstanceCreatedEvent) GetParentTraceContext 

func (x *SubOrchestrationInstanceCreatedEvent) GetParentTraceContext() *TraceContext

func (*SubOrchestrationInstanceCreatedEvent) GetVersion 

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

func (*SubOrchestrationInstanceCreatedEvent) ProtoMessage 

func (*SubOrchestrationInstanceCreatedEvent) ProtoMessage()

func (*SubOrchestrationInstanceCreatedEvent) ProtoReflect 

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

func (*SubOrchestrationInstanceCreatedEvent) Reset 

func (x *SubOrchestrationInstanceCreatedEvent) Reset()

func (*SubOrchestrationInstanceCreatedEvent) String 

func (x *SubOrchestrationInstanceCreatedEvent) String() string

type SubOrchestrationInstanceFailedEvent 

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

func (*SubOrchestrationInstanceFailedEvent) Descriptor deprecated 

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

Deprecated: Use SubOrchestrationInstanceFailedEvent.ProtoReflect.Descriptor instead.

func (*SubOrchestrationInstanceFailedEvent) GetFailureDetails 

func (x *SubOrchestrationInstanceFailedEvent) GetFailureDetails() *TaskFailureDetails

func (*SubOrchestrationInstanceFailedEvent) GetTaskScheduledId 

func (x *SubOrchestrationInstanceFailedEvent) GetTaskScheduledId() int32

func (*SubOrchestrationInstanceFailedEvent) ProtoMessage 

func (*SubOrchestrationInstanceFailedEvent) ProtoMessage()

func (*SubOrchestrationInstanceFailedEvent) ProtoReflect 

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

func (*SubOrchestrationInstanceFailedEvent) Reset 

func (x *SubOrchestrationInstanceFailedEvent) Reset()

func (*SubOrchestrationInstanceFailedEvent) String 

func (x *SubOrchestrationInstanceFailedEvent) String() string

type SuspendRequest 

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

func (*SuspendRequest) Descriptor deprecated 

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

Deprecated: Use SuspendRequest.ProtoReflect.Descriptor instead.

func (*SuspendRequest) GetInstanceId 

func (x *SuspendRequest) GetInstanceId() string

func (*SuspendRequest) GetReason 

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

func (*SuspendRequest) ProtoMessage 

func (*SuspendRequest) ProtoMessage()

func (*SuspendRequest) ProtoReflect 

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

func (*SuspendRequest) Reset 

func (x *SuspendRequest) Reset()

func (*SuspendRequest) String 

func (x *SuspendRequest) String() string

type SuspendResponse 

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

func (*SuspendResponse) Descriptor deprecated 

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

Deprecated: Use SuspendResponse.ProtoReflect.Descriptor instead.

func (*SuspendResponse) ProtoMessage 

func (*SuspendResponse) ProtoMessage()

func (*SuspendResponse) ProtoReflect 

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

func (*SuspendResponse) Reset 

func (x *SuspendResponse) Reset()

func (*SuspendResponse) String 

func (x *SuspendResponse) String() string

type TaskCompletedEvent 

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

func (*TaskCompletedEvent) Descriptor deprecated 

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

Deprecated: Use TaskCompletedEvent.ProtoReflect.Descriptor instead.

func (*TaskCompletedEvent) GetResult 

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

func (*TaskCompletedEvent) GetTaskExecutionId added in v0.8.0 

func (x *TaskCompletedEvent) GetTaskExecutionId() string

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"`
	TaskExecutionId string              `protobuf:"bytes,3,opt,name=taskExecutionId,proto3" json:"taskExecutionId,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) GetTaskExecutionId added in v0.8.0 

func (x *TaskFailedEvent) GetTaskExecutionId() string

func (*TaskFailedEvent) GetTaskScheduledId 

func (x *TaskFailedEvent) GetTaskScheduledId() int32

func (*TaskFailedEvent) ProtoMessage 

func (*TaskFailedEvent) ProtoMessage()

func (*TaskFailedEvent) ProtoReflect 

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

func (*TaskFailedEvent) Reset 

func (x *TaskFailedEvent) Reset()

func (*TaskFailedEvent) String 

func (x *TaskFailedEvent) String() string

type TaskFailureDetails 

type TaskFailureDetails struct {
	ErrorType      string                  `protobuf:"bytes,1,opt,name=errorType,proto3" json:"errorType,omitempty"`
	ErrorMessage   string                  `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	StackTrace     *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=stackTrace,proto3" json:"stackTrace,omitempty"`
	InnerFailure   *TaskFailureDetails     `protobuf:"bytes,4,opt,name=innerFailure,proto3" json:"innerFailure,omitempty"`
	IsNonRetriable bool                    `protobuf:"varint,5,opt,name=isNonRetriable,proto3" json:"isNonRetriable,omitempty"`
	// 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() *wrapperspb.StringValue

func (*TaskFailureDetails) ProtoMessage 

func (*TaskFailureDetails) ProtoMessage()

func (*TaskFailureDetails) ProtoReflect 

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

func (*TaskFailureDetails) Reset 

func (x *TaskFailureDetails) Reset()

func (*TaskFailureDetails) String 

func (x *TaskFailureDetails) String() string

type TaskHubSidecarServiceClient 

type TaskHubSidecarServiceClient interface {
	// Sends a hello request to the sidecar service.
	Hello(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Starts a new orchestration instance.
	StartInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// Gets the status of an existing orchestration instance.
	GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Rewinds an orchestration instance to last known good state and replays from there.
	RewindInstance(ctx context.Context, in *RewindInstanceRequest, opts ...grpc.CallOption) (*RewindInstanceResponse, error)
	// 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)
	// Gets the history of an orchestration instance as a stream of events.
	StreamInstanceHistory(ctx context.Context, in *StreamInstanceHistoryRequest, opts ...grpc.CallOption) (TaskHubSidecarService_StreamInstanceHistoryClient, error)
	// Deletes and Creates the necessary resources for the orchestration service and the instance store
	CreateTaskHub(ctx context.Context, in *CreateTaskHubRequest, opts ...grpc.CallOption) (*CreateTaskHubResponse, error)
	// Deletes the resources for the orchestration service and optionally the instance store
	DeleteTaskHub(ctx context.Context, in *DeleteTaskHubRequest, opts ...grpc.CallOption) (*DeleteTaskHubResponse, error)
	// sends a signal to an entity
	SignalEntity(ctx context.Context, in *SignalEntityRequest, opts ...grpc.CallOption) (*SignalEntityResponse, error)
	// get information about a specific entity
	GetEntity(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*GetEntityResponse, error)
	// query entities
	QueryEntities(ctx context.Context, in *QueryEntitiesRequest, opts ...grpc.CallOption) (*QueryEntitiesResponse, error)
	// clean entity storage
	CleanEntityStorage(ctx context.Context, in *CleanEntityStorageRequest, opts ...grpc.CallOption) (*CleanEntityStorageResponse, error)
	// Abandons a single work item
	AbandonTaskActivityWorkItem(ctx context.Context, in *AbandonActivityTaskRequest, opts ...grpc.CallOption) (*AbandonActivityTaskResponse, error)
	// Abandon an orchestration work item
	AbandonTaskOrchestratorWorkItem(ctx context.Context, in *AbandonOrchestrationTaskRequest, opts ...grpc.CallOption) (*AbandonOrchestrationTaskResponse, error)
	// Abandon an entity work item
	AbandonTaskEntityWorkItem(ctx context.Context, in *AbandonEntityTaskRequest, opts ...grpc.CallOption) (*AbandonEntityTaskResponse, error)
	// Rerun a Workflow from a specific event ID of a workflow instance.
	RerunWorkflowFromEvent(ctx context.Context, in *RerunWorkflowFromEventRequest, opts ...grpc.CallOption) (*RerunWorkflowFromEventResponse, error)
}

TaskHubSidecarServiceClient is the client API for TaskHubSidecarService service.

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

func NewTaskHubSidecarServiceClient 

func NewTaskHubSidecarServiceClient(cc grpc.ClientConnInterface) TaskHubSidecarServiceClient

type TaskHubSidecarServiceServer 

type TaskHubSidecarServiceServer interface {
	// Sends a hello request to the sidecar service.
	Hello(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// Starts a new orchestration instance.
	StartInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// Gets the status of an existing orchestration instance.
	GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Rewinds an orchestration instance to last known good state and replays from there.
	RewindInstance(context.Context, *RewindInstanceRequest) (*RewindInstanceResponse, error)
	// 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)
	// Gets the history of an orchestration instance as a stream of events.
	StreamInstanceHistory(*StreamInstanceHistoryRequest, TaskHubSidecarService_StreamInstanceHistoryServer) error
	// Deletes and Creates the necessary resources for the orchestration service and the instance store
	CreateTaskHub(context.Context, *CreateTaskHubRequest) (*CreateTaskHubResponse, error)
	// Deletes the resources for the orchestration service and optionally the instance store
	DeleteTaskHub(context.Context, *DeleteTaskHubRequest) (*DeleteTaskHubResponse, error)
	// sends a signal to an entity
	SignalEntity(context.Context, *SignalEntityRequest) (*SignalEntityResponse, error)
	// get information about a specific entity
	GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)
	// query entities
	QueryEntities(context.Context, *QueryEntitiesRequest) (*QueryEntitiesResponse, error)
	// clean entity storage
	CleanEntityStorage(context.Context, *CleanEntityStorageRequest) (*CleanEntityStorageResponse, error)
	// Abandons a single work item
	AbandonTaskActivityWorkItem(context.Context, *AbandonActivityTaskRequest) (*AbandonActivityTaskResponse, error)
	// Abandon an orchestration work item
	AbandonTaskOrchestratorWorkItem(context.Context, *AbandonOrchestrationTaskRequest) (*AbandonOrchestrationTaskResponse, error)
	// Abandon an entity work item
	AbandonTaskEntityWorkItem(context.Context, *AbandonEntityTaskRequest) (*AbandonEntityTaskResponse, error)
	// Rerun a Workflow from a specific event ID of a workflow instance.
	RerunWorkflowFromEvent(context.Context, *RerunWorkflowFromEventRequest) (*RerunWorkflowFromEventResponse, 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 TaskHubSidecarService_StreamInstanceHistoryClient added in v0.7.0 

type TaskHubSidecarService_StreamInstanceHistoryClient interface {
	Recv() (*HistoryChunk, error)
	grpc.ClientStream
}

type TaskHubSidecarService_StreamInstanceHistoryServer added in v0.7.0 

type TaskHubSidecarService_StreamInstanceHistoryServer interface {
	Send(*HistoryChunk) error
	grpc.ServerStream
}

type TaskRouter added in v0.8.0 

type TaskRouter struct {
	SourceAppID string  `protobuf:"bytes,1,opt,name=sourceAppID,proto3" json:"sourceAppID,omitempty"`
	TargetAppID *string `protobuf:"bytes,2,opt,name=targetAppID,proto3,oneof" json:"targetAppID,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskRouter) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use TaskRouter.ProtoReflect.Descriptor instead.

func (*TaskRouter) GetSourceAppID added in v0.8.0 

func (x *TaskRouter) GetSourceAppID() string

func (*TaskRouter) GetTargetAppID added in v0.8.0 

func (x *TaskRouter) GetTargetAppID() string

func (*TaskRouter) ProtoMessage added in v0.8.0 

func (*TaskRouter) ProtoMessage()

func (*TaskRouter) ProtoReflect added in v0.8.0 

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

func (*TaskRouter) Reset added in v0.8.0 

func (x *TaskRouter) Reset()

func (*TaskRouter) String added in v0.8.0 

func (x *TaskRouter) String() string

type TaskScheduledEvent 

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

func (*TaskScheduledEvent) GetName 

func (x *TaskScheduledEvent) GetName() string

func (*TaskScheduledEvent) GetParentTraceContext 

func (x *TaskScheduledEvent) GetParentTraceContext() *TraceContext

func (*TaskScheduledEvent) GetTaskExecutionId added in v0.8.0 

func (x *TaskScheduledEvent) GetTaskExecutionId() string

func (*TaskScheduledEvent) GetVersion 

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

func (*TaskScheduledEvent) ProtoMessage 

func (*TaskScheduledEvent) ProtoMessage()

func (*TaskScheduledEvent) ProtoReflect 

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

func (*TaskScheduledEvent) Reset 

func (x *TaskScheduledEvent) Reset()

func (*TaskScheduledEvent) String 

func (x *TaskScheduledEvent) String() string

type TerminateOrchestrationAction 

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

func (*TerminateOrchestrationAction) Descriptor deprecated 

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

Deprecated: Use TerminateOrchestrationAction.ProtoReflect.Descriptor instead.

func (*TerminateOrchestrationAction) GetInstanceId 

func (x *TerminateOrchestrationAction) GetInstanceId() string

func (*TerminateOrchestrationAction) GetReason 

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

func (*TerminateOrchestrationAction) GetRecurse 

func (x *TerminateOrchestrationAction) GetRecurse() bool

func (*TerminateOrchestrationAction) ProtoMessage 

func (*TerminateOrchestrationAction) ProtoMessage()

func (*TerminateOrchestrationAction) ProtoReflect 

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

func (*TerminateOrchestrationAction) Reset 

func (x *TerminateOrchestrationAction) Reset()

func (*TerminateOrchestrationAction) String 

func (x *TerminateOrchestrationAction) String() string

type TerminateRequest 

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

func (*TerminateRequest) Descriptor deprecated 

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

Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.

func (*TerminateRequest) GetInstanceId 

func (x *TerminateRequest) GetInstanceId() string

func (*TerminateRequest) GetOutput 

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

func (*TerminateRequest) GetRecursive 

func (x *TerminateRequest) GetRecursive() bool

func (*TerminateRequest) ProtoMessage 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) ProtoReflect 

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

func (*TerminateRequest) Reset 

func (x *TerminateRequest) Reset()

func (*TerminateRequest) String 

func (x *TerminateRequest) String() string

type TerminateResponse 

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

func (*TerminateResponse) Descriptor deprecated 

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

Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.

func (*TerminateResponse) ProtoMessage 

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) ProtoReflect 

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

func (*TerminateResponse) Reset 

func (x *TerminateResponse) Reset()

func (*TerminateResponse) String 

func (x *TerminateResponse) String() string

type TimerCreatedEvent 

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

func (*TimerCreatedEvent) Descriptor deprecated 

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

Deprecated: Use TimerCreatedEvent.ProtoReflect.Descriptor instead.

func (*TimerCreatedEvent) GetFireAt 

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

func (*TimerCreatedEvent) GetName added in v0.7.0 

func (x *TimerCreatedEvent) GetName() string

func (*TimerCreatedEvent) ProtoMessage 

func (*TimerCreatedEvent) ProtoMessage()

func (*TimerCreatedEvent) ProtoReflect 

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

func (*TimerCreatedEvent) Reset 

func (x *TimerCreatedEvent) Reset()

func (*TimerCreatedEvent) String 

func (x *TimerCreatedEvent) String() string

type TimerFiredEvent 

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

func (*TimerFiredEvent) Descriptor deprecated 

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

Deprecated: Use TimerFiredEvent.ProtoReflect.Descriptor instead.

func (*TimerFiredEvent) GetFireAt 

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

func (*TimerFiredEvent) GetTimerId 

func (x *TimerFiredEvent) GetTimerId() int32

func (*TimerFiredEvent) ProtoMessage 

func (*TimerFiredEvent) ProtoMessage()

func (*TimerFiredEvent) ProtoReflect 

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

func (*TimerFiredEvent) Reset 

func (x *TimerFiredEvent) Reset()

func (*TimerFiredEvent) String 

func (x *TimerFiredEvent) String() string

type TraceContext 

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

func (*TraceContext) Descriptor deprecated 

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

Deprecated: Use TraceContext.ProtoReflect.Descriptor instead.

func (*TraceContext) GetSpanID deprecated 

func (x *TraceContext) GetSpanID() string

Deprecated: Marked as deprecated in orchestrator_service.proto.

func (*TraceContext) GetTraceParent 

func (x *TraceContext) GetTraceParent() string

func (*TraceContext) GetTraceState 

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

func (*TraceContext) ProtoMessage 

func (*TraceContext) ProtoMessage()

func (*TraceContext) ProtoReflect 

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

func (*TraceContext) Reset 

func (x *TraceContext) Reset()

func (*TraceContext) String 

func (x *TraceContext) String() string

type UnimplementedBackendServiceServer 

type UnimplementedBackendServiceServer struct {
}

UnimplementedBackendServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBackendServiceServer) AbandonActivityWorkItem 

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

func (UnimplementedBackendServiceServer) AbandonEntityWorkItem added in v0.7.0 

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

func (UnimplementedBackendServiceServer) AbandonOrchestrationWorkItem 

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

func (UnimplementedBackendServiceServer) AddEvent 

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

func (UnimplementedBackendServiceServer) CleanEntityStorage added in v0.7.0 

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

func (UnimplementedBackendServiceServer) CompleteActivityWorkItem 

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

func (UnimplementedBackendServiceServer) CompleteEntityWorkItem added in v0.7.0 

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

func (UnimplementedBackendServiceServer) CompleteOrchestrationWorkItem 

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

func (UnimplementedBackendServiceServer) CreateInstance 

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

func (UnimplementedBackendServiceServer) GetEntity added in v0.7.0 

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

func (UnimplementedBackendServiceServer) GetInstance 

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

func (UnimplementedBackendServiceServer) GetMetrics added in v0.7.0 

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

func (UnimplementedBackendServiceServer) GetOrchestrationRuntimeState 

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

func (UnimplementedBackendServiceServer) GetWorkItems 

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

func (UnimplementedBackendServiceServer) Ping 

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

func (UnimplementedBackendServiceServer) PurgeInstances 

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

func (UnimplementedBackendServiceServer) QueryEntities added in v0.7.0 

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

func (UnimplementedBackendServiceServer) QueryInstances 

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

func (UnimplementedBackendServiceServer) StreamInstanceHistory added in v0.7.0 

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

func (UnimplementedBackendServiceServer) WaitForInstance 

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

type UnimplementedTaskHubSidecarServiceServer 

type UnimplementedTaskHubSidecarServiceServer struct {
}

UnimplementedTaskHubSidecarServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskHubSidecarServiceServer) AbandonTaskActivityWorkItem added in v0.7.0 

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

func (UnimplementedTaskHubSidecarServiceServer) AbandonTaskEntityWorkItem added in v0.7.0 

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

func (UnimplementedTaskHubSidecarServiceServer) AbandonTaskOrchestratorWorkItem added in v0.7.0 

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

func (UnimplementedTaskHubSidecarServiceServer) CleanEntityStorage 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteEntityTask 

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteOrchestratorTask 

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

func (UnimplementedTaskHubSidecarServiceServer) CreateTaskHub 

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

func (UnimplementedTaskHubSidecarServiceServer) DeleteTaskHub 

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

func (UnimplementedTaskHubSidecarServiceServer) GetEntity 

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

func (UnimplementedTaskHubSidecarServiceServer) GetInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems 

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

func (UnimplementedTaskHubSidecarServiceServer) Hello 

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

func (UnimplementedTaskHubSidecarServiceServer) PurgeInstances 

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

func (UnimplementedTaskHubSidecarServiceServer) QueryEntities 

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

func (UnimplementedTaskHubSidecarServiceServer) QueryInstances 

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

func (UnimplementedTaskHubSidecarServiceServer) RaiseEvent 

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

func (UnimplementedTaskHubSidecarServiceServer) RerunWorkflowFromEvent added in v0.7.0 

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

func (UnimplementedTaskHubSidecarServiceServer) ResumeInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) RewindInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) SignalEntity 

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

func (UnimplementedTaskHubSidecarServiceServer) StartInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) StreamInstanceHistory added in v0.7.0 

func (UnimplementedTaskHubSidecarServiceServer) StreamInstanceHistory(*StreamInstanceHistoryRequest, TaskHubSidecarService_StreamInstanceHistoryServer) error

func (UnimplementedTaskHubSidecarServiceServer) SuspendInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) TerminateInstance 

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

func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceCompletion 

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

func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceStart 

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

type UnsafeBackendServiceServer 

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

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

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 WaitForInstanceRequest 

type WaitForInstanceRequest 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
}

Request payload for waiting for instance completion.

func (*WaitForInstanceRequest) Descriptor deprecated 

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

Deprecated: Use WaitForInstanceRequest.ProtoReflect.Descriptor instead.

func (*WaitForInstanceRequest) GetGetInputsAndOutputs 

func (x *WaitForInstanceRequest) GetGetInputsAndOutputs() bool

func (*WaitForInstanceRequest) GetInstanceId 

func (x *WaitForInstanceRequest) GetInstanceId() string

func (*WaitForInstanceRequest) ProtoMessage 

func (*WaitForInstanceRequest) ProtoMessage()

func (*WaitForInstanceRequest) ProtoReflect 

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

func (*WaitForInstanceRequest) Reset 

func (x *WaitForInstanceRequest) Reset()

func (*WaitForInstanceRequest) String 

func (x *WaitForInstanceRequest) String() string

type WaitForInstanceResponse 

type WaitForInstanceResponse 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
}

Response payload for waiting for instance completion.

func (*WaitForInstanceResponse) Descriptor deprecated 

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

Deprecated: Use WaitForInstanceResponse.ProtoReflect.Descriptor instead.

func (*WaitForInstanceResponse) GetExists 

func (x *WaitForInstanceResponse) GetExists() bool

func (*WaitForInstanceResponse) GetOrchestrationState 

func (x *WaitForInstanceResponse) GetOrchestrationState() *OrchestrationState

func (*WaitForInstanceResponse) ProtoMessage 

func (*WaitForInstanceResponse) ProtoMessage()

func (*WaitForInstanceResponse) ProtoReflect 

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

func (*WaitForInstanceResponse) Reset 

func (x *WaitForInstanceResponse) Reset()

func (*WaitForInstanceResponse) String 

func (x *WaitForInstanceResponse) String() string

type WorkItem 

type WorkItem struct {

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

func (*WorkItem) Descriptor deprecated 

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

Deprecated: Use WorkItem.ProtoReflect.Descriptor instead.

func (*WorkItem) GetActivityRequest 

func (x *WorkItem) GetActivityRequest() *ActivityRequest

func (*WorkItem) GetCompletionToken 

func (x *WorkItem) GetCompletionToken() string

func (*WorkItem) GetEntityRequest 

func (x *WorkItem) GetEntityRequest() *EntityBatchRequest

func (*WorkItem) GetEntityRequestV2 added in v0.7.0 

func (x *WorkItem) GetEntityRequestV2() *EntityRequest

func (*WorkItem) GetHealthPing 

func (x *WorkItem) GetHealthPing() *HealthPing

func (*WorkItem) GetOrchestratorRequest 

func (x *WorkItem) GetOrchestratorRequest() *OrchestratorRequest

func (*WorkItem) GetRequest 

func (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 WorkItemMetrics added in v0.7.0 

type WorkItemMetrics struct {

	// Number of work items that are queued and waiting to be processed
	Pending int32 `protobuf:"varint,1,opt,name=pending,proto3" json:"pending,omitempty"`
	// Number of work items that are currently being processed
	Active int32 `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	// Age of the oldest work item in the queue, in seconds
	OldestAgeInSeconds int32 `protobuf:"varint,3,opt,name=oldestAgeInSeconds,proto3" json:"oldestAgeInSeconds,omitempty"`
	// contains filtered or unexported fields
}

Metrics related to work items

func (*WorkItemMetrics) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use WorkItemMetrics.ProtoReflect.Descriptor instead.

func (*WorkItemMetrics) GetActive added in v0.7.0 

func (x *WorkItemMetrics) GetActive() int32

func (*WorkItemMetrics) GetOldestAgeInSeconds added in v0.7.0 

func (x *WorkItemMetrics) GetOldestAgeInSeconds() int32

func (*WorkItemMetrics) GetPending added in v0.7.0 

func (x *WorkItemMetrics) GetPending() int32

func (*WorkItemMetrics) ProtoMessage added in v0.7.0 

func (*WorkItemMetrics) ProtoMessage()

func (*WorkItemMetrics) ProtoReflect added in v0.7.0 

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

func (*WorkItemMetrics) Reset added in v0.7.0 

func (x *WorkItemMetrics) Reset()

func (*WorkItemMetrics) String added in v0.7.0 

func (x *WorkItemMetrics) String() string

type WorkItem_ActivityRequest 

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

type WorkItem_EntityRequest 

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

type WorkItem_EntityRequestV2 added in v0.7.0 

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

type WorkItem_HealthPing 

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

type WorkItem_OrchestratorRequest 

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

type WorkerCapability added in v0.7.0 

type WorkerCapability int32
const (
	WorkerCapability_WORKER_CAPABILITY_UNSPECIFIED WorkerCapability = 0
	// Indicates that the worker is capable of streaming instance history as a more optimized
	// alternative to receiving the full history embedded in the orchestrator work-item.
	// When set, the service may return work items without any history events as an optimization.
	// It is strongly recommended that all SDKs support this capability.
	WorkerCapability_WORKER_CAPABILITY_HISTORY_STREAMING WorkerCapability = 1
)

func (WorkerCapability) Descriptor added in v0.7.0 

func (WorkerCapability) Descriptor() protoreflect.EnumDescriptor

func (WorkerCapability) Enum added in v0.7.0 

func (x WorkerCapability) Enum() *WorkerCapability

func (WorkerCapability) EnumDescriptor deprecated added in v0.7.0 

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

Deprecated: Use WorkerCapability.Descriptor instead.

func (WorkerCapability) Number added in v0.7.0 

func (x WorkerCapability) Number() protoreflect.EnumNumber

func (WorkerCapability) String added in v0.7.0 

func (x WorkerCapability) String() string

func (WorkerCapability) Type added in v0.7.0 

func (WorkerCapability) Type() protoreflect.EnumType

type WorkflowState 

type WorkflowState struct {
	Inbox        []*HistoryEvent         `protobuf:"bytes,1,rep,name=inbox,proto3" json:"inbox,omitempty"`
	History      []*HistoryEvent         `protobuf:"bytes,2,rep,name=history,proto3" json:"history,omitempty"`
	CustomStatus *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	Generation   uint64                  `protobuf:"varint,4,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowState) Descriptor deprecated 

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

Deprecated: Use WorkflowState.ProtoReflect.Descriptor instead.

func (*WorkflowState) GetCustomStatus 

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

func (*WorkflowState) GetGeneration 

func (x *WorkflowState) GetGeneration() uint64

func (*WorkflowState) GetHistory 

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

func (*WorkflowState) GetInbox 

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

func (*WorkflowState) ProtoMessage 

func (*WorkflowState) ProtoMessage()

func (*WorkflowState) ProtoReflect 

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

func (*WorkflowState) Reset 

func (x *WorkflowState) Reset()

func (*WorkflowState) String 

func (x *WorkflowState) String() string

type WorkflowStateMetadata 

type WorkflowStateMetadata struct {
	InboxLength   uint64 `protobuf:"varint,1,opt,name=inboxLength,proto3" json:"inboxLength,omitempty"`
	HistoryLength uint64 `protobuf:"varint,2,opt,name=historyLength,proto3" json:"historyLength,omitempty"`
	Generation    uint64 `protobuf:"varint,3,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowStateMetadata) Descriptor deprecated 

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

Deprecated: Use WorkflowStateMetadata.ProtoReflect.Descriptor instead.

func (*WorkflowStateMetadata) GetGeneration 

func (x *WorkflowStateMetadata) GetGeneration() uint64

func (*WorkflowStateMetadata) GetHistoryLength 

func (x *WorkflowStateMetadata) GetHistoryLength() uint64

func (*WorkflowStateMetadata) GetInboxLength 

func (x *WorkflowStateMetadata) GetInboxLength() uint64

func (*WorkflowStateMetadata) ProtoMessage 

func (*WorkflowStateMetadata) ProtoMessage()

func (*WorkflowStateMetadata) ProtoReflect 

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

func (*WorkflowStateMetadata) Reset 

func (x *WorkflowStateMetadata) Reset()

func (*WorkflowStateMetadata) String 

func (x *WorkflowStateMetadata) String() string

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.