persistence

package
v1.26.0-120.1 Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2024 License: MIT Imports: 21 Imported by: 4

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var (
	BuildId_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "STATE_ACTIVE",
		2: "STATE_DELETED",
	}
	BuildId_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"STATE_ACTIVE":      1,
		"STATE_DELETED":     2,
	}
)

Enum value maps for BuildId_State.

View Source 
var File_temporal_server_api_persistence_v1_cluster_metadata_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_executions_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_history_tree_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_hsm_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_namespaces_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_nexus_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_predicates_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_queue_metadata_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_queues_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_task_queues_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_tasks_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_update_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_persistence_v1_workflow_mutable_state_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ActivityInfo 

type ActivityInfo struct {
	Version               int64                  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	ScheduledEventBatchId int64                  `` /* 129-byte string literal not displayed */
	ScheduledTime         *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	StartedEventId        int64                  `protobuf:"varint,5,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
	StartedTime           *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`
	ActivityId            string                 `protobuf:"bytes,8,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	RequestId             string                 `protobuf:"bytes,9,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeout *durationpb.Duration `` /* 132-byte string literal not displayed */
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToCloseTimeout *durationpb.Duration `` /* 132-byte string literal not displayed */
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	StartToCloseTimeout         *durationpb.Duration   `protobuf:"bytes,12,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,omitempty"`
	HeartbeatTimeout            *durationpb.Duration   `protobuf:"bytes,13,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3" json:"heartbeat_timeout,omitempty"`
	CancelRequested             bool                   `protobuf:"varint,14,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	CancelRequestId             int64                  `protobuf:"varint,15,opt,name=cancel_request_id,json=cancelRequestId,proto3" json:"cancel_request_id,omitempty"`
	TimerTaskStatus             int32                  `protobuf:"varint,16,opt,name=timer_task_status,json=timerTaskStatus,proto3" json:"timer_task_status,omitempty"`
	Attempt                     int32                  `protobuf:"varint,17,opt,name=attempt,proto3" json:"attempt,omitempty"`
	TaskQueue                   string                 `protobuf:"bytes,18,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	StartedIdentity             string                 `protobuf:"bytes,19,opt,name=started_identity,json=startedIdentity,proto3" json:"started_identity,omitempty"`
	HasRetryPolicy              bool                   `protobuf:"varint,20,opt,name=has_retry_policy,json=hasRetryPolicy,proto3" json:"has_retry_policy,omitempty"`
	RetryInitialInterval        *durationpb.Duration   `protobuf:"bytes,21,opt,name=retry_initial_interval,json=retryInitialInterval,proto3" json:"retry_initial_interval,omitempty"`
	RetryMaximumInterval        *durationpb.Duration   `protobuf:"bytes,22,opt,name=retry_maximum_interval,json=retryMaximumInterval,proto3" json:"retry_maximum_interval,omitempty"`
	RetryMaximumAttempts        int32                  `protobuf:"varint,23,opt,name=retry_maximum_attempts,json=retryMaximumAttempts,proto3" json:"retry_maximum_attempts,omitempty"`
	RetryExpirationTime         *timestamppb.Timestamp `protobuf:"bytes,24,opt,name=retry_expiration_time,json=retryExpirationTime,proto3" json:"retry_expiration_time,omitempty"`
	RetryBackoffCoefficient     float64                `` /* 135-byte string literal not displayed */
	RetryNonRetryableErrorTypes []string               `` /* 149-byte string literal not displayed */
	RetryLastFailure            *v17.Failure           `protobuf:"bytes,27,opt,name=retry_last_failure,json=retryLastFailure,proto3" json:"retry_last_failure,omitempty"`
	RetryLastWorkerIdentity     string                 `` /* 135-byte string literal not displayed */
	ScheduledEventId            int64                  `protobuf:"varint,30,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	LastHeartbeatDetails        *v12.Payloads          `protobuf:"bytes,31,opt,name=last_heartbeat_details,json=lastHeartbeatDetails,proto3" json:"last_heartbeat_details,omitempty"`
	LastHeartbeatUpdateTime     *timestamppb.Timestamp `` /* 135-byte string literal not displayed */
	// When true, it means the activity is assigned to the build ID of its workflow (only set for old versioning)
	// Deprecated. use `use_workflow_build_id`
	UseCompatibleVersion bool              `protobuf:"varint,33,opt,name=use_compatible_version,json=useCompatibleVersion,proto3" json:"use_compatible_version,omitempty"`
	ActivityType         *v12.ActivityType `protobuf:"bytes,34,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
	// Absence of `assigned_build_id` generally means this task is on an "unversioned" task queue.
	// In rare cases, it can also mean that the task queue is versioned but we failed to write activity's
	// independently-assigned build ID to the database. This case heals automatically once the task is dispatched.
	//
	// Types that are assignable to BuildIdInfo:
	//
	//	*ActivityInfo_UseWorkflowBuildIdInfo_
	//	*ActivityInfo_LastIndependentlyAssignedBuildId
	BuildIdInfo isActivityInfo_BuildIdInfo `protobuf_oneof:"build_id_info"`
	// The version stamp of the worker to whom this activity was most-recently dispatched
	LastWorkerVersionStamp        *v12.WorkerVersionStamp `` /* 132-byte string literal not displayed */
	LastUpdateVersionedTransition *VersionedTransition    `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

activity_map column

func (*ActivityInfo) Descriptor deprecated 

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

Deprecated: Use ActivityInfo.ProtoReflect.Descriptor instead.

func (*ActivityInfo) Equal 

func (this *ActivityInfo) Equal(that interface{}) bool

Equal returns whether two ActivityInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ActivityInfo) GetActivityId 

func (x *ActivityInfo) GetActivityId() string

func (*ActivityInfo) GetActivityType added in v1.22.0 

func (x *ActivityInfo) GetActivityType() *v12.ActivityType

func (*ActivityInfo) GetAttempt 

func (x *ActivityInfo) GetAttempt() int32

func (*ActivityInfo) GetBuildIdInfo added in v1.24.0 

func (m *ActivityInfo) GetBuildIdInfo() isActivityInfo_BuildIdInfo

func (*ActivityInfo) GetCancelRequestId 

func (x *ActivityInfo) GetCancelRequestId() int64

func (*ActivityInfo) GetCancelRequested 

func (x *ActivityInfo) GetCancelRequested() bool

func (*ActivityInfo) GetHasRetryPolicy 

func (x *ActivityInfo) GetHasRetryPolicy() bool

func (*ActivityInfo) GetHeartbeatTimeout 

func (x *ActivityInfo) GetHeartbeatTimeout() *durationpb.Duration

func (*ActivityInfo) GetLastHeartbeatDetails 

func (x *ActivityInfo) GetLastHeartbeatDetails() *v12.Payloads

func (*ActivityInfo) GetLastHeartbeatUpdateTime 

func (x *ActivityInfo) GetLastHeartbeatUpdateTime() *timestamppb.Timestamp

func (*ActivityInfo) GetLastIndependentlyAssignedBuildId added in v1.24.0 

func (x *ActivityInfo) GetLastIndependentlyAssignedBuildId() string

func (*ActivityInfo) GetLastUpdateVersionedTransition added in v1.25.0 

func (x *ActivityInfo) GetLastUpdateVersionedTransition() *VersionedTransition

func (*ActivityInfo) GetLastWorkerVersionStamp added in v1.24.0 

func (x *ActivityInfo) GetLastWorkerVersionStamp() *v12.WorkerVersionStamp

func (*ActivityInfo) GetRequestId 

func (x *ActivityInfo) GetRequestId() string

func (*ActivityInfo) GetRetryBackoffCoefficient 

func (x *ActivityInfo) GetRetryBackoffCoefficient() float64

func (*ActivityInfo) GetRetryExpirationTime 

func (x *ActivityInfo) GetRetryExpirationTime() *timestamppb.Timestamp

func (*ActivityInfo) GetRetryInitialInterval 

func (x *ActivityInfo) GetRetryInitialInterval() *durationpb.Duration

func (*ActivityInfo) GetRetryLastFailure 

func (x *ActivityInfo) GetRetryLastFailure() *v17.Failure

func (*ActivityInfo) GetRetryLastWorkerIdentity 

func (x *ActivityInfo) GetRetryLastWorkerIdentity() string

func (*ActivityInfo) GetRetryMaximumAttempts 

func (x *ActivityInfo) GetRetryMaximumAttempts() int32

func (*ActivityInfo) GetRetryMaximumInterval 

func (x *ActivityInfo) GetRetryMaximumInterval() *durationpb.Duration

func (*ActivityInfo) GetRetryNonRetryableErrorTypes 

func (x *ActivityInfo) GetRetryNonRetryableErrorTypes() []string

func (*ActivityInfo) GetScheduleToCloseTimeout 

func (x *ActivityInfo) GetScheduleToCloseTimeout() *durationpb.Duration

func (*ActivityInfo) GetScheduleToStartTimeout 

func (x *ActivityInfo) GetScheduleToStartTimeout() *durationpb.Duration

func (*ActivityInfo) GetScheduledEventBatchId 

func (x *ActivityInfo) GetScheduledEventBatchId() int64

func (*ActivityInfo) GetScheduledEventId added in v1.17.0 

func (x *ActivityInfo) GetScheduledEventId() int64

func (*ActivityInfo) GetScheduledTime 

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

func (*ActivityInfo) GetStartToCloseTimeout 

func (x *ActivityInfo) GetStartToCloseTimeout() *durationpb.Duration

func (*ActivityInfo) GetStartedEventId added in v1.17.0 

func (x *ActivityInfo) GetStartedEventId() int64

func (*ActivityInfo) GetStartedIdentity 

func (x *ActivityInfo) GetStartedIdentity() string

func (*ActivityInfo) GetStartedTime 

func (x *ActivityInfo) GetStartedTime() *timestamppb.Timestamp

func (*ActivityInfo) GetTaskQueue 

func (x *ActivityInfo) GetTaskQueue() string

func (*ActivityInfo) GetTimerTaskStatus 

func (x *ActivityInfo) GetTimerTaskStatus() int32

func (*ActivityInfo) GetUseCompatibleVersion added in v1.21.0 

func (x *ActivityInfo) GetUseCompatibleVersion() bool

func (*ActivityInfo) GetUseWorkflowBuildIdInfo added in v1.24.0 

func (x *ActivityInfo) GetUseWorkflowBuildIdInfo() *ActivityInfo_UseWorkflowBuildIdInfo

func (*ActivityInfo) GetVersion 

func (x *ActivityInfo) GetVersion() int64

func (*ActivityInfo) Marshal 

func (val *ActivityInfo) Marshal() ([]byte, error)

Marshal an object of type ActivityInfo to the protobuf v3 wire format

func (*ActivityInfo) ProtoMessage 

func (*ActivityInfo) ProtoMessage()

func (*ActivityInfo) ProtoReflect added in v1.23.0 

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

func (*ActivityInfo) Reset 

func (x *ActivityInfo) Reset()

func (*ActivityInfo) Size 

func (val *ActivityInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ActivityInfo) String 

func (x *ActivityInfo) String() string

func (*ActivityInfo) Unmarshal 

func (val *ActivityInfo) Unmarshal(buf []byte) error

Unmarshal an object of type ActivityInfo from the protobuf v3 wire format

type ActivityInfo_LastIndependentlyAssignedBuildId added in v1.24.0 

type ActivityInfo_LastIndependentlyAssignedBuildId struct {
	// This means the activity is independently versioned and not bound to the build ID of its workflow.
	// If the task fails and is scheduled again, the assigned build ID may change according to the latest versioning
	// rules. This value also updates if a redirect rule is applied to the activity task to reflect the build ID
	// of the worker who received the task.
	LastIndependentlyAssignedBuildId string `protobuf:"bytes,36,opt,name=last_independently_assigned_build_id,json=lastIndependentlyAssignedBuildId,proto3,oneof"`
}

type ActivityInfo_UseWorkflowBuildIdInfo added in v1.24.0 

type ActivityInfo_UseWorkflowBuildIdInfo struct {

	// build ID of the wf when this activity started last time (which is the build ID of
	// the worker who received this activity)
	LastUsedBuildId string `protobuf:"bytes,1,opt,name=last_used_build_id,json=lastUsedBuildId,proto3" json:"last_used_build_id,omitempty"`
	// workflows redirect_counter value when this activity started last time
	LastRedirectCounter int64 `protobuf:"varint,2,opt,name=last_redirect_counter,json=lastRedirectCounter,proto3" json:"last_redirect_counter,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivityInfo_UseWorkflowBuildIdInfo) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use ActivityInfo_UseWorkflowBuildIdInfo.ProtoReflect.Descriptor instead.

func (*ActivityInfo_UseWorkflowBuildIdInfo) GetLastRedirectCounter added in v1.24.0 

func (x *ActivityInfo_UseWorkflowBuildIdInfo) GetLastRedirectCounter() int64

func (*ActivityInfo_UseWorkflowBuildIdInfo) GetLastUsedBuildId added in v1.24.0 

func (x *ActivityInfo_UseWorkflowBuildIdInfo) GetLastUsedBuildId() string

func (*ActivityInfo_UseWorkflowBuildIdInfo) ProtoMessage added in v1.24.0 

func (*ActivityInfo_UseWorkflowBuildIdInfo) ProtoMessage()

func (*ActivityInfo_UseWorkflowBuildIdInfo) ProtoReflect added in v1.24.0 

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

func (*ActivityInfo_UseWorkflowBuildIdInfo) Reset added in v1.24.0 

func (x *ActivityInfo_UseWorkflowBuildIdInfo) Reset()

func (*ActivityInfo_UseWorkflowBuildIdInfo) String added in v1.24.0 

func (x *ActivityInfo_UseWorkflowBuildIdInfo) String() string

type ActivityInfo_UseWorkflowBuildIdInfo_ added in v1.24.0 

type ActivityInfo_UseWorkflowBuildIdInfo_ struct {
	// When present, it means this activity is assigned to the build ID of its workflow.
	UseWorkflowBuildIdInfo *ActivityInfo_UseWorkflowBuildIdInfo `protobuf:"bytes,35,opt,name=use_workflow_build_id_info,json=useWorkflowBuildIdInfo,proto3,oneof"`
}

type AllocatedTaskInfo 

type AllocatedTaskInfo struct {
	Data   *TaskInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	TaskId int64     `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

task column

func (*AllocatedTaskInfo) Descriptor deprecated 

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

Deprecated: Use AllocatedTaskInfo.ProtoReflect.Descriptor instead.

func (*AllocatedTaskInfo) Equal 

func (this *AllocatedTaskInfo) Equal(that interface{}) bool

Equal returns whether two AllocatedTaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AllocatedTaskInfo) GetData 

func (x *AllocatedTaskInfo) GetData() *TaskInfo

func (*AllocatedTaskInfo) GetTaskId 

func (x *AllocatedTaskInfo) GetTaskId() int64

func (*AllocatedTaskInfo) Marshal 

func (val *AllocatedTaskInfo) Marshal() ([]byte, error)

Marshal an object of type AllocatedTaskInfo to the protobuf v3 wire format

func (*AllocatedTaskInfo) ProtoMessage 

func (*AllocatedTaskInfo) ProtoMessage()

func (*AllocatedTaskInfo) ProtoReflect added in v1.23.0 

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

func (*AllocatedTaskInfo) Reset 

func (x *AllocatedTaskInfo) Reset()

func (*AllocatedTaskInfo) Size 

func (val *AllocatedTaskInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AllocatedTaskInfo) String 

func (x *AllocatedTaskInfo) String() string

func (*AllocatedTaskInfo) Unmarshal 

func (val *AllocatedTaskInfo) Unmarshal(buf []byte) error

Unmarshal an object of type AllocatedTaskInfo from the protobuf v3 wire format

type AndPredicateAttributes added in v1.17.3 

type AndPredicateAttributes struct {
	Predicates []*Predicate `protobuf:"bytes,1,rep,name=predicates,proto3" json:"predicates,omitempty"`
	// contains filtered or unexported fields
}

func (*AndPredicateAttributes) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use AndPredicateAttributes.ProtoReflect.Descriptor instead.

func (*AndPredicateAttributes) Equal added in v1.17.3 

func (this *AndPredicateAttributes) Equal(that interface{}) bool

Equal returns whether two AndPredicateAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AndPredicateAttributes) GetPredicates added in v1.17.3 

func (x *AndPredicateAttributes) GetPredicates() []*Predicate

func (*AndPredicateAttributes) Marshal added in v1.17.3 

func (val *AndPredicateAttributes) Marshal() ([]byte, error)

Marshal an object of type AndPredicateAttributes to the protobuf v3 wire format

func (*AndPredicateAttributes) ProtoMessage added in v1.17.3 

func (*AndPredicateAttributes) ProtoMessage()

func (*AndPredicateAttributes) ProtoReflect added in v1.23.0 

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

func (*AndPredicateAttributes) Reset added in v1.17.3 

func (x *AndPredicateAttributes) Reset()

func (*AndPredicateAttributes) Size added in v1.17.3 

func (val *AndPredicateAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AndPredicateAttributes) String added in v1.17.3 

func (x *AndPredicateAttributes) String() string

func (*AndPredicateAttributes) Unmarshal added in v1.17.3 

func (val *AndPredicateAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type AndPredicateAttributes from the protobuf v3 wire format

type ArchivalTaskInfo added in v1.19.0 

type ArchivalTaskInfo struct {
	TaskId         int64                  `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	NamespaceId    string                 `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId     string                 `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId          string                 `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskType       v1.TaskType            `` /* 129-byte string literal not displayed */
	Version        int64                  `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	VisibilityTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
	// contains filtered or unexported fields
}

func (*ArchivalTaskInfo) Descriptor deprecated added in v1.19.0 

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

Deprecated: Use ArchivalTaskInfo.ProtoReflect.Descriptor instead.

func (*ArchivalTaskInfo) Equal added in v1.19.0 

func (this *ArchivalTaskInfo) Equal(that interface{}) bool

Equal returns whether two ArchivalTaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ArchivalTaskInfo) GetNamespaceId added in v1.19.0 

func (x *ArchivalTaskInfo) GetNamespaceId() string

func (*ArchivalTaskInfo) GetRunId added in v1.19.0 

func (x *ArchivalTaskInfo) GetRunId() string

func (*ArchivalTaskInfo) GetTaskId added in v1.19.0 

func (x *ArchivalTaskInfo) GetTaskId() int64

func (*ArchivalTaskInfo) GetTaskType added in v1.19.0 

func (x *ArchivalTaskInfo) GetTaskType() v1.TaskType

func (*ArchivalTaskInfo) GetVersion added in v1.19.0 

func (x *ArchivalTaskInfo) GetVersion() int64

func (*ArchivalTaskInfo) GetVisibilityTime added in v1.19.0 

func (x *ArchivalTaskInfo) GetVisibilityTime() *timestamppb.Timestamp

func (*ArchivalTaskInfo) GetWorkflowId added in v1.19.0 

func (x *ArchivalTaskInfo) GetWorkflowId() string

func (*ArchivalTaskInfo) Marshal added in v1.19.0 

func (val *ArchivalTaskInfo) Marshal() ([]byte, error)

Marshal an object of type ArchivalTaskInfo to the protobuf v3 wire format

func (*ArchivalTaskInfo) ProtoMessage added in v1.19.0 

func (*ArchivalTaskInfo) ProtoMessage()

func (*ArchivalTaskInfo) ProtoReflect added in v1.23.0 

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

func (*ArchivalTaskInfo) Reset added in v1.19.0 

func (x *ArchivalTaskInfo) Reset()

func (*ArchivalTaskInfo) Size added in v1.19.0 

func (val *ArchivalTaskInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ArchivalTaskInfo) String added in v1.19.0 

func (x *ArchivalTaskInfo) String() string

func (*ArchivalTaskInfo) Unmarshal added in v1.19.0 

func (val *ArchivalTaskInfo) Unmarshal(buf []byte) error

Unmarshal an object of type ArchivalTaskInfo from the protobuf v3 wire format

type AssignmentRule added in v1.24.0 

type AssignmentRule struct {
	Rule *v11.BuildIdAssignmentRule `protobuf:"bytes,1,opt,name=rule,proto3" json:"rule,omitempty"`
	// (-- api-linter: core::0142::time-field-type=disabled
	//
	//	aip.dev/not-precedent: Using HLC instead of wall clock. --)
	CreateTimestamp *v1.HybridLogicalClock `protobuf:"bytes,2,opt,name=create_timestamp,json=createTimestamp,proto3" json:"create_timestamp,omitempty"`
	//	when delete_timestamp is present the rule should be treated as deleted
	//
	// (-- api-linter: core::0142::time-field-type=disabled
	//
	//	aip.dev/not-precedent: Using HLC instead of wall clock. --)
	DeleteTimestamp *v1.HybridLogicalClock `protobuf:"bytes,3,opt,name=delete_timestamp,json=deleteTimestamp,proto3" json:"delete_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*AssignmentRule) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use AssignmentRule.ProtoReflect.Descriptor instead.

func (*AssignmentRule) Equal added in v1.24.0 

func (this *AssignmentRule) Equal(that interface{}) bool

Equal returns whether two AssignmentRule values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AssignmentRule) GetCreateTimestamp added in v1.24.0 

func (x *AssignmentRule) GetCreateTimestamp() *v1.HybridLogicalClock

func (*AssignmentRule) GetDeleteTimestamp added in v1.24.0 

func (x *AssignmentRule) GetDeleteTimestamp() *v1.HybridLogicalClock

func (*AssignmentRule) GetRule added in v1.24.0 

func (x *AssignmentRule) GetRule() *v11.BuildIdAssignmentRule

func (*AssignmentRule) Marshal added in v1.24.0 

func (val *AssignmentRule) Marshal() ([]byte, error)

Marshal an object of type AssignmentRule to the protobuf v3 wire format

func (*AssignmentRule) ProtoMessage added in v1.24.0 

func (*AssignmentRule) ProtoMessage()

func (*AssignmentRule) ProtoReflect added in v1.24.0 

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

func (*AssignmentRule) Reset added in v1.24.0 

func (x *AssignmentRule) Reset()

func (*AssignmentRule) Size added in v1.24.0 

func (val *AssignmentRule) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AssignmentRule) String added in v1.24.0 

func (x *AssignmentRule) String() string

func (*AssignmentRule) Unmarshal added in v1.24.0 

func (val *AssignmentRule) Unmarshal(buf []byte) error

Unmarshal an object of type AssignmentRule from the protobuf v3 wire format

type BuildId added in v1.21.0 

type BuildId struct {
	Id    string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State BuildId_State `protobuf:"varint,2,opt,name=state,proto3,enum=temporal.server.api.persistence.v1.BuildId_State" json:"state,omitempty"`
	// HLC timestamp representing when the state was updated or the when build ID was originally inserted.
	// (-- api-linter: core::0142::time-field-type=disabled
	//
	//	aip.dev/not-precedent: Using HLC instead of wall clock. --)
	StateUpdateTimestamp *v1.HybridLogicalClock `protobuf:"bytes,3,opt,name=state_update_timestamp,json=stateUpdateTimestamp,proto3" json:"state_update_timestamp,omitempty"`
	// HLC timestamp representing when this build ID was last made default in its version set.
	// (-- api-linter: core::0142::time-field-type=disabled
	//
	//	aip.dev/not-precedent: Using HLC instead of wall clock. --)
	BecameDefaultTimestamp *v1.HybridLogicalClock `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

BuildId is an identifier with a timestamped status used to identify workers for task queue versioning purposes.

func (*BuildId) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use BuildId.ProtoReflect.Descriptor instead.

func (*BuildId) Equal added in v1.21.0 

func (this *BuildId) Equal(that interface{}) bool

Equal returns whether two BuildId values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*BuildId) GetBecameDefaultTimestamp added in v1.21.0 

func (x *BuildId) GetBecameDefaultTimestamp() *v1.HybridLogicalClock

func (*BuildId) GetId added in v1.21.0 

func (x *BuildId) GetId() string

func (*BuildId) GetState added in v1.21.0 

func (x *BuildId) GetState() BuildId_State

func (*BuildId) GetStateUpdateTimestamp added in v1.21.0 

func (x *BuildId) GetStateUpdateTimestamp() *v1.HybridLogicalClock

func (*BuildId) Marshal added in v1.21.0 

func (val *BuildId) Marshal() ([]byte, error)

Marshal an object of type BuildId to the protobuf v3 wire format

func (*BuildId) ProtoMessage added in v1.21.0 

func (*BuildId) ProtoMessage()

func (*BuildId) ProtoReflect added in v1.23.0 

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

func (*BuildId) Reset added in v1.21.0 

func (x *BuildId) Reset()

func (*BuildId) Size added in v1.21.0 

func (val *BuildId) Size() int

Size returns the size of the object, in bytes, once serialized

func (*BuildId) String added in v1.21.0 

func (x *BuildId) String() string

func (*BuildId) Unmarshal added in v1.21.0 

func (val *BuildId) Unmarshal(buf []byte) error

Unmarshal an object of type BuildId from the protobuf v3 wire format

type BuildId_State added in v1.21.0 

type BuildId_State int32
const (
	STATE_UNSPECIFIED BuildId_State = 0
	STATE_ACTIVE      BuildId_State = 1
	STATE_DELETED     BuildId_State = 2
)

func (BuildId_State) Descriptor added in v1.23.0 

func (BuildId_State) Descriptor() protoreflect.EnumDescriptor

func (BuildId_State) Enum added in v1.23.0 

func (x BuildId_State) Enum() *BuildId_State

func (BuildId_State) EnumDescriptor deprecated added in v1.21.0 

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

Deprecated: Use BuildId_State.Descriptor instead.

func (BuildId_State) Number added in v1.23.0 

func (x BuildId_State) Number() protoreflect.EnumNumber

func (BuildId_State) String added in v1.21.0 

func (x BuildId_State) String() string

func (BuildId_State) Type added in v1.23.0 

func (BuildId_State) Type() protoreflect.EnumType

type Callback added in v1.25.0 

type Callback struct {

	// Types that are assignable to Variant:
	//
	//	*Callback_Nexus_
	//	*Callback_Hsm
	Variant isCallback_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

func (*Callback) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use Callback.ProtoReflect.Descriptor instead.

func (*Callback) Equal added in v1.25.0 

func (this *Callback) Equal(that interface{}) bool

Equal returns whether two Callback values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*Callback) GetHsm added in v1.25.0 

func (x *Callback) GetHsm() *Callback_HSM

func (*Callback) GetNexus added in v1.25.0 

func (x *Callback) GetNexus() *Callback_Nexus

func (*Callback) GetVariant added in v1.25.0 

func (m *Callback) GetVariant() isCallback_Variant

func (*Callback) Marshal added in v1.25.0 

func (val *Callback) Marshal() ([]byte, error)

Marshal an object of type Callback to the protobuf v3 wire format

func (*Callback) ProtoMessage added in v1.25.0 

func (*Callback) ProtoMessage()

func (*Callback) ProtoReflect added in v1.25.0 

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

func (*Callback) Reset added in v1.25.0 

func (x *Callback) Reset()

func (*Callback) Size added in v1.25.0 

func (val *Callback) Size() int

Size returns the size of the object, in bytes, once serialized

func (*Callback) String added in v1.25.0 

func (x *Callback) String() string

func (*Callback) Unmarshal added in v1.25.0 

func (val *Callback) Unmarshal(buf []byte) error

Unmarshal an object of type Callback from the protobuf v3 wire format

type CallbackInfo added in v1.24.0 

