protos

package
v0.12.0 Latest Latest
Warning

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

Go to latest
Published: May 21, 2026 License: Apache-2.0 Imports: 11 Imported by: 16

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_RerunWorkflowFromEvent_FullMethodName    = "/TaskHubSidecarService/RerunWorkflowFromEvent"
	TaskHubSidecarService_ListInstanceIDs_FullMethodName           = "/TaskHubSidecarService/ListInstanceIDs"
	TaskHubSidecarService_GetInstanceHistory_FullMethodName        = "/TaskHubSidecarService/GetInstanceHistory"
)

Variables

View Source
var (
	TerminalStatus_name = map[int32]string{
		0: "TERMINAL_STATUS_UNSPECIFIED",
		1: "TERMINAL_STATUS_COMPLETED",
		2: "TERMINAL_STATUS_FAILED",
	}
	TerminalStatus_value = map[string]int32{
		"TERMINAL_STATUS_UNSPECIFIED": 0,
		"TERMINAL_STATUS_COMPLETED":   1,
		"TERMINAL_STATUS_FAILED":      2,
	}
)

Enum value maps for TerminalStatus.

View Source
var (
	ActivityTerminalStatus_name = map[int32]string{
		0: "ACTIVITY_TERMINAL_STATUS_UNSPECIFIED",
		1: "ACTIVITY_TERMINAL_STATUS_COMPLETED",
		2: "ACTIVITY_TERMINAL_STATUS_FAILED",
	}
	ActivityTerminalStatus_value = map[string]int32{
		"ACTIVITY_TERMINAL_STATUS_UNSPECIFIED": 0,
		"ACTIVITY_TERMINAL_STATUS_COMPLETED":   1,
		"ACTIVITY_TERMINAL_STATUS_FAILED":      2,
	}
)

Enum value maps for ActivityTerminalStatus.

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

Enum value maps for WorkerCapability.

View Source
var File_attestation_proto protoreflect.FileDescriptor
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: "RerunWorkflowFromEvent",
			Handler:    _TaskHubSidecarService_RerunWorkflowFromEvent_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 ActivityCompletionAttestation added in v0.12.0

type ActivityCompletionAttestation struct {

	// Deterministically serialized form of
	// ActivityCompletionAttestationPayload produced once by the signer.
	// Opaque bytes thereafter; receivers, storage layers, and verifiers
	// never re-marshal.
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// Cryptographic signature over sha256(payload).
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

Signed wrapper around ActivityCompletionAttestationPayload.

func (*ActivityCompletionAttestation) Descriptor deprecated added in v0.12.0

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

Deprecated: Use ActivityCompletionAttestation.ProtoReflect.Descriptor instead.

func (*ActivityCompletionAttestation) GetPayload added in v0.12.0

func (x *ActivityCompletionAttestation) GetPayload() []byte

func (*ActivityCompletionAttestation) GetSignature added in v0.12.0

func (x *ActivityCompletionAttestation) GetSignature() []byte

func (*ActivityCompletionAttestation) ProtoMessage added in v0.12.0

func (*ActivityCompletionAttestation) ProtoMessage()

func (*ActivityCompletionAttestation) ProtoReflect added in v0.12.0

func (*ActivityCompletionAttestation) Reset added in v0.12.0

func (x *ActivityCompletionAttestation) Reset()

func (*ActivityCompletionAttestation) String added in v0.12.0

type ActivityCompletionAttestationPayload added in v0.12.0

type ActivityCompletionAttestationPayload struct {

	// Parent workflow instance ID that scheduled the activity.
	ParentInstanceId string `protobuf:"bytes,1,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"`
	// taskScheduledId from the parent's TaskScheduledEvent. Unique within
	// the parent instance.
	ParentTaskScheduledId int32 `protobuf:"varint,2,opt,name=parentTaskScheduledId,proto3" json:"parentTaskScheduledId,omitempty"`
	// Activity name from the parent's TaskScheduledEvent. Explicit because
	// no separate creation event binds it in the parent's history the way
	// ChildWorkflowInstanceCreatedEvent does for child workflows.
	ActivityName string `protobuf:"bytes,3,opt,name=activityName,proto3" json:"activityName,omitempty"`
	// sha256 commitment to this invocation's input and output. See the
	// canonical byte serialization spec at the top of this file. Use
	// terminalStatus (ACTIVITY_TERMINAL_STATUS_COMPLETED or _FAILED) to
	// select the output serialization rule.
	IoDigest []byte `protobuf:"bytes,4,opt,name=ioDigest,proto3" json:"ioDigest,omitempty"`
	// sha256 of the DER-encoded X.509 certificate chain bytes of the
	// activity executor's signer. Same semantics and storage behavior as
	// ChildCompletionAttestationPayload.signerCertDigest.
	SignerCertDigest []byte `protobuf:"bytes,5,opt,name=signerCertDigest,proto3" json:"signerCertDigest,omitempty"`
	// Terminal state of the activity at the moment of attestation.
	TerminalStatus ActivityTerminalStatus `protobuf:"varint,6,opt,name=terminalStatus,proto3,enum=ActivityTerminalStatus" json:"terminalStatus,omitempty"`
	// Version of the canonical byte serialization spec used to compute
	// ioDigest. See the "Versioning" section of the spec block at the top
	// of this file. Verifiers that don't recognize the value reject the
	// attestation rather than risk a silent digest mismatch. Current
	// value: 1.
	CanonicalSpecVersion uint32 `protobuf:"varint,7,opt,name=canonicalSpecVersion,proto3" json:"canonicalSpecVersion,omitempty"`
	// contains filtered or unexported fields
}

Inner signed payload for an activity completion attestation. Activities have no signed history chain of their own (unlike child workflows), so there is no finalSignatureDigest field. Activity identity is the hosting app's SPIFFE identity; a compromised app can attest only to activities it hosts, not to activities hosted on other apps.

func (*ActivityCompletionAttestationPayload) Descriptor deprecated added in v0.12.0

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

Deprecated: Use ActivityCompletionAttestationPayload.ProtoReflect.Descriptor instead.

func (*ActivityCompletionAttestationPayload) GetActivityName added in v0.12.0

func (x *ActivityCompletionAttestationPayload) GetActivityName() string

func (*ActivityCompletionAttestationPayload) GetCanonicalSpecVersion added in v0.12.0

func (x *ActivityCompletionAttestationPayload) GetCanonicalSpecVersion() uint32

func (*ActivityCompletionAttestationPayload) GetIoDigest added in v0.12.0

func (x *ActivityCompletionAttestationPayload) GetIoDigest() []byte

func (*ActivityCompletionAttestationPayload) GetParentInstanceId added in v0.12.0

func (x *ActivityCompletionAttestationPayload) GetParentInstanceId() string

func (*ActivityCompletionAttestationPayload) GetParentTaskScheduledId added in v0.12.0

func (x *ActivityCompletionAttestationPayload) GetParentTaskScheduledId() int32

func (*ActivityCompletionAttestationPayload) GetSignerCertDigest added in v0.12.0

func (x *ActivityCompletionAttestationPayload) GetSignerCertDigest() []byte

func (*ActivityCompletionAttestationPayload) GetTerminalStatus added in v0.12.0

func (*ActivityCompletionAttestationPayload) ProtoMessage added in v0.12.0

func (*ActivityCompletionAttestationPayload) ProtoMessage()

func (*ActivityCompletionAttestationPayload) ProtoReflect added in v0.12.0

func (*ActivityCompletionAttestationPayload) Reset added in v0.12.0

func (*ActivityCompletionAttestationPayload) String added in v0.12.0

type ActivityInvocation added in v0.12.0

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

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

Deprecated: Use ActivityInvocation.ProtoReflect.Descriptor instead.

func (*ActivityInvocation) GetHistoryEvent added in v0.12.0

func (x *ActivityInvocation) GetHistoryEvent() *HistoryEvent

func (*ActivityInvocation) GetPropagatedHistory added in v0.12.0

func (x *ActivityInvocation) GetPropagatedHistory() *PropagatedHistory

func (*ActivityInvocation) ProtoMessage added in v0.12.0

func (*ActivityInvocation) ProtoMessage()

func (*ActivityInvocation) ProtoReflect added in v0.12.0

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

func (*ActivityInvocation) Reset added in v0.12.0

func (x *ActivityInvocation) Reset()

func (*ActivityInvocation) String added in v0.12.0

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

func (x *ActivityRequest) GetPropagatedHistory() *PropagatedHistory

func (*ActivityRequest) GetTaskExecutionId added in v0.8.0

func (x *ActivityRequest) GetTaskExecutionId() string

func (*ActivityRequest) GetTaskId

func (x *ActivityRequest) GetTaskId() int32

func (*ActivityRequest) GetVersion

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

func (*ActivityRequest) GetWorkflowInstance added in v0.12.0

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

func (x *ActivityResponse) GetCompletionToken() string

func (*ActivityResponse) GetFailureDetails

func (x *ActivityResponse) GetFailureDetails() *TaskFailureDetails

func (*ActivityResponse) GetInstanceId

func (x *ActivityResponse) GetInstanceId() string

func (*ActivityResponse) GetResult

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

func (*ActivityResponse) GetTaskId

func (x *ActivityResponse) GetTaskId() int32

func (*ActivityResponse) ProtoMessage

func (*ActivityResponse) ProtoMessage()

func (*ActivityResponse) ProtoReflect

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

func (*ActivityResponse) Reset

func (x *ActivityResponse) Reset()

func (*ActivityResponse) String

func (x *ActivityResponse) String() string

type ActivityTerminalStatus added in v0.12.0

type ActivityTerminalStatus int32

Terminal state of an activity task at the moment of attestation. Activities have no "terminate" operation, so the space is smaller than TerminalStatus.

const (
	ActivityTerminalStatus_ACTIVITY_TERMINAL_STATUS_UNSPECIFIED ActivityTerminalStatus = 0
	ActivityTerminalStatus_ACTIVITY_TERMINAL_STATUS_COMPLETED   ActivityTerminalStatus = 1
	ActivityTerminalStatus_ACTIVITY_TERMINAL_STATUS_FAILED      ActivityTerminalStatus = 2
)

func (ActivityTerminalStatus) Descriptor added in v0.12.0

func (ActivityTerminalStatus) Enum added in v0.12.0

func (ActivityTerminalStatus) EnumDescriptor deprecated added in v0.12.0

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

Deprecated: Use ActivityTerminalStatus.Descriptor instead.

func (ActivityTerminalStatus) Number added in v0.12.0

func (ActivityTerminalStatus) String added in v0.12.0

func (x ActivityTerminalStatus) String() string

func (ActivityTerminalStatus) Type added in v0.12.0

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

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

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

Deprecated: Use BackendWorkflowState.ProtoReflect.Descriptor instead.

func (*BackendWorkflowState) GetCustomStatus added in v0.12.0

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

func (*BackendWorkflowState) GetGeneration added in v0.12.0

func (x *BackendWorkflowState) GetGeneration() uint64

func (*BackendWorkflowState) GetHistory added in v0.12.0

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

func (*BackendWorkflowState) GetInbox added in v0.12.0

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

func (*BackendWorkflowState) ProtoMessage added in v0.12.0

func (*BackendWorkflowState) ProtoMessage()

func (*BackendWorkflowState) ProtoReflect added in v0.12.0

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

func (*BackendWorkflowState) Reset added in v0.12.0

func (x *BackendWorkflowState) Reset()

func (*BackendWorkflowState) String added in v0.12.0

func (x *BackendWorkflowState) String() string

type BackendWorkflowStateMetadata added in v0.12.0

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"`
	// Number of HistorySignature entries stored (signature-NNNNNN keys).
	SignatureLength uint64 `protobuf:"varint,4,opt,name=signatureLength,proto3" json:"signatureLength,omitempty"`
	// Number of SigningCertificate entries stored (sigcert-NNNNNN keys).
	SigningCertificateLength uint64 `protobuf:"varint,5,opt,name=signingCertificateLength,proto3" json:"signingCertificateLength,omitempty"`
	// Number of ExternalSigningCertificate entries stored
	// (ext-sigcert-NNNNNN keys). Same lifecycle as signingCertificateLength:
	// monotonically grows within a run as new foreign signer certificates
	// are absorbed from incoming attestations, zeroed on ContinueAsNew,
	// cleared on instance purge. Subject to the same maxStateEntries
	// tampering bound.
	ExternalSigningCertificateLength uint64 `protobuf:"varint,6,opt,name=externalSigningCertificateLength,proto3" json:"externalSigningCertificateLength,omitempty"`
	// contains filtered or unexported fields
}

func (*BackendWorkflowStateMetadata) Descriptor deprecated added in v0.12.0

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

