protos

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Dec 18, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for OrchestrationStatus.

View Source
var (
	CreateOrchestrationAction_name = map[int32]string{
		0: "ERROR",
		1: "IGNORE",
		2: "TERMINATE",
	}
	CreateOrchestrationAction_value = map[string]int32{
		"ERROR":     0,
		"IGNORE":    1,
		"TERMINATE": 2,
	}
)

Enum value maps for CreateOrchestrationAction.

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

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

Functions

func RegisterTaskHubSidecarServiceServer

func RegisterTaskHubSidecarServiceServer(s grpc.ServiceRegistrar, srv TaskHubSidecarServiceServer)

Types

type ActivityRequest

type ActivityRequest struct {
	Name                  string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version               *wrappers.StringValue  `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input                 *wrappers.StringValue  `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	OrchestrationInstance *OrchestrationInstance `protobuf:"bytes,4,opt,name=orchestrationInstance,proto3" json:"orchestrationInstance,omitempty"`
	TaskId                int32                  `protobuf:"varint,5,opt,name=taskId,proto3" json:"taskId,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityRequest) Descriptor deprecated

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

Deprecated: Use ActivityRequest.ProtoReflect.Descriptor instead.

func (*ActivityRequest) GetInput

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

func (*ActivityRequest) GetName

func (x *ActivityRequest) GetName() string

func (*ActivityRequest) GetOrchestrationInstance

func (x *ActivityRequest) GetOrchestrationInstance() *OrchestrationInstance

func (*ActivityRequest) GetTaskId

func (x *ActivityRequest) GetTaskId() int32

func (*ActivityRequest) GetVersion

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

func (*ActivityRequest) ProtoMessage

func (*ActivityRequest) ProtoMessage()

func (*ActivityRequest) ProtoReflect

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

func (*ActivityRequest) Reset

func (x *ActivityRequest) Reset()

func (*ActivityRequest) String

func (x *ActivityRequest) String() string

type ActivityResponse

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

func (*ActivityResponse) Descriptor deprecated

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

Deprecated: Use ActivityResponse.ProtoReflect.Descriptor instead.

func (*ActivityResponse) GetFailureDetails

func (x *ActivityResponse) GetFailureDetails() *TaskFailureDetails

func (*ActivityResponse) GetInstanceId

func (x *ActivityResponse) GetInstanceId() string

func (*ActivityResponse) GetResult

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

func (*ActivityResponse) GetTaskId

func (x *ActivityResponse) GetTaskId() int32

func (*ActivityResponse) ProtoMessage

func (*ActivityResponse) ProtoMessage()

func (*ActivityResponse) ProtoReflect

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

func (*ActivityResponse) Reset

func (x *ActivityResponse) Reset()

func (*ActivityResponse) String

func (x *ActivityResponse) String() string

type CleanEntityStorageRequest added in v0.3.2

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

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

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

Deprecated: Use CleanEntityStorageRequest.ProtoReflect.Descriptor instead.

func (*CleanEntityStorageRequest) GetContinuationToken added in v0.3.2

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

func (*CleanEntityStorageRequest) GetReleaseOrphanedLocks added in v0.3.2

func (x *CleanEntityStorageRequest) GetReleaseOrphanedLocks() bool

func (*CleanEntityStorageRequest) GetRemoveEmptyEntities added in v0.3.2

func (x *CleanEntityStorageRequest) GetRemoveEmptyEntities() bool

func (*CleanEntityStorageRequest) ProtoMessage added in v0.3.2

func (*CleanEntityStorageRequest) ProtoMessage()

func (*CleanEntityStorageRequest) ProtoReflect added in v0.3.2

func (*CleanEntityStorageRequest) Reset added in v0.3.2

func (x *CleanEntityStorageRequest) Reset()

func (*CleanEntityStorageRequest) String added in v0.3.2

func (x *CleanEntityStorageRequest) String() string

type CleanEntityStorageResponse added in v0.3.2

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

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

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

Deprecated: Use CleanEntityStorageResponse.ProtoReflect.Descriptor instead.

func (*CleanEntityStorageResponse) GetContinuationToken added in v0.3.2

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

func (*CleanEntityStorageResponse) GetEmptyEntitiesRemoved added in v0.3.2

func (x *CleanEntityStorageResponse) GetEmptyEntitiesRemoved() int32

func (*CleanEntityStorageResponse) GetOrphanedLocksReleased added in v0.3.2

func (x *CleanEntityStorageResponse) GetOrphanedLocksReleased() int32

func (*CleanEntityStorageResponse) ProtoMessage added in v0.3.2

func (*CleanEntityStorageResponse) ProtoMessage()

func (*CleanEntityStorageResponse) ProtoReflect added in v0.3.2

func (*CleanEntityStorageResponse) Reset added in v0.3.2

func (x *CleanEntityStorageResponse) Reset()

func (*CleanEntityStorageResponse) String added in v0.3.2

func (x *CleanEntityStorageResponse) String() string

type CompleteOrchestrationAction

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

func (*CompleteOrchestrationAction) Descriptor deprecated

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

Deprecated: Use CompleteOrchestrationAction.ProtoReflect.Descriptor instead.

func (*CompleteOrchestrationAction) GetCarryoverEvents

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

func (*CompleteOrchestrationAction) GetDetails

func (*CompleteOrchestrationAction) GetFailureDetails

func (x *CompleteOrchestrationAction) GetFailureDetails() *TaskFailureDetails

func (*CompleteOrchestrationAction) GetNewVersion

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

func (*CompleteOrchestrationAction) GetOrchestrationStatus

func (x *CompleteOrchestrationAction) GetOrchestrationStatus() OrchestrationStatus

func (*CompleteOrchestrationAction) GetResult

func (*CompleteOrchestrationAction) ProtoMessage

func (*CompleteOrchestrationAction) ProtoMessage()

func (*CompleteOrchestrationAction) ProtoReflect

func (*CompleteOrchestrationAction) Reset

func (x *CompleteOrchestrationAction) Reset()

func (*CompleteOrchestrationAction) String

func (x *CompleteOrchestrationAction) String() string

type CompleteTaskResponse

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

func (*CompleteTaskResponse) Descriptor deprecated

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

Deprecated: Use CompleteTaskResponse.ProtoReflect.Descriptor instead.

func (*CompleteTaskResponse) ProtoMessage

func (*CompleteTaskResponse) ProtoMessage()

func (*CompleteTaskResponse) ProtoReflect

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

func (*CompleteTaskResponse) Reset

func (x *CompleteTaskResponse) Reset()

func (*CompleteTaskResponse) String

func (x *CompleteTaskResponse) String() string

type ContinueAsNewEvent

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

func (*ContinueAsNewEvent) Descriptor deprecated

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

Deprecated: Use ContinueAsNewEvent.ProtoReflect.Descriptor instead.

func (*ContinueAsNewEvent) GetInput

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

func (*ContinueAsNewEvent) ProtoMessage

func (*ContinueAsNewEvent) ProtoMessage()

func (*ContinueAsNewEvent) ProtoReflect

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

func (*ContinueAsNewEvent) Reset

func (x *ContinueAsNewEvent) Reset()

func (*ContinueAsNewEvent) String

func (x *ContinueAsNewEvent) String() string

type CreateInstanceRequest

type CreateInstanceRequest struct {
	InstanceId                 string                      `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name                       string                      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version                    *wrappers.StringValue       `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input                      *wrappers.StringValue       `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledStartTimestamp    *timestamp.Timestamp        `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	OrchestrationIdReusePolicy *OrchestrationIdReusePolicy `protobuf:"bytes,6,opt,name=orchestrationIdReusePolicy,proto3" json:"orchestrationIdReusePolicy,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateInstanceRequest) Descriptor deprecated

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

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetInput

func (*CreateInstanceRequest) GetInstanceId

func (x *CreateInstanceRequest) GetInstanceId() string

func (*CreateInstanceRequest) GetName

func (x *CreateInstanceRequest) GetName() string

func (*CreateInstanceRequest) GetOrchestrationIdReusePolicy added in v0.3.2

func (x *CreateInstanceRequest) GetOrchestrationIdReusePolicy() *OrchestrationIdReusePolicy

func (*CreateInstanceRequest) GetScheduledStartTimestamp

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

func (*CreateInstanceRequest) GetVersion

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

func (*CreateInstanceRequest) ProtoMessage

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) ProtoReflect

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

func (*CreateInstanceRequest) Reset

func (x *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String

func (x *CreateInstanceRequest) String() string

type CreateInstanceResponse

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

func (*CreateInstanceResponse) Descriptor deprecated

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

Deprecated: Use CreateInstanceResponse.ProtoReflect.Descriptor instead.

func (*CreateInstanceResponse) GetInstanceId

func (x *CreateInstanceResponse) GetInstanceId() string

func (*CreateInstanceResponse) ProtoMessage

func (*CreateInstanceResponse) ProtoMessage()

func (*CreateInstanceResponse) ProtoReflect

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

func (*CreateInstanceResponse) Reset

func (x *CreateInstanceResponse) Reset()

func (*CreateInstanceResponse) String

func (x *CreateInstanceResponse) String() string

type CreateOrchestrationAction added in v0.3.2

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

func (CreateOrchestrationAction) Descriptor added in v0.3.2

func (CreateOrchestrationAction) Enum added in v0.3.2

func (CreateOrchestrationAction) EnumDescriptor deprecated added in v0.3.2

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

Deprecated: Use CreateOrchestrationAction.Descriptor instead.

func (CreateOrchestrationAction) Number added in v0.3.2

func (CreateOrchestrationAction) String added in v0.3.2

func (x CreateOrchestrationAction) String() string

func (CreateOrchestrationAction) Type added in v0.3.2

type CreateSubOrchestrationAction

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

func (*CreateSubOrchestrationAction) Descriptor deprecated

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

Deprecated: Use CreateSubOrchestrationAction.ProtoReflect.Descriptor instead.

func (*CreateSubOrchestrationAction) GetInput

func (*CreateSubOrchestrationAction) GetInstanceId

func (x *CreateSubOrchestrationAction) GetInstanceId() string

func (*CreateSubOrchestrationAction) GetName

func (x *CreateSubOrchestrationAction) GetName() string

func (*CreateSubOrchestrationAction) GetVersion

func (*CreateSubOrchestrationAction) ProtoMessage

func (*CreateSubOrchestrationAction) ProtoMessage()

func (*CreateSubOrchestrationAction) ProtoReflect

func (*CreateSubOrchestrationAction) Reset

func (x *CreateSubOrchestrationAction) Reset()

func (*CreateSubOrchestrationAction) String

type CreateTaskHubRequest

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

func (*CreateTaskHubRequest) Descriptor deprecated

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

Deprecated: Use CreateTaskHubRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskHubRequest) GetRecreateIfExists