type CallbackInfo struct {

	// Information on how this callback should be invoked (e.g. its URL and type).
	Callback *Callback `protobuf:"bytes,1,opt,name=callback,proto3" json:"callback,omitempty"`
	// Trigger for this callback.
	Trigger *CallbackInfo_Trigger `protobuf:"bytes,2,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// The time when the callback was registered.
	RegistrationTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=registration_time,json=registrationTime,proto3" json:"registration_time,omitempty"`
	State            v1.CallbackState       `protobuf:"varint,4,opt,name=state,proto3,enum=temporal.server.api.enums.v1.CallbackState" json:"state,omitempty"`
	// The number of attempts made to deliver the callback.
	// This number represents a minimum bound since the attempt is incremented after the callback request completes.
	Attempt int32 `protobuf:"varint,5,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// The time when the last attempt completed.
	LastAttemptCompleteTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
	// The last attempt's failure, if any.
	LastAttemptFailure *v17.Failure `protobuf:"bytes,7,opt,name=last_attempt_failure,json=lastAttemptFailure,proto3" json:"last_attempt_failure,omitempty"`
	// The time when the next attempt is scheduled.
	NextAttemptScheduleTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CallbackInfo) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use CallbackInfo.ProtoReflect.Descriptor instead.

func (*CallbackInfo) Equal added in v1.24.0 

func (this *CallbackInfo) Equal(that interface{}) bool

Equal returns whether two CallbackInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CallbackInfo) GetAttempt added in v1.25.0 

func (x *CallbackInfo) GetAttempt() int32

func (*CallbackInfo) GetCallback added in v1.25.0 

func (x *CallbackInfo) GetCallback() *Callback

func (*CallbackInfo) GetLastAttemptCompleteTime added in v1.25.0 

func (x *CallbackInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp

func (*CallbackInfo) GetLastAttemptFailure added in v1.25.0 

func (x *CallbackInfo) GetLastAttemptFailure() *v17.Failure

func (*CallbackInfo) GetNextAttemptScheduleTime added in v1.25.0 

func (x *CallbackInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp

func (*CallbackInfo) GetRegistrationTime added in v1.25.0 

func (x *CallbackInfo) GetRegistrationTime() *timestamppb.Timestamp

func (*CallbackInfo) GetState added in v1.25.0 

func (x *CallbackInfo) GetState() v1.CallbackState

func (*CallbackInfo) GetTrigger added in v1.25.0 

func (x *CallbackInfo) GetTrigger() *CallbackInfo_Trigger

func (*CallbackInfo) Marshal added in v1.24.0 

func (val *CallbackInfo) Marshal() ([]byte, error)

Marshal an object of type CallbackInfo to the protobuf v3 wire format

func (*CallbackInfo) ProtoMessage added in v1.24.0 

func (*CallbackInfo) ProtoMessage()

func (*CallbackInfo) ProtoReflect added in v1.24.0 

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

func (*CallbackInfo) Reset added in v1.24.0 

func (x *CallbackInfo) Reset()

func (*CallbackInfo) Size added in v1.24.0 

func (val *CallbackInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CallbackInfo) String added in v1.24.0 

func (x *CallbackInfo) String() string

func (*CallbackInfo) Unmarshal added in v1.24.0 

func (val *CallbackInfo) Unmarshal(buf []byte) error

Unmarshal an object of type CallbackInfo from the protobuf v3 wire format

type CallbackInfo_Trigger added in v1.25.0 

type CallbackInfo_Trigger struct {

	// Types that are assignable to Variant:
	//
	//	*CallbackInfo_Trigger_WorkflowClosed
	Variant isCallbackInfo_Trigger_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

func (*CallbackInfo_Trigger) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use CallbackInfo_Trigger.ProtoReflect.Descriptor instead.

func (*CallbackInfo_Trigger) GetVariant added in v1.25.0 

func (m *CallbackInfo_Trigger) GetVariant() isCallbackInfo_Trigger_Variant

func (*CallbackInfo_Trigger) GetWorkflowClosed added in v1.25.0 

func (x *CallbackInfo_Trigger) GetWorkflowClosed() *CallbackInfo_WorkflowClosed

func (*CallbackInfo_Trigger) ProtoMessage added in v1.25.0 

func (*CallbackInfo_Trigger) ProtoMessage()

func (*CallbackInfo_Trigger) ProtoReflect added in v1.25.0 

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

func (*CallbackInfo_Trigger) Reset added in v1.25.0 

func (x *CallbackInfo_Trigger) Reset()

func (*CallbackInfo_Trigger) String added in v1.25.0 

func (x *CallbackInfo_Trigger) String() string

type CallbackInfo_Trigger_WorkflowClosed added in v1.25.0 

type CallbackInfo_Trigger_WorkflowClosed struct {
	WorkflowClosed *CallbackInfo_WorkflowClosed `protobuf:"bytes,1,opt,name=workflow_closed,json=workflowClosed,proto3,oneof"`
}

type CallbackInfo_WorkflowClosed added in v1.25.0 

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

Trigger for when the workflow is closed.

func (*CallbackInfo_WorkflowClosed) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use CallbackInfo_WorkflowClosed.ProtoReflect.Descriptor instead.

func (*CallbackInfo_WorkflowClosed) ProtoMessage added in v1.25.0 

func (*CallbackInfo_WorkflowClosed) ProtoMessage()

func (*CallbackInfo_WorkflowClosed) ProtoReflect added in v1.25.0 

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

func (*CallbackInfo_WorkflowClosed) Reset added in v1.25.0 

func (x *CallbackInfo_WorkflowClosed) Reset()

func (*CallbackInfo_WorkflowClosed) String added in v1.25.0 

func (x *CallbackInfo_WorkflowClosed) String() string

type Callback_HSM added in v1.25.0 

type Callback_HSM struct {

	// namespace id of the target state machine.
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// ID of the workflow that the target state machine is attached to.
	WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// Run id of said workflow.
	RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// A reference to the state machine.
	Ref *StateMachineRef `protobuf:"bytes,4,opt,name=ref,proto3" json:"ref,omitempty"`
	// The method name to invoke. Methods must be explicitly registered for the target state machine in the state
	// machine registry, and accept an argument type of HistoryEvent that is the completion event of the completed
	// workflow.
	Method string `protobuf:"bytes,5,opt,name=method,proto3" json:"method,omitempty"`
	// contains filtered or unexported fields
}

func (*Callback_HSM) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use Callback_HSM.ProtoReflect.Descriptor instead.

func (*Callback_HSM) GetMethod added in v1.25.0 

func (x *Callback_HSM) GetMethod() string

func (*Callback_HSM) GetNamespaceId added in v1.25.0 

func (x *Callback_HSM) GetNamespaceId() string

func (*Callback_HSM) GetRef added in v1.25.0 

func (x *Callback_HSM) GetRef() *StateMachineRef

func (*Callback_HSM) GetRunId added in v1.25.0 

func (x *Callback_HSM) GetRunId() string

func (*Callback_HSM) GetWorkflowId added in v1.25.0 

func (x *Callback_HSM) GetWorkflowId() string

func (*Callback_HSM) ProtoMessage added in v1.25.0 

func (*Callback_HSM) ProtoMessage()

func (*Callback_HSM) ProtoReflect added in v1.25.0 

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

func (*Callback_HSM) Reset added in v1.25.0 

func (x *Callback_HSM) Reset()

func (*Callback_HSM) String added in v1.25.0 

func (x *Callback_HSM) String() string

type Callback_Hsm added in v1.25.0 

type Callback_Hsm struct {
	Hsm *Callback_HSM `protobuf:"bytes,3,opt,name=hsm,proto3,oneof"`
}

type Callback_Nexus added in v1.25.0 

type Callback_Nexus struct {

	// Callback URL.
	// (-- api-linter: core::0140::uri=disabled
	//
	//	aip.dev/not-precedent: Not respecting aip here. --)
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Header to attach to callback request.
	Header map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Callback_Nexus) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use Callback_Nexus.ProtoReflect.Descriptor instead.

func (*Callback_Nexus) GetHeader added in v1.25.0 

func (x *Callback_Nexus) GetHeader() map[string]string

func (*Callback_Nexus) GetUrl added in v1.25.0 

func (x *Callback_Nexus) GetUrl() string

func (*Callback_Nexus) ProtoMessage added in v1.25.0 

func (*Callback_Nexus) ProtoMessage()

func (*Callback_Nexus) ProtoReflect added in v1.25.0 

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

func (*Callback_Nexus) Reset added in v1.25.0 

func (x *Callback_Nexus) Reset()

func (*Callback_Nexus) String added in v1.25.0 

func (x *Callback_Nexus) String() string

type Callback_Nexus_ added in v1.25.0 

type Callback_Nexus_ struct {
	Nexus *Callback_Nexus `protobuf:"bytes,2,opt,name=nexus,proto3,oneof"`
}

type Checksum 

type Checksum struct {
	Version int32             `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Flavor  v1.ChecksumFlavor `protobuf:"varint,2,opt,name=flavor,proto3,enum=temporal.server.api.enums.v1.ChecksumFlavor" json:"flavor,omitempty"`
	Value   []byte            `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

checksum column

func (*Checksum) Descriptor deprecated 

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

Deprecated: Use Checksum.ProtoReflect.Descriptor instead.

func (*Checksum) Equal 

func (this *Checksum) Equal(that interface{}) bool

Equal returns whether two Checksum values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*Checksum) GetFlavor 

func (x *Checksum) GetFlavor() v1.ChecksumFlavor

func (*Checksum) GetValue 

func (x *Checksum) GetValue() []byte

func (*Checksum) GetVersion 

func (x *Checksum) GetVersion() int32

func (*Checksum) Marshal 

func (val *Checksum) Marshal() ([]byte, error)

Marshal an object of type Checksum to the protobuf v3 wire format

func (*Checksum) ProtoMessage 

func (*Checksum) ProtoMessage()

func (*Checksum) ProtoReflect added in v1.23.0 

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

func (*Checksum) Reset 

func (x *Checksum) Reset()

func (*Checksum) Size 

func (val *Checksum) Size() int

Size returns the size of the object, in bytes, once serialized

func (*Checksum) String 

func (x *Checksum) String() string

func (*Checksum) Unmarshal 

func (val *Checksum) Unmarshal(buf []byte) error

Unmarshal an object of type Checksum from the protobuf v3 wire format

type ChildExecutionInfo 

type ChildExecutionInfo struct {
	Version                       int64                 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	InitiatedEventBatchId         int64                 `` /* 129-byte string literal not displayed */
	StartedEventId                int64                 `protobuf:"varint,3,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
	StartedWorkflowId             string                `protobuf:"bytes,5,opt,name=started_workflow_id,json=startedWorkflowId,proto3" json:"started_workflow_id,omitempty"`
	StartedRunId                  string                `protobuf:"bytes,6,opt,name=started_run_id,json=startedRunId,proto3" json:"started_run_id,omitempty"`
	CreateRequestId               string                `protobuf:"bytes,8,opt,name=create_request_id,json=createRequestId,proto3" json:"create_request_id,omitempty"`
	Namespace                     string                `protobuf:"bytes,9,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowTypeName              string                `protobuf:"bytes,10,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
	ParentClosePolicy             v16.ParentClosePolicy `` /* 161-byte string literal not displayed */
	InitiatedEventId              int64                 `protobuf:"varint,12,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"`
	Clock                         *v14.VectorClock      `protobuf:"bytes,13,opt,name=clock,proto3" json:"clock,omitempty"`
	NamespaceId                   string                `protobuf:"bytes,14,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	LastUpdateVersionedTransition *VersionedTransition  `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

child_executions_map column

func (*ChildExecutionInfo) Descriptor deprecated 

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

Deprecated: Use ChildExecutionInfo.ProtoReflect.Descriptor instead.

func (*ChildExecutionInfo) Equal 

func (this *ChildExecutionInfo) Equal(that interface{}) bool

Equal returns whether two ChildExecutionInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ChildExecutionInfo) GetClock added in v1.17.0 

func (x *ChildExecutionInfo) GetClock() *v14.VectorClock

func (*ChildExecutionInfo) GetCreateRequestId 

func (x *ChildExecutionInfo) GetCreateRequestId() string

func (*ChildExecutionInfo) GetInitiatedEventBatchId 

func (x *ChildExecutionInfo) GetInitiatedEventBatchId() int64

func (*ChildExecutionInfo) GetInitiatedEventId added in v1.17.0 

func (x *ChildExecutionInfo) GetInitiatedEventId() int64

func (*ChildExecutionInfo) GetLastUpdateVersionedTransition added in v1.25.0 

func (x *ChildExecutionInfo) GetLastUpdateVersionedTransition() *VersionedTransition

func (*ChildExecutionInfo) GetNamespace 

func (x *ChildExecutionInfo) GetNamespace() string

func (*ChildExecutionInfo) GetNamespaceId added in v1.17.0 

func (x *ChildExecutionInfo) GetNamespaceId() string

func (*ChildExecutionInfo) GetParentClosePolicy 

func (x *ChildExecutionInfo) GetParentClosePolicy() v16.ParentClosePolicy

func (*ChildExecutionInfo) GetStartedEventId added in v1.17.0 

func (x *ChildExecutionInfo) GetStartedEventId() int64

func (*ChildExecutionInfo) GetStartedRunId 

func (x *ChildExecutionInfo) GetStartedRunId() string

func (*ChildExecutionInfo) GetStartedWorkflowId 

func (x *ChildExecutionInfo) GetStartedWorkflowId() string

func (*ChildExecutionInfo) GetVersion 

func (x *ChildExecutionInfo) GetVersion() int64

func (*ChildExecutionInfo) GetWorkflowTypeName 

func (x *ChildExecutionInfo) GetWorkflowTypeName() string

func (*ChildExecutionInfo) Marshal 

func (val *ChildExecutionInfo) Marshal() ([]byte, error)

Marshal an object of type ChildExecutionInfo to the protobuf v3 wire format

func (*ChildExecutionInfo) ProtoMessage 

func (*ChildExecutionInfo) ProtoMessage()

func (*ChildExecutionInfo) ProtoReflect added in v1.23.0 

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

func (*ChildExecutionInfo) Reset 

func (x *ChildExecutionInfo) Reset()

func (*ChildExecutionInfo) Size 

func (val *ChildExecutionInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ChildExecutionInfo) String 

func (x *ChildExecutionInfo) String() string

func (*ChildExecutionInfo) Unmarshal 

func (val *ChildExecutionInfo) Unmarshal(buf []byte) error

Unmarshal an object of type ChildExecutionInfo from the protobuf v3 wire format

type ClusterMetadata 

type ClusterMetadata struct {
	ClusterName              string                            `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	HistoryShardCount        int32                             `protobuf:"varint,2,opt,name=history_shard_count,json=historyShardCount,proto3" json:"history_shard_count,omitempty"`
	ClusterId                string                            `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	VersionInfo              *v1.VersionInfo                   `protobuf:"bytes,4,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
	IndexSearchAttributes    map[string]*IndexSearchAttributes `` /* 214-byte string literal not displayed */
	ClusterAddress           string                            `protobuf:"bytes,6,opt,name=cluster_address,json=clusterAddress,proto3" json:"cluster_address,omitempty"`
	HttpAddress              string                            `protobuf:"bytes,13,opt,name=http_address,json=httpAddress,proto3" json:"http_address,omitempty"`
	FailoverVersionIncrement int64                             `` /* 136-byte string literal not displayed */
	InitialFailoverVersion   int64                             `` /* 130-byte string literal not displayed */
	IsGlobalNamespaceEnabled bool                              `` /* 138-byte string literal not displayed */
	IsConnectionEnabled      bool                              `protobuf:"varint,10,opt,name=is_connection_enabled,json=isConnectionEnabled,proto3" json:"is_connection_enabled,omitempty"`
	UseClusterIdMembership   bool                              `` /* 133-byte string literal not displayed */
	Tags                     map[string]string                 `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

data column

func (*ClusterMetadata) Descriptor deprecated 

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

Deprecated: Use ClusterMetadata.ProtoReflect.Descriptor instead.

func (*ClusterMetadata) Equal 

func (this *ClusterMetadata) Equal(that interface{}) bool

Equal returns whether two ClusterMetadata values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ClusterMetadata) GetClusterAddress added in v1.14.0 

func (x *ClusterMetadata) GetClusterAddress() string

func (*ClusterMetadata) GetClusterId 

func (x *ClusterMetadata) GetClusterId() string

func (*ClusterMetadata) GetClusterName 

func (x *ClusterMetadata) GetClusterName() string

func (*ClusterMetadata) GetFailoverVersionIncrement added in v1.14.0 

func (x *ClusterMetadata) GetFailoverVersionIncrement() int64

func (*ClusterMetadata) GetHistoryShardCount 

func (x *ClusterMetadata) GetHistoryShardCount() int32

func (*ClusterMetadata) GetHttpAddress added in v1.24.0 

func (x *ClusterMetadata) GetHttpAddress() string

func (*ClusterMetadata) GetIndexSearchAttributes added in v1.10.0 

func (x *ClusterMetadata) GetIndexSearchAttributes() map[string]*IndexSearchAttributes

func (*ClusterMetadata) GetInitialFailoverVersion added in v1.14.0 

func (x *ClusterMetadata) GetInitialFailoverVersion() int64

func (*ClusterMetadata) GetIsConnectionEnabled added in v1.14.0 

func (x *ClusterMetadata) GetIsConnectionEnabled() bool

func (*ClusterMetadata) GetIsGlobalNamespaceEnabled added in v1.14.0 

func (x *ClusterMetadata) GetIsGlobalNamespaceEnabled() bool

func (*ClusterMetadata) GetTags added in v1.22.0 

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

func (*ClusterMetadata) GetUseClusterIdMembership added in v1.19.0 

func (x *ClusterMetadata) GetUseClusterIdMembership() bool

func (*ClusterMetadata) GetVersionInfo 

func (x *ClusterMetadata) GetVersionInfo() *v1.VersionInfo

func (*ClusterMetadata) Marshal 

func (val *ClusterMetadata) Marshal() ([]byte, error)

Marshal an object of type ClusterMetadata to the protobuf v3 wire format

func (*ClusterMetadata) ProtoMessage 

func (*ClusterMetadata) ProtoMessage()

func (*ClusterMetadata) ProtoReflect added in v1.23.0 

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

func (*ClusterMetadata) Reset 

func (x *ClusterMetadata) Reset()

func (*ClusterMetadata) Size 

func (val *ClusterMetadata) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ClusterMetadata) String 

func (x *ClusterMetadata) String() string

func (*ClusterMetadata) Unmarshal 

func (val *ClusterMetadata) Unmarshal(buf []byte) error

Unmarshal an object of type ClusterMetadata from the protobuf v3 wire format

type CompatibleVersionSet added in v1.21.0 

type CompatibleVersionSet struct {

	// Set IDs are used internally by matching.
	// A set typically has one set ID and extra care is taken to enforce this.
	// In some situations, including:
	//   - Replication race between task queue user data and history events
	//   - Replication split-brain + later merge
	//   - Delayed user data propagation between partitions
	//   - Cross-task-queue activities/child workflows/CAN where the user has not set up parallel
	//     versioning data
	//
	// we have to guess the set id for a build ID. If that happens, and then the build ID is
	// discovered to be in a different set, then the sets will be merged and both (or more)
	// build ids will be preserved, so that we don't lose tasks.
	// The first set id is considered the "primary", and the others are "demoted". Once a build
	// id is demoted, it cannot be made the primary again.
	SetIds []string `protobuf:"bytes,1,rep,name=set_ids,json=setIds,proto3" json:"set_ids,omitempty"`
	// All the compatible versions, unordered except for the last element, which is considered the set "default".
	BuildIds []*BuildId `protobuf:"bytes,2,rep,name=build_ids,json=buildIds,proto3" json:"build_ids,omitempty"`
	// HLC timestamp representing when this set was last made the default for the queue.
	// (-- api-linter: core::0142::time-field-type=disabled
	//
	//	aip.dev/not-precedent: Using HLC instead of wall clock. --)
	BecameDefaultTimestamp *v1.HybridLogicalClock `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

An internal represenation of temporal.api.taskqueue.v1.CompatibleVersionSet

func (*CompatibleVersionSet) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use CompatibleVersionSet.ProtoReflect.Descriptor instead.

func (*CompatibleVersionSet) Equal added in v1.21.0 

func (this *CompatibleVersionSet) Equal(that interface{}) bool

Equal returns whether two CompatibleVersionSet values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CompatibleVersionSet) GetBecameDefaultTimestamp added in v1.21.0 

func (x *CompatibleVersionSet) GetBecameDefaultTimestamp() *v1.HybridLogicalClock

func (*CompatibleVersionSet) GetBuildIds added in v1.21.0 

func (x *CompatibleVersionSet) GetBuildIds() []*BuildId

func (*CompatibleVersionSet) GetSetIds added in v1.21.0 

func (x *CompatibleVersionSet) GetSetIds() []string

func (*CompatibleVersionSet) Marshal added in v1.21.0 

func (val *CompatibleVersionSet) Marshal() ([]byte, error)

Marshal an object of type CompatibleVersionSet to the protobuf v3 wire format

func (*CompatibleVersionSet) ProtoMessage added in v1.21.0 

func (*CompatibleVersionSet) ProtoMessage()

func (*CompatibleVersionSet) ProtoReflect added in v1.23.0 

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

func (*CompatibleVersionSet) Reset added in v1.21.0 

func (x *CompatibleVersionSet) Reset()

func (*CompatibleVersionSet) Size added in v1.21.0 

func (val *CompatibleVersionSet) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CompatibleVersionSet) String added in v1.21.0 

func (x *CompatibleVersionSet) String() string

func (*CompatibleVersionSet) Unmarshal added in v1.21.0 

func (val *CompatibleVersionSet) Unmarshal(buf []byte) error

Unmarshal an object of type CompatibleVersionSet from the protobuf v3 wire format

type DestinationPredicateAttributes added in v1.24.0 

type DestinationPredicateAttributes struct {
	Destinations []string `protobuf:"bytes,1,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// contains filtered or unexported fields
}

func (*DestinationPredicateAttributes) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use DestinationPredicateAttributes.ProtoReflect.Descriptor instead.

func (*DestinationPredicateAttributes) Equal added in v1.24.0 

func (this *DestinationPredicateAttributes) Equal(that interface{}) bool

Equal returns whether two DestinationPredicateAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DestinationPredicateAttributes) GetDestinations added in v1.24.0 

func (x *DestinationPredicateAttributes) GetDestinations() []string

func (*DestinationPredicateAttributes) Marshal added in v1.24.0 

func (val *DestinationPredicateAttributes) Marshal() ([]byte, error)

Marshal an object of type DestinationPredicateAttributes to the protobuf v3 wire format

func (*DestinationPredicateAttributes) ProtoMessage added in v1.24.0 

func (*DestinationPredicateAttributes) ProtoMessage()

func (*DestinationPredicateAttributes) ProtoReflect added in v1.24.0 

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

func (*DestinationPredicateAttributes) Reset added in v1.24.0 

func (x *DestinationPredicateAttributes) Reset()

func (*DestinationPredicateAttributes) Size added in v1.24.0 

func (val *DestinationPredicateAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DestinationPredicateAttributes) String added in v1.24.0 

func (x *DestinationPredicateAttributes) String() string

func (*DestinationPredicateAttributes) Unmarshal added in v1.24.0 

func (val *DestinationPredicateAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type DestinationPredicateAttributes from the protobuf v3 wire format

type EmptyPredicateAttributes added in v1.17.3 

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

func (*EmptyPredicateAttributes) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use EmptyPredicateAttributes.ProtoReflect.Descriptor instead.

func (*EmptyPredicateAttributes) Equal added in v1.17.3 

func (this *EmptyPredicateAttributes) Equal(that interface{}) bool

Equal returns whether two EmptyPredicateAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*EmptyPredicateAttributes) Marshal added in v1.17.3 

func (val *EmptyPredicateAttributes) Marshal() ([]byte, error)

Marshal an object of type EmptyPredicateAttributes to the protobuf v3 wire format

func (*EmptyPredicateAttributes) ProtoMessage added in v1.17.3 

func (*EmptyPredicateAttributes) ProtoMessage()

func (*EmptyPredicateAttributes) ProtoReflect added in v1.23.0 

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

func (*EmptyPredicateAttributes) Reset added in v1.17.3 

func (x *EmptyPredicateAttributes) Reset()

func (*EmptyPredicateAttributes) Size added in v1.17.3 

func (val *EmptyPredicateAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*EmptyPredicateAttributes) String added in v1.17.3 

func (x *EmptyPredicateAttributes) String() string

func (*EmptyPredicateAttributes) Unmarshal added in v1.17.3 

func (val *EmptyPredicateAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type EmptyPredicateAttributes from the protobuf v3 wire format

type ExecutionStats 

type ExecutionStats struct {
	HistorySize int64 `protobuf:"varint,1,opt,name=history_size,json=historySize,proto3" json:"history_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionStats) Descriptor deprecated 

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

Deprecated: Use ExecutionStats.ProtoReflect.Descriptor instead.

func (*ExecutionStats) Equal 

func (this *ExecutionStats) Equal(that interface{}) bool

Equal returns whether two ExecutionStats values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ExecutionStats) GetHistorySize 

func (x *ExecutionStats) GetHistorySize() int64

func (*ExecutionStats) Marshal 

func (val *ExecutionStats) Marshal() ([]byte, error)

Marshal an object of type ExecutionStats to the protobuf v3 wire format

func (*ExecutionStats) ProtoMessage 

func (*ExecutionStats) ProtoMessage()

func (*ExecutionStats) ProtoReflect added in v1.23.0 

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

func (*ExecutionStats) Reset 

func (x *ExecutionStats) Reset()

func (*ExecutionStats) Size 

func (val *ExecutionStats) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ExecutionStats) String 

func (x *ExecutionStats) String() string

func (*ExecutionStats) Unmarshal 

func (val *ExecutionStats) Unmarshal(buf []byte) error

Unmarshal an object of type ExecutionStats from the protobuf v3 wire format

type FailoverStatus added in v1.17.3 

type FailoverStatus struct {
	FailoverTime    *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=failover_time,json=failoverTime,proto3" json:"failover_time,omitempty"`
	FailoverVersion int64                  `protobuf:"varint,2,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
	// contains filtered or unexported fields
}

Represents a historical replication status of a Namespace

func (*FailoverStatus) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use FailoverStatus.ProtoReflect.Descriptor instead.

func (*FailoverStatus) Equal added in v1.17.3 

func (this *FailoverStatus) Equal(that interface{}) bool

Equal returns whether two FailoverStatus values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*FailoverStatus) GetFailoverTime added in v1.17.3 

func (x *FailoverStatus) GetFailoverTime() *timestamppb.Timestamp

func (*FailoverStatus) GetFailoverVersion added in v1.17.3 

func (x *FailoverStatus) GetFailoverVersion() int64

func (*FailoverStatus) Marshal added in v1.17.3 

func (val *FailoverStatus) Marshal() ([]byte, error)

Marshal an object of type FailoverStatus to the protobuf v3 wire format

func (*FailoverStatus) ProtoMessage added in v1.17.3 

func (*FailoverStatus) ProtoMessage()

func (*FailoverStatus) ProtoReflect added in v1.23.0 

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

func (*FailoverStatus) Reset added in v1.17.3 

func (x *FailoverStatus) Reset()

func (*FailoverStatus) Size added in v1.17.3 

func (val *FailoverStatus) Size() int

Size returns the size of the object, in bytes, once serialized

func (*FailoverStatus) String added in v1.17.3 

func (x *FailoverStatus) String() string

func (*FailoverStatus) Unmarshal added in v1.17.3 

func (val *FailoverStatus) Unmarshal(buf []byte) error

Unmarshal an object of type FailoverStatus from the protobuf v3 wire format

type HSMCompletionCallbackArg added in v1.25.0 

type HSMCompletionCallbackArg struct {

	// namespace ID of the workflow that just completed.
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// ID of the workflow that just completed.
	WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// run ID of the workflow that just completed.
	RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Last event of the completed workflow.
	LastEvent *v18.HistoryEvent `protobuf:"bytes,4,opt,name=last_event,json=lastEvent,proto3" json:"last_event,omitempty"`
	// contains filtered or unexported fields
}

func (*HSMCompletionCallbackArg) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use HSMCompletionCallbackArg.ProtoReflect.Descriptor instead.

func (*HSMCompletionCallbackArg) Equal added in v1.25.0 

func (this *HSMCompletionCallbackArg) Equal(that interface{}) bool

Equal returns whether two HSMCompletionCallbackArg values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*HSMCompletionCallbackArg) GetLastEvent added in v1.25.0 

func (x *HSMCompletionCallbackArg) GetLastEvent() *v18.HistoryEvent

func (*HSMCompletionCallbackArg) GetNamespaceId added in v1.25.0 

func (x *HSMCompletionCallbackArg) GetNamespaceId() string

func (*HSMCompletionCallbackArg) GetRunId added in v1.25.0 

func (x *HSMCompletionCallbackArg) GetRunId() string

func (*HSMCompletionCallbackArg) GetWorkflowId added in v1.25.0 

func (x *HSMCompletionCallbackArg) GetWorkflowId() string

func (*HSMCompletionCallbackArg) Marshal added in v1.25.0 

func (val *HSMCompletionCallbackArg) Marshal() ([]byte, error)

Marshal an object of type HSMCompletionCallbackArg to the protobuf v3 wire format

func (*HSMCompletionCallbackArg) ProtoMessage added in v1.25.0 

func (*HSMCompletionCallbackArg) ProtoMessage()

func (*HSMCompletionCallbackArg) ProtoReflect added in v1.25.0 

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

func (*HSMCompletionCallbackArg) Reset added in v1.25.0 

func (x *HSMCompletionCallbackArg) Reset()

func (*HSMCompletionCallbackArg) Size added in v1.25.0 

func (val *HSMCompletionCallbackArg) Size() int

Size returns the size of the object, in bytes, once serialized

func (*HSMCompletionCallbackArg) String added in v1.25.0 

func (x *HSMCompletionCallbackArg) String() string

func (*HSMCompletionCallbackArg) Unmarshal added in v1.25.0 

func (val *HSMCompletionCallbackArg) Unmarshal(buf []byte) error

Unmarshal an object of type HSMCompletionCallbackArg from the protobuf v3 wire format

type HistoryBranch 

type HistoryBranch struct {
	TreeId    string                `protobuf:"bytes,1,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	BranchId  string                `protobuf:"bytes,2,opt,name=branch_id,json=branchId,proto3" json:"branch_id,omitempty"`
	Ancestors []*HistoryBranchRange `protobuf:"bytes,3,rep,name=ancestors,proto3" json:"ancestors,omitempty"`
	// contains filtered or unexported fields
}

For history persistence to serialize/deserialize branch details.

func (*HistoryBranch) Descriptor deprecated 

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

Deprecated: Use HistoryBranch.ProtoReflect.Descriptor instead.

func (*HistoryBranch) Equal 

func (this *HistoryBranch) Equal(that interface{}) bool

Equal returns whether two HistoryBranch values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*HistoryBranch) GetAncestors 

func (x *HistoryBranch) GetAncestors() []*HistoryBranchRange

func (*HistoryBranch) GetBranchId 

func (x *HistoryBranch) GetBranchId() string

func (*HistoryBranch) GetTreeId 

func (x *HistoryBranch) GetTreeId() string

func (*HistoryBranch) Marshal 

func (val *HistoryBranch) Marshal() ([]byte, error)

Marshal an object of type HistoryBranch to the protobuf v3 wire format

func (*HistoryBranch) ProtoMessage 

func (*HistoryBranch) ProtoMessage()

func (*HistoryBranch) ProtoReflect added in v1.23.0 

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

func (*HistoryBranch) Reset 

func (x *HistoryBranch) Reset()

func (*HistoryBranch) Size 

func (val *HistoryBranch) Size() int

Size returns the size of the object, in bytes, once serialized

func (*HistoryBranch) String 

func (x *HistoryBranch) String() string

func (*HistoryBranch) Unmarshal 

func (val *HistoryBranch) Unmarshal(buf []byte) error

Unmarshal an object of type HistoryBranch from the protobuf v3 wire format

type HistoryBranchRange 

type HistoryBranchRange struct {

	// BranchId of original branch forked from.
	BranchId string `protobuf:"bytes,1,opt,name=branch_id,json=branchId,proto3" json:"branch_id,omitempty"`
	// Beginning node for the range, inclusive.
	BeginNodeId int64 `protobuf:"varint,2,opt,name=begin_node_id,json=beginNodeId,proto3" json:"begin_node_id,omitempty"`
	// Ending node for the range, exclusive.
	EndNodeId int64 `protobuf:"varint,3,opt,name=end_node_id,json=endNodeId,proto3" json:"end_node_id,omitempty"`
	// contains filtered or unexported fields
}

HistoryBranchRange represents a piece of range for a branch.

func (*HistoryBranchRange) Descriptor deprecated 

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

Deprecated: Use HistoryBranchRange.ProtoReflect.Descriptor instead.

func (*HistoryBranchRange) Equal 

func (this *HistoryBranchRange) Equal(that interface{}) bool

Equal returns whether two HistoryBranchRange values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*HistoryBranchRange) GetBeginNodeId 

func (x *HistoryBranchRange) GetBeginNodeId() int64

func (*HistoryBranchRange) GetBranchId 

func (x *HistoryBranchRange) GetBranchId() string

func (*HistoryBranchRange) GetEndNodeId 

func (x *HistoryBranchRange) GetEndNodeId() int64

func (*HistoryBranchRange) Marshal 

func (val *HistoryBranchRange) Marshal() ([]byte, error)

Marshal an object of type HistoryBranchRange to the protobuf v3 wire format

func (*HistoryBranchRange) ProtoMessage 

func (*HistoryBranchRange) ProtoMessage()

func (*HistoryBranchRange) ProtoReflect added in v1.23.0 

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

func (*HistoryBranchRange) Reset 

func (x *HistoryBranchRange) Reset()

func (*HistoryBranchRange) Size 

func (val *HistoryBranchRange) Size() int

Size returns the size of the object, in bytes, once serialized

func (*HistoryBranchRange) String 

func (x *HistoryBranchRange) String() string

func (*HistoryBranchRange) Unmarshal 

func (val *HistoryBranchRange) Unmarshal(buf []byte) error

Unmarshal an object of type HistoryBranchRange from the protobuf v3 wire format

type HistoryTask added in v1.23.0 

type HistoryTask struct {

	// shard_id that this task belonged to when it was created. Technically, you can derive this from the task data
	// blob, but it's useful to have it here for quick access and to avoid deserializing the blob. Note that this may be
	// different from the shard id of this task in the current cluster because it could have come from a cluster with a
	// different shard id. This will always be the shard id of the task in its original cluster.
	ShardId int32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// blob that contains the history task proto. There is a GoLang-specific generic deserializer for this blob, but
	// there is no common proto for all task proto types, so deserializing in other languages will require a custom
	// switch on the task category, which should be available from the metadata for the queue that this task came from.
	Blob *v1.DataBlob `protobuf:"bytes,2,opt,name=blob,proto3" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

HistoryTask represents an internal history service task for a particular shard. We use a blob because there is no common proto for all task proto types.

func (*HistoryTask) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use HistoryTask.ProtoReflect.Descriptor instead.

func (*HistoryTask) Equal added in v1.23.0 

func (this *HistoryTask) Equal(that interface{}) bool

Equal returns whether two HistoryTask values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*HistoryTask) GetBlob added in v1.23.0 

func (x *HistoryTask) GetBlob() *v1.DataBlob

func (*HistoryTask) GetShardId added in v1.23.0 

func (x *HistoryTask) GetShardId() int32

func (*HistoryTask) Marshal added in v1.23.0 

func (val *HistoryTask) Marshal() ([]byte, error)

Marshal an object of type HistoryTask to the protobuf v3 wire format

func (*HistoryTask) ProtoMessage added in v1.23.0 

func (*HistoryTask) ProtoMessage()

func (*HistoryTask) ProtoReflect added in v1.23.0 

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

func (*HistoryTask) Reset added in v1.23.0 

func (x *HistoryTask) Reset()

func (*HistoryTask) Size added in v1.23.0 

func (val *HistoryTask) Size() int

Size returns the size of the object, in bytes, once serialized

func (*HistoryTask) String added in v1.23.0 

func (x *HistoryTask) String() string

func (*HistoryTask) Unmarshal added in v1.23.0 

func (val *HistoryTask) Unmarshal(buf []byte) error

Unmarshal an object of type HistoryTask from the protobuf v3 wire format

type HistoryTreeInfo 

type HistoryTreeInfo struct {
	BranchInfo *HistoryBranch `protobuf:"bytes,1,opt,name=branch_info,json=branchInfo,proto3" json:"branch_info,omitempty"`
	// For fork operation to prevent race condition of leaking event data when forking branches fail. Also can be used for clean up leaked data.
	ForkTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=fork_time,json=forkTime,proto3" json:"fork_time,omitempty"`
	// For lookup back to workflow during debugging, also background cleanup when fork operation cannot finish self cleanup due to crash.
	Info string `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// Deprecating branch token in favor of branch info.
	//
	// Deprecated: Marked as deprecated in temporal/server/api/persistence/v1/history_tree.proto.
	BranchToken []byte `protobuf:"bytes,4,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
	// contains filtered or unexported fields
}

branch column

func (*HistoryTreeInfo) Descriptor deprecated 

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

Deprecated: Use HistoryTreeInfo.ProtoReflect.Descriptor instead.

func (*HistoryTreeInfo) Equal 

func (this *HistoryTreeInfo) Equal(that interface{}) bool

Equal returns whether two HistoryTreeInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*HistoryTreeInfo) GetBranchInfo 

func (x *HistoryTreeInfo) GetBranchInfo() *HistoryBranch

func (*HistoryTreeInfo) GetBranchToken deprecated added in v1.19.0 

func (x *HistoryTreeInfo) GetBranchToken() []byte

Deprecated: Marked as deprecated in temporal/server/api/persistence/v1/history_tree.proto.

func (*HistoryTreeInfo) GetForkTime 