Deprecated: Use BackendWorkflowStateMetadata.ProtoReflect.Descriptor instead.

func (*BackendWorkflowStateMetadata) GetExternalSigningCertificateLength added in v0.12.0

func (x *BackendWorkflowStateMetadata) GetExternalSigningCertificateLength() uint64

func (*BackendWorkflowStateMetadata) GetGeneration added in v0.12.0

func (x *BackendWorkflowStateMetadata) GetGeneration() uint64

func (*BackendWorkflowStateMetadata) GetHistoryLength added in v0.12.0

func (x *BackendWorkflowStateMetadata) GetHistoryLength() uint64

func (*BackendWorkflowStateMetadata) GetInboxLength added in v0.12.0

func (x *BackendWorkflowStateMetadata) GetInboxLength() uint64

func (*BackendWorkflowStateMetadata) GetSignatureLength added in v0.12.0

func (x *BackendWorkflowStateMetadata) GetSignatureLength() uint64

func (*BackendWorkflowStateMetadata) GetSigningCertificateLength added in v0.12.0

func (x *BackendWorkflowStateMetadata) GetSigningCertificateLength() uint64

func (*BackendWorkflowStateMetadata) ProtoMessage added in v0.12.0

func (*BackendWorkflowStateMetadata) ProtoMessage()

func (*BackendWorkflowStateMetadata) ProtoReflect added in v0.12.0

func (*BackendWorkflowStateMetadata) Reset added in v0.12.0

func (x *BackendWorkflowStateMetadata) Reset()

func (*BackendWorkflowStateMetadata) String added in v0.12.0

type ChildCompletionAttestation added in v0.12.0

type ChildCompletionAttestation struct {

	// Deterministically serialized form of ChildCompletionAttestationPayload
	// produced once by the signer. Opaque bytes thereafter; receivers,
	// storage layers, and verifiers never re-marshal.
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// Cryptographic signature over sha256(payload) using the private key
	// corresponding to the certificate whose digest is in the payload's
	// signerCertDigest field. Signature format follows the same rules as
	// HistorySignature.signature.
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

Signed wrapper around ChildCompletionAttestationPayload.

func (*ChildCompletionAttestation) Descriptor deprecated added in v0.12.0

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

Deprecated: Use ChildCompletionAttestation.ProtoReflect.Descriptor instead.

func (*ChildCompletionAttestation) GetPayload added in v0.12.0

func (x *ChildCompletionAttestation) GetPayload() []byte

func (*ChildCompletionAttestation) GetSignature added in v0.12.0

func (x *ChildCompletionAttestation) GetSignature() []byte

func (*ChildCompletionAttestation) ProtoMessage added in v0.12.0

func (*ChildCompletionAttestation) ProtoMessage()

func (*ChildCompletionAttestation) ProtoReflect added in v0.12.0

func (*ChildCompletionAttestation) Reset added in v0.12.0

func (x *ChildCompletionAttestation) Reset()

func (*ChildCompletionAttestation) String added in v0.12.0

func (x *ChildCompletionAttestation) String() string

type ChildCompletionAttestationPayload added in v0.12.0

type ChildCompletionAttestationPayload struct {

	// Parent workflow instance ID. Binds the attestation to a single parent
	// run, preventing replay by other instances of the same parent workflow
	// that share a signing key.
	ParentInstanceId string `protobuf:"bytes,1,opt,name=parentInstanceId,proto3" json:"parentInstanceId,omitempty"`
	// taskScheduledId from the parent's ChildWorkflowInstanceCreatedEvent.
	// Unique within the parent instance; distinguishes multiple invocations
	// of the same child workflow.
	ParentTaskScheduledId int32 `protobuf:"varint,2,opt,name=parentTaskScheduledId,proto3" json:"parentTaskScheduledId,omitempty"`
	// sha256 commitment to this invocation's input and output. The bytes
	// fed into the digest are produced by the canonical byte serialization
	// spec at the top of this file — not by any protobuf marshaler — so
	// the digest is stable across proto versions, implementations, and
	// languages. Use terminalStatus to select the output serialization rule
	// (COMPLETED or FAILED).
	IoDigest []byte `protobuf:"bytes,3,opt,name=ioDigest,proto3" json:"ioDigest,omitempty"`
	// sha256 of the DER-encoded X.509 certificate chain bytes of the
	// signer (leaf first, intermediates concatenated; same byte format
	// as the `certificate` field of SigningCertificate). Computed directly
	// over the DER bytes rather than any protobuf envelope, so the digest
	// is stable across protobuf version changes. The certificate itself
	// is carried as a companion field on the enclosing event on first
	// delivery and stored once in the receiver's external certificate
	// table (ext-sigcert-NNNNNN), looked up by this digest.
	SignerCertDigest []byte `protobuf:"bytes,4,opt,name=signerCertDigest,proto3" json:"signerCertDigest,omitempty"`
	// Terminal state of the child workflow at the moment of attestation.
	// Signed so that a verifier reading the attestation from propagated
	// history can tell whether the child succeeded without relying on the
	// enclosing event type (Completed vs Failed), which may not be
	// visible or trustworthy when the attestation is inspected in
	// isolation.
	TerminalStatus TerminalStatus `protobuf:"varint,5,opt,name=terminalStatus,proto3,enum=TerminalStatus" json:"terminalStatus,omitempty"`
	// Version of the canonical byte serialization spec used to compute
	// ioDigest. See the "Versioning" section of the spec block at the top
	// of this file. Verifiers that don't recognize the value reject the
	// attestation rather than risk a silent digest mismatch. Current
	// value: 1.
	CanonicalSpecVersion uint32 `protobuf:"varint,6,opt,name=canonicalSpecVersion,proto3" json:"canonicalSpecVersion,omitempty"`
	// contains filtered or unexported fields
}

Inner signed payload for a child workflow completion attestation. The deterministically serialized form of this message is what the signer signs over and what receivers verify against; the bytes are produced once and never re-marshaled.

func (*ChildCompletionAttestationPayload) Descriptor deprecated added in v0.12.0

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

Deprecated: Use ChildCompletionAttestationPayload.ProtoReflect.Descriptor instead.

func (*ChildCompletionAttestationPayload) GetCanonicalSpecVersion added in v0.12.0

func (x *ChildCompletionAttestationPayload) GetCanonicalSpecVersion() uint32

func (*ChildCompletionAttestationPayload) GetIoDigest added in v0.12.0

func (x *ChildCompletionAttestationPayload) GetIoDigest() []byte

func (*ChildCompletionAttestationPayload) GetParentInstanceId added in v0.12.0

func (x *ChildCompletionAttestationPayload) GetParentInstanceId() string

func (*ChildCompletionAttestationPayload) GetParentTaskScheduledId added in v0.12.0

func (x *ChildCompletionAttestationPayload) GetParentTaskScheduledId() int32

func (*ChildCompletionAttestationPayload) GetSignerCertDigest added in v0.12.0

func (x *ChildCompletionAttestationPayload) GetSignerCertDigest() []byte

func (*ChildCompletionAttestationPayload) GetTerminalStatus added in v0.12.0

func (x *ChildCompletionAttestationPayload) GetTerminalStatus() TerminalStatus

func (*ChildCompletionAttestationPayload) ProtoMessage added in v0.12.0

func (*ChildCompletionAttestationPayload) ProtoMessage()

func (*ChildCompletionAttestationPayload) ProtoReflect added in v0.12.0

func (*ChildCompletionAttestationPayload) Reset added in v0.12.0

func (*ChildCompletionAttestationPayload) String added in v0.12.0

type ChildWorkflowInstanceCompletedEvent added in v0.12.0

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"`
	// Attestation signed by the completing child workflow's SPIFFE
	// identity. Present when the child was executed under a signing-enabled
	// configuration. Verified on inbox ingestion against the companion
	// signerCertificate and preserved in stored history for future audit
	// and forwarding via provenance bundles.
	Attestation *ChildCompletionAttestation `protobuf:"bytes,3,opt,name=attestation,proto3,oneof" json:"attestation,omitempty"`
	// Companion: DER-encoded X.509 certificate chain of the child's signing
	// identity (leaf first, intermediates concatenated; same format as
	// SigningCertificate.certificate in backend_service.proto). Wire-only;
	// stripped by the receiver before the event is written to
	// history-NNNNNN. The certificate lives once in ext-sigcert-NNNNNN,
	// referenced by attestation payload's signerCertDigest.
	SignerCertificate []byte `protobuf:"bytes,4,opt,name=signerCertificate,proto3,oneof" json:"signerCertificate,omitempty"`
	// contains filtered or unexported fields
}

func (*ChildWorkflowInstanceCompletedEvent) Descriptor deprecated added in v0.12.0

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

Deprecated: Use ChildWorkflowInstanceCompletedEvent.ProtoReflect.Descriptor instead.

func (*ChildWorkflowInstanceCompletedEvent) GetAttestation added in v0.12.0

func (*ChildWorkflowInstanceCompletedEvent) GetResult added in v0.12.0

func (*ChildWorkflowInstanceCompletedEvent) GetSignerCertificate added in v0.12.0

func (x *ChildWorkflowInstanceCompletedEvent) GetSignerCertificate() []byte

func (*ChildWorkflowInstanceCompletedEvent) GetTaskScheduledId added in v0.12.0

func (x *ChildWorkflowInstanceCompletedEvent) GetTaskScheduledId() int32

func (*ChildWorkflowInstanceCompletedEvent) ProtoMessage added in v0.12.0

func (*ChildWorkflowInstanceCompletedEvent) ProtoMessage()

func (*ChildWorkflowInstanceCompletedEvent) ProtoReflect added in v0.12.0

func (*ChildWorkflowInstanceCompletedEvent) Reset added in v0.12.0

func (*ChildWorkflowInstanceCompletedEvent) String added in v0.12.0

type ChildWorkflowInstanceCreatedEvent added in v0.12.0

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"`
	// If defined, indicates that this task was the starting point of a new
	// workflow execution as the result of a rerun operation.
	RerunParentInstanceInfo *RerunParentInstanceInfo `protobuf:"bytes,6,opt,name=rerunParentInstanceInfo,proto3,oneof" json:"rerunParentInstanceInfo,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 */
	// contains filtered or unexported fields
}

func (*ChildWorkflowInstanceCreatedEvent) Descriptor deprecated added in v0.12.0

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

Deprecated: Use ChildWorkflowInstanceCreatedEvent.ProtoReflect.Descriptor instead.

func (*ChildWorkflowInstanceCreatedEvent) GetHistoryPropagationScope added in v0.12.0

func (x *ChildWorkflowInstanceCreatedEvent) GetHistoryPropagationScope() HistoryPropagationScope

func (*ChildWorkflowInstanceCreatedEvent) GetInput added in v0.12.0

func (*ChildWorkflowInstanceCreatedEvent) GetInstanceId added in v0.12.0

func (x *ChildWorkflowInstanceCreatedEvent) GetInstanceId() string

func (*ChildWorkflowInstanceCreatedEvent) GetName added in v0.12.0

func (*ChildWorkflowInstanceCreatedEvent) GetParentTraceContext added in v0.12.0

func (x *ChildWorkflowInstanceCreatedEvent) GetParentTraceContext() *TraceContext

func (*ChildWorkflowInstanceCreatedEvent) GetRerunParentInstanceInfo added in v0.12.0

func (x *ChildWorkflowInstanceCreatedEvent) GetRerunParentInstanceInfo() *RerunParentInstanceInfo

func (*ChildWorkflowInstanceCreatedEvent) GetVersion added in v0.12.0

func (*ChildWorkflowInstanceCreatedEvent) ProtoMessage added in v0.12.0

func (*ChildWorkflowInstanceCreatedEvent) ProtoMessage()

func (*ChildWorkflowInstanceCreatedEvent) ProtoReflect added in v0.12.0

func (*ChildWorkflowInstanceCreatedEvent) Reset added in v0.12.0

func (*ChildWorkflowInstanceCreatedEvent) String added in v0.12.0

type ChildWorkflowInstanceFailedEvent added in v0.12.0

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"`
	// See ChildWorkflowInstanceCompletedEvent.attestation.
	Attestation *ChildCompletionAttestation `protobuf:"bytes,3,opt,name=attestation,proto3,oneof" json:"attestation,omitempty"`
	// Wire-only companion; see
	// ChildWorkflowInstanceCompletedEvent.signerCertificate.
	SignerCertificate []byte `protobuf:"bytes,4,opt,name=signerCertificate,proto3,oneof" json:"signerCertificate,omitempty"`
	// contains filtered or unexported fields
}

