protos

package
v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Aug 26, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TaskHubSidecarService_Hello_FullMethodName                     = "/TaskHubSidecarService/Hello"
	TaskHubSidecarService_StartInstance_FullMethodName             = "/TaskHubSidecarService/StartInstance"
	TaskHubSidecarService_GetInstance_FullMethodName               = "/TaskHubSidecarService/GetInstance"
	TaskHubSidecarService_WaitForInstanceStart_FullMethodName      = "/TaskHubSidecarService/WaitForInstanceStart"
	TaskHubSidecarService_WaitForInstanceCompletion_FullMethodName = "/TaskHubSidecarService/WaitForInstanceCompletion"
	TaskHubSidecarService_RaiseEvent_FullMethodName                = "/TaskHubSidecarService/RaiseEvent"
	TaskHubSidecarService_TerminateInstance_FullMethodName         = "/TaskHubSidecarService/TerminateInstance"
	TaskHubSidecarService_SuspendInstance_FullMethodName           = "/TaskHubSidecarService/SuspendInstance"
	TaskHubSidecarService_ResumeInstance_FullMethodName            = "/TaskHubSidecarService/ResumeInstance"
	TaskHubSidecarService_PurgeInstances_FullMethodName            = "/TaskHubSidecarService/PurgeInstances"
	TaskHubSidecarService_GetWorkItems_FullMethodName              = "/TaskHubSidecarService/GetWorkItems"
	TaskHubSidecarService_CompleteActivityTask_FullMethodName      = "/TaskHubSidecarService/CompleteActivityTask"
	TaskHubSidecarService_CompleteOrchestratorTask_FullMethodName  = "/TaskHubSidecarService/CompleteOrchestratorTask"
	TaskHubSidecarService_CompleteWorkflowTask_FullMethodName      = "/TaskHubSidecarService/CompleteWorkflowTask"
	TaskHubSidecarService_ListInstanceIDs_FullMethodName           = "/TaskHubSidecarService/ListInstanceIDs"
	TaskHubSidecarService_GetInstanceHistory_FullMethodName        = "/TaskHubSidecarService/GetInstanceHistory"
)

Variables

View Source
var (
	StalledReason_name = map[int32]string{
		0: "PATCH_MISMATCH",
		1: "VERSION_NOT_AVAILABLE",
		2: "PAYLOAD_SIZE_EXCEEDED",
	}
	StalledReason_value = map[string]int32{
		"PATCH_MISMATCH":        0,
		"VERSION_NOT_AVAILABLE": 1,
		"PAYLOAD_SIZE_EXCEEDED": 2,
	}
)

Enum value maps for StalledReason.

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",
		8: "ORCHESTRATION_STATUS_STALLED",
	}
	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,
		"ORCHESTRATION_STATUS_STALLED":          8,
	}
)

Enum value maps for OrchestrationStatus.

View Source
var (
	HistoryPropagationScope_name = map[int32]string{
		0: "HISTORY_PROPAGATION_SCOPE_NONE",
		1: "HISTORY_PROPAGATION_SCOPE_OWN_HISTORY",
		2: "HISTORY_PROPAGATION_SCOPE_LINEAGE",
	}
	HistoryPropagationScope_value = map[string]int32{
		"HISTORY_PROPAGATION_SCOPE_NONE":        0,
		"HISTORY_PROPAGATION_SCOPE_OWN_HISTORY": 1,
		"HISTORY_PROPAGATION_SCOPE_LINEAGE":     2,
	}
)

Enum value maps for HistoryPropagationScope.

View Source
var (
	WorkerCapability_name = map[int32]string{
		0: "WORKER_CAPABILITY_UNSPECIFIED",
		2: "WORKER_CAPABILITY_STATEFUL_HISTORY",
	}
	WorkerCapability_value = map[string]int32{
		"WORKER_CAPABILITY_UNSPECIFIED":      0,
		"WORKER_CAPABILITY_STATEFUL_HISTORY": 2,
	}
)

Enum value maps for WorkerCapability.

