repication

package
v1.9.5 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2026 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_server_api_replication_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BackfillHistoryTaskAttributes 

type BackfillHistoryTaskAttributes 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"`
	EventVersionHistory []*v16.VersionHistoryItem `protobuf:"bytes,5,rep,name=event_version_history,json=eventVersionHistory,proto3" json:"event_version_history,omitempty"`
	EventBatches        []*v11.DataBlob           `protobuf:"bytes,6,rep,name=event_batches,json=eventBatches,proto3" json:"event_batches,omitempty"`
	NewRunInfo          *NewRunInfo               `protobuf:"bytes,7,opt,name=new_run_info,json=newRunInfo,proto3" json:"new_run_info,omitempty"`
	// contains filtered or unexported fields
}

func (*BackfillHistoryTaskAttributes) Descriptor deprecated 

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

Deprecated: Use BackfillHistoryTaskAttributes.ProtoReflect.Descriptor instead.

func (*BackfillHistoryTaskAttributes) Equal 

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

Equal returns whether two BackfillHistoryTaskAttributes 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 (*BackfillHistoryTaskAttributes) GetEventBatches 

func (x *BackfillHistoryTaskAttributes) GetEventBatches() []*v11.DataBlob

func (*BackfillHistoryTaskAttributes) GetEventVersionHistory 

func (x *BackfillHistoryTaskAttributes) GetEventVersionHistory() []*v16.VersionHistoryItem

func (*BackfillHistoryTaskAttributes) GetNamespaceId 

func (x *BackfillHistoryTaskAttributes) GetNamespaceId() string

func (*BackfillHistoryTaskAttributes) GetNewRunInfo 

func (x *BackfillHistoryTaskAttributes) GetNewRunInfo() *NewRunInfo

func (*BackfillHistoryTaskAttributes) GetRunId 

func (x *BackfillHistoryTaskAttributes) GetRunId() string

func (*BackfillHistoryTaskAttributes) GetWorkflowId 

func (x *BackfillHistoryTaskAttributes) GetWorkflowId() string

func (*BackfillHistoryTaskAttributes) Marshal 

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

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

func (*BackfillHistoryTaskAttributes) ProtoMessage 

func (*BackfillHistoryTaskAttributes) ProtoMessage()

func (*BackfillHistoryTaskAttributes) ProtoReflect 

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

func (*BackfillHistoryTaskAttributes) Reset 

func (x *BackfillHistoryTaskAttributes) Reset()

func (*BackfillHistoryTaskAttributes) Size 

func (val *BackfillHistoryTaskAttributes) Size() int

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

func (*BackfillHistoryTaskAttributes) String 

func (x *BackfillHistoryTaskAttributes) String() string

func (*BackfillHistoryTaskAttributes) Unmarshal 

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

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

type HistoryTaskAttributes 

type HistoryTaskAttributes struct {
	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"`
	VersionHistoryItems []*v16.VersionHistoryItem `protobuf:"bytes,5,rep,name=version_history_items,json=versionHistoryItems,proto3" json:"version_history_items,omitempty"`
	// to be deprecated in favor of using events_batches
	Events *v11.DataBlob `protobuf:"bytes,6,opt,name=events,proto3" json:"events,omitempty"`
	// New run events does not need version history since there is no prior events.
	NewRunEvents      *v11.DataBlob          `protobuf:"bytes,7,opt,name=new_run_events,json=newRunEvents,proto3" json:"new_run_events,omitempty"`
	BaseExecutionInfo *v17.BaseExecutionInfo `protobuf:"bytes,8,opt,name=base_execution_info,json=baseExecutionInfo,proto3" json:"base_execution_info,omitempty"`
	NewRunId          string                 `protobuf:"bytes,9,opt,name=new_run_id,json=newRunId,proto3" json:"new_run_id,omitempty"`
	EventsBatches     []*v11.DataBlob        `protobuf:"bytes,10,rep,name=events_batches,json=eventsBatches,proto3" json:"events_batches,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryTaskAttributes) Descriptor deprecated 

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

Deprecated: Use HistoryTaskAttributes.ProtoReflect.Descriptor instead.

func (*HistoryTaskAttributes) Equal 

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

Equal returns whether two HistoryTaskAttributes 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 (*HistoryTaskAttributes) GetBaseExecutionInfo 

func (x *HistoryTaskAttributes) GetBaseExecutionInfo() *v17.BaseExecutionInfo

func (*HistoryTaskAttributes) GetEvents 

func (x *HistoryTaskAttributes) GetEvents() *v11.DataBlob

func (*HistoryTaskAttributes) GetEventsBatches 

func (x *HistoryTaskAttributes) GetEventsBatches() []*v11.DataBlob

func (*HistoryTaskAttributes) GetNamespaceId 

func (x *HistoryTaskAttributes) GetNamespaceId() string

func (*HistoryTaskAttributes) GetNewRunEvents 

func (x *HistoryTaskAttributes) GetNewRunEvents() *v11.DataBlob

func (*HistoryTaskAttributes) GetNewRunId 

func (x *HistoryTaskAttributes) GetNewRunId() string

func (*HistoryTaskAttributes) GetRunId 

func (x *HistoryTaskAttributes) GetRunId() string

func (*HistoryTaskAttributes) GetVersionHistoryItems 

func (x *HistoryTaskAttributes) GetVersionHistoryItems() []*v16.VersionHistoryItem

func (*HistoryTaskAttributes) GetWorkflowId 

func (x *HistoryTaskAttributes) GetWorkflowId() string

func (*HistoryTaskAttributes) Marshal 

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

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

func (*HistoryTaskAttributes) ProtoMessage 

func (*HistoryTaskAttributes) ProtoMessage()

func (*HistoryTaskAttributes) ProtoReflect 

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

func (*HistoryTaskAttributes) Reset 

func (x *HistoryTaskAttributes) Reset()

func (*HistoryTaskAttributes) Size 

func (val *HistoryTaskAttributes) Size() int

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

func (*HistoryTaskAttributes) String 

func (x *HistoryTaskAttributes) String() string

func (*HistoryTaskAttributes) Unmarshal 

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

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

type MigrationExecutionInfo 

type MigrationExecutionInfo struct {

	// The proto json name of this field needs to be "workflowId",
	// to be backward compatibility with commonpb.WorkflowExecution,
	// which is what used to be used in migration workflow's activity
	// input/output.
	BusinessId string `protobuf:"bytes,1,opt,name=business_id,json=workflowId,proto3" json:"business_id,omitempty"`
	RunId      string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// (-- api-linter: core::0141::forbidden-types=disabled --)
	ArchetypeId uint32 `protobuf:"varint,3,opt,name=archetype_id,json=archetypeId,proto3" json:"archetype_id,omitempty"`
	// contains filtered or unexported fields
}

MigrationExecutionInfo is only used in unit tests for validation compatibility. Remove it after v1.30 is released.

func (*MigrationExecutionInfo) Descriptor deprecated 

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

Deprecated: Use MigrationExecutionInfo.ProtoReflect.Descriptor instead.

func (*MigrationExecutionInfo) Equal 

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

Equal returns whether two MigrationExecutionInfo 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 (*MigrationExecutionInfo) GetArchetypeId 

func (x *MigrationExecutionInfo) GetArchetypeId() uint32

func (*MigrationExecutionInfo) GetBusinessId 

func (x *MigrationExecutionInfo) GetBusinessId() string

func (*MigrationExecutionInfo) GetRunId 

func (x *MigrationExecutionInfo) GetRunId() string

func (*MigrationExecutionInfo) Marshal 

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

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

func (*MigrationExecutionInfo) ProtoMessage 

func (*MigrationExecutionInfo) ProtoMessage()

func (*MigrationExecutionInfo) ProtoReflect 

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

func (*MigrationExecutionInfo) Reset 

func (x *MigrationExecutionInfo) Reset()

func (*MigrationExecutionInfo) Size 

func (val *MigrationExecutionInfo) Size() int

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

func (*MigrationExecutionInfo) String 

func (x *MigrationExecutionInfo) String() string

func (*MigrationExecutionInfo) Unmarshal 

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

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

type NamespaceTaskAttributes 

type NamespaceTaskAttributes struct {
	NamespaceOperation v1.NamespaceOperation           `` /* 169-byte string literal not displayed */
	Id                 string                          `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Info               *v13.NamespaceInfo              `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	Config             *v13.NamespaceConfig            `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	ReplicationConfig  *v14.NamespaceReplicationConfig `protobuf:"bytes,5,opt,name=replication_config,json=replicationConfig,proto3" json:"replication_config,omitempty"`
	ConfigVersion      int64                           `protobuf:"varint,6,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
	FailoverVersion    int64                           `protobuf:"varint,7,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
	FailoverHistory    []*v14.FailoverStatus           `protobuf:"bytes,8,rep,name=failover_history,json=failoverHistory,proto3" json:"failover_history,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespaceTaskAttributes) Descriptor deprecated 

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

Deprecated: Use NamespaceTaskAttributes.ProtoReflect.Descriptor instead.

func (*NamespaceTaskAttributes) Equal 

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

Equal returns whether two NamespaceTaskAttributes 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 (*NamespaceTaskAttributes) GetConfig 

func (x *NamespaceTaskAttributes) GetConfig() *v13.NamespaceConfig

func (*NamespaceTaskAttributes) GetConfigVersion 

func (x *NamespaceTaskAttributes) GetConfigVersion() int64

func (*NamespaceTaskAttributes) GetFailoverHistory 

func (x *NamespaceTaskAttributes) GetFailoverHistory() []*v14.FailoverStatus

func (*NamespaceTaskAttributes) GetFailoverVersion 

func (x *NamespaceTaskAttributes) GetFailoverVersion() int64

func (*NamespaceTaskAttributes) GetId 

func (x *NamespaceTaskAttributes) GetId() string

func (*NamespaceTaskAttributes) GetInfo 

func (x *NamespaceTaskAttributes) GetInfo() *v13.NamespaceInfo

func (*NamespaceTaskAttributes) GetNamespaceOperation 

func (x *NamespaceTaskAttributes) GetNamespaceOperation() v1.NamespaceOperation

func (*NamespaceTaskAttributes) GetReplicationConfig 

func (x *NamespaceTaskAttributes) GetReplicationConfig() *v14.NamespaceReplicationConfig

func (*NamespaceTaskAttributes) Marshal 

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

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

func (*NamespaceTaskAttributes) ProtoMessage 

func (*NamespaceTaskAttributes) ProtoMessage()

func (*NamespaceTaskAttributes) ProtoReflect 

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

func (*NamespaceTaskAttributes) Reset 

func (x *NamespaceTaskAttributes) Reset()

func (*NamespaceTaskAttributes) Size 

func (val *NamespaceTaskAttributes) Size() int

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

func (*NamespaceTaskAttributes) String 

func (x *NamespaceTaskAttributes) String() string

func (*NamespaceTaskAttributes) Unmarshal 

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

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

type NewRunInfo 

type NewRunInfo struct {
	RunId      string        `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	EventBatch *v11.DataBlob `protobuf:"bytes,2,opt,name=event_batch,json=eventBatch,proto3" json:"event_batch,omitempty"`
	// contains filtered or unexported fields
}