func (x *HistoryTreeInfo) GetForkTime() *timestamppb.Timestamp

func (*HistoryTreeInfo) GetInfo 

func (x *HistoryTreeInfo) GetInfo() string

func (*HistoryTreeInfo) Marshal 

func (val *HistoryTreeInfo) Marshal() ([]byte, error)

Marshal an object of type HistoryTreeInfo to the protobuf v3 wire format

func (*HistoryTreeInfo) ProtoMessage 

func (*HistoryTreeInfo) ProtoMessage()

func (*HistoryTreeInfo) ProtoReflect added in v1.23.0 

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

func (*HistoryTreeInfo) Reset 

func (x *HistoryTreeInfo) Reset()

func (*HistoryTreeInfo) Size 

func (val *HistoryTreeInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*HistoryTreeInfo) String 

func (x *HistoryTreeInfo) String() string

func (*HistoryTreeInfo) Unmarshal 

func (val *HistoryTreeInfo) Unmarshal(buf []byte) error

Unmarshal an object of type HistoryTreeInfo from the protobuf v3 wire format

type IndexSearchAttributes added in v1.10.0 

type IndexSearchAttributes struct {
	CustomSearchAttributes map[string]v11.IndexedValueType `` /* 262-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*IndexSearchAttributes) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use IndexSearchAttributes.ProtoReflect.Descriptor instead.

func (*IndexSearchAttributes) Equal added in v1.10.0 

func (this *IndexSearchAttributes) Equal(that interface{}) bool

Equal returns whether two IndexSearchAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*IndexSearchAttributes) GetCustomSearchAttributes added in v1.10.0 

func (x *IndexSearchAttributes) GetCustomSearchAttributes() map[string]v11.IndexedValueType

func (*IndexSearchAttributes) Marshal added in v1.10.0 

func (val *IndexSearchAttributes) Marshal() ([]byte, error)

Marshal an object of type IndexSearchAttributes to the protobuf v3 wire format

func (*IndexSearchAttributes) ProtoMessage added in v1.10.0 

func (*IndexSearchAttributes) ProtoMessage()

func (*IndexSearchAttributes) ProtoReflect added in v1.23.0 

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

func (*IndexSearchAttributes) Reset added in v1.10.0 

func (x *IndexSearchAttributes) Reset()

func (*IndexSearchAttributes) Size added in v1.10.0 

func (val *IndexSearchAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*IndexSearchAttributes) String added in v1.10.0 

func (x *IndexSearchAttributes) String() string

func (*IndexSearchAttributes) Unmarshal added in v1.10.0 

func (val *IndexSearchAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type IndexSearchAttributes from the protobuf v3 wire format

type ListQueuesNextPageToken added in v1.23.0 

type ListQueuesNextPageToken struct {
	LastReadQueueNumber int64 `protobuf:"varint,1,opt,name=last_read_queue_number,json=lastReadQueueNumber,proto3" json:"last_read_queue_number,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuesNextPageToken) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use ListQueuesNextPageToken.ProtoReflect.Descriptor instead.

func (*ListQueuesNextPageToken) Equal added in v1.23.0 

func (this *ListQueuesNextPageToken) Equal(that interface{}) bool

Equal returns whether two ListQueuesNextPageToken values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListQueuesNextPageToken) GetLastReadQueueNumber added in v1.23.0 

func (x *ListQueuesNextPageToken) GetLastReadQueueNumber() int64

func (*ListQueuesNextPageToken) Marshal added in v1.23.0 

func (val *ListQueuesNextPageToken) Marshal() ([]byte, error)

Marshal an object of type ListQueuesNextPageToken to the protobuf v3 wire format

func (*ListQueuesNextPageToken) ProtoMessage added in v1.23.0 

func (*ListQueuesNextPageToken) ProtoMessage()

func (*ListQueuesNextPageToken) ProtoReflect added in v1.23.0 

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

func (*ListQueuesNextPageToken) Reset added in v1.23.0 

func (x *ListQueuesNextPageToken) Reset()

func (*ListQueuesNextPageToken) Size added in v1.23.0 

func (val *ListQueuesNextPageToken) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListQueuesNextPageToken) String added in v1.23.0 

func (x *ListQueuesNextPageToken) String() string

func (*ListQueuesNextPageToken) Unmarshal added in v1.23.0 

func (val *ListQueuesNextPageToken) Unmarshal(buf []byte) error

Unmarshal an object of type ListQueuesNextPageToken from the protobuf v3 wire format

type NamespaceConfig 

type NamespaceConfig struct {
	Retention                    *durationpb.Duration `protobuf:"bytes,1,opt,name=retention,proto3" json:"retention,omitempty"`
	ArchivalBucket               string               `protobuf:"bytes,2,opt,name=archival_bucket,json=archivalBucket,proto3" json:"archival_bucket,omitempty"`
	BadBinaries                  *v11.BadBinaries     `protobuf:"bytes,3,opt,name=bad_binaries,json=badBinaries,proto3" json:"bad_binaries,omitempty"`
	HistoryArchivalState         v1.ArchivalState     `` /* 165-byte string literal not displayed */
	HistoryArchivalUri           string               `protobuf:"bytes,5,opt,name=history_archival_uri,json=historyArchivalUri,proto3" json:"history_archival_uri,omitempty"`
	VisibilityArchivalState      v1.ArchivalState     `` /* 174-byte string literal not displayed */
	VisibilityArchivalUri        string               `` /* 126-byte string literal not displayed */
	CustomSearchAttributeAliases map[string]string    `` /* 237-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NamespaceConfig) Descriptor deprecated 

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

Deprecated: Use NamespaceConfig.ProtoReflect.Descriptor instead.

func (*NamespaceConfig) Equal 

func (this *NamespaceConfig) Equal(that interface{}) bool

Equal returns whether two NamespaceConfig values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NamespaceConfig) GetArchivalBucket 

func (x *NamespaceConfig) GetArchivalBucket() string

func (*NamespaceConfig) GetBadBinaries 

func (x *NamespaceConfig) GetBadBinaries() *v11.BadBinaries

func (*NamespaceConfig) GetCustomSearchAttributeAliases added in v1.20.0 

func (x *NamespaceConfig) GetCustomSearchAttributeAliases() map[string]string

func (*NamespaceConfig) GetHistoryArchivalState 

func (x *NamespaceConfig) GetHistoryArchivalState() v1.ArchivalState

func (*NamespaceConfig) GetHistoryArchivalUri 

func (x *NamespaceConfig) GetHistoryArchivalUri() string

func (*NamespaceConfig) GetRetention 

func (x *NamespaceConfig) GetRetention() *durationpb.Duration

func (*NamespaceConfig) GetVisibilityArchivalState 

func (x *NamespaceConfig) GetVisibilityArchivalState() v1.ArchivalState

func (*NamespaceConfig) GetVisibilityArchivalUri 

func (x *NamespaceConfig) GetVisibilityArchivalUri() string

func (*NamespaceConfig) Marshal 

func (val *NamespaceConfig) Marshal() ([]byte, error)

Marshal an object of type NamespaceConfig to the protobuf v3 wire format

func (*NamespaceConfig) ProtoMessage 

func (*NamespaceConfig) ProtoMessage()

func (*NamespaceConfig) ProtoReflect added in v1.23.0 

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

func (*NamespaceConfig) Reset 

func (x *NamespaceConfig) Reset()

func (*NamespaceConfig) Size 

func (val *NamespaceConfig) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NamespaceConfig) String 

func (x *NamespaceConfig) String() string

func (*NamespaceConfig) Unmarshal 

func (val *NamespaceConfig) Unmarshal(buf []byte) error

Unmarshal an object of type NamespaceConfig from the protobuf v3 wire format

type NamespaceDetail 

type NamespaceDetail struct {
	Info                        *NamespaceInfo              `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Config                      *NamespaceConfig            `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	ReplicationConfig           *NamespaceReplicationConfig `protobuf:"bytes,3,opt,name=replication_config,json=replicationConfig,proto3" json:"replication_config,omitempty"`
	ConfigVersion               int64                       `protobuf:"varint,4,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
	FailoverNotificationVersion int64                       `` /* 145-byte string literal not displayed */
	FailoverVersion             int64                       `protobuf:"varint,6,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
	FailoverEndTime             *timestamppb.Timestamp      `protobuf:"bytes,7,opt,name=failover_end_time,json=failoverEndTime,proto3" json:"failover_end_time,omitempty"`
	// contains filtered or unexported fields
}

detail column

func (*NamespaceDetail) Descriptor deprecated 

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

Deprecated: Use NamespaceDetail.ProtoReflect.Descriptor instead.

func (*NamespaceDetail) Equal 

func (this *NamespaceDetail) Equal(that interface{}) bool

Equal returns whether two NamespaceDetail values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NamespaceDetail) GetConfig 

func (x *NamespaceDetail) GetConfig() *NamespaceConfig

func (*NamespaceDetail) GetConfigVersion 

func (x *NamespaceDetail) GetConfigVersion() int64

func (*NamespaceDetail) GetFailoverEndTime 

func (x *NamespaceDetail) GetFailoverEndTime() *timestamppb.Timestamp

func (*NamespaceDetail) GetFailoverNotificationVersion 

func (x *NamespaceDetail) GetFailoverNotificationVersion() int64

func (*NamespaceDetail) GetFailoverVersion 

func (x *NamespaceDetail) GetFailoverVersion() int64

func (*NamespaceDetail) GetInfo 

func (x *NamespaceDetail) GetInfo() *NamespaceInfo

func (*NamespaceDetail) GetReplicationConfig 

func (x *NamespaceDetail) GetReplicationConfig() *NamespaceReplicationConfig

func (*NamespaceDetail) Marshal 

func (val *NamespaceDetail) Marshal() ([]byte, error)

Marshal an object of type NamespaceDetail to the protobuf v3 wire format

func (*NamespaceDetail) ProtoMessage 

func (*NamespaceDetail) ProtoMessage()

func (*NamespaceDetail) ProtoReflect added in v1.23.0 

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

func (*NamespaceDetail) Reset 

func (x *NamespaceDetail) Reset()

func (*NamespaceDetail) Size 

func (val *NamespaceDetail) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NamespaceDetail) String 

func (x *NamespaceDetail) String() string

func (*NamespaceDetail) Unmarshal 

func (val *NamespaceDetail) Unmarshal(buf []byte) error

Unmarshal an object of type NamespaceDetail from the protobuf v3 wire format

type NamespaceIdPredicateAttributes added in v1.17.3 

type NamespaceIdPredicateAttributes struct {
	NamespaceIds []string `protobuf:"bytes,1,rep,name=namespace_ids,json=namespaceIds,proto3" json:"namespace_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespaceIdPredicateAttributes) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use NamespaceIdPredicateAttributes.ProtoReflect.Descriptor instead.

func (*NamespaceIdPredicateAttributes) Equal added in v1.17.3 

func (this *NamespaceIdPredicateAttributes) Equal(that interface{}) bool

Equal returns whether two NamespaceIdPredicateAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NamespaceIdPredicateAttributes) GetNamespaceIds added in v1.17.3 

func (x *NamespaceIdPredicateAttributes) GetNamespaceIds() []string

func (*NamespaceIdPredicateAttributes) Marshal added in v1.17.3 

func (val *NamespaceIdPredicateAttributes) Marshal() ([]byte, error)

Marshal an object of type NamespaceIdPredicateAttributes to the protobuf v3 wire format

func (*NamespaceIdPredicateAttributes) ProtoMessage added in v1.17.3 

func (*NamespaceIdPredicateAttributes) ProtoMessage()

func (*NamespaceIdPredicateAttributes) ProtoReflect added in v1.23.0 

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

func (*NamespaceIdPredicateAttributes) Reset added in v1.17.3 

func (x *NamespaceIdPredicateAttributes) Reset()

func (*NamespaceIdPredicateAttributes) Size added in v1.17.3 

func (val *NamespaceIdPredicateAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NamespaceIdPredicateAttributes) String added in v1.17.3 

func (x *NamespaceIdPredicateAttributes) String() string

func (*NamespaceIdPredicateAttributes) Unmarshal added in v1.17.3 

func (val *NamespaceIdPredicateAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type NamespaceIdPredicateAttributes from the protobuf v3 wire format

type NamespaceInfo 

type NamespaceInfo struct {
	Id          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State       v1.NamespaceState `protobuf:"varint,2,opt,name=state,proto3,enum=temporal.api.enums.v1.NamespaceState" json:"state,omitempty"`
	Name        string            `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description string            `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Owner       string            `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`
	Data        map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NamespaceInfo) Descriptor deprecated 

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

Deprecated: Use NamespaceInfo.ProtoReflect.Descriptor instead.

func (*NamespaceInfo) Equal 

func (this *NamespaceInfo) Equal(that interface{}) bool

Equal returns whether two NamespaceInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NamespaceInfo) GetData 

func (x *NamespaceInfo) GetData() map[string]string

func (*NamespaceInfo) GetDescription 

func (x *NamespaceInfo) GetDescription() string

func (*NamespaceInfo) GetId 

func (x *NamespaceInfo) GetId() string

func (*NamespaceInfo) GetName 

func (x *NamespaceInfo) GetName() string

func (*NamespaceInfo) GetOwner 

func (x *NamespaceInfo) GetOwner() string

func (*NamespaceInfo) GetState 

func (x *NamespaceInfo) GetState() v1.NamespaceState

func (*NamespaceInfo) Marshal 

func (val *NamespaceInfo) Marshal() ([]byte, error)

Marshal an object of type NamespaceInfo to the protobuf v3 wire format

func (*NamespaceInfo) ProtoMessage 

func (*NamespaceInfo) ProtoMessage()

func (*NamespaceInfo) ProtoReflect added in v1.23.0 

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

func (*NamespaceInfo) Reset 

func (x *NamespaceInfo) Reset()

func (*NamespaceInfo) Size 

func (val *NamespaceInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NamespaceInfo) String 

func (x *NamespaceInfo) String() string

func (*NamespaceInfo) Unmarshal 

func (val *NamespaceInfo) Unmarshal(buf []byte) error

Unmarshal an object of type NamespaceInfo from the protobuf v3 wire format

type NamespaceReplicationConfig 

type NamespaceReplicationConfig struct {
	ActiveClusterName string              `protobuf:"bytes,1,opt,name=active_cluster_name,json=activeClusterName,proto3" json:"active_cluster_name,omitempty"`
	Clusters          []string            `protobuf:"bytes,2,rep,name=clusters,proto3" json:"clusters,omitempty"`
	State             v1.ReplicationState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.enums.v1.ReplicationState" json:"state,omitempty"`
	FailoverHistory   []*FailoverStatus   `protobuf:"bytes,8,rep,name=failover_history,json=failoverHistory,proto3" json:"failover_history,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespaceReplicationConfig) Descriptor deprecated 

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

Deprecated: Use NamespaceReplicationConfig.ProtoReflect.Descriptor instead.

func (*NamespaceReplicationConfig) Equal 

func (this *NamespaceReplicationConfig) Equal(that interface{}) bool

Equal returns whether two NamespaceReplicationConfig values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NamespaceReplicationConfig) GetActiveClusterName 

func (x *NamespaceReplicationConfig) GetActiveClusterName() string

func (*NamespaceReplicationConfig) GetClusters 

func (x *NamespaceReplicationConfig) GetClusters() []string

func (*NamespaceReplicationConfig) GetFailoverHistory added in v1.17.3 

func (x *NamespaceReplicationConfig) GetFailoverHistory() []*FailoverStatus

func (*NamespaceReplicationConfig) GetState added in v1.14.0 

func (x *NamespaceReplicationConfig) GetState() v1.ReplicationState

func (*NamespaceReplicationConfig) Marshal 

func (val *NamespaceReplicationConfig) Marshal() ([]byte, error)

Marshal an object of type NamespaceReplicationConfig to the protobuf v3 wire format

func (*NamespaceReplicationConfig) ProtoMessage 

func (*NamespaceReplicationConfig) ProtoMessage()

func (*NamespaceReplicationConfig) ProtoReflect added in v1.23.0 

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

func (*NamespaceReplicationConfig) Reset 

func (x *NamespaceReplicationConfig) Reset()

func (*NamespaceReplicationConfig) Size 

func (val *NamespaceReplicationConfig) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NamespaceReplicationConfig) String 

func (x *NamespaceReplicationConfig) String() string

func (*NamespaceReplicationConfig) Unmarshal 

func (val *NamespaceReplicationConfig) Unmarshal(buf []byte) error

Unmarshal an object of type NamespaceReplicationConfig from the protobuf v3 wire format

type NexusEndpoint added in v1.25.0 

type NexusEndpoint struct {

	// The last recorded cluster-local Hybrid Logical Clock timestamp for _this_ endpoint.
	// Updated whenever the endpoint is directly updated due to a user action but not when applying replication events.
	// The clock is referenced when new timestamps are generated to ensure it produces monotonically increasing
	// timestamps.
	Clock *v11.HybridLogicalClock `protobuf:"bytes,1,opt,name=clock,proto3" json:"clock,omitempty"`
	// Endpoint specification. This is a mirror of the public API and is intended to be mutable.
	Spec *NexusEndpointSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// The date and time when the endpoint was created.
	// (-- api-linter: core::0142::time-field-names=disabled
	//
	//	aip.dev/not-precedent: Not following linter rules. --)
	CreatedTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// contains filtered or unexported fields
}

func (*NexusEndpoint) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use NexusEndpoint.ProtoReflect.Descriptor instead.

func (*NexusEndpoint) Equal added in v1.25.0 

func (this *NexusEndpoint) Equal(that interface{}) bool

Equal returns whether two NexusEndpoint values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NexusEndpoint) GetClock added in v1.25.0 

func (x *NexusEndpoint) GetClock() *v11.HybridLogicalClock

func (*NexusEndpoint) GetCreatedTime added in v1.25.0 

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

func (*NexusEndpoint) GetSpec added in v1.25.0 

func (x *NexusEndpoint) GetSpec() *NexusEndpointSpec

func (*NexusEndpoint) Marshal added in v1.25.0 

func (val *NexusEndpoint) Marshal() ([]byte, error)

Marshal an object of type NexusEndpoint to the protobuf v3 wire format

func (*NexusEndpoint) ProtoMessage added in v1.25.0 

func (*NexusEndpoint) ProtoMessage()

func (*NexusEndpoint) ProtoReflect added in v1.25.0 

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

func (*NexusEndpoint) Reset added in v1.25.0 

func (x *NexusEndpoint) Reset()

func (*NexusEndpoint) Size added in v1.25.0 

func (val *NexusEndpoint) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NexusEndpoint) String added in v1.25.0 

func (x *NexusEndpoint) String() string

func (*NexusEndpoint) Unmarshal added in v1.25.0 

func (val *NexusEndpoint) Unmarshal(buf []byte) error

Unmarshal an object of type NexusEndpoint from the protobuf v3 wire format

type NexusEndpointEntry added in v1.25.0 

type NexusEndpointEntry struct {
	Version  int64          `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Id       string         `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Endpoint *NexusEndpoint `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

Container for a version, a UUID, and a NexusEndpoint.

func (*NexusEndpointEntry) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use NexusEndpointEntry.ProtoReflect.Descriptor instead.

func (*NexusEndpointEntry) Equal added in v1.25.0 

func (this *NexusEndpointEntry) Equal(that interface{}) bool

Equal returns whether two NexusEndpointEntry values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NexusEndpointEntry) GetEndpoint added in v1.25.0 

func (x *NexusEndpointEntry) GetEndpoint() *NexusEndpoint

func (*NexusEndpointEntry) GetId added in v1.25.0 

func (x *NexusEndpointEntry) GetId() string

func (*NexusEndpointEntry) GetVersion added in v1.25.0 

func (x *NexusEndpointEntry) GetVersion() int64

func (*NexusEndpointEntry) Marshal added in v1.25.0 

func (val *NexusEndpointEntry) Marshal() ([]byte, error)

Marshal an object of type NexusEndpointEntry to the protobuf v3 wire format

func (*NexusEndpointEntry) ProtoMessage added in v1.25.0 

func (*NexusEndpointEntry) ProtoMessage()

func (*NexusEndpointEntry) ProtoReflect added in v1.25.0 

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

func (*NexusEndpointEntry) Reset added in v1.25.0 

func (x *NexusEndpointEntry) Reset()

func (*NexusEndpointEntry) Size added in v1.25.0 

func (val *NexusEndpointEntry) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NexusEndpointEntry) String added in v1.25.0 

func (x *NexusEndpointEntry) String() string

func (*NexusEndpointEntry) Unmarshal added in v1.25.0 

func (val *NexusEndpointEntry) Unmarshal(buf []byte) error

Unmarshal an object of type NexusEndpointEntry from the protobuf v3 wire format

type NexusEndpointSpec added in v1.25.0 

type NexusEndpointSpec struct {

	// Endpoint name, unique for this cluster. Must match `[a-zA-Z_][a-zA-Z0-9_]*`.
	// Renaming an endpoint breaks all workflow callers that reference this endpoint, causing operations to fail.
	Name        string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description *v1.Payload `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Target to route requests to.
	Target *NexusEndpointTarget `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

Contains mutable fields for an Endpoint. Duplicated from the public API's temporal.api.nexus.v1.EndpointSpec where the worker target has a namespace name. We store an ID in persistence to prevent namespace renames from breaking references.

func (*NexusEndpointSpec) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use NexusEndpointSpec.ProtoReflect.Descriptor instead.

func (*NexusEndpointSpec) Equal added in v1.25.0 

func (this *NexusEndpointSpec) Equal(that interface{}) bool

Equal returns whether two NexusEndpointSpec values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NexusEndpointSpec) GetDescription added in v1.25.0 

func (x *NexusEndpointSpec) GetDescription() *v1.Payload

func (*NexusEndpointSpec) GetName added in v1.25.0 

func (x *NexusEndpointSpec) GetName() string

func (*NexusEndpointSpec) GetTarget added in v1.25.0 

func (x *NexusEndpointSpec) GetTarget() *NexusEndpointTarget

func (*NexusEndpointSpec) Marshal added in v1.25.0 

func (val *NexusEndpointSpec) Marshal() ([]byte, error)

Marshal an object of type NexusEndpointSpec to the protobuf v3 wire format

func (*NexusEndpointSpec) ProtoMessage added in v1.25.0 

func (*NexusEndpointSpec) ProtoMessage()

func (*NexusEndpointSpec) ProtoReflect added in v1.25.0 

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

func (*NexusEndpointSpec) Reset added in v1.25.0 

func (x *NexusEndpointSpec) Reset()

func (*NexusEndpointSpec) Size added in v1.25.0 

func (val *NexusEndpointSpec) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NexusEndpointSpec) String added in v1.25.0 

func (x *NexusEndpointSpec) String() string

func (*NexusEndpointSpec) Unmarshal added in v1.25.0 

func (val *NexusEndpointSpec) Unmarshal(buf []byte) error

Unmarshal an object of type NexusEndpointSpec from the protobuf v3 wire format

type NexusEndpointTarget added in v1.25.0 

type NexusEndpointTarget struct {

	// Types that are assignable to Variant:
	//
	//	*NexusEndpointTarget_Worker_
	//	*NexusEndpointTarget_External_
	Variant isNexusEndpointTarget_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

Target to route requests to. Duplicated from the public API's temporal.api.nexus.v1.EndpointTarget where the worker target has a namespace name. We store an ID in persistence to prevent namespace renames from breaking references.

func (*NexusEndpointTarget) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use NexusEndpointTarget.ProtoReflect.Descriptor instead.

func (*NexusEndpointTarget) Equal added in v1.25.0 

func (this *NexusEndpointTarget) Equal(that interface{}) bool

Equal returns whether two NexusEndpointTarget values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NexusEndpointTarget) GetExternal added in v1.25.0 

func (x *NexusEndpointTarget) GetExternal() *NexusEndpointTarget_External

func (*NexusEndpointTarget) GetVariant added in v1.25.0 

func (m *NexusEndpointTarget) GetVariant() isNexusEndpointTarget_Variant

func (*NexusEndpointTarget) GetWorker added in v1.25.0 

func (x *NexusEndpointTarget) GetWorker() *NexusEndpointTarget_Worker

func (*NexusEndpointTarget) Marshal added in v1.25.0 

func (val *NexusEndpointTarget) Marshal() ([]byte, error)

Marshal an object of type NexusEndpointTarget to the protobuf v3 wire format

func (*NexusEndpointTarget) ProtoMessage added in v1.25.0 

func (*NexusEndpointTarget) ProtoMessage()

func (*NexusEndpointTarget) ProtoReflect added in v1.25.0 

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

func (*NexusEndpointTarget) Reset added in v1.25.0 

func (x *NexusEndpointTarget) Reset()

func (*NexusEndpointTarget) Size added in v1.25.0 

func (val *NexusEndpointTarget) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NexusEndpointTarget) String added in v1.25.0 

func (x *NexusEndpointTarget) String() string

func (*NexusEndpointTarget) Unmarshal added in v1.25.0 

func (val *NexusEndpointTarget) Unmarshal(buf []byte) error

Unmarshal an object of type NexusEndpointTarget from the protobuf v3 wire format

type NexusEndpointTarget_External added in v1.25.0 

type NexusEndpointTarget_External struct {

	// URL to call.
	// (-- api-linter: core::0140::uri=disabled
	//
	//	aip.dev/not-precedent: Not following linter rules. --)
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

Target an external server by URL. At a later point, this will support providing credentials, in the meantime, an http.RoundTripper can be injected into the server to modify the request.

func (*NexusEndpointTarget_External) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use NexusEndpointTarget_External.ProtoReflect.Descriptor instead.

func (*NexusEndpointTarget_External) GetUrl added in v1.25.0 

func (x *NexusEndpointTarget_External) GetUrl() string

func (*NexusEndpointTarget_External) ProtoMessage added in v1.25.0 

func (*NexusEndpointTarget_External) ProtoMessage()

func (*NexusEndpointTarget_External) ProtoReflect added in v1.25.0 

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

func (*NexusEndpointTarget_External) Reset added in v1.25.0 

func (x *NexusEndpointTarget_External) Reset()

func (*NexusEndpointTarget_External) String added in v1.25.0 

func (x *NexusEndpointTarget_External) String() string

type NexusEndpointTarget_External_ added in v1.25.0 

type NexusEndpointTarget_External_ struct {
	External *NexusEndpointTarget_External `protobuf:"bytes,2,opt,name=external,proto3,oneof"`
}

type NexusEndpointTarget_Worker added in v1.25.0 

type NexusEndpointTarget_Worker struct {

	// Namespace ID to route requests to.
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// Nexus task queue to route requests to.
	TaskQueue string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// contains filtered or unexported fields
}

Target a worker polling on a Nexus task queue in a specific namespace.

func (*NexusEndpointTarget_Worker) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use NexusEndpointTarget_Worker.ProtoReflect.Descriptor instead.

func (*NexusEndpointTarget_Worker) GetNamespaceId added in v1.25.0 

func (x *NexusEndpointTarget_Worker) GetNamespaceId() string

func (*NexusEndpointTarget_Worker) GetTaskQueue added in v1.25.0 

func (x *NexusEndpointTarget_Worker) GetTaskQueue() string

func (*NexusEndpointTarget_Worker) ProtoMessage added in v1.25.0 

func (*NexusEndpointTarget_Worker) ProtoMessage()

func (*NexusEndpointTarget_Worker) ProtoReflect added in v1.25.0 

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

func (*NexusEndpointTarget_Worker) Reset added in v1.25.0 

func (x *NexusEndpointTarget_Worker) Reset()

func (*NexusEndpointTarget_Worker) String added in v1.25.0 

func (x *NexusEndpointTarget_Worker) String() string

type NexusEndpointTarget_Worker_ added in v1.25.0 

type NexusEndpointTarget_Worker_ struct {
	Worker *NexusEndpointTarget_Worker `protobuf:"bytes,1,opt,name=worker,proto3,oneof"`
}

type NexusOperationCancellationInfo added in v1.24.0 

type NexusOperationCancellationInfo struct {

	// The time when cancelation was requested.
	RequestedTime *timestamppb.Timestamp              `protobuf:"bytes,1,opt,name=requested_time,json=requestedTime,proto3" json:"requested_time,omitempty"`
	State         v16.NexusOperationCancellationState `protobuf:"varint,2,opt,name=state,proto3,enum=temporal.api.enums.v1.NexusOperationCancellationState" json:"state,omitempty"`
	// The number of attempts made to deliver the cancel operation request.
	// This number represents a minimum bound since the attempt is incremented after the request completes.
	Attempt int32 `protobuf:"varint,3,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// The time when the last attempt completed.
	LastAttemptCompleteTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
	// The last attempt's failure, if any.
	LastAttemptFailure *v17.Failure `protobuf:"bytes,5,opt,name=last_attempt_failure,json=lastAttemptFailure,proto3" json:"last_attempt_failure,omitempty"`
	// The time when the next attempt is scheduled.
	NextAttemptScheduleTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

NexusOperationCancellationInfo contains the state of a nexus operation cancelation.

func (*NexusOperationCancellationInfo) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use NexusOperationCancellationInfo.ProtoReflect.Descriptor instead.

func (*NexusOperationCancellationInfo) Equal added in v1.24.0 

func (this *NexusOperationCancellationInfo) Equal(that interface{}) bool

Equal returns whether two NexusOperationCancellationInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NexusOperationCancellationInfo) GetAttempt added in v1.24.0 

func (x *NexusOperationCancellationInfo) GetAttempt() int32

func (*NexusOperationCancellationInfo) GetLastAttemptCompleteTime added in v1.24.0 

func (x *NexusOperationCancellationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp

func (*NexusOperationCancellationInfo) GetLastAttemptFailure added in v1.24.0 

func (x *NexusOperationCancellationInfo) GetLastAttemptFailure() *v17.Failure

func (*NexusOperationCancellationInfo) GetNextAttemptScheduleTime added in v1.24.0 

func (x *NexusOperationCancellationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp

func (*NexusOperationCancellationInfo) GetRequestedTime added in v1.24.0 

func (x *NexusOperationCancellationInfo) GetRequestedTime() *timestamppb.Timestamp

func (*NexusOperationCancellationInfo) GetState added in v1.24.0 

func (x *NexusOperationCancellationInfo) GetState() v16.NexusOperationCancellationState

func (*NexusOperationCancellationInfo) Marshal added in v1.24.0 

func (val *NexusOperationCancellationInfo) Marshal() ([]byte, error)

Marshal an object of type NexusOperationCancellationInfo to the protobuf v3 wire format

func (*NexusOperationCancellationInfo) ProtoMessage added in v1.24.0 

func (*NexusOperationCancellationInfo) ProtoMessage()

func (*NexusOperationCancellationInfo) ProtoReflect added in v1.24.0 

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

func (*NexusOperationCancellationInfo) Reset added in v1.24.0 

func (x *NexusOperationCancellationInfo) Reset()

func (*NexusOperationCancellationInfo) Size added in v1.24.0 

func (val *NexusOperationCancellationInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NexusOperationCancellationInfo) String added in v1.24.0 

func (x *NexusOperationCancellationInfo) String() string

func (*NexusOperationCancellationInfo) Unmarshal added in v1.24.0 

func (val *NexusOperationCancellationInfo) Unmarshal(buf []byte) error

Unmarshal an object of type NexusOperationCancellationInfo from the protobuf v3 wire format

type NexusOperationInfo added in v1.24.0 

type NexusOperationInfo struct {

	// Endpoint name.
	// Resolved the endpoint registry for this workflow's namespace.
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Service name.
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// Operation name.
	Operation string `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	// If set the state machine will remove itself from the HSM tree on completion.
	DeleteOnCompletion bool `protobuf:"varint,4,opt,name=delete_on_completion,json=deleteOnCompletion,proto3" json:"delete_on_completion,omitempty"`
	// Token for fetching the scheduled event.
	ScheduledEventToken []byte `protobuf:"bytes,5,opt,name=scheduled_event_token,json=scheduledEventToken,proto3" json:"scheduled_event_token,omitempty"`
	// Operation ID. Only set for asynchronous operations after a successful StartOperation call.
	OperationId string `protobuf:"bytes,6,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// Schedule-to-close timeout for this operation.
	// This is the only timeout settable by a workflow.
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "since" is needed here. --)
	ScheduleToCloseTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	// The time when the operation was scheduled.
	ScheduledTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	// Unique request ID allocated for all retry attempts of the StartOperation request.
	RequestId string                 `protobuf:"bytes,9,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	State     v1.NexusOperationState `protobuf:"varint,10,opt,name=state,proto3,enum=temporal.server.api.enums.v1.NexusOperationState" json:"state,omitempty"`
	// The number of attempts made to deliver the start operation request.
	// This number represents a minimum bound since the attempt is incremented after the request completes.
	Attempt int32 `protobuf:"varint,11,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// The time when the last attempt completed.
	LastAttemptCompleteTime *timestamppb.Timestamp `` /* 135-byte string literal not displayed */
	// The last attempt's failure, if any.
	LastAttemptFailure *v17.Failure `protobuf:"bytes,13,opt,name=last_attempt_failure,json=lastAttemptFailure,proto3" json:"last_attempt_failure,omitempty"`
	// The time when the next attempt is scheduled.
	NextAttemptScheduleTime *timestamppb.Timestamp `` /* 135-byte string literal not displayed */
	// Endpoint ID, the name is also stored here (field 1) but we use the ID internally to avoid failing operation
	// requests when an endpoint is renamed.
	EndpointId string `protobuf:"bytes,15,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	// contains filtered or unexported fields
}

NexusOperationInfo contains the state of a nexus operation.

func (*NexusOperationInfo) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use NexusOperationInfo.ProtoReflect.Descriptor instead.

func (*NexusOperationInfo) Equal added in v1.24.0 

func (this *NexusOperationInfo) Equal(that interface{}) bool

Equal returns whether two NexusOperationInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NexusOperationInfo) GetAttempt added in v1.24.0 