View Source
var File_backend_service_proto protoreflect.FileDescriptor
View Source
var File_history_events_proto protoreflect.FileDescriptor
View Source
var File_orchestration_proto protoreflect.FileDescriptor
View Source
var File_orchestrator_actions_proto protoreflect.FileDescriptor
View Source
var File_orchestrator_service_proto protoreflect.FileDescriptor
View Source
var File_runtime_state_proto protoreflect.FileDescriptor
View Source
var TaskHubSidecarService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "TaskHubSidecarService",
	HandlerType: (*TaskHubSidecarServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Hello",
			Handler:    _TaskHubSidecarService_Hello_Handler,
		},
		{
			MethodName: "StartInstance",
			Handler:    _TaskHubSidecarService_StartInstance_Handler,
		},
		{
			MethodName: "GetInstance",
			Handler:    _TaskHubSidecarService_GetInstance_Handler,
		},
		{
			MethodName: "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: "PurgeInstances",
			Handler:    _TaskHubSidecarService_PurgeInstances_Handler,
		},
		{
			MethodName: "CompleteActivityTask",
			Handler:    _TaskHubSidecarService_CompleteActivityTask_Handler,
		},
		{
			MethodName: "CompleteOrchestratorTask",
			Handler:    _TaskHubSidecarService_CompleteOrchestratorTask_Handler,
		},
		{
			MethodName: "CompleteWorkflowTask",
			Handler:    _TaskHubSidecarService_CompleteWorkflowTask_Handler,
		},
		{
			MethodName: "ListInstanceIDs",
			Handler:    _TaskHubSidecarService_ListInstanceIDs_Handler,
		},
		{
			MethodName: "GetInstanceHistory",
			Handler:    _TaskHubSidecarService_GetInstanceHistory_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 ActivityInvocation

type ActivityInvocation struct {
	HistoryEvent *HistoryEvent `protobuf:"bytes,1,opt,name=historyEvent,proto3" json:"historyEvent,omitempty"`
	// Propagated history from the calling workflow.
	PropagatedHistory *PropagatedHistory `protobuf:"bytes,2,opt,name=propagatedHistory,proto3,oneof" json:"propagatedHistory,omitempty"`
	// contains filtered or unexported fields
}

ActivityInvocation wraps a TaskScheduled HistoryEvent with optional propagated history for delivery to an activity actor.

func (*ActivityInvocation) Descriptor deprecated

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

Deprecated: Use ActivityInvocation.ProtoReflect.Descriptor instead.

func (*ActivityInvocation) GetHistoryEvent

func (x *ActivityInvocation) GetHistoryEvent() *HistoryEvent

func (*ActivityInvocation) GetPropagatedHistory

func (x *ActivityInvocation) GetPropagatedHistory() *PropagatedHistory

func (*ActivityInvocation) ProtoMessage

func (*ActivityInvocation) ProtoMessage()

func (*ActivityInvocation) ProtoReflect

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

func (*ActivityInvocation) Reset

func (x *ActivityInvocation) Reset()

func (*ActivityInvocation) String

func (x *ActivityInvocation) String() string

type ActivityRequest

type ActivityRequest struct {
	Name               string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version            *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	WorkflowInstance   *WorkflowInstance       `protobuf:"bytes,4,opt,name=workflowInstance,proto3" json:"workflowInstance,omitempty"`
	TaskId             int32                   `protobuf:"varint,5,opt,name=taskId,proto3" json:"taskId,omitempty"`
	ParentTraceContext *TraceContext           `protobuf:"bytes,6,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	TaskExecutionId    string                  `protobuf:"bytes,7,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
	// Propagated history from the calling workflow.
	// Delivered via the work item stream to the SDK, so that the
	// activity function can access it via ctx.
	PropagatedHistory *PropagatedHistory `protobuf:"bytes,8,opt,name=propagatedHistory,proto3,oneof" json:"propagatedHistory,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityRequest) Descriptor deprecated

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

Deprecated: Use ActivityRequest.ProtoReflect.Descriptor instead.

func (*ActivityRequest) GetInput

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

func (*ActivityRequest) GetName

func (x *ActivityRequest) GetName() string

func (*ActivityRequest) GetParentTraceContext

func (x *ActivityRequest) GetParentTraceContext() *TraceContext

func (*ActivityRequest) GetPropagatedHistory

func (x *ActivityRequest) GetPropagatedHistory() *PropagatedHistory

func (*ActivityRequest) GetTaskExecutionId

func (x *ActivityRequest) GetTaskExecutionId() string

func (*ActivityRequest) GetTaskId

func (x *ActivityRequest) GetTaskId() int32

func (*ActivityRequest) GetVersion

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

func (*ActivityRequest) GetWorkflowInstance

func (x *ActivityRequest) GetWorkflowInstance() *WorkflowInstance

func (*ActivityRequest) ProtoMessage

func (*ActivityRequest) ProtoMessage()

func (*ActivityRequest) ProtoReflect

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

func (*ActivityRequest) Reset

func (x *ActivityRequest) Reset()

func (*ActivityRequest) String

func (x *ActivityRequest) String() string

type ActivityResponse

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

func (*ActivityResponse) Descriptor deprecated

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

Deprecated: Use ActivityResponse.ProtoReflect.Descriptor instead.

func (*ActivityResponse) GetCompletionToken

func (x *ActivityResponse) GetCompletionToken() string

func (*ActivityResponse) GetFailureDetails

func (x *ActivityResponse) GetFailureDetails() *TaskFailureDetails

func (*ActivityResponse) GetInstanceId

func (x *ActivityResponse) GetInstanceId() string

func (*ActivityResponse) GetResult

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

func (*ActivityResponse) GetTaskId

func (x *ActivityResponse) GetTaskId() int32

func (*ActivityResponse) ProtoMessage

func (*ActivityResponse) ProtoMessage()

func (*ActivityResponse) ProtoReflect

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

func (*ActivityResponse) Reset

func (x *ActivityResponse) Reset()

func (*ActivityResponse) String

func (x *ActivityResponse) String() string

type AddEventRequest

type AddEventRequest struct {

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

Request payload for adding new workflow events.

func (*AddEventRequest) Descriptor deprecated

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

Deprecated: Use AddEventRequest.ProtoReflect.Descriptor instead.

func (*AddEventRequest) GetEvent

func (x *AddEventRequest) GetEvent() *HistoryEvent

func (*AddEventRequest) GetInstance

func (x *AddEventRequest) GetInstance() *WorkflowInstance

func (*AddEventRequest) ProtoMessage

func (*AddEventRequest) ProtoMessage()

func (*AddEventRequest) ProtoReflect

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

func (*AddEventRequest) Reset

func (x *AddEventRequest) Reset()

func (*AddEventRequest) String

func (x *AddEventRequest) String() string

type AddEventResponse

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

Response payload for adding new workflow events.

func (*AddEventResponse) Descriptor deprecated

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

Deprecated: Use AddEventResponse.ProtoReflect.Descriptor instead.

func (*AddEventResponse) ProtoMessage

func (*AddEventResponse) ProtoMessage()

func (*AddEventResponse) ProtoReflect

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

func (*AddEventResponse) Reset

func (x *AddEventResponse) Reset()

func (*AddEventResponse) String

func (x *AddEventResponse) String() string

type BackendWorkflowState

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

func (*BackendWorkflowState) Descriptor deprecated

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

Deprecated: Use BackendWorkflowState.ProtoReflect.Descriptor instead.

func (*BackendWorkflowState) GetCustomStatus

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

func (*BackendWorkflowState) GetGeneration

func (x *BackendWorkflowState) GetGeneration() uint64

func (*BackendWorkflowState) GetHistory

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

func (*BackendWorkflowState) GetInbox

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

func (*BackendWorkflowState) ProtoMessage

func (*BackendWorkflowState) ProtoMessage()

func (*BackendWorkflowState) ProtoReflect

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

func (*BackendWorkflowState) Reset

func (x *BackendWorkflowState) Reset()

func (*BackendWorkflowState) String

func (x *BackendWorkflowState) String() string

type BackendWorkflowStateMetadata

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

func (*BackendWorkflowStateMetadata) Descriptor deprecated

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

Deprecated: Use BackendWorkflowStateMetadata.ProtoReflect.Descriptor instead.

func (*BackendWorkflowStateMetadata) GetGeneration

func (x *BackendWorkflowStateMetadata) GetGeneration() uint64

func (*BackendWorkflowStateMetadata) GetHistoryLength

func (x *BackendWorkflowStateMetadata) GetHistoryLength() uint64

func (*BackendWorkflowStateMetadata) GetInboxLength

func (x *BackendWorkflowStateMetadata) GetInboxLength() uint64

func (*BackendWorkflowStateMetadata) ProtoMessage

func (*BackendWorkflowStateMetadata) ProtoMessage()

func (*BackendWorkflowStateMetadata) ProtoReflect

func (*BackendWorkflowStateMetadata) Reset

func (x *BackendWorkflowStateMetadata) Reset()

func (*BackendWorkflowStateMetadata) String

type CachedHistory

type CachedHistory struct {

	// eventCount is the number of leading (committed) history events the
	// service believes the worker already holds, i.e. the length of the prefix
	// omitted from pastEvents. The worker's cached prefix must contain exactly
	// this many events; if it does not, the worker must treat this as a cache
	// miss and fetch the full history via GetInstanceHistory before applying
	// newEvents.
	EventCount int32 `protobuf:"varint,1,opt,name=eventCount,proto3" json:"eventCount,omitempty"`
	// contains filtered or unexported fields
}

CachedHistory is set on a WorkflowRequest when the service has intentionally omitted the committed history prefix the worker is expected to already hold for this instance from a previous turn on the same stream (see WORKER_CAPABILITY_STATEFUL_HISTORY). Its presence means pastEvents carries only the delta since the worker was last brought up to date; its absence means pastEvents is the full committed history. The worker reconstructs the full past history by prepending its cached events to pastEvents. The service only sets this for workers that advertised WORKER_CAPABILITY_STATEFUL_HISTORY and that it believes to be warm for the instance, so it is always safe for a worker to fall back to the GetInstanceHistory RPC.

func (*CachedHistory) Descriptor deprecated

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

Deprecated: Use CachedHistory.ProtoReflect.Descriptor instead.

func (*CachedHistory) GetEventCount

func (x *CachedHistory) GetEventCount() int32

func (*CachedHistory) ProtoMessage

func (*CachedHistory) ProtoMessage()

func (*CachedHistory) ProtoReflect

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

func (*CachedHistory) Reset

func (x *CachedHistory) Reset()

func (*CachedHistory) String

func (x *CachedHistory) String() string

type ChildWorkflowInstanceCompletedEvent

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

func (*ChildWorkflowInstanceCompletedEvent) Descriptor deprecated

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

Deprecated: Use ChildWorkflowInstanceCompletedEvent.ProtoReflect.Descriptor instead.

func (*ChildWorkflowInstanceCompletedEvent) GetResult

func (*ChildWorkflowInstanceCompletedEvent) GetTaskScheduledId

func (x *ChildWorkflowInstanceCompletedEvent) GetTaskScheduledId() int32

func (*ChildWorkflowInstanceCompletedEvent) ProtoMessage

func (*ChildWorkflowInstanceCompletedEvent) ProtoMessage()

func (*ChildWorkflowInstanceCompletedEvent) ProtoReflect

func (*ChildWorkflowInstanceCompletedEvent) Reset

func (*ChildWorkflowInstanceCompletedEvent) String

type ChildWorkflowInstanceCreatedEvent

type ChildWorkflowInstanceCreatedEvent struct {
	InstanceId         string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name               string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version            *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ParentTraceContext *TraceContext           `protobuf:"bytes,5,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	// History propagation scope used when this child workflow was originally
	// scheduled. Persisted on the event so rerun can re-issue the child with
	// the same scope after the action has been discarded.
	HistoryPropagationScope *HistoryPropagationScope `` /* 135-byte string literal not displayed */
	// If defined, indicates that this child workflow is a retry attempt and
	// links it back to the first attempt in the retry chain. Absent on the
	// first attempt. Consumers correlate retry attempts by grouping on
	// retryParentInstanceInfo.instanceID when present, otherwise on this
	// event's own instanceId.
	RetryParentInstanceInfo *RetryParentInstanceInfo `protobuf:"bytes,8,opt,name=retryParentInstanceInfo,proto3,oneof" json:"retryParentInstanceInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*ChildWorkflowInstanceCreatedEvent) Descriptor deprecated

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

Deprecated: Use ChildWorkflowInstanceCreatedEvent.ProtoReflect.Descriptor instead.

func (*ChildWorkflowInstanceCreatedEvent) GetHistoryPropagationScope

func (x *ChildWorkflowInstanceCreatedEvent) GetHistoryPropagationScope() HistoryPropagationScope

func (*ChildWorkflowInstanceCreatedEvent) GetInput

func (*ChildWorkflowInstanceCreatedEvent) GetInstanceId

func (x *ChildWorkflowInstanceCreatedEvent) GetInstanceId() string

func (*ChildWorkflowInstanceCreatedEvent) GetName

func (*ChildWorkflowInstanceCreatedEvent) GetParentTraceContext

func (x *ChildWorkflowInstanceCreatedEvent) GetParentTraceContext() *TraceContext

func (*ChildWorkflowInstanceCreatedEvent) GetRetryParentInstanceInfo

func (x *ChildWorkflowInstanceCreatedEvent) GetRetryParentInstanceInfo() *RetryParentInstanceInfo

func (*ChildWorkflowInstanceCreatedEvent) GetVersion

func (*ChildWorkflowInstanceCreatedEvent) ProtoMessage

func (*ChildWorkflowInstanceCreatedEvent) ProtoMessage()

func (*ChildWorkflowInstanceCreatedEvent) ProtoReflect

func (*ChildWorkflowInstanceCreatedEvent) Reset

func (*ChildWorkflowInstanceCreatedEvent) String

type ChildWorkflowInstanceFailedEvent

type ChildWorkflowInstanceFailedEvent 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 (*ChildWorkflowInstanceFailedEvent) Descriptor deprecated

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

Deprecated: Use ChildWorkflowInstanceFailedEvent.ProtoReflect.Descriptor instead.

func (*ChildWorkflowInstanceFailedEvent) GetFailureDetails

func (x *ChildWorkflowInstanceFailedEvent) GetFailureDetails() *TaskFailureDetails

func (*ChildWorkflowInstanceFailedEvent) GetTaskScheduledId

func (x *ChildWorkflowInstanceFailedEvent) GetTaskScheduledId() int32

func (*ChildWorkflowInstanceFailedEvent) ProtoMessage

func (*ChildWorkflowInstanceFailedEvent) ProtoMessage()

func (*ChildWorkflowInstanceFailedEvent) ProtoReflect

func (*ChildWorkflowInstanceFailedEvent) Reset

func (*ChildWorkflowInstanceFailedEvent) String

type CompleteActivityWorkItemRequest

type CompleteActivityWorkItemRequest struct {

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

Request payload for completing an activity work item.

func (*CompleteActivityWorkItemRequest) Descriptor deprecated

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

Deprecated: Use CompleteActivityWorkItemRequest.ProtoReflect.Descriptor instead.

func (*CompleteActivityWorkItemRequest) GetCompletionToken

func (x *CompleteActivityWorkItemRequest) GetCompletionToken() string

func (*CompleteActivityWorkItemRequest) GetResponseEvent

func (x *CompleteActivityWorkItemRequest) GetResponseEvent() *HistoryEvent

func (*CompleteActivityWorkItemRequest) ProtoMessage

func (*CompleteActivityWorkItemRequest) ProtoMessage()

func (*CompleteActivityWorkItemRequest) ProtoReflect

func (*CompleteActivityWorkItemRequest) Reset

func (*CompleteActivityWorkItemRequest) String

type CompleteActivityWorkItemResponse

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

Response payload for completing an activity work item.

func (*CompleteActivityWorkItemResponse) Descriptor deprecated

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

Deprecated: Use CompleteActivityWorkItemResponse.ProtoReflect.Descriptor instead.

func (*CompleteActivityWorkItemResponse) ProtoMessage

func (*CompleteActivityWorkItemResponse) ProtoMessage()

func (*CompleteActivityWorkItemResponse) ProtoReflect

func (*CompleteActivityWorkItemResponse) Reset

func (*CompleteActivityWorkItemResponse) String

type CompleteOrchestrationAction deprecated

type CompleteOrchestrationAction = CompleteWorkflowAction

Deprecated: Use CompleteWorkflowAction instead.

type CompleteOrchestrationWorkItemRequest deprecated

type CompleteOrchestrationWorkItemRequest = CompleteWorkflowWorkItemRequest

Deprecated: Use CompleteWorkflowWorkItemRequest instead.

type CompleteOrchestrationWorkItemResponse deprecated

type CompleteOrchestrationWorkItemResponse = CompleteWorkflowWorkItemResponse

Deprecated: Use CompleteWorkflowWorkItemResponse instead.

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 CompleteWorkflowAction

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

func (*CompleteWorkflowAction) Descriptor deprecated

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

Deprecated: Use CompleteWorkflowAction.ProtoReflect.Descriptor instead.

func (*CompleteWorkflowAction) GetCarryoverEvents

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

func (*CompleteWorkflowAction) GetDetails

func (*CompleteWorkflowAction) GetFailureDetails

func (x *CompleteWorkflowAction) GetFailureDetails() *TaskFailureDetails

func (*CompleteWorkflowAction) GetNewVersion

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

func (*CompleteWorkflowAction) GetOrchestrationStatus deprecated

func (x *CompleteWorkflowAction) GetOrchestrationStatus() OrchestrationStatus

Deprecated: Use GetWorkflowStatus on CompleteWorkflowAction instead.

func (*CompleteWorkflowAction) GetResult

func (*CompleteWorkflowAction) GetWorkflowStatus

func (x *CompleteWorkflowAction) GetWorkflowStatus() OrchestrationStatus

func (*CompleteWorkflowAction) ProtoMessage

func (*CompleteWorkflowAction) ProtoMessage()

func (*CompleteWorkflowAction) ProtoReflect

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

func (*CompleteWorkflowAction) Reset

func (x *CompleteWorkflowAction) Reset()

func (*CompleteWorkflowAction) String

func (x *CompleteWorkflowAction) String() string

type CompleteWorkflowWorkItemRequest

type CompleteWorkflowWorkItemRequest struct {

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

Request payload for completing a workflow work item.

func (*CompleteWorkflowWorkItemRequest) Descriptor deprecated

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

Deprecated: Use CompleteWorkflowWorkItemRequest.ProtoReflect.Descriptor instead.

func (*CompleteWorkflowWorkItemRequest) GetCompletionToken

func (x *CompleteWorkflowWorkItemRequest) GetCompletionToken() string

func (*CompleteWorkflowWorkItemRequest) GetCustomStatus

func (*CompleteWorkflowWorkItemRequest) GetInstance

func (*CompleteWorkflowWorkItemRequest) GetNewHistory

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

func (*CompleteWorkflowWorkItemRequest) GetNewMessages

func (x *CompleteWorkflowWorkItemRequest) GetNewMessages() []*WorkflowMessage

func (*CompleteWorkflowWorkItemRequest) GetNewTasks

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

func (*CompleteWorkflowWorkItemRequest) GetNewTimers

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

func (*CompleteWorkflowWorkItemRequest) GetNumEventsProcessed

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

func (*CompleteWorkflowWorkItemRequest) GetRuntimeStatus

func (*CompleteWorkflowWorkItemRequest) ProtoMessage

func (*CompleteWorkflowWorkItemRequest) ProtoMessage()

func (*CompleteWorkflowWorkItemRequest) ProtoReflect

func (*CompleteWorkflowWorkItemRequest) Reset

func (*CompleteWorkflowWorkItemRequest) String

type CompleteWorkflowWorkItemResponse

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

Response payload for completing a workflow work item.

func (*CompleteWorkflowWorkItemResponse) Descriptor deprecated

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

Deprecated: Use CompleteWorkflowWorkItemResponse.ProtoReflect.Descriptor instead.

func (*CompleteWorkflowWorkItemResponse) ProtoMessage

func (*CompleteWorkflowWorkItemResponse) ProtoMessage()

func (*CompleteWorkflowWorkItemResponse) ProtoReflect

func (*CompleteWorkflowWorkItemResponse) Reset

func (*CompleteWorkflowWorkItemResponse) String

type ContinueAsNewEvent

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

func (*ContinueAsNewEvent) Descriptor deprecated

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

Deprecated: Use ContinueAsNewEvent.ProtoReflect.Descriptor instead.

func (*ContinueAsNewEvent) GetInput

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

func (*ContinueAsNewEvent) ProtoMessage

func (*ContinueAsNewEvent) ProtoMessage()

func (*ContinueAsNewEvent) ProtoReflect

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

func (*ContinueAsNewEvent) Reset

func (x *ContinueAsNewEvent) Reset()

func (*ContinueAsNewEvent) String

func (x *ContinueAsNewEvent) String() string

type CreateChildWorkflowAction

type CreateChildWorkflowAction struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name       string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input      *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// History propagation scope. Absent/SCOPE_NONE = no propagation.
	HistoryPropagationScope *HistoryPropagationScope `` /* 135-byte string literal not displayed */
	// If defined, indicates that this child workflow is a retry attempt and
	// links it back to the first attempt in the retry chain. Absent on the
	// first attempt. The runtime persists this onto the resulting
	// ChildWorkflowInstanceCreatedEvent so consumers can correlate retry
	// attempts by grouping on retryParentInstanceInfo.instanceID when present,
	// otherwise on the created instance's own instanceId.
	RetryParentInstanceInfo *RetryParentInstanceInfo `protobuf:"bytes,7,opt,name=retryParentInstanceInfo,proto3,oneof" json:"retryParentInstanceInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateChildWorkflowAction) Descriptor deprecated

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

Deprecated: Use CreateChildWorkflowAction.ProtoReflect.Descriptor instead.

func (*CreateChildWorkflowAction) GetHistoryPropagationScope

func (x *CreateChildWorkflowAction) GetHistoryPropagationScope() HistoryPropagationScope

func (*CreateChildWorkflowAction) GetInput

func (*CreateChildWorkflowAction) GetInstanceId

func (x *CreateChildWorkflowAction) GetInstanceId() string

func (*CreateChildWorkflowAction) GetName

func (x *CreateChildWorkflowAction) GetName() string

func (*CreateChildWorkflowAction) GetRetryParentInstanceInfo

func (x *CreateChildWorkflowAction) GetRetryParentInstanceInfo() *RetryParentInstanceInfo

func (*CreateChildWorkflowAction) GetVersion

func (*CreateChildWorkflowAction) ProtoMessage

func (*CreateChildWorkflowAction) ProtoMessage()

func (*CreateChildWorkflowAction) ProtoReflect

func (*CreateChildWorkflowAction) Reset

func (x *CreateChildWorkflowAction) Reset()

func (*CreateChildWorkflowAction) String

func (x *CreateChildWorkflowAction) String() string

type CreateDetachedWorkflowAction

type CreateDetachedWorkflowAction struct {

	// instanceId is the ID assigned to the new workflow. It is mandatory:
	// implementors must set a stable, deterministic ID so that on replay the
	// call resolves to the same DetachedWorkflowInstanceCreatedEvent in
	// history.
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// name of the workflow to schedule. Mandatory.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The remaining fields mirror the optional inputs of
	// CreateInstanceRequest. Wrapper types (StringValue) carry presence via
	// the wrapper; bare message fields are explicitly marked optional.
	Version                 *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input                   *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledStartTimestamp *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3,oneof" json:"scheduledStartTimestamp,omitempty"`
	ExecutionId             *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=executionId,proto3" json:"executionId,omitempty"`
	Tags                    map[string]string       `` /* 149-byte string literal not displayed */
	ParentTraceContext      *TraceContext           `protobuf:"bytes,8,opt,name=parentTraceContext,proto3,oneof" json:"parentTraceContext,omitempty"`
	// contains filtered or unexported fields
}

CreateDetachedWorkflowAction creates a new, detached workflow instance from a running workflow. Mirrors the fields of CreateInstanceRequest (the client scheduling API) so the runtime has all the information needed to schedule the new instance directly from this action. The spawned workflow is fully decoupled from the caller: no parent pointer is recorded on the new workflow, no completion is awaited, and no failure propagation flows back. The creation is recorded once in the caller's history as a DetachedWorkflowInstanceCreatedEvent referencing the new instance ID.

func (*CreateDetachedWorkflowAction) Descriptor deprecated

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

Deprecated: Use CreateDetachedWorkflowAction.ProtoReflect.Descriptor instead.

func (*CreateDetachedWorkflowAction) GetExecutionId

func (*CreateDetachedWorkflowAction) GetInput

func (*CreateDetachedWorkflowAction) GetInstanceId

func (x *CreateDetachedWorkflowAction) GetInstanceId() string

func (*CreateDetachedWorkflowAction) GetName

func (x *CreateDetachedWorkflowAction) GetName() string

func (*CreateDetachedWorkflowAction) GetParentTraceContext

func (x *CreateDetachedWorkflowAction) GetParentTraceContext() *TraceContext

func (*CreateDetachedWorkflowAction) GetScheduledStartTimestamp

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

func (*CreateDetachedWorkflowAction) GetTags

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

func (*CreateDetachedWorkflowAction) GetVersion

func (*CreateDetachedWorkflowAction) ProtoMessage

func (*CreateDetachedWorkflowAction) ProtoMessage()

func (*CreateDetachedWorkflowAction) ProtoReflect

func (*CreateDetachedWorkflowAction) Reset

func (x *CreateDetachedWorkflowAction) Reset()

func (*CreateDetachedWorkflowAction) String

type CreateInstanceRequest

type CreateInstanceRequest struct {
	InstanceId              string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name                    string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version                 *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Input                   *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledStartTimestamp *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=scheduledStartTimestamp,proto3" json:"scheduledStartTimestamp,omitempty"`
	ExecutionId             *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=executionId,proto3" json:"executionId,omitempty"`
	Tags                    map[string]string       `` /* 135-byte string literal not displayed */
	ParentTraceContext      *TraceContext           `protobuf:"bytes,9,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	// When true, the request fails with an ALREADY_EXISTS error if a workflow
	// instance with the same instanceId already exists, whether active or
	// completed. When false, an existing completed instance is restarted.
	EnforceUniqueInstanceId bool `protobuf:"varint,10,opt,name=enforceUniqueInstanceId,proto3" json:"enforceUniqueInstanceId,omitempty"`
	// router optionally routes this operation to the workflow instance owned
	// by another app. When targetAppID names a different app, the operation is
	// executed against that app's instance (same namespace unless
	// targetAppNamespace is set). sourceAppID is stamped by the sidecar, not
	// the client.
	Router *TaskRouter `protobuf:"bytes,11,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateInstanceRequest) Descriptor deprecated

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

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetEnforceUniqueInstanceId

func (x *CreateInstanceRequest) GetEnforceUniqueInstanceId() bool

func (*CreateInstanceRequest) GetExecutionId

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

func (*CreateInstanceRequest) GetInput

func (*CreateInstanceRequest) GetInstanceId

func (x *CreateInstanceRequest) GetInstanceId() string

func (*CreateInstanceRequest) GetName

func (x *CreateInstanceRequest) GetName() string

func (*CreateInstanceRequest) GetParentTraceContext

func (x *CreateInstanceRequest) GetParentTraceContext() *TraceContext

func (*CreateInstanceRequest) GetRouter

func (x *CreateInstanceRequest) GetRouter() *TaskRouter

func (*CreateInstanceRequest) GetScheduledStartTimestamp

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

func (*CreateInstanceRequest) GetTags

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

func (*CreateInstanceRequest) GetVersion

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

func (*CreateInstanceRequest) ProtoMessage

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) ProtoReflect

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

func (*CreateInstanceRequest) Reset

func (x *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String

func (x *CreateInstanceRequest) String() string

type CreateInstanceResponse

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

func (*CreateInstanceResponse) Descriptor deprecated

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

Deprecated: Use CreateInstanceResponse.ProtoReflect.Descriptor instead.

func (*CreateInstanceResponse) GetInstanceId

func (x *CreateInstanceResponse) GetInstanceId() string

func (*CreateInstanceResponse) ProtoMessage

func (*CreateInstanceResponse) ProtoMessage()

func (*CreateInstanceResponse) ProtoReflect

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

func (*CreateInstanceResponse) Reset

func (x *CreateInstanceResponse) Reset()

func (*CreateInstanceResponse) String

func (x *CreateInstanceResponse) String() string

type CreateSubOrchestrationAction deprecated

type CreateSubOrchestrationAction = CreateChildWorkflowAction

Deprecated: Use CreateChildWorkflowAction instead.

type CreateTimerAction

type CreateTimerAction struct {
	FireAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fireAt,proto3" json:"fireAt,omitempty"`
	Name   *string                `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// If set, provides additional context attached to this timer.
	//
	// Types that are assignable to Origin:
	//
	//	*CreateTimerAction_CreateTimer
	//	*CreateTimerAction_ExternalEvent
	//	*CreateTimerAction_ActivityRetry
	//	*CreateTimerAction_ChildWorkflowRetry
	Origin isCreateTimerAction_Origin `protobuf_oneof:"origin"`
	// contains filtered or unexported fields
}

func (*CreateTimerAction) Descriptor deprecated

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

Deprecated: Use CreateTimerAction.ProtoReflect.Descriptor instead.

func (*CreateTimerAction) GetActivityRetry

func (x *CreateTimerAction) GetActivityRetry() *TimerOriginActivityRetry

func (*CreateTimerAction) GetChildWorkflowRetry

func (x *CreateTimerAction) GetChildWorkflowRetry() *TimerOriginChildWorkflowRetry

func (*CreateTimerAction) GetCreateTimer

func (x *CreateTimerAction) GetCreateTimer() *TimerOriginCreateTimer

func (*CreateTimerAction) GetExternalEvent

func (x *CreateTimerAction) GetExternalEvent() *TimerOriginExternalEvent

func (*CreateTimerAction) GetFireAt

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

func (*CreateTimerAction) GetName

func (x *CreateTimerAction) GetName() string

func (*CreateTimerAction) GetOrigin

func (m *CreateTimerAction) GetOrigin() isCreateTimerAction_Origin

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 CreateTimerAction_ActivityRetry

type CreateTimerAction_ActivityRetry struct {
	ActivityRetry *TimerOriginActivityRetry `protobuf:"bytes,5,opt,name=activityRetry,proto3,oneof"`
}

type CreateTimerAction_ChildWorkflowRetry

type CreateTimerAction_ChildWorkflowRetry struct {
	ChildWorkflowRetry *TimerOriginChildWorkflowRetry `protobuf:"bytes,6,opt,name=childWorkflowRetry,proto3,oneof"`
}

type CreateTimerAction_CreateTimer

type CreateTimerAction_CreateTimer struct {
	CreateTimer *TimerOriginCreateTimer `protobuf:"bytes,3,opt,name=createTimer,proto3,oneof"`
}

type CreateTimerAction_ExternalEvent

type CreateTimerAction_ExternalEvent struct {
	ExternalEvent *TimerOriginExternalEvent `protobuf:"bytes,4,opt,name=externalEvent,proto3,oneof"`
}

type CreateWorkflowInstanceRequest

type CreateWorkflowInstanceRequest struct {
	StartEvent *HistoryEvent `protobuf:"bytes,1,opt,name=startEvent,proto3" json:"startEvent,omitempty"`
	// Propagated history from the parent workflow.
	PropagatedHistory *PropagatedHistory `protobuf:"bytes,3,opt,name=propagatedHistory,proto3,oneof" json:"propagatedHistory,omitempty"`
	// When true, the request fails with an ALREADY_EXISTS error if a workflow
	// instance with the same instanceId already exists, whether active or
	// completed. When false, an existing completed instance is restarted.
	EnforceUniqueInstanceId bool `protobuf:"varint,4,opt,name=enforceUniqueInstanceId,proto3" json:"enforceUniqueInstanceId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateWorkflowInstanceRequest) Descriptor deprecated

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

Deprecated: Use CreateWorkflowInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateWorkflowInstanceRequest) GetEnforceUniqueInstanceId

func (x *CreateWorkflowInstanceRequest) GetEnforceUniqueInstanceId() bool

func (*CreateWorkflowInstanceRequest) GetPropagatedHistory

func (x *CreateWorkflowInstanceRequest) GetPropagatedHistory() *PropagatedHistory

func (*CreateWorkflowInstanceRequest) GetStartEvent

func (x *CreateWorkflowInstanceRequest) GetStartEvent() *HistoryEvent

func (*CreateWorkflowInstanceRequest) ProtoMessage

func (*CreateWorkflowInstanceRequest) ProtoMessage()

func (*CreateWorkflowInstanceRequest) ProtoReflect

func (*CreateWorkflowInstanceRequest) Reset

func (x *CreateWorkflowInstanceRequest) Reset()

func (*CreateWorkflowInstanceRequest) String

type DetachedWorkflowInstanceCreatedEvent

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

DetachedWorkflowInstanceCreatedEvent records that a running workflow created a new, detached workflow instance via CreateDetachedWorkflowAction. The new workflow has no parent linkage (no completion or failure flows back), so this event only stores a pointer to the spawned instance — the inputs themselves are consumed directly from the action when scheduling. Replay matches on instanceId, so it is the same value the action carried.

func (*DetachedWorkflowInstanceCreatedEvent) Descriptor deprecated

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

Deprecated: Use DetachedWorkflowInstanceCreatedEvent.ProtoReflect.Descriptor instead.

func (*DetachedWorkflowInstanceCreatedEvent) GetInstanceId

func (x *DetachedWorkflowInstanceCreatedEvent) GetInstanceId() string

func (*DetachedWorkflowInstanceCreatedEvent) ProtoMessage

func (*DetachedWorkflowInstanceCreatedEvent) ProtoMessage()

func (*DetachedWorkflowInstanceCreatedEvent) ProtoReflect

func (*DetachedWorkflowInstanceCreatedEvent) Reset

func (*DetachedWorkflowInstanceCreatedEvent) String

type DurableTimer

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

func (*DurableTimer) Descriptor deprecated

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

Deprecated: Use DurableTimer.ProtoReflect.Descriptor instead.

func (*DurableTimer) GetGeneration

func (x *DurableTimer) GetGeneration() uint64

func (*DurableTimer) GetTimerEvent

func (x *DurableTimer) GetTimerEvent() *HistoryEvent

func (*DurableTimer) ProtoMessage

func (*DurableTimer) ProtoMessage()

func (*DurableTimer) ProtoReflect

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

func (*DurableTimer) Reset

func (x *DurableTimer) Reset()

func (*DurableTimer) String

func (x *DurableTimer) String() string

type EventRaisedEvent

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

func (*EventRaisedEvent) Descriptor deprecated

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

Deprecated: Use EventRaisedEvent.ProtoReflect.Descriptor instead.

func (*EventRaisedEvent) GetInput

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

func (*EventRaisedEvent) GetName

func (x *EventRaisedEvent) GetName() string

func (*EventRaisedEvent) ProtoMessage

func (*EventRaisedEvent) ProtoMessage()

func (*EventRaisedEvent) ProtoReflect

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

func (*EventRaisedEvent) Reset

func (x *EventRaisedEvent) Reset()

func (*EventRaisedEvent) String

func (x *EventRaisedEvent) String() string

type EventSentEvent

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

func (*EventSentEvent) Descriptor deprecated

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

Deprecated: Use EventSentEvent.ProtoReflect.Descriptor instead.

func (*EventSentEvent) GetInput

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

func (*EventSentEvent) GetInstanceId

func (x *EventSentEvent) GetInstanceId() string

func (*EventSentEvent) GetName

func (x *EventSentEvent) GetName() string

func (*EventSentEvent) ProtoMessage

func (*EventSentEvent) ProtoMessage()

func (*EventSentEvent) ProtoReflect

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

func (*EventSentEvent) Reset

func (x *EventSentEvent) Reset()

func (*EventSentEvent) String

func (x *EventSentEvent) String() string

type ExecutionCompletedEvent

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

func (*ExecutionCompletedEvent) Descriptor deprecated

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

Deprecated: Use ExecutionCompletedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionCompletedEvent) GetFailureDetails

func (x *ExecutionCompletedEvent) GetFailureDetails() *TaskFailureDetails

func (*ExecutionCompletedEvent) GetOrchestrationStatus deprecated

func (x *ExecutionCompletedEvent) GetOrchestrationStatus() OrchestrationStatus

Deprecated: Use GetWorkflowStatus on ExecutionCompletedEvent instead.

func (*ExecutionCompletedEvent) GetResult

func (*ExecutionCompletedEvent) GetWorkflowStatus

func (x *ExecutionCompletedEvent) GetWorkflowStatus() OrchestrationStatus

func (*ExecutionCompletedEvent) ProtoMessage

func (*ExecutionCompletedEvent) ProtoMessage()

func (*ExecutionCompletedEvent) ProtoReflect

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

func (*ExecutionCompletedEvent) Reset

func (x *ExecutionCompletedEvent) Reset()

func (*ExecutionCompletedEvent) String

func (x *ExecutionCompletedEvent) String() string

type ExecutionResumedEvent

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

func (*ExecutionResumedEvent) Descriptor deprecated

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

Deprecated: Use ExecutionResumedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionResumedEvent) GetInput

func (*ExecutionResumedEvent) ProtoMessage

func (*ExecutionResumedEvent) ProtoMessage()

func (*ExecutionResumedEvent) ProtoReflect

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

func (*ExecutionResumedEvent) Reset

func (x *ExecutionResumedEvent) Reset()

func (*ExecutionResumedEvent) String

func (x *ExecutionResumedEvent) String() string

type ExecutionStalledEvent

type ExecutionStalledEvent struct {
	Reason      StalledReason `protobuf:"varint,1,opt,name=reason,proto3,enum=StalledReason" json:"reason,omitempty"`
	Description *string       `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionStalledEvent) Descriptor deprecated

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

Deprecated: Use ExecutionStalledEvent.ProtoReflect.Descriptor instead.

func (*ExecutionStalledEvent) GetDescription

func (x *ExecutionStalledEvent) GetDescription() string

func (*ExecutionStalledEvent) GetReason

func (x *ExecutionStalledEvent) GetReason() StalledReason

func (*ExecutionStalledEvent) ProtoMessage

func (*ExecutionStalledEvent) ProtoMessage()

func (*ExecutionStalledEvent) ProtoReflect

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

func (*ExecutionStalledEvent) Reset

func (x *ExecutionStalledEvent) Reset()

func (*ExecutionStalledEvent) String

func (x *ExecutionStalledEvent) String() string

type ExecutionStartedEvent

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

func (*ExecutionStartedEvent) Descriptor deprecated

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

Deprecated: Use ExecutionStartedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionStartedEvent) GetInput

func (*ExecutionStartedEvent) GetName

func (x *ExecutionStartedEvent) GetName() string

func (*ExecutionStartedEvent) GetOrchestrationInstance deprecated

func (x *ExecutionStartedEvent) GetOrchestrationInstance() *WorkflowInstance

Deprecated: Use GetWorkflowInstance instead.

func (*ExecutionStartedEvent) GetOrchestrationSpanID deprecated

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

Deprecated: Use GetWorkflowSpanID instead.

func (*ExecutionStartedEvent) GetParentInstance

func (x *ExecutionStartedEvent) GetParentInstance() *ParentInstanceInfo

func (*ExecutionStartedEvent) GetParentTraceContext

func (x *ExecutionStartedEvent) GetParentTraceContext() *TraceContext

func (*ExecutionStartedEvent) GetScheduledStartTimestamp

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

func (*ExecutionStartedEvent) GetTags

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

func (*ExecutionStartedEvent) GetVersion

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

func (*ExecutionStartedEvent) GetWorkflowInstance

func (x *ExecutionStartedEvent) GetWorkflowInstance() *WorkflowInstance

func (*ExecutionStartedEvent) GetWorkflowSpanID

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

func (*ExecutionStartedEvent) ProtoMessage

func (*ExecutionStartedEvent) ProtoMessage()

func (*ExecutionStartedEvent) ProtoReflect

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

func (*ExecutionStartedEvent) Reset

func (x *ExecutionStartedEvent) Reset()

func (*ExecutionStartedEvent) String

func (x *ExecutionStartedEvent) String() string

type ExecutionSuspendedEvent

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

func (*ExecutionSuspendedEvent) Descriptor deprecated

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

Deprecated: Use ExecutionSuspendedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionSuspendedEvent) GetInput

func (*ExecutionSuspendedEvent) ProtoMessage

func (*ExecutionSuspendedEvent) ProtoMessage()

func (*ExecutionSuspendedEvent) ProtoReflect

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

func (*ExecutionSuspendedEvent) Reset

func (x *ExecutionSuspendedEvent) Reset()

func (*ExecutionSuspendedEvent) String

func (x *ExecutionSuspendedEvent) String() string

type ExecutionTerminatedEvent

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

func (*ExecutionTerminatedEvent) Descriptor deprecated

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

Deprecated: Use ExecutionTerminatedEvent.ProtoReflect.Descriptor instead.

func (*ExecutionTerminatedEvent) GetInput

func (*ExecutionTerminatedEvent) GetRecurse

func (x *ExecutionTerminatedEvent) GetRecurse() bool

func (*ExecutionTerminatedEvent) ProtoMessage

func (*ExecutionTerminatedEvent) ProtoMessage()

func (*ExecutionTerminatedEvent) ProtoReflect

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

func (*ExecutionTerminatedEvent) Reset

func (x *ExecutionTerminatedEvent) Reset()

func (*ExecutionTerminatedEvent) String

func (x *ExecutionTerminatedEvent) String() string

type GetInstanceHistoryRequest

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

GetInstanceHistoryRequest is used to get the full history of a workflow instance.

func (*GetInstanceHistoryRequest) Descriptor deprecated

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

Deprecated: Use GetInstanceHistoryRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceHistoryRequest) GetInstanceId

func (x *GetInstanceHistoryRequest) GetInstanceId() string

func (*GetInstanceHistoryRequest) ProtoMessage

func (*GetInstanceHistoryRequest) ProtoMessage()

func (*GetInstanceHistoryRequest) ProtoReflect

func (*GetInstanceHistoryRequest) Reset

func (x *GetInstanceHistoryRequest) Reset()

func (*GetInstanceHistoryRequest) String

func (x *GetInstanceHistoryRequest) String() string

type GetInstanceHistoryResponse

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

GetInstanceHistoryResponse is the response to executing GetInstanceHistory.

func (*GetInstanceHistoryResponse) Descriptor deprecated

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

Deprecated: Use GetInstanceHistoryResponse.ProtoReflect.Descriptor instead.

func (*GetInstanceHistoryResponse) GetEvents

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

func (*GetInstanceHistoryResponse) ProtoMessage

func (*GetInstanceHistoryResponse) ProtoMessage()

func (*GetInstanceHistoryResponse) ProtoReflect

func (*GetInstanceHistoryResponse) Reset

func (x *GetInstanceHistoryResponse) Reset()

func (*GetInstanceHistoryResponse) String

func (x *GetInstanceHistoryResponse) 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"`
	// router optionally routes this operation to the workflow instance owned
	// by another app. sourceAppID is stamped by the sidecar, not the client.
	Router *TaskRouter `protobuf:"bytes,3,opt,name=router,proto3,oneof" json:"router,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) GetRouter

func (x *GetInstanceRequest) GetRouter() *TaskRouter

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"`
	WorkflowState *WorkflowState `protobuf:"bytes,2,opt,name=workflowState,proto3" json:"workflowState,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) GetWorkflowState

func (x *GetInstanceResponse) GetWorkflowState() *WorkflowState

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 {

	// capabilities advertises the optional protocol features this worker
	// supports, so the service can opt into optimizations on a per-stream
	// basis. Workers that leave this empty receive the default (fully
	// self-contained) behavior.
	Capabilities []WorkerCapability `protobuf:"varint,4,rep,packed,name=capabilities,proto3,enum=WorkerCapability" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkItemsRequest) Descriptor deprecated

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

Deprecated: Use GetWorkItemsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkItemsRequest) GetCapabilities

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

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 *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are assignable to EventType:
	//
	//	*HistoryEvent_ExecutionStarted
	//	*HistoryEvent_ExecutionCompleted
	//	*HistoryEvent_ExecutionTerminated
	//	*HistoryEvent_TaskScheduled
	//	*HistoryEvent_TaskCompleted
	//	*HistoryEvent_TaskFailed
	//	*HistoryEvent_ChildWorkflowInstanceCreated
	//	*HistoryEvent_ChildWorkflowInstanceCompleted
	//	*HistoryEvent_ChildWorkflowInstanceFailed
	//	*HistoryEvent_TimerCreated
	//	*HistoryEvent_TimerFired
	//	*HistoryEvent_WorkflowStarted
	//	*HistoryEvent_WorkflowCompleted
	//	*HistoryEvent_EventSent
	//	*HistoryEvent_EventRaised
	//	*HistoryEvent_ContinueAsNew
	//	*HistoryEvent_ExecutionSuspended
	//	*HistoryEvent_ExecutionResumed
	//	*HistoryEvent_ExecutionStalled
	//	*HistoryEvent_DetachedWorkflowInstanceCreated
	EventType isHistoryEvent_EventType `protobuf_oneof:"eventType"`
	Router    *TaskRouter              `protobuf:"bytes,30,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryEvent) Descriptor deprecated

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

Deprecated: Use HistoryEvent.ProtoReflect.Descriptor instead.

func (*HistoryEvent) GetChildWorkflowInstanceCompleted

func (x *HistoryEvent) GetChildWorkflowInstanceCompleted() *ChildWorkflowInstanceCompletedEvent

func (*HistoryEvent) GetChildWorkflowInstanceCreated

func (x *HistoryEvent) GetChildWorkflowInstanceCreated() *ChildWorkflowInstanceCreatedEvent

func (*HistoryEvent) GetChildWorkflowInstanceFailed

func (x *HistoryEvent) GetChildWorkflowInstanceFailed() *ChildWorkflowInstanceFailedEvent

func (*HistoryEvent) GetContinueAsNew

func (x *HistoryEvent) GetContinueAsNew() *ContinueAsNewEvent

func (*HistoryEvent) GetDetachedWorkflowInstanceCreated

func (x *HistoryEvent) GetDetachedWorkflowInstanceCreated() *DetachedWorkflowInstanceCreatedEvent

func (*HistoryEvent) GetEventId

func (x *HistoryEvent) GetEventId() int32

func (*HistoryEvent) GetEventRaised

func (x *HistoryEvent) GetEventRaised() *EventRaisedEvent

func (*HistoryEvent) GetEventSent

func (x *HistoryEvent) GetEventSent() *EventSentEvent

func (*HistoryEvent) GetEventType

func (m *HistoryEvent) GetEventType() isHistoryEvent_EventType

func (*HistoryEvent) GetExecutionCompleted

func (x *HistoryEvent) GetExecutionCompleted() *ExecutionCompletedEvent

func (*HistoryEvent) GetExecutionResumed

func (x *HistoryEvent) GetExecutionResumed() *ExecutionResumedEvent

func (*HistoryEvent) GetExecutionStalled

func (x *HistoryEvent) GetExecutionStalled() *ExecutionStalledEvent

func (*HistoryEvent) GetExecutionStarted

func (x *HistoryEvent) GetExecutionStarted() *ExecutionStartedEvent

func (*HistoryEvent) GetExecutionSuspended

func (x *HistoryEvent) GetExecutionSuspended() *ExecutionSuspendedEvent

func (*HistoryEvent) GetExecutionTerminated

func (x *HistoryEvent) GetExecutionTerminated() *ExecutionTerminatedEvent

func (*HistoryEvent) GetOrchestratorCompleted deprecated

func (x *HistoryEvent) GetOrchestratorCompleted() *WorkflowCompletedEvent

Deprecated: Use GetWorkflowCompleted instead.

func (*HistoryEvent) GetOrchestratorStarted deprecated

func (x *HistoryEvent) GetOrchestratorStarted() *WorkflowStartedEvent

Deprecated: Use GetWorkflowStarted instead.

func (*HistoryEvent) GetRouter

func (x *HistoryEvent) GetRouter() *TaskRouter

func (*HistoryEvent) GetSubOrchestrationInstanceCompleted deprecated

func (x *HistoryEvent) GetSubOrchestrationInstanceCompleted() *ChildWorkflowInstanceCompletedEvent

Deprecated: Use GetChildWorkflowInstanceCompleted instead.

func (*HistoryEvent) GetSubOrchestrationInstanceCreated deprecated

func (x *HistoryEvent) GetSubOrchestrationInstanceCreated() *ChildWorkflowInstanceCreatedEvent

Deprecated: Use GetChildWorkflowInstanceCreated instead.

func (*HistoryEvent) GetSubOrchestrationInstanceFailed deprecated

func (x *HistoryEvent) GetSubOrchestrationInstanceFailed() *ChildWorkflowInstanceFailedEvent

Deprecated: Use GetChildWorkflowInstanceFailed instead.

func (*HistoryEvent) GetTaskCompleted

func (x *HistoryEvent) GetTaskCompleted() *TaskCompletedEvent

func (*HistoryEvent) GetTaskFailed

func (x *HistoryEvent) GetTaskFailed() *TaskFailedEvent

func (*HistoryEvent) GetTaskScheduled

func (x *HistoryEvent) GetTaskScheduled() *TaskScheduledEvent

func (*HistoryEvent) GetTimerCreated

func (x *HistoryEvent) GetTimerCreated() *TimerCreatedEvent

func (*HistoryEvent) GetTimerFired

func (x *HistoryEvent) GetTimerFired() *TimerFiredEvent

func (*HistoryEvent) GetTimestamp

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

func (*HistoryEvent) GetWorkflowCompleted

func (x *HistoryEvent) GetWorkflowCompleted() *WorkflowCompletedEvent

func (*HistoryEvent) GetWorkflowStarted

func (x *HistoryEvent) GetWorkflowStarted() *WorkflowStartedEvent

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_ChildWorkflowInstanceCompleted

type HistoryEvent_ChildWorkflowInstanceCompleted struct {
	ChildWorkflowInstanceCompleted *ChildWorkflowInstanceCompletedEvent `protobuf:"bytes,10,opt,name=childWorkflowInstanceCompleted,proto3,oneof"`
}

type HistoryEvent_ChildWorkflowInstanceCreated

type HistoryEvent_ChildWorkflowInstanceCreated struct {
	ChildWorkflowInstanceCreated *ChildWorkflowInstanceCreatedEvent `protobuf:"bytes,9,opt,name=childWorkflowInstanceCreated,proto3,oneof"`
}

type HistoryEvent_ChildWorkflowInstanceFailed

type HistoryEvent_ChildWorkflowInstanceFailed struct {
	ChildWorkflowInstanceFailed *ChildWorkflowInstanceFailedEvent `protobuf:"bytes,11,opt,name=childWorkflowInstanceFailed,proto3,oneof"`
}

type HistoryEvent_ContinueAsNew

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

type HistoryEvent_DetachedWorkflowInstanceCreated

type HistoryEvent_DetachedWorkflowInstanceCreated struct {
	DetachedWorkflowInstanceCreated *DetachedWorkflowInstanceCreatedEvent `protobuf:"bytes,32,opt,name=detachedWorkflowInstanceCreated,proto3,oneof"`
}

type HistoryEvent_EventRaised

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

type HistoryEvent_EventSent

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

type HistoryEvent_ExecutionCompleted

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

type HistoryEvent_ExecutionResumed

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

type HistoryEvent_ExecutionStalled

type HistoryEvent_ExecutionStalled struct {
	ExecutionStalled *ExecutionStalledEvent `protobuf:"bytes,31,opt,name=executionStalled,proto3,oneof"`
}

type HistoryEvent_ExecutionStarted

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

type HistoryEvent_ExecutionSuspended

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

type HistoryEvent_ExecutionTerminated

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

type HistoryEvent_OrchestratorCompleted deprecated

type HistoryEvent_OrchestratorCompleted = HistoryEvent_WorkflowCompleted

Deprecated: Use HistoryEvent_WorkflowCompleted instead.

type HistoryEvent_OrchestratorStarted deprecated

type HistoryEvent_OrchestratorStarted = HistoryEvent_WorkflowStarted

Deprecated: Use HistoryEvent_WorkflowStarted instead.

type HistoryEvent_SubOrchestrationInstanceCompleted deprecated

type HistoryEvent_SubOrchestrationInstanceCompleted = HistoryEvent_ChildWorkflowInstanceCompleted

Deprecated: Use HistoryEvent_ChildWorkflowInstanceCompleted instead.

type HistoryEvent_SubOrchestrationInstanceCreated deprecated

type HistoryEvent_SubOrchestrationInstanceCreated = HistoryEvent_ChildWorkflowInstanceCreated

Deprecated: Use HistoryEvent_ChildWorkflowInstanceCreated instead.

type HistoryEvent_SubOrchestrationInstanceFailed deprecated

type HistoryEvent_SubOrchestrationInstanceFailed = HistoryEvent_ChildWorkflowInstanceFailed

Deprecated: Use HistoryEvent_ChildWorkflowInstanceFailed instead.

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 HistoryEvent_WorkflowCompleted

type HistoryEvent_WorkflowCompleted struct {
	WorkflowCompleted *WorkflowCompletedEvent `protobuf:"bytes,15,opt,name=workflowCompleted,proto3,oneof"`
}

type HistoryEvent_WorkflowStarted

type HistoryEvent_WorkflowStarted struct {
	WorkflowStarted *WorkflowStartedEvent `protobuf:"bytes,14,opt,name=workflowStarted,proto3,oneof"`
}

type HistoryPropagationScope

type HistoryPropagationScope int32

HistoryPropagationScope controls how history is propagated to a child workflow or activity

const (
	// No propagation. This is the default for an unset/missing field; the
	// child receives no history from the caller.
	HistoryPropagationScope_HISTORY_PROPAGATION_SCOPE_NONE HistoryPropagationScope = 0
	// Propagate the caller's own history events only. The child does
	// not see any ancestral history (trust boundary).
	HistoryPropagationScope_HISTORY_PROPAGATION_SCOPE_OWN_HISTORY HistoryPropagationScope = 1
	// Propagate the caller's own history events AND the full ancestral
	// chain. Any propagated history this workflow received from its
	// parent is forwarded to the child.
	HistoryPropagationScope_HISTORY_PROPAGATION_SCOPE_LINEAGE HistoryPropagationScope = 2
)

func (HistoryPropagationScope) Descriptor

func (HistoryPropagationScope) Enum

func (HistoryPropagationScope) EnumDescriptor deprecated

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

Deprecated: Use HistoryPropagationScope.Descriptor instead.

func (HistoryPropagationScope) Number

func (HistoryPropagationScope) String

func (x HistoryPropagationScope) String() string

func (HistoryPropagationScope) Type

type ListInstanceIDsRequest

type ListInstanceIDsRequest struct {

	// continuationToken is the continuation token to use for pagination. This
	// is the token which the next page should start from. If not given, the
	// first page will be returned.
	ContinuationToken *string `protobuf:"bytes,1,opt,name=continuationToken,proto3,oneof" json:"continuationToken,omitempty"`
	// pageSize is the maximum number of instances to return for this page. If
	// not given, all instances will be attempted to be returned.
	PageSize *uint32 `protobuf:"varint,2,opt,name=pageSize,proto3,oneof" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