func (*NewRunInfo) Descriptor deprecated 

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

Deprecated: Use NewRunInfo.ProtoReflect.Descriptor instead.

func (*NewRunInfo) Equal 

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

Equal returns whether two NewRunInfo 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 (*NewRunInfo) GetEventBatch 

func (x *NewRunInfo) GetEventBatch() *v11.DataBlob

func (*NewRunInfo) GetRunId 

func (x *NewRunInfo) GetRunId() string

func (*NewRunInfo) Marshal 

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

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

func (*NewRunInfo) ProtoMessage 

func (*NewRunInfo) ProtoMessage()

func (*NewRunInfo) ProtoReflect 

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

func (*NewRunInfo) Reset 

func (x *NewRunInfo) Reset()

func (*NewRunInfo) Size 

func (val *NewRunInfo) Size() int

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

func (*NewRunInfo) String 

func (x *NewRunInfo) String() string

func (*NewRunInfo) Unmarshal 

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

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

type ReplicationMessages 

type ReplicationMessages struct {
	ReplicationTasks []*ReplicationTask `protobuf:"bytes,1,rep,name=replication_tasks,json=replicationTasks,proto3" json:"replication_tasks,omitempty"`
	// This can be different than the last taskId in the above list, because sender can decide to skip tasks (e.g. for completed workflows).
	LastRetrievedMessageId int64 `` /* 132-byte string literal not displayed */
	// Hint for flow control.
	HasMore         bool             `protobuf:"varint,3,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	SyncShardStatus *SyncShardStatus `protobuf:"bytes,4,opt,name=sync_shard_status,json=syncShardStatus,proto3" json:"sync_shard_status,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationMessages) Descriptor deprecated 

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

Deprecated: Use ReplicationMessages.ProtoReflect.Descriptor instead.

func (*ReplicationMessages) Equal 

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

Equal returns whether two ReplicationMessages 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 (*ReplicationMessages) GetHasMore 

func (x *ReplicationMessages) GetHasMore() bool

func (*ReplicationMessages) GetLastRetrievedMessageId 

func (x *ReplicationMessages) GetLastRetrievedMessageId() int64

func (*ReplicationMessages) GetReplicationTasks 

func (x *ReplicationMessages) GetReplicationTasks() []*ReplicationTask

func (*ReplicationMessages) GetSyncShardStatus 

func (x *ReplicationMessages) GetSyncShardStatus() *SyncShardStatus

func (*ReplicationMessages) Marshal 

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

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

func (*ReplicationMessages) ProtoMessage 

func (*ReplicationMessages) ProtoMessage()

func (*ReplicationMessages) ProtoReflect 

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

func (*ReplicationMessages) Reset 

func (x *ReplicationMessages) Reset()

func (*ReplicationMessages) Size 

func (val *ReplicationMessages) Size() int

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

func (*ReplicationMessages) String 

func (x *ReplicationMessages) String() string

func (*ReplicationMessages) Unmarshal 

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

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

type ReplicationState 

type ReplicationState struct {
	InclusiveLowWatermark     int64                            `` /* 127-byte string literal not displayed */
	InclusiveLowWatermarkTime *timestamppb.Timestamp           `` /* 140-byte string literal not displayed */
	FlowControlCommand        v1.ReplicationFlowControlCommand `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReplicationState) Descriptor deprecated 

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

Deprecated: Use ReplicationState.ProtoReflect.Descriptor instead.

func (*ReplicationState) Equal 

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

Equal returns whether two ReplicationState 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 (*ReplicationState) GetFlowControlCommand 

func (x *ReplicationState) GetFlowControlCommand() v1.ReplicationFlowControlCommand

func (*ReplicationState) GetInclusiveLowWatermark 

func (x *ReplicationState) GetInclusiveLowWatermark() int64

func (*ReplicationState) GetInclusiveLowWatermarkTime 

func (x *ReplicationState) GetInclusiveLowWatermarkTime() *timestamppb.Timestamp

func (*ReplicationState) Marshal 

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

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

func (*ReplicationState) ProtoMessage 

func (*ReplicationState) ProtoMessage()

func (*ReplicationState) ProtoReflect 

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

func (*ReplicationState) Reset 

func (x *ReplicationState) Reset()

func (*ReplicationState) Size 

func (val *ReplicationState) Size() int

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

func (*ReplicationState) String 

func (x *ReplicationState) String() string

func (*ReplicationState) Unmarshal 

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

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

type ReplicationTask 

type ReplicationTask struct {
	TaskType     v1.ReplicationTaskType `` /* 140-byte string literal not displayed */
	SourceTaskId int64                  `protobuf:"varint,2,opt,name=source_task_id,json=sourceTaskId,proto3" json:"source_task_id,omitempty"`
	// Types that are valid to be assigned to Attributes:
	//
	//	*ReplicationTask_NamespaceTaskAttributes
	//	*ReplicationTask_SyncShardStatusTaskAttributes
	//	*ReplicationTask_SyncActivityTaskAttributes
	//	*ReplicationTask_HistoryTaskAttributes
	//	*ReplicationTask_SyncWorkflowStateTaskAttributes
	//	*ReplicationTask_TaskQueueUserDataAttributes
	//	*ReplicationTask_SyncHsmAttributes
	//	*ReplicationTask_BackfillHistoryTaskAttributes
	//	*ReplicationTask_VerifyVersionedTransitionTaskAttributes
	//	*ReplicationTask_SyncVersionedTransitionTaskAttributes
	Attributes isReplicationTask_Attributes `protobuf_oneof:"attributes"`
	// All attributes should be deprecated and replaced by this field.
	// The task_type + data provide more flexibility in future use cases.
	Data                *v11.DataBlob            `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"`
	VisibilityTime      *timestamppb.Timestamp   `protobuf:"bytes,9,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
	Priority            v1.TaskPriority          `protobuf:"varint,13,opt,name=priority,proto3,enum=temporal.server.api.enums.v1.TaskPriority" json:"priority,omitempty"`
	VersionedTransition *v12.VersionedTransition `protobuf:"bytes,15,opt,name=versioned_transition,json=versionedTransition,proto3" json:"versioned_transition,omitempty"`
	RawTaskInfo         *v12.ReplicationTaskInfo `protobuf:"bytes,17,opt,name=raw_task_info,json=rawTaskInfo,proto3" json:"raw_task_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationTask) Descriptor deprecated 

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

Deprecated: Use ReplicationTask.ProtoReflect.Descriptor instead.

func (*ReplicationTask) Equal 

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

Equal returns whether two ReplicationTask 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 (*ReplicationTask) GetAttributes 

func (x *ReplicationTask) GetAttributes() isReplicationTask_Attributes

func (*ReplicationTask) GetBackfillHistoryTaskAttributes 

func (x *ReplicationTask) GetBackfillHistoryTaskAttributes() *BackfillHistoryTaskAttributes

func (*ReplicationTask) GetData 

func (x *ReplicationTask) GetData() *v11.DataBlob

func (*ReplicationTask) GetHistoryTaskAttributes 

func (x *ReplicationTask) GetHistoryTaskAttributes() *HistoryTaskAttributes

func (*ReplicationTask) GetNamespaceTaskAttributes 

func (x *ReplicationTask) GetNamespaceTaskAttributes() *NamespaceTaskAttributes

func (*ReplicationTask) GetPriority 

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

func (*ReplicationTask) GetRawTaskInfo 

func (x *ReplicationTask) GetRawTaskInfo() *v12.ReplicationTaskInfo

func (*ReplicationTask) GetSourceTaskId 

func (x *ReplicationTask) GetSourceTaskId() int64

func (*ReplicationTask) GetSyncActivityTaskAttributes 

func (x *ReplicationTask) GetSyncActivityTaskAttributes() *SyncActivityTaskAttributes

func (*ReplicationTask) GetSyncHsmAttributes 

func (x *ReplicationTask) GetSyncHsmAttributes() *SyncHSMAttributes

func (*ReplicationTask) GetSyncShardStatusTaskAttributes 

func (x *ReplicationTask) GetSyncShardStatusTaskAttributes() *SyncShardStatusTaskAttributes

func (*ReplicationTask) GetSyncVersionedTransitionTaskAttributes 

func (x *ReplicationTask) GetSyncVersionedTransitionTaskAttributes() *SyncVersionedTransitionTaskAttributes

func (*ReplicationTask) GetSyncWorkflowStateTaskAttributes 

func (x *ReplicationTask) GetSyncWorkflowStateTaskAttributes() *SyncWorkflowStateTaskAttributes

func (*ReplicationTask) GetTaskQueueUserDataAttributes 

func (x *ReplicationTask) GetTaskQueueUserDataAttributes() *TaskQueueUserDataAttributes

func (*ReplicationTask) GetTaskType 

func (x *ReplicationTask) GetTaskType() v1.ReplicationTaskType

func (*ReplicationTask) GetVerifyVersionedTransitionTaskAttributes 

func (x *ReplicationTask) GetVerifyVersionedTransitionTaskAttributes() *VerifyVersionedTransitionTaskAttributes

func (*ReplicationTask) GetVersionedTransition 

func (x *ReplicationTask) GetVersionedTransition() *v12.VersionedTransition

func (*ReplicationTask) GetVisibilityTime 

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

func (*ReplicationTask) Marshal 

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

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

func (*ReplicationTask) ProtoMessage 

func (*ReplicationTask) ProtoMessage()

func (*ReplicationTask) ProtoReflect 

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

func (*ReplicationTask) Reset 

func (x *ReplicationTask) Reset()

func (*ReplicationTask) Size 

func (val *ReplicationTask) Size() int

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

func (*ReplicationTask) String 

func (x *ReplicationTask) String() string

func (*ReplicationTask) Unmarshal 

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

Unmarshal an object of type ReplicationTask 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 */
	TaskId           int64           `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Version          int64           `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	FirstEventId     int64           `protobuf:"varint,7,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"`
	NextEventId      int64           `protobuf:"varint,8,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	ScheduledEventId int64           `protobuf:"varint,9,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	Priority         v1.TaskPriority `protobuf:"varint,10,opt,name=priority,proto3,enum=temporal.server.api.enums.v1.TaskPriority" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

TODO: Deprecate this definition, it only used by the deprecated replication DLQ v1 logic

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) GetFirstEventId 

func (x *ReplicationTaskInfo) GetFirstEventId() int64

func (*ReplicationTaskInfo) GetNamespaceId 

func (x *ReplicationTaskInfo) GetNamespaceId() string

func (*ReplicationTaskInfo) GetNextEventId 

func (x *ReplicationTaskInfo) GetNextEventId() int64

func (*ReplicationTaskInfo) GetPriority 

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

func (*ReplicationTaskInfo) GetRunId 

func (x *ReplicationTaskInfo) GetRunId() string

func (*ReplicationTaskInfo) GetScheduledEventId 

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) 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 

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 ReplicationTask_BackfillHistoryTaskAttributes 