func (x *NexusOperationInfo) GetAttempt() int32

func (*NexusOperationInfo) GetDeleteOnCompletion added in v1.24.0 

func (x *NexusOperationInfo) GetDeleteOnCompletion() bool

func (*NexusOperationInfo) GetEndpoint added in v1.25.0 

func (x *NexusOperationInfo) GetEndpoint() string

func (*NexusOperationInfo) GetEndpointId added in v1.25.0 

func (x *NexusOperationInfo) GetEndpointId() string

func (*NexusOperationInfo) GetLastAttemptCompleteTime added in v1.24.0 

func (x *NexusOperationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp

func (*NexusOperationInfo) GetLastAttemptFailure added in v1.24.0 

func (x *NexusOperationInfo) GetLastAttemptFailure() *v17.Failure

func (*NexusOperationInfo) GetNextAttemptScheduleTime added in v1.24.0 

func (x *NexusOperationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp

func (*NexusOperationInfo) GetOperation added in v1.24.0 

func (x *NexusOperationInfo) GetOperation() string

func (*NexusOperationInfo) GetOperationId added in v1.24.0 

func (x *NexusOperationInfo) GetOperationId() string

func (*NexusOperationInfo) GetRequestId added in v1.24.0 

func (x *NexusOperationInfo) GetRequestId() string

func (*NexusOperationInfo) GetScheduleToCloseTimeout added in v1.24.0 

func (x *NexusOperationInfo) GetScheduleToCloseTimeout() *durationpb.Duration

func (*NexusOperationInfo) GetScheduledEventToken added in v1.24.0 

func (x *NexusOperationInfo) GetScheduledEventToken() []byte

func (*NexusOperationInfo) GetScheduledTime added in v1.24.0 

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

func (*NexusOperationInfo) GetService added in v1.24.0 

func (x *NexusOperationInfo) GetService() string

func (*NexusOperationInfo) GetState added in v1.24.0 

func (x *NexusOperationInfo) GetState() v1.NexusOperationState

func (*NexusOperationInfo) Marshal added in v1.24.0 

func (val *NexusOperationInfo) Marshal() ([]byte, error)

Marshal an object of type NexusOperationInfo to the protobuf v3 wire format

func (*NexusOperationInfo) ProtoMessage added in v1.24.0 

func (*NexusOperationInfo) ProtoMessage()

func (*NexusOperationInfo) ProtoReflect added in v1.24.0 

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

func (*NexusOperationInfo) Reset added in v1.24.0 

func (x *NexusOperationInfo) Reset()

func (*NexusOperationInfo) Size added in v1.24.0 

func (val *NexusOperationInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NexusOperationInfo) String added in v1.24.0 

func (x *NexusOperationInfo) String() string

func (*NexusOperationInfo) Unmarshal added in v1.24.0 

func (val *NexusOperationInfo) Unmarshal(buf []byte) error

Unmarshal an object of type NexusOperationInfo from the protobuf v3 wire format

type NotPredicateAttributes added in v1.17.3 

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

func (*NotPredicateAttributes) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use NotPredicateAttributes.ProtoReflect.Descriptor instead.

func (*NotPredicateAttributes) Equal added in v1.17.3 

func (this *NotPredicateAttributes) Equal(that interface{}) bool

Equal returns whether two NotPredicateAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NotPredicateAttributes) GetPredicate added in v1.17.3 

func (x *NotPredicateAttributes) GetPredicate() *Predicate

func (*NotPredicateAttributes) Marshal added in v1.17.3 

func (val *NotPredicateAttributes) Marshal() ([]byte, error)

Marshal an object of type NotPredicateAttributes to the protobuf v3 wire format

func (*NotPredicateAttributes) ProtoMessage added in v1.17.3 

func (*NotPredicateAttributes) ProtoMessage()

func (*NotPredicateAttributes) ProtoReflect added in v1.23.0 

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

func (*NotPredicateAttributes) Reset added in v1.17.3 

func (x *NotPredicateAttributes) Reset()

func (*NotPredicateAttributes) Size added in v1.17.3 

func (val *NotPredicateAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NotPredicateAttributes) String added in v1.17.3 

func (x *NotPredicateAttributes) String() string

func (*NotPredicateAttributes) Unmarshal added in v1.17.3 

func (val *NotPredicateAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type NotPredicateAttributes from the protobuf v3 wire format

type OrPredicateAttributes added in v1.17.3 

type OrPredicateAttributes struct {
	Predicates []*Predicate `protobuf:"bytes,1,rep,name=predicates,proto3" json:"predicates,omitempty"`
	// contains filtered or unexported fields
}

func (*OrPredicateAttributes) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use OrPredicateAttributes.ProtoReflect.Descriptor instead.

func (*OrPredicateAttributes) Equal added in v1.17.3 

func (this *OrPredicateAttributes) Equal(that interface{}) bool

Equal returns whether two OrPredicateAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*OrPredicateAttributes) GetPredicates added in v1.17.3 

func (x *OrPredicateAttributes) GetPredicates() []*Predicate

func (*OrPredicateAttributes) Marshal added in v1.17.3 

func (val *OrPredicateAttributes) Marshal() ([]byte, error)

Marshal an object of type OrPredicateAttributes to the protobuf v3 wire format

func (*OrPredicateAttributes) ProtoMessage added in v1.17.3 

func (*OrPredicateAttributes) ProtoMessage()

func (*OrPredicateAttributes) ProtoReflect added in v1.23.0 

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

func (*OrPredicateAttributes) Reset added in v1.17.3 

func (x *OrPredicateAttributes) Reset()

func (*OrPredicateAttributes) Size added in v1.17.3 

func (val *OrPredicateAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*OrPredicateAttributes) String added in v1.17.3 

func (x *OrPredicateAttributes) String() string

func (*OrPredicateAttributes) Unmarshal added in v1.17.3 

func (val *OrPredicateAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type OrPredicateAttributes from the protobuf v3 wire format

type OutboundTaskGroupPredicateAttributes added in v1.25.0 

type OutboundTaskGroupPredicateAttributes struct {
	Groups []string `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*OutboundTaskGroupPredicateAttributes) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use OutboundTaskGroupPredicateAttributes.ProtoReflect.Descriptor instead.

func (*OutboundTaskGroupPredicateAttributes) Equal added in v1.25.0 

func (this *OutboundTaskGroupPredicateAttributes) Equal(that interface{}) bool

Equal returns whether two OutboundTaskGroupPredicateAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*OutboundTaskGroupPredicateAttributes) GetGroups added in v1.25.0 

func (x *OutboundTaskGroupPredicateAttributes) GetGroups() []string

func (*OutboundTaskGroupPredicateAttributes) Marshal added in v1.25.0 

func (val *OutboundTaskGroupPredicateAttributes) Marshal() ([]byte, error)

Marshal an object of type OutboundTaskGroupPredicateAttributes to the protobuf v3 wire format

func (*OutboundTaskGroupPredicateAttributes) ProtoMessage added in v1.25.0 

func (*OutboundTaskGroupPredicateAttributes) ProtoMessage()

func (*OutboundTaskGroupPredicateAttributes) ProtoReflect added in v1.25.0 

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

func (*OutboundTaskGroupPredicateAttributes) Reset added in v1.25.0 

func (x *OutboundTaskGroupPredicateAttributes) Reset()

func (*OutboundTaskGroupPredicateAttributes) Size added in v1.25.0 

func (val *OutboundTaskGroupPredicateAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*OutboundTaskGroupPredicateAttributes) String added in v1.25.0 

func (x *OutboundTaskGroupPredicateAttributes) String() string

func (*OutboundTaskGroupPredicateAttributes) Unmarshal added in v1.25.0 

func (val *OutboundTaskGroupPredicateAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type OutboundTaskGroupPredicateAttributes from the protobuf v3 wire format

type OutboundTaskInfo added in v1.24.0 

type OutboundTaskInfo struct {
	NamespaceId    string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId     string                 `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId          string                 `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskType       v1.TaskType            `` /* 129-byte string literal not displayed */
	TaskId         int64                  `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
	// Destination of this task (e.g. protocol+host+port for callbacks).
	// Outbound tasks are grouped by this field (and the namespace ID) when scheduling.
	Destination string `protobuf:"bytes,7,opt,name=destination,proto3" json:"destination,omitempty"`
	// If task addresses a sub-statemachine (e.g. callback), this field will be set.
	StateMachineInfo *StateMachineTaskInfo `protobuf:"bytes,8,opt,name=state_machine_info,json=stateMachineInfo,proto3" json:"state_machine_info,omitempty"`
	// contains filtered or unexported fields
}

func (*OutboundTaskInfo) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use OutboundTaskInfo.ProtoReflect.Descriptor instead.

func (*OutboundTaskInfo) Equal added in v1.24.0 

func (this *OutboundTaskInfo) Equal(that interface{}) bool

Equal returns whether two OutboundTaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*OutboundTaskInfo) GetDestination added in v1.24.0 

func (x *OutboundTaskInfo) GetDestination() string

func (*OutboundTaskInfo) GetNamespaceId added in v1.24.0 

func (x *OutboundTaskInfo) GetNamespaceId() string

func (*OutboundTaskInfo) GetRunId added in v1.24.0 

func (x *OutboundTaskInfo) GetRunId() string

func (*OutboundTaskInfo) GetStateMachineInfo added in v1.24.0 

func (x *OutboundTaskInfo) GetStateMachineInfo() *StateMachineTaskInfo

func (*OutboundTaskInfo) GetTaskId added in v1.24.0 

func (x *OutboundTaskInfo) GetTaskId() int64

func (*OutboundTaskInfo) GetTaskType added in v1.24.0 

func (x *OutboundTaskInfo) GetTaskType() v1.TaskType

func (*OutboundTaskInfo) GetVisibilityTime added in v1.24.0 

func (x *OutboundTaskInfo) GetVisibilityTime() *timestamppb.Timestamp

func (*OutboundTaskInfo) GetWorkflowId added in v1.24.0 

func (x *OutboundTaskInfo) GetWorkflowId() string

func (*OutboundTaskInfo) Marshal added in v1.24.0 

func (val *OutboundTaskInfo) Marshal() ([]byte, error)

Marshal an object of type OutboundTaskInfo to the protobuf v3 wire format

func (*OutboundTaskInfo) ProtoMessage added in v1.24.0 

func (*OutboundTaskInfo) ProtoMessage()

func (*OutboundTaskInfo) ProtoReflect added in v1.24.0 

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

func (*OutboundTaskInfo) Reset added in v1.24.0 

func (x *OutboundTaskInfo) Reset()

func (*OutboundTaskInfo) Size added in v1.24.0 

func (val *OutboundTaskInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*OutboundTaskInfo) String added in v1.24.0 

func (x *OutboundTaskInfo) String() string

func (*OutboundTaskInfo) Unmarshal added in v1.24.0 

func (val *OutboundTaskInfo) Unmarshal(buf []byte) error

Unmarshal an object of type OutboundTaskInfo from the protobuf v3 wire format

type OutboundTaskPredicateAttributes added in v1.25.0 

type OutboundTaskPredicateAttributes struct {
	Groups []*OutboundTaskPredicateAttributes_Group `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*OutboundTaskPredicateAttributes) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use OutboundTaskPredicateAttributes.ProtoReflect.Descriptor instead.

func (*OutboundTaskPredicateAttributes) Equal added in v1.25.0 

func (this *OutboundTaskPredicateAttributes) Equal(that interface{}) bool

Equal returns whether two OutboundTaskPredicateAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*OutboundTaskPredicateAttributes) GetGroups added in v1.25.0 

func (x *OutboundTaskPredicateAttributes) GetGroups() []*OutboundTaskPredicateAttributes_Group

func (*OutboundTaskPredicateAttributes) Marshal added in v1.25.0 

func (val *OutboundTaskPredicateAttributes) Marshal() ([]byte, error)

Marshal an object of type OutboundTaskPredicateAttributes to the protobuf v3 wire format

func (*OutboundTaskPredicateAttributes) ProtoMessage added in v1.25.0 

func (*OutboundTaskPredicateAttributes) ProtoMessage()

func (*OutboundTaskPredicateAttributes) ProtoReflect added in v1.25.0 

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

func (*OutboundTaskPredicateAttributes) Reset added in v1.25.0 

func (x *OutboundTaskPredicateAttributes) Reset()

func (*OutboundTaskPredicateAttributes) Size added in v1.25.0 

func (val *OutboundTaskPredicateAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*OutboundTaskPredicateAttributes) String added in v1.25.0 

func (x *OutboundTaskPredicateAttributes) String() string

func (*OutboundTaskPredicateAttributes) Unmarshal added in v1.25.0 

func (val *OutboundTaskPredicateAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type OutboundTaskPredicateAttributes from the protobuf v3 wire format

type OutboundTaskPredicateAttributes_Group added in v1.25.0 

type OutboundTaskPredicateAttributes_Group struct {
	TaskGroup   string `protobuf:"bytes,1,opt,name=task_group,json=taskGroup,proto3" json:"task_group,omitempty"`
	NamespaceId string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Destination string `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty"`
	// contains filtered or unexported fields
}

func (*OutboundTaskPredicateAttributes_Group) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use OutboundTaskPredicateAttributes_Group.ProtoReflect.Descriptor instead.

func (*OutboundTaskPredicateAttributes_Group) GetDestination added in v1.25.0 

func (x *OutboundTaskPredicateAttributes_Group) GetDestination() string

func (*OutboundTaskPredicateAttributes_Group) GetNamespaceId added in v1.25.0 

func (x *OutboundTaskPredicateAttributes_Group) GetNamespaceId() string

func (*OutboundTaskPredicateAttributes_Group) GetTaskGroup added in v1.25.0 

func (x *OutboundTaskPredicateAttributes_Group) GetTaskGroup() string

func (*OutboundTaskPredicateAttributes_Group) ProtoMessage added in v1.25.0 

func (*OutboundTaskPredicateAttributes_Group) ProtoMessage()

func (*OutboundTaskPredicateAttributes_Group) ProtoReflect added in v1.25.0 

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

func (*OutboundTaskPredicateAttributes_Group) Reset added in v1.25.0 

func (x *OutboundTaskPredicateAttributes_Group) Reset()

func (*OutboundTaskPredicateAttributes_Group) String added in v1.25.0 

func (x *OutboundTaskPredicateAttributes_Group) String() string

type Predicate added in v1.17.3 

type Predicate struct {
	PredicateType v1.PredicateType `` /* 149-byte string literal not displayed */
	// Types that are assignable to Attributes:
	//
	//	*Predicate_UniversalPredicateAttributes
	//	*Predicate_EmptyPredicateAttributes
	//	*Predicate_AndPredicateAttributes
	//	*Predicate_OrPredicateAttributes
	//	*Predicate_NotPredicateAttributes
	//	*Predicate_NamespaceIdPredicateAttributes
	//	*Predicate_TaskTypePredicateAttributes
	//	*Predicate_DestinationPredicateAttributes
	//	*Predicate_OutboundTaskGroupPredicateAttributes
	//	*Predicate_OutboundTaskPredicateAttributes
	Attributes isPredicate_Attributes `protobuf_oneof:"attributes"`
	// contains filtered or unexported fields
}

func (*Predicate) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use Predicate.ProtoReflect.Descriptor instead.

func (*Predicate) Equal added in v1.17.3 

func (this *Predicate) Equal(that interface{}) bool

Equal returns whether two Predicate values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*Predicate) GetAndPredicateAttributes added in v1.17.3 

func (x *Predicate) GetAndPredicateAttributes() *AndPredicateAttributes

func (*Predicate) GetAttributes added in v1.17.3 

func (m *Predicate) GetAttributes() isPredicate_Attributes

func (*Predicate) GetDestinationPredicateAttributes added in v1.24.0 

func (x *Predicate) GetDestinationPredicateAttributes() *DestinationPredicateAttributes

func (*Predicate) GetEmptyPredicateAttributes added in v1.17.3 

func (x *Predicate) GetEmptyPredicateAttributes() *EmptyPredicateAttributes

func (*Predicate) GetNamespaceIdPredicateAttributes added in v1.17.3 

func (x *Predicate) GetNamespaceIdPredicateAttributes() *NamespaceIdPredicateAttributes

func (*Predicate) GetNotPredicateAttributes added in v1.17.3 

func (x *Predicate) GetNotPredicateAttributes() *NotPredicateAttributes

func (*Predicate) GetOrPredicateAttributes added in v1.17.3 

func (x *Predicate) GetOrPredicateAttributes() *OrPredicateAttributes

func (*Predicate) GetOutboundTaskGroupPredicateAttributes added in v1.25.0 

func (x *Predicate) GetOutboundTaskGroupPredicateAttributes() *OutboundTaskGroupPredicateAttributes

func (*Predicate) GetOutboundTaskPredicateAttributes added in v1.25.0 

func (x *Predicate) GetOutboundTaskPredicateAttributes() *OutboundTaskPredicateAttributes

func (*Predicate) GetPredicateType added in v1.17.3 

func (x *Predicate) GetPredicateType() v1.PredicateType

func (*Predicate) GetTaskTypePredicateAttributes added in v1.17.3 

func (x *Predicate) GetTaskTypePredicateAttributes() *TaskTypePredicateAttributes

func (*Predicate) GetUniversalPredicateAttributes added in v1.17.3 

func (x *Predicate) GetUniversalPredicateAttributes() *UniversalPredicateAttributes

func (*Predicate) Marshal added in v1.17.3 

func (val *Predicate) Marshal() ([]byte, error)

Marshal an object of type Predicate to the protobuf v3 wire format

func (*Predicate) ProtoMessage added in v1.17.3 

func (*Predicate) ProtoMessage()

func (*Predicate) ProtoReflect added in v1.23.0 

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

func (*Predicate) Reset added in v1.17.3 

func (x *Predicate) Reset()

func (*Predicate) Size added in v1.17.3 

func (val *Predicate) Size() int

Size returns the size of the object, in bytes, once serialized

func (*Predicate) String added in v1.17.3 

func (x *Predicate) String() string

func (*Predicate) Unmarshal added in v1.17.3 

func (val *Predicate) Unmarshal(buf []byte) error

Unmarshal an object of type Predicate from the protobuf v3 wire format

type Predicate_AndPredicateAttributes added in v1.17.3 

type Predicate_AndPredicateAttributes struct {
	AndPredicateAttributes *AndPredicateAttributes `protobuf:"bytes,4,opt,name=and_predicate_attributes,json=andPredicateAttributes,proto3,oneof"`
}

type Predicate_DestinationPredicateAttributes added in v1.24.0 

type Predicate_DestinationPredicateAttributes struct {
	DestinationPredicateAttributes *DestinationPredicateAttributes `protobuf:"bytes,9,opt,name=destination_predicate_attributes,json=destinationPredicateAttributes,proto3,oneof"`
}

type Predicate_EmptyPredicateAttributes added in v1.17.3 

type Predicate_EmptyPredicateAttributes struct {
	EmptyPredicateAttributes *EmptyPredicateAttributes `protobuf:"bytes,3,opt,name=empty_predicate_attributes,json=emptyPredicateAttributes,proto3,oneof"`
}

type Predicate_NamespaceIdPredicateAttributes added in v1.17.3 

type Predicate_NamespaceIdPredicateAttributes struct {
	NamespaceIdPredicateAttributes *NamespaceIdPredicateAttributes `protobuf:"bytes,7,opt,name=namespace_id_predicate_attributes,json=namespaceIdPredicateAttributes,proto3,oneof"`
}

type Predicate_NotPredicateAttributes added in v1.17.3 

type Predicate_NotPredicateAttributes struct {
	NotPredicateAttributes *NotPredicateAttributes `protobuf:"bytes,6,opt,name=not_predicate_attributes,json=notPredicateAttributes,proto3,oneof"`
}

type Predicate_OrPredicateAttributes added in v1.17.3 

type Predicate_OrPredicateAttributes struct {
	OrPredicateAttributes *OrPredicateAttributes `protobuf:"bytes,5,opt,name=or_predicate_attributes,json=orPredicateAttributes,proto3,oneof"`
}

type Predicate_OutboundTaskGroupPredicateAttributes added in v1.25.0 

type Predicate_OutboundTaskGroupPredicateAttributes struct {
	OutboundTaskGroupPredicateAttributes *OutboundTaskGroupPredicateAttributes `protobuf:"bytes,10,opt,name=outbound_task_group_predicate_attributes,json=outboundTaskGroupPredicateAttributes,proto3,oneof"`
}

type Predicate_OutboundTaskPredicateAttributes added in v1.25.0 

type Predicate_OutboundTaskPredicateAttributes struct {
	OutboundTaskPredicateAttributes *OutboundTaskPredicateAttributes `protobuf:"bytes,11,opt,name=outbound_task_predicate_attributes,json=outboundTaskPredicateAttributes,proto3,oneof"`
}

type Predicate_TaskTypePredicateAttributes added in v1.17.3 

type Predicate_TaskTypePredicateAttributes struct {
	TaskTypePredicateAttributes *TaskTypePredicateAttributes `protobuf:"bytes,8,opt,name=task_type_predicate_attributes,json=taskTypePredicateAttributes,proto3,oneof"`
}

type Predicate_UniversalPredicateAttributes added in v1.17.3 

type Predicate_UniversalPredicateAttributes struct {
	UniversalPredicateAttributes *UniversalPredicateAttributes `protobuf:"bytes,2,opt,name=universal_predicate_attributes,json=universalPredicateAttributes,proto3,oneof"`
}

type Queue added in v1.23.0 

type Queue struct {

	// A map from partition index (0-based) to the partition metadata.
	Partitions map[int32]*QueuePartition `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Queue) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use Queue.ProtoReflect.Descriptor instead.

func (*Queue) Equal added in v1.23.0 

func (this *Queue) Equal(that interface{}) bool

Equal returns whether two Queue values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*Queue) GetPartitions added in v1.23.0 

func (x *Queue) GetPartitions() map[int32]*QueuePartition

func (*Queue) Marshal added in v1.23.0 

func (val *Queue) Marshal() ([]byte, error)

Marshal an object of type Queue to the protobuf v3 wire format

func (*Queue) ProtoMessage added in v1.23.0 

func (*Queue) ProtoMessage()

func (*Queue) ProtoReflect added in v1.23.0 

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

func (*Queue) Reset added in v1.23.0 

func (x *Queue) Reset()

func (*Queue) Size added in v1.23.0 

func (val *Queue) Size() int

Size returns the size of the object, in bytes, once serialized

func (*Queue) String added in v1.23.0 

func (x *Queue) String() string

func (*Queue) Unmarshal added in v1.23.0 

func (val *Queue) Unmarshal(buf []byte) error

Unmarshal an object of type Queue from the protobuf v3 wire format

type QueueMetadata added in v1.4.0 

type QueueMetadata struct {
	ClusterAckLevels map[string]int64 `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

data column

func (*QueueMetadata) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use QueueMetadata.ProtoReflect.Descriptor instead.

func (*QueueMetadata) Equal added in v1.4.0 

func (this *QueueMetadata) Equal(that interface{}) bool

Equal returns whether two QueueMetadata values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*QueueMetadata) GetClusterAckLevels added in v1.4.0 

func (x *QueueMetadata) GetClusterAckLevels() map[string]int64

func (*QueueMetadata) Marshal added in v1.4.0 

func (val *QueueMetadata) Marshal() ([]byte, error)

Marshal an object of type QueueMetadata to the protobuf v3 wire format

func (*QueueMetadata) ProtoMessage added in v1.4.0 

func (*QueueMetadata) ProtoMessage()

func (*QueueMetadata) ProtoReflect added in v1.23.0 

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

func (*QueueMetadata) Reset added in v1.4.0 

func (x *QueueMetadata) Reset()

func (*QueueMetadata) Size added in v1.4.0 

func (val *QueueMetadata) Size() int

Size returns the size of the object, in bytes, once serialized

func (*QueueMetadata) String added in v1.4.0 

func (x *QueueMetadata) String() string

func (*QueueMetadata) Unmarshal added in v1.4.0 

func (val *QueueMetadata) Unmarshal(buf []byte) error

Unmarshal an object of type QueueMetadata from the protobuf v3 wire format

type QueuePartition added in v1.23.0 

type QueuePartition struct {

	// min_message_id is less than or equal to the id of every message in the queue. The min_message_id is mainly used to
	// skip over tombstones in Cassandra: let's say we deleted the first 1K messages from a queue with 1.1K messages. If
	//
	//	an operator asked for the first 100 messages, without the min_message_id, we would have to scan over the 1K
	//
	// tombstone rows before we could return the 100 messages. With the min_message_id, we can skip over all of the
	// tombstones by specifying message_id >= queue.min_message_id. Note: it is possible for this to be less than the id
	// of the lowest message in the queue temporarily because we delete messages before we update the queue metadata.
	// However, such errors surface to clients with an "Unavailable" code, so clients retry, and the id should be updated
	// soon. Additionally, we only use min_message_id to skip over tombstones, so it will only affect read performance,
	// not correctness.
	MinMessageId int64 `protobuf:"varint,1,opt,name=min_message_id,json=minMessageId,proto3" json:"min_message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*QueuePartition) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use QueuePartition.ProtoReflect.Descriptor instead.

func (*QueuePartition) Equal added in v1.23.0 

func (this *QueuePartition) Equal(that interface{}) bool

Equal returns whether two QueuePartition values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*QueuePartition) GetMinMessageId added in v1.23.0 

func (x *QueuePartition) GetMinMessageId() int64

func (*QueuePartition) Marshal added in v1.23.0 

func (val *QueuePartition) Marshal() ([]byte, error)

Marshal an object of type QueuePartition to the protobuf v3 wire format

func (*QueuePartition) ProtoMessage added in v1.23.0 

func (*QueuePartition) ProtoMessage()

func (*QueuePartition) ProtoReflect added in v1.23.0 

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

func (*QueuePartition) Reset added in v1.23.0 

func (x *QueuePartition) Reset()

func (*QueuePartition) Size added in v1.23.0 

func (val *QueuePartition) Size() int

Size returns the size of the object, in bytes, once serialized

func (*QueuePartition) String added in v1.23.0 

func (x *QueuePartition) String() string

func (*QueuePartition) Unmarshal added in v1.23.0 

func (val *QueuePartition) Unmarshal(buf []byte) error

Unmarshal an object of type QueuePartition from the protobuf v3 wire format

type QueueReaderState added in v1.17.3 

type QueueReaderState struct {
	Scopes []*QueueSliceScope `protobuf:"bytes,1,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueReaderState) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use QueueReaderState.ProtoReflect.Descriptor instead.

func (*QueueReaderState) Equal added in v1.17.3 

func (this *QueueReaderState) Equal(that interface{}) bool

Equal returns whether two QueueReaderState values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*QueueReaderState) GetScopes added in v1.17.3 

func (x *QueueReaderState) GetScopes() []*QueueSliceScope

func (*QueueReaderState) Marshal added in v1.17.3 

func (val *QueueReaderState) Marshal() ([]byte, error)

Marshal an object of type QueueReaderState to the protobuf v3 wire format

func (*QueueReaderState) ProtoMessage added in v1.17.3 

func (*QueueReaderState) ProtoMessage()

func (*QueueReaderState) ProtoReflect added in v1.23.0 

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

func (*QueueReaderState) Reset added in v1.17.3 

func (x *QueueReaderState) Reset()

func (*QueueReaderState) Size added in v1.17.3 

func (val *QueueReaderState) Size() int

Size returns the size of the object, in bytes, once serialized

func (*QueueReaderState) String added in v1.17.3 

func (x *QueueReaderState) String() string

func (*QueueReaderState) Unmarshal added in v1.17.3 

func (val *QueueReaderState) Unmarshal(buf []byte) error

Unmarshal an object of type QueueReaderState from the protobuf v3 wire format

type QueueSliceRange added in v1.17.3 

type QueueSliceRange struct {
	InclusiveMin *TaskKey `protobuf:"bytes,1,opt,name=inclusive_min,json=inclusiveMin,proto3" json:"inclusive_min,omitempty"`
	ExclusiveMax *TaskKey `protobuf:"bytes,2,opt,name=exclusive_max,json=exclusiveMax,proto3" json:"exclusive_max,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueSliceRange) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use QueueSliceRange.ProtoReflect.Descriptor instead.

func (*QueueSliceRange) Equal added in v1.17.3 

func (this *QueueSliceRange) Equal(that interface{}) bool

Equal returns whether two QueueSliceRange values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*QueueSliceRange) GetExclusiveMax added in v1.17.3 

func (x *QueueSliceRange) GetExclusiveMax() *TaskKey

func (*QueueSliceRange) GetInclusiveMin added in v1.17.3 

func (x *QueueSliceRange) GetInclusiveMin() *TaskKey

func (*QueueSliceRange) Marshal added in v1.17.3 

func (val *QueueSliceRange) Marshal() ([]byte, error)

Marshal an object of type QueueSliceRange to the protobuf v3 wire format

func (*QueueSliceRange) ProtoMessage added in v1.17.3 

func (*QueueSliceRange) ProtoMessage()

func (*QueueSliceRange) ProtoReflect added in v1.23.0 

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

func (*QueueSliceRange) Reset added in v1.17.3 

func (x *QueueSliceRange) Reset()

func (*QueueSliceRange) Size added in v1.17.3 

func (val *QueueSliceRange) Size() int

Size returns the size of the object, in bytes, once serialized

func (*QueueSliceRange) String added in v1.17.3 

func (x *QueueSliceRange) String() string

func (*QueueSliceRange) Unmarshal added in v1.17.3 

func (val *QueueSliceRange) Unmarshal(buf []byte) error

Unmarshal an object of type QueueSliceRange from the protobuf v3 wire format

type QueueSliceScope added in v1.17.3 

type QueueSliceScope struct {
	Range     *QueueSliceRange `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	Predicate *Predicate       `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueSliceScope) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use QueueSliceScope.ProtoReflect.Descriptor instead.

func (*QueueSliceScope) Equal added in v1.17.3 

func (this *QueueSliceScope) Equal(that interface{}) bool

Equal returns whether two QueueSliceScope values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*QueueSliceScope) GetPredicate added in v1.17.3 

func (x *QueueSliceScope) GetPredicate() *Predicate

func (*QueueSliceScope) GetRange added in v1.17.3 

func (x *QueueSliceScope) GetRange() *QueueSliceRange

func (*QueueSliceScope) Marshal added in v1.17.3 

func (val *QueueSliceScope) Marshal() ([]byte, error)

Marshal an object of type QueueSliceScope to the protobuf v3 wire format

func (*QueueSliceScope) ProtoMessage added in v1.17.3 

func (*QueueSliceScope) ProtoMessage()

func (*QueueSliceScope) ProtoReflect added in v1.23.0 

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

func (*QueueSliceScope) Reset added in v1.17.3 

func (x *QueueSliceScope) Reset()

func (*QueueSliceScope) Size added in v1.17.3 

func (val *QueueSliceScope) Size() int

Size returns the size of the object, in bytes, once serialized

func (*QueueSliceScope) String added in v1.17.3 

func (x *QueueSliceScope) String() string

func (*QueueSliceScope) Unmarshal added in v1.17.3 

func (val *QueueSliceScope) Unmarshal(buf []byte) error

Unmarshal an object of type QueueSliceScope from the protobuf v3 wire format

type QueueState added in v1.17.3 

type QueueState struct {
	ReaderStates                 map[int64]*QueueReaderState `` /* 186-byte string literal not displayed */
	ExclusiveReaderHighWatermark *TaskKey                    `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueueState) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use QueueState.ProtoReflect.Descriptor instead.

func (*QueueState) Equal added in v1.17.3 

func (this *QueueState) Equal(that interface{}) bool

Equal returns whether two QueueState values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*QueueState) GetExclusiveReaderHighWatermark added in v1.17.3 