ListInstanceIDsRequest is used to list all workflow instances.

func (*ListInstanceIDsRequest) Descriptor deprecated

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

Deprecated: Use ListInstanceIDsRequest.ProtoReflect.Descriptor instead.

func (*ListInstanceIDsRequest) GetContinuationToken

func (x *ListInstanceIDsRequest) GetContinuationToken() string

func (*ListInstanceIDsRequest) GetPageSize

func (x *ListInstanceIDsRequest) GetPageSize() uint32

func (*ListInstanceIDsRequest) ProtoMessage

func (*ListInstanceIDsRequest) ProtoMessage()

func (*ListInstanceIDsRequest) ProtoReflect

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

func (*ListInstanceIDsRequest) Reset

func (x *ListInstanceIDsRequest) Reset()

func (*ListInstanceIDsRequest) String

func (x *ListInstanceIDsRequest) String() string

type ListInstanceIDsResponse

type ListInstanceIDsResponse struct {

	// instanceIds is the list of instance IDs returned.
	InstanceIds []string `protobuf:"bytes,1,rep,name=instanceIds,proto3" json:"instanceIds,omitempty"`
	// continuationToken is the continuation token to use for pagination. If
	// there are no more pages, this will be null.
	ContinuationToken *string `protobuf:"bytes,2,opt,name=continuationToken,proto3,oneof" json:"continuationToken,omitempty"`
	// contains filtered or unexported fields
}