type ReplicationTask_BackfillHistoryTaskAttributes struct {
	BackfillHistoryTaskAttributes *BackfillHistoryTaskAttributes `protobuf:"bytes,16,opt,name=backfill_history_task_attributes,json=backfillHistoryTaskAttributes,proto3,oneof"`
}

type ReplicationTask_HistoryTaskAttributes 

type ReplicationTask_HistoryTaskAttributes struct {
	HistoryTaskAttributes *HistoryTaskAttributes `protobuf:"bytes,8,opt,name=history_task_attributes,json=historyTaskAttributes,proto3,oneof"`
}

type ReplicationTask_NamespaceTaskAttributes 

type ReplicationTask_NamespaceTaskAttributes struct {
	NamespaceTaskAttributes *NamespaceTaskAttributes `protobuf:"bytes,3,opt,name=namespace_task_attributes,json=namespaceTaskAttributes,proto3,oneof"`
}

type ReplicationTask_SyncActivityTaskAttributes 

type ReplicationTask_SyncActivityTaskAttributes struct {
	SyncActivityTaskAttributes *SyncActivityTaskAttributes `protobuf:"bytes,6,opt,name=sync_activity_task_attributes,json=syncActivityTaskAttributes,proto3,oneof"`
}

type ReplicationTask_SyncHsmAttributes 