func (x *QueueState) GetExclusiveReaderHighWatermark() *TaskKey

func (*QueueState) GetReaderStates added in v1.17.3 

func (x *QueueState) GetReaderStates() map[int64]*QueueReaderState

func (*QueueState) Marshal added in v1.17.3 

func (val *QueueState) Marshal() ([]byte, error)

Marshal an object of type QueueState to the protobuf v3 wire format

func (*QueueState) ProtoMessage added in v1.17.3 

func (*QueueState) ProtoMessage()

func (*QueueState) ProtoReflect added in v1.23.0 

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

func (*QueueState) Reset added in v1.17.3 

func (x *QueueState) Reset()

func (*QueueState) Size added in v1.17.3 

func (val *QueueState) Size() int

Size returns the size of the object, in bytes, once serialized

func (*QueueState) String added in v1.17.3 

func (x *QueueState) String() string

func (*QueueState) Unmarshal added in v1.17.3 

func (val *QueueState) Unmarshal(buf []byte) error

Unmarshal an object of type QueueState from the protobuf v3 wire format

type ReadQueueMessagesNextPageToken added in v1.23.0 

type ReadQueueMessagesNextPageToken struct {
	LastReadMessageId int64 `protobuf:"varint,1,opt,name=last_read_message_id,json=lastReadMessageId,proto3" json:"last_read_message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadQueueMessagesNextPageToken) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use ReadQueueMessagesNextPageToken.ProtoReflect.Descriptor instead.

func (*ReadQueueMessagesNextPageToken) Equal added in v1.23.0 

func (this *ReadQueueMessagesNextPageToken) Equal(that interface{}) bool

Equal returns whether two ReadQueueMessagesNextPageToken values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ReadQueueMessagesNextPageToken) GetLastReadMessageId added in v1.23.0 

func (x *ReadQueueMessagesNextPageToken) GetLastReadMessageId() int64

func (*ReadQueueMessagesNextPageToken) Marshal added in v1.23.0 

func (val *ReadQueueMessagesNextPageToken) Marshal() ([]byte, error)

Marshal an object of type ReadQueueMessagesNextPageToken to the protobuf v3 wire format

func (*ReadQueueMessagesNextPageToken) ProtoMessage added in v1.23.0 

func (*ReadQueueMessagesNextPageToken) ProtoMessage()

func (*ReadQueueMessagesNextPageToken) ProtoReflect added in v1.23.0 

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

func (*ReadQueueMessagesNextPageToken) Reset added in v1.23.0 

func (x *ReadQueueMessagesNextPageToken) Reset()

func (*ReadQueueMessagesNextPageToken) Size added in v1.23.0 

func (val *ReadQueueMessagesNextPageToken) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ReadQueueMessagesNextPageToken) String added in v1.23.0 

func (x *ReadQueueMessagesNextPageToken) String() string

func (*ReadQueueMessagesNextPageToken) Unmarshal added in v1.23.0 

func (val *ReadQueueMessagesNextPageToken) Unmarshal(buf []byte) error

Unmarshal an object of type ReadQueueMessagesNextPageToken from the protobuf v3 wire format

type RedirectRule added in v1.24.0 

type RedirectRule struct {
	Rule *v11.CompatibleBuildIdRedirectRule `protobuf:"bytes,1,opt,name=rule,proto3" json:"rule,omitempty"`
	// (-- api-linter: core::0142::time-field-type=disabled
	//
	//	aip.dev/not-precedent: Using HLC instead of wall clock. --)
	CreateTimestamp *v1.HybridLogicalClock `protobuf:"bytes,2,opt,name=create_timestamp,json=createTimestamp,proto3" json:"create_timestamp,omitempty"`
	//	when delete_timestamp is present the rule should be treated as deleted
	//
	// (-- api-linter: core::0142::time-field-type=disabled
	//
	//	aip.dev/not-precedent: Using HLC instead of wall clock. --)
	DeleteTimestamp *v1.HybridLogicalClock `protobuf:"bytes,3,opt,name=delete_timestamp,json=deleteTimestamp,proto3" json:"delete_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*RedirectRule) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use RedirectRule.ProtoReflect.Descriptor instead.

func (*RedirectRule) Equal added in v1.24.0 

func (this *RedirectRule) Equal(that interface{}) bool

Equal returns whether two RedirectRule values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RedirectRule) GetCreateTimestamp added in v1.24.0 

func (x *RedirectRule) GetCreateTimestamp() *v1.HybridLogicalClock

func (*RedirectRule) GetDeleteTimestamp added in v1.24.0 

func (x *RedirectRule) GetDeleteTimestamp() *v1.HybridLogicalClock

func (*RedirectRule) GetRule added in v1.24.0 

func (x *RedirectRule) GetRule() *v11.CompatibleBuildIdRedirectRule

func (*RedirectRule) Marshal added in v1.24.0 

func (val *RedirectRule) Marshal() ([]byte, error)

Marshal an object of type RedirectRule to the protobuf v3 wire format

func (*RedirectRule) ProtoMessage added in v1.24.0 

func (*RedirectRule) ProtoMessage()

func (*RedirectRule) ProtoReflect added in v1.24.0 

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

func (*RedirectRule) Reset added in v1.24.0 

func (x *RedirectRule) Reset()

func (*RedirectRule) Size added in v1.24.0 

func (val *RedirectRule) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RedirectRule) String added in v1.24.0 

func (x *RedirectRule) String() string

func (*RedirectRule) Unmarshal added in v1.24.0 

func (val *RedirectRule) Unmarshal(buf []byte) error

Unmarshal an object of type RedirectRule from the protobuf v3 wire format

type ReplicationTaskInfo 

type ReplicationTaskInfo struct {
	NamespaceId         string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId          string                 `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId               string                 `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskType            v1.TaskType            `` /* 129-byte string literal not displayed */
	Version             int64                  `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	FirstEventId        int64                  `protobuf:"varint,6,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"`
	NextEventId         int64                  `protobuf:"varint,7,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	ScheduledEventId    int64                  `protobuf:"varint,8,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	BranchToken         []byte                 `protobuf:"bytes,11,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
	NewRunBranchToken   []byte                 `protobuf:"bytes,13,opt,name=new_run_branch_token,json=newRunBranchToken,proto3" json:"new_run_branch_token,omitempty"`
	TaskId              int64                  `protobuf:"varint,15,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime      *timestamppb.Timestamp `protobuf:"bytes,16,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
	NewRunId            string                 `protobuf:"bytes,17,opt,name=new_run_id,json=newRunId,proto3" json:"new_run_id,omitempty"`
	Priority            v1.TaskPriority        `protobuf:"varint,18,opt,name=priority,proto3,enum=temporal.server.api.enums.v1.TaskPriority" json:"priority,omitempty"`
	VersionedTransition *VersionedTransition   `protobuf:"bytes,19,opt,name=versioned_transition,json=versionedTransition,proto3" json:"versioned_transition,omitempty"`
	// contains filtered or unexported fields
}

replication column

func (*ReplicationTaskInfo) Descriptor deprecated 

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

Deprecated: Use ReplicationTaskInfo.ProtoReflect.Descriptor instead.

func (*ReplicationTaskInfo) Equal 

func (this *ReplicationTaskInfo) Equal(that interface{}) bool

Equal returns whether two ReplicationTaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ReplicationTaskInfo) GetBranchToken 

func (x *ReplicationTaskInfo) GetBranchToken() []byte

func (*ReplicationTaskInfo) GetFirstEventId 

func (x *ReplicationTaskInfo) GetFirstEventId() int64

func (*ReplicationTaskInfo) GetNamespaceId 

func (x *ReplicationTaskInfo) GetNamespaceId() string

func (*ReplicationTaskInfo) GetNewRunBranchToken 

func (x *ReplicationTaskInfo) GetNewRunBranchToken() []byte

func (*ReplicationTaskInfo) GetNewRunId added in v1.18.1 

func (x *ReplicationTaskInfo) GetNewRunId() string

func (*ReplicationTaskInfo) GetNextEventId 

func (x *ReplicationTaskInfo) GetNextEventId() int64

func (*ReplicationTaskInfo) GetPriority added in v1.24.0 

func (x *ReplicationTaskInfo) GetPriority() v1.TaskPriority

func (*ReplicationTaskInfo) GetRunId 

func (x *ReplicationTaskInfo) GetRunId() string

func (*ReplicationTaskInfo) GetScheduledEventId added in v1.17.0 

func (x *ReplicationTaskInfo) GetScheduledEventId() int64

func (*ReplicationTaskInfo) GetTaskId 

func (x *ReplicationTaskInfo) GetTaskId() int64

func (*ReplicationTaskInfo) GetTaskType 

func (x *ReplicationTaskInfo) GetTaskType() v1.TaskType

func (*ReplicationTaskInfo) GetVersion 

func (x *ReplicationTaskInfo) GetVersion() int64

func (*ReplicationTaskInfo) GetVersionedTransition added in v1.25.0 

func (x *ReplicationTaskInfo) GetVersionedTransition() *VersionedTransition

func (*ReplicationTaskInfo) GetVisibilityTime added in v1.14.0 

func (x *ReplicationTaskInfo) GetVisibilityTime() *timestamppb.Timestamp

func (*ReplicationTaskInfo) GetWorkflowId 

func (x *ReplicationTaskInfo) GetWorkflowId() string

func (*ReplicationTaskInfo) Marshal 

func (val *ReplicationTaskInfo) Marshal() ([]byte, error)

Marshal an object of type ReplicationTaskInfo to the protobuf v3 wire format

func (*ReplicationTaskInfo) ProtoMessage 

func (*ReplicationTaskInfo) ProtoMessage()

func (*ReplicationTaskInfo) ProtoReflect added in v1.23.0 

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

func (*ReplicationTaskInfo) Reset 

func (x *ReplicationTaskInfo) Reset()

func (*ReplicationTaskInfo) Size 

func (val *ReplicationTaskInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ReplicationTaskInfo) String 

func (x *ReplicationTaskInfo) String() string

func (*ReplicationTaskInfo) Unmarshal 

func (val *ReplicationTaskInfo) Unmarshal(buf []byte) error

Unmarshal an object of type ReplicationTaskInfo from the protobuf v3 wire format

type RequestCancelInfo 

type RequestCancelInfo struct {
	Version                       int64                `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	InitiatedEventBatchId         int64                `` /* 129-byte string literal not displayed */
	CancelRequestId               string               `protobuf:"bytes,3,opt,name=cancel_request_id,json=cancelRequestId,proto3" json:"cancel_request_id,omitempty"`
	InitiatedEventId              int64                `protobuf:"varint,4,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"`
	LastUpdateVersionedTransition *VersionedTransition `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

request_cancel_map column

func (*RequestCancelInfo) Descriptor deprecated 

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

Deprecated: Use RequestCancelInfo.ProtoReflect.Descriptor instead.

func (*RequestCancelInfo) Equal 

func (this *RequestCancelInfo) Equal(that interface{}) bool

Equal returns whether two RequestCancelInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RequestCancelInfo) GetCancelRequestId 

func (x *RequestCancelInfo) GetCancelRequestId() string

func (*RequestCancelInfo) GetInitiatedEventBatchId 

func (x *RequestCancelInfo) GetInitiatedEventBatchId() int64

func (*RequestCancelInfo) GetInitiatedEventId added in v1.17.0 

func (x *RequestCancelInfo) GetInitiatedEventId() int64

func (*RequestCancelInfo) GetLastUpdateVersionedTransition added in v1.25.0 

func (x *RequestCancelInfo) GetLastUpdateVersionedTransition() *VersionedTransition

func (*RequestCancelInfo) GetVersion 

func (x *RequestCancelInfo) GetVersion() int64

func (*RequestCancelInfo) Marshal 

func (val *RequestCancelInfo) Marshal() ([]byte, error)

Marshal an object of type RequestCancelInfo to the protobuf v3 wire format

func (*RequestCancelInfo) ProtoMessage 

func (*RequestCancelInfo) ProtoMessage()

func (*RequestCancelInfo) ProtoReflect added in v1.23.0 

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

func (*RequestCancelInfo) Reset 

func (x *RequestCancelInfo) Reset()

func (*RequestCancelInfo) Size 

func (val *RequestCancelInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RequestCancelInfo) String 

func (x *RequestCancelInfo) String() string

func (*RequestCancelInfo) Unmarshal 

func (val *RequestCancelInfo) Unmarshal(buf []byte) error

Unmarshal an object of type RequestCancelInfo from the protobuf v3 wire format

type ShardInfo 

type ShardInfo struct {
	ShardId int32  `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	RangeId int64  `protobuf:"varint,2,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	Owner   string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "since" is needed here. --)
	StolenSinceRenew       int32                  `protobuf:"varint,6,opt,name=stolen_since_renew,json=stolenSinceRenew,proto3" json:"stolen_since_renew,omitempty"`
	UpdateTime             *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	ReplicationDlqAckLevel map[string]int64       `` /* 221-byte string literal not displayed */
	QueueStates            map[int32]*QueueState  `` /* 184-byte string literal not displayed */
	// contains filtered or unexported fields
}

shard column

func (*ShardInfo) Descriptor deprecated 

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

Deprecated: Use ShardInfo.ProtoReflect.Descriptor instead.

func (*ShardInfo) Equal 

func (this *ShardInfo) Equal(that interface{}) bool

Equal returns whether two ShardInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ShardInfo) GetOwner 

func (x *ShardInfo) GetOwner() string

func (*ShardInfo) GetQueueStates added in v1.17.3 

func (x *ShardInfo) GetQueueStates() map[int32]*QueueState

func (*ShardInfo) GetRangeId 

func (x *ShardInfo) GetRangeId() int64

func (*ShardInfo) GetReplicationDlqAckLevel 

func (x *ShardInfo) GetReplicationDlqAckLevel() map[string]int64

func (*ShardInfo) GetShardId 

func (x *ShardInfo) GetShardId() int32

func (*ShardInfo) GetStolenSinceRenew 

func (x *ShardInfo) GetStolenSinceRenew() int32

func (*ShardInfo) GetUpdateTime 

func (x *ShardInfo) GetUpdateTime() *timestamppb.Timestamp

func (*ShardInfo) Marshal 

func (val *ShardInfo) Marshal() ([]byte, error)

Marshal an object of type ShardInfo to the protobuf v3 wire format

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) ProtoReflect added in v1.23.0 

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

func (*ShardInfo) Reset 

func (x *ShardInfo) Reset()

func (*ShardInfo) Size 

func (val *ShardInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ShardInfo) String 

func (x *ShardInfo) String() string

func (*ShardInfo) Unmarshal 

func (val *ShardInfo) Unmarshal(buf []byte) error

Unmarshal an object of type ShardInfo from the protobuf v3 wire format

type SignalInfo 

type SignalInfo struct {
	Version                       int64                `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	InitiatedEventBatchId         int64                `` /* 129-byte string literal not displayed */
	RequestId                     string               `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	InitiatedEventId              int64                `protobuf:"varint,7,opt,name=initiated_event_id,json=initiatedEventId,proto3" json:"initiated_event_id,omitempty"`
	LastUpdateVersionedTransition *VersionedTransition `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

signal_map column

func (*SignalInfo) Descriptor deprecated 

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

Deprecated: Use SignalInfo.ProtoReflect.Descriptor instead.

func (*SignalInfo) Equal 

func (this *SignalInfo) Equal(that interface{}) bool

Equal returns whether two SignalInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*SignalInfo) GetInitiatedEventBatchId 

func (x *SignalInfo) GetInitiatedEventBatchId() int64

func (*SignalInfo) GetInitiatedEventId added in v1.17.0 

func (x *SignalInfo) GetInitiatedEventId() int64

func (*SignalInfo) GetLastUpdateVersionedTransition added in v1.25.0 

func (x *SignalInfo) GetLastUpdateVersionedTransition() *VersionedTransition

func (*SignalInfo) GetRequestId 

func (x *SignalInfo) GetRequestId() string

func (*SignalInfo) GetVersion 

func (x *SignalInfo) GetVersion() int64

func (*SignalInfo) Marshal 

func (val *SignalInfo) Marshal() ([]byte, error)

Marshal an object of type SignalInfo to the protobuf v3 wire format

func (*SignalInfo) ProtoMessage 

func (*SignalInfo) ProtoMessage()

func (*SignalInfo) ProtoReflect added in v1.23.0 

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

func (*SignalInfo) Reset 

func (x *SignalInfo) Reset()

func (*SignalInfo) Size 

func (val *SignalInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*SignalInfo) String 

func (x *SignalInfo) String() string

func (*SignalInfo) Unmarshal 

func (val *SignalInfo) Unmarshal(buf []byte) error

Unmarshal an object of type SignalInfo from the protobuf v3 wire format

type StateMachineKey added in v1.24.0 

type StateMachineKey struct {

	// Addressable type of the corresponding state machine in a single tree level.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Addressable ID of the corresponding state machine in a single tree level.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*StateMachineKey) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use StateMachineKey.ProtoReflect.Descriptor instead.

func (*StateMachineKey) Equal added in v1.24.0 

func (this *StateMachineKey) Equal(that interface{}) bool

Equal returns whether two StateMachineKey values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StateMachineKey) GetId added in v1.24.0 

func (x *StateMachineKey) GetId() string

func (*StateMachineKey) GetType added in v1.24.0 

func (x *StateMachineKey) GetType() string

func (*StateMachineKey) Marshal added in v1.24.0 

func (val *StateMachineKey) Marshal() ([]byte, error)

Marshal an object of type StateMachineKey to the protobuf v3 wire format

func (*StateMachineKey) ProtoMessage added in v1.24.0 

func (*StateMachineKey) ProtoMessage()

func (*StateMachineKey) ProtoReflect added in v1.24.0 

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

func (*StateMachineKey) Reset added in v1.24.0 

func (x *StateMachineKey) Reset()

func (*StateMachineKey) Size added in v1.24.0 

func (val *StateMachineKey) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StateMachineKey) String added in v1.24.0 

func (x *StateMachineKey) String() string

func (*StateMachineKey) Unmarshal added in v1.24.0 

func (val *StateMachineKey) Unmarshal(buf []byte) error

Unmarshal an object of type StateMachineKey from the protobuf v3 wire format

type StateMachineMap added in v1.24.0 

type StateMachineMap struct {

	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "by" is used to clarify the keys and values. --)
	MachinesById map[string]*StateMachineNode `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

Map of state machine ID to StateMachineNode.

func (*StateMachineMap) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use StateMachineMap.ProtoReflect.Descriptor instead.

func (*StateMachineMap) Equal added in v1.24.0 

func (this *StateMachineMap) Equal(that interface{}) bool

Equal returns whether two StateMachineMap values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StateMachineMap) GetMachinesById added in v1.24.0 

func (x *StateMachineMap) GetMachinesById() map[string]*StateMachineNode

func (*StateMachineMap) Marshal added in v1.24.0 

func (val *StateMachineMap) Marshal() ([]byte, error)

Marshal an object of type StateMachineMap to the protobuf v3 wire format

func (*StateMachineMap) ProtoMessage added in v1.24.0 

func (*StateMachineMap) ProtoMessage()

func (*StateMachineMap) ProtoReflect added in v1.24.0 

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

func (*StateMachineMap) Reset added in v1.24.0 

func (x *StateMachineMap) Reset()

func (*StateMachineMap) Size added in v1.24.0 

func (val *StateMachineMap) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StateMachineMap) String added in v1.24.0 

func (x *StateMachineMap) String() string

func (*StateMachineMap) Unmarshal added in v1.24.0 

func (val *StateMachineMap) Unmarshal(buf []byte) error

Unmarshal an object of type StateMachineMap from the protobuf v3 wire format

type StateMachineNode added in v1.24.0 

type StateMachineNode struct {

	// Serialized data of the underlying state machine.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Map of state machine type to a map of machines by ID.
	Children map[string]*StateMachineMap `` /* 157-byte string literal not displayed */
	// Versioned transition when the node was instantiated.
	// This field, plus node path uniquely identifies a state machine node in a mutable state instance.
	// This field will always be set even when transition history is disabled.
	// NOTE: If transition history is disabled, the transition_count field will be 0 and
	// cannot be used to uniquely identify a node.
	// NOTE: Node deletion is not yet implemented at the time of writing so we can still uniquely identify a node just
	// with the initial namespace failover version.
	InitialVersionedTransition *VersionedTransition `` /* 141-byte string literal not displayed */
	// Versioned transition when the node was last updated.
	// This field will always be set even when transition history is disabled.
	// NOTE: If transition history is disabled, the transition_count field will be 0 and
	// cannot be used for non-concurrent task staleness check or to determine whether this node should be synced
	// during state replication.
	LastUpdateVersionedTransition *VersionedTransition `` /* 152-byte string literal not displayed */
	// Number of transitions on this state machine object.
	// Used to verify that a task is not stale if the state machine does not allow concurrent task execution.
	// The transition count monotonically increases with each state transition and only resets when the entire
	// mutable state was rebuilt. This case is handled by the task_generation_shard_clock_timestamp field in
	// WorkflowExecutionInfo.
	// NOTE: This field is cluster specific and cannot be replicated.
	// NOTE: This field will be made obsolete when transition history is enabled in favor of
	// last_update_versioned_transition.
	TransitionCount int64 `protobuf:"varint,100,opt,name=transition_count,json=transitionCount,proto3" json:"transition_count,omitempty"`
	// contains filtered or unexported fields
}

A node in a hierarchical state machine tree.

func (*StateMachineNode) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use StateMachineNode.ProtoReflect.Descriptor instead.

func (*StateMachineNode) Equal added in v1.24.0 

func (this *StateMachineNode) Equal(that interface{}) bool

Equal returns whether two StateMachineNode values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StateMachineNode) GetChildren added in v1.24.0 

func (x *StateMachineNode) GetChildren() map[string]*StateMachineMap

func (*StateMachineNode) GetData added in v1.24.0 

func (x *StateMachineNode) GetData() []byte

func (*StateMachineNode) GetInitialVersionedTransition added in v1.25.0 

func (x *StateMachineNode) GetInitialVersionedTransition() *VersionedTransition

func (*StateMachineNode) GetLastUpdateVersionedTransition added in v1.25.0 

func (x *StateMachineNode) GetLastUpdateVersionedTransition() *VersionedTransition

func (*StateMachineNode) GetTransitionCount added in v1.24.0 

func (x *StateMachineNode) GetTransitionCount() int64

func (*StateMachineNode) Marshal added in v1.24.0 

func (val *StateMachineNode) Marshal() ([]byte, error)

Marshal an object of type StateMachineNode to the protobuf v3 wire format

func (*StateMachineNode) ProtoMessage added in v1.24.0 

func (*StateMachineNode) ProtoMessage()

func (*StateMachineNode) ProtoReflect added in v1.24.0 

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

func (*StateMachineNode) Reset added in v1.24.0 

func (x *StateMachineNode) Reset()

func (*StateMachineNode) Size added in v1.24.0 

func (val *StateMachineNode) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StateMachineNode) String added in v1.24.0 

func (x *StateMachineNode) String() string

func (*StateMachineNode) Unmarshal added in v1.24.0 

func (val *StateMachineNode) Unmarshal(buf []byte) error

Unmarshal an object of type StateMachineNode from the protobuf v3 wire format

type StateMachinePath added in v1.25.0 

type StateMachinePath struct {
	Path []*StateMachineKey `protobuf:"bytes,1,rep,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*StateMachinePath) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use StateMachinePath.ProtoReflect.Descriptor instead.

func (*StateMachinePath) Equal added in v1.25.0 

func (this *StateMachinePath) Equal(that interface{}) bool

Equal returns whether two StateMachinePath values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StateMachinePath) GetPath added in v1.25.0 

func (x *StateMachinePath) GetPath() []*StateMachineKey

func (*StateMachinePath) Marshal added in v1.25.0 

func (val *StateMachinePath) Marshal() ([]byte, error)

Marshal an object of type StateMachinePath to the protobuf v3 wire format

func (*StateMachinePath) ProtoMessage added in v1.25.0 

func (*StateMachinePath) ProtoMessage()

func (*StateMachinePath) ProtoReflect added in v1.25.0 

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

func (*StateMachinePath) Reset added in v1.25.0 

func (x *StateMachinePath) Reset()

func (*StateMachinePath) Size added in v1.25.0 

func (val *StateMachinePath) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StateMachinePath) String added in v1.25.0 

func (x *StateMachinePath) String() string

func (*StateMachinePath) Unmarshal added in v1.25.0 

func (val *StateMachinePath) Unmarshal(buf []byte) error

Unmarshal an object of type StateMachinePath from the protobuf v3 wire format

type StateMachineRef added in v1.24.0 

type StateMachineRef struct {

	// Nested path to a state machine.
	Path []*StateMachineKey `protobuf:"bytes,1,rep,name=path,proto3" json:"path,omitempty"`
	// Versioned transition of the ref was instantiated.
	// Used to verify that the ref is not referencing a stale state or, in some situations,
	// that the ref itself is not stale.
	// NOTE: If transition history is disabled, the field will not be specified and
	// cannot be used for staleness check.
	MutableStateVersionedTransition *VersionedTransition `` /* 158-byte string literal not displayed */
	// Versioned transition when the state machine node was instantiated.
	// This field, plus node path uniquely identifies a state machine node in a mutable state instance.
	// This field will always be set even when transition history is disabled.
	// NOTE: If transition history is disabled, the transition_count field will be 0 and
	// cannot be used to uniquely identify a node.
	// NOTE: Node deletion is not yet implemented at the time of writing so we can still uniquely identify a node just
	// with the initial namespace failover version.
	MachineInitialVersionedTransition *VersionedTransition `` /* 164-byte string literal not displayed */
	// Versioned transition when the state machine node was last updated.
	// If not specified, this reference is considered non-concurrent,
	// and should match the last_update_versioned_transition on the corresponding state machine node.
	// NOTE: If transition history is disabled, the transition_count field will be 0 and
	// cannot be used for non-concurrent task staleness check.
	MachineLastUpdateVersionedTransition *VersionedTransition `` /* 175-byte string literal not displayed */
	// Number of transitions executed on the referenced state machine node at the time this Ref is instantiated.
	// If non-zero, this reference is considered non-concurrent and this number should match the number of state
	// transitions on the corresponding state machine node.
	// This field will be obsolete once mutable state transition history is productionized.
	MachineTransitionCount int64 `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

A reference to a state machine at a point in time.

func (*StateMachineRef) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use StateMachineRef.ProtoReflect.Descriptor instead.

func (*StateMachineRef) Equal added in v1.24.0 

func (this *StateMachineRef) Equal(that interface{}) bool

Equal returns whether two StateMachineRef values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StateMachineRef) GetMachineInitialVersionedTransition added in v1.25.0 

func (x *StateMachineRef) GetMachineInitialVersionedTransition() *VersionedTransition

func (*StateMachineRef) GetMachineLastUpdateVersionedTransition added in v1.25.0 

func (x *StateMachineRef) GetMachineLastUpdateVersionedTransition() *VersionedTransition

func (*StateMachineRef) GetMachineTransitionCount added in v1.24.0 

func (x *StateMachineRef) GetMachineTransitionCount() int64

func (*StateMachineRef) GetMutableStateVersionedTransition added in v1.25.0 

func (x *StateMachineRef) GetMutableStateVersionedTransition() *VersionedTransition

func (*StateMachineRef) GetPath added in v1.24.0 

func (x *StateMachineRef) GetPath() []*StateMachineKey

func (*StateMachineRef) Marshal added in v1.24.0 

func (val *StateMachineRef) Marshal() ([]byte, error)

Marshal an object of type StateMachineRef to the protobuf v3 wire format

func (*StateMachineRef) ProtoMessage added in v1.24.0 

func (*StateMachineRef) ProtoMessage()

func (*StateMachineRef) ProtoReflect added in v1.24.0 

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

func (*StateMachineRef) Reset added in v1.24.0 

func (x *StateMachineRef) Reset()

func (*StateMachineRef) Size added in v1.24.0 

func (val *StateMachineRef) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StateMachineRef) String added in v1.24.0 

func (x *StateMachineRef) String() string

func (*StateMachineRef) Unmarshal added in v1.24.0 

func (val *StateMachineRef) Unmarshal(buf []byte) error

Unmarshal an object of type StateMachineRef from the protobuf v3 wire format

type StateMachineTaskInfo added in v1.24.0 

type StateMachineTaskInfo struct {

	// Reference to a state machine.
	Ref *StateMachineRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Task type. Not to be confused with the state machine's type in the `ref` field.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Opaque data attached to this task. May be nil. Deserialized by a registered TaskSerializer for this type.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StateMachineTaskInfo) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use StateMachineTaskInfo.ProtoReflect.Descriptor instead.

func (*StateMachineTaskInfo) Equal added in v1.24.0 

func (this *StateMachineTaskInfo) Equal(that interface{}) bool

Equal returns whether two StateMachineTaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StateMachineTaskInfo) GetData added in v1.24.0 

func (x *StateMachineTaskInfo) GetData() []byte

func (*StateMachineTaskInfo) GetRef added in v1.24.0 

func (x *StateMachineTaskInfo) GetRef() *StateMachineRef

func (*StateMachineTaskInfo) GetType added in v1.24.0 

func (x *StateMachineTaskInfo) GetType() string

func (*StateMachineTaskInfo) Marshal added in v1.24.0 

func (val *StateMachineTaskInfo) Marshal() ([]byte, error)

Marshal an object of type StateMachineTaskInfo to the protobuf v3 wire format

func (*StateMachineTaskInfo) ProtoMessage added in v1.24.0 

func (*StateMachineTaskInfo) ProtoMessage()

func (*StateMachineTaskInfo) ProtoReflect added in v1.24.0 

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

func (*StateMachineTaskInfo) Reset added in v1.24.0 

func (x *StateMachineTaskInfo) Reset()

func (*StateMachineTaskInfo) Size added in v1.24.0 

func (val *StateMachineTaskInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StateMachineTaskInfo) String added in v1.24.0 

func (x *StateMachineTaskInfo) String() string

func (*StateMachineTaskInfo) Unmarshal added in v1.24.0 

func (val *StateMachineTaskInfo) Unmarshal(buf []byte) error

Unmarshal an object of type StateMachineTaskInfo from the protobuf v3 wire format

type StateMachineTimerGroup added in v1.25.0 

type StateMachineTimerGroup struct {

	// Task information.
	Infos []*StateMachineTaskInfo `protobuf:"bytes,1,rep,name=infos,proto3" json:"infos,omitempty"`
	// When this timer should be fired.
	// (-- api-linter: core::0142::time-field-names=disabled
	//
	//	aip.dev/not-precedent: Ignoring lint rules. --)
	Deadline *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// Whether or not a task was put in the queue for this group's deadline.
	Scheduled bool `protobuf:"varint,3,opt,name=scheduled,proto3" json:"scheduled,omitempty"`
	// contains filtered or unexported fields
}

A group of state machine timer tasks for a given deadline, used for collapsing state machine timer tasks.

func (*StateMachineTimerGroup) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use StateMachineTimerGroup.ProtoReflect.Descriptor instead.

func (*StateMachineTimerGroup) Equal added in v1.25.0 

func (this *StateMachineTimerGroup) Equal(that interface{}) bool

Equal returns whether two StateMachineTimerGroup values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StateMachineTimerGroup) GetDeadline added in v1.25.0 

func (x *StateMachineTimerGroup) GetDeadline() *timestamppb.Timestamp

func (*StateMachineTimerGroup) GetInfos added in v1.25.0 

func (x *StateMachineTimerGroup) GetInfos() []*StateMachineTaskInfo

func (*StateMachineTimerGroup) GetScheduled added in v1.25.0 

func (x *StateMachineTimerGroup) GetScheduled() bool

func (*StateMachineTimerGroup) Marshal added in v1.25.0 

func (val *StateMachineTimerGroup) Marshal() ([]byte, error)

Marshal an object of type StateMachineTimerGroup to the protobuf v3 wire format

func (*StateMachineTimerGroup) ProtoMessage added in v1.25.0 

func (*StateMachineTimerGroup) ProtoMessage()

func (*StateMachineTimerGroup) ProtoReflect added in v1.25.0 

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

func (*StateMachineTimerGroup) Reset added in v1.25.0 

func (x *StateMachineTimerGroup) Reset()

func (*StateMachineTimerGroup) Size added in v1.25.0 

func (val *StateMachineTimerGroup) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StateMachineTimerGroup) String added in v1.25.0 

func (x *StateMachineTimerGroup) String() string

func (*StateMachineTimerGroup) Unmarshal added in v1.25.0 

func (val *StateMachineTimerGroup) Unmarshal(buf []byte) error

Unmarshal an object of type StateMachineTimerGroup from the protobuf v3 wire format

type StateMachineTombstone added in v1.25.0 