ListInstanceIDsResponse is the response to executing ListInstanceIDs.

func (*ListInstanceIDsResponse) Descriptor deprecated

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

Deprecated: Use ListInstanceIDsResponse.ProtoReflect.Descriptor instead.

func (*ListInstanceIDsResponse) GetContinuationToken

func (x *ListInstanceIDsResponse) GetContinuationToken() string

func (*ListInstanceIDsResponse) GetInstanceIds

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

func (*ListInstanceIDsResponse) ProtoMessage

func (*ListInstanceIDsResponse) ProtoMessage()

func (*ListInstanceIDsResponse) ProtoReflect

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

func (*ListInstanceIDsResponse) Reset

func (x *ListInstanceIDsResponse) Reset()

func (*ListInstanceIDsResponse) String

func (x *ListInstanceIDsResponse) String() string

type OrchestrationInstance deprecated

type OrchestrationInstance = WorkflowInstance

Deprecated: Use WorkflowInstance instead.

type OrchestrationMetadata deprecated

type OrchestrationMetadata = WorkflowMetadata

Deprecated: Use WorkflowMetadata instead.

type OrchestrationRuntimeState deprecated

type OrchestrationRuntimeState = WorkflowRuntimeState

Deprecated: Use WorkflowRuntimeState instead.

type OrchestrationRuntimeStateMessage deprecated

type OrchestrationRuntimeStateMessage = WorkflowRuntimeStateMessage

Deprecated: Use WorkflowRuntimeStateMessage instead.

type OrchestrationState deprecated

type OrchestrationState = WorkflowState

Deprecated: Use WorkflowState instead.

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
	OrchestrationStatus_ORCHESTRATION_STATUS_STALLED          OrchestrationStatus = 8
)

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 deprecated

type OrchestratorAction = WorkflowAction

Deprecated: Use WorkflowAction instead.

type OrchestratorAction_CompleteOrchestration deprecated

type OrchestratorAction_CompleteOrchestration = WorkflowAction_CompleteWorkflow

Deprecated: Use WorkflowAction_CompleteWorkflow instead.

type OrchestratorAction_CreateSubOrchestration deprecated

type OrchestratorAction_CreateSubOrchestration = WorkflowAction_CreateChildWorkflow

Deprecated: Use WorkflowAction_CreateChildWorkflow instead.

type OrchestratorAction_CreateTimer deprecated

type OrchestratorAction_CreateTimer = WorkflowAction_CreateTimer

Deprecated: Use WorkflowAction_CreateTimer instead.

type OrchestratorAction_OrchestratorVersionNotAvailable deprecated

type OrchestratorAction_OrchestratorVersionNotAvailable = WorkflowAction_WorkflowVersionNotAvailable

Deprecated: Use WorkflowAction_WorkflowVersionNotAvailable instead.

type OrchestratorAction_ScheduleTask deprecated