type ReplicationTask_SyncHsmAttributes struct {
	SyncHsmAttributes *SyncHSMAttributes `protobuf:"bytes,14,opt,name=sync_hsm_attributes,json=syncHsmAttributes,proto3,oneof"`
}

type ReplicationTask_SyncShardStatusTaskAttributes 

type ReplicationTask_SyncShardStatusTaskAttributes struct {
	SyncShardStatusTaskAttributes *SyncShardStatusTaskAttributes `protobuf:"bytes,5,opt,name=sync_shard_status_task_attributes,json=syncShardStatusTaskAttributes,proto3,oneof"`
}

type ReplicationTask_SyncVersionedTransitionTaskAttributes 

type ReplicationTask_SyncVersionedTransitionTaskAttributes struct {
	SyncVersionedTransitionTaskAttributes *SyncVersionedTransitionTaskAttributes `` /* 126-byte string literal not displayed */
}

type ReplicationTask_SyncWorkflowStateTaskAttributes 

type ReplicationTask_SyncWorkflowStateTaskAttributes struct {
	SyncWorkflowStateTaskAttributes *SyncWorkflowStateTaskAttributes `protobuf:"bytes,10,opt,name=sync_workflow_state_task_attributes,json=syncWorkflowStateTaskAttributes,proto3,oneof"`
}

type ReplicationTask_TaskQueueUserDataAttributes 

type ReplicationTask_TaskQueueUserDataAttributes struct {
	TaskQueueUserDataAttributes *TaskQueueUserDataAttributes `protobuf:"bytes,11,opt,name=task_queue_user_data_attributes,json=taskQueueUserDataAttributes,proto3,oneof"`
}

type ReplicationTask_VerifyVersionedTransitionTaskAttributes 

type ReplicationTask_VerifyVersionedTransitionTaskAttributes struct {
	VerifyVersionedTransitionTaskAttributes *VerifyVersionedTransitionTaskAttributes `` /* 130-byte string literal not displayed */
}

type ReplicationToken 