type StateMachineTombstone struct {

	// Types that are assignable to StateMachineKey:
	//
	//	*StateMachineTombstone_ActivityScheduledEventId
	//	*StateMachineTombstone_TimerId
	//	*StateMachineTombstone_ChildExecutionInitiatedEventId
	//	*StateMachineTombstone_RequestCancelInitiatedEventId
	//	*StateMachineTombstone_SignalExternalInitiatedEventId
	//	*StateMachineTombstone_UpdateId
	//	*StateMachineTombstone_StateMachinePath
	StateMachineKey isStateMachineTombstone_StateMachineKey `protobuf_oneof:"state_machine_key"`
	// contains filtered or unexported fields
}

func (*StateMachineTombstone) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use StateMachineTombstone.ProtoReflect.Descriptor instead.

func (*StateMachineTombstone) Equal added in v1.25.0 

func (this *StateMachineTombstone) Equal(that interface{}) bool

Equal returns whether two StateMachineTombstone values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StateMachineTombstone) GetActivityScheduledEventId added in v1.25.0 

func (x *StateMachineTombstone) GetActivityScheduledEventId() int64

func (*StateMachineTombstone) GetChildExecutionInitiatedEventId added in v1.25.0 

func (x *StateMachineTombstone) GetChildExecutionInitiatedEventId() int64

func (*StateMachineTombstone) GetRequestCancelInitiatedEventId added in v1.25.0 

func (x *StateMachineTombstone) GetRequestCancelInitiatedEventId() int64

func (*StateMachineTombstone) GetSignalExternalInitiatedEventId added in v1.25.0 

func (x *StateMachineTombstone) GetSignalExternalInitiatedEventId() int64

func (*StateMachineTombstone) GetStateMachineKey added in v1.25.0 

func (m *StateMachineTombstone) GetStateMachineKey() isStateMachineTombstone_StateMachineKey

func (*StateMachineTombstone) GetStateMachinePath added in v1.25.0 

func (x *StateMachineTombstone) GetStateMachinePath() *StateMachinePath

func (*StateMachineTombstone) GetTimerId added in v1.25.0 

func (x *StateMachineTombstone) GetTimerId() string

func (*StateMachineTombstone) GetUpdateId added in v1.25.0 

func (x *StateMachineTombstone) GetUpdateId() string

func (*StateMachineTombstone) Marshal added in v1.25.0 

func (val *StateMachineTombstone) Marshal() ([]byte, error)

Marshal an object of type StateMachineTombstone to the protobuf v3 wire format

func (*StateMachineTombstone) ProtoMessage added in v1.25.0 

func (*StateMachineTombstone) ProtoMessage()

func (*StateMachineTombstone) ProtoReflect added in v1.25.0 

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

func (*StateMachineTombstone) Reset added in v1.25.0 

func (x *StateMachineTombstone) Reset()

func (*StateMachineTombstone) Size added in v1.25.0 

func (val *StateMachineTombstone) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StateMachineTombstone) String added in v1.25.0 

func (x *StateMachineTombstone) String() string

func (*StateMachineTombstone) Unmarshal added in v1.25.0 

func (val *StateMachineTombstone) Unmarshal(buf []byte) error

Unmarshal an object of type StateMachineTombstone from the protobuf v3 wire format

type StateMachineTombstoneBatch added in v1.25.0 

type StateMachineTombstoneBatch struct {

	// The versioned transition in which the tombstones were created.
	VersionedTransition    *VersionedTransition     `protobuf:"bytes,1,opt,name=versioned_transition,json=versionedTransition,proto3" json:"versioned_transition,omitempty"`
	StateMachineTombstones []*StateMachineTombstone `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StateMachineTombstoneBatch) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use StateMachineTombstoneBatch.ProtoReflect.Descriptor instead.

func (*StateMachineTombstoneBatch) Equal added in v1.25.0 

func (this *StateMachineTombstoneBatch) Equal(that interface{}) bool

Equal returns whether two StateMachineTombstoneBatch values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StateMachineTombstoneBatch) GetStateMachineTombstones added in v1.25.0 

func (x *StateMachineTombstoneBatch) GetStateMachineTombstones() []*StateMachineTombstone

func (*StateMachineTombstoneBatch) GetVersionedTransition added in v1.25.0 

func (x *StateMachineTombstoneBatch) GetVersionedTransition() *VersionedTransition

func (*StateMachineTombstoneBatch) Marshal added in v1.25.0 

func (val *StateMachineTombstoneBatch) Marshal() ([]byte, error)

Marshal an object of type StateMachineTombstoneBatch to the protobuf v3 wire format

func (*StateMachineTombstoneBatch) ProtoMessage added in v1.25.0 

func (*StateMachineTombstoneBatch) ProtoMessage()

func (*StateMachineTombstoneBatch) ProtoReflect added in v1.25.0 

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

func (*StateMachineTombstoneBatch) Reset added in v1.25.0 

func (x *StateMachineTombstoneBatch) Reset()

func (*StateMachineTombstoneBatch) Size added in v1.25.0 

func (val *StateMachineTombstoneBatch) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StateMachineTombstoneBatch) String added in v1.25.0 

func (x *StateMachineTombstoneBatch) String() string

func (*StateMachineTombstoneBatch) Unmarshal added in v1.25.0 

func (val *StateMachineTombstoneBatch) Unmarshal(buf []byte) error

Unmarshal an object of type StateMachineTombstoneBatch from the protobuf v3 wire format

type StateMachineTombstone_ActivityScheduledEventId added in v1.25.0 

type StateMachineTombstone_ActivityScheduledEventId struct {
	ActivityScheduledEventId int64 `protobuf:"varint,1,opt,name=activity_scheduled_event_id,json=activityScheduledEventId,proto3,oneof"`
}

type StateMachineTombstone_ChildExecutionInitiatedEventId added in v1.25.0 

type StateMachineTombstone_ChildExecutionInitiatedEventId struct {
	ChildExecutionInitiatedEventId int64 `protobuf:"varint,3,opt,name=child_execution_initiated_event_id,json=childExecutionInitiatedEventId,proto3,oneof"`
}

type StateMachineTombstone_RequestCancelInitiatedEventId added in v1.25.0 

type StateMachineTombstone_RequestCancelInitiatedEventId struct {
	RequestCancelInitiatedEventId int64 `protobuf:"varint,4,opt,name=request_cancel_initiated_event_id,json=requestCancelInitiatedEventId,proto3,oneof"`
}

type StateMachineTombstone_SignalExternalInitiatedEventId added in v1.25.0 

type StateMachineTombstone_SignalExternalInitiatedEventId struct {
	SignalExternalInitiatedEventId int64 `protobuf:"varint,5,opt,name=signal_external_initiated_event_id,json=signalExternalInitiatedEventId,proto3,oneof"`
}

type StateMachineTombstone_StateMachinePath added in v1.25.0 

type StateMachineTombstone_StateMachinePath struct {
	StateMachinePath *StateMachinePath `protobuf:"bytes,7,opt,name=state_machine_path,json=stateMachinePath,proto3,oneof"`
}

type StateMachineTombstone_TimerId added in v1.25.0 

type StateMachineTombstone_TimerId struct {
	TimerId string `protobuf:"bytes,2,opt,name=timer_id,json=timerId,proto3,oneof"`
}

type StateMachineTombstone_UpdateId added in v1.25.0 

type StateMachineTombstone_UpdateId struct {
	UpdateId string `protobuf:"bytes,6,opt,name=update_id,json=updateId,proto3,oneof"`
}

type TaskInfo 

type TaskInfo struct {
	NamespaceId      string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId       string                 `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId            string                 `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	ScheduledEventId int64                  `protobuf:"varint,4,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	CreateTime       *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	ExpiryTime       *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=expiry_time,json=expiryTime,proto3" json:"expiry_time,omitempty"`
	Clock            *v1.VectorClock        `protobuf:"bytes,7,opt,name=clock,proto3" json:"clock,omitempty"`
	// How this task should be directed. (Missing means the default for
	// TaskVersionDirective, which is unversioned.)
	// Deprecated. No need to store this for new versioning [cleanup-old-wv]
	VersionDirective *v11.TaskVersionDirective `protobuf:"bytes,8,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskInfo) Descriptor deprecated 

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

Deprecated: Use TaskInfo.ProtoReflect.Descriptor instead.

func (*TaskInfo) Equal 

func (this *TaskInfo) Equal(that interface{}) bool

Equal returns whether two TaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TaskInfo) GetClock added in v1.17.0 

func (x *TaskInfo) GetClock() *v1.VectorClock

func (*TaskInfo) GetCreateTime 

func (x *TaskInfo) GetCreateTime() *timestamppb.Timestamp

func (*TaskInfo) GetExpiryTime 

func (x *TaskInfo) GetExpiryTime() *timestamppb.Timestamp

func (*TaskInfo) GetNamespaceId 

func (x *TaskInfo) GetNamespaceId() string

func (*TaskInfo) GetRunId 

func (x *TaskInfo) GetRunId() string

func (*TaskInfo) GetScheduledEventId added in v1.17.0 

func (x *TaskInfo) GetScheduledEventId() int64

func (*TaskInfo) GetVersionDirective added in v1.21.0 

func (x *TaskInfo) GetVersionDirective() *v11.TaskVersionDirective

func (*TaskInfo) GetWorkflowId 

func (x *TaskInfo) GetWorkflowId() string

func (*TaskInfo) Marshal 

func (val *TaskInfo) Marshal() ([]byte, error)

Marshal an object of type TaskInfo to the protobuf v3 wire format

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) ProtoReflect added in v1.23.0 

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

func (*TaskInfo) Reset 

func (x *TaskInfo) Reset()

func (*TaskInfo) Size 

func (val *TaskInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TaskInfo) String 

func (x *TaskInfo) String() string

func (*TaskInfo) Unmarshal 

func (val *TaskInfo) Unmarshal(buf []byte) error

Unmarshal an object of type TaskInfo from the protobuf v3 wire format

type TaskKey added in v1.17.3 

type TaskKey struct {
	FireTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=fire_time,json=fireTime,proto3" json:"fire_time,omitempty"`
	TaskId   int64                  `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskKey) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use TaskKey.ProtoReflect.Descriptor instead.

func (*TaskKey) Equal added in v1.17.3 

func (this *TaskKey) Equal(that interface{}) bool

Equal returns whether two TaskKey values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TaskKey) GetFireTime added in v1.17.3 

func (x *TaskKey) GetFireTime() *timestamppb.Timestamp

func (*TaskKey) GetTaskId added in v1.17.3 

func (x *TaskKey) GetTaskId() int64

func (*TaskKey) Marshal added in v1.17.3 

func (val *TaskKey) Marshal() ([]byte, error)

Marshal an object of type TaskKey to the protobuf v3 wire format

func (*TaskKey) ProtoMessage added in v1.17.3 

func (*TaskKey) ProtoMessage()

func (*TaskKey) ProtoReflect added in v1.23.0 

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

func (*TaskKey) Reset added in v1.17.3 

func (x *TaskKey) Reset()

func (*TaskKey) Size added in v1.17.3 

func (val *TaskKey) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TaskKey) String added in v1.17.3 

func (x *TaskKey) String() string

func (*TaskKey) Unmarshal added in v1.17.3 

func (val *TaskKey) Unmarshal(buf []byte) error

Unmarshal an object of type TaskKey from the protobuf v3 wire format

type TaskQueueInfo 

type TaskQueueInfo struct {
	NamespaceId             string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Name                    string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	TaskType                v12.TaskQueueType      `` /* 127-byte string literal not displayed */
	Kind                    v12.TaskQueueKind      `protobuf:"varint,4,opt,name=kind,proto3,enum=temporal.api.enums.v1.TaskQueueKind" json:"kind,omitempty"`
	AckLevel                int64                  `protobuf:"varint,5,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"`
	ExpiryTime              *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=expiry_time,json=expiryTime,proto3" json:"expiry_time,omitempty"`
	LastUpdateTime          *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	ApproximateBacklogCount int64                  `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

task_queue column

func (*TaskQueueInfo) Descriptor deprecated 

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

Deprecated: Use TaskQueueInfo.ProtoReflect.Descriptor instead.

func (*TaskQueueInfo) Equal 

func (this *TaskQueueInfo) Equal(that interface{}) bool

Equal returns whether two TaskQueueInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TaskQueueInfo) GetAckLevel 

func (x *TaskQueueInfo) GetAckLevel() int64

func (*TaskQueueInfo) GetApproximateBacklogCount added in v1.25.0 

func (x *TaskQueueInfo) GetApproximateBacklogCount() int64

func (*TaskQueueInfo) GetExpiryTime 

func (x *TaskQueueInfo) GetExpiryTime() *timestamppb.Timestamp

func (*TaskQueueInfo) GetKind 

func (x *TaskQueueInfo) GetKind() v12.TaskQueueKind

func (*TaskQueueInfo) GetLastUpdateTime 

func (x *TaskQueueInfo) GetLastUpdateTime() *timestamppb.Timestamp

func (*TaskQueueInfo) GetName 

func (x *TaskQueueInfo) GetName() string

func (*TaskQueueInfo) GetNamespaceId 

func (x *TaskQueueInfo) GetNamespaceId() string

func (*TaskQueueInfo) GetTaskType 

func (x *TaskQueueInfo) GetTaskType() v12.TaskQueueType

func (*TaskQueueInfo) Marshal 

func (val *TaskQueueInfo) Marshal() ([]byte, error)

Marshal an object of type TaskQueueInfo to the protobuf v3 wire format

func (*TaskQueueInfo) ProtoMessage 

func (*TaskQueueInfo) ProtoMessage()

func (*TaskQueueInfo) ProtoReflect added in v1.23.0 

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

func (*TaskQueueInfo) Reset 

func (x *TaskQueueInfo) Reset()

func (*TaskQueueInfo) Size 

func (val *TaskQueueInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TaskQueueInfo) String 

func (x *TaskQueueInfo) String() string

func (*TaskQueueInfo) Unmarshal 

func (val *TaskQueueInfo) Unmarshal(buf []byte) error

Unmarshal an object of type TaskQueueInfo from the protobuf v3 wire format

type TaskQueueUserData added in v1.21.0 

type TaskQueueUserData struct {

	// The last recorded cluster-local Hybrid Logical Clock timestamp for _this_ task queue.
	// Updated whenever user data is directly updated due to a user action but not when applying replication events.
	// The clock is referenced when new timestamps are generated to ensure it produces monotonically increasing
	// timestamps.
	Clock          *v1.HybridLogicalClock `protobuf:"bytes,1,opt,name=clock,proto3" json:"clock,omitempty"`
	VersioningData *VersioningData        `protobuf:"bytes,2,opt,name=versioning_data,json=versioningData,proto3" json:"versioning_data,omitempty"`
	// contains filtered or unexported fields
}

Container for all persistent user provided data for a task queue. Task queue as a named concept here is close to how users interpret them, rather than relating to some specific type (workflow vs activity, etc) and thus, as a consequence, any data that applies to a specific type (say, activity rate limiting) should be defined as such within this structure. This data must all fit in a single DB column and is kept cached in-memory, take extra care to ensure data added here has reasonable size limits imposed on it.

func (*TaskQueueUserData) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use TaskQueueUserData.ProtoReflect.Descriptor instead.

func (*TaskQueueUserData) Equal added in v1.21.0 

func (this *TaskQueueUserData) Equal(that interface{}) bool

Equal returns whether two TaskQueueUserData values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TaskQueueUserData) GetClock added in v1.21.0 

func (x *TaskQueueUserData) GetClock() *v1.HybridLogicalClock

func (*TaskQueueUserData) GetVersioningData added in v1.21.0 

func (x *TaskQueueUserData) GetVersioningData() *VersioningData

func (*TaskQueueUserData) Marshal added in v1.21.0 

func (val *TaskQueueUserData) Marshal() ([]byte, error)

Marshal an object of type TaskQueueUserData to the protobuf v3 wire format

func (*TaskQueueUserData) ProtoMessage added in v1.21.0 

func (*TaskQueueUserData) ProtoMessage()

func (*TaskQueueUserData) ProtoReflect added in v1.23.0 

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

func (*TaskQueueUserData) Reset added in v1.21.0 

func (x *TaskQueueUserData) Reset()

func (*TaskQueueUserData) Size added in v1.21.0 

func (val *TaskQueueUserData) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TaskQueueUserData) String added in v1.21.0 

func (x *TaskQueueUserData) String() string

func (*TaskQueueUserData) Unmarshal added in v1.21.0 

func (val *TaskQueueUserData) Unmarshal(buf []byte) error

Unmarshal an object of type TaskQueueUserData from the protobuf v3 wire format

type TaskTypePredicateAttributes added in v1.17.3 

type TaskTypePredicateAttributes struct {
	TaskTypes []v1.TaskType `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskTypePredicateAttributes) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use TaskTypePredicateAttributes.ProtoReflect.Descriptor instead.

func (*TaskTypePredicateAttributes) Equal added in v1.17.3 

func (this *TaskTypePredicateAttributes) Equal(that interface{}) bool

Equal returns whether two TaskTypePredicateAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TaskTypePredicateAttributes) GetTaskTypes added in v1.17.3 

func (x *TaskTypePredicateAttributes) GetTaskTypes() []v1.TaskType

func (*TaskTypePredicateAttributes) Marshal added in v1.17.3 

func (val *TaskTypePredicateAttributes) Marshal() ([]byte, error)

Marshal an object of type TaskTypePredicateAttributes to the protobuf v3 wire format

func (*TaskTypePredicateAttributes) ProtoMessage added in v1.17.3 

func (*TaskTypePredicateAttributes) ProtoMessage()

func (*TaskTypePredicateAttributes) ProtoReflect added in v1.23.0 

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

func (*TaskTypePredicateAttributes) Reset added in v1.17.3 

func (x *TaskTypePredicateAttributes) Reset()

func (*TaskTypePredicateAttributes) Size added in v1.17.3 

func (val *TaskTypePredicateAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TaskTypePredicateAttributes) String added in v1.17.3 

func (x *TaskTypePredicateAttributes) String() string

func (*TaskTypePredicateAttributes) Unmarshal added in v1.17.3 

func (val *TaskTypePredicateAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type TaskTypePredicateAttributes from the protobuf v3 wire format

type TimerInfo 

type TimerInfo struct {
	Version        int64                  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	StartedEventId int64                  `protobuf:"varint,2,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
	ExpiryTime     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expiry_time,json=expiryTime,proto3" json:"expiry_time,omitempty"`
	TaskStatus     int64                  `protobuf:"varint,4,opt,name=task_status,json=taskStatus,proto3" json:"task_status,omitempty"`
	// timerId serves the purpose of indicating whether a timer task is generated for this timer info.
	TimerId                       string               `protobuf:"bytes,5,opt,name=timer_id,json=timerId,proto3" json:"timer_id,omitempty"`
	LastUpdateVersionedTransition *VersionedTransition `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

timer_map column

func (*TimerInfo) Descriptor deprecated 

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

Deprecated: Use TimerInfo.ProtoReflect.Descriptor instead.

func (*TimerInfo) Equal 

func (this *TimerInfo) Equal(that interface{}) bool

Equal returns whether two TimerInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TimerInfo) GetExpiryTime 

func (x *TimerInfo) GetExpiryTime() *timestamppb.Timestamp

func (*TimerInfo) GetLastUpdateVersionedTransition added in v1.25.0 

func (x *TimerInfo) GetLastUpdateVersionedTransition() *VersionedTransition

func (*TimerInfo) GetStartedEventId added in v1.17.0 

func (x *TimerInfo) GetStartedEventId() int64

func (*TimerInfo) GetTaskStatus 

func (x *TimerInfo) GetTaskStatus() int64

func (*TimerInfo) GetTimerId 

func (x *TimerInfo) GetTimerId() string

func (*TimerInfo) GetVersion 

func (x *TimerInfo) GetVersion() int64

func (*TimerInfo) Marshal 

func (val *TimerInfo) Marshal() ([]byte, error)

Marshal an object of type TimerInfo to the protobuf v3 wire format

func (*TimerInfo) ProtoMessage 

func (*TimerInfo) ProtoMessage()

func (*TimerInfo) ProtoReflect added in v1.23.0 

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

func (*TimerInfo) Reset 

func (x *TimerInfo) Reset()

func (*TimerInfo) Size 

func (val *TimerInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TimerInfo) String 

func (x *TimerInfo) String() string

func (*TimerInfo) Unmarshal 

func (val *TimerInfo) Unmarshal(buf []byte) error

Unmarshal an object of type TimerInfo from the protobuf v3 wire format

type TimerTaskInfo 

type TimerTaskInfo struct {
	NamespaceId         string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId          string                 `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId               string                 `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskType            v1.TaskType            `` /* 129-byte string literal not displayed */
	TimeoutType         v16.TimeoutType        `` /* 134-byte string literal not displayed */
	WorkflowBackoffType v1.WorkflowBackoffType `` /* 175-byte string literal not displayed */
	Version             int64                  `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
	ScheduleAttempt     int32                  `protobuf:"varint,8,opt,name=schedule_attempt,json=scheduleAttempt,proto3" json:"schedule_attempt,omitempty"`
	EventId             int64                  `protobuf:"varint,9,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	TaskId              int64                  `protobuf:"varint,10,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime      *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
	BranchToken         []byte                 `protobuf:"bytes,12,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
	// If this is true, we can bypass archival before deleting. Only defined for DeleteHistoryEventTasks.
	AlreadyArchived bool `protobuf:"varint,13,opt,name=already_archived,json=alreadyArchived,proto3" json:"already_archived,omitempty"`
	// Number of transitions on the corresponding mutable state object. Used to verify that a task is not referencing a
	// stale state or, in some situations, that the task itself is not stale.
	// If task addresses a sub-statemachine (e.g. callback), this field will be set.
	MutableStateTransitionCount int64 `` /* 148-byte string literal not displayed */
	// If specified, the task is a for a workflow chain instead of a specific workflow run.
	// A workflow chain is identified by the run_id of the first workflow in the chain.
	FirstRunId string `protobuf:"bytes,15,opt,name=first_run_id,json=firstRunId,proto3" json:"first_run_id,omitempty"`
	// contains filtered or unexported fields
}

timer column

func (*TimerTaskInfo) Descriptor deprecated 

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

Deprecated: Use TimerTaskInfo.ProtoReflect.Descriptor instead.

func (*TimerTaskInfo) Equal 

func (this *TimerTaskInfo) Equal(that interface{}) bool

Equal returns whether two TimerTaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TimerTaskInfo) GetAlreadyArchived added in v1.19.0 

func (x *TimerTaskInfo) GetAlreadyArchived() bool

func (*TimerTaskInfo) GetBranchToken added in v1.16.0 

func (x *TimerTaskInfo) GetBranchToken() []byte

func (*TimerTaskInfo) GetEventId 

func (x *TimerTaskInfo) GetEventId() int64

func (*TimerTaskInfo) GetFirstRunId added in v1.24.0 

func (x *TimerTaskInfo) GetFirstRunId() string

func (*TimerTaskInfo) GetMutableStateTransitionCount added in v1.25.0 

func (x *TimerTaskInfo) GetMutableStateTransitionCount() int64

func (*TimerTaskInfo) GetNamespaceId 

func (x *TimerTaskInfo) GetNamespaceId() string

func (*TimerTaskInfo) GetRunId 

func (x *TimerTaskInfo) GetRunId() string

func (*TimerTaskInfo) GetScheduleAttempt 

func (x *TimerTaskInfo) GetScheduleAttempt() int32

func (*TimerTaskInfo) GetTaskId 

func (x *TimerTaskInfo) GetTaskId() int64

func (*TimerTaskInfo) GetTaskType 

func (x *TimerTaskInfo) GetTaskType() v1.TaskType

func (*TimerTaskInfo) GetTimeoutType 

func (x *TimerTaskInfo) GetTimeoutType() v16.TimeoutType

func (*TimerTaskInfo) GetVersion 

func (x *TimerTaskInfo) GetVersion() int64

func (*TimerTaskInfo) GetVisibilityTime 

func (x *TimerTaskInfo) GetVisibilityTime() *timestamppb.Timestamp

func (*TimerTaskInfo) GetWorkflowBackoffType 

func (x *TimerTaskInfo) GetWorkflowBackoffType() v1.WorkflowBackoffType

func (*TimerTaskInfo) GetWorkflowId 

func (x *TimerTaskInfo) GetWorkflowId() string

func (*TimerTaskInfo) Marshal 

func (val *TimerTaskInfo) Marshal() ([]byte, error)

Marshal an object of type TimerTaskInfo to the protobuf v3 wire format

func (*TimerTaskInfo) ProtoMessage 

func (*TimerTaskInfo) ProtoMessage()

func (*TimerTaskInfo) ProtoReflect added in v1.23.0 

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

func (*TimerTaskInfo) Reset 

func (x *TimerTaskInfo) Reset()

func (*TimerTaskInfo) Size 

func (val *TimerTaskInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TimerTaskInfo) String 

func (x *TimerTaskInfo) String() string

func (*TimerTaskInfo) Unmarshal 

func (val *TimerTaskInfo) Unmarshal(buf []byte) error

Unmarshal an object of type TimerTaskInfo from the protobuf v3 wire format

type TransferTaskInfo 

type TransferTaskInfo struct {
	NamespaceId             string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId              string                 `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId                   string                 `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskType                v1.TaskType            `` /* 129-byte string literal not displayed */
	TargetNamespaceId       string                 `protobuf:"bytes,5,opt,name=target_namespace_id,json=targetNamespaceId,proto3" json:"target_namespace_id,omitempty"`
	TargetWorkflowId        string                 `protobuf:"bytes,6,opt,name=target_workflow_id,json=targetWorkflowId,proto3" json:"target_workflow_id,omitempty"`
	TargetRunId             string                 `protobuf:"bytes,7,opt,name=target_run_id,json=targetRunId,proto3" json:"target_run_id,omitempty"`
	TaskQueue               string                 `protobuf:"bytes,8,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	TargetChildWorkflowOnly bool                   `` /* 135-byte string literal not displayed */
	ScheduledEventId        int64                  `protobuf:"varint,10,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	Version                 int64                  `protobuf:"varint,11,opt,name=version,proto3" json:"version,omitempty"`
	TaskId                  int64                  `protobuf:"varint,12,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime          *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "after" is used to indicate sequence of actions. --)
	DeleteAfterClose bool `protobuf:"varint,15,opt,name=delete_after_close,json=deleteAfterClose,proto3" json:"delete_after_close,omitempty"`
	// Types that are assignable to TaskDetails:
	//
	//	*TransferTaskInfo_CloseExecutionTaskDetails_
	TaskDetails isTransferTaskInfo_TaskDetails `protobuf_oneof:"task_details"`
	// contains filtered or unexported fields
}

transfer column

func (*TransferTaskInfo) Descriptor deprecated 

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

Deprecated: Use TransferTaskInfo.ProtoReflect.Descriptor instead.

func (*TransferTaskInfo) Equal 

func (this *TransferTaskInfo) Equal(that interface{}) bool

Equal returns whether two TransferTaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TransferTaskInfo) GetCloseExecutionTaskDetails added in v1.19.0 

func (x *TransferTaskInfo) GetCloseExecutionTaskDetails() *TransferTaskInfo_CloseExecutionTaskDetails

func (*TransferTaskInfo) GetDeleteAfterClose added in v1.17.0 

func (x *TransferTaskInfo) GetDeleteAfterClose() bool

func (*TransferTaskInfo) GetNamespaceId 

func (x *TransferTaskInfo) GetNamespaceId() string

func (*TransferTaskInfo) GetRunId 

func (x *TransferTaskInfo) GetRunId() string

func (*TransferTaskInfo) GetScheduledEventId added in v1.17.0 

func (x *TransferTaskInfo) GetScheduledEventId() int64

func (*TransferTaskInfo) GetTargetChildWorkflowOnly 

func (x *TransferTaskInfo) GetTargetChildWorkflowOnly() bool

func (*TransferTaskInfo) GetTargetNamespaceId 

func (x *TransferTaskInfo) GetTargetNamespaceId() string

func (*TransferTaskInfo) GetTargetRunId 

func (x *TransferTaskInfo) GetTargetRunId() string

func (*TransferTaskInfo) GetTargetWorkflowId 

func (x *TransferTaskInfo) GetTargetWorkflowId() string

func (*TransferTaskInfo) GetTaskDetails added in v1.19.0 

func (m *TransferTaskInfo) GetTaskDetails() isTransferTaskInfo_TaskDetails

func (*TransferTaskInfo) GetTaskId 

func (x *TransferTaskInfo) GetTaskId() int64

func (*TransferTaskInfo) GetTaskQueue 

func (x *TransferTaskInfo) GetTaskQueue() string

func (*TransferTaskInfo) GetTaskType 

func (x *TransferTaskInfo) GetTaskType() v1.TaskType

func (*TransferTaskInfo) GetVersion 

func (x *TransferTaskInfo) GetVersion() int64

func (*TransferTaskInfo) GetVisibilityTime 

func (x *TransferTaskInfo) GetVisibilityTime() *timestamppb.Timestamp

func (*TransferTaskInfo) GetWorkflowId 

func (x *TransferTaskInfo) GetWorkflowId() string

func (*TransferTaskInfo) Marshal 

func (val *TransferTaskInfo) Marshal() ([]byte, error)

Marshal an object of type TransferTaskInfo to the protobuf v3 wire format

func (*TransferTaskInfo) ProtoMessage 

func (*TransferTaskInfo) ProtoMessage()

func (*TransferTaskInfo) ProtoReflect added in v1.23.0 

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

func (*TransferTaskInfo) Reset 

func (x *TransferTaskInfo) Reset()

func (*TransferTaskInfo) Size 

func (val *TransferTaskInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TransferTaskInfo) String 

func (x *TransferTaskInfo) String() string

func (*TransferTaskInfo) Unmarshal 

func (val *TransferTaskInfo) Unmarshal(buf []byte) error

Unmarshal an object of type TransferTaskInfo from the protobuf v3 wire format

type TransferTaskInfo_CloseExecutionTaskDetails added in v1.19.0 