type OrchestratorAction_ScheduleTask = WorkflowAction_ScheduleTask

Deprecated: Use WorkflowAction_ScheduleTask instead.

type OrchestratorAction_SendEvent deprecated

type OrchestratorAction_SendEvent = WorkflowAction_SendEvent

Deprecated: Use WorkflowAction_SendEvent instead.

type OrchestratorAction_TerminateOrchestration deprecated

type OrchestratorAction_TerminateOrchestration = WorkflowAction_TerminateWorkflow

Deprecated: Use WorkflowAction_TerminateWorkflow instead.

type OrchestratorCompletedEvent deprecated

type OrchestratorCompletedEvent = WorkflowCompletedEvent

Deprecated: Use WorkflowCompletedEvent instead.

type OrchestratorMessage deprecated

type OrchestratorMessage = WorkflowMessage

Deprecated: Use WorkflowMessage instead.

type OrchestratorRequest deprecated

type OrchestratorRequest = WorkflowRequest

Deprecated: Use WorkflowRequest instead.

type OrchestratorResponse deprecated

type OrchestratorResponse = WorkflowResponse

Deprecated: Use WorkflowResponse instead.

type OrchestratorStartedEvent deprecated

type OrchestratorStartedEvent = WorkflowStartedEvent

Deprecated: Use WorkflowStartedEvent instead.

type OrchestratorVersionNotAvailableAction deprecated

type OrchestratorVersionNotAvailableAction = WorkflowVersionNotAvailableAction

Deprecated: Use WorkflowVersionNotAvailableAction instead.

type ParentInstanceInfo

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

func (*ParentInstanceInfo) Descriptor deprecated

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

Deprecated: Use ParentInstanceInfo.ProtoReflect.Descriptor instead.

func (*ParentInstanceInfo) GetAppID

func (x *ParentInstanceInfo) GetAppID() string

func (*ParentInstanceInfo) GetAppNamespace

func (x *ParentInstanceInfo) GetAppNamespace() string

func (*ParentInstanceInfo) GetName

func (*ParentInstanceInfo) GetOrchestrationInstance deprecated

func (x *ParentInstanceInfo) GetOrchestrationInstance() *WorkflowInstance

Deprecated: Use GetWorkflowInstance instead.

func (*ParentInstanceInfo) GetTaskScheduledId

func (x *ParentInstanceInfo) GetTaskScheduledId() int32

func (*ParentInstanceInfo) GetVersion

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

func (*ParentInstanceInfo) GetWorkflowInstance

func (x *ParentInstanceInfo) GetWorkflowInstance() *WorkflowInstance

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 PropagatedHistory

type PropagatedHistory struct {

	// The propagation scope that was used to produce this history.
	Scope HistoryPropagationScope `protobuf:"varint,1,opt,name=scope,proto3,enum=HistoryPropagationScope" json:"scope,omitempty"`
	// Per-app history chunks. Each chunk owns the raw event bytes its producer
	// signed (PropagatedHistoryChunk.rawEvents); receivers digest those bytes
	// directly and decode them into typed HistoryEvents on demand. Chunks are
	// ordered, non-overlapping, and together describe the full propagated
	// event sequence.
	Chunks []*PropagatedHistoryChunk `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks,omitempty"`
	// contains filtered or unexported fields
}

func (*PropagatedHistory) Descriptor deprecated

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

Deprecated: Use PropagatedHistory.ProtoReflect.Descriptor instead.

func (*PropagatedHistory) GetChunks

func (x *PropagatedHistory) GetChunks() []*PropagatedHistoryChunk

func (*PropagatedHistory) GetScope

func (*PropagatedHistory) ProtoMessage

func (*PropagatedHistory) ProtoMessage()

func (*PropagatedHistory) ProtoReflect

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

func (*PropagatedHistory) Reset

func (x *PropagatedHistory) Reset()

func (*PropagatedHistory) String

func (x *PropagatedHistory) String() string

type PropagatedHistoryChunk

type PropagatedHistoryChunk struct {

	// Raw protobuf bytes of each HistoryEvent in this chunk, in execution order.
	RawEvents [][]byte `protobuf:"bytes,1,rep,name=rawEvents,proto3" json:"rawEvents,omitempty"`
	AppId     string   `protobuf:"bytes,2,opt,name=appId,proto3" json:"appId,omitempty"`
	// The workflow instance ID/name that produced the events in this chunk.
	InstanceId   string `protobuf:"bytes,3,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	WorkflowName string `protobuf:"bytes,4,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	// contains filtered or unexported fields
}

A self-contained range of events produced by a single app, used when history from multiple workflows is propagated to a downstream workflow or activity. Each chunk owns its raw event bytes, which receivers decode into typed HistoryEvents on demand.

func (*PropagatedHistoryChunk) Descriptor deprecated

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

Deprecated: Use PropagatedHistoryChunk.ProtoReflect.Descriptor instead.

func (*PropagatedHistoryChunk) GetAppId

func (x *PropagatedHistoryChunk) GetAppId() string

func (*PropagatedHistoryChunk) GetInstanceId

func (x *PropagatedHistoryChunk) GetInstanceId() string

func (*PropagatedHistoryChunk) GetRawEvents

func (x *PropagatedHistoryChunk) GetRawEvents() [][]byte

func (*PropagatedHistoryChunk) GetWorkflowName

func (x *PropagatedHistoryChunk) GetWorkflowName() string

func (*PropagatedHistoryChunk) ProtoMessage

func (*PropagatedHistoryChunk) ProtoMessage()

func (*PropagatedHistoryChunk) ProtoReflect

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

func (*PropagatedHistoryChunk) Reset

func (x *PropagatedHistoryChunk) Reset()

func (*PropagatedHistoryChunk) String

func (x *PropagatedHistoryChunk) String() string

type PurgeInstanceFilter

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

func (*PurgeInstanceFilter) Descriptor deprecated

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

Deprecated: Use PurgeInstanceFilter.ProtoReflect.Descriptor instead.

func (*PurgeInstanceFilter) GetCreatedTimeFrom

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

func (*PurgeInstanceFilter) GetCreatedTimeTo

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

func (*PurgeInstanceFilter) GetRuntimeStatus

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

func (*PurgeInstanceFilter) ProtoMessage

func (*PurgeInstanceFilter) ProtoMessage()

func (*PurgeInstanceFilter) ProtoReflect

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

func (*PurgeInstanceFilter) Reset

func (x *PurgeInstanceFilter) Reset()

func (*PurgeInstanceFilter) String

func (x *PurgeInstanceFilter) String() string

type PurgeInstancesRequest

type PurgeInstancesRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*PurgeInstancesRequest_InstanceId
	//	*PurgeInstancesRequest_PurgeInstanceFilter
	Request   isPurgeInstancesRequest_Request `protobuf_oneof:"request"`
	Recursive bool                            `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// force will force a purge of a workflow, regardless of its current
	// runtime state, or whether an active worker can process it, the backend
	// will attempt to delete it anyway. This neccessarily means the purging is
	// executed out side of the workflow state machine, and therefore, can lead
	// to corrupt state or broken workflow execution. Usage of this should
	// _only_ be used when the client knows the workflow is not being currently
	// processed. It is highly recommended to avoid using this flag unless
	// absolutely necessary.
	// Defaults to false.
	Force *bool `protobuf:"varint,4,opt,name=force,proto3,oneof" json:"force,omitempty"`
	// router optionally routes this operation to the workflow instance owned
	// by another app. Cross-app purges are delegated to the target app in
	// full, so they are always recursive on the remote side. sourceAppID is
	// stamped by the sidecar, not the client.
	Router *TaskRouter `protobuf:"bytes,5,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeInstancesRequest) Descriptor deprecated

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

Deprecated: Use PurgeInstancesRequest.ProtoReflect.Descriptor instead.

func (*PurgeInstancesRequest) GetForce

func (x *PurgeInstancesRequest) GetForce() bool

func (*PurgeInstancesRequest) GetInstanceId

func (x *PurgeInstancesRequest) GetInstanceId() string

func (*PurgeInstancesRequest) GetPurgeInstanceFilter

func (x *PurgeInstancesRequest) GetPurgeInstanceFilter() *PurgeInstanceFilter

func (*PurgeInstancesRequest) GetRecursive

func (x *PurgeInstancesRequest) GetRecursive() bool

func (*PurgeInstancesRequest) GetRequest

func (x *PurgeInstancesRequest) GetRequest() isPurgeInstancesRequest_Request

func (*PurgeInstancesRequest) GetRouter

func (x *PurgeInstancesRequest) GetRouter() *TaskRouter

func (*PurgeInstancesRequest) ProtoMessage

func (*PurgeInstancesRequest) ProtoMessage()

func (*PurgeInstancesRequest) ProtoReflect

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

func (*PurgeInstancesRequest) Reset

func (x *PurgeInstancesRequest) Reset()

func (*PurgeInstancesRequest) String

func (x *PurgeInstancesRequest) String() string

type PurgeInstancesRequest_InstanceId

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

type PurgeInstancesRequest_PurgeInstanceFilter

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

type PurgeInstancesResponse

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

func (*PurgeInstancesResponse) Descriptor deprecated

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

Deprecated: Use PurgeInstancesResponse.ProtoReflect.Descriptor instead.

func (*PurgeInstancesResponse) GetDeletedInstanceCount

func (x *PurgeInstancesResponse) GetDeletedInstanceCount() int32

func (*PurgeInstancesResponse) GetIsComplete

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

func (*PurgeInstancesResponse) ProtoMessage

func (*PurgeInstancesResponse) ProtoMessage()

func (*PurgeInstancesResponse) ProtoReflect

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

func (*PurgeInstancesResponse) Reset

func (x *PurgeInstancesResponse) Reset()

func (*PurgeInstancesResponse) String

func (x *PurgeInstancesResponse) String() string

type RaiseEventRequest

type RaiseEventRequest struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name       string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Input      *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	// router optionally routes this operation to the workflow instance owned
	// by another app. sourceAppID is stamped by the sidecar, not the client.
	Router *TaskRouter `protobuf:"bytes,4,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// externalDeliveryId identifies an at-least-once delivery from an external
	// publisher. Backends that support it durably accept a repeated value for
	// the same instance and event name without appending another event.
	ExternalDeliveryId *string `protobuf:"bytes,5,opt,name=externalDeliveryId,proto3,oneof" json:"externalDeliveryId,omitempty"`
	// contains filtered or unexported fields
}

func (*RaiseEventRequest) Descriptor deprecated

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

Deprecated: Use RaiseEventRequest.ProtoReflect.Descriptor instead.

func (*RaiseEventRequest) GetExternalDeliveryId added in v1.1.0

func (x *RaiseEventRequest) GetExternalDeliveryId() string

func (*RaiseEventRequest) GetInput

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

func (*RaiseEventRequest) GetInstanceId

func (x *RaiseEventRequest) GetInstanceId() string

func (*RaiseEventRequest) GetName

func (x *RaiseEventRequest) GetName() string

func (*RaiseEventRequest) GetRouter

func (x *RaiseEventRequest) GetRouter() *TaskRouter

func (*RaiseEventRequest) ProtoMessage

func (*RaiseEventRequest) ProtoMessage()

func (*RaiseEventRequest) ProtoReflect

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

func (*RaiseEventRequest) Reset

func (x *RaiseEventRequest) Reset()

func (*RaiseEventRequest) String

func (x *RaiseEventRequest) String() string

type RaiseEventResponse

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

func (*RaiseEventResponse) Descriptor deprecated

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

Deprecated: Use RaiseEventResponse.ProtoReflect.Descriptor instead.

func (*RaiseEventResponse) ProtoMessage

func (*RaiseEventResponse) ProtoMessage()

func (*RaiseEventResponse) ProtoReflect

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

func (*RaiseEventResponse) Reset

func (x *RaiseEventResponse) Reset()

func (*RaiseEventResponse) String

func (x *RaiseEventResponse) String() string

type ResumeRequest

type ResumeRequest struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Reason     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// router optionally routes this operation to the workflow instance owned
	// by another app. sourceAppID is stamped by the sidecar, not the client.
	Router *TaskRouter `protobuf:"bytes,3,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeRequest) Descriptor deprecated

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

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetInstanceId

func (x *ResumeRequest) GetInstanceId() string

func (*ResumeRequest) GetReason

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

func (*ResumeRequest) GetRouter

func (x *ResumeRequest) GetRouter() *TaskRouter

func (*ResumeRequest) ProtoMessage

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect

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

func (*ResumeRequest) Reset

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String

func (x *ResumeRequest) String() string

type ResumeResponse

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

func (*ResumeResponse) Descriptor deprecated

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

Deprecated: Use ResumeResponse.ProtoReflect.Descriptor instead.

func (*ResumeResponse) ProtoMessage

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) ProtoReflect

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

func (*ResumeResponse) Reset

func (x *ResumeResponse) Reset()

func (*ResumeResponse) String

func (x *ResumeResponse) String() string

type RetryParentInstanceInfo

type RetryParentInstanceInfo struct {

	// instanceID is the instance ID of the first attempt in this child-workflow
	// retry chain.
	InstanceID string `protobuf:"bytes,1,opt,name=instanceID,proto3" json:"instanceID,omitempty"`
	// contains filtered or unexported fields
}

RetryParentInstanceInfo correlates a child-workflow retry attempt with the initial attempt that spawned it. When a child workflow is scheduled with a retry policy, each retry executes as a separate child workflow instance with its own auto-generated instance ID. This message provides an explicit, first-class link back to the first attempt so consumers no longer need to reconstruct the relationship from event ordering and timer origins.

Semantics: the first attempt carries no RetryParentInstanceInfo. Retry attempts (2nd onward) carry RetryParentInstanceInfo with instanceID set to the first attempt's instance ID. Consumers group attempts by reading the parent workflow's history; the group key is retryParentInstanceInfo.instanceID when present, otherwise the event's own instanceId.

func (*RetryParentInstanceInfo) Descriptor deprecated

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

Deprecated: Use RetryParentInstanceInfo.ProtoReflect.Descriptor instead.

func (*RetryParentInstanceInfo) GetInstanceID

func (x *RetryParentInstanceInfo) GetInstanceID() string

func (*RetryParentInstanceInfo) ProtoMessage

func (*RetryParentInstanceInfo) ProtoMessage()

func (*RetryParentInstanceInfo) ProtoReflect

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

func (*RetryParentInstanceInfo) Reset

func (x *RetryParentInstanceInfo) Reset()

func (*RetryParentInstanceInfo) String

func (x *RetryParentInstanceInfo) String() string

type RuntimeStateStalled