func (x *CreateTaskHubRequest) GetRecreateIfExists() bool

func (*CreateTaskHubRequest) ProtoMessage

func (*CreateTaskHubRequest) ProtoMessage()

func (*CreateTaskHubRequest) ProtoReflect

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

func (*CreateTaskHubRequest) Reset

func (x *CreateTaskHubRequest) Reset()

func (*CreateTaskHubRequest) String

func (x *CreateTaskHubRequest) String() string

type CreateTaskHubResponse

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

func (*CreateTaskHubResponse) Descriptor deprecated

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

Deprecated: Use CreateTaskHubResponse.ProtoReflect.Descriptor instead.

func (*CreateTaskHubResponse) ProtoMessage

func (*CreateTaskHubResponse) ProtoMessage()

func (*CreateTaskHubResponse) ProtoReflect

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

func (*CreateTaskHubResponse) Reset

func (x *CreateTaskHubResponse) Reset()

func (*CreateTaskHubResponse) String

func (x *CreateTaskHubResponse) String() string

type CreateTimerAction

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

func (*CreateTimerAction) Descriptor deprecated

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

Deprecated: Use CreateTimerAction.ProtoReflect.Descriptor instead.

func (*CreateTimerAction) GetFireAt

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

func (*CreateTimerAction) ProtoMessage

func (*CreateTimerAction) ProtoMessage()

func (*CreateTimerAction) ProtoReflect

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

func (*CreateTimerAction) Reset

func (x *CreateTimerAction) Reset()

func (*CreateTimerAction) String

func (x *CreateTimerAction) String() string

type DeleteTaskHubRequest

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

func (*DeleteTaskHubRequest) Descriptor deprecated

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

Deprecated: Use DeleteTaskHubRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskHubRequest) ProtoMessage

func (*DeleteTaskHubRequest) ProtoMessage()

func (*DeleteTaskHubRequest) ProtoReflect

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

func (*DeleteTaskHubRequest) Reset

func (x *DeleteTaskHubRequest) Reset()

func (*DeleteTaskHubRequest) String

func (x *DeleteTaskHubRequest) String() string

type DeleteTaskHubResponse

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

func (*DeleteTaskHubResponse) Descriptor deprecated

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

Deprecated: Use DeleteTaskHubResponse.ProtoReflect.Descriptor instead.

func (*DeleteTaskHubResponse) ProtoMessage

func (*DeleteTaskHubResponse) ProtoMessage()

func (*DeleteTaskHubResponse) ProtoReflect

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

func (*DeleteTaskHubResponse) Reset

func (x *DeleteTaskHubResponse) Reset()

func (*DeleteTaskHubResponse) String

func (x *DeleteTaskHubResponse) String() string

type EntityBatchRequest added in v0.3.2

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

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

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

Deprecated: Use EntityBatchRequest.ProtoReflect.Descriptor instead.

func (*EntityBatchRequest) GetEntityState added in v0.3.2

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

func (*EntityBatchRequest) GetInstanceId added in v0.3.2

func (x *EntityBatchRequest) GetInstanceId() string

func (*EntityBatchRequest) GetOperations added in v0.3.2

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

func (*EntityBatchRequest) ProtoMessage added in v0.3.2

func (*EntityBatchRequest) ProtoMessage()

func (*EntityBatchRequest) ProtoReflect added in v0.3.2

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

func (*EntityBatchRequest) Reset added in v0.3.2

func (x *EntityBatchRequest) Reset()

func (*EntityBatchRequest) String added in v0.3.2

func (x *EntityBatchRequest) String() string

type EntityBatchResult added in v0.3.2

type EntityBatchResult struct {
	Results        []*OperationResult    `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	Actions        []*OperationAction    `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	EntityState    *wrappers.StringValue `protobuf:"bytes,3,opt,name=entityState,proto3" json:"entityState,omitempty"`
	FailureDetails *TaskFailureDetails   `protobuf:"bytes,4,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use EntityBatchResult.ProtoReflect.Descriptor instead.

func (*EntityBatchResult) GetActions added in v0.3.2

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

func (*EntityBatchResult) GetEntityState added in v0.3.2

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

func (*EntityBatchResult) GetFailureDetails added in v0.3.2

func (x *EntityBatchResult) GetFailureDetails() *TaskFailureDetails

func (*EntityBatchResult) GetResults added in v0.3.2

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

func (*EntityBatchResult) ProtoMessage added in v0.3.2

func (*EntityBatchResult) ProtoMessage()

func (*EntityBatchResult) ProtoReflect added in v0.3.2

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

func (*EntityBatchResult) Reset added in v0.3.2

func (x *EntityBatchResult) Reset()

func (*EntityBatchResult) String added in v0.3.2

func (x *EntityBatchResult) String() string

type EntityMetadata added in v0.3.2

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

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

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

Deprecated: Use EntityMetadata.ProtoReflect.Descriptor instead.

func (*EntityMetadata) GetBacklogQueueSize added in v0.3.2

func (x *EntityMetadata) GetBacklogQueueSize() int32

func (*EntityMetadata) GetInstanceId added in v0.3.2

func (x *EntityMetadata) GetInstanceId() string

func (*EntityMetadata) GetLastModifiedTime added in v0.3.2

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

func (*EntityMetadata) GetLockedBy added in v0.3.2

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

func (*EntityMetadata) GetSerializedState added in v0.3.2

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

func (*EntityMetadata) ProtoMessage added in v0.3.2

func (*EntityMetadata) ProtoMessage()

func (*EntityMetadata) ProtoReflect added in v0.3.2

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

func (*EntityMetadata) Reset added in v0.3.2

func (x *EntityMetadata) Reset()

func (*EntityMetadata) String added in v0.3.2

func (x *EntityMetadata) String() string

type EntityQuery added in v0.3.2

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

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

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

Deprecated: Use EntityQuery.ProtoReflect.Descriptor instead.

func (*EntityQuery) GetContinuationToken added in v0.3.2

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

func (*EntityQuery) GetIncludeState added in v0.3.2

func (x *EntityQuery) GetIncludeState() bool

func (*EntityQuery) GetIncludeTransient added in v0.3.2

func (x *EntityQuery) GetIncludeTransient() bool

func (*EntityQuery) GetInstanceIdStartsWith added in v0.3.2

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

func (*EntityQuery) GetLastModifiedFrom added in v0.3.2

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

func (*EntityQuery) GetLastModifiedTo added in v0.3.2

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

func (*EntityQuery) GetPageSize added in v0.3.2

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

func (*EntityQuery) ProtoMessage added in v0.3.2

func (*EntityQuery) ProtoMessage()

func (*EntityQuery) ProtoReflect added in v0.3.2

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

func (*EntityQuery) Reset added in v0.3.2

func (x *EntityQuery) Reset()

func (*EntityQuery) String added in v0.3.2

func (x *EntityQuery) String() string

type EventRaisedEvent

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

func (*EventRaisedEvent) Descriptor deprecated

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

Deprecated: Use EventRaisedEvent.ProtoReflect.Descriptor instead.

func (*EventRaisedEvent) GetInput

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

func (*EventRaisedEvent) GetName

func (x *EventRaisedEvent) GetName() string

func (*EventRaisedEvent) ProtoMessage

func (*EventRaisedEvent) ProtoMessage()

func (*EventRaisedEvent) ProtoReflect

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

func (*EventRaisedEvent) Reset

func (x *EventRaisedEvent) Reset()

func (*EventRaisedEvent) String

func (x *EventRaisedEvent) String() string

type EventSentEvent

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

func (*EventSentEvent) Descriptor deprecated

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

Deprecated: Use EventSentEvent.ProtoReflect.Descriptor instead.

func (*EventSentEvent) GetInput

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

func (*EventSentEvent) GetInstanceId

func (x *EventSentEvent) GetInstanceId() string

func (*EventSentEvent) GetName

func (x *EventSentEvent) GetName() string

func (*EventSentEvent) ProtoMessage

func (*EventSentEvent) ProtoMessage()

func (*EventSentEvent) ProtoReflect

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

func (*EventSentEvent) Reset

func (x *EventSentEvent) Reset()

func (*EventSentEvent) String

func (x *EventSentEvent) String() string

type ExecutionCompletedEvent

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

func (*ExecutionCompletedEvent) Descriptor deprecated

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

Deprecated: Use ExecutionCompletedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionCompletedEvent) GetFailureDetails

func (x *ExecutionCompletedEvent) GetFailureDetails() *TaskFailureDetails

func (*ExecutionCompletedEvent) GetOrchestrationStatus

func (x *ExecutionCompletedEvent) GetOrchestrationStatus() OrchestrationStatus

func (*ExecutionCompletedEvent) GetResult

func (*ExecutionCompletedEvent) ProtoMessage

func (*ExecutionCompletedEvent) ProtoMessage()

func (*ExecutionCompletedEvent) ProtoReflect

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

func (*ExecutionCompletedEvent) Reset

func (x *ExecutionCompletedEvent) Reset()

func (*ExecutionCompletedEvent) String

func (x *ExecutionCompletedEvent) String() string

type ExecutionResumedEvent added in v0.1.1

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

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

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

Deprecated: Use ExecutionResumedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionResumedEvent) GetInput added in v0.1.1

func (*ExecutionResumedEvent) ProtoMessage added in v0.1.1

func (*ExecutionResumedEvent) ProtoMessage()

func (*ExecutionResumedEvent) ProtoReflect added in v0.1.1

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

func (*ExecutionResumedEvent) Reset added in v0.1.1

func (x *ExecutionResumedEvent) Reset()

func (*ExecutionResumedEvent) String added in v0.1.1

func (x *ExecutionResumedEvent) String() string

type ExecutionStartedEvent

type ExecutionStartedEvent struct {
	Name                    string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version                 *wrappers.StringValue  `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input                   *wrappers.StringValue  `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	OrchestrationInstance   *OrchestrationInstance `protobuf:"bytes,4,opt,name=orchestrationInstance,proto3" json:"orchestrationInstance,omitempty"`
	ParentInstance          *ParentInstanceInfo    `protobuf:"bytes,5,opt,name=parentInstance,proto3" json:"parentInstance,omitempty"`
	ScheduledStartTimestamp *timestamp.Timestamp   `protobuf:"bytes,6,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	ParentTraceContext      *TraceContext          `protobuf:"bytes,7,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	OrchestrationSpanID     *wrappers.StringValue  `protobuf:"bytes,8,opt,name=orchestrationSpanID,proto3" json:"orchestrationSpanID,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionStartedEvent) Descriptor deprecated

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

Deprecated: Use ExecutionStartedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionStartedEvent) GetInput

func (*ExecutionStartedEvent) GetName

func (x *ExecutionStartedEvent) GetName() string

func (*ExecutionStartedEvent) GetOrchestrationInstance

func (x *ExecutionStartedEvent) GetOrchestrationInstance() *OrchestrationInstance

func (*ExecutionStartedEvent) GetOrchestrationSpanID added in v0.1.1

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

func (*ExecutionStartedEvent) GetParentInstance

func (x *ExecutionStartedEvent) GetParentInstance() *ParentInstanceInfo

func (*ExecutionStartedEvent) GetParentTraceContext added in v0.1.1

func (x *ExecutionStartedEvent) GetParentTraceContext() *TraceContext

func (*ExecutionStartedEvent) GetScheduledStartTimestamp

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

func (*ExecutionStartedEvent) GetVersion

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

func (*ExecutionStartedEvent) ProtoMessage

func (*ExecutionStartedEvent) ProtoMessage()

func (*ExecutionStartedEvent) ProtoReflect

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

func (*ExecutionStartedEvent) Reset

func (x *ExecutionStartedEvent) Reset()

func (*ExecutionStartedEvent) String

func (x *ExecutionStartedEvent) String() string

type ExecutionSuspendedEvent added in v0.1.1

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

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

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

Deprecated: Use ExecutionSuspendedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionSuspendedEvent) GetInput added in v0.1.1

func (*ExecutionSuspendedEvent) ProtoMessage added in v0.1.1

func (*ExecutionSuspendedEvent) ProtoMessage()

func (*ExecutionSuspendedEvent) ProtoReflect added in v0.1.1

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

func (*ExecutionSuspendedEvent) Reset added in v0.1.1

func (x *ExecutionSuspendedEvent) Reset()

func (*ExecutionSuspendedEvent) String added in v0.1.1

func (x *ExecutionSuspendedEvent) String() string

type ExecutionTerminatedEvent

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

func (*ExecutionTerminatedEvent) Descriptor deprecated

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

Deprecated: Use ExecutionTerminatedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionTerminatedEvent) GetInput

func (*ExecutionTerminatedEvent) GetRecurse added in v0.3.0

func (x *ExecutionTerminatedEvent) GetRecurse() bool

func (*ExecutionTerminatedEvent) ProtoMessage

func (*ExecutionTerminatedEvent) ProtoMessage()

func (*ExecutionTerminatedEvent) ProtoReflect

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

func (*ExecutionTerminatedEvent) Reset

func (x *ExecutionTerminatedEvent) Reset()

func (*ExecutionTerminatedEvent) String

func (x *ExecutionTerminatedEvent) String() string

type GenericEvent

type GenericEvent struct {
	Data string `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() string

func (*GenericEvent) ProtoMessage

func (*GenericEvent) ProtoMessage()

func (*GenericEvent) ProtoReflect

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

func (*GenericEvent) Reset

func (x *GenericEvent) Reset()

func (*GenericEvent) String

func (x *GenericEvent) String() string

type GetEntityRequest added in v0.3.2

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

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

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

Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.

func (*GetEntityRequest) GetIncludeState added in v0.3.2

func (x *GetEntityRequest) GetIncludeState() bool

func (*GetEntityRequest) GetInstanceId added in v0.3.2

func (x *GetEntityRequest) GetInstanceId() string

func (*GetEntityRequest) ProtoMessage added in v0.3.2

func (*GetEntityRequest) ProtoMessage()

func (*GetEntityRequest) ProtoReflect added in v0.3.2

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

func (*GetEntityRequest) Reset added in v0.3.2

func (x *GetEntityRequest) Reset()

func (*GetEntityRequest) String added in v0.3.2

func (x *GetEntityRequest) String() string

type GetEntityResponse added in v0.3.2

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

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

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

Deprecated: Use GetEntityResponse.ProtoReflect.Descriptor instead.

func (*GetEntityResponse) GetEntity added in v0.3.2

func (x *GetEntityResponse) GetEntity() *EntityMetadata

func (*GetEntityResponse) GetExists added in v0.3.2

func (x *GetEntityResponse) GetExists() bool

func (*GetEntityResponse) ProtoMessage added in v0.3.2

func (*GetEntityResponse) ProtoMessage()

func (*GetEntityResponse) ProtoReflect added in v0.3.2

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

func (*GetEntityResponse) Reset added in v0.3.2

func (x *GetEntityResponse) Reset()

func (*GetEntityResponse) String added in v0.3.2

func (x *GetEntityResponse) String() string

type GetInstanceRequest

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

func (*GetInstanceRequest) Descriptor deprecated

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

Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceRequest) GetGetInputsAndOutputs