func (*ChildWorkflowInstanceFailedEvent) Descriptor deprecated added in v0.12.0

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

Deprecated: Use ChildWorkflowInstanceFailedEvent.ProtoReflect.Descriptor instead.

func (*ChildWorkflowInstanceFailedEvent) GetAttestation added in v0.12.0

func (*ChildWorkflowInstanceFailedEvent) GetFailureDetails added in v0.12.0

func (x *ChildWorkflowInstanceFailedEvent) GetFailureDetails() *TaskFailureDetails

func (*ChildWorkflowInstanceFailedEvent) GetSignerCertificate added in v0.12.0

func (x *ChildWorkflowInstanceFailedEvent) GetSignerCertificate() []byte

func (*ChildWorkflowInstanceFailedEvent) GetTaskScheduledId added in v0.12.0

func (x *ChildWorkflowInstanceFailedEvent) GetTaskScheduledId() int32

func (*ChildWorkflowInstanceFailedEvent) ProtoMessage added in v0.12.0

func (*ChildWorkflowInstanceFailedEvent) ProtoMessage()

func (*ChildWorkflowInstanceFailedEvent) ProtoReflect added in v0.12.0

func (*ChildWorkflowInstanceFailedEvent) Reset added in v0.12.0

func (*ChildWorkflowInstanceFailedEvent) String added in v0.12.0

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

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

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

Deprecated: Use CompleteWorkflowAction.ProtoReflect.Descriptor instead.

func (*CompleteWorkflowAction) GetCarryoverEvents added in v0.12.0

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

func (*CompleteWorkflowAction) GetDetails added in v0.12.0

func (*CompleteWorkflowAction) GetFailureDetails added in v0.12.0

func (x *CompleteWorkflowAction) GetFailureDetails() *TaskFailureDetails

func (*CompleteWorkflowAction) GetNewVersion added in v0.12.0

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

func (*CompleteWorkflowAction) GetOrchestrationStatus deprecated added in v0.12.0

func (x *CompleteWorkflowAction) GetOrchestrationStatus() OrchestrationStatus

Deprecated: Use GetWorkflowStatus on CompleteWorkflowAction instead.

func (*CompleteWorkflowAction) GetResult added in v0.12.0

func (*CompleteWorkflowAction) GetWorkflowStatus added in v0.12.0

func (x *CompleteWorkflowAction) GetWorkflowStatus() OrchestrationStatus

func (*CompleteWorkflowAction) ProtoMessage added in v0.12.0

func (*CompleteWorkflowAction) ProtoMessage()

func (*CompleteWorkflowAction) ProtoReflect added in v0.12.0

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

func (*CompleteWorkflowAction) Reset added in v0.12.0

func (x *CompleteWorkflowAction) Reset()

func (*CompleteWorkflowAction) String added in v0.12.0

func (x *CompleteWorkflowAction) String() string

type CompleteWorkflowWorkItemRequest added in v0.12.0

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

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

Deprecated: Use CompleteWorkflowWorkItemRequest.ProtoReflect.Descriptor instead.

func (*CompleteWorkflowWorkItemRequest) GetCompletionToken added in v0.12.0

func (x *CompleteWorkflowWorkItemRequest) GetCompletionToken() string

func (*CompleteWorkflowWorkItemRequest) GetCustomStatus added in v0.12.0

func (*CompleteWorkflowWorkItemRequest) GetInstance added in v0.12.0

func (*CompleteWorkflowWorkItemRequest) GetNewHistory added in v0.12.0

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

func (*CompleteWorkflowWorkItemRequest) GetNewMessages added in v0.12.0

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

func (*CompleteWorkflowWorkItemRequest) GetNewTasks added in v0.12.0

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

func (*CompleteWorkflowWorkItemRequest) GetNewTimers added in v0.12.0

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

func (*CompleteWorkflowWorkItemRequest) GetNumEventsProcessed added in v0.12.0

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

func (*CompleteWorkflowWorkItemRequest) GetRuntimeStatus added in v0.12.0

func (*CompleteWorkflowWorkItemRequest) ProtoMessage added in v0.12.0

func (*CompleteWorkflowWorkItemRequest) ProtoMessage()

func (*CompleteWorkflowWorkItemRequest) ProtoReflect added in v0.12.0

func (*CompleteWorkflowWorkItemRequest) Reset added in v0.12.0

func (*CompleteWorkflowWorkItemRequest) String added in v0.12.0

type CompleteWorkflowWorkItemResponse added in v0.12.0

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

Response payload for completing a workflow work item.

func (*CompleteWorkflowWorkItemResponse) Descriptor deprecated added in v0.12.0

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

Deprecated: Use CompleteWorkflowWorkItemResponse.ProtoReflect.Descriptor instead.

func (*CompleteWorkflowWorkItemResponse) ProtoMessage added in v0.12.0

func (*CompleteWorkflowWorkItemResponse) ProtoMessage()

func (*CompleteWorkflowWorkItemResponse) ProtoReflect added in v0.12.0

func (*CompleteWorkflowWorkItemResponse) Reset added in v0.12.0

func (*CompleteWorkflowWorkItemResponse) String added in v0.12.0

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

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"`
	Router     *TaskRouter             `protobuf:"bytes,5,opt,name=router,proto3,oneof" json:"router,omitempty"`
	// History propagation scope. Absent/SCOPE_NONE = no propagation.
	HistoryPropagationScope *HistoryPropagationScope `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateChildWorkflowAction) Descriptor deprecated added in v0.12.0

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

Deprecated: Use CreateChildWorkflowAction.ProtoReflect.Descriptor instead.

func (*CreateChildWorkflowAction) GetHistoryPropagationScope added in v0.12.0

func (x *CreateChildWorkflowAction) GetHistoryPropagationScope() HistoryPropagationScope

func (*CreateChildWorkflowAction) GetInput added in v0.12.0

func (*CreateChildWorkflowAction) GetInstanceId added in v0.12.0

func (x *CreateChildWorkflowAction) GetInstanceId() string

func (*CreateChildWorkflowAction) GetName added in v0.12.0

func (x *CreateChildWorkflowAction) GetName() string

func (*CreateChildWorkflowAction) GetRouter added in v0.12.0

func (x *CreateChildWorkflowAction) GetRouter() *TaskRouter

func (*CreateChildWorkflowAction) GetVersion added in v0.12.0

func (*CreateChildWorkflowAction) ProtoMessage added in v0.12.0

func (*CreateChildWorkflowAction) ProtoMessage()

func (*CreateChildWorkflowAction) ProtoReflect added in v0.12.0

func (*CreateChildWorkflowAction) Reset added in v0.12.0

func (x *CreateChildWorkflowAction) Reset()

func (*CreateChildWorkflowAction) String added in v0.12.0

func (x *CreateChildWorkflowAction) String() string

type CreateDetachedWorkflowAction added in v0.12.0

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"`
	Router                  *TaskRouter             `protobuf:"bytes,9,opt,name=router,proto3,oneof" json:"router,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 added in v0.12.0

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

Deprecated: Use CreateDetachedWorkflowAction.ProtoReflect.Descriptor instead.

func (*CreateDetachedWorkflowAction) GetExecutionId added in v0.12.0

func (*CreateDetachedWorkflowAction) GetInput added in v0.12.0

func (*CreateDetachedWorkflowAction) GetInstanceId added in v0.12.0

func (x *CreateDetachedWorkflowAction) GetInstanceId() string

func (*CreateDetachedWorkflowAction) GetName added in v0.12.0

func (x *CreateDetachedWorkflowAction) GetName() string

func (*CreateDetachedWorkflowAction) GetParentTraceContext added in v0.12.0

func (x *CreateDetachedWorkflowAction) GetParentTraceContext() *TraceContext

func (*CreateDetachedWorkflowAction) GetRouter added in v0.12.0

func (x *CreateDetachedWorkflowAction) GetRouter() *TaskRouter

func (*CreateDetachedWorkflowAction) GetScheduledStartTimestamp added in v0.12.0

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

func (*CreateDetachedWorkflowAction) GetTags added in v0.12.0

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

func (*CreateDetachedWorkflowAction) GetVersion added in v0.12.0

func (*CreateDetachedWorkflowAction) ProtoMessage added in v0.12.0

func (*CreateDetachedWorkflowAction) ProtoMessage()

func (*CreateDetachedWorkflowAction) ProtoReflect added in v0.12.0

func (*CreateDetachedWorkflowAction) Reset added in v0.12.0

func (x *CreateDetachedWorkflowAction) Reset()

func (*CreateDetachedWorkflowAction) String added in v0.12.0

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       `` /* 149-byte string literal not displayed */
	ParentTraceContext      *TraceContext           `protobuf:"bytes,9,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateInstanceRequest) Descriptor deprecated

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

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetExecutionId

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

func (*CreateInstanceRequest) GetInput

func (*CreateInstanceRequest) GetInstanceId

func (x *CreateInstanceRequest) GetInstanceId() string

func (*CreateInstanceRequest) GetName

func (x *CreateInstanceRequest) GetName() string

func (*CreateInstanceRequest) GetParentTraceContext added in v0.7.0

func (x *CreateInstanceRequest) GetParentTraceContext() *TraceContext

func (*CreateInstanceRequest) GetScheduledStartTimestamp

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

func (*CreateInstanceRequest) GetTags

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

func (*CreateInstanceRequest) GetVersion

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

func (*CreateInstanceRequest) ProtoMessage

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) ProtoReflect

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

func (*CreateInstanceRequest) Reset

func (x *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String

func (x *CreateInstanceRequest) String() string

type CreateInstanceResponse

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

func (*CreateInstanceResponse) Descriptor deprecated

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

Deprecated: Use CreateInstanceResponse.ProtoReflect.Descriptor instead.

func (*CreateInstanceResponse) GetInstanceId

func (x *CreateInstanceResponse) GetInstanceId() string

func (*CreateInstanceResponse) ProtoMessage

func (*CreateInstanceResponse) ProtoMessage()

func (*CreateInstanceResponse) ProtoReflect

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

func (*CreateInstanceResponse) Reset

func (x *CreateInstanceResponse) Reset()

func (*CreateInstanceResponse) String

func (x *CreateInstanceResponse) String() string

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

func (x *CreateTimerAction) GetActivityRetry() *TimerOriginActivityRetry

func (*CreateTimerAction) GetChildWorkflowRetry added in v0.12.0

func (x *CreateTimerAction) GetChildWorkflowRetry() *TimerOriginChildWorkflowRetry

func (*CreateTimerAction) GetCreateTimer added in v0.12.0

func (x *CreateTimerAction) GetCreateTimer() *TimerOriginCreateTimer

func (*CreateTimerAction) GetExternalEvent added in v0.12.0

func (x *CreateTimerAction) GetExternalEvent() *TimerOriginExternalEvent

func (*CreateTimerAction) GetFireAt

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

func (*CreateTimerAction) GetName added in v0.7.0

func (x *CreateTimerAction) GetName() string

func (*CreateTimerAction) GetOrigin added in v0.12.0

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

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

type CreateTimerAction_ChildWorkflowRetry added in v0.12.0

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

type CreateTimerAction_CreateTimer added in v0.12.0

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

type CreateTimerAction_ExternalEvent added in v0.12.0

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

func (*CreateWorkflowInstanceRequest) Descriptor deprecated

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

Deprecated: Use CreateWorkflowInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateWorkflowInstanceRequest) GetPropagatedHistory added in v0.12.0

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

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

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

Deprecated: Use DetachedWorkflowInstanceCreatedEvent.ProtoReflect.Descriptor instead.

func (*DetachedWorkflowInstanceCreatedEvent) GetInstanceId added in v0.12.0

func (x *DetachedWorkflowInstanceCreatedEvent) GetInstanceId() string

func (*DetachedWorkflowInstanceCreatedEvent) ProtoMessage added in v0.12.0

func (*DetachedWorkflowInstanceCreatedEvent) ProtoMessage()

func (*DetachedWorkflowInstanceCreatedEvent) ProtoReflect added in v0.12.0

func (*DetachedWorkflowInstanceCreatedEvent) Reset added in v0.12.0

func (*DetachedWorkflowInstanceCreatedEvent) String added in v0.12.0

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

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

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

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

Deprecated: Use ExecutionStalledEvent.ProtoReflect.Descriptor instead.

func (*ExecutionStalledEvent) GetDescription added in v0.11.0

func (x *ExecutionStalledEvent) GetDescription() string

func (*ExecutionStalledEvent) GetReason added in v0.11.0

func (x *ExecutionStalledEvent) GetReason() StalledReason

func (*ExecutionStalledEvent) ProtoMessage added in v0.11.0

func (*ExecutionStalledEvent) ProtoMessage()