type RuntimeStateStalled struct {
	Reason      StalledReason `protobuf:"varint,1,opt,name=reason,proto3,enum=StalledReason" json:"reason,omitempty"`
	Description *string       `protobuf:"bytes,2,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeStateStalled) Descriptor deprecated

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

Deprecated: Use RuntimeStateStalled.ProtoReflect.Descriptor instead.

func (*RuntimeStateStalled) GetDescription

func (x *RuntimeStateStalled) GetDescription() string

func (*RuntimeStateStalled) GetReason

func (x *RuntimeStateStalled) GetReason() StalledReason

func (*RuntimeStateStalled) ProtoMessage

func (*RuntimeStateStalled) ProtoMessage()

func (*RuntimeStateStalled) ProtoReflect

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

func (*RuntimeStateStalled) Reset

func (x *RuntimeStateStalled) Reset()

func (*RuntimeStateStalled) String

func (x *RuntimeStateStalled) String() string

type ScheduleTaskAction

type ScheduleTaskAction struct {
	Name            string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version         *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input           *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	TaskExecutionId string                  `protobuf:"bytes,5,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
	// History propagation scope. Absent/SCOPE_NONE = no propagation.
	HistoryPropagationScope *HistoryPropagationScope `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ScheduleTaskAction) Descriptor deprecated

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

Deprecated: Use ScheduleTaskAction.ProtoReflect.Descriptor instead.

func (*ScheduleTaskAction) GetHistoryPropagationScope

func (x *ScheduleTaskAction) GetHistoryPropagationScope() HistoryPropagationScope

func (*ScheduleTaskAction) GetInput

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

func (*ScheduleTaskAction) GetName

func (x *ScheduleTaskAction) GetName() string

func (*ScheduleTaskAction) GetTaskExecutionId

func (x *ScheduleTaskAction) GetTaskExecutionId() string

func (*ScheduleTaskAction) GetVersion

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

func (*ScheduleTaskAction) ProtoMessage

func (*ScheduleTaskAction) ProtoMessage()

func (*ScheduleTaskAction) ProtoReflect

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

func (*ScheduleTaskAction) Reset

func (x *ScheduleTaskAction) Reset()

func (*ScheduleTaskAction) String

func (x *ScheduleTaskAction) String() string

type SendEventAction

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

func (*SendEventAction) Descriptor deprecated

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

Deprecated: Use SendEventAction.ProtoReflect.Descriptor instead.

func (*SendEventAction) GetData

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

func (*SendEventAction) GetInstance

func (x *SendEventAction) GetInstance() *WorkflowInstance

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 StalledReason

type StalledReason int32
const (
	StalledReason_PATCH_MISMATCH        StalledReason = 0
	StalledReason_VERSION_NOT_AVAILABLE StalledReason = 1
	StalledReason_PAYLOAD_SIZE_EXCEEDED StalledReason = 2
)

func (StalledReason) Descriptor

func (StalledReason) Enum

func (x StalledReason) Enum() *StalledReason

func (StalledReason) EnumDescriptor deprecated

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

Deprecated: Use StalledReason.Descriptor instead.

func (StalledReason) Number

func (StalledReason) String

func (x StalledReason) String() string

func (StalledReason) Type

type SubOrchestrationInstanceCompletedEvent deprecated

type SubOrchestrationInstanceCompletedEvent = ChildWorkflowInstanceCompletedEvent

Deprecated: Use ChildWorkflowInstanceCompletedEvent instead.

type SubOrchestrationInstanceCreatedEvent deprecated

type SubOrchestrationInstanceCreatedEvent = ChildWorkflowInstanceCreatedEvent

Deprecated: Use ChildWorkflowInstanceCreatedEvent instead.

type SubOrchestrationInstanceFailedEvent deprecated

type SubOrchestrationInstanceFailedEvent = ChildWorkflowInstanceFailedEvent

Deprecated: Use ChildWorkflowInstanceFailedEvent instead.

type SuspendRequest

type SuspendRequest struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Reason     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// router optionally routes this operation to the workflow instance owned
	// by another app. sourceAppID is stamped by the sidecar, not the client.
	Router *TaskRouter `protobuf:"bytes,3,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*SuspendRequest) Descriptor deprecated

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

Deprecated: Use SuspendRequest.ProtoReflect.Descriptor instead.

func (*SuspendRequest) GetInstanceId

func (x *SuspendRequest) GetInstanceId() string

func (*SuspendRequest) GetReason

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

func (*SuspendRequest) GetRouter

func (x *SuspendRequest) GetRouter() *TaskRouter

func (*SuspendRequest) ProtoMessage

func (*SuspendRequest) ProtoMessage()

func (*SuspendRequest) ProtoReflect

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

func (*SuspendRequest) Reset

func (x *SuspendRequest) Reset()

func (*SuspendRequest) String

func (x *SuspendRequest) String() string

type SuspendResponse

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

func (*SuspendResponse) Descriptor deprecated

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

Deprecated: Use SuspendResponse.ProtoReflect.Descriptor instead.

func (*SuspendResponse) ProtoMessage

func (*SuspendResponse) ProtoMessage()

func (*SuspendResponse) ProtoReflect

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

func (*SuspendResponse) Reset

func (x *SuspendResponse) Reset()

func (*SuspendResponse) String

func (x *SuspendResponse) String() string

type TaskCompletedEvent

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

func (*TaskCompletedEvent) Descriptor deprecated

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

Deprecated: Use TaskCompletedEvent.ProtoReflect.Descriptor instead.

func (*TaskCompletedEvent) GetResult

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

func (*TaskCompletedEvent) GetTaskExecutionId

func (x *TaskCompletedEvent) GetTaskExecutionId() string

func (*TaskCompletedEvent) GetTaskScheduledId

func (x *TaskCompletedEvent) GetTaskScheduledId() int32

func (*TaskCompletedEvent) ProtoMessage

func (*TaskCompletedEvent) ProtoMessage()

func (*TaskCompletedEvent) ProtoReflect

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

func (*TaskCompletedEvent) Reset

func (x *TaskCompletedEvent) Reset()

func (*TaskCompletedEvent) String

func (x *TaskCompletedEvent) String() string

type TaskFailedEvent

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

func (*TaskFailedEvent) Descriptor deprecated

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

Deprecated: Use TaskFailedEvent.ProtoReflect.Descriptor instead.

func (*TaskFailedEvent) GetFailureDetails

func (x *TaskFailedEvent) GetFailureDetails() *TaskFailureDetails

func (*TaskFailedEvent) GetTaskExecutionId

func (x *TaskFailedEvent) GetTaskExecutionId() string

func (*TaskFailedEvent) GetTaskScheduledId

func (x *TaskFailedEvent) GetTaskScheduledId() int32

func (*TaskFailedEvent) ProtoMessage

func (*TaskFailedEvent) ProtoMessage()

func (*TaskFailedEvent) ProtoReflect

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

func (*TaskFailedEvent) Reset

func (x *TaskFailedEvent) Reset()

func (*TaskFailedEvent) String

func (x *TaskFailedEvent) String() string

type TaskFailureDetails

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

func (*TaskFailureDetails) Descriptor deprecated

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

Deprecated: Use TaskFailureDetails.ProtoReflect.Descriptor instead.

func (*TaskFailureDetails) GetErrorMessage

func (x *TaskFailureDetails) GetErrorMessage() string

func (*TaskFailureDetails) GetErrorType

func (x *TaskFailureDetails) GetErrorType() string

func (*TaskFailureDetails) GetInnerFailure

func (x *TaskFailureDetails) GetInnerFailure() *TaskFailureDetails

func (*TaskFailureDetails) GetIsNonRetriable

func (x *TaskFailureDetails) GetIsNonRetriable() bool

func (*TaskFailureDetails) GetStackTrace

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

func (*TaskFailureDetails) ProtoMessage

func (*TaskFailureDetails) ProtoMessage()

func (*TaskFailureDetails) ProtoReflect

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

func (*TaskFailureDetails) Reset

func (x *TaskFailureDetails) Reset()

func (*TaskFailureDetails) String

func (x *TaskFailureDetails) String() string

type TaskHubSidecarServiceClient

type TaskHubSidecarServiceClient interface {
	// Sends a hello request to the sidecar service.
	Hello(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Starts a new workflow instance.
	StartInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// Gets the status of an existing workflow instance.
	GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Waits for a workflow instance to reach a running or completion state.
	WaitForInstanceStart(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*GetInstanceResponse, error)
	// Waits for a workflow 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 workflow instance.
	RaiseEvent(ctx context.Context, in *RaiseEventRequest, opts ...grpc.CallOption) (*RaiseEventResponse, error)
	// Terminates a running workflow instance.
	TerminateInstance(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
	// Suspends a running workflow instance.
	SuspendInstance(ctx context.Context, in *SuspendRequest, opts ...grpc.CallOption) (*SuspendResponse, error)
	// Resumes a suspended workflow instance.
	ResumeInstance(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*ResumeResponse, error)
	PurgeInstances(ctx context.Context, in *PurgeInstancesRequest, opts ...grpc.CallOption) (*PurgeInstancesResponse, error)
	GetWorkItems(ctx context.Context, in *GetWorkItemsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[WorkItem], error)
	CompleteActivityTask(ctx context.Context, in *ActivityResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	// Deprecated: Do not use.
	// Deprecated: Use CompleteWorkflowTask instead.
	CompleteOrchestratorTask(ctx context.Context, in *WorkflowResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	// Completes a workflow work item.
	CompleteWorkflowTask(ctx context.Context, in *WorkflowResponse, opts ...grpc.CallOption) (*CompleteTaskResponse, error)
	ListInstanceIDs(ctx context.Context, in *ListInstanceIDsRequest, opts ...grpc.CallOption) (*ListInstanceIDsResponse, error)
	GetInstanceHistory(ctx context.Context, in *GetInstanceHistoryRequest, opts ...grpc.CallOption) (*GetInstanceHistoryResponse, 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, *emptypb.Empty) (*emptypb.Empty, error)
	// Starts a new workflow instance.
	StartInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// Gets the status of an existing workflow instance.
	GetInstance(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Waits for a workflow instance to reach a running or completion state.
	WaitForInstanceStart(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Waits for a workflow instance to reach a completion state (completed, failed, terminated, etc.).
	WaitForInstanceCompletion(context.Context, *GetInstanceRequest) (*GetInstanceResponse, error)
	// Raises an event to a running workflow instance.
	RaiseEvent(context.Context, *RaiseEventRequest) (*RaiseEventResponse, error)
	// Terminates a running workflow instance.
	TerminateInstance(context.Context, *TerminateRequest) (*TerminateResponse, error)
	// Suspends a running workflow instance.
	SuspendInstance(context.Context, *SuspendRequest) (*SuspendResponse, error)
	// Resumes a suspended workflow instance.
	ResumeInstance(context.Context, *ResumeRequest) (*ResumeResponse, error)
	PurgeInstances(context.Context, *PurgeInstancesRequest) (*PurgeInstancesResponse, error)
	GetWorkItems(*GetWorkItemsRequest, grpc.ServerStreamingServer[WorkItem]) error
	CompleteActivityTask(context.Context, *ActivityResponse) (*CompleteTaskResponse, error)
	// Deprecated: Do not use.
	// Deprecated: Use CompleteWorkflowTask instead.
	CompleteOrchestratorTask(context.Context, *WorkflowResponse) (*CompleteTaskResponse, error)
	// Completes a workflow work item.
	CompleteWorkflowTask(context.Context, *WorkflowResponse) (*CompleteTaskResponse, error)
	ListInstanceIDs(context.Context, *ListInstanceIDsRequest) (*ListInstanceIDsResponse, error)
	GetInstanceHistory(context.Context, *GetInstanceHistoryRequest) (*GetInstanceHistoryResponse, error)
	// contains filtered or unexported methods
}

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

type TaskHubSidecarService_GetWorkItemsClient

type TaskHubSidecarService_GetWorkItemsClient = grpc.ServerStreamingClient[WorkItem]

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

type TaskHubSidecarService_GetWorkItemsServer

type TaskHubSidecarService_GetWorkItemsServer = grpc.ServerStreamingServer[WorkItem]

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

type TaskRouter

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

func (*TaskRouter) Descriptor deprecated

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

Deprecated: Use TaskRouter.ProtoReflect.Descriptor instead.

func (*TaskRouter) GetSourceAppID

func (x *TaskRouter) GetSourceAppID() string

func (*TaskRouter) GetTargetAppID

func (x *TaskRouter) GetTargetAppID() string

func (*TaskRouter) GetTargetAppNamespace

func (x *TaskRouter) GetTargetAppNamespace() string

func (*TaskRouter) ProtoMessage

func (*TaskRouter) ProtoMessage()

func (*TaskRouter) ProtoReflect

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

func (*TaskRouter) Reset

func (x *TaskRouter) Reset()

func (*TaskRouter) String

func (x *TaskRouter) String() string

type TaskScheduledEvent

type TaskScheduledEvent struct {
	Name               string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version            *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	ParentTraceContext *TraceContext           `protobuf:"bytes,4,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	TaskExecutionId    string                  `protobuf:"bytes,5,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
	// History propagation scope used when this task was originally scheduled.
	// Persisted on the event so rerun can re-issue the task with the same
	// scope after the action has been discarded.
	HistoryPropagationScope *HistoryPropagationScope `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskScheduledEvent) Descriptor deprecated

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

Deprecated: Use TaskScheduledEvent.ProtoReflect.Descriptor instead.

func (*TaskScheduledEvent) GetHistoryPropagationScope

func (x *TaskScheduledEvent) GetHistoryPropagationScope() HistoryPropagationScope

func (*TaskScheduledEvent) GetInput

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

func (*TaskScheduledEvent) GetName

func (x *TaskScheduledEvent) GetName() string

func (*TaskScheduledEvent) GetParentTraceContext

func (x *TaskScheduledEvent) GetParentTraceContext() *TraceContext

func (*TaskScheduledEvent) GetTaskExecutionId

func (x *TaskScheduledEvent) GetTaskExecutionId() string

func (*TaskScheduledEvent) GetVersion

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

func (*TaskScheduledEvent) ProtoMessage

func (*TaskScheduledEvent) ProtoMessage()

func (*TaskScheduledEvent) ProtoReflect

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

func (*TaskScheduledEvent) Reset

func (x *TaskScheduledEvent) Reset()

func (*TaskScheduledEvent) String

func (x *TaskScheduledEvent) String() string

type TerminateOrchestrationAction deprecated

type TerminateOrchestrationAction = TerminateWorkflowAction

Deprecated: Use TerminateWorkflowAction instead.

type TerminateRequest

type TerminateRequest struct {
	InstanceId string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Output     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	Recursive  bool                    `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// router optionally routes this operation to the workflow instance owned
	// by another app. sourceAppID is stamped by the sidecar, not the client.
	Router *TaskRouter `protobuf:"bytes,4,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateRequest) Descriptor deprecated

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

Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.

func (*TerminateRequest) GetInstanceId

func (x *TerminateRequest) GetInstanceId() string

func (*TerminateRequest) GetOutput

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

func (*TerminateRequest) GetRecursive

func (x *TerminateRequest) GetRecursive() bool

func (*TerminateRequest) GetRouter

func (x *TerminateRequest) GetRouter() *TaskRouter

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 TerminateWorkflowAction

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

func (*TerminateWorkflowAction) Descriptor deprecated

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

Deprecated: Use TerminateWorkflowAction.ProtoReflect.Descriptor instead.

func (*TerminateWorkflowAction) GetInstanceId

func (x *TerminateWorkflowAction) GetInstanceId() string

func (*TerminateWorkflowAction) GetReason

func (*TerminateWorkflowAction) GetRecurse

func (x *TerminateWorkflowAction) GetRecurse() bool

func (*TerminateWorkflowAction) ProtoMessage

func (*TerminateWorkflowAction) ProtoMessage()

func (*TerminateWorkflowAction) ProtoReflect

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

func (*TerminateWorkflowAction) Reset

func (x *TerminateWorkflowAction) Reset()

func (*TerminateWorkflowAction) String

func (x *TerminateWorkflowAction) String() string

type TimerCreatedEvent

type TimerCreatedEvent struct {
	FireAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fireAt,proto3" json:"fireAt,omitempty"`
	Name   *string                `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// If set, provides additional context attached to this timer.
	//
	// Types that are assignable to Origin:
	//
	//	*TimerCreatedEvent_CreateTimer
	//	*TimerCreatedEvent_ExternalEvent
	//	*TimerCreatedEvent_ActivityRetry
	//	*TimerCreatedEvent_ChildWorkflowRetry
	Origin isTimerCreatedEvent_Origin `protobuf_oneof:"origin"`
	// contains filtered or unexported fields
}

func (*TimerCreatedEvent) Descriptor deprecated

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

Deprecated: Use TimerCreatedEvent.ProtoReflect.Descriptor instead.

func (*TimerCreatedEvent) GetActivityRetry

func (x *TimerCreatedEvent) GetActivityRetry() *TimerOriginActivityRetry

func (*TimerCreatedEvent) GetChildWorkflowRetry

func (x *TimerCreatedEvent) GetChildWorkflowRetry() *TimerOriginChildWorkflowRetry

func (*TimerCreatedEvent) GetCreateTimer

func (x *TimerCreatedEvent) GetCreateTimer() *TimerOriginCreateTimer

func (*TimerCreatedEvent) GetExternalEvent

func (x *TimerCreatedEvent) GetExternalEvent() *TimerOriginExternalEvent

func (*TimerCreatedEvent) GetFireAt

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

func (*TimerCreatedEvent) GetName

func (x *TimerCreatedEvent) GetName() string

func (*TimerCreatedEvent) GetOrigin

func (m *TimerCreatedEvent) GetOrigin() isTimerCreatedEvent_Origin

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 TimerCreatedEvent_ActivityRetry

type TimerCreatedEvent_ActivityRetry struct {
	ActivityRetry *TimerOriginActivityRetry `protobuf:"bytes,6,opt,name=activityRetry,proto3,oneof"`
}

type TimerCreatedEvent_ChildWorkflowRetry

type TimerCreatedEvent_ChildWorkflowRetry struct {
	ChildWorkflowRetry *TimerOriginChildWorkflowRetry `protobuf:"bytes,7,opt,name=childWorkflowRetry,proto3,oneof"`
}

type TimerCreatedEvent_CreateTimer

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

type TimerCreatedEvent_ExternalEvent

type TimerCreatedEvent_ExternalEvent struct {
	ExternalEvent *TimerOriginExternalEvent `protobuf:"bytes,5,opt,name=externalEvent,proto3,oneof"`
}

type TimerFiredEvent

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

func (*TimerFiredEvent) Descriptor deprecated

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

Deprecated: Use TimerFiredEvent.ProtoReflect.Descriptor instead.

func (*TimerFiredEvent) GetFireAt

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

func (*TimerFiredEvent) GetTimerId

func (x *TimerFiredEvent) GetTimerId() int32

func (*TimerFiredEvent) ProtoMessage

func (*TimerFiredEvent) ProtoMessage()

func (*TimerFiredEvent) ProtoReflect

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

func (*TimerFiredEvent) Reset

func (x *TimerFiredEvent) Reset()

func (*TimerFiredEvent) String

func (x *TimerFiredEvent) String() string

type TimerOriginActivityRetry

type TimerOriginActivityRetry struct {

	// The task execution ID of the activity being retried.
	TaskExecutionId string `protobuf:"bytes,1,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
	// contains filtered or unexported fields
}

Indicates the timer was created as a retry delay for an activity execution.

func (*TimerOriginActivityRetry) Descriptor deprecated

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

Deprecated: Use TimerOriginActivityRetry.ProtoReflect.Descriptor instead.

func (*TimerOriginActivityRetry) GetTaskExecutionId

func (x *TimerOriginActivityRetry) GetTaskExecutionId() string

func (*TimerOriginActivityRetry) ProtoMessage

func (*TimerOriginActivityRetry) ProtoMessage()

func (*TimerOriginActivityRetry) ProtoReflect

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

func (*TimerOriginActivityRetry) Reset

func (x *TimerOriginActivityRetry) Reset()

func (*TimerOriginActivityRetry) String

func (x *TimerOriginActivityRetry) String() string

type TimerOriginChildWorkflowRetry

type TimerOriginChildWorkflowRetry struct {

	// The instance ID of the workflow being retried.
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// contains filtered or unexported fields
}

Indicates the timer was created as a retry delay for a child workflow execution.

func (*TimerOriginChildWorkflowRetry) Descriptor deprecated

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

Deprecated: Use TimerOriginChildWorkflowRetry.ProtoReflect.Descriptor instead.

func (*TimerOriginChildWorkflowRetry) GetInstanceId

func (x *TimerOriginChildWorkflowRetry) GetInstanceId() string

func (*TimerOriginChildWorkflowRetry) ProtoMessage

func (*TimerOriginChildWorkflowRetry) ProtoMessage()

func (*TimerOriginChildWorkflowRetry) ProtoReflect

func (*TimerOriginChildWorkflowRetry) Reset

func (x *TimerOriginChildWorkflowRetry) Reset()

func (*TimerOriginChildWorkflowRetry) String

type TimerOriginCreateTimer

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

Indicates the timer was created by a createTimer call with no special origin.

func (*TimerOriginCreateTimer) Descriptor deprecated

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

Deprecated: Use TimerOriginCreateTimer.ProtoReflect.Descriptor instead.

func (*TimerOriginCreateTimer) ProtoMessage

func (*TimerOriginCreateTimer) ProtoMessage()

func (*TimerOriginCreateTimer) ProtoReflect

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

func (*TimerOriginCreateTimer) Reset

func (x *TimerOriginCreateTimer) Reset()

func (*TimerOriginCreateTimer) String

func (x *TimerOriginCreateTimer) String() string

type TimerOriginExternalEvent

type TimerOriginExternalEvent struct {

	// The name of the external event being waited on, matching EventRaisedEvent.name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Indicates the timer was created as a timeout for a waitForExternalEvent call.

func (*TimerOriginExternalEvent) Descriptor deprecated

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

Deprecated: Use TimerOriginExternalEvent.ProtoReflect.Descriptor instead.

func (*TimerOriginExternalEvent) GetName

func (x *TimerOriginExternalEvent) GetName() string

func (*TimerOriginExternalEvent) ProtoMessage

func (*TimerOriginExternalEvent) ProtoMessage()

func (*TimerOriginExternalEvent) ProtoReflect

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

func (*TimerOriginExternalEvent) Reset

func (x *TimerOriginExternalEvent) Reset()

func (*TimerOriginExternalEvent) String

func (x *TimerOriginExternalEvent) String() string

type TraceContext

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

func (*TraceContext) Descriptor deprecated

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

Deprecated: Use TraceContext.ProtoReflect.Descriptor instead.

func (*TraceContext) GetSpanID deprecated

func (x *TraceContext) GetSpanID() string

Deprecated: Marked as deprecated in orchestration.proto.

func (*TraceContext) GetTraceParent

func (x *TraceContext) GetTraceParent() string

func (*TraceContext) GetTraceState

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

func (*TraceContext) ProtoMessage

func (*TraceContext) ProtoMessage()

func (*TraceContext) ProtoReflect

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

func (*TraceContext) Reset

func (x *TraceContext) Reset()

func (*TraceContext) String

func (x *TraceContext) String() string

type UnimplementedTaskHubSidecarServiceServer

type UnimplementedTaskHubSidecarServiceServer struct{}

UnimplementedTaskHubSidecarServiceServer must be embedded to have forward compatible implementations.

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

func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask

func (UnimplementedTaskHubSidecarServiceServer) CompleteOrchestratorTask

func (UnimplementedTaskHubSidecarServiceServer) CompleteWorkflowTask

func (UnimplementedTaskHubSidecarServiceServer) GetInstance

func (UnimplementedTaskHubSidecarServiceServer) GetInstanceHistory

func (UnimplementedTaskHubSidecarServiceServer) GetWorkItems

func (UnimplementedTaskHubSidecarServiceServer) Hello

func (UnimplementedTaskHubSidecarServiceServer) ListInstanceIDs

func (UnimplementedTaskHubSidecarServiceServer) PurgeInstances

func (UnimplementedTaskHubSidecarServiceServer) RaiseEvent

func (UnimplementedTaskHubSidecarServiceServer) ResumeInstance

func (UnimplementedTaskHubSidecarServiceServer) StartInstance

func (UnimplementedTaskHubSidecarServiceServer) SuspendInstance

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 valid to be assigned to Request:
	//
	//	*WorkItem_WorkflowRequest
	//	*WorkItem_ActivityRequest
	Request         isWorkItem_Request `protobuf_oneof:"request"`
	CompletionToken string             `protobuf:"bytes,10,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkItem) Descriptor deprecated

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

Deprecated: Use WorkItem.ProtoReflect.Descriptor instead.

func (*WorkItem) GetActivityRequest

func (x *WorkItem) GetActivityRequest() *ActivityRequest

func (*WorkItem) GetCompletionToken

func (x *WorkItem) GetCompletionToken() string

func (*WorkItem) GetOrchestratorRequest deprecated

func (x *WorkItem) GetOrchestratorRequest() *WorkflowRequest

Deprecated: Use GetWorkflowRequest instead.

func (*WorkItem) GetRequest

func (x *WorkItem) GetRequest() isWorkItem_Request

func (*WorkItem) GetWorkflowRequest

func (x *WorkItem) GetWorkflowRequest() *WorkflowRequest

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_OrchestratorRequest deprecated

type WorkItem_OrchestratorRequest = WorkItem_WorkflowRequest

Deprecated: Use WorkItem_WorkflowRequest instead.

type WorkItem_WorkflowRequest

type WorkItem_WorkflowRequest struct {
	WorkflowRequest *WorkflowRequest `protobuf:"bytes,1,opt,name=workflowRequest,proto3,oneof"`
}

type WorkerCapability

type WorkerCapability int32
const (
	WorkerCapability_WORKER_CAPABILITY_UNSPECIFIED WorkerCapability = 0
	// Indicates that the worker retains an instance's accumulated history in
	// memory between workflow turns on the same work-item stream, so that the
	// service can send only the new events (the delta) instead of the full
	// history each turn. When the service has dispatched a turn for an
	// instance to this stream and believes the stream is still warm for it, it
	// may set WorkflowRequest.cachedHistory and drop the committed-history
	// prefix the worker already holds from pastEvents, leaving only the delta
	// there. On a cache miss the worker recovers the full history via the
	// GetInstanceHistory RPC, so the optimization never affects correctness.
	WorkerCapability_WORKER_CAPABILITY_STATEFUL_HISTORY WorkerCapability = 2
)

func (WorkerCapability) Descriptor

func (WorkerCapability) Enum

func (WorkerCapability) EnumDescriptor deprecated

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

Deprecated: Use WorkerCapability.Descriptor instead.

func (WorkerCapability) Number

func (WorkerCapability) String

func (x WorkerCapability) String() string

func (WorkerCapability) Type

type WorkflowAction

type WorkflowAction struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to WorkflowActionType:
	//
	//	*WorkflowAction_ScheduleTask
	//	*WorkflowAction_CreateChildWorkflow
	//	*WorkflowAction_CreateTimer
	//	*WorkflowAction_SendEvent
	//	*WorkflowAction_CompleteWorkflow
	//	*WorkflowAction_TerminateWorkflow
	//	*WorkflowAction_WorkflowVersionNotAvailable
	//	*WorkflowAction_CreateDetachedWorkflow
	WorkflowActionType isWorkflowAction_WorkflowActionType `protobuf_oneof:"workflowActionType"`
	Router             *TaskRouter                         `protobuf:"bytes,9,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowAction) Descriptor deprecated

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

Deprecated: Use WorkflowAction.ProtoReflect.Descriptor instead.

func (*WorkflowAction) GetCompleteOrchestration deprecated

func (x *WorkflowAction) GetCompleteOrchestration() *CompleteWorkflowAction

Deprecated: Use GetCompleteWorkflow instead.

func (*WorkflowAction) GetCompleteWorkflow

func (x *WorkflowAction) GetCompleteWorkflow() *CompleteWorkflowAction

func (*WorkflowAction) GetCreateChildWorkflow

func (x *WorkflowAction) GetCreateChildWorkflow() *CreateChildWorkflowAction

func (*WorkflowAction) GetCreateDetachedWorkflow

func (x *WorkflowAction) GetCreateDetachedWorkflow() *CreateDetachedWorkflowAction

func (*WorkflowAction) GetCreateSubOrchestration deprecated

func (x *WorkflowAction) GetCreateSubOrchestration() *CreateChildWorkflowAction

Deprecated: Use GetCreateChildWorkflow instead.

func (*WorkflowAction) GetCreateTimer

func (x *WorkflowAction) GetCreateTimer() *CreateTimerAction

func (*WorkflowAction) GetId

func (x *WorkflowAction) GetId() int32

func (*WorkflowAction) GetOrchestratorVersionNotAvailable deprecated

func (x *WorkflowAction) GetOrchestratorVersionNotAvailable() *WorkflowVersionNotAvailableAction

Deprecated: Use GetWorkflowVersionNotAvailable instead.

func (*WorkflowAction) GetRouter

func (x *WorkflowAction) GetRouter() *TaskRouter

func (*WorkflowAction) GetScheduleTask

func (x *WorkflowAction) GetScheduleTask() *ScheduleTaskAction

func (*WorkflowAction) GetSendEvent

func (x *WorkflowAction) GetSendEvent() *SendEventAction

func (*WorkflowAction) GetTerminateOrchestration deprecated

func (x *WorkflowAction) GetTerminateOrchestration() *TerminateWorkflowAction

Deprecated: Use GetTerminateWorkflow instead.

func (*WorkflowAction) GetTerminateWorkflow

func (x *WorkflowAction) GetTerminateWorkflow() *TerminateWorkflowAction

func (*WorkflowAction) GetWorkflowActionType

func (m *WorkflowAction) GetWorkflowActionType() isWorkflowAction_WorkflowActionType

func (*WorkflowAction) GetWorkflowVersionNotAvailable

func (x *WorkflowAction) GetWorkflowVersionNotAvailable() *WorkflowVersionNotAvailableAction

func (*WorkflowAction) ProtoMessage

func (*WorkflowAction) ProtoMessage()

func (*WorkflowAction) ProtoReflect

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

func (*WorkflowAction) Reset

func (x *WorkflowAction) Reset()

func (*WorkflowAction) String

func (x *WorkflowAction) String() string

type WorkflowAction_CompleteWorkflow

type WorkflowAction_CompleteWorkflow struct {
	CompleteWorkflow *CompleteWorkflowAction `protobuf:"bytes,6,opt,name=completeWorkflow,proto3,oneof"`
}

type WorkflowAction_CreateChildWorkflow

type WorkflowAction_CreateChildWorkflow struct {
	CreateChildWorkflow *CreateChildWorkflowAction `protobuf:"bytes,3,opt,name=createChildWorkflow,proto3,oneof"`
}

type WorkflowAction_CreateDetachedWorkflow

type WorkflowAction_CreateDetachedWorkflow struct {
	CreateDetachedWorkflow *CreateDetachedWorkflowAction `protobuf:"bytes,11,opt,name=createDetachedWorkflow,proto3,oneof"`
}

type WorkflowAction_CreateTimer

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

type WorkflowAction_ScheduleTask

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

type WorkflowAction_SendEvent

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

type WorkflowAction_TerminateWorkflow

type WorkflowAction_TerminateWorkflow struct {
	TerminateWorkflow *TerminateWorkflowAction `protobuf:"bytes,7,opt,name=terminateWorkflow,proto3,oneof"`
}

type WorkflowAction_WorkflowVersionNotAvailable

type WorkflowAction_WorkflowVersionNotAvailable struct {
	WorkflowVersionNotAvailable *WorkflowVersionNotAvailableAction `protobuf:"bytes,10,opt,name=workflowVersionNotAvailable,proto3,oneof"`
}

type WorkflowCompletedEvent

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

func (*WorkflowCompletedEvent) Descriptor deprecated

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

Deprecated: Use WorkflowCompletedEvent.ProtoReflect.Descriptor instead.

func (*WorkflowCompletedEvent) ProtoMessage

func (*WorkflowCompletedEvent) ProtoMessage()

func (*WorkflowCompletedEvent) ProtoReflect

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

func (*WorkflowCompletedEvent) Reset

func (x *WorkflowCompletedEvent) Reset()

func (*WorkflowCompletedEvent) String

func (x *WorkflowCompletedEvent) String() string

type WorkflowInstance

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

func (*WorkflowInstance) Descriptor deprecated

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

Deprecated: Use WorkflowInstance.ProtoReflect.Descriptor instead.

func (*WorkflowInstance) GetExecutionId

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

func (*WorkflowInstance) GetInstanceId

func (x *WorkflowInstance) GetInstanceId() string

func (*WorkflowInstance) ProtoMessage

func (*WorkflowInstance) ProtoMessage()

func (*WorkflowInstance) ProtoReflect

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

func (*WorkflowInstance) Reset

func (x *WorkflowInstance) Reset()

func (*WorkflowInstance) String

func (x *WorkflowInstance) String() string

type WorkflowMessage

type WorkflowMessage struct {

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

A message to be delivered to a workflow by the backend.

func (*WorkflowMessage) Descriptor deprecated

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

Deprecated: Use WorkflowMessage.ProtoReflect.Descriptor instead.

func (*WorkflowMessage) GetEvent

func (x *WorkflowMessage) GetEvent() *HistoryEvent

func (*WorkflowMessage) GetInstance

func (x *WorkflowMessage) GetInstance() *WorkflowInstance

func (*WorkflowMessage) ProtoMessage

func (*WorkflowMessage) ProtoMessage()

func (*WorkflowMessage) ProtoReflect

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

func (*WorkflowMessage) Reset

func (x *WorkflowMessage) Reset()

func (*WorkflowMessage) String

func (x *WorkflowMessage) String() string

type WorkflowMetadata

type WorkflowMetadata struct {
	InstanceId       string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name             string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	RuntimeStatus    OrchestrationStatus     `protobuf:"varint,3,opt,name=runtimeStatus,proto3,enum=OrchestrationStatus" json:"runtimeStatus,omitempty"`
	CreatedAt        *timestamppb.Timestamp  `protobuf:"bytes,4,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	LastUpdatedAt    *timestamppb.Timestamp  `protobuf:"bytes,5,opt,name=lastUpdatedAt,proto3" json:"lastUpdatedAt,omitempty"`
	Input            *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=input,proto3" json:"input,omitempty"`
	Output           *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=output,proto3" json:"output,omitempty"`
	CustomStatus     *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	FailureDetails   *TaskFailureDetails     `protobuf:"bytes,9,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	CompletedAt      *timestamppb.Timestamp  `protobuf:"bytes,10,opt,name=completedAt,proto3" json:"completedAt,omitempty"`
	ParentInstanceId string                  `protobuf:"bytes,11,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"`
	Version          *wrapperspb.StringValue `protobuf:"bytes,12,opt,name=version,proto3,oneof" json:"version,omitempty"`
	ParentAppId      *wrapperspb.StringValue `protobuf:"bytes,13,opt,name=parentAppId,proto3,oneof" json:"parentAppId,omitempty"`
	StartedAt        *timestamppb.Timestamp  `protobuf:"bytes,14,opt,name=startedAt,proto3,oneof" json:"startedAt,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowMetadata) Descriptor deprecated

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

Deprecated: Use WorkflowMetadata.ProtoReflect.Descriptor instead.

func (*WorkflowMetadata) GetCompletedAt

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

func (*WorkflowMetadata) GetCreatedAt

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

func (*WorkflowMetadata) GetCustomStatus

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

func (*WorkflowMetadata) GetFailureDetails

func (x *WorkflowMetadata) GetFailureDetails() *TaskFailureDetails

func (*WorkflowMetadata) GetInput

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

func (*WorkflowMetadata) GetInstanceId

func (x *WorkflowMetadata) GetInstanceId() string

func (*WorkflowMetadata) GetLastUpdatedAt

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

func (*WorkflowMetadata) GetName

func (x *WorkflowMetadata) GetName() string

func (*WorkflowMetadata) GetOutput

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

func (*WorkflowMetadata) GetParentAppId

func (x *WorkflowMetadata) GetParentAppId() *wrapperspb.StringValue

func (*WorkflowMetadata) GetParentInstanceId

func (x *WorkflowMetadata) GetParentInstanceId() string

func (*WorkflowMetadata) GetRuntimeStatus

func (x *WorkflowMetadata) GetRuntimeStatus() OrchestrationStatus

func (*WorkflowMetadata) GetStartedAt

func (x *WorkflowMetadata) GetStartedAt() *timestamppb.Timestamp

func (*WorkflowMetadata) GetVersion

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

func (*WorkflowMetadata) ProtoMessage

func (*WorkflowMetadata) ProtoMessage()

func (*WorkflowMetadata) ProtoReflect

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

func (*WorkflowMetadata) Reset

func (x *WorkflowMetadata) Reset()

func (*WorkflowMetadata) String

func (x *WorkflowMetadata) String() string

type WorkflowRequest

type WorkflowRequest struct {
	InstanceId               string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	ExecutionId              *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=executionId,proto3" json:"executionId,omitempty"`
	PastEvents               []*HistoryEvent         `protobuf:"bytes,3,rep,name=pastEvents,proto3" json:"pastEvents,omitempty"`
	NewEvents                []*HistoryEvent         `protobuf:"bytes,4,rep,name=newEvents,proto3" json:"newEvents,omitempty"`
	RequiresHistoryStreaming bool                    `protobuf:"varint,6,opt,name=requiresHistoryStreaming,proto3" json:"requiresHistoryStreaming,omitempty"`
	Router                   *TaskRouter             `protobuf:"bytes,7,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// Propagated history from a parent workflow.
	// Delivered via the work item stream to the SDK, so that the
	// workflow function can access it via ctx.
	PropagatedHistory *PropagatedHistory `protobuf:"bytes,8,opt,name=propagatedHistory,proto3,oneof" json:"propagatedHistory,omitempty"`
	// cachedHistory, when present, signals that pastEvents holds only the
	// delta and the worker must reconstruct the omitted prefix from its own
	// cache (or fetch it via GetInstanceHistory on a miss). Absent for
	// full-history sends.
	CachedHistory *CachedHistory `protobuf:"bytes,9,opt,name=cachedHistory,proto3,oneof" json:"cachedHistory,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowRequest) Descriptor deprecated

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

Deprecated: Use WorkflowRequest.ProtoReflect.Descriptor instead.

func (*WorkflowRequest) GetCachedHistory

func (x *WorkflowRequest) GetCachedHistory() *CachedHistory

func (*WorkflowRequest) GetExecutionId

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

func (*WorkflowRequest) GetInstanceId

func (x *WorkflowRequest) GetInstanceId() string

func (*WorkflowRequest) GetNewEvents

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

func (*WorkflowRequest) GetPastEvents

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

func (*WorkflowRequest) GetPropagatedHistory

func (x *WorkflowRequest) GetPropagatedHistory() *PropagatedHistory

func (*WorkflowRequest) GetRequiresHistoryStreaming

func (x *WorkflowRequest) GetRequiresHistoryStreaming() bool

func (*WorkflowRequest) GetRouter

func (x *WorkflowRequest) GetRouter() *TaskRouter

func (*WorkflowRequest) ProtoMessage

func (*WorkflowRequest) ProtoMessage()

func (*WorkflowRequest) ProtoReflect

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

func (*WorkflowRequest) Reset

func (x *WorkflowRequest) Reset()

func (*WorkflowRequest) String

func (x *WorkflowRequest) String() string

type WorkflowResponse

type WorkflowResponse struct {
	InstanceId      string                  `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Actions         []*WorkflowAction       `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	CustomStatus    *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=customStatus,proto3" json:"customStatus,omitempty"`
	CompletionToken string                  `protobuf:"bytes,4,opt,name=completionToken,proto3" json:"completionToken,omitempty"`
	// The number of work item events that were processed by the workflow.
	// This field is optional. If not set, the service should assume that the workflow processed all events.
	NumEventsProcessed *wrapperspb.Int32Value `protobuf:"bytes,5,opt,name=numEventsProcessed,proto3" json:"numEventsProcessed,omitempty"`
	Version            *WorkflowVersion       `protobuf:"bytes,6,opt,name=version,proto3,oneof" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowResponse) Descriptor deprecated

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

Deprecated: Use WorkflowResponse.ProtoReflect.Descriptor instead.

func (*WorkflowResponse) GetActions

func (x *WorkflowResponse) GetActions() []*WorkflowAction

func (*WorkflowResponse) GetCompletionToken

func (x *WorkflowResponse) GetCompletionToken() string

func (*WorkflowResponse) GetCustomStatus

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

func (*WorkflowResponse) GetInstanceId

func (x *WorkflowResponse) GetInstanceId() string

func (*WorkflowResponse) GetNumEventsProcessed

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

func (*WorkflowResponse) GetVersion

func (x *WorkflowResponse) GetVersion() *WorkflowVersion

func (*WorkflowResponse) ProtoMessage

func (*WorkflowResponse) ProtoMessage()

func (*WorkflowResponse) ProtoReflect

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

func (*WorkflowResponse) Reset

func (x *WorkflowResponse) Reset()

func (*WorkflowResponse) String

func (x *WorkflowResponse) String() string

type WorkflowRuntimeState

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

WorkflowRuntimeState holds the current state for a workflow.

func (*WorkflowRuntimeState) Descriptor deprecated

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

Deprecated: Use WorkflowRuntimeState.ProtoReflect.Descriptor instead.

func (*WorkflowRuntimeState) GetCompletedEvent

func (x *WorkflowRuntimeState) GetCompletedEvent() *ExecutionCompletedEvent

func (*WorkflowRuntimeState) GetCompletedTime

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

func (*WorkflowRuntimeState) GetContinuedAsNew

func (x *WorkflowRuntimeState) GetContinuedAsNew() bool

func (*WorkflowRuntimeState) GetCreatedTime

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

func (*WorkflowRuntimeState) GetCustomStatus

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

func (*WorkflowRuntimeState) GetInstanceId

func (x *WorkflowRuntimeState) GetInstanceId() string

func (*WorkflowRuntimeState) GetIsSuspended

func (x *WorkflowRuntimeState) GetIsSuspended() bool

func (*WorkflowRuntimeState) GetLastUpdatedTime

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

func (*WorkflowRuntimeState) GetNewEvents

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

func (*WorkflowRuntimeState) GetOldEvents

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

func (*WorkflowRuntimeState) GetPendingMessages

func (x *WorkflowRuntimeState) GetPendingMessages() []*WorkflowRuntimeStateMessage

func (*WorkflowRuntimeState) GetPendingTasks

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

func (*WorkflowRuntimeState) GetPendingTimers

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

func (*WorkflowRuntimeState) GetStalled

func (x *WorkflowRuntimeState) GetStalled() *RuntimeStateStalled

func (*WorkflowRuntimeState) GetStartEvent

func (x *WorkflowRuntimeState) GetStartEvent() *ExecutionStartedEvent

func (*WorkflowRuntimeState) ProtoMessage

func (*WorkflowRuntimeState) ProtoMessage()

func (*WorkflowRuntimeState) ProtoReflect

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

func (*WorkflowRuntimeState) Reset

func (x *WorkflowRuntimeState) Reset()

func (*WorkflowRuntimeState) String

func (x *WorkflowRuntimeState) String() string

type WorkflowRuntimeStateMessage

type WorkflowRuntimeStateMessage struct {
	HistoryEvent     *HistoryEvent `protobuf:"bytes,1,opt,name=historyEvent,proto3" json:"historyEvent,omitempty"`
	TargetInstanceId string        `protobuf:"bytes,2,opt,name=targetInstanceId,proto3" json:"targetInstanceId,omitempty"`
	// Propagated history to deliver to the child workflow.
	// This is a transport field used when creating child workflows with
	// history propagation enabled. It is NOT stored as part of any
	// workflow's history events.
	PropagatedHistory *PropagatedHistory `protobuf:"bytes,3,opt,name=propagatedHistory,proto3,oneof" json:"propagatedHistory,omitempty"`
	// contains filtered or unexported fields
}

WorkflowRuntimeStateMessage holds a HistoryEvent payload and the target instance ID.

func (*WorkflowRuntimeStateMessage) Descriptor deprecated

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

Deprecated: Use WorkflowRuntimeStateMessage.ProtoReflect.Descriptor instead.

func (*WorkflowRuntimeStateMessage) GetHistoryEvent

func (x *WorkflowRuntimeStateMessage) GetHistoryEvent() *HistoryEvent

func (*WorkflowRuntimeStateMessage) GetPropagatedHistory

func (x *WorkflowRuntimeStateMessage) GetPropagatedHistory() *PropagatedHistory

func (*WorkflowRuntimeStateMessage) GetTargetInstanceId

func (x *WorkflowRuntimeStateMessage) GetTargetInstanceId() string

func (*WorkflowRuntimeStateMessage) ProtoMessage

func (*WorkflowRuntimeStateMessage) ProtoMessage()

func (*WorkflowRuntimeStateMessage) ProtoReflect

func (*WorkflowRuntimeStateMessage) Reset

func (x *WorkflowRuntimeStateMessage) Reset()

func (*WorkflowRuntimeStateMessage) String

func (x *WorkflowRuntimeStateMessage) String() string

type WorkflowStartedEvent

type WorkflowStartedEvent struct {
	Version *WorkflowVersion `protobuf:"bytes,1,opt,name=version,proto3,oneof" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowStartedEvent) Descriptor deprecated

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

Deprecated: Use WorkflowStartedEvent.ProtoReflect.Descriptor instead.

func (*WorkflowStartedEvent) GetVersion

func (x *WorkflowStartedEvent) GetVersion() *WorkflowVersion

func (*WorkflowStartedEvent) ProtoMessage

func (*WorkflowStartedEvent) ProtoMessage()

func (*WorkflowStartedEvent) ProtoReflect

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

func (*WorkflowStartedEvent) Reset

func (x *WorkflowStartedEvent) Reset()

func (*WorkflowStartedEvent) String

func (x *WorkflowStartedEvent) String() string

type WorkflowState

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

func (*WorkflowState) Descriptor deprecated

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

Deprecated: Use WorkflowState.ProtoReflect.Descriptor instead.

func (*WorkflowState) GetCompletedTimestamp

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

func (*WorkflowState) GetCreatedTimestamp

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

func (*WorkflowState) GetCustomStatus

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

func (*WorkflowState) GetExecutionId

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

func (*WorkflowState) GetFailureDetails

func (x *WorkflowState) GetFailureDetails() *TaskFailureDetails

func (*WorkflowState) GetInput

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

func (*WorkflowState) GetInstanceId

func (x *WorkflowState) GetInstanceId() string

func (*WorkflowState) GetLastUpdatedTimestamp

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

func (*WorkflowState) GetName

func (x *WorkflowState) GetName() string

func (*WorkflowState) GetOutput

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

func (*WorkflowState) GetParentAppId

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

func (*WorkflowState) GetParentInstanceId

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

func (*WorkflowState) GetScheduledStartTimestamp

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

func (*WorkflowState) GetStartedAt

func (x *WorkflowState) GetStartedAt() *timestamppb.Timestamp

func (*WorkflowState) GetTags

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

func (*WorkflowState) GetVersion

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

func (*WorkflowState) GetWorkflowStatus

func (x *WorkflowState) GetWorkflowStatus() OrchestrationStatus

func (*WorkflowState) ProtoMessage

func (*WorkflowState) ProtoMessage()

func (*WorkflowState) ProtoReflect

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

func (*WorkflowState) Reset

func (x *WorkflowState) Reset()

func (*WorkflowState) String

func (x *WorkflowState) String() string

type WorkflowVersion

type WorkflowVersion struct {
	Patches []string `protobuf:"bytes,1,rep,name=patches,proto3" json:"patches,omitempty"`
	// The name of the executed workflow
	Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowVersion) Descriptor deprecated

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

Deprecated: Use WorkflowVersion.ProtoReflect.Descriptor instead.

func (*WorkflowVersion) GetName

func (x *WorkflowVersion) GetName() string

func (*WorkflowVersion) GetPatches

func (x *WorkflowVersion) GetPatches() []string

func (*WorkflowVersion) ProtoMessage

func (*WorkflowVersion) ProtoMessage()

func (*WorkflowVersion) ProtoReflect

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

func (*WorkflowVersion) Reset

func (x *WorkflowVersion) Reset()

func (*WorkflowVersion) String

func (x *WorkflowVersion) String() string

type WorkflowVersionNotAvailableAction

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

func (*WorkflowVersionNotAvailableAction) Descriptor deprecated

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

Deprecated: Use WorkflowVersionNotAvailableAction.ProtoReflect.Descriptor instead.

func (*WorkflowVersionNotAvailableAction) ProtoMessage

func (*WorkflowVersionNotAvailableAction) ProtoMessage()

func (*WorkflowVersionNotAvailableAction) ProtoReflect

func (*WorkflowVersionNotAvailableAction) Reset

func (*WorkflowVersionNotAvailableAction) String

Jump to

Keyboard shortcuts

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