type ReplicationToken struct {
	ShardId int32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// lastRetrievedMessageId is where the next fetch should begin with.
	LastRetrievedMessageId int64 `` /* 132-byte string literal not displayed */
	// lastProcessedMessageId is the last messageId that is processed on the passive side.
	// This can be different than lastRetrievedMessageId if passive side supports prefetching messages.
	LastProcessedMessageId int64 `` /* 132-byte string literal not displayed */
	// The VisibilityTime of last processed ReplicationTask
	LastProcessedVisibilityTime *timestamppb.Timestamp `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReplicationToken) Descriptor deprecated 

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

Deprecated: Use ReplicationToken.ProtoReflect.Descriptor instead.

func (*ReplicationToken) Equal 

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

Equal returns whether two ReplicationToken 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 (*ReplicationToken) GetLastProcessedMessageId 

func (x *ReplicationToken) GetLastProcessedMessageId() int64

func (*ReplicationToken) GetLastProcessedVisibilityTime 

func (x *ReplicationToken) GetLastProcessedVisibilityTime() *timestamppb.Timestamp

func (*ReplicationToken) GetLastRetrievedMessageId 

func (x *ReplicationToken) GetLastRetrievedMessageId() int64

func (*ReplicationToken) GetShardId 

func (x *ReplicationToken) GetShardId() int32

func (*ReplicationToken) Marshal 

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

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

func (*ReplicationToken) ProtoMessage 

func (*ReplicationToken) ProtoMessage()

func (*ReplicationToken) ProtoReflect 

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

func (*ReplicationToken) Reset 

func (x *ReplicationToken) Reset()

func (*ReplicationToken) Size 

func (val *ReplicationToken) Size() int

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

func (*ReplicationToken) String 

func (x *ReplicationToken) String() string

func (*ReplicationToken) Unmarshal 

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

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

type SyncActivityTaskAttributes 

type SyncActivityTaskAttributes 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"`
	Version            int64                  `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	ScheduledEventId   int64                  `protobuf:"varint,5,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	ScheduledTime      *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	StartedEventId     int64                  `protobuf:"varint,7,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
	StartedTime        *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`
	LastHeartbeatTime  *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3" json:"last_heartbeat_time,omitempty"`
	Details            *v11.Payloads          `protobuf:"bytes,10,opt,name=details,proto3" json:"details,omitempty"`
	Attempt            int32                  `protobuf:"varint,11,opt,name=attempt,proto3" json:"attempt,omitempty"`
	LastFailure        *v15.Failure           `protobuf:"bytes,12,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
	LastWorkerIdentity string                 `protobuf:"bytes,13,opt,name=last_worker_identity,json=lastWorkerIdentity,proto3" json:"last_worker_identity,omitempty"`
	VersionHistory     *v16.VersionHistory    `protobuf:"bytes,14,opt,name=version_history,json=versionHistory,proto3" json:"version_history,omitempty"`
	BaseExecutionInfo  *v17.BaseExecutionInfo `protobuf:"bytes,15,opt,name=base_execution_info,json=baseExecutionInfo,proto3" json:"base_execution_info,omitempty"`
	// build ID of the worker who received this activity last time
	LastStartedBuildId string `protobuf:"bytes,16,opt,name=last_started_build_id,json=lastStartedBuildId,proto3" json:"last_started_build_id,omitempty"`
	// workflows redirect_counter value when this activity started last time
	LastStartedRedirectCounter int64 `` /* 145-byte string literal not displayed */
	// The first time the activity was scheduled.
	FirstScheduledTime *timestamppb.Timestamp `protobuf:"bytes,18,opt,name=first_scheduled_time,json=firstScheduledTime,proto3" json:"first_scheduled_time,omitempty"`
	// The last time an activity attempt completion was recorded by the server.
	LastAttemptCompleteTime *timestamppb.Timestamp `` /* 135-byte string literal not displayed */
	// Stamp represents the internal “version” of the activity options and can/will be changed with Activity API.
	// It monotonically increments when the activity options are changed.
	Stamp int32 `protobuf:"varint,20,opt,name=stamp,proto3" json:"stamp,omitempty"`
	// Flag indicating whether the activity is currently paused.
	Paused bool `protobuf:"varint,21,opt,name=paused,proto3" json:"paused,omitempty"`
	// Retry policy for the activity. It needs to be replicated now, since the activity properties can be updated.
	RetryInitialInterval    *durationpb.Duration `protobuf:"bytes,22,opt,name=retry_initial_interval,json=retryInitialInterval,proto3" json:"retry_initial_interval,omitempty"`
	RetryMaximumInterval    *durationpb.Duration `protobuf:"bytes,23,opt,name=retry_maximum_interval,json=retryMaximumInterval,proto3" json:"retry_maximum_interval,omitempty"`
	RetryMaximumAttempts    int32                `protobuf:"varint,24,opt,name=retry_maximum_attempts,json=retryMaximumAttempts,proto3" json:"retry_maximum_attempts,omitempty"`
	RetryBackoffCoefficient float64              `` /* 135-byte string literal not displayed */
	StartVersion            int64                `protobuf:"varint,26,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncActivityTaskAttributes) Descriptor deprecated 

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

Deprecated: Use SyncActivityTaskAttributes.ProtoReflect.Descriptor instead.

func (*SyncActivityTaskAttributes) Equal 

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

Equal returns whether two SyncActivityTaskAttributes 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 (*SyncActivityTaskAttributes) GetAttempt 

func (x *SyncActivityTaskAttributes) GetAttempt() int32

func (*SyncActivityTaskAttributes) GetBaseExecutionInfo 

func (x *SyncActivityTaskAttributes) GetBaseExecutionInfo() *v17.BaseExecutionInfo

func (*SyncActivityTaskAttributes) GetDetails 

func (x *SyncActivityTaskAttributes) GetDetails() *v11.Payloads

func (*SyncActivityTaskAttributes) GetFirstScheduledTime 

func (x *SyncActivityTaskAttributes) GetFirstScheduledTime() *timestamppb.Timestamp

func (*SyncActivityTaskAttributes) GetLastAttemptCompleteTime 

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

func (*SyncActivityTaskAttributes) GetLastFailure 

func (x *SyncActivityTaskAttributes) GetLastFailure() *v15.Failure

func (*SyncActivityTaskAttributes) GetLastHeartbeatTime 

func (x *SyncActivityTaskAttributes) GetLastHeartbeatTime() *timestamppb.Timestamp

func (*SyncActivityTaskAttributes) GetLastStartedBuildId 

func (x *SyncActivityTaskAttributes) GetLastStartedBuildId() string

func (*SyncActivityTaskAttributes) GetLastStartedRedirectCounter 

func (x *SyncActivityTaskAttributes) GetLastStartedRedirectCounter() int64

func (*SyncActivityTaskAttributes) GetLastWorkerIdentity 

func (x *SyncActivityTaskAttributes) GetLastWorkerIdentity() string

func (*SyncActivityTaskAttributes) GetNamespaceId 

func (x *SyncActivityTaskAttributes) GetNamespaceId() string

func (*SyncActivityTaskAttributes) GetPaused 

func (x *SyncActivityTaskAttributes) GetPaused() bool

func (*SyncActivityTaskAttributes) GetRetryBackoffCoefficient 

func (x *SyncActivityTaskAttributes) GetRetryBackoffCoefficient() float64

func (*SyncActivityTaskAttributes) GetRetryInitialInterval 

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

func (*SyncActivityTaskAttributes) GetRetryMaximumAttempts 

func (x *SyncActivityTaskAttributes) GetRetryMaximumAttempts() int32

func (*SyncActivityTaskAttributes) GetRetryMaximumInterval 

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

func (*SyncActivityTaskAttributes) GetRunId 

func (x *SyncActivityTaskAttributes) GetRunId() string

func (*SyncActivityTaskAttributes) GetScheduledEventId 

func (x *SyncActivityTaskAttributes) GetScheduledEventId() int64

func (*SyncActivityTaskAttributes) GetScheduledTime 

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

func (*SyncActivityTaskAttributes) GetStamp 

func (x *SyncActivityTaskAttributes) GetStamp() int32

func (*SyncActivityTaskAttributes) GetStartVersion 

func (x *SyncActivityTaskAttributes) GetStartVersion() int64

func (*SyncActivityTaskAttributes) GetStartedEventId 

func (x *SyncActivityTaskAttributes) GetStartedEventId() int64

func (*SyncActivityTaskAttributes) GetStartedTime 

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

func (*SyncActivityTaskAttributes) GetVersion 

func (x *SyncActivityTaskAttributes) GetVersion() int64

func (*SyncActivityTaskAttributes) GetVersionHistory 

func (x *SyncActivityTaskAttributes) GetVersionHistory() *v16.VersionHistory

func (*SyncActivityTaskAttributes) GetWorkflowId 

func (x *SyncActivityTaskAttributes) GetWorkflowId() string

func (*SyncActivityTaskAttributes) Marshal 

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

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

func (*SyncActivityTaskAttributes) ProtoMessage 

func (*SyncActivityTaskAttributes) ProtoMessage()

func (*SyncActivityTaskAttributes) ProtoReflect 

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

func (*SyncActivityTaskAttributes) Reset 

func (x *SyncActivityTaskAttributes) Reset()

func (*SyncActivityTaskAttributes) Size 

func (val *SyncActivityTaskAttributes) Size() int

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

func (*SyncActivityTaskAttributes) String 

func (x *SyncActivityTaskAttributes) String() string

func (*SyncActivityTaskAttributes) Unmarshal 

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

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

type SyncHSMAttributes 

type SyncHSMAttributes 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"`
	VersionHistory   *v16.VersionHistory   `protobuf:"bytes,4,opt,name=version_history,json=versionHistory,proto3" json:"version_history,omitempty"`
	StateMachineNode *v12.StateMachineNode `protobuf:"bytes,5,opt,name=state_machine_node,json=stateMachineNode,proto3" json:"state_machine_node,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncHSMAttributes) Descriptor deprecated 

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

Deprecated: Use SyncHSMAttributes.ProtoReflect.Descriptor instead.

func (*SyncHSMAttributes) Equal 

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

Equal returns whether two SyncHSMAttributes 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 (*SyncHSMAttributes) GetNamespaceId 

func (x *SyncHSMAttributes) GetNamespaceId() string

func (*SyncHSMAttributes) GetRunId 

func (x *SyncHSMAttributes) GetRunId() string

func (*SyncHSMAttributes) GetStateMachineNode 

func (x *SyncHSMAttributes) GetStateMachineNode() *v12.StateMachineNode

func (*SyncHSMAttributes) GetVersionHistory 

func (x *SyncHSMAttributes) GetVersionHistory() *v16.VersionHistory

func (*SyncHSMAttributes) GetWorkflowId 

func (x *SyncHSMAttributes) GetWorkflowId() string

func (*SyncHSMAttributes) Marshal 

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

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

func (*SyncHSMAttributes) ProtoMessage 

func (*SyncHSMAttributes) ProtoMessage()

func (*SyncHSMAttributes) ProtoReflect 

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

func (*SyncHSMAttributes) Reset 

func (x *SyncHSMAttributes) Reset()

func (*SyncHSMAttributes) Size 

func (val *SyncHSMAttributes) Size() int

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

func (*SyncHSMAttributes) String 

func (x *SyncHSMAttributes) String() string

func (*SyncHSMAttributes) Unmarshal 

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

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

type SyncReplicationState 

type SyncReplicationState struct {

	// deprecated in favor of using ReplicationState object
	InclusiveLowWatermark int64 `` /* 127-byte string literal not displayed */
	// deprecated in favor of using ReplicationState object
	InclusiveLowWatermarkTime *timestamppb.Timestamp `` /* 140-byte string literal not displayed */
	HighPriorityState         *ReplicationState      `protobuf:"bytes,3,opt,name=high_priority_state,json=highPriorityState,proto3" json:"high_priority_state,omitempty"`
	LowPriorityState          *ReplicationState      `protobuf:"bytes,4,opt,name=low_priority_state,json=lowPriorityState,proto3" json:"low_priority_state,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncReplicationState) Descriptor deprecated 

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

Deprecated: Use SyncReplicationState.ProtoReflect.Descriptor instead.

func (*SyncReplicationState) Equal 

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

Equal returns whether two SyncReplicationState 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 (*SyncReplicationState) GetHighPriorityState 

func (x *SyncReplicationState) GetHighPriorityState() *ReplicationState

func (*SyncReplicationState) GetInclusiveLowWatermark 

func (x *SyncReplicationState) GetInclusiveLowWatermark() int64

func (*SyncReplicationState) GetInclusiveLowWatermarkTime 

func (x *SyncReplicationState) GetInclusiveLowWatermarkTime() *timestamppb.Timestamp

func (*SyncReplicationState) GetLowPriorityState 

func (x *SyncReplicationState) GetLowPriorityState() *ReplicationState

func (*SyncReplicationState) Marshal 

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

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

func (*SyncReplicationState) ProtoMessage 

func (*SyncReplicationState) ProtoMessage()

func (*SyncReplicationState) ProtoReflect 

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

func (*SyncReplicationState) Reset 

func (x *SyncReplicationState) Reset()

func (*SyncReplicationState) Size 

func (val *SyncReplicationState) Size() int

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

func (*SyncReplicationState) String 

func (x *SyncReplicationState) String() string

func (*SyncReplicationState) Unmarshal 

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

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

type SyncShardStatus 

type SyncShardStatus struct {
	StatusTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=status_time,json=statusTime,proto3" json:"status_time,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncShardStatus) Descriptor deprecated 

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

Deprecated: Use SyncShardStatus.ProtoReflect.Descriptor instead.

func (*SyncShardStatus) Equal 

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

Equal returns whether two SyncShardStatus 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 (*SyncShardStatus) GetStatusTime 

func (x *SyncShardStatus) GetStatusTime() *timestamppb.Timestamp

func (*SyncShardStatus) Marshal 

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

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

func (*SyncShardStatus) ProtoMessage 

func (*SyncShardStatus) ProtoMessage()

func (*SyncShardStatus) ProtoReflect 

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

func (*SyncShardStatus) Reset 

func (x *SyncShardStatus) Reset()

func (*SyncShardStatus) Size 

func (val *SyncShardStatus) Size() int

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

func (*SyncShardStatus) String 

func (x *SyncShardStatus) String() string

func (*SyncShardStatus) Unmarshal 

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

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

type SyncShardStatusTaskAttributes 

type SyncShardStatusTaskAttributes struct {
	SourceCluster string                 `protobuf:"bytes,1,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	ShardId       int32                  `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	StatusTime    *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=status_time,json=statusTime,proto3" json:"status_time,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncShardStatusTaskAttributes) Descriptor deprecated 

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

Deprecated: Use SyncShardStatusTaskAttributes.ProtoReflect.Descriptor instead.

func (*SyncShardStatusTaskAttributes) Equal 

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

Equal returns whether two SyncShardStatusTaskAttributes 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 (*SyncShardStatusTaskAttributes) GetShardId 

func (x *SyncShardStatusTaskAttributes) GetShardId() int32

func (*SyncShardStatusTaskAttributes) GetSourceCluster 

func (x *SyncShardStatusTaskAttributes) GetSourceCluster() string

func (*SyncShardStatusTaskAttributes) GetStatusTime 

func (x *SyncShardStatusTaskAttributes) GetStatusTime() *timestamppb.Timestamp

func (*SyncShardStatusTaskAttributes) Marshal 

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

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

func (*SyncShardStatusTaskAttributes) ProtoMessage 

func (*SyncShardStatusTaskAttributes) ProtoMessage()

func (*SyncShardStatusTaskAttributes) ProtoReflect 

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

func (*SyncShardStatusTaskAttributes) Reset 

func (x *SyncShardStatusTaskAttributes) Reset()

func (*SyncShardStatusTaskAttributes) Size 

func (val *SyncShardStatusTaskAttributes) Size() int

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

func (*SyncShardStatusTaskAttributes) String 

func (x *SyncShardStatusTaskAttributes) String() string

func (*SyncShardStatusTaskAttributes) Unmarshal 

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

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

type SyncVersionedTransitionTaskAttributes 

type SyncVersionedTransitionTaskAttributes struct {
	VersionedTransitionArtifact *VersionedTransitionArtifact `` /* 144-byte string literal not displayed */
	NamespaceId                 string                       `protobuf:"bytes,6,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId                  string                       `protobuf:"bytes,7,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId                       string                       `protobuf:"bytes,8,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// (-- api-linter: core::0141::forbidden-types=disabled --)
	ArchetypeId uint32 `protobuf:"varint,9,opt,name=archetype_id,json=archetypeId,proto3" json:"archetype_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncVersionedTransitionTaskAttributes) Descriptor deprecated 

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

Deprecated: Use SyncVersionedTransitionTaskAttributes.ProtoReflect.Descriptor instead.

func (*SyncVersionedTransitionTaskAttributes) Equal 

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

Equal returns whether two SyncVersionedTransitionTaskAttributes 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 (*SyncVersionedTransitionTaskAttributes) GetArchetypeId 

func (x *SyncVersionedTransitionTaskAttributes) GetArchetypeId() uint32

func (*SyncVersionedTransitionTaskAttributes) GetNamespaceId 

func (x *SyncVersionedTransitionTaskAttributes) GetNamespaceId() string

func (*SyncVersionedTransitionTaskAttributes) GetRunId 

func (x *SyncVersionedTransitionTaskAttributes) GetRunId() string

func (*SyncVersionedTransitionTaskAttributes) GetVersionedTransitionArtifact 

func (x *SyncVersionedTransitionTaskAttributes) GetVersionedTransitionArtifact() *VersionedTransitionArtifact

func (*SyncVersionedTransitionTaskAttributes) GetWorkflowId 

func (x *SyncVersionedTransitionTaskAttributes) GetWorkflowId() string

func (*SyncVersionedTransitionTaskAttributes) Marshal 

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

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

func (*SyncVersionedTransitionTaskAttributes) ProtoMessage 

func (*SyncVersionedTransitionTaskAttributes) ProtoMessage()

func (*SyncVersionedTransitionTaskAttributes) ProtoReflect 

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

func (*SyncVersionedTransitionTaskAttributes) Reset 

func (x *SyncVersionedTransitionTaskAttributes) Reset()

func (*SyncVersionedTransitionTaskAttributes) Size 

func (val *SyncVersionedTransitionTaskAttributes) Size() int

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

func (*SyncVersionedTransitionTaskAttributes) String 

func (x *SyncVersionedTransitionTaskAttributes) String() string

func (*SyncVersionedTransitionTaskAttributes) Unmarshal 

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

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

type SyncWorkflowStateMutationAttributes 

type SyncWorkflowStateMutationAttributes struct {
	ExclusiveStartVersionedTransition *v12.VersionedTransition          `` /* 164-byte string literal not displayed */
	StateMutation                     *v12.WorkflowMutableStateMutation `protobuf:"bytes,2,opt,name=state_mutation,json=stateMutation,proto3" json:"state_mutation,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncWorkflowStateMutationAttributes) Descriptor deprecated 

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

Deprecated: Use SyncWorkflowStateMutationAttributes.ProtoReflect.Descriptor instead.

func (*SyncWorkflowStateMutationAttributes) Equal 

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

Equal returns whether two SyncWorkflowStateMutationAttributes 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 (*SyncWorkflowStateMutationAttributes) GetExclusiveStartVersionedTransition 

func (x *SyncWorkflowStateMutationAttributes) GetExclusiveStartVersionedTransition() *v12.VersionedTransition

func (*SyncWorkflowStateMutationAttributes) GetStateMutation 

func (x *SyncWorkflowStateMutationAttributes) GetStateMutation() *v12.WorkflowMutableStateMutation

func (*SyncWorkflowStateMutationAttributes) Marshal 

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

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

func (*SyncWorkflowStateMutationAttributes) ProtoMessage 

func (*SyncWorkflowStateMutationAttributes) ProtoMessage()

func (*SyncWorkflowStateMutationAttributes) ProtoReflect 

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

func (*SyncWorkflowStateMutationAttributes) Reset 

func (x *SyncWorkflowStateMutationAttributes) Reset()

func (*SyncWorkflowStateMutationAttributes) Size 

func (val *SyncWorkflowStateMutationAttributes) Size() int

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

func (*SyncWorkflowStateMutationAttributes) String 

func (x *SyncWorkflowStateMutationAttributes) String() string

func (*SyncWorkflowStateMutationAttributes) Unmarshal 

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

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

type SyncWorkflowStateSnapshotAttributes 

type SyncWorkflowStateSnapshotAttributes struct {
	State *v12.WorkflowMutableState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncWorkflowStateSnapshotAttributes) Descriptor deprecated 

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

Deprecated: Use SyncWorkflowStateSnapshotAttributes.ProtoReflect.Descriptor instead.

func (*SyncWorkflowStateSnapshotAttributes) Equal 

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

Equal returns whether two SyncWorkflowStateSnapshotAttributes 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 (*SyncWorkflowStateSnapshotAttributes) GetState 

func (x *SyncWorkflowStateSnapshotAttributes) GetState() *v12.WorkflowMutableState

func (*SyncWorkflowStateSnapshotAttributes) Marshal 

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

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

func (*SyncWorkflowStateSnapshotAttributes) ProtoMessage 

func (*SyncWorkflowStateSnapshotAttributes) ProtoMessage()

func (*SyncWorkflowStateSnapshotAttributes) ProtoReflect 

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

func (*SyncWorkflowStateSnapshotAttributes) Reset 

func (x *SyncWorkflowStateSnapshotAttributes) Reset()

func (*SyncWorkflowStateSnapshotAttributes) Size 

func (val *SyncWorkflowStateSnapshotAttributes) Size() int

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

func (*SyncWorkflowStateSnapshotAttributes) String 

func (x *SyncWorkflowStateSnapshotAttributes) String() string

func (*SyncWorkflowStateSnapshotAttributes) Unmarshal 

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

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

type SyncWorkflowStateTaskAttributes 

type SyncWorkflowStateTaskAttributes struct {
	WorkflowState            *v12.WorkflowMutableState `protobuf:"bytes,1,opt,name=workflow_state,json=workflowState,proto3" json:"workflow_state,omitempty"`
	IsForceReplication       bool                      `protobuf:"varint,2,opt,name=is_force_replication,json=isForceReplication,proto3" json:"is_force_replication,omitempty"`
	IsCloseTransferTaskAcked bool                      `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SyncWorkflowStateTaskAttributes) Descriptor deprecated 

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

Deprecated: Use SyncWorkflowStateTaskAttributes.ProtoReflect.Descriptor instead.

func (*SyncWorkflowStateTaskAttributes) Equal 

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

Equal returns whether two SyncWorkflowStateTaskAttributes 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 (*SyncWorkflowStateTaskAttributes) GetIsCloseTransferTaskAcked 

func (x *SyncWorkflowStateTaskAttributes) GetIsCloseTransferTaskAcked() bool

func (*SyncWorkflowStateTaskAttributes) GetIsForceReplication 

func (x *SyncWorkflowStateTaskAttributes) GetIsForceReplication() bool

func (*SyncWorkflowStateTaskAttributes) GetWorkflowState 

func (x *SyncWorkflowStateTaskAttributes) GetWorkflowState() *v12.WorkflowMutableState

func (*SyncWorkflowStateTaskAttributes) Marshal 

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

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

func (*SyncWorkflowStateTaskAttributes) ProtoMessage 

func (*SyncWorkflowStateTaskAttributes) ProtoMessage()

func (*SyncWorkflowStateTaskAttributes) ProtoReflect 

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

func (*SyncWorkflowStateTaskAttributes) Reset 

func (x *SyncWorkflowStateTaskAttributes) Reset()

func (*SyncWorkflowStateTaskAttributes) Size 

func (val *SyncWorkflowStateTaskAttributes) Size() int

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

func (*SyncWorkflowStateTaskAttributes) String 

func (x *SyncWorkflowStateTaskAttributes) String() string

func (*SyncWorkflowStateTaskAttributes) Unmarshal 

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

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

type TaskQueueUserDataAttributes 

type TaskQueueUserDataAttributes struct {
	NamespaceId   string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueueName string                 `protobuf:"bytes,2,opt,name=task_queue_name,json=taskQueueName,proto3" json:"task_queue_name,omitempty"`
	UserData      *v12.TaskQueueUserData `protobuf:"bytes,3,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueUserDataAttributes) Descriptor deprecated 

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

Deprecated: Use TaskQueueUserDataAttributes.ProtoReflect.Descriptor instead.

func (*TaskQueueUserDataAttributes) Equal 

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

Equal returns whether two TaskQueueUserDataAttributes 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 (*TaskQueueUserDataAttributes) GetNamespaceId 

func (x *TaskQueueUserDataAttributes) GetNamespaceId() string

func (*TaskQueueUserDataAttributes) GetTaskQueueName 

func (x *TaskQueueUserDataAttributes) GetTaskQueueName() string

func (*TaskQueueUserDataAttributes) GetUserData 

func (x *TaskQueueUserDataAttributes) GetUserData() *v12.TaskQueueUserData

func (*TaskQueueUserDataAttributes) Marshal 

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

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

func (*TaskQueueUserDataAttributes) ProtoMessage 

func (*TaskQueueUserDataAttributes) ProtoMessage()

func (*TaskQueueUserDataAttributes) ProtoReflect 

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

func (*TaskQueueUserDataAttributes) Reset 

func (x *TaskQueueUserDataAttributes) Reset()

func (*TaskQueueUserDataAttributes) Size 

func (val *TaskQueueUserDataAttributes) Size() int

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

func (*TaskQueueUserDataAttributes) String 

func (x *TaskQueueUserDataAttributes) String() string

func (*TaskQueueUserDataAttributes) Unmarshal 

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

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

type VerifyVersionedTransitionTaskAttributes 

type VerifyVersionedTransitionTaskAttributes 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"`
	NextEventId         int64                     `protobuf:"varint,4,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	EventVersionHistory []*v16.VersionHistoryItem `protobuf:"bytes,5,rep,name=event_version_history,json=eventVersionHistory,proto3" json:"event_version_history,omitempty"`
	NewRunId            string                    `protobuf:"bytes,6,opt,name=new_run_id,json=newRunId,proto3" json:"new_run_id,omitempty"`
	// (-- api-linter: core::0141::forbidden-types=disabled --)
	ArchetypeId uint32 `protobuf:"varint,7,opt,name=archetype_id,json=archetypeId,proto3" json:"archetype_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyVersionedTransitionTaskAttributes) Descriptor deprecated 

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

Deprecated: Use VerifyVersionedTransitionTaskAttributes.ProtoReflect.Descriptor instead.

func (*VerifyVersionedTransitionTaskAttributes) Equal 

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

Equal returns whether two VerifyVersionedTransitionTaskAttributes 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 (*VerifyVersionedTransitionTaskAttributes) GetArchetypeId 

func (x *VerifyVersionedTransitionTaskAttributes) GetArchetypeId() uint32

func (*VerifyVersionedTransitionTaskAttributes) GetEventVersionHistory 

func (x *VerifyVersionedTransitionTaskAttributes) GetEventVersionHistory() []*v16.VersionHistoryItem

func (*VerifyVersionedTransitionTaskAttributes) GetNamespaceId 

func (x *VerifyVersionedTransitionTaskAttributes) GetNamespaceId() string

func (*VerifyVersionedTransitionTaskAttributes) GetNewRunId 

func (x *VerifyVersionedTransitionTaskAttributes) GetNewRunId() string

func (*VerifyVersionedTransitionTaskAttributes) GetNextEventId 

func (x *VerifyVersionedTransitionTaskAttributes) GetNextEventId() int64

func (*VerifyVersionedTransitionTaskAttributes) GetRunId 

func (x *VerifyVersionedTransitionTaskAttributes) GetRunId() string

func (*VerifyVersionedTransitionTaskAttributes) GetWorkflowId 

func (x *VerifyVersionedTransitionTaskAttributes) GetWorkflowId() string

func (*VerifyVersionedTransitionTaskAttributes) Marshal 

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

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

func (*VerifyVersionedTransitionTaskAttributes) ProtoMessage 

func (*VerifyVersionedTransitionTaskAttributes) ProtoMessage()

func (*VerifyVersionedTransitionTaskAttributes) ProtoReflect 

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

func (*VerifyVersionedTransitionTaskAttributes) Reset 

func (x *VerifyVersionedTransitionTaskAttributes) Reset()

func (*VerifyVersionedTransitionTaskAttributes) Size 

func (val *VerifyVersionedTransitionTaskAttributes) Size() int

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

func (*VerifyVersionedTransitionTaskAttributes) String 

func (x *VerifyVersionedTransitionTaskAttributes) String() string

func (*VerifyVersionedTransitionTaskAttributes) Unmarshal 

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

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

type VersionedTransitionArtifact 

type VersionedTransitionArtifact struct {

	// Types that are valid to be assigned to StateAttributes:
	//
	//	*VersionedTransitionArtifact_SyncWorkflowStateMutationAttributes
	//	*VersionedTransitionArtifact_SyncWorkflowStateSnapshotAttributes
	StateAttributes          isVersionedTransitionArtifact_StateAttributes `protobuf_oneof:"state_attributes"`
	EventBatches             []*v11.DataBlob                               `protobuf:"bytes,3,rep,name=event_batches,json=eventBatches,proto3" json:"event_batches,omitempty"`
	NewRunInfo               *NewRunInfo                                   `protobuf:"bytes,4,opt,name=new_run_info,json=newRunInfo,proto3" json:"new_run_info,omitempty"`
	IsFirstSync              bool                                          `protobuf:"varint,5,opt,name=is_first_sync,json=isFirstSync,proto3" json:"is_first_sync,omitempty"`
	IsCloseTransferTaskAcked bool                                          `` /* 140-byte string literal not displayed */
	IsForceReplication       bool                                          `protobuf:"varint,7,opt,name=is_force_replication,json=isForceReplication,proto3" json:"is_force_replication,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionedTransitionArtifact) Descriptor deprecated 

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

Deprecated: Use VersionedTransitionArtifact.ProtoReflect.Descriptor instead.

func (*VersionedTransitionArtifact) Equal 

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

Equal returns whether two VersionedTransitionArtifact 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 (*VersionedTransitionArtifact) GetEventBatches 

func (x *VersionedTransitionArtifact) GetEventBatches() []*v11.DataBlob

func (*VersionedTransitionArtifact) GetIsCloseTransferTaskAcked 

func (x *VersionedTransitionArtifact) GetIsCloseTransferTaskAcked() bool

func (*VersionedTransitionArtifact) GetIsFirstSync 

func (x *VersionedTransitionArtifact) GetIsFirstSync() bool

func (*VersionedTransitionArtifact) GetIsForceReplication 

func (x *VersionedTransitionArtifact) GetIsForceReplication() bool

func (*VersionedTransitionArtifact) GetNewRunInfo 

func (x *VersionedTransitionArtifact) GetNewRunInfo() *NewRunInfo

func (*VersionedTransitionArtifact) GetStateAttributes 

func (x *VersionedTransitionArtifact) GetStateAttributes() isVersionedTransitionArtifact_StateAttributes

func (*VersionedTransitionArtifact) GetSyncWorkflowStateMutationAttributes 

func (x *VersionedTransitionArtifact) GetSyncWorkflowStateMutationAttributes() *SyncWorkflowStateMutationAttributes

func (*VersionedTransitionArtifact) GetSyncWorkflowStateSnapshotAttributes 

func (x *VersionedTransitionArtifact) GetSyncWorkflowStateSnapshotAttributes() *SyncWorkflowStateSnapshotAttributes

func (*VersionedTransitionArtifact) Marshal 

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

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

func (*VersionedTransitionArtifact) ProtoMessage 

func (*VersionedTransitionArtifact) ProtoMessage()

func (*VersionedTransitionArtifact) ProtoReflect 

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

func (*VersionedTransitionArtifact) Reset 

func (x *VersionedTransitionArtifact) Reset()

func (*VersionedTransitionArtifact) Size 

func (val *VersionedTransitionArtifact) Size() int

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

func (*VersionedTransitionArtifact) String 

func (x *VersionedTransitionArtifact) String() string

func (*VersionedTransitionArtifact) Unmarshal 

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

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

type VersionedTransitionArtifact_SyncWorkflowStateMutationAttributes 

type VersionedTransitionArtifact_SyncWorkflowStateMutationAttributes struct {
	SyncWorkflowStateMutationAttributes *SyncWorkflowStateMutationAttributes `protobuf:"bytes,1,opt,name=sync_workflow_state_mutation_attributes,json=syncWorkflowStateMutationAttributes,proto3,oneof"`
}

type VersionedTransitionArtifact_SyncWorkflowStateSnapshotAttributes 

type VersionedTransitionArtifact_SyncWorkflowStateSnapshotAttributes struct {
	SyncWorkflowStateSnapshotAttributes *SyncWorkflowStateSnapshotAttributes `protobuf:"bytes,2,opt,name=sync_workflow_state_snapshot_attributes,json=syncWorkflowStateSnapshotAttributes,proto3,oneof"`
}

type WorkflowReplicationMessages 

type WorkflowReplicationMessages struct {
	ReplicationTasks []*ReplicationTask `protobuf:"bytes,1,rep,name=replication_tasks,json=replicationTasks,proto3" json:"replication_tasks,omitempty"`
	// This can be different than the last taskId in the above list, because sender can decide to skip tasks (e.g. for completed workflows).
	ExclusiveHighWatermark     int64                  `` /* 130-byte string literal not displayed */
	ExclusiveHighWatermarkTime *timestamppb.Timestamp `` /* 143-byte string literal not displayed */
	Priority                   v1.TaskPriority        `protobuf:"varint,4,opt,name=priority,proto3,enum=temporal.server.api.enums.v1.TaskPriority" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowReplicationMessages) Descriptor deprecated 

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

Deprecated: Use WorkflowReplicationMessages.ProtoReflect.Descriptor instead.

func (*WorkflowReplicationMessages) Equal 

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

Equal returns whether two WorkflowReplicationMessages 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 (*WorkflowReplicationMessages) GetExclusiveHighWatermark 

func (x *WorkflowReplicationMessages) GetExclusiveHighWatermark() int64

func (*WorkflowReplicationMessages) GetExclusiveHighWatermarkTime 

func (x *WorkflowReplicationMessages) GetExclusiveHighWatermarkTime() *timestamppb.Timestamp

func (*WorkflowReplicationMessages) GetPriority 

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

func (*WorkflowReplicationMessages) GetReplicationTasks 

func (x *WorkflowReplicationMessages) GetReplicationTasks() []*ReplicationTask

func (*WorkflowReplicationMessages) Marshal 

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

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

func (*WorkflowReplicationMessages) ProtoMessage 

func (*WorkflowReplicationMessages) ProtoMessage()

func (*WorkflowReplicationMessages) ProtoReflect 

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

func (*WorkflowReplicationMessages) Reset 

func (x *WorkflowReplicationMessages) Reset()

func (*WorkflowReplicationMessages) Size 

func (val *WorkflowReplicationMessages) Size() int

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

func (*WorkflowReplicationMessages) String 

func (x *WorkflowReplicationMessages) String() string

func (*WorkflowReplicationMessages) Unmarshal 

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

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

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.