func (*ExecutionStalledEvent) ProtoReflect added in v0.11.0

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

func (*ExecutionStalledEvent) Reset added in v0.11.0

func (x *ExecutionStalledEvent) Reset()

func (*ExecutionStalledEvent) String added in v0.11.0

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

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

func (*ExecutionStartedEvent) GetVersion

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

func (*ExecutionStartedEvent) GetWorkflowInstance added in v0.12.0

func (x *ExecutionStartedEvent) GetWorkflowInstance() *WorkflowInstance

func (*ExecutionStartedEvent) GetWorkflowSpanID added in v0.12.0

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

type ExternalSigningCertificate struct {

	// sha256 of the DER-encoded X.509 certificate chain bytes (the value
	// in `certificate` below). Also the primary lookup key used by
	// attestations' signerCertDigest fields. Stored explicitly so
	// load-time index construction and post-load integrity checks do not
	// have to re-hash every entry.
	Digest []byte `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	// Same byte format as SigningCertificate.certificate: DER-encoded
	// X.509 chain, leaf first, intermediates concatenated.
	Certificate []byte `protobuf:"bytes,2,opt,name=certificate,proto3" json:"certificate,omitempty"`
	// contains filtered or unexported fields
}

A foreign signer's X.509 certificate; one belonging to another workflow instance or activity executor whose attestations this workflow has received. Stored once per unique digest and referenced by digest from any attestation embedded in history. Stored as individual actor state keys: ext-sigcert-000000, ext-sigcert-000001, etc.

Lifecycle mirrors SigningCertificate (monotonically appended within a run, cleared on ContinueAsNew and instance purge, tracked by BackendWorkflowStateMetadata.externalSigningCertificateLength). Dedup within a run is performed by in-memory digest→index lookup built at load time.

func (*ExternalSigningCertificate) Descriptor deprecated added in v0.12.0

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

Deprecated: Use ExternalSigningCertificate.ProtoReflect.Descriptor instead.

func (*ExternalSigningCertificate) GetCertificate added in v0.12.0

func (x *ExternalSigningCertificate) GetCertificate() []byte

func (*ExternalSigningCertificate) GetDigest added in v0.12.0

func (x *ExternalSigningCertificate) GetDigest() []byte

func (*ExternalSigningCertificate) ProtoMessage added in v0.12.0

func (*ExternalSigningCertificate) ProtoMessage()

func (*ExternalSigningCertificate) ProtoReflect added in v0.12.0

func (*ExternalSigningCertificate) Reset added in v0.12.0

func (x *ExternalSigningCertificate) Reset()

func (*ExternalSigningCertificate) String added in v0.12.0

func (x *ExternalSigningCertificate) String() string

type GetInstanceHistoryRequest added in v0.11.0

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

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

Deprecated: Use GetInstanceHistoryRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceHistoryRequest) GetInstanceId added in v0.11.0

func (x *GetInstanceHistoryRequest) GetInstanceId() string

func (*GetInstanceHistoryRequest) ProtoMessage added in v0.11.0

func (*GetInstanceHistoryRequest) ProtoMessage()

func (*GetInstanceHistoryRequest) ProtoReflect added in v0.11.0

func (*GetInstanceHistoryRequest) Reset added in v0.11.0

func (x *GetInstanceHistoryRequest) Reset()

func (*GetInstanceHistoryRequest) String added in v0.11.0

func (x *GetInstanceHistoryRequest) String() string

type GetInstanceHistoryResponse added in v0.11.0

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

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

Deprecated: Use GetInstanceHistoryResponse.ProtoReflect.Descriptor instead.

func (*GetInstanceHistoryResponse) GetEvents added in v0.11.0

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

func (*GetInstanceHistoryResponse) ProtoMessage added in v0.11.0

func (*GetInstanceHistoryResponse) ProtoMessage()

func (*GetInstanceHistoryResponse) ProtoReflect added in v0.11.0

func (*GetInstanceHistoryResponse) Reset added in v0.11.0

func (x *GetInstanceHistoryResponse) Reset()

func (*GetInstanceHistoryResponse) String added in v0.11.0

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

func (*GetInstanceRequest) Descriptor deprecated

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

Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceRequest) GetGetInputsAndOutputs

func (x *GetInstanceRequest) GetGetInputsAndOutputs() bool

func (*GetInstanceRequest) GetInstanceId

func (x *GetInstanceRequest) GetInstanceId() string

func (*GetInstanceRequest) ProtoMessage

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) ProtoReflect

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

func (*GetInstanceRequest) Reset

func (x *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String

func (x *GetInstanceRequest) String() string

type GetInstanceResponse

type GetInstanceResponse struct {
	Exists        bool           `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	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 added in v0.12.0

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

func (*GetWorkItemsRequest) Descriptor deprecated

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

Deprecated: Use GetWorkItemsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkItemsRequest) ProtoMessage

func (*GetWorkItemsRequest) ProtoMessage()

func (*GetWorkItemsRequest) ProtoReflect

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

func (*GetWorkItemsRequest) Reset

func (x *GetWorkItemsRequest) Reset()

func (*GetWorkItemsRequest) String

func (x *GetWorkItemsRequest) String() string

type HistoryEvent

