repication

package
v1.23.1 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2024 License: MIT Imports: 14 Imported by: 2

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 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 []*v15.VersionHistoryItem `protobuf:"bytes,5,rep,name=version_history_items,json=versionHistoryItems,proto3" json:"version_history_items,omitempty"`
	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 *v16.BaseExecutionInfo `protobuf:"bytes,8,opt,name=base_execution_info,json=baseExecutionInfo,proto3" json:"base_execution_info,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 added in v1.21.0 

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

func (*HistoryTaskAttributes) GetEvents added in v1.17.0 

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

func (*HistoryTaskAttributes) GetNamespaceId 

func (x *HistoryTaskAttributes) GetNamespaceId() string

func (*HistoryTaskAttributes) GetNewRunEvents added in v1.17.0 

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

func (*HistoryTaskAttributes) GetRunId 

func (x *HistoryTaskAttributes) GetRunId() string

func (*HistoryTaskAttributes) GetVersionHistoryItems added in v1.17.0 

func (x *HistoryTaskAttributes) GetVersionHistoryItems() []*v15.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 added in v1.23.0 

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 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               *v12.NamespaceInfo              `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	Config             *v12.NamespaceConfig            `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	ReplicationConfig  *v13.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    []*v13.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() *v12.NamespaceConfig

func (*NamespaceTaskAttributes) GetConfigVersion 

func (x *NamespaceTaskAttributes) GetConfigVersion() int64

func (*NamespaceTaskAttributes) GetFailoverHistory added in v1.18.1 

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

func (*NamespaceTaskAttributes) GetFailoverVersion 

func (x *NamespaceTaskAttributes) GetFailoverVersion() int64

func (*NamespaceTaskAttributes) GetId 

func (x *NamespaceTaskAttributes) GetId() string

func (*NamespaceTaskAttributes) GetInfo 

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

func (*NamespaceTaskAttributes) GetNamespaceOperation 

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

func (*NamespaceTaskAttributes) GetReplicationConfig 

func (x *NamespaceTaskAttributes) GetReplicationConfig() *v13.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 added in v1.23.0 

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 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 added in v1.23.0 

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 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 assignable to Attributes:
	//
	//	*ReplicationTask_NamespaceTaskAttributes
	//	*ReplicationTask_SyncShardStatusTaskAttributes
	//	*ReplicationTask_SyncActivityTaskAttributes
	//	*ReplicationTask_HistoryTaskAttributes
	//	*ReplicationTask_SyncWorkflowStateTaskAttributes
	//	*ReplicationTask_TaskQueueUserDataAttributes
	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"`
	// 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 (m *ReplicationTask) GetAttributes() isReplicationTask_Attributes

func (*ReplicationTask) GetData added in v1.23.0 

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

func (*ReplicationTask) GetHistoryTaskAttributes 

func (x *ReplicationTask) GetHistoryTaskAttributes() *HistoryTaskAttributes

func (*ReplicationTask) GetNamespaceTaskAttributes 

func (x *ReplicationTask) GetNamespaceTaskAttributes() *NamespaceTaskAttributes

func (*ReplicationTask) GetSourceTaskId 

func (x *ReplicationTask) GetSourceTaskId() int64

func (*ReplicationTask) GetSyncActivityTaskAttributes 

func (x *ReplicationTask) GetSyncActivityTaskAttributes() *SyncActivityTaskAttributes

func (*ReplicationTask) GetSyncShardStatusTaskAttributes 

func (x *ReplicationTask) GetSyncShardStatusTaskAttributes() *SyncShardStatusTaskAttributes

func (*ReplicationTask) GetSyncWorkflowStateTaskAttributes added in v1.17.0 

func (x *ReplicationTask) GetSyncWorkflowStateTaskAttributes() *SyncWorkflowStateTaskAttributes

func (*ReplicationTask) GetTaskQueueUserDataAttributes added in v1.21.0 

func (x *ReplicationTask) GetTaskQueueUserDataAttributes() *TaskQueueUserDataAttributes

func (*ReplicationTask) GetTaskType 

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

func (*ReplicationTask) GetVisibilityTime added in v1.14.0 

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 added in v1.23.0 

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

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

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

type ReplicationTask_SyncWorkflowStateTaskAttributes added in v1.17.0 

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