func (x *GetInstanceRequest) GetGetInputsAndOutputs() bool

func (*GetInstanceRequest) GetInstanceId

func (x *GetInstanceRequest) GetInstanceId() string

func (*GetInstanceRequest) ProtoMessage

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) ProtoReflect

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

func (*GetInstanceRequest) Reset

func (x *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String

func (x *GetInstanceRequest) String() string

type GetInstanceResponse

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

func (*GetInstanceResponse) Descriptor deprecated

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

Deprecated: Use GetInstanceResponse.ProtoReflect.Descriptor instead.

func (*GetInstanceResponse) GetExists

func (x *GetInstanceResponse) GetExists() bool

func (*GetInstanceResponse) GetOrchestrationState

func (x *GetInstanceResponse) GetOrchestrationState() *OrchestrationState

func (*GetInstanceResponse) ProtoMessage

func (*GetInstanceResponse) ProtoMessage()

func (*GetInstanceResponse) ProtoReflect

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

func (*GetInstanceResponse) Reset

func (x *GetInstanceResponse) Reset()

func (*GetInstanceResponse) String

func (x *GetInstanceResponse) String() string

type GetWorkItemsRequest

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

func (*GetWorkItemsRequest) Descriptor deprecated

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

Deprecated: Use GetWorkItemsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkItemsRequest) ProtoMessage

func (*GetWorkItemsRequest) ProtoMessage()

func (*GetWorkItemsRequest) ProtoReflect

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

func (*GetWorkItemsRequest) Reset

func (x *GetWorkItemsRequest) Reset()

func (*GetWorkItemsRequest) String

func (x *GetWorkItemsRequest) String() string

type HistoryEvent

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

func (*HistoryEvent) Descriptor deprecated

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

Deprecated: Use HistoryEvent.ProtoReflect.Descriptor instead.

func (*HistoryEvent) GetContinueAsNew

func (x *HistoryEvent) GetContinueAsNew() *ContinueAsNewEvent

func (*HistoryEvent) GetEventId

func (x *HistoryEvent) GetEventId() int32

func (*HistoryEvent) GetEventRaised

func (x *HistoryEvent) GetEventRaised() *EventRaisedEvent

func (*HistoryEvent) GetEventSent

func (x *HistoryEvent) GetEventSent() *EventSentEvent

func (*HistoryEvent) GetEventType

func (m *HistoryEvent) GetEventType() isHistoryEvent_EventType

func (*HistoryEvent) GetExecutionCompleted

func (x *HistoryEvent) GetExecutionCompleted() *ExecutionCompletedEvent

func (*HistoryEvent) GetExecutionResumed added in v0.1.1

func (x *HistoryEvent) GetExecutionResumed() *ExecutionResumedEvent

func (*HistoryEvent) GetExecutionStarted

func (x *HistoryEvent) GetExecutionStarted() *ExecutionStartedEvent

func (*HistoryEvent) GetExecutionSuspended added in v0.1.1

func (x *HistoryEvent) GetExecutionSuspended() *ExecutionSuspendedEvent

func (*HistoryEvent) GetExecutionTerminated

func (x *HistoryEvent) GetExecutionTerminated() *ExecutionTerminatedEvent

func (*HistoryEvent) GetGenericEvent

func (x *HistoryEvent) GetGenericEvent() *GenericEvent

func (*HistoryEvent) GetHistoryState

func (x *HistoryEvent) GetHistoryState() *HistoryStateEvent

func (*HistoryEvent) GetOrchestratorCompleted

func (x *HistoryEvent) GetOrchestratorCompleted() *OrchestratorCompletedEvent

func (*HistoryEvent) GetOrchestratorStarted

func (x *HistoryEvent) GetOrchestratorStarted() *OrchestratorStartedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceCompleted

func (x *HistoryEvent) GetSubOrchestrationInstanceCompleted() *SubOrchestrationInstanceCompletedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceCreated

func (x *HistoryEvent) GetSubOrchestrationInstanceCreated() *SubOrchestrationInstanceCreatedEvent

func (*HistoryEvent) GetSubOrchestrationInstanceFailed

func (x *HistoryEvent) GetSubOrchestrationInstanceFailed() *SubOrchestrationInstanceFailedEvent

func (*HistoryEvent) GetTaskCompleted

func (x *HistoryEvent) GetTaskCompleted() *TaskCompletedEvent

func (*HistoryEvent) GetTaskFailed

func (x *HistoryEvent) GetTaskFailed() *TaskFailedEvent

func (*HistoryEvent) GetTaskScheduled

func (x *HistoryEvent) GetTaskScheduled() *TaskScheduledEvent

func (*HistoryEvent) GetTimerCreated

func (x *HistoryEvent) GetTimerCreated() *TimerCreatedEvent

func (*HistoryEvent) GetTimerFired

func (x *HistoryEvent) GetTimerFired() *TimerFiredEvent

func (*HistoryEvent) GetTimestamp

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

func (*HistoryEvent) ProtoMessage

func (*HistoryEvent) ProtoMessage()

func (*HistoryEvent) ProtoReflect

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

func (*HistoryEvent) Reset

func (x *HistoryEvent) Reset()

func (*HistoryEvent) String

func (x *HistoryEvent) String() string

type HistoryEvent_ContinueAsNew

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

type HistoryEvent_EventRaised

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

type HistoryEvent_EventSent

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

type HistoryEvent_ExecutionCompleted

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

type HistoryEvent_ExecutionResumed added in v0.1.1

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

type HistoryEvent_ExecutionStarted

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

type HistoryEvent_ExecutionSuspended added in v0.1.1

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