type HistoryEvent struct {
	EventId   int32                  `protobuf:"varint,1,opt,name=eventId,proto3" json:"eventId,omitempty"`
	Timestamp *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 added in v0.12.0

func (x *HistoryEvent) GetChildWorkflowInstanceCompleted() *ChildWorkflowInstanceCompletedEvent

func (*HistoryEvent) GetChildWorkflowInstanceCreated added in v0.12.0

func (x *HistoryEvent) GetChildWorkflowInstanceCreated() *ChildWorkflowInstanceCreatedEvent

func (*HistoryEvent) GetChildWorkflowInstanceFailed added in v0.12.0

func (x *HistoryEvent) GetChildWorkflowInstanceFailed() *ChildWorkflowInstanceFailedEvent

func (*HistoryEvent) GetContinueAsNew

func (x *HistoryEvent) GetContinueAsNew() *ContinueAsNewEvent

func (*HistoryEvent) GetDetachedWorkflowInstanceCreated added in v0.12.0

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

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

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

func (x *HistoryEvent) GetWorkflowCompleted() *WorkflowCompletedEvent

func (*HistoryEvent) GetWorkflowStarted added in v0.12.0

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

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

type HistoryEvent_ChildWorkflowInstanceCreated added in v0.12.0

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

type HistoryEvent_ChildWorkflowInstanceFailed added in v0.12.0

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

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

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

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

type HistoryEvent_WorkflowStarted added in v0.12.0

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

type HistoryPropagationScope added in v0.12.0

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

func (HistoryPropagationScope) Enum added in v0.12.0

func (HistoryPropagationScope) EnumDescriptor deprecated added in v0.12.0

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

Deprecated: Use HistoryPropagationScope.Descriptor instead.

func (HistoryPropagationScope) Number added in v0.12.0

func (HistoryPropagationScope) String added in v0.12.0

func (x HistoryPropagationScope) String() string

func (HistoryPropagationScope) Type added in v0.12.0

type HistorySignature added in v0.12.0

type HistorySignature struct {

	// Index of the first event covered by this signature (inclusive).
	StartEventIndex uint64 `protobuf:"varint,1,opt,name=startEventIndex,proto3" json:"startEventIndex,omitempty"`
	// Number of events covered by this signature.
	EventCount uint64 `protobuf:"varint,2,opt,name=eventCount,proto3" json:"eventCount,omitempty"`
	// SHA-256 digest of the previous HistorySignature message (the entire
	// deterministically serialized protobuf message). Absent for the first
	// signature in the chain (no predecessor). When computing the signature
	// input for the root case, this value is treated as empty (zero-length).
	PreviousSignatureDigest []byte `protobuf:"bytes,3,opt,name=previousSignatureDigest,proto3,oneof" json:"previousSignatureDigest,omitempty"`
	// SHA-256 digest over the concatenation of the raw serialized bytes of each
	// history event in this range, in order. The bytes are the exact values
	// persisted to the state store (one per history-NNNNNN key).
	EventsDigest []byte `protobuf:"bytes,4,opt,name=eventsDigest,proto3" json:"eventsDigest,omitempty"`
	// Index into the SigningCertificate table (sigcert-NNNNNN keys).
	// Multiple signatures from the same identity share the same index.
	// A new entry is appended only when the certificate rotates.
	CertificateIndex uint64 `protobuf:"varint,5,opt,name=certificateIndex,proto3" json:"certificateIndex,omitempty"`
	// Cryptographic signature over
	// SHA-256(previousSignatureDigest || eventsDigest)
	// using the private key corresponding to the referenced certificate.
	// The algorithm is determined by the certificate's key type:
	//
	//	Ed25519: raw Ed25519 signature over the input bytes
	//	ECDSA:   fixed-size r||s over SHA-256(input), each component
	//	         zero-padded to the curve byte length
	//	RSA:     PKCS#1 v1.5 with SHA-256
	Signature []byte `protobuf:"bytes,6,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

Signing metadata for a contiguous range of history events. This is metadata-only — it does NOT contain the events themselves. Events are stored once in history-NNNNNN keys; this message references them by index range and stores only the signing artifacts. Stored as individual actor state keys: signature-000000, signature-000001, etc.

func (*HistorySignature) Descriptor deprecated added in v0.12.0

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

Deprecated: Use HistorySignature.ProtoReflect.Descriptor instead.

func (*HistorySignature) GetCertificateIndex added in v0.12.0

func (x *HistorySignature) GetCertificateIndex() uint64

func (*HistorySignature) GetEventCount added in v0.12.0

func (x *HistorySignature) GetEventCount() uint64

func (*HistorySignature) GetEventsDigest added in v0.12.0

func (x *HistorySignature) GetEventsDigest() []byte

func (*HistorySignature) GetPreviousSignatureDigest added in v0.12.0

func (x *HistorySignature) GetPreviousSignatureDigest() []byte

func (*HistorySignature) GetSignature added in v0.12.0

func (x *HistorySignature) GetSignature() []byte

func (*HistorySignature) GetStartEventIndex added in v0.12.0

func (x *HistorySignature) GetStartEventIndex() uint64

func (*HistorySignature) ProtoMessage added in v0.12.0

func (*HistorySignature) ProtoMessage()

func (*HistorySignature) ProtoReflect added in v0.12.0

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

func (*HistorySignature) Reset added in v0.12.0

func (x *HistorySignature) Reset()

func (*HistorySignature) String added in v0.12.0

func (x *HistorySignature) String() string

type ListInstanceIDsRequest added in v0.11.0

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

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

Deprecated: Use ListInstanceIDsRequest.ProtoReflect.Descriptor instead.

func (*ListInstanceIDsRequest) GetContinuationToken added in v0.11.0

func (x *ListInstanceIDsRequest) GetContinuationToken() string

func (*ListInstanceIDsRequest) GetPageSize added in v0.11.0

func (x *ListInstanceIDsRequest) GetPageSize() uint32

func (*ListInstanceIDsRequest) ProtoMessage added in v0.11.0

func (*ListInstanceIDsRequest) ProtoMessage()

func (*ListInstanceIDsRequest) ProtoReflect added in v0.11.0

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

func (*ListInstanceIDsRequest) Reset added in v0.11.0

func (x *ListInstanceIDsRequest) Reset()

func (*ListInstanceIDsRequest) String added in v0.11.0

func (x *ListInstanceIDsRequest) String() string

type ListInstanceIDsResponse added in v0.11.0

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

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

Deprecated: Use ListInstanceIDsResponse.ProtoReflect.Descriptor instead.

func (*ListInstanceIDsResponse) GetContinuationToken added in v0.11.0

func (x *ListInstanceIDsResponse) GetContinuationToken() string

func (*ListInstanceIDsResponse) GetInstanceIds added in v0.11.0

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

func (*ListInstanceIDsResponse) ProtoMessage added in v0.11.0

func (*ListInstanceIDsResponse) ProtoMessage()

func (*ListInstanceIDsResponse) ProtoReflect added in v0.11.0

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

func (*ListInstanceIDsResponse) Reset added in v0.11.0

func (x *ListInstanceIDsResponse) Reset()

func (*ListInstanceIDsResponse) String added in v0.11.0

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

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

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

func (x *ParentInstanceInfo) GetAppID() string

func (*ParentInstanceInfo) GetAppNamespace added in v0.12.0

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

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

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

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

Deprecated: Use PropagatedHistory.ProtoReflect.Descriptor instead.

func (*PropagatedHistory) GetChunks added in v0.12.0

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

func (*PropagatedHistory) GetScope added in v0.12.0

func (*PropagatedHistory) ProtoMessage added in v0.12.0

func (*PropagatedHistory) ProtoMessage()

func (*PropagatedHistory) ProtoReflect added in v0.12.0

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

func (*PropagatedHistory) Reset added in v0.12.0

func (x *PropagatedHistory) Reset()

func (*PropagatedHistory) String added in v0.12.0

func (x *PropagatedHistory) String() string

type PropagatedHistoryChunk added in v0.12.0

type PropagatedHistoryChunk struct {

	// Raw deterministic bytes of each HistoryEvent in this chunk, in execution
	// order. The producer marshals each event once and signs over these exact
	// bytes; receivers digest them directly and never re-marshal, so chunk
	// verification is independent of protobuf marshaler-version stability
	// across producer and receiver. This mirrors the approach attestations use
	// for ioDigest: signed bytes travel verbatim end-to-end. The chunk's
	// length is len(rawEvents).
	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"`
	// Raw deterministic bytes of each HistorySignature message produced by the
	// chunk's app at dispatch time, covering rawEvents in order. Receivers
	// unmarshal these on demand to verify the chain. Raw bytes are required
	// because HistorySignature.previousSignatureDigest commits to the exact
	// persisted serialization; re-marshaling on the wire would break chain
	// linkage. See backend_service.proto: HistorySignature.
	RawSignatures [][]byte `protobuf:"bytes,5,rep,name=rawSignatures,proto3" json:"rawSignatures,omitempty"`
	// X.509 certificate chains of the chunk app's signing identities,
	// DER-concatenated leaf-first then intermediates (same encoding as
	// backend_service.proto: SigningCertificate.certificate). Each
	// HistorySignature in rawSignatures has a certificateIndex that indexes
	// into this list, scoped to the chunk's producer app. Raw bytes here avoid
	// a circular import on backend_service.proto's SigningCertificate type.
	SigningCertChains [][]byte `protobuf:"bytes,6,rep,name=signingCertChains,proto3" json:"signingCertChains,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 the raw event bytes its producer signed; receivers digest those bytes directly and decode them into typed HistoryEvents on demand.

func (*PropagatedHistoryChunk) Descriptor deprecated added in v0.12.0

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

Deprecated: Use PropagatedHistoryChunk.ProtoReflect.Descriptor instead.

func (*PropagatedHistoryChunk) GetAppId added in v0.12.0

func (x *PropagatedHistoryChunk) GetAppId() string

func (*PropagatedHistoryChunk) GetInstanceId added in v0.12.0

func (x *PropagatedHistoryChunk) GetInstanceId() string

func (*PropagatedHistoryChunk) GetRawEvents added in v0.12.0

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

func (*PropagatedHistoryChunk) GetRawSignatures added in v0.12.0

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

func (*PropagatedHistoryChunk) GetSigningCertChains added in v0.12.0

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

func (*PropagatedHistoryChunk) GetWorkflowName added in v0.12.0

func (x *PropagatedHistoryChunk) GetWorkflowName() string

func (*PropagatedHistoryChunk) ProtoMessage added in v0.12.0

func (*PropagatedHistoryChunk) ProtoMessage()

func (*PropagatedHistoryChunk) ProtoReflect added in v0.12.0

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

func (*PropagatedHistoryChunk) Reset added in v0.12.0

func (x *PropagatedHistoryChunk) Reset()

func (*PropagatedHistoryChunk) String added in v0.12.0

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 assignable to Request:
	//
	//	*PurgeInstancesRequest_InstanceId
	//	*PurgeInstancesRequest_PurgeInstanceFilter
	Request   isPurgeInstancesRequest_Request `protobuf_oneof:"request"`
	Recursive bool                            `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// 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"`
	// contains filtered or unexported fields
}

func (*PurgeInstancesRequest) Descriptor deprecated

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

Deprecated: Use PurgeInstancesRequest.ProtoReflect.Descriptor instead.

func (*PurgeInstancesRequest) GetForce added in v0.11.0

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 (m *PurgeInstancesRequest) GetRequest() isPurgeInstancesRequest_Request

func (*PurgeInstancesRequest) ProtoMessage

func (*PurgeInstancesRequest) ProtoMessage()

func (*PurgeInstancesRequest) ProtoReflect

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

func (*PurgeInstancesRequest) Reset

func (x *PurgeInstancesRequest) Reset()

func (*PurgeInstancesRequest) String

func (x *PurgeInstancesRequest) String() string

type PurgeInstancesRequest_InstanceId

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

type PurgeInstancesRequest_PurgeInstanceFilter

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

type PurgeInstancesResponse

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

func (*PurgeInstancesResponse) Descriptor deprecated

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

Deprecated: Use PurgeInstancesResponse.ProtoReflect.Descriptor instead.

func (*PurgeInstancesResponse) GetDeletedInstanceCount

func (x *PurgeInstancesResponse) GetDeletedInstanceCount() int32

func (*PurgeInstancesResponse) GetIsComplete added in v0.7.0

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

func (*PurgeInstancesResponse) ProtoMessage

func (*PurgeInstancesResponse) ProtoMessage()

func (*PurgeInstancesResponse) ProtoReflect

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

func (*PurgeInstancesResponse) Reset

func (x *PurgeInstancesResponse) Reset()

func (*PurgeInstancesResponse) String

func (x *PurgeInstancesResponse) String() string

type RaiseEventRequest

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

func (*RaiseEventRequest) Descriptor deprecated

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

Deprecated: Use RaiseEventRequest.ProtoReflect.Descriptor instead.

func (*RaiseEventRequest) GetInput

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

func (*RaiseEventRequest) GetInstanceId

func (x *RaiseEventRequest) GetInstanceId() string

func (*RaiseEventRequest) GetName

func (x *RaiseEventRequest) GetName() string

func (*RaiseEventRequest) ProtoMessage

func (*RaiseEventRequest) ProtoMessage()

func (*RaiseEventRequest) ProtoReflect

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

func (*RaiseEventRequest) Reset

func (x *RaiseEventRequest) Reset()

func (*RaiseEventRequest) String

func (x *RaiseEventRequest) String() string

type RaiseEventResponse

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

func (*RaiseEventResponse) Descriptor deprecated

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

Deprecated: Use RaiseEventResponse.ProtoReflect.Descriptor instead.

func (*RaiseEventResponse) ProtoMessage

func (*RaiseEventResponse) ProtoMessage()

func (*RaiseEventResponse) ProtoReflect

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

func (*RaiseEventResponse) Reset

func (x *RaiseEventResponse) Reset()

func (*RaiseEventResponse) String

func (x *RaiseEventResponse) String() string

type RerunParentInstanceInfo added in v0.11.0

type RerunParentInstanceInfo struct {

	// instanceID is the workflow instance ID this workflow has been
	// rerun from.
	InstanceID string `protobuf:"bytes,1,opt,name=instanceID,proto3" json:"instanceID,omitempty"`
	// contains filtered or unexported fields
}

RerunParentInstanceInfo is used to indicate that this workflow was started as part of a rerun operation. Contains information about the parent workflow instance which was rerun.

func (*RerunParentInstanceInfo) Descriptor deprecated added in v0.11.0

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

Deprecated: Use RerunParentInstanceInfo.ProtoReflect.Descriptor instead.

func (*RerunParentInstanceInfo) GetInstanceID added in v0.11.0

func (x *RerunParentInstanceInfo) GetInstanceID() string

func (*RerunParentInstanceInfo) ProtoMessage added in v0.11.0

func (*RerunParentInstanceInfo) ProtoMessage()

func (*RerunParentInstanceInfo) ProtoReflect added in v0.11.0

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

func (*RerunParentInstanceInfo) Reset added in v0.11.0

func (x *RerunParentInstanceInfo) Reset()

func (*RerunParentInstanceInfo) String added in v0.11.0

func (x *RerunParentInstanceInfo) String() string

type RerunWorkflowFromEventRequest added in v0.7.0

type RerunWorkflowFromEventRequest struct {

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

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

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

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

Deprecated: Use RerunWorkflowFromEventRequest.ProtoReflect.Descriptor instead.

func (*RerunWorkflowFromEventRequest) GetEventID added in v0.7.0

func (x *RerunWorkflowFromEventRequest) GetEventID() uint32

func (*RerunWorkflowFromEventRequest) GetInput added in v0.7.0

func (*RerunWorkflowFromEventRequest) GetNewChildWorkflowInstanceID added in v0.11.0

func (x *RerunWorkflowFromEventRequest) GetNewChildWorkflowInstanceID() string

func (*RerunWorkflowFromEventRequest) GetNewInstanceID added in v0.7.0

func (x *RerunWorkflowFromEventRequest) GetNewInstanceID() string

func (*RerunWorkflowFromEventRequest) GetOverwriteInput added in v0.7.0

func (x *RerunWorkflowFromEventRequest) GetOverwriteInput() bool

func (*RerunWorkflowFromEventRequest) GetSourceInstanceID added in v0.7.0

func (x *RerunWorkflowFromEventRequest) GetSourceInstanceID() string

func (*RerunWorkflowFromEventRequest) ProtoMessage added in v0.7.0

func (*RerunWorkflowFromEventRequest) ProtoMessage()

func (*RerunWorkflowFromEventRequest) ProtoReflect added in v0.7.0

func (*RerunWorkflowFromEventRequest) Reset added in v0.7.0

func (x *RerunWorkflowFromEventRequest) Reset()

func (*RerunWorkflowFromEventRequest) String added in v0.7.0

type RerunWorkflowFromEventResponse added in v0.7.0

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

RerunWorkflowFromEventResponse is the response to executing RerunWorkflowFromEvent.

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

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

Deprecated: Use RerunWorkflowFromEventResponse.ProtoReflect.Descriptor instead.

func (*RerunWorkflowFromEventResponse) GetNewInstanceID added in v0.7.0

func (x *RerunWorkflowFromEventResponse) GetNewInstanceID() string

func (*RerunWorkflowFromEventResponse) ProtoMessage added in v0.7.0

func (*RerunWorkflowFromEventResponse) ProtoMessage()

func (*RerunWorkflowFromEventResponse) ProtoReflect added in v0.7.0

func (*RerunWorkflowFromEventResponse) Reset added in v0.7.0

func (x *RerunWorkflowFromEventResponse) Reset()

func (*RerunWorkflowFromEventResponse) String added in v0.7.0

type ResumeRequest

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

func (*ResumeRequest) Descriptor deprecated

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

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetInstanceId

func (x *ResumeRequest) GetInstanceId() string

func (*ResumeRequest) GetReason

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

func (*ResumeRequest) ProtoMessage

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect

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

func (*ResumeRequest) Reset

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String

func (x *ResumeRequest) String() string

type ResumeResponse

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

func (*ResumeResponse) Descriptor deprecated

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

Deprecated: Use ResumeResponse.ProtoReflect.Descriptor instead.

func (*ResumeResponse) ProtoMessage

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) ProtoReflect

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

func (*ResumeResponse) Reset

func (x *ResumeResponse) Reset()

func (*ResumeResponse) String

func (x *ResumeResponse) String() string

type RuntimeStateStalled added in v0.11.0

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

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

Deprecated: Use RuntimeStateStalled.ProtoReflect.Descriptor instead.

func (*RuntimeStateStalled) GetDescription added in v0.11.0

func (x *RuntimeStateStalled) GetDescription() string

func (*RuntimeStateStalled) GetReason added in v0.11.0

func (x *RuntimeStateStalled) GetReason() StalledReason

func (*RuntimeStateStalled) ProtoMessage added in v0.11.0

func (*RuntimeStateStalled) ProtoMessage()

func (*RuntimeStateStalled) ProtoReflect added in v0.11.0

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

func (*RuntimeStateStalled) Reset added in v0.11.0

func (x *RuntimeStateStalled) Reset()

func (*RuntimeStateStalled) String added in v0.11.0

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"`
	Router          *TaskRouter             `protobuf:"bytes,4,opt,name=router,proto3,oneof" json:"router,omitempty"`
	TaskExecutionId string                  `protobuf:"bytes,5,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
	// 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 added in v0.12.0

func (x *ScheduleTaskAction) GetHistoryPropagationScope() HistoryPropagationScope

func (*ScheduleTaskAction) GetInput

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

func (*ScheduleTaskAction) GetName

func (x *ScheduleTaskAction) GetName() string

func (*ScheduleTaskAction) GetRouter added in v0.8.0

func (x *ScheduleTaskAction) GetRouter() *TaskRouter

func (*ScheduleTaskAction) GetTaskExecutionId added in v0.8.0

func (x *ScheduleTaskAction) GetTaskExecutionId() string

func (*ScheduleTaskAction) GetVersion

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

func (*ScheduleTaskAction) ProtoMessage

func (*ScheduleTaskAction) ProtoMessage()

func (*ScheduleTaskAction) ProtoReflect

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

func (*ScheduleTaskAction) Reset

func (x *ScheduleTaskAction) Reset()

func (*ScheduleTaskAction) String

func (x *ScheduleTaskAction) String() string

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

type SigningCertificate struct {

	// X.509 certificate chain of the signing identity. Certificates are
	// DER-encoded and concatenated directly in order: leaf first, followed by
	// intermediates. Each certificate is a self-delimiting ASN.1 SEQUENCE,
	// so the chain can be parsed by reading consecutive DER structures.
	Certificate []byte `protobuf:"bytes,1,opt,name=certificate,proto3" json:"certificate,omitempty"`
	// contains filtered or unexported fields
}

A signing identity's X.509 certificate, stored once and referenced by index from HistorySignature entries. This avoids duplicating the certificate across every signature from the same identity. Stored as individual actor state keys: sigcert-000000, sigcert-000001, etc.

func (*SigningCertificate) Descriptor deprecated added in v0.12.0

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

Deprecated: Use SigningCertificate.ProtoReflect.Descriptor instead.

func (*SigningCertificate) GetCertificate added in v0.12.0

func (x *SigningCertificate) GetCertificate() []byte

func (*SigningCertificate) ProtoMessage added in v0.12.0

func (*SigningCertificate) ProtoMessage()

func (*SigningCertificate) ProtoReflect added in v0.12.0

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

func (*SigningCertificate) Reset added in v0.12.0

func (x *SigningCertificate) Reset()

func (*SigningCertificate) String added in v0.12.0

func (x *SigningCertificate) String() string

type StalledReason added in v0.11.0

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

func (StalledReason) Descriptor added in v0.11.0

func (StalledReason) Enum added in v0.11.0

func (x StalledReason) Enum() *StalledReason

func (StalledReason) EnumDescriptor deprecated added in v0.11.0

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

Deprecated: Use StalledReason.Descriptor instead.

func (StalledReason) Number added in v0.11.0

func (StalledReason) String added in v0.11.0

func (x StalledReason) String() string

func (StalledReason) Type added in v0.11.0

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

func (*SuspendRequest) Descriptor deprecated

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

Deprecated: Use SuspendRequest.ProtoReflect.Descriptor instead.

func (*SuspendRequest) GetInstanceId

func (x *SuspendRequest) GetInstanceId() string

func (*SuspendRequest) GetReason

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

func (*SuspendRequest) ProtoMessage

func (*SuspendRequest) ProtoMessage()

func (*SuspendRequest) ProtoReflect

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

func (*SuspendRequest) Reset

func (x *SuspendRequest) Reset()

func (*SuspendRequest) String

func (x *SuspendRequest) String() string

type SuspendResponse

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

func (*SuspendResponse) Descriptor deprecated

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

Deprecated: Use SuspendResponse.ProtoReflect.Descriptor instead.

func (*SuspendResponse) ProtoMessage

func (*SuspendResponse) ProtoMessage()

func (*SuspendResponse) ProtoReflect

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

func (*SuspendResponse) Reset

func (x *SuspendResponse) Reset()

func (*SuspendResponse) String

func (x *SuspendResponse) String() string

type TaskCompletedEvent

type TaskCompletedEvent struct {
	TaskScheduledId int32                   `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	Result          *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	TaskExecutionId string                  `protobuf:"bytes,3,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
	// Attestation signed by the activity executor's SPIFFE identity.
	// Present when the activity was executed under a signing-enabled
	// configuration. Verified on inbox ingestion against the companion
	// signerCertificate and preserved in stored history for future audit
	// and forwarding via provenance bundles.
	Attestation *ActivityCompletionAttestation `protobuf:"bytes,4,opt,name=attestation,proto3,oneof" json:"attestation,omitempty"`
	// Companion: DER-encoded X.509 certificate chain of the executor's
	// signing identity (leaf first, intermediates concatenated; same
	// format as SigningCertificate.certificate in backend_service.proto).
	// Wire-only; stripped by the receiver before the event is written to
	// history-NNNNNN. The certificate lives once in ext-sigcert-NNNNNN,
	// referenced by attestation payload's signerCertDigest.
	SignerCertificate []byte `protobuf:"bytes,5,opt,name=signerCertificate,proto3,oneof" json:"signerCertificate,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskCompletedEvent) Descriptor deprecated

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

Deprecated: Use TaskCompletedEvent.ProtoReflect.Descriptor instead.

func (*TaskCompletedEvent) GetAttestation added in v0.12.0

func (*TaskCompletedEvent) GetResult

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

func (*TaskCompletedEvent) GetSignerCertificate added in v0.12.0

func (x *TaskCompletedEvent) GetSignerCertificate() []byte

func (*TaskCompletedEvent) GetTaskExecutionId added in v0.8.0

func (x *TaskCompletedEvent) GetTaskExecutionId() string

func (*TaskCompletedEvent) GetTaskScheduledId

func (x *TaskCompletedEvent) GetTaskScheduledId() int32

func (*TaskCompletedEvent) ProtoMessage

func (*TaskCompletedEvent) ProtoMessage()

func (*TaskCompletedEvent) ProtoReflect

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

func (*TaskCompletedEvent) Reset

func (x *TaskCompletedEvent) Reset()

func (*TaskCompletedEvent) String

func (x *TaskCompletedEvent) String() string

type TaskFailedEvent

type TaskFailedEvent struct {
	TaskScheduledId int32               `protobuf:"varint,1,opt,name=taskScheduledId,proto3" json:"taskScheduledId,omitempty"`
	FailureDetails  *TaskFailureDetails `protobuf:"bytes,2,opt,name=failureDetails,proto3" json:"failureDetails,omitempty"`
	TaskExecutionId string              `protobuf:"bytes,3,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
	// See TaskCompletedEvent.attestation.
	Attestation *ActivityCompletionAttestation `protobuf:"bytes,4,opt,name=attestation,proto3,oneof" json:"attestation,omitempty"`
	// Wire-only companion; see TaskCompletedEvent.signerCertificate.
	SignerCertificate []byte `protobuf:"bytes,5,opt,name=signerCertificate,proto3,oneof" json:"signerCertificate,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskFailedEvent) Descriptor deprecated

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

Deprecated: Use TaskFailedEvent.ProtoReflect.Descriptor instead.

func (*TaskFailedEvent) GetAttestation added in v0.12.0

func (x *TaskFailedEvent) GetAttestation() *ActivityCompletionAttestation

func (*TaskFailedEvent) GetFailureDetails

func (x *TaskFailedEvent) GetFailureDetails() *TaskFailureDetails

func (*TaskFailedEvent) GetSignerCertificate added in v0.12.0

func (x *TaskFailedEvent) GetSignerCertificate() []byte

func (*TaskFailedEvent) GetTaskExecutionId added in v0.8.0

func (x *TaskFailedEvent) GetTaskExecutionId() string

func (*TaskFailedEvent) GetTaskScheduledId

func (x *TaskFailedEvent) GetTaskScheduledId() int32

func (*TaskFailedEvent) ProtoMessage

func (*TaskFailedEvent) ProtoMessage()

func (*TaskFailedEvent) ProtoReflect

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

func (*TaskFailedEvent) Reset

func (x *TaskFailedEvent) Reset()

func (*TaskFailedEvent) String

func (x *TaskFailedEvent) String() string

type TaskFailureDetails

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

func (*TaskFailureDetails) Descriptor deprecated

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

Deprecated: Use TaskFailureDetails.ProtoReflect.Descriptor instead.

func (*TaskFailureDetails) GetErrorMessage

func (x *TaskFailureDetails) GetErrorMessage() string

func (*TaskFailureDetails) GetErrorType

func (x *TaskFailureDetails) GetErrorType() string

func (*TaskFailureDetails) GetInnerFailure

func (x *TaskFailureDetails) GetInnerFailure() *TaskFailureDetails

func (*TaskFailureDetails) GetIsNonRetriable

func (x *TaskFailureDetails) GetIsNonRetriable() bool

func (*TaskFailureDetails) GetStackTrace

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

func (*TaskFailureDetails) ProtoMessage

func (*TaskFailureDetails) ProtoMessage()

func (*TaskFailureDetails) ProtoReflect

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

func (*TaskFailureDetails) Reset

func (x *TaskFailureDetails) Reset()

func (*TaskFailureDetails) String

func (x *TaskFailureDetails) String() string

type TaskHubSidecarServiceClient

type TaskHubSidecarServiceClient interface {
	// Sends a hello request to the sidecar service.
	Hello(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Starts a new 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) (TaskHubSidecarService_GetWorkItemsClient, 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)
	// Rerun a Workflow from a specific event ID of a workflow instance.
	RerunWorkflowFromEvent(ctx context.Context, in *RerunWorkflowFromEventRequest, opts ...grpc.CallOption) (*RerunWorkflowFromEventResponse, 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, TaskHubSidecarService_GetWorkItemsServer) 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)
	// Rerun a Workflow from a specific event ID of a workflow instance.
	RerunWorkflowFromEvent(context.Context, *RerunWorkflowFromEventRequest) (*RerunWorkflowFromEventResponse, 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 interface {
	Recv() (*WorkItem, error)
	grpc.ClientStream
}

type TaskHubSidecarService_GetWorkItemsServer

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

type TaskRouter added in v0.8.0

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

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

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

Deprecated: Use TaskRouter.ProtoReflect.Descriptor instead.

func (*TaskRouter) GetSourceAppID added in v0.8.0

func (x *TaskRouter) GetSourceAppID() string

func (*TaskRouter) GetTargetAppID added in v0.8.0

func (x *TaskRouter) GetTargetAppID() string

func (*TaskRouter) GetTargetAppNamespace added in v0.12.0

func (x *TaskRouter) GetTargetAppNamespace() string

func (*TaskRouter) ProtoMessage added in v0.8.0

func (*TaskRouter) ProtoMessage()

func (*TaskRouter) ProtoReflect added in v0.8.0

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

func (*TaskRouter) Reset added in v0.8.0

func (x *TaskRouter) Reset()

func (*TaskRouter) String added in v0.8.0

func (x *TaskRouter) String() string

type TaskScheduledEvent

type TaskScheduledEvent struct {
	Name               string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version            *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Input              *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	ParentTraceContext *TraceContext           `protobuf:"bytes,4,opt,name=parentTraceContext,proto3" json:"parentTraceContext,omitempty"`
	TaskExecutionId    string                  `protobuf:"bytes,5,opt,name=taskExecutionId,proto3" json:"taskExecutionId,omitempty"`
	// If defined, indicates that this task was the starting point of a new
	// workflow execution as the result of a rerun operation.
	RerunParentInstanceInfo *RerunParentInstanceInfo `protobuf:"bytes,6,opt,name=rerunParentInstanceInfo,proto3,oneof" json:"rerunParentInstanceInfo,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 added in v0.12.0

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) GetRerunParentInstanceInfo added in v0.11.0

func (x *TaskScheduledEvent) GetRerunParentInstanceInfo() *RerunParentInstanceInfo

func (*TaskScheduledEvent) GetTaskExecutionId added in v0.8.0

func (x *TaskScheduledEvent) GetTaskExecutionId() string

func (*TaskScheduledEvent) GetVersion

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

func (*TaskScheduledEvent) ProtoMessage

func (*TaskScheduledEvent) ProtoMessage()

func (*TaskScheduledEvent) ProtoReflect

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

func (*TaskScheduledEvent) Reset

func (x *TaskScheduledEvent) Reset()

func (*TaskScheduledEvent) String

func (x *TaskScheduledEvent) String() string

type TerminalStatus added in v0.12.0

type TerminalStatus int32

Terminal state of a child workflow at the moment of attestation.

const (
	TerminalStatus_TERMINAL_STATUS_UNSPECIFIED TerminalStatus = 0
	TerminalStatus_TERMINAL_STATUS_COMPLETED   TerminalStatus = 1
	TerminalStatus_TERMINAL_STATUS_FAILED      TerminalStatus = 2
)

func (TerminalStatus) Descriptor added in v0.12.0

func (TerminalStatus) Enum added in v0.12.0

func (x TerminalStatus) Enum() *TerminalStatus

func (TerminalStatus) EnumDescriptor deprecated added in v0.12.0

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

Deprecated: Use TerminalStatus.Descriptor instead.

func (TerminalStatus) Number added in v0.12.0

func (TerminalStatus) String added in v0.12.0

func (x TerminalStatus) String() string

func (TerminalStatus) Type added in v0.12.0

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

func (*TerminateRequest) Descriptor deprecated

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

Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.

func (*TerminateRequest) GetInstanceId

func (x *TerminateRequest) GetInstanceId() string

func (*TerminateRequest) GetOutput

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

func (*TerminateRequest) GetRecursive

func (x *TerminateRequest) GetRecursive() bool

func (*TerminateRequest) ProtoMessage

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) ProtoReflect

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

func (*TerminateRequest) Reset

func (x *TerminateRequest) Reset()

func (*TerminateRequest) String

func (x *TerminateRequest) String() string

type TerminateResponse

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

func (*TerminateResponse) Descriptor deprecated

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

Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.

func (*TerminateResponse) ProtoMessage

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) ProtoReflect

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

func (*TerminateResponse) Reset

func (x *TerminateResponse) Reset()

func (*TerminateResponse) String

func (x *TerminateResponse) String() string

type TerminateWorkflowAction added in v0.12.0

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

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

Deprecated: Use TerminateWorkflowAction.ProtoReflect.Descriptor instead.

func (*TerminateWorkflowAction) GetInstanceId added in v0.12.0

func (x *TerminateWorkflowAction) GetInstanceId() string

func (*TerminateWorkflowAction) GetReason added in v0.12.0

func (*TerminateWorkflowAction) GetRecurse added in v0.12.0

func (x *TerminateWorkflowAction) GetRecurse() bool

func (*TerminateWorkflowAction) ProtoMessage added in v0.12.0

func (*TerminateWorkflowAction) ProtoMessage()

func (*TerminateWorkflowAction) ProtoReflect added in v0.12.0

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

func (*TerminateWorkflowAction) Reset added in v0.12.0

func (x *TerminateWorkflowAction) Reset()

func (*TerminateWorkflowAction) String added in v0.12.0

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 defined, indicates that this task was the starting point of a new
	// workflow execution as the result of a rerun operation.
	RerunParentInstanceInfo *RerunParentInstanceInfo `protobuf:"bytes,3,opt,name=rerunParentInstanceInfo,proto3,oneof" json:"rerunParentInstanceInfo,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 added in v0.12.0

func (x *TimerCreatedEvent) GetActivityRetry() *TimerOriginActivityRetry

func (*TimerCreatedEvent) GetChildWorkflowRetry added in v0.12.0

func (x *TimerCreatedEvent) GetChildWorkflowRetry() *TimerOriginChildWorkflowRetry

func (*TimerCreatedEvent) GetCreateTimer added in v0.12.0

func (x *TimerCreatedEvent) GetCreateTimer() *TimerOriginCreateTimer

func (*TimerCreatedEvent) GetExternalEvent added in v0.12.0

func (x *TimerCreatedEvent) GetExternalEvent() *TimerOriginExternalEvent

func (*TimerCreatedEvent) GetFireAt

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

func (*TimerCreatedEvent) GetName added in v0.7.0

func (x *TimerCreatedEvent) GetName() string

func (*TimerCreatedEvent) GetOrigin added in v0.12.0

func (m *TimerCreatedEvent) GetOrigin() isTimerCreatedEvent_Origin

func (*TimerCreatedEvent) GetRerunParentInstanceInfo added in v0.11.0

func (x *TimerCreatedEvent) GetRerunParentInstanceInfo() *RerunParentInstanceInfo

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

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

type TimerCreatedEvent_ChildWorkflowRetry added in v0.12.0

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

type TimerCreatedEvent_CreateTimer added in v0.12.0

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

type TimerCreatedEvent_ExternalEvent added in v0.12.0

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

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

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

Deprecated: Use TimerOriginActivityRetry.ProtoReflect.Descriptor instead.

func (*TimerOriginActivityRetry) GetTaskExecutionId added in v0.12.0

func (x *TimerOriginActivityRetry) GetTaskExecutionId() string

func (*TimerOriginActivityRetry) ProtoMessage added in v0.12.0

func (*TimerOriginActivityRetry) ProtoMessage()

func (*TimerOriginActivityRetry) ProtoReflect added in v0.12.0

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

func (*TimerOriginActivityRetry) Reset added in v0.12.0

func (x *TimerOriginActivityRetry) Reset()

func (*TimerOriginActivityRetry) String added in v0.12.0

func (x *TimerOriginActivityRetry) String() string

type TimerOriginChildWorkflowRetry added in v0.12.0

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

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

Deprecated: Use TimerOriginChildWorkflowRetry.ProtoReflect.Descriptor instead.

func (*TimerOriginChildWorkflowRetry) GetInstanceId added in v0.12.0

func (x *TimerOriginChildWorkflowRetry) GetInstanceId() string

func (*TimerOriginChildWorkflowRetry) ProtoMessage added in v0.12.0

func (*TimerOriginChildWorkflowRetry) ProtoMessage()

func (*TimerOriginChildWorkflowRetry) ProtoReflect added in v0.12.0

func (*TimerOriginChildWorkflowRetry) Reset added in v0.12.0

func (x *TimerOriginChildWorkflowRetry) Reset()

func (*TimerOriginChildWorkflowRetry) String added in v0.12.0

type TimerOriginCreateTimer added in v0.12.0

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

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

Deprecated: Use TimerOriginCreateTimer.ProtoReflect.Descriptor instead.

func (*TimerOriginCreateTimer) ProtoMessage added in v0.12.0

func (*TimerOriginCreateTimer) ProtoMessage()

func (*TimerOriginCreateTimer) ProtoReflect added in v0.12.0

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

func (*TimerOriginCreateTimer) Reset added in v0.12.0

func (x *TimerOriginCreateTimer) Reset()

func (*TimerOriginCreateTimer) String added in v0.12.0

func (x *TimerOriginCreateTimer) String() string

type TimerOriginExternalEvent added in v0.12.0

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

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

Deprecated: Use TimerOriginExternalEvent.ProtoReflect.Descriptor instead.

func (*TimerOriginExternalEvent) GetName added in v0.12.0

func (x *TimerOriginExternalEvent) GetName() string

func (*TimerOriginExternalEvent) ProtoMessage added in v0.12.0

func (*TimerOriginExternalEvent) ProtoMessage()

func (*TimerOriginExternalEvent) ProtoReflect added in v0.12.0

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

func (*TimerOriginExternalEvent) Reset added in v0.12.0

func (x *TimerOriginExternalEvent) Reset()

func (*TimerOriginExternalEvent) String added in v0.12.0

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.

func (UnimplementedTaskHubSidecarServiceServer) CompleteActivityTask

func (UnimplementedTaskHubSidecarServiceServer) CompleteOrchestratorTask

func (UnimplementedTaskHubSidecarServiceServer) CompleteWorkflowTask added in v0.12.0

func (UnimplementedTaskHubSidecarServiceServer) GetInstance

func (UnimplementedTaskHubSidecarServiceServer) GetInstanceHistory added in v0.11.0

func (UnimplementedTaskHubSidecarServiceServer) Hello

func (UnimplementedTaskHubSidecarServiceServer) ListInstanceIDs added in v0.11.0

func (UnimplementedTaskHubSidecarServiceServer) PurgeInstances

func (UnimplementedTaskHubSidecarServiceServer) RaiseEvent

func (UnimplementedTaskHubSidecarServiceServer) RerunWorkflowFromEvent added in v0.7.0

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 assignable 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 (m *WorkItem) GetRequest() isWorkItem_Request

func (*WorkItem) GetWorkflowRequest added in v0.12.0

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

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

type WorkerCapability added in v0.7.0

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

func (WorkerCapability) Descriptor added in v0.7.0

func (WorkerCapability) Enum added in v0.7.0

func (WorkerCapability) EnumDescriptor deprecated added in v0.7.0

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

Deprecated: Use WorkerCapability.Descriptor instead.

func (WorkerCapability) Number added in v0.7.0

func (WorkerCapability) String added in v0.7.0

func (x WorkerCapability) String() string

func (WorkerCapability) Type added in v0.7.0

type WorkflowAction added in v0.12.0

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

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

Deprecated: Use WorkflowAction.ProtoReflect.Descriptor instead.

func (*WorkflowAction) GetCompleteOrchestration deprecated added in v0.12.0

func (x *WorkflowAction) GetCompleteOrchestration() *CompleteWorkflowAction

Deprecated: Use GetCompleteWorkflow instead.

func (*WorkflowAction) GetCompleteWorkflow added in v0.12.0

func (x *WorkflowAction) GetCompleteWorkflow() *CompleteWorkflowAction

func (*WorkflowAction) GetCreateChildWorkflow added in v0.12.0

func (x *WorkflowAction) GetCreateChildWorkflow() *CreateChildWorkflowAction

func (*WorkflowAction) GetCreateDetachedWorkflow added in v0.12.0

func (x *WorkflowAction) GetCreateDetachedWorkflow() *CreateDetachedWorkflowAction

func (*WorkflowAction) GetCreateSubOrchestration deprecated added in v0.12.0

func (x *WorkflowAction) GetCreateSubOrchestration() *CreateChildWorkflowAction

Deprecated: Use GetCreateChildWorkflow instead.

func (*WorkflowAction) GetCreateTimer added in v0.12.0

func (x *WorkflowAction) GetCreateTimer() *CreateTimerAction

func (*WorkflowAction) GetId added in v0.12.0

func (x *WorkflowAction) GetId() int32

func (*WorkflowAction) GetOrchestratorVersionNotAvailable deprecated added in v0.12.0

func (x *WorkflowAction) GetOrchestratorVersionNotAvailable() *WorkflowVersionNotAvailableAction

Deprecated: Use GetWorkflowVersionNotAvailable instead.

func (*WorkflowAction) GetRouter added in v0.12.0

func (x *WorkflowAction) GetRouter() *TaskRouter

func (*WorkflowAction) GetScheduleTask added in v0.12.0

func (x *WorkflowAction) GetScheduleTask() *ScheduleTaskAction

func (*WorkflowAction) GetSendEvent added in v0.12.0

func (x *WorkflowAction) GetSendEvent() *SendEventAction

func (*WorkflowAction) GetTerminateOrchestration deprecated added in v0.12.0

func (x *WorkflowAction) GetTerminateOrchestration() *TerminateWorkflowAction

Deprecated: Use GetTerminateWorkflow instead.

func (*WorkflowAction) GetTerminateWorkflow added in v0.12.0

func (x *WorkflowAction) GetTerminateWorkflow() *TerminateWorkflowAction

func (*WorkflowAction) GetWorkflowActionType added in v0.12.0

func (m *WorkflowAction) GetWorkflowActionType() isWorkflowAction_WorkflowActionType

func (*WorkflowAction) GetWorkflowVersionNotAvailable added in v0.12.0

func (x *WorkflowAction) GetWorkflowVersionNotAvailable() *WorkflowVersionNotAvailableAction

func (*WorkflowAction) ProtoMessage added in v0.12.0

func (*WorkflowAction) ProtoMessage()

func (*WorkflowAction) ProtoReflect added in v0.12.0

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

func (*WorkflowAction) Reset added in v0.12.0

func (x *WorkflowAction) Reset()

func (*WorkflowAction) String added in v0.12.0

func (x *WorkflowAction) String() string

type WorkflowAction_CompleteWorkflow added in v0.12.0

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

type WorkflowAction_CreateChildWorkflow added in v0.12.0

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

type WorkflowAction_CreateDetachedWorkflow added in v0.12.0

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

type WorkflowAction_CreateTimer added in v0.12.0

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

type WorkflowAction_ScheduleTask added in v0.12.0

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

type WorkflowAction_SendEvent added in v0.12.0

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

type WorkflowAction_TerminateWorkflow added in v0.12.0

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

type WorkflowAction_WorkflowVersionNotAvailable added in v0.12.0

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

type WorkflowCompletedEvent added in v0.12.0

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

func (*WorkflowCompletedEvent) Descriptor deprecated added in v0.12.0

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

Deprecated: Use WorkflowCompletedEvent.ProtoReflect.Descriptor instead.

func (*WorkflowCompletedEvent) ProtoMessage added in v0.12.0

func (*WorkflowCompletedEvent) ProtoMessage()

func (*WorkflowCompletedEvent) ProtoReflect added in v0.12.0

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

func (*WorkflowCompletedEvent) Reset added in v0.12.0

func (x *WorkflowCompletedEvent) Reset()

func (*WorkflowCompletedEvent) String added in v0.12.0

func (x *WorkflowCompletedEvent) String() string

type WorkflowInstance added in v0.12.0

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

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

Deprecated: Use WorkflowInstance.ProtoReflect.Descriptor instead.

func (*WorkflowInstance) GetExecutionId added in v0.12.0

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

func (*WorkflowInstance) GetInstanceId added in v0.12.0

func (x *WorkflowInstance) GetInstanceId() string

func (*WorkflowInstance) ProtoMessage added in v0.12.0

func (*WorkflowInstance) ProtoMessage()

func (*WorkflowInstance) ProtoReflect added in v0.12.0

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

func (*WorkflowInstance) Reset added in v0.12.0

func (x *WorkflowInstance) Reset()

func (*WorkflowInstance) String added in v0.12.0

func (x *WorkflowInstance) String() string

type WorkflowMessage added in v0.12.0

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

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

Deprecated: Use WorkflowMessage.ProtoReflect.Descriptor instead.

func (*WorkflowMessage) GetEvent added in v0.12.0

func (x *WorkflowMessage) GetEvent() *HistoryEvent

func (*WorkflowMessage) GetInstance added in v0.12.0

func (x *WorkflowMessage) GetInstance() *WorkflowInstance

func (*WorkflowMessage) ProtoMessage added in v0.12.0

func (*WorkflowMessage) ProtoMessage()

func (*WorkflowMessage) ProtoReflect added in v0.12.0

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

func (*WorkflowMessage) Reset added in v0.12.0

func (x *WorkflowMessage) Reset()

func (*WorkflowMessage) String added in v0.12.0

func (x *WorkflowMessage) String() string

type WorkflowMetadata added in v0.12.0

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

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

Deprecated: Use WorkflowMetadata.ProtoReflect.Descriptor instead.

func (*WorkflowMetadata) GetCompletedAt added in v0.12.0

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

func (*WorkflowMetadata) GetCreatedAt added in v0.12.0

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

func (*WorkflowMetadata) GetCustomStatus added in v0.12.0

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

func (*WorkflowMetadata) GetFailureDetails added in v0.12.0

func (x *WorkflowMetadata) GetFailureDetails() *TaskFailureDetails

func (*WorkflowMetadata) GetInput added in v0.12.0

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

func (*WorkflowMetadata) GetInstanceId added in v0.12.0

func (x *WorkflowMetadata) GetInstanceId() string

func (*WorkflowMetadata) GetLastUpdatedAt added in v0.12.0

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

func (*WorkflowMetadata) GetName added in v0.12.0

func (x *WorkflowMetadata) GetName() string

func (*WorkflowMetadata) GetOutput added in v0.12.0

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

func (*WorkflowMetadata) GetParentAppId added in v0.12.0

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

func (*WorkflowMetadata) GetParentInstanceId added in v0.12.0

func (x *WorkflowMetadata) GetParentInstanceId() string

func (*WorkflowMetadata) GetRuntimeStatus added in v0.12.0

func (x *WorkflowMetadata) GetRuntimeStatus() OrchestrationStatus

func (*WorkflowMetadata) GetStartedAt added in v0.12.0

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

func (*WorkflowMetadata) GetVersion added in v0.12.0

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

func (*WorkflowMetadata) ProtoMessage added in v0.12.0

func (*WorkflowMetadata) ProtoMessage()

func (*WorkflowMetadata) ProtoReflect added in v0.12.0

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

func (*WorkflowMetadata) Reset added in v0.12.0

func (x *WorkflowMetadata) Reset()

func (*WorkflowMetadata) String added in v0.12.0

func (x *WorkflowMetadata) String() string

type WorkflowRequest added in v0.12.0

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

func (*WorkflowRequest) Descriptor deprecated added in v0.12.0

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

Deprecated: Use WorkflowRequest.ProtoReflect.Descriptor instead.

func (*WorkflowRequest) GetExecutionId added in v0.12.0

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

func (*WorkflowRequest) GetInstanceId added in v0.12.0

func (x *WorkflowRequest) GetInstanceId() string

func (*WorkflowRequest) GetNewEvents added in v0.12.0

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

func (*WorkflowRequest) GetPastEvents added in v0.12.0

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

func (*WorkflowRequest) GetPropagatedHistory added in v0.12.0

func (x *WorkflowRequest) GetPropagatedHistory() *PropagatedHistory

func (*WorkflowRequest) GetRequiresHistoryStreaming added in v0.12.0

func (x *WorkflowRequest) GetRequiresHistoryStreaming() bool

func (*WorkflowRequest) GetRouter added in v0.12.0

func (x *WorkflowRequest) GetRouter() *TaskRouter

func (*WorkflowRequest) ProtoMessage added in v0.12.0

func (*WorkflowRequest) ProtoMessage()

func (*WorkflowRequest) ProtoReflect added in v0.12.0

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

func (*WorkflowRequest) Reset added in v0.12.0

func (x *WorkflowRequest) Reset()

func (*WorkflowRequest) String added in v0.12.0

func (x *WorkflowRequest) String() string

type WorkflowResponse added in v0.12.0

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

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

Deprecated: Use WorkflowResponse.ProtoReflect.Descriptor instead.

func (*WorkflowResponse) GetActions added in v0.12.0

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

func (*WorkflowResponse) GetCompletionToken added in v0.12.0

func (x *WorkflowResponse) GetCompletionToken() string

func (*WorkflowResponse) GetCustomStatus added in v0.12.0

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

func (*WorkflowResponse) GetInstanceId added in v0.12.0

func (x *WorkflowResponse) GetInstanceId() string

func (*WorkflowResponse) GetNumEventsProcessed added in v0.12.0

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

func (*WorkflowResponse) GetVersion added in v0.12.0

func (x *WorkflowResponse) GetVersion() *WorkflowVersion

func (*WorkflowResponse) ProtoMessage added in v0.12.0

func (*WorkflowResponse) ProtoMessage()

func (*WorkflowResponse) ProtoReflect added in v0.12.0

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

func (*WorkflowResponse) Reset added in v0.12.0

func (x *WorkflowResponse) Reset()

func (*WorkflowResponse) String added in v0.12.0

func (x *WorkflowResponse) String() string

type WorkflowRuntimeState added in v0.12.0

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

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

Deprecated: Use WorkflowRuntimeState.ProtoReflect.Descriptor instead.

func (*WorkflowRuntimeState) GetCompletedEvent added in v0.12.0

func (x *WorkflowRuntimeState) GetCompletedEvent() *ExecutionCompletedEvent

func (*WorkflowRuntimeState) GetCompletedTime added in v0.12.0

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

func (*WorkflowRuntimeState) GetContinuedAsNew added in v0.12.0

func (x *WorkflowRuntimeState) GetContinuedAsNew() bool

func (*WorkflowRuntimeState) GetCreatedTime added in v0.12.0

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

func (*WorkflowRuntimeState) GetCustomStatus added in v0.12.0

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

func (*WorkflowRuntimeState) GetInstanceId added in v0.12.0

func (x *WorkflowRuntimeState) GetInstanceId() string

func (*WorkflowRuntimeState) GetIsSuspended added in v0.12.0

func (x *WorkflowRuntimeState) GetIsSuspended() bool

func (*WorkflowRuntimeState) GetLastUpdatedTime added in v0.12.0

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

func (*WorkflowRuntimeState) GetNewEvents added in v0.12.0

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

func (*WorkflowRuntimeState) GetOldEvents added in v0.12.0

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

func (*WorkflowRuntimeState) GetPendingMessages added in v0.12.0

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

func (*WorkflowRuntimeState) GetPendingTasks added in v0.12.0

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

func (*WorkflowRuntimeState) GetPendingTimers added in v0.12.0

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

func (*WorkflowRuntimeState) GetStalled added in v0.12.0

func (x *WorkflowRuntimeState) GetStalled() *RuntimeStateStalled

func (*WorkflowRuntimeState) GetStartEvent added in v0.12.0

func (x *WorkflowRuntimeState) GetStartEvent() *ExecutionStartedEvent

func (*WorkflowRuntimeState) ProtoMessage added in v0.12.0

func (*WorkflowRuntimeState) ProtoMessage()

func (*WorkflowRuntimeState) ProtoReflect added in v0.12.0

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

func (*WorkflowRuntimeState) Reset added in v0.12.0

func (x *WorkflowRuntimeState) Reset()

func (*WorkflowRuntimeState) String added in v0.12.0

func (x *WorkflowRuntimeState) String() string

type WorkflowRuntimeStateMessage added in v0.12.0

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

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

Deprecated: Use WorkflowRuntimeStateMessage.ProtoReflect.Descriptor instead.

func (*WorkflowRuntimeStateMessage) GetHistoryEvent added in v0.12.0

func (x *WorkflowRuntimeStateMessage) GetHistoryEvent() *HistoryEvent

func (*WorkflowRuntimeStateMessage) GetPropagatedHistory added in v0.12.0

func (x *WorkflowRuntimeStateMessage) GetPropagatedHistory() *PropagatedHistory

func (*WorkflowRuntimeStateMessage) GetTargetInstanceId added in v0.12.0

func (x *WorkflowRuntimeStateMessage) GetTargetInstanceId() string

func (*WorkflowRuntimeStateMessage) ProtoMessage added in v0.12.0

func (*WorkflowRuntimeStateMessage) ProtoMessage()

func (*WorkflowRuntimeStateMessage) ProtoReflect added in v0.12.0

func (*WorkflowRuntimeStateMessage) Reset added in v0.12.0

func (x *WorkflowRuntimeStateMessage) Reset()

func (*WorkflowRuntimeStateMessage) String added in v0.12.0

func (x *WorkflowRuntimeStateMessage) String() string

type WorkflowStartedEvent added in v0.12.0

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

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

Deprecated: Use WorkflowStartedEvent.ProtoReflect.Descriptor instead.

func (*WorkflowStartedEvent) GetVersion added in v0.12.0

func (x *WorkflowStartedEvent) GetVersion() *WorkflowVersion

func (*WorkflowStartedEvent) ProtoMessage added in v0.12.0

func (*WorkflowStartedEvent) ProtoMessage()

func (*WorkflowStartedEvent) ProtoReflect added in v0.12.0

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

func (*WorkflowStartedEvent) Reset added in v0.12.0

func (x *WorkflowStartedEvent) Reset()

func (*WorkflowStartedEvent) String added in v0.12.0

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

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

func (*WorkflowState) GetCreatedTimestamp added in v0.12.0

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

func (*WorkflowState) GetCustomStatus

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

func (*WorkflowState) GetExecutionId added in v0.12.0

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

func (*WorkflowState) GetFailureDetails added in v0.12.0

func (x *WorkflowState) GetFailureDetails() *TaskFailureDetails

func (*WorkflowState) GetInput added in v0.12.0

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

func (*WorkflowState) GetInstanceId added in v0.12.0

func (x *WorkflowState) GetInstanceId() string

func (*WorkflowState) GetLastUpdatedTimestamp added in v0.12.0

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

func (*WorkflowState) GetName added in v0.12.0

func (x *WorkflowState) GetName() string

func (*WorkflowState) GetOutput added in v0.12.0

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

func (*WorkflowState) GetParentAppId added in v0.12.0

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

func (*WorkflowState) GetParentInstanceId added in v0.12.0

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

func (*WorkflowState) GetScheduledStartTimestamp added in v0.12.0

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

func (*WorkflowState) GetStartedAt added in v0.12.0

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

func (*WorkflowState) GetTags added in v0.12.0

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

func (*WorkflowState) GetVersion added in v0.12.0

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

func (*WorkflowState) GetWorkflowStatus added in v0.12.0

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

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

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

Deprecated: Use WorkflowVersion.ProtoReflect.Descriptor instead.

func (*WorkflowVersion) GetName added in v0.12.0

func (x *WorkflowVersion) GetName() string

func (*WorkflowVersion) GetPatches added in v0.12.0

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

func (*WorkflowVersion) ProtoMessage added in v0.12.0

func (*WorkflowVersion) ProtoMessage()

func (*WorkflowVersion) ProtoReflect added in v0.12.0

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

func (*WorkflowVersion) Reset added in v0.12.0

func (x *WorkflowVersion) Reset()

func (*WorkflowVersion) String added in v0.12.0

func (x *WorkflowVersion) String() string

type WorkflowVersionNotAvailableAction added in v0.12.0

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

func (*WorkflowVersionNotAvailableAction) Descriptor deprecated added in v0.12.0

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

Deprecated: Use WorkflowVersionNotAvailableAction.ProtoReflect.Descriptor instead.

func (*WorkflowVersionNotAvailableAction) ProtoMessage added in v0.12.0

func (*WorkflowVersionNotAvailableAction) ProtoMessage()

func (*WorkflowVersionNotAvailableAction) ProtoReflect added in v0.12.0

func (*WorkflowVersionNotAvailableAction) Reset added in v0.12.0

func (*WorkflowVersionNotAvailableAction) String added in v0.12.0

Jump to

Keyboard shortcuts

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