type TransferTaskInfo_CloseExecutionTaskDetails struct {

	// can_skip_visibility_archival is set to true when we can guarantee that visibility records will be archived
	// by some other task, so this task doesn't need to worry about it.
	CanSkipVisibilityArchival bool `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TransferTaskInfo_CloseExecutionTaskDetails) Descriptor deprecated added in v1.19.0 

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

Deprecated: Use TransferTaskInfo_CloseExecutionTaskDetails.ProtoReflect.Descriptor instead.

func (*TransferTaskInfo_CloseExecutionTaskDetails) GetCanSkipVisibilityArchival added in v1.19.0 

func (x *TransferTaskInfo_CloseExecutionTaskDetails) GetCanSkipVisibilityArchival() bool

func (*TransferTaskInfo_CloseExecutionTaskDetails) ProtoMessage added in v1.19.0 

func (*TransferTaskInfo_CloseExecutionTaskDetails) ProtoMessage()

func (*TransferTaskInfo_CloseExecutionTaskDetails) ProtoReflect added in v1.23.0 

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

func (*TransferTaskInfo_CloseExecutionTaskDetails) Reset added in v1.19.0 

func (x *TransferTaskInfo_CloseExecutionTaskDetails) Reset()

func (*TransferTaskInfo_CloseExecutionTaskDetails) String added in v1.19.0 

func (x *TransferTaskInfo_CloseExecutionTaskDetails) String() string

type TransferTaskInfo_CloseExecutionTaskDetails_ added in v1.19.0 

type TransferTaskInfo_CloseExecutionTaskDetails_ struct {
	CloseExecutionTaskDetails *TransferTaskInfo_CloseExecutionTaskDetails `protobuf:"bytes,16,opt,name=close_execution_task_details,json=closeExecutionTaskDetails,proto3,oneof"`
}

type UniversalPredicateAttributes added in v1.17.3 

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

func (*UniversalPredicateAttributes) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use UniversalPredicateAttributes.ProtoReflect.Descriptor instead.

func (*UniversalPredicateAttributes) Equal added in v1.17.3 

func (this *UniversalPredicateAttributes) Equal(that interface{}) bool

Equal returns whether two UniversalPredicateAttributes values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UniversalPredicateAttributes) Marshal added in v1.17.3 

func (val *UniversalPredicateAttributes) Marshal() ([]byte, error)

Marshal an object of type UniversalPredicateAttributes to the protobuf v3 wire format

func (*UniversalPredicateAttributes) ProtoMessage added in v1.17.3 

func (*UniversalPredicateAttributes) ProtoMessage()

func (*UniversalPredicateAttributes) ProtoReflect added in v1.23.0 

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

func (*UniversalPredicateAttributes) Reset added in v1.17.3 

func (x *UniversalPredicateAttributes) Reset()

func (*UniversalPredicateAttributes) Size added in v1.17.3 

func (val *UniversalPredicateAttributes) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UniversalPredicateAttributes) String added in v1.17.3 

func (x *UniversalPredicateAttributes) String() string

func (*UniversalPredicateAttributes) Unmarshal added in v1.17.3 

func (val *UniversalPredicateAttributes) Unmarshal(buf []byte) error

Unmarshal an object of type UniversalPredicateAttributes from the protobuf v3 wire format

type UpdateAcceptanceInfo added in v1.25.0 

type UpdateAcceptanceInfo struct {

	// the event ID of the WorkflowExecutionUpdateAcceptedEvent
	EventId int64 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// contains filtered or unexported fields
}

UpdateAcceptanceInfo contains information about an accepted update

func (*UpdateAcceptanceInfo) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use UpdateAcceptanceInfo.ProtoReflect.Descriptor instead.

func (*UpdateAcceptanceInfo) Equal added in v1.25.0 

func (this *UpdateAcceptanceInfo) Equal(that interface{}) bool

Equal returns whether two UpdateAcceptanceInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateAcceptanceInfo) GetEventId added in v1.25.0 

func (x *UpdateAcceptanceInfo) GetEventId() int64

func (*UpdateAcceptanceInfo) Marshal added in v1.25.0 

func (val *UpdateAcceptanceInfo) Marshal() ([]byte, error)

Marshal an object of type UpdateAcceptanceInfo to the protobuf v3 wire format

func (*UpdateAcceptanceInfo) ProtoMessage added in v1.25.0 

func (*UpdateAcceptanceInfo) ProtoMessage()

func (*UpdateAcceptanceInfo) ProtoReflect added in v1.25.0 

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

func (*UpdateAcceptanceInfo) Reset added in v1.25.0 

func (x *UpdateAcceptanceInfo) Reset()

func (*UpdateAcceptanceInfo) Size added in v1.25.0 

func (val *UpdateAcceptanceInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateAcceptanceInfo) String added in v1.25.0 

func (x *UpdateAcceptanceInfo) String() string

func (*UpdateAcceptanceInfo) Unmarshal added in v1.25.0 

func (val *UpdateAcceptanceInfo) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateAcceptanceInfo from the protobuf v3 wire format

type UpdateAdmissionInfo added in v1.25.0 

type UpdateAdmissionInfo struct {

	// Types that are assignable to Location:
	//
	//	*UpdateAdmissionInfo_HistoryPointer_
	Location isUpdateAdmissionInfo_Location `protobuf_oneof:"location"`
	// contains filtered or unexported fields
}

UpdateAdmissionInfo contains information about a durably admitted update. Note that updates in Admitted state are typically non-durable (i.e. do not have a corresponding event in history). Durably admitted updates arise as a result of workflow reset or history event replication conflict: in these cases a WorkflowExecutionUpdateAdmittedEvent event is created when an accepted update (on one branch of workflow history) is converted into an admitted update (on another branch).

func (*UpdateAdmissionInfo) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use UpdateAdmissionInfo.ProtoReflect.Descriptor instead.

func (*UpdateAdmissionInfo) Equal added in v1.25.0 

func (this *UpdateAdmissionInfo) Equal(that interface{}) bool

Equal returns whether two UpdateAdmissionInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateAdmissionInfo) GetHistoryPointer added in v1.25.0 

func (x *UpdateAdmissionInfo) GetHistoryPointer() *UpdateAdmissionInfo_HistoryPointer

func (*UpdateAdmissionInfo) GetLocation added in v1.25.0 

func (m *UpdateAdmissionInfo) GetLocation() isUpdateAdmissionInfo_Location

func (*UpdateAdmissionInfo) Marshal added in v1.25.0 

func (val *UpdateAdmissionInfo) Marshal() ([]byte, error)

Marshal an object of type UpdateAdmissionInfo to the protobuf v3 wire format

func (*UpdateAdmissionInfo) ProtoMessage added in v1.25.0 

func (*UpdateAdmissionInfo) ProtoMessage()

func (*UpdateAdmissionInfo) ProtoReflect added in v1.25.0 

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

func (*UpdateAdmissionInfo) Reset added in v1.25.0 

func (x *UpdateAdmissionInfo) Reset()

func (*UpdateAdmissionInfo) Size added in v1.25.0 

func (val *UpdateAdmissionInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateAdmissionInfo) String added in v1.25.0 

func (x *UpdateAdmissionInfo) String() string

func (*UpdateAdmissionInfo) Unmarshal added in v1.25.0 

func (val *UpdateAdmissionInfo) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateAdmissionInfo from the protobuf v3 wire format

type UpdateAdmissionInfo_HistoryPointer added in v1.25.0 

type UpdateAdmissionInfo_HistoryPointer struct {

	// the event ID of the WorkflowExecutionUpdateAdmittedEvent
	EventId int64 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// the ID of the event batch containing the event_id
	EventBatchId int64 `protobuf:"varint,2,opt,name=event_batch_id,json=eventBatchId,proto3" json:"event_batch_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateAdmissionInfo_HistoryPointer) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use UpdateAdmissionInfo_HistoryPointer.ProtoReflect.Descriptor instead.

func (*UpdateAdmissionInfo_HistoryPointer) GetEventBatchId added in v1.25.0 

func (x *UpdateAdmissionInfo_HistoryPointer) GetEventBatchId() int64

func (*UpdateAdmissionInfo_HistoryPointer) GetEventId added in v1.25.0 

func (x *UpdateAdmissionInfo_HistoryPointer) GetEventId() int64

func (*UpdateAdmissionInfo_HistoryPointer) ProtoMessage added in v1.25.0 

func (*UpdateAdmissionInfo_HistoryPointer) ProtoMessage()

func (*UpdateAdmissionInfo_HistoryPointer) ProtoReflect added in v1.25.0 

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

func (*UpdateAdmissionInfo_HistoryPointer) Reset added in v1.25.0 

func (x *UpdateAdmissionInfo_HistoryPointer) Reset()

func (*UpdateAdmissionInfo_HistoryPointer) String added in v1.25.0 

func (x *UpdateAdmissionInfo_HistoryPointer) String() string

type UpdateAdmissionInfo_HistoryPointer_ added in v1.25.0 

type UpdateAdmissionInfo_HistoryPointer_ struct {
	HistoryPointer *UpdateAdmissionInfo_HistoryPointer `protobuf:"bytes,1,opt,name=history_pointer,json=historyPointer,proto3,oneof"`
}

type UpdateCompletionInfo added in v1.25.0 

type UpdateCompletionInfo struct {

	// the event ID of the WorkflowExecutionUpdateCompletedEvent
	EventId int64 `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// the ID of the event batch containing the event_id above
	EventBatchId int64 `protobuf:"varint,2,opt,name=event_batch_id,json=eventBatchId,proto3" json:"event_batch_id,omitempty"`
	// contains filtered or unexported fields
}

UpdateCompletionInfo contains information about a completed update

func (*UpdateCompletionInfo) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use UpdateCompletionInfo.ProtoReflect.Descriptor instead.

func (*UpdateCompletionInfo) Equal added in v1.25.0 

func (this *UpdateCompletionInfo) Equal(that interface{}) bool

Equal returns whether two UpdateCompletionInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateCompletionInfo) GetEventBatchId added in v1.25.0 

func (x *UpdateCompletionInfo) GetEventBatchId() int64

func (*UpdateCompletionInfo) GetEventId added in v1.25.0 

func (x *UpdateCompletionInfo) GetEventId() int64

func (*UpdateCompletionInfo) Marshal added in v1.25.0 

func (val *UpdateCompletionInfo) Marshal() ([]byte, error)

Marshal an object of type UpdateCompletionInfo to the protobuf v3 wire format

func (*UpdateCompletionInfo) ProtoMessage added in v1.25.0 

func (*UpdateCompletionInfo) ProtoMessage()

func (*UpdateCompletionInfo) ProtoReflect added in v1.25.0 

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

func (*UpdateCompletionInfo) Reset added in v1.25.0 

func (x *UpdateCompletionInfo) Reset()

func (*UpdateCompletionInfo) Size added in v1.25.0 

func (val *UpdateCompletionInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateCompletionInfo) String added in v1.25.0 

func (x *UpdateCompletionInfo) String() string

func (*UpdateCompletionInfo) Unmarshal added in v1.25.0 

func (val *UpdateCompletionInfo) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateCompletionInfo from the protobuf v3 wire format

type UpdateInfo added in v1.25.0 

type UpdateInfo struct {

	// Types that are assignable to Value:
	//
	//	*UpdateInfo_Acceptance
	//	*UpdateInfo_Completion
	//	*UpdateInfo_Admission
	Value                         isUpdateInfo_Value   `protobuf_oneof:"value"`
	LastUpdateVersionedTransition *VersionedTransition `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

UpdateInfo is the persistent state of a single update

func (*UpdateInfo) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use UpdateInfo.ProtoReflect.Descriptor instead.

func (*UpdateInfo) Equal added in v1.25.0 

func (this *UpdateInfo) Equal(that interface{}) bool

Equal returns whether two UpdateInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateInfo) GetAcceptance added in v1.25.0 

func (x *UpdateInfo) GetAcceptance() *UpdateAcceptanceInfo

func (*UpdateInfo) GetAdmission added in v1.25.0 

func (x *UpdateInfo) GetAdmission() *UpdateAdmissionInfo

func (*UpdateInfo) GetCompletion added in v1.25.0 

func (x *UpdateInfo) GetCompletion() *UpdateCompletionInfo

func (*UpdateInfo) GetLastUpdateVersionedTransition added in v1.25.0 

func (x *UpdateInfo) GetLastUpdateVersionedTransition() *VersionedTransition

func (*UpdateInfo) GetValue added in v1.25.0 

func (m *UpdateInfo) GetValue() isUpdateInfo_Value

func (*UpdateInfo) Marshal added in v1.25.0 

func (val *UpdateInfo) Marshal() ([]byte, error)

Marshal an object of type UpdateInfo to the protobuf v3 wire format

func (*UpdateInfo) ProtoMessage added in v1.25.0 

func (*UpdateInfo) ProtoMessage()

func (*UpdateInfo) ProtoReflect added in v1.25.0 

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

func (*UpdateInfo) Reset added in v1.25.0 

func (x *UpdateInfo) Reset()

func (*UpdateInfo) Size added in v1.25.0 

func (val *UpdateInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateInfo) String added in v1.25.0 

func (x *UpdateInfo) String() string

func (*UpdateInfo) Unmarshal added in v1.25.0 

func (val *UpdateInfo) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateInfo from the protobuf v3 wire format

type UpdateInfo_Acceptance added in v1.25.0 

type UpdateInfo_Acceptance struct {
	// update has been accepted and this is the acceptance metadata
	Acceptance *UpdateAcceptanceInfo `protobuf:"bytes,1,opt,name=acceptance,proto3,oneof"`
}

type UpdateInfo_Admission added in v1.25.0 

type UpdateInfo_Admission struct {
	// update has been admitted and this is the admission metadata
	Admission *UpdateAdmissionInfo `protobuf:"bytes,3,opt,name=admission,proto3,oneof"`
}

type UpdateInfo_Completion added in v1.25.0 

type UpdateInfo_Completion struct {
	// update has been completed and this is the completion metadata
	Completion *UpdateCompletionInfo `protobuf:"bytes,2,opt,name=completion,proto3,oneof"`
}

type VersionedTaskQueueUserData added in v1.21.0 

type VersionedTaskQueueUserData struct {
	Data    *TaskQueueUserData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Version int64              `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Simple wrapper that includes a TaskQueueUserData and its storage version.

func (*VersionedTaskQueueUserData) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use VersionedTaskQueueUserData.ProtoReflect.Descriptor instead.

func (*VersionedTaskQueueUserData) Equal added in v1.21.0 

func (this *VersionedTaskQueueUserData) Equal(that interface{}) bool

Equal returns whether two VersionedTaskQueueUserData values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*VersionedTaskQueueUserData) GetData added in v1.21.0 

func (x *VersionedTaskQueueUserData) GetData() *TaskQueueUserData

func (*VersionedTaskQueueUserData) GetVersion added in v1.21.0 

func (x *VersionedTaskQueueUserData) GetVersion() int64

func (*VersionedTaskQueueUserData) Marshal added in v1.21.0 

func (val *VersionedTaskQueueUserData) Marshal() ([]byte, error)

Marshal an object of type VersionedTaskQueueUserData to the protobuf v3 wire format

func (*VersionedTaskQueueUserData) ProtoMessage added in v1.21.0 

func (*VersionedTaskQueueUserData) ProtoMessage()

func (*VersionedTaskQueueUserData) ProtoReflect added in v1.23.0 

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

func (*VersionedTaskQueueUserData) Reset added in v1.21.0 

func (x *VersionedTaskQueueUserData) Reset()

func (*VersionedTaskQueueUserData) Size added in v1.21.0 

func (val *VersionedTaskQueueUserData) Size() int

Size returns the size of the object, in bytes, once serialized

func (*VersionedTaskQueueUserData) String added in v1.21.0 

func (x *VersionedTaskQueueUserData) String() string

func (*VersionedTaskQueueUserData) Unmarshal added in v1.21.0 

func (val *VersionedTaskQueueUserData) Unmarshal(buf []byte) error

Unmarshal an object of type VersionedTaskQueueUserData from the protobuf v3 wire format

type VersionedTransition added in v1.24.0 

type VersionedTransition struct {

	// The namespace failover version at transition time.
	NamespaceFailoverVersion int64 `` /* 136-byte string literal not displayed */
	// State transition count perceived during the specified namespace_failover_version.
	TransitionCount int64 `protobuf:"varint,2,opt,name=transition_count,json=transitionCount,proto3" json:"transition_count,omitempty"`
	// contains filtered or unexported fields
}

VersionedTransition is a unique identifier for a specific mutable state transition.

func (*VersionedTransition) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use VersionedTransition.ProtoReflect.Descriptor instead.

func (*VersionedTransition) Equal added in v1.24.0 

func (this *VersionedTransition) Equal(that interface{}) bool

Equal returns whether two VersionedTransition values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*VersionedTransition) GetNamespaceFailoverVersion added in v1.24.0 

func (x *VersionedTransition) GetNamespaceFailoverVersion() int64

func (*VersionedTransition) GetTransitionCount added in v1.25.0 

func (x *VersionedTransition) GetTransitionCount() int64

func (*VersionedTransition) Marshal added in v1.24.0 

func (val *VersionedTransition) Marshal() ([]byte, error)

Marshal an object of type VersionedTransition to the protobuf v3 wire format

func (*VersionedTransition) ProtoMessage added in v1.24.0 

func (*VersionedTransition) ProtoMessage()

func (*VersionedTransition) ProtoReflect added in v1.24.0 

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

func (*VersionedTransition) Reset added in v1.24.0 

func (x *VersionedTransition) Reset()

func (*VersionedTransition) Size added in v1.24.0 

func (val *VersionedTransition) Size() int

Size returns the size of the object, in bytes, once serialized

func (*VersionedTransition) String added in v1.24.0 

func (x *VersionedTransition) String() string

func (*VersionedTransition) Unmarshal added in v1.24.0 

func (val *VersionedTransition) Unmarshal(buf []byte) error

Unmarshal an object of type VersionedTransition from the protobuf v3 wire format

type VersioningData added in v1.17.3 

type VersioningData struct {

	// All the incompatible version sets, unordered except for the last element, which is considered the set "default".
	VersionSets []*CompatibleVersionSet `protobuf:"bytes,1,rep,name=version_sets,json=versionSets,proto3" json:"version_sets,omitempty"`
	// Ordered list of assignment rules. Also contains recently-deleted rules.
	AssignmentRules []*AssignmentRule `protobuf:"bytes,2,rep,name=assignment_rules,json=assignmentRules,proto3" json:"assignment_rules,omitempty"`
	// Unordered list of redirect rules. Also contains recently-deleted rules.
	RedirectRules []*RedirectRule `protobuf:"bytes,3,rep,name=redirect_rules,json=redirectRules,proto3" json:"redirect_rules,omitempty"`
	// contains filtered or unexported fields
}

Holds all the data related to worker versioning for a task queue. Backwards-incompatible changes cannot be made, as this would make existing stored data unreadable.

func (*VersioningData) Descriptor deprecated added in v1.17.3 

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

Deprecated: Use VersioningData.ProtoReflect.Descriptor instead.

func (*VersioningData) Equal added in v1.17.3 

func (this *VersioningData) Equal(that interface{}) bool

Equal returns whether two VersioningData values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*VersioningData) GetAssignmentRules added in v1.24.0 

func (x *VersioningData) GetAssignmentRules() []*AssignmentRule

func (*VersioningData) GetRedirectRules added in v1.24.0 

func (x *VersioningData) GetRedirectRules() []*RedirectRule

func (*VersioningData) GetVersionSets added in v1.21.0 

func (x *VersioningData) GetVersionSets() []*CompatibleVersionSet

func (*VersioningData) Marshal added in v1.17.3 

func (val *VersioningData) Marshal() ([]byte, error)

Marshal an object of type VersioningData to the protobuf v3 wire format

func (*VersioningData) ProtoMessage added in v1.17.3 

func (*VersioningData) ProtoMessage()

func (*VersioningData) ProtoReflect added in v1.23.0 

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

func (*VersioningData) Reset added in v1.17.3 

func (x *VersioningData) Reset()

func (*VersioningData) Size added in v1.17.3 

func (val *VersioningData) Size() int

Size returns the size of the object, in bytes, once serialized

func (*VersioningData) String added in v1.17.3 

func (x *VersioningData) String() string

func (*VersioningData) Unmarshal added in v1.17.3 

func (val *VersioningData) Unmarshal(buf []byte) error

Unmarshal an object of type VersioningData from the protobuf v3 wire format

type VisibilityTaskInfo added in v1.5.0 

type VisibilityTaskInfo struct {
	NamespaceId           string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId            string                 `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId                 string                 `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskType              v1.TaskType            `` /* 129-byte string literal not displayed */
	Version               int64                  `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	TaskId                int64                  `protobuf:"varint,6,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime        *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
	CloseVisibilityTaskId int64                  `` /* 130-byte string literal not displayed */
	CloseTime             *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
	// contains filtered or unexported fields
}

visibility_task_data column

func (*VisibilityTaskInfo) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use VisibilityTaskInfo.ProtoReflect.Descriptor instead.

func (*VisibilityTaskInfo) Equal added in v1.5.0 

func (this *VisibilityTaskInfo) Equal(that interface{}) bool

Equal returns whether two VisibilityTaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*VisibilityTaskInfo) GetCloseTime added in v1.15.0 

func (x *VisibilityTaskInfo) GetCloseTime() *timestamppb.Timestamp

func (*VisibilityTaskInfo) GetCloseVisibilityTaskId added in v1.18.0 

func (x *VisibilityTaskInfo) GetCloseVisibilityTaskId() int64

func (*VisibilityTaskInfo) GetNamespaceId added in v1.5.0 

func (x *VisibilityTaskInfo) GetNamespaceId() string

func (*VisibilityTaskInfo) GetRunId added in v1.5.0 

func (x *VisibilityTaskInfo) GetRunId() string

func (*VisibilityTaskInfo) GetTaskId added in v1.5.0 

func (x *VisibilityTaskInfo) GetTaskId() int64

func (*VisibilityTaskInfo) GetTaskType added in v1.5.0 

func (x *VisibilityTaskInfo) GetTaskType() v1.TaskType

func (*VisibilityTaskInfo) GetVersion added in v1.5.0 

func (x *VisibilityTaskInfo) GetVersion() int64

func (*VisibilityTaskInfo) GetVisibilityTime added in v1.5.0 

func (x *VisibilityTaskInfo) GetVisibilityTime() *timestamppb.Timestamp

func (*VisibilityTaskInfo) GetWorkflowId added in v1.5.0 

func (x *VisibilityTaskInfo) GetWorkflowId() string

func (*VisibilityTaskInfo) Marshal added in v1.5.0 

func (val *VisibilityTaskInfo) Marshal() ([]byte, error)

Marshal an object of type VisibilityTaskInfo to the protobuf v3 wire format

func (*VisibilityTaskInfo) ProtoMessage added in v1.5.0 

func (*VisibilityTaskInfo) ProtoMessage()

func (*VisibilityTaskInfo) ProtoReflect added in v1.23.0 

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

func (*VisibilityTaskInfo) Reset added in v1.5.0 

func (x *VisibilityTaskInfo) Reset()

func (*VisibilityTaskInfo) Size added in v1.5.0 

func (val *VisibilityTaskInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*VisibilityTaskInfo) String added in v1.5.0 

func (x *VisibilityTaskInfo) String() string

func (*VisibilityTaskInfo) Unmarshal added in v1.5.0 

func (val *VisibilityTaskInfo) Unmarshal(buf []byte) error

Unmarshal an object of type VisibilityTaskInfo from the protobuf v3 wire format

type WorkflowExecutionInfo 

type WorkflowExecutionInfo struct {
	NamespaceId                             string               `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId                              string               `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	ParentNamespaceId                       string               `protobuf:"bytes,3,opt,name=parent_namespace_id,json=parentNamespaceId,proto3" json:"parent_namespace_id,omitempty"`
	ParentWorkflowId                        string               `protobuf:"bytes,4,opt,name=parent_workflow_id,json=parentWorkflowId,proto3" json:"parent_workflow_id,omitempty"`
	ParentRunId                             string               `protobuf:"bytes,5,opt,name=parent_run_id,json=parentRunId,proto3" json:"parent_run_id,omitempty"`
	ParentInitiatedId                       int64                `protobuf:"varint,6,opt,name=parent_initiated_id,json=parentInitiatedId,proto3" json:"parent_initiated_id,omitempty"`
	CompletionEventBatchId                  int64                `` /* 132-byte string literal not displayed */
	TaskQueue                               string               `protobuf:"bytes,9,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	WorkflowTypeName                        string               `protobuf:"bytes,10,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
	WorkflowExecutionTimeout                *durationpb.Duration `` /* 136-byte string literal not displayed */
	WorkflowRunTimeout                      *durationpb.Duration `protobuf:"bytes,12,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
	DefaultWorkflowTaskTimeout              *durationpb.Duration `` /* 144-byte string literal not displayed */
	LastEventTaskId                         int64                `protobuf:"varint,17,opt,name=last_event_task_id,json=lastEventTaskId,proto3" json:"last_event_task_id,omitempty"`
	LastFirstEventId                        int64                `protobuf:"varint,18,opt,name=last_first_event_id,json=lastFirstEventId,proto3" json:"last_first_event_id,omitempty"`
	LastCompletedWorkflowTaskStartedEventId int64                `` /* 190-byte string literal not displayed */
	// Deprecated. use `WorkflowExecutionState.start_time`
	StartTime      *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// Workflow task fields.
	WorkflowTaskVersion               int64                  `protobuf:"varint,22,opt,name=workflow_task_version,json=workflowTaskVersion,proto3" json:"workflow_task_version,omitempty"`
	WorkflowTaskScheduledEventId      int64                  `` /* 153-byte string literal not displayed */
	WorkflowTaskStartedEventId        int64                  `` /* 147-byte string literal not displayed */
	WorkflowTaskTimeout               *durationpb.Duration   `protobuf:"bytes,25,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"`
	WorkflowTaskAttempt               int32                  `protobuf:"varint,26,opt,name=workflow_task_attempt,json=workflowTaskAttempt,proto3" json:"workflow_task_attempt,omitempty"`
	WorkflowTaskStartedTime           *timestamppb.Timestamp `` /* 135-byte string literal not displayed */
	WorkflowTaskScheduledTime         *timestamppb.Timestamp `` /* 141-byte string literal not displayed */
	WorkflowTaskOriginalScheduledTime *timestamppb.Timestamp `` /* 167-byte string literal not displayed */
	WorkflowTaskRequestId             string                 `` /* 129-byte string literal not displayed */
	WorkflowTaskType                  v1.WorkflowTaskType    `` /* 164-byte string literal not displayed */
	WorkflowTaskSuggestContinueAsNew  bool                   `` /* 167-byte string literal not displayed */
	WorkflowTaskHistorySizeBytes      int64                  `` /* 153-byte string literal not displayed */
	// tracks the started build ID for transient/speculative WFT. This info is used for two purposes:
	// - verify WFT completes by the same Build ID that started in the latest attempt
	// - when persisting transient/speculative WFT, the right Build ID is used in the WFT started event
	WorkflowTaskBuildId string `protobuf:"bytes,88,opt,name=workflow_task_build_id,json=workflowTaskBuildId,proto3" json:"workflow_task_build_id,omitempty"`
	// tracks the started build ID redirect counter for transient/speculative WFT. This info is to
	// ensure the right redirect counter is used in the WFT started event created later
	// for a transient/speculative WFT.
	WorkflowTaskBuildIdRedirectCounter int64  `` /* 173-byte string literal not displayed */
	CancelRequested                    bool   `protobuf:"varint,29,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	CancelRequestId                    string `protobuf:"bytes,32,opt,name=cancel_request_id,json=cancelRequestId,proto3" json:"cancel_request_id,omitempty"`
	StickyTaskQueue                    string `protobuf:"bytes,33,opt,name=sticky_task_queue,json=stickyTaskQueue,proto3" json:"sticky_task_queue,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	StickyScheduleToStartTimeout    *durationpb.Duration    `` /* 152-byte string literal not displayed */
	Attempt                         int32                   `protobuf:"varint,35,opt,name=attempt,proto3" json:"attempt,omitempty"`
	RetryInitialInterval            *durationpb.Duration    `protobuf:"bytes,36,opt,name=retry_initial_interval,json=retryInitialInterval,proto3" json:"retry_initial_interval,omitempty"`
	RetryMaximumInterval            *durationpb.Duration    `protobuf:"bytes,37,opt,name=retry_maximum_interval,json=retryMaximumInterval,proto3" json:"retry_maximum_interval,omitempty"`
	RetryMaximumAttempts            int32                   `protobuf:"varint,38,opt,name=retry_maximum_attempts,json=retryMaximumAttempts,proto3" json:"retry_maximum_attempts,omitempty"`
	RetryBackoffCoefficient         float64                 `` /* 135-byte string literal not displayed */
	WorkflowExecutionExpirationTime *timestamppb.Timestamp  `` /* 159-byte string literal not displayed */
	RetryNonRetryableErrorTypes     []string                `` /* 149-byte string literal not displayed */
	HasRetryPolicy                  bool                    `protobuf:"varint,42,opt,name=has_retry_policy,json=hasRetryPolicy,proto3" json:"has_retry_policy,omitempty"`
	CronSchedule                    string                  `protobuf:"bytes,43,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	SignalCount                     int64                   `protobuf:"varint,46,opt,name=signal_count,json=signalCount,proto3" json:"signal_count,omitempty"`
	ActivityCount                   int64                   `protobuf:"varint,71,opt,name=activity_count,json=activityCount,proto3" json:"activity_count,omitempty"`
	ChildExecutionCount             int64                   `protobuf:"varint,72,opt,name=child_execution_count,json=childExecutionCount,proto3" json:"child_execution_count,omitempty"`
	UserTimerCount                  int64                   `protobuf:"varint,73,opt,name=user_timer_count,json=userTimerCount,proto3" json:"user_timer_count,omitempty"`
	RequestCancelExternalCount      int64                   `` /* 145-byte string literal not displayed */
	SignalExternalCount             int64                   `protobuf:"varint,75,opt,name=signal_external_count,json=signalExternalCount,proto3" json:"signal_external_count,omitempty"`
	UpdateCount                     int64                   `protobuf:"varint,77,opt,name=update_count,json=updateCount,proto3" json:"update_count,omitempty"`
	AutoResetPoints                 *v11.ResetPoints        `protobuf:"bytes,51,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
	SearchAttributes                map[string]*v12.Payload `` /* 198-byte string literal not displayed */
	Memo                            map[string]*v12.Payload `` /* 150-byte string literal not displayed */
	VersionHistories                *v13.VersionHistories   `protobuf:"bytes,54,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"`
	FirstExecutionRunId             string                  `protobuf:"bytes,55,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
	ExecutionStats                  *ExecutionStats         `protobuf:"bytes,56,opt,name=execution_stats,json=executionStats,proto3" json:"execution_stats,omitempty"`
	WorkflowRunExpirationTime       *timestamppb.Timestamp  `` /* 141-byte string literal not displayed */
	// Transaction Id of the first event in the last batch of events.
	LastFirstEventTxnId  int64                  `` /* 126-byte string literal not displayed */
	StateTransitionCount int64                  `protobuf:"varint,59,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"`
	ExecutionTime        *timestamppb.Timestamp `protobuf:"bytes,60,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
	// If continued-as-new, or retried, or cron, holds the new run id.
	NewExecutionRunId string           `protobuf:"bytes,61,opt,name=new_execution_run_id,json=newExecutionRunId,proto3" json:"new_execution_run_id,omitempty"`
	ParentClock       *v14.VectorClock `protobuf:"bytes,62,opt,name=parent_clock,json=parentClock,proto3" json:"parent_clock,omitempty"`
	// version of child execution initiated event in parent workflow
	ParentInitiatedVersion int64 `` /* 131-byte string literal not displayed */
	// Used to check if transfer close task is processed before deleting the workflow execution.
	CloseTransferTaskId int64 `protobuf:"varint,64,opt,name=close_transfer_task_id,json=closeTransferTaskId,proto3" json:"close_transfer_task_id,omitempty"`
	// Used to check if visibility close task is processed before deleting the workflow execution.
	CloseVisibilityTaskId        int64                  `` /* 130-byte string literal not displayed */
	CloseTime                    *timestamppb.Timestamp `protobuf:"bytes,66,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
	CloseVisibilityTaskCompleted bool                   `` /* 151-byte string literal not displayed */
	BaseExecutionInfo            *v15.BaseExecutionInfo `protobuf:"bytes,76,opt,name=base_execution_info,json=baseExecutionInfo,proto3" json:"base_execution_info,omitempty"`
	// If using build-id based versioning: version stamp of the last worker to complete a
	// workflow tasks for this workflow.
	MostRecentWorkerVersionStamp *v12.WorkerVersionStamp `` /* 152-byte string literal not displayed */
	// The currently assigned build ID for this execution. Presence of this value means worker versioning is used
	// for this execution. Assigned build ID is selected by matching based on Worker Versioning Assignment Rules
	// when the first workflow task of the execution is scheduled. If the first workflow task fails and is scheduled
	// again, the assigned build ID may change according to the latest versioning rules.
	// Assigned build ID can also change in the middle of a execution if Compatible Redirect Rules are applied to
	// this execution.
	AssignedBuildId string `protobuf:"bytes,85,opt,name=assigned_build_id,json=assignedBuildId,proto3" json:"assigned_build_id,omitempty"`
	// Build ID inherited from a previous/parent execution. If present, assigned_build_id will be set to this, instead
	// of using the assignment rules.
	InheritedBuildId string `protobuf:"bytes,86,opt,name=inherited_build_id,json=inheritedBuildId,proto3" json:"inherited_build_id,omitempty"`
	// Tracks the number of times a redirect rule is applied to this workflow. Used to apply redirects in the right
	// order when mutable state is rebuilt from history events.
	BuildIdRedirectCounter int64 `` /* 133-byte string literal not displayed */
	// index of update IDs and pointers to associated history events.
	UpdateInfos map[string]*UpdateInfo `` /* 183-byte string literal not displayed */
	// Transition history encodes all transitions a mutable state object has gone through in a compact way.
	// Here the transition_count field of VersionedTransition represents the maximum transition count the mutable state object
	// has gone through for the corresponding namespace failover version.
	// For example, if the transition history is `[{v: 1, t: 3}, {v: 2, t: 5}]`, it means transition 1-3 have failover version 1,
	// and transition 4-5 have failover version 2.
	//
	// Each task generated by the HSM framework is imprinted with the current VersionedTransition at the end of the transaction.
	// When a task is being processed, the transition history is compared with the imprinted task information to
	// verify that a task is not referencing a stale state or that the task itself is not stale.
	// For example, with the same transition history above, task A `{v: 2, t: 4}` **is not**
	// referencing stale state because for version `2` transitions `4-5` are valid, while task B `{v: 2, t: 6}` **is**
	// referencing stale state because the transition count is out of range for version `2`.
	// Furthermore, task C `{v: 1, t: 4}` itself is stale because it is referencing an impossible state, likely due to post
	// split-brain reconciliation.
	TransitionHistory []*VersionedTransition `protobuf:"bytes,80,rep,name=transition_history,json=transitionHistory,proto3" json:"transition_history,omitempty"`
	// Map of state machine type to map of machine by ID.
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "by" is used to clarify the keys and values. --)
	SubStateMachinesByType map[string]*StateMachineMap `` /* 222-byte string literal not displayed */
	// This field is for tracking if the workflow execution timer task is created or not.
	// We don't need this field if we always create the execution timer task when the first
	// workflow in a workflow chain starts. However, this execution timer logic is later added.
	// To maintain backward compatibility, we need to track if the execution timer task is created
	// for a workflow chain since later workflows in the chain also need to create the execution
	// timer task if it is not created yet.
	// NOTE: Task status is clsuter specific information, so when replicating mutable state, this
	// field need to be sanitized.
	WorkflowExecutionTimerTaskStatus int32 `` /* 165-byte string literal not displayed */
	// The root workflow execution is defined as follows:
	// 1. A workflow without parent workflow is its own root workflow.
	// 2. A workflow that has a parent workflow has the same root workflow as its parent workflow.
	RootWorkflowId string `protobuf:"bytes,83,opt,name=root_workflow_id,json=rootWorkflowId,proto3" json:"root_workflow_id,omitempty"`
	RootRunId      string `protobuf:"bytes,84,opt,name=root_run_id,json=rootRunId,proto3" json:"root_run_id,omitempty"`
	// Timer tasks emitted from state machines are stored in this array, grouped and sorted by their deadline. Only the
	// next state machine timer task is generated at a time per mutable state. When that task is processed it iterates
	// this array and triggers timers that are ready.
	// NOTE: Task status is cluster specific information, so when replicating mutable state, this field needs to be
	// sanitized.
	StateMachineTimers []*StateMachineTimerGroup `protobuf:"bytes,90,rep,name=state_machine_timers,json=stateMachineTimers,proto3" json:"state_machine_timers,omitempty"`
	// The shard clock's timestamp at the time the first valid task was created for this mutable state (either for a new
	// mutable state or when rebuilding from events). The field should be updated whenever we refresh tasks, marking
	// older generation tasks obsolete.
	// This field is used for task staleness checks when mutable state is rebuilt.
	// NOTE: Task status is cluster specific information, so when replicating mutable state, this field needs to be
	// sanitized.
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: Ignoring api-linter rules for clarity --)
	//
	// (-- api-linter: core::0142::time-field-type=disabled
	//
	//	aip.dev/not-precedent: This is a vector clock, not a timestamp --)
	TaskGenerationShardClockTimestamp             int64                         `` /* 168-byte string literal not displayed */
	WorkflowTaskLastUpdateVersionedTransition     *VersionedTransition          `` /* 193-byte string literal not displayed */
	VisibilityLastUpdateVersionedTransition       *VersionedTransition          `` /* 185-byte string literal not displayed */
	SignalRequestIdsLastUpdateVersionedTransition *VersionedTransition          `` /* 207-byte string literal not displayed */
	SubStateMachineTombstoneBatches               []*StateMachineTombstoneBatch `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

execution column

func (*WorkflowExecutionInfo) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionInfo.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionInfo) Equal 

func (this *WorkflowExecutionInfo) Equal(that interface{}) bool

Equal returns whether two WorkflowExecutionInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WorkflowExecutionInfo) GetActivityCount added in v1.20.1 

func (x *WorkflowExecutionInfo) GetActivityCount() int64

func (*WorkflowExecutionInfo) GetAssignedBuildId added in v1.24.0 

func (x *WorkflowExecutionInfo) GetAssignedBuildId() string

func (*WorkflowExecutionInfo) GetAttempt 

func (x *WorkflowExecutionInfo) GetAttempt() int32

func (*WorkflowExecutionInfo) GetAutoResetPoints 

func (x *WorkflowExecutionInfo) GetAutoResetPoints() *v11.ResetPoints

func (*WorkflowExecutionInfo) GetBaseExecutionInfo added in v1.21.0 

func (x *WorkflowExecutionInfo) GetBaseExecutionInfo() *v15.BaseExecutionInfo

func (*WorkflowExecutionInfo) GetBuildIdRedirectCounter added in v1.24.0 

func (x *WorkflowExecutionInfo) GetBuildIdRedirectCounter() int64

func (*WorkflowExecutionInfo) GetCancelRequestId 

func (x *WorkflowExecutionInfo) GetCancelRequestId() string

func (*WorkflowExecutionInfo) GetCancelRequested 

func (x *WorkflowExecutionInfo) GetCancelRequested() bool

func (*WorkflowExecutionInfo) GetChildExecutionCount added in v1.20.1 

func (x *WorkflowExecutionInfo) GetChildExecutionCount() int64

func (*WorkflowExecutionInfo) GetCloseTime added in v1.17.0 

func (x *WorkflowExecutionInfo) GetCloseTime() *timestamppb.Timestamp

func (*WorkflowExecutionInfo) GetCloseTransferTaskId added in v1.17.0 

func (x *WorkflowExecutionInfo) GetCloseTransferTaskId() int64

func (*WorkflowExecutionInfo) GetCloseVisibilityTaskCompleted added in v1.19.0 

func (x *WorkflowExecutionInfo) GetCloseVisibilityTaskCompleted() bool

func (*WorkflowExecutionInfo) GetCloseVisibilityTaskId added in v1.17.0 

func (x *WorkflowExecutionInfo) GetCloseVisibilityTaskId() int64

func (*WorkflowExecutionInfo) GetCompletionEventBatchId 

func (x *WorkflowExecutionInfo) GetCompletionEventBatchId() int64

func (*WorkflowExecutionInfo) GetCronSchedule 

func (x *WorkflowExecutionInfo) GetCronSchedule() string

func (*WorkflowExecutionInfo) GetDefaultWorkflowTaskTimeout 

func (x *WorkflowExecutionInfo) GetDefaultWorkflowTaskTimeout() *durationpb.Duration

func (*WorkflowExecutionInfo) GetExecutionStats 

func (x *WorkflowExecutionInfo) GetExecutionStats() *ExecutionStats

func (*WorkflowExecutionInfo) GetExecutionTime added in v1.11.0 

func (x *WorkflowExecutionInfo) GetExecutionTime() *timestamppb.Timestamp

func (*WorkflowExecutionInfo) GetFirstExecutionRunId 

func (x *WorkflowExecutionInfo) GetFirstExecutionRunId() string

func (*WorkflowExecutionInfo) GetHasRetryPolicy 

func (x *WorkflowExecutionInfo) GetHasRetryPolicy() bool

func (*WorkflowExecutionInfo) GetInheritedBuildId added in v1.24.0 

func (x *WorkflowExecutionInfo) GetInheritedBuildId() string

func (*WorkflowExecutionInfo) GetLastCompletedWorkflowTaskStartedEventId added in v1.25.0 

func (x *WorkflowExecutionInfo) GetLastCompletedWorkflowTaskStartedEventId() int64

func (*WorkflowExecutionInfo) GetLastEventTaskId 

func (x *WorkflowExecutionInfo) GetLastEventTaskId() int64

func (*WorkflowExecutionInfo) GetLastFirstEventId 

func (x *WorkflowExecutionInfo) GetLastFirstEventId() int64

func (*WorkflowExecutionInfo) GetLastFirstEventTxnId added in v1.9.0 

func (x *WorkflowExecutionInfo) GetLastFirstEventTxnId() int64

func (*WorkflowExecutionInfo) GetLastUpdateTime 

func (x *WorkflowExecutionInfo) GetLastUpdateTime() *timestamppb.Timestamp

func (*WorkflowExecutionInfo) GetMemo 

func (x *WorkflowExecutionInfo) GetMemo() map[string]*v12.Payload

func (*WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp added in v1.24.0 

func (x *WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp() *v12.WorkerVersionStamp

func (*WorkflowExecutionInfo) GetNamespaceId 

func (x *WorkflowExecutionInfo) GetNamespaceId() string

func (*WorkflowExecutionInfo) GetNewExecutionRunId added in v1.13.0 

func (x *WorkflowExecutionInfo) GetNewExecutionRunId() string

func (*WorkflowExecutionInfo) GetParentClock added in v1.17.0 

func (x *WorkflowExecutionInfo) GetParentClock() *v14.VectorClock

func (*WorkflowExecutionInfo) GetParentInitiatedId added in v1.17.0 

func (x *WorkflowExecutionInfo) GetParentInitiatedId() int64

func (*WorkflowExecutionInfo) GetParentInitiatedVersion added in v1.17.0 

func (x *WorkflowExecutionInfo) GetParentInitiatedVersion() int64

func (*WorkflowExecutionInfo) GetParentNamespaceId 

func (x *WorkflowExecutionInfo) GetParentNamespaceId() string

func (*WorkflowExecutionInfo) GetParentRunId 

func (x *WorkflowExecutionInfo) GetParentRunId() string

func (*WorkflowExecutionInfo) GetParentWorkflowId 

func (x *WorkflowExecutionInfo) GetParentWorkflowId() string

func (*WorkflowExecutionInfo) GetRequestCancelExternalCount added in v1.20.1 

func (x *WorkflowExecutionInfo) GetRequestCancelExternalCount() int64

func (*WorkflowExecutionInfo) GetRetryBackoffCoefficient 

func (x *WorkflowExecutionInfo) GetRetryBackoffCoefficient() float64

func (*WorkflowExecutionInfo) GetRetryInitialInterval 

func (x *WorkflowExecutionInfo) GetRetryInitialInterval() *durationpb.Duration

func (*WorkflowExecutionInfo) GetRetryMaximumAttempts 

func (x *WorkflowExecutionInfo) GetRetryMaximumAttempts() int32

func (*WorkflowExecutionInfo) GetRetryMaximumInterval 

func (x *WorkflowExecutionInfo) GetRetryMaximumInterval() *durationpb.Duration

func (*WorkflowExecutionInfo) GetRetryNonRetryableErrorTypes 

func (x *WorkflowExecutionInfo) GetRetryNonRetryableErrorTypes() []string

func (*WorkflowExecutionInfo) GetRootRunId added in v1.24.0 

func (x *WorkflowExecutionInfo) GetRootRunId() string

func (*WorkflowExecutionInfo) GetRootWorkflowId added in v1.24.0 

func (x *WorkflowExecutionInfo) GetRootWorkflowId() string

func (*WorkflowExecutionInfo) GetSearchAttributes 

func (x *WorkflowExecutionInfo) GetSearchAttributes() map[string]*v12.Payload

func (*WorkflowExecutionInfo) GetSignalCount 

func (x *WorkflowExecutionInfo) GetSignalCount() int64

func (*WorkflowExecutionInfo) GetSignalExternalCount added in v1.20.1 

func (x *WorkflowExecutionInfo) GetSignalExternalCount() int64

func (*WorkflowExecutionInfo) GetSignalRequestIdsLastUpdateVersionedTransition added in v1.25.0 

func (x *WorkflowExecutionInfo) GetSignalRequestIdsLastUpdateVersionedTransition() *VersionedTransition

func (*WorkflowExecutionInfo) GetStartTime 

func (x *WorkflowExecutionInfo) GetStartTime() *timestamppb.Timestamp

func (*WorkflowExecutionInfo) GetStateMachineTimers added in v1.25.0 

func (x *WorkflowExecutionInfo) GetStateMachineTimers() []*StateMachineTimerGroup

func (*WorkflowExecutionInfo) GetStateTransitionCount added in v1.10.0 

func (x *WorkflowExecutionInfo) GetStateTransitionCount() int64

func (*WorkflowExecutionInfo) GetStickyScheduleToStartTimeout 

func (x *WorkflowExecutionInfo) GetStickyScheduleToStartTimeout() *durationpb.Duration

func (*WorkflowExecutionInfo) GetStickyTaskQueue 

func (x *WorkflowExecutionInfo) GetStickyTaskQueue() string

func (*WorkflowExecutionInfo) GetSubStateMachineTombstoneBatches added in v1.25.0 

func (x *WorkflowExecutionInfo) GetSubStateMachineTombstoneBatches() []*StateMachineTombstoneBatch

func (*WorkflowExecutionInfo) GetSubStateMachinesByType added in v1.24.0 

func (x *WorkflowExecutionInfo) GetSubStateMachinesByType() map[string]*StateMachineMap

func (*WorkflowExecutionInfo) GetTaskGenerationShardClockTimestamp added in v1.25.0 

func (x *WorkflowExecutionInfo) GetTaskGenerationShardClockTimestamp() int64

func (*WorkflowExecutionInfo) GetTaskQueue 

func (x *WorkflowExecutionInfo) GetTaskQueue() string

func (*WorkflowExecutionInfo) GetTransitionHistory added in v1.24.0 

func (x *WorkflowExecutionInfo) GetTransitionHistory() []*VersionedTransition

func (*WorkflowExecutionInfo) GetUpdateCount added in v1.21.0 

func (x *WorkflowExecutionInfo) GetUpdateCount() int64

func (*WorkflowExecutionInfo) GetUpdateInfos added in v1.21.0 

func (x *WorkflowExecutionInfo) GetUpdateInfos() map[string]*UpdateInfo

func (*WorkflowExecutionInfo) GetUserTimerCount added in v1.20.1 

func (x *WorkflowExecutionInfo) GetUserTimerCount() int64

func (*WorkflowExecutionInfo) GetVersionHistories 

func (x *WorkflowExecutionInfo) GetVersionHistories() *v13.VersionHistories

func (*WorkflowExecutionInfo) GetVisibilityLastUpdateVersionedTransition added in v1.25.0 

func (x *WorkflowExecutionInfo) GetVisibilityLastUpdateVersionedTransition() *VersionedTransition

func (*WorkflowExecutionInfo) GetWorkflowExecutionExpirationTime added in v1.4.0 

func (x *WorkflowExecutionInfo) GetWorkflowExecutionExpirationTime() *timestamppb.Timestamp

func (*WorkflowExecutionInfo) GetWorkflowExecutionTimeout 

func (x *WorkflowExecutionInfo) GetWorkflowExecutionTimeout() *durationpb.Duration

func (*WorkflowExecutionInfo) GetWorkflowExecutionTimerTaskStatus added in v1.24.0 

func (x *WorkflowExecutionInfo) GetWorkflowExecutionTimerTaskStatus() int32

func (*WorkflowExecutionInfo) GetWorkflowId 

func (x *WorkflowExecutionInfo) GetWorkflowId() string

func (*WorkflowExecutionInfo) GetWorkflowRunExpirationTime added in v1.4.0 

func (x *WorkflowExecutionInfo) GetWorkflowRunExpirationTime() *timestamppb.Timestamp

func (*WorkflowExecutionInfo) GetWorkflowRunTimeout 

func (x *WorkflowExecutionInfo) GetWorkflowRunTimeout() *durationpb.Duration

func (*WorkflowExecutionInfo) GetWorkflowTaskAttempt 

func (x *WorkflowExecutionInfo) GetWorkflowTaskAttempt() int32

func (*WorkflowExecutionInfo) GetWorkflowTaskBuildId added in v1.24.0 

func (x *WorkflowExecutionInfo) GetWorkflowTaskBuildId() string

func (*WorkflowExecutionInfo) GetWorkflowTaskBuildIdRedirectCounter added in v1.24.0 

func (x *WorkflowExecutionInfo) GetWorkflowTaskBuildIdRedirectCounter() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskHistorySizeBytes added in v1.20.0 

func (x *WorkflowExecutionInfo) GetWorkflowTaskHistorySizeBytes() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskLastUpdateVersionedTransition added in v1.25.0 

func (x *WorkflowExecutionInfo) GetWorkflowTaskLastUpdateVersionedTransition() *VersionedTransition

func (*WorkflowExecutionInfo) GetWorkflowTaskOriginalScheduledTime 

func (x *WorkflowExecutionInfo) GetWorkflowTaskOriginalScheduledTime() *timestamppb.Timestamp

func (*WorkflowExecutionInfo) GetWorkflowTaskRequestId 

func (x *WorkflowExecutionInfo) GetWorkflowTaskRequestId() string

func (*WorkflowExecutionInfo) GetWorkflowTaskScheduledEventId added in v1.17.0 

func (x *WorkflowExecutionInfo) GetWorkflowTaskScheduledEventId() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskScheduledTime 

func (x *WorkflowExecutionInfo) GetWorkflowTaskScheduledTime() *timestamppb.Timestamp

func (*WorkflowExecutionInfo) GetWorkflowTaskStartedEventId added in v1.17.0 

func (x *WorkflowExecutionInfo) GetWorkflowTaskStartedEventId() int64

func (*WorkflowExecutionInfo) GetWorkflowTaskStartedTime 

func (x *WorkflowExecutionInfo) GetWorkflowTaskStartedTime() *timestamppb.Timestamp

func (*WorkflowExecutionInfo) GetWorkflowTaskSuggestContinueAsNew added in v1.20.0 

func (x *WorkflowExecutionInfo) GetWorkflowTaskSuggestContinueAsNew() bool

func (*WorkflowExecutionInfo) GetWorkflowTaskTimeout 

func (x *WorkflowExecutionInfo) GetWorkflowTaskTimeout() *durationpb.Duration

func (*WorkflowExecutionInfo) GetWorkflowTaskType added in v1.20.0 

func (x *WorkflowExecutionInfo) GetWorkflowTaskType() v1.WorkflowTaskType

func (*WorkflowExecutionInfo) GetWorkflowTaskVersion 

func (x *WorkflowExecutionInfo) GetWorkflowTaskVersion() int64

func (*WorkflowExecutionInfo) GetWorkflowTypeName 

func (x *WorkflowExecutionInfo) GetWorkflowTypeName() string

func (*WorkflowExecutionInfo) Marshal 

func (val *WorkflowExecutionInfo) Marshal() ([]byte, error)

Marshal an object of type WorkflowExecutionInfo to the protobuf v3 wire format

func (*WorkflowExecutionInfo) ProtoMessage 

func (*WorkflowExecutionInfo) ProtoMessage()

func (*WorkflowExecutionInfo) ProtoReflect added in v1.23.0 

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

func (*WorkflowExecutionInfo) Reset 

func (x *WorkflowExecutionInfo) Reset()

func (*WorkflowExecutionInfo) Size 

func (val *WorkflowExecutionInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowExecutionInfo) String 

func (x *WorkflowExecutionInfo) String() string

func (*WorkflowExecutionInfo) Unmarshal 

func (val *WorkflowExecutionInfo) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowExecutionInfo from the protobuf v3 wire format

type WorkflowExecutionState 

type WorkflowExecutionState struct {
	CreateRequestId               string                      `protobuf:"bytes,1,opt,name=create_request_id,json=createRequestId,proto3" json:"create_request_id,omitempty"`
	RunId                         string                      `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	State                         v1.WorkflowExecutionState   `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.server.api.enums.v1.WorkflowExecutionState" json:"state,omitempty"`
	Status                        v16.WorkflowExecutionStatus `protobuf:"varint,4,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	LastUpdateVersionedTransition *VersionedTransition        `` /* 152-byte string literal not displayed */
	StartTime                     *timestamppb.Timestamp      `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