type HistoryEvent_ExecutionTerminated

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

type HistoryEvent_GenericEvent

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

type HistoryEvent_HistoryState

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

type HistoryEvent_OrchestratorCompleted

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

type HistoryEvent_OrchestratorStarted

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

type HistoryEvent_SubOrchestrationInstanceCompleted

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

type HistoryEvent_SubOrchestrationInstanceCreated

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

type HistoryEvent_SubOrchestrationInstanceFailed

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

type HistoryEvent_TaskCompleted

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

type HistoryEvent_TaskFailed

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

type HistoryEvent_TaskScheduled

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

type HistoryEvent_TimerCreated

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

type HistoryEvent_TimerFired

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

type HistoryStateEvent

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

func (*HistoryStateEvent) Descriptor deprecated

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

Deprecated: Use HistoryStateEvent.ProtoReflect.Descriptor instead.

func (*HistoryStateEvent) GetOrchestrationState

func (x *HistoryStateEvent) GetOrchestrationState() *OrchestrationState

func (*HistoryStateEvent) ProtoMessage

func (*HistoryStateEvent) ProtoMessage()

func (*HistoryStateEvent) ProtoReflect

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

func (*HistoryStateEvent) Reset

func (x *HistoryStateEvent) Reset()

func (*HistoryStateEvent) String

func (x *HistoryStateEvent) String() string

type InstanceQuery

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

func (*InstanceQuery) Descriptor deprecated

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

Deprecated: Use InstanceQuery.ProtoReflect.Descriptor instead.

func (*InstanceQuery) GetContinuationToken

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

func (*InstanceQuery) GetCreatedTimeFrom

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

func (*InstanceQuery) GetCreatedTimeTo

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

func (*InstanceQuery) GetFetchInputsAndOutputs

func (x *InstanceQuery) GetFetchInputsAndOutputs() bool

func (*InstanceQuery) GetInstanceIdPrefix

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

func (*InstanceQuery) GetMaxInstanceCount

func (x *InstanceQuery) GetMaxInstanceCount() int32

func (*InstanceQuery) GetRuntimeStatus

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

func (*InstanceQuery) GetTaskHubNames

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

func (*InstanceQuery) ProtoMessage

func (*InstanceQuery) ProtoMessage()

func (*InstanceQuery) ProtoReflect

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

func (*InstanceQuery) Reset

func (x *InstanceQuery) Reset()

func (*InstanceQuery) String

func (x *InstanceQuery) String() string

type OperationAction added in v0.3.2

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

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

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

Deprecated: Use OperationAction.ProtoReflect.Descriptor instead.

func (*OperationAction) GetId added in v0.3.2

func (x *OperationAction) GetId() int32

func (*OperationAction) GetOperationActionType added in v0.3.2

func (m *OperationAction) GetOperationActionType() isOperationAction_OperationActionType

func (*OperationAction) GetSendSignal added in v0.3.2

func (x *OperationAction) GetSendSignal() *SendSignalAction

func (*OperationAction) GetStartNewOrchestration added in v0.3.2

func (x *OperationAction) GetStartNewOrchestration() *StartNewOrchestrationAction

func (*OperationAction) ProtoMessage added in v0.3.2

func (*OperationAction) ProtoMessage()

func (*OperationAction) ProtoReflect added in v0.3.2

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

func (*OperationAction) Reset added in v0.3.2

func (x *OperationAction) Reset()

func (*OperationAction) String added in v0.3.2

func (x *OperationAction) String() string

type OperationAction_SendSignal added in v0.3.2

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

type OperationAction_StartNewOrchestration added in v0.3.2

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

type OperationRequest added in v0.3.2

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

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

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

Deprecated: Use OperationRequest.ProtoReflect.Descriptor instead.

func (*OperationRequest) GetInput added in v0.3.2

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

func (*OperationRequest) GetOperation added in v0.3.2

func (x *OperationRequest) GetOperation() string

func (*OperationRequest) GetRequestId added in v0.3.2

func (x *OperationRequest) GetRequestId() string

func (*OperationRequest) ProtoMessage added in v0.3.2

func (*OperationRequest) ProtoMessage()

func (*OperationRequest) ProtoReflect added in v0.3.2

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

func (*OperationRequest) Reset added in v0.3.2

func (x *OperationRequest) Reset()

func (*OperationRequest) String added in v0.3.2

func (x *OperationRequest) String() string

type OperationResult added in v0.3.2