type ReplicationTask_TaskQueueUserDataAttributes added in v1.21.0 

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

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 added in v1.14.0 

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 added in v1.23.0 

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        *v14.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     *v15.VersionHistory    `protobuf:"bytes,14,opt,name=version_history,json=versionHistory,proto3" json:"version_history,omitempty"`
	BaseExecutionInfo  *v16.BaseExecutionInfo `protobuf:"bytes,15,opt,name=base_execution_info,json=baseExecutionInfo,proto3" json:"base_execution_info,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 added in v1.21.0 

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

func (*SyncActivityTaskAttributes) GetDetails 

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

func (*SyncActivityTaskAttributes) GetLastFailure 

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

func (*SyncActivityTaskAttributes) GetLastHeartbeatTime 

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

func (*SyncActivityTaskAttributes) GetLastWorkerIdentity 

func (x *SyncActivityTaskAttributes) GetLastWorkerIdentity() string

func (*SyncActivityTaskAttributes) GetNamespaceId 

func (x *SyncActivityTaskAttributes) GetNamespaceId() string

func (*SyncActivityTaskAttributes) GetRunId 

func (x *SyncActivityTaskAttributes) GetRunId() string

func (*SyncActivityTaskAttributes) GetScheduledEventId added in v1.17.0 

func (x *SyncActivityTaskAttributes) GetScheduledEventId() int64

func (*SyncActivityTaskAttributes) GetScheduledTime 

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

func (*SyncActivityTaskAttributes) GetStartedEventId added in v1.17.0 

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() *v15.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 added in v1.23.0 

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 SyncReplicationState added in v1.21.0 

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

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

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

Deprecated: Use SyncReplicationState.ProtoReflect.Descriptor instead.

func (*SyncReplicationState) Equal added in v1.21.0 

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) GetInclusiveLowWatermark added in v1.21.0 

func (x *SyncReplicationState) GetInclusiveLowWatermark() int64

func (*SyncReplicationState) GetInclusiveLowWatermarkTime added in v1.21.0 

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

func (*SyncReplicationState) Marshal added in v1.21.0 

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

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

func (*SyncReplicationState) ProtoMessage added in v1.21.0 

func (*SyncReplicationState) ProtoMessage()

func (*SyncReplicationState) ProtoReflect added in v1.23.0 

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

func (*SyncReplicationState) Reset added in v1.21.0 

func (x *SyncReplicationState) Reset()

func (*SyncReplicationState) Size added in v1.21.0 

func (val *SyncReplicationState) Size() int

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

func (*SyncReplicationState) String added in v1.21.0 

func (x *SyncReplicationState) String() string

func (*SyncReplicationState) Unmarshal added in v1.21.0 

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

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 added in v1.23.0 

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

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 added in v1.23.0 

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 SyncWorkflowStateTaskAttributes added in v1.17.0 

type SyncWorkflowStateTaskAttributes struct {
	WorkflowState *v17.WorkflowMutableState `protobuf:"bytes,1,opt,name=workflow_state,json=workflowState,proto3" json:"workflow_state,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncWorkflowStateTaskAttributes) Descriptor deprecated added in v1.17.0 

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

Deprecated: Use SyncWorkflowStateTaskAttributes.ProtoReflect.Descriptor instead.

func (*SyncWorkflowStateTaskAttributes) Equal added in v1.17.0 

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) GetWorkflowState added in v1.17.0 

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

func (*SyncWorkflowStateTaskAttributes) Marshal added in v1.17.0 

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

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

func (*SyncWorkflowStateTaskAttributes) ProtoMessage added in v1.17.0 

func (*SyncWorkflowStateTaskAttributes) ProtoMessage()

func (*SyncWorkflowStateTaskAttributes) ProtoReflect added in v1.23.0 

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

func (*SyncWorkflowStateTaskAttributes) Reset added in v1.17.0 

func (x *SyncWorkflowStateTaskAttributes) Reset()

func (*SyncWorkflowStateTaskAttributes) Size added in v1.17.0 

func (val *SyncWorkflowStateTaskAttributes) Size() int

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

func (*SyncWorkflowStateTaskAttributes) String added in v1.17.0 

func (x *SyncWorkflowStateTaskAttributes) String() string

func (*SyncWorkflowStateTaskAttributes) Unmarshal added in v1.17.0 

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

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

type TaskQueueUserDataAttributes added in v1.21.0 

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      *v17.TaskQueueUserData `protobuf:"bytes,3,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use TaskQueueUserDataAttributes.ProtoReflect.Descriptor instead.

func (*TaskQueueUserDataAttributes) Equal added in v1.21.0 

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 added in v1.21.0 

func (x *TaskQueueUserDataAttributes) GetNamespaceId() string

func (*TaskQueueUserDataAttributes) GetTaskQueueName added in v1.21.0 

func (x *TaskQueueUserDataAttributes) GetTaskQueueName() string

func (*TaskQueueUserDataAttributes) GetUserData added in v1.21.0 

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

func (*TaskQueueUserDataAttributes) Marshal added in v1.21.0 

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

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

func (*TaskQueueUserDataAttributes) ProtoMessage added in v1.21.0 

func (*TaskQueueUserDataAttributes) ProtoMessage()

func (*TaskQueueUserDataAttributes) ProtoReflect added in v1.23.0 

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

func (*TaskQueueUserDataAttributes) Reset added in v1.21.0 

func (x *TaskQueueUserDataAttributes) Reset()

func (*TaskQueueUserDataAttributes) Size added in v1.21.0 

func (val *TaskQueueUserDataAttributes) Size() int

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

func (*TaskQueueUserDataAttributes) String added in v1.21.0 

func (x *TaskQueueUserDataAttributes) String() string

func (*TaskQueueUserDataAttributes) Unmarshal added in v1.21.0 

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

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

type WorkflowReplicationMessages added in v1.21.0 

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

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

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

Deprecated: Use WorkflowReplicationMessages.ProtoReflect.Descriptor instead.

func (*WorkflowReplicationMessages) Equal added in v1.21.0 

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 added in v1.21.0 

func (x *WorkflowReplicationMessages) GetExclusiveHighWatermark() int64

func (*WorkflowReplicationMessages) GetExclusiveHighWatermarkTime added in v1.21.0 

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

func (*WorkflowReplicationMessages) GetReplicationTasks added in v1.21.0 

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

func (*WorkflowReplicationMessages) Marshal added in v1.21.0 

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

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

func (*WorkflowReplicationMessages) ProtoMessage added in v1.21.0 

func (*WorkflowReplicationMessages) ProtoMessage()

func (*WorkflowReplicationMessages) ProtoReflect added in v1.23.0 

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

func (*WorkflowReplicationMessages) Reset added in v1.21.0 

func (x *WorkflowReplicationMessages) Reset()

func (*WorkflowReplicationMessages) Size added in v1.21.0 

func (val *WorkflowReplicationMessages) Size() int

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

func (*WorkflowReplicationMessages) String added in v1.21.0 

func (x *WorkflowReplicationMessages) String() string

func (*WorkflowReplicationMessages) Unmarshal added in v1.21.0 

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.