execution_state column

func (*WorkflowExecutionState) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionState.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionState) Equal 

func (this *WorkflowExecutionState) Equal(that interface{}) bool

Equal returns whether two WorkflowExecutionState values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WorkflowExecutionState) GetCreateRequestId 

func (x *WorkflowExecutionState) GetCreateRequestId() string

func (*WorkflowExecutionState) GetLastUpdateVersionedTransition added in v1.25.0 

func (x *WorkflowExecutionState) GetLastUpdateVersionedTransition() *VersionedTransition

func (*WorkflowExecutionState) GetRunId 

func (x *WorkflowExecutionState) GetRunId() string

func (*WorkflowExecutionState) GetStartTime added in v1.25.0 

func (x *WorkflowExecutionState) GetStartTime() *timestamppb.Timestamp

func (*WorkflowExecutionState) GetState 

func (x *WorkflowExecutionState) GetState() v1.WorkflowExecutionState

func (*WorkflowExecutionState) GetStatus 

func (x *WorkflowExecutionState) GetStatus() v16.WorkflowExecutionStatus

func (*WorkflowExecutionState) Marshal 

func (val *WorkflowExecutionState) Marshal() ([]byte, error)

Marshal an object of type WorkflowExecutionState to the protobuf v3 wire format

func (*WorkflowExecutionState) ProtoMessage 

func (*WorkflowExecutionState) ProtoMessage()

func (*WorkflowExecutionState) ProtoReflect added in v1.23.0 

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

func (*WorkflowExecutionState) Reset 

func (x *WorkflowExecutionState) Reset()

func (*WorkflowExecutionState) Size 

func (val *WorkflowExecutionState) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowExecutionState) String 

func (x *WorkflowExecutionState) String() string

func (*WorkflowExecutionState) Unmarshal 

func (val *WorkflowExecutionState) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowExecutionState from the protobuf v3 wire format

type WorkflowMutableState 

type WorkflowMutableState struct {
	ActivityInfos       map[int64]*ActivityInfo       `` /* 189-byte string literal not displayed */
	TimerInfos          map[string]*TimerInfo         `` /* 179-byte string literal not displayed */
	ChildExecutionInfos map[int64]*ChildExecutionInfo `` /* 209-byte string literal not displayed */
	RequestCancelInfos  map[int64]*RequestCancelInfo  `` /* 206-byte string literal not displayed */
	SignalInfos         map[int64]*SignalInfo         `` /* 183-byte string literal not displayed */
	SignalRequestedIds  []string                      `protobuf:"bytes,6,rep,name=signal_requested_ids,json=signalRequestedIds,proto3" json:"signal_requested_ids,omitempty"`
	ExecutionInfo       *WorkflowExecutionInfo        `protobuf:"bytes,7,opt,name=execution_info,json=executionInfo,proto3" json:"execution_info,omitempty"`
	ExecutionState      *WorkflowExecutionState       `protobuf:"bytes,8,opt,name=execution_state,json=executionState,proto3" json:"execution_state,omitempty"`
	NextEventId         int64                         `protobuf:"varint,9,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	BufferedEvents      []*v1.HistoryEvent            `protobuf:"bytes,10,rep,name=buffered_events,json=bufferedEvents,proto3" json:"buffered_events,omitempty"`
	Checksum            *Checksum                     `protobuf:"bytes,11,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowMutableState) Descriptor deprecated 

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

Deprecated: Use WorkflowMutableState.ProtoReflect.Descriptor instead.

func (*WorkflowMutableState) Equal 

func (this *WorkflowMutableState) Equal(that interface{}) bool

Equal returns whether two WorkflowMutableState values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WorkflowMutableState) GetActivityInfos 

func (x *WorkflowMutableState) GetActivityInfos() map[int64]*ActivityInfo

func (*WorkflowMutableState) GetBufferedEvents 

func (x *WorkflowMutableState) GetBufferedEvents() []*v1.HistoryEvent

func (*WorkflowMutableState) GetChecksum 

func (x *WorkflowMutableState) GetChecksum() *Checksum

func (*WorkflowMutableState) GetChildExecutionInfos 

func (x *WorkflowMutableState) GetChildExecutionInfos() map[int64]*ChildExecutionInfo

func (*WorkflowMutableState) GetExecutionInfo 

func (x *WorkflowMutableState) GetExecutionInfo() *WorkflowExecutionInfo

func (*WorkflowMutableState) GetExecutionState 

func (x *WorkflowMutableState) GetExecutionState() *WorkflowExecutionState

func (*WorkflowMutableState) GetNextEventId 

func (x *WorkflowMutableState) GetNextEventId() int64

func (*WorkflowMutableState) GetRequestCancelInfos 

func (x *WorkflowMutableState) GetRequestCancelInfos() map[int64]*RequestCancelInfo

func (*WorkflowMutableState) GetSignalInfos 

func (x *WorkflowMutableState) GetSignalInfos() map[int64]*SignalInfo

func (*WorkflowMutableState) GetSignalRequestedIds 

func (x *WorkflowMutableState) GetSignalRequestedIds() []string

func (*WorkflowMutableState) GetTimerInfos 

func (x *WorkflowMutableState) GetTimerInfos() map[string]*TimerInfo

func (*WorkflowMutableState) Marshal 

func (val *WorkflowMutableState) Marshal() ([]byte, error)

Marshal an object of type WorkflowMutableState to the protobuf v3 wire format

func (*WorkflowMutableState) ProtoMessage 

func (*WorkflowMutableState) ProtoMessage()

func (*WorkflowMutableState) ProtoReflect added in v1.23.0 

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

func (*WorkflowMutableState) Reset 

func (x *WorkflowMutableState) Reset()

func (*WorkflowMutableState) Size 

func (val *WorkflowMutableState) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowMutableState) String 

func (x *WorkflowMutableState) String() string

func (*WorkflowMutableState) Unmarshal 

func (val *WorkflowMutableState) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowMutableState from the protobuf v3 wire format

type WorkflowMutableStateMutation added in v1.25.0 

type WorkflowMutableStateMutation struct {

	// The following updated_* fields are computed based on the
	// lastUpdateVersionedTransition field of each sub state machine.
	UpdatedActivityInfos       map[int64]*ActivityInfo                                  `` /* 212-byte string literal not displayed */
	UpdatedTimerInfos          map[string]*TimerInfo                                    `` /* 202-byte string literal not displayed */
	UpdatedChildExecutionInfos map[int64]*ChildExecutionInfo                            `` /* 232-byte string literal not displayed */
	UpdatedRequestCancelInfos  map[int64]*RequestCancelInfo                             `` /* 229-byte string literal not displayed */
	UpdatedSignalInfos         map[int64]*SignalInfo                                    `` /* 206-byte string literal not displayed */
	UpdatedUpdateInfos         map[string]*UpdateInfo                                   `` /* 205-byte string literal not displayed */
	UpdatedSubStateMachines    []*WorkflowMutableStateMutation_StateMachineNodeMutation `` /* 134-byte string literal not displayed */
	// The following deleted_* fields are computed based on the
	// sub_state_machine_tombstone_batches field of mutable state.
	DeletedActivities          []int64             `protobuf:"varint,8,rep,packed,name=deleted_activities,json=deletedActivities,proto3" json:"deleted_activities,omitempty"`
	DeletedTimers              []string            `protobuf:"bytes,9,rep,name=deleted_timers,json=deletedTimers,proto3" json:"deleted_timers,omitempty"`
	DeletedChildExecutionInfos []int64             `` /* 152-byte string literal not displayed */
	DeletedRequestCancelInfos  []int64             `` /* 149-byte string literal not displayed */
	DeletedSignalInfos         []int64             `` /* 126-byte string literal not displayed */
	DeletedUpdateInfos         []string            `protobuf:"bytes,13,rep,name=deleted_update_infos,json=deletedUpdateInfos,proto3" json:"deleted_update_infos,omitempty"`
	DeletedSubStateMachines    []*StateMachinePath `` /* 135-byte string literal not displayed */
	SignalRequestedIds         []string            `protobuf:"bytes,15,rep,name=signal_requested_ids,json=signalRequestedIds,proto3" json:"signal_requested_ids,omitempty"`
	// Partial WorkflowExecutionInfo. Some fields, such as
	// update_infos and sub_state_machines_by_type, are not populated here.
	// Instead, only diffs are synced in the deleted_* and updated_* fields above.
	ExecutionInfo  *WorkflowExecutionInfo  `protobuf:"bytes,16,opt,name=execution_info,json=executionInfo,proto3" json:"execution_info,omitempty"`
	ExecutionState *WorkflowExecutionState `protobuf:"bytes,17,opt,name=execution_state,json=executionState,proto3" json:"execution_state,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowMutableStateMutation) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use WorkflowMutableStateMutation.ProtoReflect.Descriptor instead.

func (*WorkflowMutableStateMutation) Equal added in v1.25.0 

func (this *WorkflowMutableStateMutation) Equal(that interface{}) bool

Equal returns whether two WorkflowMutableStateMutation values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WorkflowMutableStateMutation) GetDeletedActivities added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetDeletedActivities() []int64

func (*WorkflowMutableStateMutation) GetDeletedChildExecutionInfos added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetDeletedChildExecutionInfos() []int64

func (*WorkflowMutableStateMutation) GetDeletedRequestCancelInfos added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetDeletedRequestCancelInfos() []int64

func (*WorkflowMutableStateMutation) GetDeletedSignalInfos added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetDeletedSignalInfos() []int64

func (*WorkflowMutableStateMutation) GetDeletedSubStateMachines added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetDeletedSubStateMachines() []*StateMachinePath

func (*WorkflowMutableStateMutation) GetDeletedTimers added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetDeletedTimers() []string

func (*WorkflowMutableStateMutation) GetDeletedUpdateInfos added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetDeletedUpdateInfos() []string

func (*WorkflowMutableStateMutation) GetExecutionInfo added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetExecutionInfo() *WorkflowExecutionInfo

func (*WorkflowMutableStateMutation) GetExecutionState added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetExecutionState() *WorkflowExecutionState

func (*WorkflowMutableStateMutation) GetSignalRequestedIds added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetSignalRequestedIds() []string

func (*WorkflowMutableStateMutation) GetUpdatedActivityInfos added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetUpdatedActivityInfos() map[int64]*ActivityInfo

func (*WorkflowMutableStateMutation) GetUpdatedChildExecutionInfos added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetUpdatedChildExecutionInfos() map[int64]*ChildExecutionInfo

func (*WorkflowMutableStateMutation) GetUpdatedRequestCancelInfos added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetUpdatedRequestCancelInfos() map[int64]*RequestCancelInfo

func (*WorkflowMutableStateMutation) GetUpdatedSignalInfos added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetUpdatedSignalInfos() map[int64]*SignalInfo

func (*WorkflowMutableStateMutation) GetUpdatedSubStateMachines added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetUpdatedSubStateMachines() []*WorkflowMutableStateMutation_StateMachineNodeMutation

func (*WorkflowMutableStateMutation) GetUpdatedTimerInfos added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetUpdatedTimerInfos() map[string]*TimerInfo

func (*WorkflowMutableStateMutation) GetUpdatedUpdateInfos added in v1.25.0 

func (x *WorkflowMutableStateMutation) GetUpdatedUpdateInfos() map[string]*UpdateInfo

func (*WorkflowMutableStateMutation) Marshal added in v1.25.0 

func (val *WorkflowMutableStateMutation) Marshal() ([]byte, error)

Marshal an object of type WorkflowMutableStateMutation to the protobuf v3 wire format

func (*WorkflowMutableStateMutation) ProtoMessage added in v1.25.0 

func (*WorkflowMutableStateMutation) ProtoMessage()

func (*WorkflowMutableStateMutation) ProtoReflect added in v1.25.0 

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

func (*WorkflowMutableStateMutation) Reset added in v1.25.0 

func (x *WorkflowMutableStateMutation) Reset()

func (*WorkflowMutableStateMutation) Size added in v1.25.0 

func (val *WorkflowMutableStateMutation) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowMutableStateMutation) String added in v1.25.0 

func (x *WorkflowMutableStateMutation) String() string

func (*WorkflowMutableStateMutation) Unmarshal added in v1.25.0 

func (val *WorkflowMutableStateMutation) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowMutableStateMutation from the protobuf v3 wire format

type WorkflowMutableStateMutation_StateMachineNodeMutation added in v1.25.0 

type WorkflowMutableStateMutation_StateMachineNodeMutation struct {
	Path                          *StateMachinePath    `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Data                          []byte               `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	InitialVersionedTransition    *VersionedTransition `` /* 141-byte string literal not displayed */
	LastUpdateVersionedTransition *VersionedTransition `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkflowMutableStateMutation_StateMachineNodeMutation) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use WorkflowMutableStateMutation_StateMachineNodeMutation.ProtoReflect.Descriptor instead.

func (*WorkflowMutableStateMutation_StateMachineNodeMutation) GetData added in v1.25.0 

func (x *WorkflowMutableStateMutation_StateMachineNodeMutation) GetData() []byte

func (*WorkflowMutableStateMutation_StateMachineNodeMutation) GetInitialVersionedTransition added in v1.25.0 

func (x *WorkflowMutableStateMutation_StateMachineNodeMutation) GetInitialVersionedTransition() *VersionedTransition

func (*WorkflowMutableStateMutation_StateMachineNodeMutation) GetLastUpdateVersionedTransition added in v1.25.0 

func (x *WorkflowMutableStateMutation_StateMachineNodeMutation) GetLastUpdateVersionedTransition() *VersionedTransition

func (*WorkflowMutableStateMutation_StateMachineNodeMutation) GetPath added in v1.25.0 

func (x *WorkflowMutableStateMutation_StateMachineNodeMutation) GetPath() *StateMachinePath

func (*WorkflowMutableStateMutation_StateMachineNodeMutation) ProtoMessage added in v1.25.0 

func (*WorkflowMutableStateMutation_StateMachineNodeMutation) ProtoMessage()

func (*WorkflowMutableStateMutation_StateMachineNodeMutation) ProtoReflect added in v1.25.0 

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

func (*WorkflowMutableStateMutation_StateMachineNodeMutation) Reset added in v1.25.0 

func (x *WorkflowMutableStateMutation_StateMachineNodeMutation) Reset()

func (*WorkflowMutableStateMutation_StateMachineNodeMutation) String added in v1.25.0 

func (x *WorkflowMutableStateMutation_StateMachineNodeMutation) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.