type OperationResult struct {

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

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

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

Deprecated: Use OperationResult.ProtoReflect.Descriptor instead.

func (*OperationResult) GetFailure added in v0.3.2

func (x *OperationResult) GetFailure() *OperationResultFailure

func (*OperationResult) GetResultType added in v0.3.2

func (m *OperationResult) GetResultType() isOperationResult_ResultType

func (*OperationResult) GetSuccess added in v0.3.2

func (x *OperationResult) GetSuccess() *OperationResultSuccess

func (*OperationResult) ProtoMessage added in v0.3.2

func (*OperationResult) ProtoMessage()

func (*OperationResult) ProtoReflect added in v0.3.2

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

func (*OperationResult) Reset added in v0.3.2

func (x *OperationResult) Reset()

func (*OperationResult) String added in v0.3.2

func (x *OperationResult) String() string

type OperationResultFailure added in v0.3.2

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

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

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

Deprecated: Use OperationResultFailure.ProtoReflect.Descriptor instead.

func (*OperationResultFailure) GetFailureDetails added in v0.3.2

func (x *OperationResultFailure) GetFailureDetails() *TaskFailureDetails

func (*OperationResultFailure) ProtoMessage added in v0.3.2

func (*OperationResultFailure) ProtoMessage()

func (*OperationResultFailure) ProtoReflect added in v0.3.2

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

func (*OperationResultFailure) Reset added in v0.3.2

func (x *OperationResultFailure) Reset()

func (*OperationResultFailure) String added in v0.3.2

func (x *OperationResultFailure) String() string

type OperationResultSuccess added in v0.3.2

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

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

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

Deprecated: Use OperationResultSuccess.ProtoReflect.Descriptor instead.

func (*OperationResultSuccess) GetResult added in v0.3.2

func (*OperationResultSuccess) ProtoMessage added in v0.3.2

func (*OperationResultSuccess) ProtoMessage()

func (*OperationResultSuccess) ProtoReflect added in v0.3.2

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

func (*OperationResultSuccess) Reset added in v0.3.2

func (x *OperationResultSuccess) Reset()

func (*OperationResultSuccess) String added in v0.3.2

func (x *OperationResultSuccess) String() string

type OperationResult_Failure added in v0.3.2

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

type OperationResult_Success added in v0.3.2

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

type OrchestrationIdReusePolicy added in v0.3.2

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

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

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

Deprecated: Use OrchestrationIdReusePolicy.ProtoReflect.Descriptor instead.

func (*OrchestrationIdReusePolicy) GetAction added in v0.3.2

func (*OrchestrationIdReusePolicy) GetOperationStatus added in v0.3.2

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

func (*OrchestrationIdReusePolicy) ProtoMessage added in v0.3.2

func (*OrchestrationIdReusePolicy) ProtoMessage()

func (*OrchestrationIdReusePolicy) ProtoReflect added in v0.3.2

func (*OrchestrationIdReusePolicy) Reset added in v0.3.2

func (x *OrchestrationIdReusePolicy) Reset()

func (*OrchestrationIdReusePolicy) String added in v0.3.2

func (x *OrchestrationIdReusePolicy) String() string

type OrchestrationInstance

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

func (*OrchestrationInstance) Descriptor deprecated

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

Deprecated: Use OrchestrationInstance.ProtoReflect.Descriptor instead.

func (*OrchestrationInstance) GetExecutionId

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

func (*OrchestrationInstance) GetInstanceId

func (x *OrchestrationInstance) GetInstanceId() string

func (*OrchestrationInstance) ProtoMessage

func (*OrchestrationInstance) ProtoMessage()

func (*OrchestrationInstance) ProtoReflect

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

func (*OrchestrationInstance) Reset

func (x *OrchestrationInstance) Reset()

func (*OrchestrationInstance) String

func (x *OrchestrationInstance) String() string

type OrchestrationState

type OrchestrationState struct {
	InstanceId              string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name                    string                `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version                 *wrappers.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	OrchestrationStatus     OrchestrationStatus   `protobuf:"varint,4,opt,name=orchestrationStatus,proto3,enum=OrchestrationStatus" json:"orchestrationStatus,omitempty"`
	ScheduledStartTimestamp *timestamp.Timestamp  `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	CreatedTimestamp        *timestamp.Timestamp  `protobuf:"bytes,6,opt,name=createdTimestamp,proto3" json:"createdTimestamp,omitempty"`
	LastUpdatedTimestamp    *timestamp.Timestamp  `protobuf:"bytes,7,opt,name=lastUpdatedTimestamp,proto3" json:"lastUpdatedTimestamp,omitempty"`
	Input                   *wrappers.StringValue `protobuf:"bytes,8,opt,name=input,proto3" json:"input,omitempty"`
	Output                  *wrappers.StringValue `protobuf:"bytes,9,opt,name=output,proto3" json:"output,omitempty"`
	CustomStatus            *wrappers.StringValue `protobuf:"bytes,10,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	FailureDetails          *TaskFailureDetails   `protobuf:"bytes,11,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestrationState) Descriptor deprecated

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

Deprecated: Use OrchestrationState.ProtoReflect.Descriptor instead.

func (*OrchestrationState) GetCreatedTimestamp

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

func (*OrchestrationState) GetCustomStatus

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

func (*OrchestrationState) GetFailureDetails

func (x *OrchestrationState) GetFailureDetails() *TaskFailureDetails

func (*OrchestrationState) GetInput

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

func (*OrchestrationState) GetInstanceId

func (x *OrchestrationState) GetInstanceId() string

func (*OrchestrationState) GetLastUpdatedTimestamp

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

func (*OrchestrationState) GetName

func (x *OrchestrationState) GetName() string

func (*OrchestrationState) GetOrchestrationStatus

func (x *OrchestrationState) GetOrchestrationStatus() OrchestrationStatus

func (*OrchestrationState) GetOutput

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

func (*OrchestrationState) GetScheduledStartTimestamp

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

func (*OrchestrationState) GetVersion

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

func (*OrchestrationState) ProtoMessage

func (*OrchestrationState) ProtoMessage()

func (*OrchestrationState) ProtoReflect

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

func (*OrchestrationState) Reset

func (x *OrchestrationState) Reset()

func (*OrchestrationState) String

func (x *OrchestrationState) String() string

type OrchestrationStatus

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

func (OrchestrationStatus) Descriptor

func (OrchestrationStatus) Enum

func (OrchestrationStatus) EnumDescriptor deprecated

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

Deprecated: Use OrchestrationStatus.Descriptor instead.

func (OrchestrationStatus) Number

func (OrchestrationStatus) String

func (x OrchestrationStatus) String() string

func (OrchestrationStatus) Type

type OrchestratorAction

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

func (*OrchestratorAction) Descriptor deprecated

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

Deprecated: Use OrchestratorAction.ProtoReflect.Descriptor instead.

func (*OrchestratorAction) GetCompleteOrchestration

func (x *OrchestratorAction) GetCompleteOrchestration() *CompleteOrchestrationAction

func (*OrchestratorAction) GetCreateSubOrchestration

func (x *OrchestratorAction) GetCreateSubOrchestration() *CreateSubOrchestrationAction

func (*OrchestratorAction) GetCreateTimer

func (x *OrchestratorAction) GetCreateTimer() *CreateTimerAction

func (*OrchestratorAction) GetId

func (x *OrchestratorAction) GetId() int32

func (*OrchestratorAction) GetOrchestratorActionType

func (m *OrchestratorAction) GetOrchestratorActionType() isOrchestratorAction_OrchestratorActionType

func (*OrchestratorAction) GetScheduleTask

func (x *OrchestratorAction) GetScheduleTask() *ScheduleTaskAction

func (*OrchestratorAction) GetSendEvent

func (x *OrchestratorAction) GetSendEvent() *SendEventAction

func (*OrchestratorAction) GetTerminateOrchestration added in v0.3.0

func (x *OrchestratorAction) GetTerminateOrchestration() *TerminateOrchestrationAction

func (*OrchestratorAction) ProtoMessage

func (*OrchestratorAction) ProtoMessage()

func (*OrchestratorAction) ProtoReflect

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

func (*OrchestratorAction) Reset

func (x *OrchestratorAction) Reset()

func (*OrchestratorAction) String

func (x *OrchestratorAction) String() string

type OrchestratorAction_CompleteOrchestration

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

type OrchestratorAction_CreateSubOrchestration

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

type OrchestratorAction_CreateTimer

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

type OrchestratorAction_ScheduleTask

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

type OrchestratorAction_SendEvent

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

type OrchestratorAction_TerminateOrchestration added in v0.3.0

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

type OrchestratorCompletedEvent

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

func (*OrchestratorCompletedEvent) Descriptor deprecated

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

Deprecated: Use OrchestratorCompletedEvent.ProtoReflect.Descriptor instead.

func (*OrchestratorCompletedEvent) ProtoMessage

func (*OrchestratorCompletedEvent) ProtoMessage()

func (*OrchestratorCompletedEvent) ProtoReflect

func (*OrchestratorCompletedEvent) Reset

func (x *OrchestratorCompletedEvent) Reset()

func (*OrchestratorCompletedEvent) String

func (x *OrchestratorCompletedEvent) String() string

type OrchestratorEntityParameters added in v0.3.2

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

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

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

Deprecated: Use OrchestratorEntityParameters.ProtoReflect.Descriptor instead.

func (*OrchestratorEntityParameters) GetEntityMessageReorderWindow added in v0.3.2

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

func (*OrchestratorEntityParameters) ProtoMessage added in v0.3.2

func (*OrchestratorEntityParameters) ProtoMessage()

func (*OrchestratorEntityParameters) ProtoReflect added in v0.3.2

func (*OrchestratorEntityParameters) Reset added in v0.3.2

func (x *OrchestratorEntityParameters) Reset()

func (*OrchestratorEntityParameters) String added in v0.3.2

type OrchestratorRequest

type OrchestratorRequest struct {
	InstanceId       string                        `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId      *wrappers.StringValue         `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	PastEvents       []*HistoryEvent               `protobuf:"bytes,3,rep,name=pastEvents,proto3" json:"pastEvents,omitempty"`
	NewEvents        []*HistoryEvent               `protobuf:"bytes,4,rep,name=newEvents,proto3" json:"newEvents,omitempty"`
	EntityParameters *OrchestratorEntityParameters `protobuf:"bytes,5,opt,name=entityParameters,proto3" json:"entityParameters,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestratorRequest) Descriptor deprecated

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

Deprecated: Use OrchestratorRequest.ProtoReflect.Descriptor instead.

func (*OrchestratorRequest) GetEntityParameters added in v0.3.2

func (x *OrchestratorRequest) GetEntityParameters() *OrchestratorEntityParameters

func (*OrchestratorRequest) GetExecutionId

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

func (*OrchestratorRequest) GetInstanceId

func (x *OrchestratorRequest) GetInstanceId() string

func (*OrchestratorRequest) GetNewEvents

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

func (*OrchestratorRequest) GetPastEvents

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

func (*OrchestratorRequest) ProtoMessage

func (*OrchestratorRequest) ProtoMessage()

func (*OrchestratorRequest) ProtoReflect

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

func (*OrchestratorRequest) Reset

func (x *OrchestratorRequest) Reset()

func (*OrchestratorRequest) String

func (x *OrchestratorRequest) String() string

type OrchestratorResponse

type OrchestratorResponse struct {
	InstanceId   string                `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Actions      []*OrchestratorAction `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	CustomStatus *wrappers.StringValue `protobuf:"bytes,3,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	// contains filtered or unexported fields
}

func (*OrchestratorResponse) Descriptor deprecated

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

Deprecated: Use OrchestratorResponse.ProtoReflect.Descriptor instead.

func (*OrchestratorResponse) GetActions

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

func (*OrchestratorResponse) GetCustomStatus

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

func (*OrchestratorResponse) GetInstanceId

func (x *OrchestratorResponse) GetInstanceId() string

func (*OrchestratorResponse) ProtoMessage

func (*OrchestratorResponse) ProtoMessage()

func (*OrchestratorResponse) ProtoReflect

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

func (*OrchestratorResponse) Reset

func (x *OrchestratorResponse) Reset()

func (*OrchestratorResponse) String

func (x *OrchestratorResponse) String() string

type OrchestratorStartedEvent

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

func (*OrchestratorStartedEvent) Descriptor deprecated

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

Deprecated: Use OrchestratorStartedEvent.ProtoReflect.Descriptor instead.

func (*OrchestratorStartedEvent) ProtoMessage

func (*OrchestratorStartedEvent) ProtoMessage()

func (*OrchestratorStartedEvent) ProtoReflect

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

func (*OrchestratorStartedEvent) Reset

func (x *OrchestratorStartedEvent) Reset()

func (*OrchestratorStartedEvent) String

func (x *OrchestratorStartedEvent) String() string

type ParentInstanceInfo

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

func (*ParentInstanceInfo) Descriptor deprecated

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

Deprecated: Use ParentInstanceInfo.ProtoReflect.Descriptor instead.

func (*ParentInstanceInfo) GetName

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

func (*ParentInstanceInfo) GetOrchestrationInstance

func (x *ParentInstanceInfo) GetOrchestrationInstance() *OrchestrationInstance

func (*ParentInstanceInfo) GetTaskScheduledId

func (x *ParentInstanceInfo) GetTaskScheduledId() int32

func (*ParentInstanceInfo) GetVersion

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

func (*ParentInstanceInfo) ProtoMessage

func (*ParentInstanceInfo) ProtoMessage()

func (*ParentInstanceInfo) ProtoReflect

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

func (*ParentInstanceInfo) Reset

func (x *ParentInstanceInfo) Reset()

func (*ParentInstanceInfo) String

func (x *ParentInstanceInfo) String() string

type PurgeInstanceFilter

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

func (*PurgeInstanceFilter) Descriptor deprecated

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

Deprecated: Use PurgeInstanceFilter.ProtoReflect.Descriptor instead.

func (*PurgeInstanceFilter) GetCreatedTimeFrom

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

func (*PurgeInstanceFilter) GetCreatedTimeTo

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

func (*PurgeInstanceFilter) GetRuntimeStatus

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

func (*PurgeInstanceFilter) ProtoMessage

func (*PurgeInstanceFilter) ProtoMessage()

func (*PurgeInstanceFilter) ProtoReflect

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

func (*PurgeInstanceFilter) Reset

func (x *PurgeInstanceFilter) Reset()

func (*PurgeInstanceFilter) String

func (x *PurgeInstanceFilter) String() string

type PurgeInstancesRequest

type PurgeInstancesRequest struct {

	// Types that are assignable to Request:
	//
	//	*PurgeInstancesRequest_InstanceId
	//	*PurgeInstancesRequest_PurgeInstanceFilter
	Request isPurgeInstancesRequest_Request `protobuf_oneof:"request"`
	// 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) GetRequest

func (m *PurgeInstancesRequest) GetRequest() isPurgeInstancesRequest_Request

func (*PurgeInstancesRequest) ProtoMessage

func (*PurgeInstancesRequest) ProtoMessage()

func (*PurgeInstancesRequest) ProtoReflect

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

func (*PurgeInstancesRequest) Reset

func (x *PurgeInstancesRequest) Reset()

func (*PurgeInstancesRequest) String

func (x *PurgeInstancesRequest) String() string

type PurgeInstancesRequest_InstanceId

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

type PurgeInstancesRequest_PurgeInstanceFilter

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

type PurgeInstancesResponse

type PurgeInstancesResponse struct {
	DeletedInstanceCount int32 `protobuf:"varint,1,opt,name=deletedInstanceCount,proto3" json:"deletedInstanceCount,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeInstancesResponse) Descriptor deprecated

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

Deprecated: Use PurgeInstancesResponse.ProtoReflect.Descriptor instead.

func (*PurgeInstancesResponse) GetDeletedInstanceCount

func (x *PurgeInstancesResponse) GetDeletedInstanceCount() int32

func (*PurgeInstancesResponse) ProtoMessage

func (*PurgeInstancesResponse) ProtoMessage()

func (*PurgeInstancesResponse) ProtoReflect

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

func (*PurgeInstancesResponse) Reset

func (x *PurgeInstancesResponse) Reset()

func (*PurgeInstancesResponse) String

func (x *PurgeInstancesResponse) String() string

type QueryEntitiesRequest added in v0.3.2

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

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

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

Deprecated: Use QueryEntitiesRequest.ProtoReflect.Descriptor instead.

func (*QueryEntitiesRequest) GetQuery added in v0.3.2

func (x *QueryEntitiesRequest) GetQuery() *EntityQuery

func (*QueryEntitiesRequest) ProtoMessage added in v0.3.2

func (*QueryEntitiesRequest) ProtoMessage()

func (*QueryEntitiesRequest) ProtoReflect added in v0.3.2

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

func (*QueryEntitiesRequest) Reset added in v0.3.2

func (x *QueryEntitiesRequest) Reset()

func (*QueryEntitiesRequest) String added in v0.3.2

func (x *QueryEntitiesRequest) String() string

type QueryEntitiesResponse added in v0.3.2

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

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

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

Deprecated: Use QueryEntitiesResponse.ProtoReflect.Descriptor instead.

func (*QueryEntitiesResponse) GetContinuationToken added in v0.3.2

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

func (*QueryEntitiesResponse) GetEntities added in v0.3.2

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

func (*QueryEntitiesResponse) ProtoMessage added in v0.3.2

func (*QueryEntitiesResponse) ProtoMessage()

func (*QueryEntitiesResponse) ProtoReflect added in v0.3.2

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

func (*QueryEntitiesResponse) Reset added in v0.3.2

func (x *QueryEntitiesResponse) Reset()

func (*QueryEntitiesResponse) String added in v0.3.2

func (x *QueryEntitiesResponse) String() string

type QueryInstancesRequest

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

func (*QueryInstancesRequest) Descriptor deprecated

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

Deprecated: Use QueryInstancesRequest.ProtoReflect.Descriptor instead.

func (*QueryInstancesRequest) GetQuery

func (x *QueryInstancesRequest) GetQuery() *InstanceQuery

func (*QueryInstancesRequest) ProtoMessage

func (*QueryInstancesRequest) ProtoMessage()

func (*QueryInstancesRequest) ProtoReflect

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

func (*QueryInstancesRequest) Reset

func (x *QueryInstancesRequest) Reset()

func (*QueryInstancesRequest) String

func (x *QueryInstancesRequest) String() string

type QueryInstancesResponse

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

func (*QueryInstancesResponse) Descriptor deprecated

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

Deprecated: Use QueryInstancesResponse.ProtoReflect.Descriptor instead.

func (*QueryInstancesResponse) GetContinuationToken

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

func (*QueryInstancesResponse) GetOrchestrationState

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

func (*QueryInstancesResponse) ProtoMessage

func (*QueryInstancesResponse) ProtoMessage()

func (*QueryInstancesResponse) ProtoReflect

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

func (*QueryInstancesResponse) Reset

func (x *QueryInstancesResponse) Reset()

func (*QueryInstancesResponse) String

func (x *QueryInstancesResponse) String() string

type RaiseEventRequest

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

func (*RaiseEventRequest) Descriptor deprecated

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

Deprecated: Use RaiseEventRequest.ProtoReflect.Descriptor instead.

func (*RaiseEventRequest) GetInput

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

func (*RaiseEventRequest) GetInstanceId

func (x *RaiseEventRequest) GetInstanceId() string

func (*RaiseEventRequest) GetName

func (x *RaiseEventRequest) GetName() string

func (*RaiseEventRequest) ProtoMessage

func (*RaiseEventRequest) ProtoMessage()

func (*RaiseEventRequest) ProtoReflect

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

func (*RaiseEventRequest) Reset

func (x *RaiseEventRequest) Reset()

func (*RaiseEventRequest) String

func (x *RaiseEventRequest) String() string

type RaiseEventResponse

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

func (*RaiseEventResponse) Descriptor deprecated

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

Deprecated: Use RaiseEventResponse.ProtoReflect.Descriptor instead.

func (*RaiseEventResponse) ProtoMessage

func (*RaiseEventResponse) ProtoMessage()

func (*RaiseEventResponse) ProtoReflect

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

func (*RaiseEventResponse) Reset

func (x *RaiseEventResponse) Reset()

func (*RaiseEventResponse) String

func (x *RaiseEventResponse) String() string

type ResumeRequest added in v0.1.1

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

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

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

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetInstanceId added in v0.1.1

func (x *ResumeRequest) GetInstanceId() string

func (*ResumeRequest) GetReason added in v0.1.1

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

func (*ResumeRequest) ProtoMessage added in v0.1.1

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect added in v0.1.1

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

func (*ResumeRequest) Reset added in v0.1.1

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String added in v0.1.1

func (x *ResumeRequest) String() string

type ResumeResponse added in v0.1.1

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

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

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

Deprecated: Use ResumeResponse.ProtoReflect.Descriptor instead.

func (*ResumeResponse) ProtoMessage added in v0.1.1

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) ProtoReflect added in v0.1.1

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

func (*ResumeResponse) Reset added in v0.1.1

func (x *ResumeResponse) Reset()

func (*ResumeResponse) String added in v0.1.1

func (x *ResumeResponse) String() string

type RewindInstanceRequest added in v0.1.1

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

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

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

Deprecated: Use RewindInstanceRequest.ProtoReflect.Descriptor instead.

func (*RewindInstanceRequest) GetInstanceId added in v0.1.1

func (x *RewindInstanceRequest) GetInstanceId() string

func (*RewindInstanceRequest) GetReason added in v0.1.1

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

func (*RewindInstanceRequest) ProtoMessage added in v0.1.1

func (*RewindInstanceRequest) ProtoMessage()

func (*RewindInstanceRequest) ProtoReflect added in v0.1.1

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

func (*RewindInstanceRequest) Reset added in v0.1.1

func (x *RewindInstanceRequest) Reset()

func (*RewindInstanceRequest) String added in v0.1.1

func (x *RewindInstanceRequest) String() string

type RewindInstanceResponse added in v0.1.1

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

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

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

Deprecated: Use RewindInstanceResponse.ProtoReflect.Descriptor instead.

func (*RewindInstanceResponse) ProtoMessage added in v0.1.1

func (*RewindInstanceResponse) ProtoMessage()

func (*RewindInstanceResponse) ProtoReflect added in v0.1.1

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

func (*RewindInstanceResponse) Reset added in v0.1.1

func (x *RewindInstanceResponse) Reset()

func (*RewindInstanceResponse) String added in v0.1.1

func (x *RewindInstanceResponse) String() string

type ScheduleTaskAction

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

func (*ScheduleTaskAction) Descriptor deprecated

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

Deprecated: Use ScheduleTaskAction.ProtoReflect.Descriptor instead.

func (*ScheduleTaskAction) GetInput

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

func (*ScheduleTaskAction) GetName

func (x *ScheduleTaskAction) GetName() string

func (*ScheduleTaskAction) GetVersion

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

func (*ScheduleTaskAction) ProtoMessage

func (*ScheduleTaskAction) ProtoMessage()

func (*ScheduleTaskAction) ProtoReflect

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

func (*ScheduleTaskAction) Reset

func (x *ScheduleTaskAction) Reset()

func (*ScheduleTaskAction) String

func (x *ScheduleTaskAction) String() string

type SendEventAction

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

func (*SendEventAction) Descriptor deprecated

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

Deprecated: Use SendEventAction.ProtoReflect.Descriptor instead.

func (*SendEventAction) GetData

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

func (*SendEventAction) GetInstance

func (x *SendEventAction) GetInstance() *OrchestrationInstance

func (*SendEventAction) GetName

func (x *SendEventAction) GetName() string

func (*SendEventAction) ProtoMessage

func (*SendEventAction) ProtoMessage()

func (*SendEventAction) ProtoReflect

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

func (*SendEventAction) Reset

func (x *SendEventAction) Reset()

func (*SendEventAction) String

func (x *SendEventAction) String() string

type SendSignalAction added in v0.3.2

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

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

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

Deprecated: Use SendSignalAction.ProtoReflect.Descriptor instead.

func (*SendSignalAction) GetInput added in v0.3.2

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

func (*SendSignalAction) GetInstanceId added in v0.3.2

func (x *SendSignalAction) GetInstanceId() string

func (*SendSignalAction) GetName added in v0.3.2

func (x *SendSignalAction) GetName() string

func (*SendSignalAction) GetScheduledTime added in v0.3.2

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

func (*SendSignalAction) ProtoMessage added in v0.3.2

func (*SendSignalAction) ProtoMessage()

func (*SendSignalAction) ProtoReflect added in v0.3.2

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

func (*SendSignalAction) Reset added in v0.3.2

func (x *SendSignalAction) Reset()

func (*SendSignalAction) String added in v0.3.2

func (x *SendSignalAction) String() string

type SignalEntityRequest added in v0.3.2

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

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

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

Deprecated: Use SignalEntityRequest.ProtoReflect.Descriptor instead.

func (*SignalEntityRequest) GetInput added in v0.3.2

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

func (*SignalEntityRequest) GetInstanceId added in v0.3.2

func (x *SignalEntityRequest) GetInstanceId() string

func (*SignalEntityRequest) GetName added in v0.3.2

func (x *SignalEntityRequest) GetName() string

func (*SignalEntityRequest) GetRequestId added in v0.3.2

func (x *SignalEntityRequest) GetRequestId() string

func (*SignalEntityRequest) GetScheduledTime added in v0.3.2

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

func (*SignalEntityRequest) ProtoMessage added in v0.3.2

func (*SignalEntityRequest) ProtoMessage()

func (*SignalEntityRequest) ProtoReflect added in v0.3.2

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

func (*SignalEntityRequest) Reset added in v0.3.2

func (x *SignalEntityRequest) Reset()

func (*SignalEntityRequest) String added in v0.3.2

func (x *SignalEntityRequest) String() string

type SignalEntityResponse added in v0.3.2

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

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

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

Deprecated: Use SignalEntityResponse.ProtoReflect.Descriptor instead.

func (*SignalEntityResponse) ProtoMessage added in v0.3.2

func (*SignalEntityResponse) ProtoMessage()

func (*SignalEntityResponse) ProtoReflect added in v0.3.2

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

func (*SignalEntityResponse) Reset added in v0.3.2

func (x *SignalEntityResponse) Reset()

func (*SignalEntityResponse) String added in v0.3.2

func (x *SignalEntityResponse) String() string

type StartNewOrchestrationAction added in v0.3.2

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

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

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

Deprecated: Use StartNewOrchestrationAction.ProtoReflect.Descriptor instead.

func (*StartNewOrchestrationAction) GetInput added in v0.3.2

func (*StartNewOrchestrationAction) GetInstanceId added in v0.3.2

func (x *StartNewOrchestrationAction) GetInstanceId() string

func (*StartNewOrchestrationAction) GetName added in v0.3.2

func (x *StartNewOrchestrationAction) GetName() string

func (*StartNewOrchestrationAction) GetScheduledTime added in v0.3.2

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

func (*StartNewOrchestrationAction) GetVersion added in v0.3.2

func (*StartNewOrchestrationAction) ProtoMessage added in v0.3.2

func (*StartNewOrchestrationAction) ProtoMessage()

func (*StartNewOrchestrationAction) ProtoReflect added in v0.3.2

func (*StartNewOrchestrationAction) Reset added in v0.3.2

func (x *StartNewOrchestrationAction) Reset()

func (*StartNewOrchestrationAction) String added in v0.3.2

func (x *StartNewOrchestrationAction) String() string

type SubOrchestrationInstanceCompletedEvent

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

func (*SubOrchestrationInstanceCompletedEvent) Descriptor deprecated

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

Deprecated: Use SubOrchestrationInstanceCompletedEvent.ProtoReflect.Descriptor instead.

func (*SubOrchestrationInstanceCompletedEvent) GetResult

func (*SubOrchestrationInstanceCompletedEvent) GetTaskScheduledId

func (x *SubOrchestrationInstanceCompletedEvent) GetTaskScheduledId() int32

func (*SubOrchestrationInstanceCompletedEvent) ProtoMessage

func (*SubOrchestrationInstanceCompletedEvent) ProtoReflect

func (*SubOrchestrationInstanceCompletedEvent) Reset

func (*SubOrchestrationInstanceCompletedEvent) String

type SubOrchestrationInstanceCreatedEvent

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

func (*SubOrchestrationInstanceCreatedEvent) Descriptor deprecated

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

Deprecated: Use SubOrchestrationInstanceCreatedEvent.ProtoReflect.Descriptor instead.

func (*SubOrchestrationInstanceCreatedEvent) GetInput

func (*SubOrchestrationInstanceCreatedEvent) GetInstanceId

func (x *SubOrchestrationInstanceCreatedEvent) GetInstanceId() string

func (*SubOrchestrationInstanceCreatedEvent) GetName

func (*SubOrchestrationInstanceCreatedEvent) GetParentTraceContext added in v0.1.1

func (x *SubOrchestrationInstanceCreatedEvent) GetParentTraceContext() *TraceContext

func (*SubOrchestrationInstanceCreatedEvent) GetVersion

func (*SubOrchestrationInstanceCreatedEvent) ProtoMessage

func (*SubOrchestrationInstanceCreatedEvent) ProtoMessage()

func (*SubOrchestrationInstanceCreatedEvent) ProtoReflect

func (*SubOrchestrationInstanceCreatedEvent) Reset

func (*SubOrchestrationInstanceCreatedEvent) 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 (*SubOrchestrationInstanceFailedEvent) GetTaskScheduledId

func (x *SubOrchestrationInstanceFailedEvent) GetTaskScheduledId() int32

func (*SubOrchestrationInstanceFailedEvent) ProtoMessage

func (*SubOrchestrationInstanceFailedEvent) ProtoMessage()

func (*SubOrchestrationInstanceFailedEvent) ProtoReflect

func (*SubOrchestrationInstanceFailedEvent) Reset

func (*SubOrchestrationInstanceFailedEvent) String

type SuspendRequest added in v0.1.1

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

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

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

Deprecated: Use SuspendRequest.ProtoReflect.Descriptor instead.

func (*SuspendRequest) GetInstanceId added in v0.1.1

func (x *SuspendRequest) GetInstanceId() string

func (*SuspendRequest) GetReason added in v0.1.1

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

func (*SuspendRequest) ProtoMessage added in v0.1.1

func (*SuspendRequest) ProtoMessage()

func (*SuspendRequest) ProtoReflect added in v0.1.1

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

func (*SuspendRequest) Reset added in v0.1.1

func (x *SuspendRequest) Reset()

func (*SuspendRequest) String added in v0.1.1

func (x *SuspendRequest) String() string

type SuspendResponse added in v0.1.1

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

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

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

Deprecated: Use SuspendResponse.ProtoReflect.Descriptor instead.

func (*SuspendResponse) ProtoMessage added in v0.1.1

func (*SuspendResponse) ProtoMessage()

func (*SuspendResponse) ProtoReflect added in v0.1.1

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

func (*SuspendResponse) Reset added in v0.1.1

func (x *SuspendResponse) Reset()

func (*SuspendResponse) String added in v0.1.1

func (x *SuspendResponse) String() string

type TaskCompletedEvent

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

func (*TaskCompletedEvent) Descriptor deprecated

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

Deprecated: Use TaskCompletedEvent.ProtoReflect.Descriptor instead.

func (*TaskCompletedEvent) GetResult

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

func (*TaskCompletedEvent) GetTaskScheduledId

func (x *TaskCompletedEvent) GetTaskScheduledId() int32

func (*TaskCompletedEvent) ProtoMessage

func (*TaskCompletedEvent) ProtoMessage()

func (*TaskCompletedEvent) ProtoReflect

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

func (*TaskCompletedEvent) Reset

func (x *TaskCompletedEvent) Reset()

func (*TaskCompletedEvent) String

func (x *TaskCompletedEvent) String() string

type TaskFailedEvent

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

func (*TaskFailedEvent) Descriptor deprecated

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

Deprecated: Use TaskFailedEvent.ProtoReflect.Descriptor instead.

func (*TaskFailedEvent) GetFailureDetails

func (x *TaskFailedEvent) GetFailureDetails() *TaskFailureDetails

func (*TaskFailedEvent) GetTaskScheduledId

func (x *TaskFailedEvent) GetTaskScheduledId() int32

func (*TaskFailedEvent) ProtoMessage

func (*TaskFailedEvent) ProtoMessage()

func (*TaskFailedEvent) ProtoReflect

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

func (*TaskFailedEvent) Reset

func (x *TaskFailedEvent) Reset()

func (*TaskFailedEvent) String

func (x *TaskFailedEvent) String() string

type TaskFailureDetails

type TaskFailureDetails struct {
	ErrorType      string                `protobuf:"bytes,1,opt,name=errorType,proto3" json:"errorType,omitempty"`
	ErrorMessage   string                `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	StackTrace     *wrappers.StringValue `protobuf:"bytes,3,opt,name=stackTrace,proto3" json:"stackTrace,omitempty"`
	InnerFailure   *TaskFailureDetails   `protobuf:"bytes,4,opt,name=innerFailure,proto3" json:"innerFailure,omitempty"`
	IsNonRetriable bool                  `protobuf:"varint,5,opt,name=isNonRetriable,proto3" json:"isNonRetriable,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskFailureDetails) Descriptor deprecated

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

Deprecated: Use TaskFailureDetails.ProtoReflect.Descriptor instead.

func (*TaskFailureDetails) GetErrorMessage

func (x *TaskFailureDetails) GetErrorMessage() string

func (*TaskFailureDetails) GetErrorType

func (x *TaskFailureDetails) GetErrorType() string

func (*TaskFailureDetails) GetInnerFailure

func (x *TaskFailureDetails) GetInnerFailure() *TaskFailureDetails

func (*TaskFailureDetails) GetIsNonRetriable

func (x *TaskFailureDetails) GetIsNonRetriable() bool

func (*TaskFailureDetails) GetStackTrace

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

func (*TaskFailureDetails) ProtoMessage

func (*TaskFailureDetails) ProtoMessage()

func (*TaskFailureDetails) ProtoReflect

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

func (*TaskFailureDetails) Reset

func (x *TaskFailureDetails) Reset()

func (*TaskFailureDetails) String

func (x *TaskFailureDetails) String() string

type TaskHubSidecarServiceClient

type TaskHubSidecarServiceClient interface {
	// Sends a hello request to the sidecar service.
	Hello(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	// Starts a new orchestration instance.
	StartInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// Gets the status of an existing orchestration instance.
	GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Rewinds an orchestration instance to last known good state and replays from there.
	RewindInstance(ctx context.Context, in *RewindInstanceRequest, opts ...grpc.CallOption) (*RewindInstanceResponse, error)
	// Waits for an orchestration instance to reach a running or completion state.
	WaitForInstanceStart(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
	WaitForInstanceCompletion(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Raises an event to a running orchestration instance.
	RaiseEvent(ctx context.Context, in *RaiseEventRequest, opts ...grpc.CallOption) (*RaiseEventResponse, error)
	// Terminates a running orchestration instance.
	TerminateInstance(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
	// Suspends a running orchestration instance.
	SuspendInstance(ctx context.Context, in *SuspendRequest, opts ...grpc.CallOption) (*SuspendResponse, error)
	// Resumes a suspended orchestration instance.
	ResumeInstance(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*ResumeResponse, error)
	QueryInstances(ctx context.Context, in *QueryInstancesRequest, opts ...grpc.CallOption) (*QueryInstancesResponse, error)
	PurgeInstances(ctx context.Context, in *PurgeInstancesRequest, opts ...grpc.CallOption) (*PurgeInstancesResponse, error)
	GetWorkItems(ctx context.Context, in *GetWorkItemsRequest, opts ...grpc.CallOption) (TaskHubSidecarService_GetWorkItemsClient, error)
	CompleteActivityTask(ctx context.Context, in *ActivityResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	CompleteOrchestratorTask(ctx context.Context, in *OrchestratorResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	CompleteEntityTask(ctx context.Context, in *EntityBatchResult, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	// Deletes and Creates the necessary resources for the orchestration service and the instance store
	CreateTaskHub(ctx context.Context, in *CreateTaskHubRequest, opts ...grpc.CallOption) (*CreateTaskHubResponse, error)
	// Deletes the resources for the orchestration service and optionally the instance store
	DeleteTaskHub(ctx context.Context, in *DeleteTaskHubRequest, opts ...grpc.CallOption) (*DeleteTaskHubResponse, error)
	// sends a signal to an entity
	SignalEntity(ctx context.Context, in *SignalEntityRequest, opts ...grpc.CallOption) (*SignalEntityResponse, error)
	// get information about a specific entity
	GetEntity(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*GetEntityResponse, error)
	// query entities
	QueryEntities(ctx context.Context, in *QueryEntitiesRequest, opts ...grpc.CallOption) (*QueryEntitiesResponse, error)
	// clean entity storage
	CleanEntityStorage(ctx context.Context, in *CleanEntityStorageRequest, opts ...grpc.CallOption) (*CleanEntityStorageResponse, error)
}

TaskHubSidecarServiceClient is the client API for TaskHubSidecarService service.

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

type TaskHubSidecarServiceServer

type TaskHubSidecarServiceServer interface {
	// Sends a hello request to the sidecar service.
	Hello(context.Context, *empty.Empty) (*empty.Empty, error)
	// Starts a new orchestration instance.
	StartInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// Gets the status of an existing orchestration instance.
	GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Rewinds an orchestration instance to last known good state and replays from there.
	RewindInstance(context.Context, *RewindInstanceRequest) (*RewindInstanceResponse, error)
	// Waits for an orchestration instance to reach a running or completion state.
	WaitForInstanceStart(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Waits for an orchestration instance to reach a completion state (completed, failed, terminated, etc.).
	WaitForInstanceCompletion(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Raises an event to a running orchestration instance.
	RaiseEvent(context.Context, *RaiseEventRequest) (*RaiseEventResponse, error)
	// Terminates a running orchestration instance.
	TerminateInstance(context.Context, *TerminateRequest) (*TerminateResponse, error)
	// Suspends a running orchestration instance.
	SuspendInstance(context.Context, *SuspendRequest) (*SuspendResponse, error)
	// Resumes a suspended orchestration instance.
	ResumeInstance(context.Context, *ResumeRequest) (*ResumeResponse, error)
	QueryInstances(context.Context, *QueryInstancesRequest) (*QueryInstancesResponse, error)
	PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)
	GetWorkItems(*GetWorkItemsRequest, TaskHubSidecarService_GetWorkItemsServer) error
	CompleteActivityTask(context.Context, *ActivityResponse) (*CompleteTaskResponse, error)
	CompleteOrchestratorTask(context.Context, *OrchestratorResponse) (*CompleteTaskResponse, error)
	CompleteEntityTask(context.Context, *EntityBatchResult) (*CompleteTaskResponse, error)
	// Deletes and Creates the necessary resources for the orchestration service and the instance store
	CreateTaskHub(context.Context, *CreateTaskHubRequest) (*CreateTaskHubResponse, error)
	// Deletes the resources for the orchestration service and optionally the instance store
	DeleteTaskHub(context.Context, *DeleteTaskHubRequest) (*DeleteTaskHubResponse, error)
	// sends a signal to an entity
	SignalEntity(context.Context, *SignalEntityRequest) (*SignalEntityResponse, error)
	// get information about a specific entity
	GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)
	// query entities
	QueryEntities(context.Context, *QueryEntitiesRequest) (*QueryEntitiesResponse, error)
	// clean entity storage
	CleanEntityStorage(context.Context, *CleanEntityStorageRequest) (*CleanEntityStorageResponse, error)
	// contains filtered or unexported methods
}

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

type TaskHubSidecarService_GetWorkItemsClient

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

type TaskHubSidecarService_GetWorkItemsServer

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

type TaskScheduledEvent

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

func (*TaskScheduledEvent) Descriptor deprecated

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

Deprecated: Use TaskScheduledEvent.ProtoReflect.Descriptor instead.

func (*TaskScheduledEvent) GetInput

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

func (*TaskScheduledEvent) GetName

func (x *TaskScheduledEvent) GetName() string

func (*TaskScheduledEvent) GetParentTraceContext added in v0.1.1

func (x *TaskScheduledEvent) GetParentTraceContext() *TraceContext

func (*TaskScheduledEvent) GetVersion

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

func (*TaskScheduledEvent) ProtoMessage

func (*TaskScheduledEvent) ProtoMessage()

func (*TaskScheduledEvent) ProtoReflect

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

func (*TaskScheduledEvent) Reset

func (x *TaskScheduledEvent) Reset()

func (*TaskScheduledEvent) String

func (x *TaskScheduledEvent) String() string

type TerminateOrchestrationAction added in v0.3.0

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

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

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

Deprecated: Use TerminateOrchestrationAction.ProtoReflect.Descriptor instead.

func (*TerminateOrchestrationAction) GetInstanceId added in v0.3.0

func (x *TerminateOrchestrationAction) GetInstanceId() string

func (*TerminateOrchestrationAction) GetReason added in v0.3.0

func (*TerminateOrchestrationAction) GetRecurse added in v0.3.0

func (x *TerminateOrchestrationAction) GetRecurse() bool

func (*TerminateOrchestrationAction) ProtoMessage added in v0.3.0

func (*TerminateOrchestrationAction) ProtoMessage()

func (*TerminateOrchestrationAction) ProtoReflect added in v0.3.0

func (*TerminateOrchestrationAction) Reset added in v0.3.0

func (x *TerminateOrchestrationAction) Reset()

func (*TerminateOrchestrationAction) String added in v0.3.0

type TerminateRequest

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

func (*TerminateRequest) Descriptor deprecated

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

Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.

func (*TerminateRequest) GetInstanceId

func (x *TerminateRequest) GetInstanceId() string

func (*TerminateRequest) GetOutput

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

func (*TerminateRequest) GetRecursive added in v0.3.0

func (x *TerminateRequest) GetRecursive() bool

func (*TerminateRequest) ProtoMessage

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) ProtoReflect

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

func (*TerminateRequest) Reset

func (x *TerminateRequest) Reset()

func (*TerminateRequest) String

func (x *TerminateRequest) String() string

type TerminateResponse

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

func (*TerminateResponse) Descriptor deprecated

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

Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.

func (*TerminateResponse) ProtoMessage

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) ProtoReflect

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

func (*TerminateResponse) Reset

func (x *TerminateResponse) Reset()

func (*TerminateResponse) String

func (x *TerminateResponse) String() string

type TimerCreatedEvent

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

func (*TimerCreatedEvent) Descriptor deprecated

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

Deprecated: Use TimerCreatedEvent.ProtoReflect.Descriptor instead.

func (*TimerCreatedEvent) GetFireAt

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

func (*TimerCreatedEvent) ProtoMessage

func (*TimerCreatedEvent) ProtoMessage()

func (*TimerCreatedEvent) ProtoReflect

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

func (*TimerCreatedEvent) Reset

func (x *TimerCreatedEvent) Reset()

func (*TimerCreatedEvent) String

func (x *TimerCreatedEvent) String() string

type TimerFiredEvent

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

func (*TimerFiredEvent) Descriptor deprecated

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

Deprecated: Use TimerFiredEvent.ProtoReflect.Descriptor instead.

func (*TimerFiredEvent) GetFireAt

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

func (*TimerFiredEvent) GetTimerId

func (x *TimerFiredEvent) GetTimerId() int32

func (*TimerFiredEvent) ProtoMessage

func (*TimerFiredEvent) ProtoMessage()

func (*TimerFiredEvent) ProtoReflect

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

func (*TimerFiredEvent) Reset

func (x *TimerFiredEvent) Reset()

func (*TimerFiredEvent) String

func (x *TimerFiredEvent) String() string

type TraceContext added in v0.1.1

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

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

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

Deprecated: Use TraceContext.ProtoReflect.Descriptor instead.

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

func (x *TraceContext) GetSpanID() string

Deprecated: Do not use.

func (*TraceContext) GetTraceParent added in v0.3.2

func (x *TraceContext) GetTraceParent() string

func (*TraceContext) GetTraceState added in v0.1.1

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

func (*TraceContext) ProtoMessage added in v0.1.1

func (*TraceContext) ProtoMessage()

func (*TraceContext) ProtoReflect added in v0.1.1

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

func (*TraceContext) Reset added in v0.1.1

func (x *TraceContext) Reset()

func (*TraceContext) String added in v0.1.1

func (x *TraceContext) String() string

type UnimplementedTaskHubSidecarServiceServer

type UnimplementedTaskHubSidecarServiceServer struct {
}

UnimplementedTaskHubSidecarServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskHubSidecarServiceServer) CleanEntityStorage added in v0.3.2

func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask

func (UnimplementedTaskHubSidecarServiceServer) CompleteEntityTask added in v0.3.2

func (UnimplementedTaskHubSidecarServiceServer) CompleteOrchestratorTask

func (UnimplementedTaskHubSidecarServiceServer) CreateTaskHub

func (UnimplementedTaskHubSidecarServiceServer) DeleteTaskHub

func (UnimplementedTaskHubSidecarServiceServer) GetEntity added in v0.3.2

func (UnimplementedTaskHubSidecarServiceServer) GetInstance

func (UnimplementedTaskHubSidecarServiceServer) Hello

func (UnimplementedTaskHubSidecarServiceServer) PurgeInstances

func (UnimplementedTaskHubSidecarServiceServer) QueryEntities added in v0.3.2

func (UnimplementedTaskHubSidecarServiceServer) QueryInstances

func (UnimplementedTaskHubSidecarServiceServer) RaiseEvent

func (UnimplementedTaskHubSidecarServiceServer) ResumeInstance added in v0.1.1

func (UnimplementedTaskHubSidecarServiceServer) RewindInstance added in v0.1.1

func (UnimplementedTaskHubSidecarServiceServer) SignalEntity added in v0.3.2

func (UnimplementedTaskHubSidecarServiceServer) StartInstance

func (UnimplementedTaskHubSidecarServiceServer) SuspendInstance added in v0.1.1

func (UnimplementedTaskHubSidecarServiceServer) TerminateInstance

func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceCompletion

func (UnimplementedTaskHubSidecarServiceServer) WaitForInstanceStart

type UnsafeTaskHubSidecarServiceServer

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

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

type WorkItem

type WorkItem struct {

	// Types that are assignable to Request:
	//
	//	*WorkItem_OrchestratorRequest
	//	*WorkItem_ActivityRequest
	//	*WorkItem_EntityRequest
	Request isWorkItem_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*WorkItem) Descriptor deprecated

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

Deprecated: Use WorkItem.ProtoReflect.Descriptor instead.

func (*WorkItem) GetActivityRequest

func (x *WorkItem) GetActivityRequest() *ActivityRequest

func (*WorkItem) GetEntityRequest added in v0.3.2

func (x *WorkItem) GetEntityRequest() *EntityBatchRequest

func (*WorkItem) GetOrchestratorRequest

func (x *WorkItem) GetOrchestratorRequest() *OrchestratorRequest

func (*WorkItem) GetRequest

func (m *WorkItem) GetRequest() isWorkItem_Request

func (*WorkItem) ProtoMessage

func (*WorkItem) ProtoMessage()

func (*WorkItem) ProtoReflect

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

func (*WorkItem) Reset

func (x *WorkItem) Reset()

func (*WorkItem) String

func (x *WorkItem) String() string

type WorkItem_ActivityRequest

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

type WorkItem_EntityRequest added in v0.3.2

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

type WorkItem_OrchestratorRequest

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

Jump to

Keyboard shortcuts

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