repication

package
v1.7.0 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2021 License: MIT Imports: 17 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type HistoryMetadataTaskAttributes 

type HistoryMetadataTaskAttributes struct {
	TargetClusters []string `protobuf:"bytes,1,rep,name=target_clusters,json=targetClusters,proto3" json:"target_clusters,omitempty"`
	NamespaceId    string   `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId     string   `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId          string   `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	FirstEventId   int64    `protobuf:"varint,5,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"`
	NextEventId    int64    `protobuf:"varint,6,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	Version        int64    `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
}

func (*HistoryMetadataTaskAttributes) Descriptor 

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

func (*HistoryMetadataTaskAttributes) Equal 

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

func (*HistoryMetadataTaskAttributes) GetFirstEventId 

func (m *HistoryMetadataTaskAttributes) GetFirstEventId() int64

func (*HistoryMetadataTaskAttributes) GetNamespaceId 

func (m *HistoryMetadataTaskAttributes) GetNamespaceId() string

func (*HistoryMetadataTaskAttributes) GetNextEventId 

func (m *HistoryMetadataTaskAttributes) GetNextEventId() int64

func (*HistoryMetadataTaskAttributes) GetRunId 

func (m *HistoryMetadataTaskAttributes) GetRunId() string

func (*HistoryMetadataTaskAttributes) GetTargetClusters 

func (m *HistoryMetadataTaskAttributes) GetTargetClusters() []string

func (*HistoryMetadataTaskAttributes) GetVersion 

func (m *HistoryMetadataTaskAttributes) GetVersion() int64

func (*HistoryMetadataTaskAttributes) GetWorkflowId 

func (m *HistoryMetadataTaskAttributes) GetWorkflowId() string

func (*HistoryMetadataTaskAttributes) GoString 

func (this *HistoryMetadataTaskAttributes) GoString() string

func (*HistoryMetadataTaskAttributes) Marshal 

func (m *HistoryMetadataTaskAttributes) Marshal() (dAtA []byte, err error)

func (*HistoryMetadataTaskAttributes) MarshalTo 

func (m *HistoryMetadataTaskAttributes) MarshalTo(dAtA []byte) (int, error)

func (*HistoryMetadataTaskAttributes) MarshalToSizedBuffer 

func (m *HistoryMetadataTaskAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HistoryMetadataTaskAttributes) ProtoMessage 

func (*HistoryMetadataTaskAttributes) ProtoMessage()

func (*HistoryMetadataTaskAttributes) Reset 

func (m *HistoryMetadataTaskAttributes) Reset()

func (*HistoryMetadataTaskAttributes) Size 

func (m *HistoryMetadataTaskAttributes) Size() (n int)

func (*HistoryMetadataTaskAttributes) String 

func (this *HistoryMetadataTaskAttributes) String() string

func (*HistoryMetadataTaskAttributes) Unmarshal 

func (m *HistoryMetadataTaskAttributes) Unmarshal(dAtA []byte) error

func (*HistoryMetadataTaskAttributes) XXX_DiscardUnknown 

func (m *HistoryMetadataTaskAttributes) XXX_DiscardUnknown()

func (*HistoryMetadataTaskAttributes) XXX_Marshal 

func (m *HistoryMetadataTaskAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistoryMetadataTaskAttributes) XXX_Merge 

func (m *HistoryMetadataTaskAttributes) XXX_Merge(src proto.Message)

func (*HistoryMetadataTaskAttributes) XXX_Size 

func (m *HistoryMetadataTaskAttributes) XXX_Size() int

func (*HistoryMetadataTaskAttributes) XXX_Unmarshal 

func (m *HistoryMetadataTaskAttributes) XXX_Unmarshal(b []byte) error

type HistoryTaskAttributes 

type HistoryTaskAttributes struct {
	TargetClusters []string     `protobuf:"bytes,1,rep,name=target_clusters,json=targetClusters,proto3" json:"target_clusters,omitempty"`
	NamespaceId    string       `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId     string       `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId          string       `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	FirstEventId   int64        `protobuf:"varint,5,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"`
	NextEventId    int64        `protobuf:"varint,6,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	Version        int64        `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
	History        *v13.History `protobuf:"bytes,9,opt,name=history,proto3" json:"history,omitempty"`
	NewRunHistory  *v13.History `protobuf:"bytes,10,opt,name=new_run_history,json=newRunHistory,proto3" json:"new_run_history,omitempty"`
}

func (*HistoryTaskAttributes) Descriptor 

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

func (*HistoryTaskAttributes) Equal 

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

func (*HistoryTaskAttributes) GetFirstEventId 

func (m *HistoryTaskAttributes) GetFirstEventId() int64

func (*HistoryTaskAttributes) GetHistory 

func (m *HistoryTaskAttributes) GetHistory() *v13.History

func (*HistoryTaskAttributes) GetNamespaceId 

func (m *HistoryTaskAttributes) GetNamespaceId() string

func (*HistoryTaskAttributes) GetNewRunHistory 

func (m *HistoryTaskAttributes) GetNewRunHistory() *v13.History

func (*HistoryTaskAttributes) GetNextEventId 

func (m *HistoryTaskAttributes) GetNextEventId() int64

func (*HistoryTaskAttributes) GetRunId 

func (m *HistoryTaskAttributes) GetRunId() string

func (*HistoryTaskAttributes) GetTargetClusters 

func (m *HistoryTaskAttributes) GetTargetClusters() []string

func (*HistoryTaskAttributes) GetVersion 

func (m *HistoryTaskAttributes) GetVersion() int64

func (*HistoryTaskAttributes) GetWorkflowId 

func (m *HistoryTaskAttributes) GetWorkflowId() string

func (*HistoryTaskAttributes) GoString 

func (this *HistoryTaskAttributes) GoString() string

func (*HistoryTaskAttributes) Marshal 

func (m *HistoryTaskAttributes) Marshal() (dAtA []byte, err error)

func (*HistoryTaskAttributes) MarshalTo 

func (m *HistoryTaskAttributes) MarshalTo(dAtA []byte) (int, error)

func (*HistoryTaskAttributes) MarshalToSizedBuffer 

func (m *HistoryTaskAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HistoryTaskAttributes) ProtoMessage 

func (*HistoryTaskAttributes) ProtoMessage()

func (*HistoryTaskAttributes) Reset 

func (m *HistoryTaskAttributes) Reset()

func (*HistoryTaskAttributes) Size 

func (m *HistoryTaskAttributes) Size() (n int)

func (*HistoryTaskAttributes) String 

func (this *HistoryTaskAttributes) String() string

func (*HistoryTaskAttributes) Unmarshal 

func (m *HistoryTaskAttributes) Unmarshal(dAtA []byte) error

func (*HistoryTaskAttributes) XXX_DiscardUnknown 

func (m *HistoryTaskAttributes) XXX_DiscardUnknown()

func (*HistoryTaskAttributes) XXX_Marshal 

func (m *HistoryTaskAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistoryTaskAttributes) XXX_Merge 

func (m *HistoryTaskAttributes) XXX_Merge(src proto.Message)

func (*HistoryTaskAttributes) XXX_Size 

func (m *HistoryTaskAttributes) XXX_Size() int

func (*HistoryTaskAttributes) XXX_Unmarshal 

func (m *HistoryTaskAttributes) XXX_Unmarshal(b []byte) error

type HistoryTaskV2Attributes 

type HistoryTaskV2Attributes struct {
	// TODO remove this task_id attribute once kafka deprecation is done
	TaskId              int64                     `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	NamespaceId         string                    `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId          string                    `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId               string                    `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	VersionHistoryItems []*v16.VersionHistoryItem `protobuf:"bytes,5,rep,name=version_history_items,json=versionHistoryItems,proto3" json:"version_history_items,omitempty"`
	Events              *v14.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 *v14.DataBlob `protobuf:"bytes,7,opt,name=new_run_events,json=newRunEvents,proto3" json:"new_run_events,omitempty"`
}

func (*HistoryTaskV2Attributes) Descriptor 

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

func (*HistoryTaskV2Attributes) Equal 

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

func (*HistoryTaskV2Attributes) GetEvents 

func (m *HistoryTaskV2Attributes) GetEvents() *v14.DataBlob

func (*HistoryTaskV2Attributes) GetNamespaceId 

func (m *HistoryTaskV2Attributes) GetNamespaceId() string

func (*HistoryTaskV2Attributes) GetNewRunEvents 

func (m *HistoryTaskV2Attributes) GetNewRunEvents() *v14.DataBlob

func (*HistoryTaskV2Attributes) GetRunId 

func (m *HistoryTaskV2Attributes) GetRunId() string

func (*HistoryTaskV2Attributes) GetTaskId 

func (m *HistoryTaskV2Attributes) GetTaskId() int64

func (*HistoryTaskV2Attributes) GetVersionHistoryItems 

func (m *HistoryTaskV2Attributes) GetVersionHistoryItems() []*v16.VersionHistoryItem

func (*HistoryTaskV2Attributes) GetWorkflowId 

func (m *HistoryTaskV2Attributes) GetWorkflowId() string

func (*HistoryTaskV2Attributes) GoString 

func (this *HistoryTaskV2Attributes) GoString() string

func (*HistoryTaskV2Attributes) Marshal 

func (m *HistoryTaskV2Attributes) Marshal() (dAtA []byte, err error)

func (*HistoryTaskV2Attributes) MarshalTo 

func (m *HistoryTaskV2Attributes) MarshalTo(dAtA []byte) (int, error)

func (*HistoryTaskV2Attributes) MarshalToSizedBuffer 

func (m *HistoryTaskV2Attributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HistoryTaskV2Attributes) ProtoMessage 

func (*HistoryTaskV2Attributes) ProtoMessage()

func (*HistoryTaskV2Attributes) Reset 

func (m *HistoryTaskV2Attributes) Reset()

func (*HistoryTaskV2Attributes) Size 

func (m *HistoryTaskV2Attributes) Size() (n int)

func (*HistoryTaskV2Attributes) String 

func (this *HistoryTaskV2Attributes) String() string

func (*HistoryTaskV2Attributes) Unmarshal 

func (m *HistoryTaskV2Attributes) Unmarshal(dAtA []byte) error

func (*HistoryTaskV2Attributes) XXX_DiscardUnknown 

func (m *HistoryTaskV2Attributes) XXX_DiscardUnknown()

func (*HistoryTaskV2Attributes) XXX_Marshal 

func (m *HistoryTaskV2Attributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistoryTaskV2Attributes) XXX_Merge 

func (m *HistoryTaskV2Attributes) XXX_Merge(src proto.Message)

func (*HistoryTaskV2Attributes) XXX_Size 

func (m *HistoryTaskV2Attributes) XXX_Size() int

func (*HistoryTaskV2Attributes) XXX_Unmarshal 

func (m *HistoryTaskV2Attributes) XXX_Unmarshal(b []byte) error

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

func (*NamespaceTaskAttributes) Descriptor 

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

func (*NamespaceTaskAttributes) Equal 

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

func (*NamespaceTaskAttributes) GetConfig 

func (m *NamespaceTaskAttributes) GetConfig() *v11.NamespaceConfig

func (*NamespaceTaskAttributes) GetConfigVersion 

func (m *NamespaceTaskAttributes) GetConfigVersion() int64

func (*NamespaceTaskAttributes) GetFailoverVersion 

func (m *NamespaceTaskAttributes) GetFailoverVersion() int64

func (*NamespaceTaskAttributes) GetId 

func (m *NamespaceTaskAttributes) GetId() string

func (*NamespaceTaskAttributes) GetInfo 

func (m *NamespaceTaskAttributes) GetInfo() *v11.NamespaceInfo

func (*NamespaceTaskAttributes) GetNamespaceOperation 

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

func (*NamespaceTaskAttributes) GetReplicationConfig 

func (m *NamespaceTaskAttributes) GetReplicationConfig() *v12.NamespaceReplicationConfig

func (*NamespaceTaskAttributes) GoString 

func (this *NamespaceTaskAttributes) GoString() string

func (*NamespaceTaskAttributes) Marshal 

func (m *NamespaceTaskAttributes) Marshal() (dAtA []byte, err error)

func (*NamespaceTaskAttributes) MarshalTo 

func (m *NamespaceTaskAttributes) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceTaskAttributes) MarshalToSizedBuffer 

func (m *NamespaceTaskAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NamespaceTaskAttributes) ProtoMessage 

func (*NamespaceTaskAttributes) ProtoMessage()

func (*NamespaceTaskAttributes) Reset 

func (m *NamespaceTaskAttributes) Reset()

func (*NamespaceTaskAttributes) Size 

func (m *NamespaceTaskAttributes) Size() (n int)

func (*NamespaceTaskAttributes) String 

func (this *NamespaceTaskAttributes) String() string

func (*NamespaceTaskAttributes) Unmarshal 

func (m *NamespaceTaskAttributes) Unmarshal(dAtA []byte) error

func (*NamespaceTaskAttributes) XXX_DiscardUnknown 

func (m *NamespaceTaskAttributes) XXX_DiscardUnknown()

func (*NamespaceTaskAttributes) XXX_Marshal 

func (m *NamespaceTaskAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NamespaceTaskAttributes) XXX_Merge 

func (m *NamespaceTaskAttributes) XXX_Merge(src proto.Message)

func (*NamespaceTaskAttributes) XXX_Size 

func (m *NamespaceTaskAttributes) XXX_Size() int

func (*NamespaceTaskAttributes) XXX_Unmarshal 

func (m *NamespaceTaskAttributes) XXX_Unmarshal(b []byte) error

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"`
}

func (*ReplicationMessages) Descriptor 

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

func (*ReplicationMessages) Equal 

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

func (*ReplicationMessages) GetHasMore 

func (m *ReplicationMessages) GetHasMore() bool

func (*ReplicationMessages) GetLastRetrievedMessageId 

func (m *ReplicationMessages) GetLastRetrievedMessageId() int64

func (*ReplicationMessages) GetReplicationTasks 

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

func (*ReplicationMessages) GetSyncShardStatus 

func (m *ReplicationMessages) GetSyncShardStatus() *SyncShardStatus

func (*ReplicationMessages) GoString 

func (this *ReplicationMessages) GoString() string

func (*ReplicationMessages) Marshal 

func (m *ReplicationMessages) Marshal() (dAtA []byte, err error)

func (*ReplicationMessages) MarshalTo 

func (m *ReplicationMessages) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationMessages) MarshalToSizedBuffer 

func (m *ReplicationMessages) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationMessages) ProtoMessage 

func (*ReplicationMessages) ProtoMessage()

func (*ReplicationMessages) Reset 

func (m *ReplicationMessages) Reset()

func (*ReplicationMessages) Size 

func (m *ReplicationMessages) Size() (n int)

func (*ReplicationMessages) String 

func (this *ReplicationMessages) String() string

func (*ReplicationMessages) Unmarshal 

func (m *ReplicationMessages) Unmarshal(dAtA []byte) error

func (*ReplicationMessages) XXX_DiscardUnknown 

func (m *ReplicationMessages) XXX_DiscardUnknown()

func (*ReplicationMessages) XXX_Marshal 

func (m *ReplicationMessages) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationMessages) XXX_Merge 

func (m *ReplicationMessages) XXX_Merge(src proto.Message)

func (*ReplicationMessages) XXX_Size 

func (m *ReplicationMessages) XXX_Size() int

func (*ReplicationMessages) XXX_Unmarshal 

func (m *ReplicationMessages) XXX_Unmarshal(b []byte) error

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_HistoryTaskAttributes
	//	*ReplicationTask_SyncShardStatusTaskAttributes
	//	*ReplicationTask_SyncActivityTaskAttributes
	//	*ReplicationTask_HistoryMetadataTaskAttributes
	//	*ReplicationTask_HistoryTaskV2Attributes
	Attributes isReplicationTask_Attributes `protobuf_oneof:"attributes"`
}

func (*ReplicationTask) Descriptor 

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

func (*ReplicationTask) Equal 

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

func (*ReplicationTask) GetAttributes 

func (m *ReplicationTask) GetAttributes() isReplicationTask_Attributes

func (*ReplicationTask) GetHistoryMetadataTaskAttributes 

func (m *ReplicationTask) GetHistoryMetadataTaskAttributes() *HistoryMetadataTaskAttributes

func (*ReplicationTask) GetHistoryTaskAttributes 

func (m *ReplicationTask) GetHistoryTaskAttributes() *HistoryTaskAttributes

func (*ReplicationTask) GetHistoryTaskV2Attributes 

func (m *ReplicationTask) GetHistoryTaskV2Attributes() *HistoryTaskV2Attributes

func (*ReplicationTask) GetNamespaceTaskAttributes 

func (m *ReplicationTask) GetNamespaceTaskAttributes() *NamespaceTaskAttributes

func (*ReplicationTask) GetSourceTaskId 

func (m *ReplicationTask) GetSourceTaskId() int64

func (*ReplicationTask) GetSyncActivityTaskAttributes 

func (m *ReplicationTask) GetSyncActivityTaskAttributes() *SyncActivityTaskAttributes

func (*ReplicationTask) GetSyncShardStatusTaskAttributes 

func (m *ReplicationTask) GetSyncShardStatusTaskAttributes() *SyncShardStatusTaskAttributes

func (*ReplicationTask) GetTaskType 

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

func (*ReplicationTask) GoString 

func (this *ReplicationTask) GoString() string

func (*ReplicationTask) Marshal 

func (m *ReplicationTask) Marshal() (dAtA []byte, err error)

func (*ReplicationTask) MarshalTo 

func (m *ReplicationTask) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationTask) MarshalToSizedBuffer 

func (m *ReplicationTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationTask) ProtoMessage 

func (*ReplicationTask) ProtoMessage()

func (*ReplicationTask) Reset 

func (m *ReplicationTask) Reset()

func (*ReplicationTask) Size 

func (m *ReplicationTask) Size() (n int)

func (*ReplicationTask) String 

func (this *ReplicationTask) String() string

func (*ReplicationTask) Unmarshal 

func (m *ReplicationTask) Unmarshal(dAtA []byte) error

func (*ReplicationTask) XXX_DiscardUnknown 

func (m *ReplicationTask) XXX_DiscardUnknown()

func (*ReplicationTask) XXX_Marshal 

func (m *ReplicationTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationTask) XXX_Merge 

func (m *ReplicationTask) XXX_Merge(src proto.Message)

func (*ReplicationTask) XXX_OneofWrappers 

func (*ReplicationTask) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReplicationTask) XXX_Size 

func (m *ReplicationTask) XXX_Size() int

func (*ReplicationTask) XXX_Unmarshal 

func (m *ReplicationTask) XXX_Unmarshal(b []byte) error

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"`
	ScheduledId  int64       `protobuf:"varint,9,opt,name=scheduled_id,json=scheduledId,proto3" json:"scheduled_id,omitempty"`
}

func (*ReplicationTaskInfo) Descriptor 

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

func (*ReplicationTaskInfo) Equal 

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

func (*ReplicationTaskInfo) GetFirstEventId 

func (m *ReplicationTaskInfo) GetFirstEventId() int64

func (*ReplicationTaskInfo) GetNamespaceId 

func (m *ReplicationTaskInfo) GetNamespaceId() string

func (*ReplicationTaskInfo) GetNextEventId 

func (m *ReplicationTaskInfo) GetNextEventId() int64

func (*ReplicationTaskInfo) GetRunId 

func (m *ReplicationTaskInfo) GetRunId() string

func (*ReplicationTaskInfo) GetScheduledId 

func (m *ReplicationTaskInfo) GetScheduledId() int64

func (*ReplicationTaskInfo) GetTaskId 

func (m *ReplicationTaskInfo) GetTaskId() int64

func (*ReplicationTaskInfo) GetTaskType 

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

func (*ReplicationTaskInfo) GetVersion 

func (m *ReplicationTaskInfo) GetVersion() int64

func (*ReplicationTaskInfo) GetWorkflowId 

func (m *ReplicationTaskInfo) GetWorkflowId() string

func (*ReplicationTaskInfo) GoString 

func (this *ReplicationTaskInfo) GoString() string

func (*ReplicationTaskInfo) Marshal 

func (m *ReplicationTaskInfo) Marshal() (dAtA []byte, err error)

func (*ReplicationTaskInfo) MarshalTo 

func (m *ReplicationTaskInfo) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationTaskInfo) MarshalToSizedBuffer 

func (m *ReplicationTaskInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationTaskInfo) ProtoMessage 

func (*ReplicationTaskInfo) ProtoMessage()

func (*ReplicationTaskInfo) Reset 

func (m *ReplicationTaskInfo) Reset()

func (*ReplicationTaskInfo) Size 

func (m *ReplicationTaskInfo) Size() (n int)

func (*ReplicationTaskInfo) String 

func (this *ReplicationTaskInfo) String() string

func (*ReplicationTaskInfo) Unmarshal 

func (m *ReplicationTaskInfo) Unmarshal(dAtA []byte) error

func (*ReplicationTaskInfo) XXX_DiscardUnknown 

func (m *ReplicationTaskInfo) XXX_DiscardUnknown()

func (*ReplicationTaskInfo) XXX_Marshal 

func (m *ReplicationTaskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationTaskInfo) XXX_Merge 

func (m *ReplicationTaskInfo) XXX_Merge(src proto.Message)

func (*ReplicationTaskInfo) XXX_Size 

func (m *ReplicationTaskInfo) XXX_Size() int

func (*ReplicationTaskInfo) XXX_Unmarshal 

func (m *ReplicationTaskInfo) XXX_Unmarshal(b []byte) error

type ReplicationTask_HistoryMetadataTaskAttributes 

type ReplicationTask_HistoryMetadataTaskAttributes struct {
	HistoryMetadataTaskAttributes *HistoryMetadataTaskAttributes `` /* 158-byte string literal not displayed */
}

func (*ReplicationTask_HistoryMetadataTaskAttributes) Equal 

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

func (*ReplicationTask_HistoryMetadataTaskAttributes) GoString 

func (this *ReplicationTask_HistoryMetadataTaskAttributes) GoString() string

func (*ReplicationTask_HistoryMetadataTaskAttributes) MarshalTo 

func (m *ReplicationTask_HistoryMetadataTaskAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationTask_HistoryMetadataTaskAttributes) MarshalToSizedBuffer 

func (m *ReplicationTask_HistoryMetadataTaskAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationTask_HistoryMetadataTaskAttributes) Size 

func (m *ReplicationTask_HistoryMetadataTaskAttributes) Size() (n int)

func (*ReplicationTask_HistoryMetadataTaskAttributes) String 

func (this *ReplicationTask_HistoryMetadataTaskAttributes) String() string

type ReplicationTask_HistoryTaskAttributes 

type ReplicationTask_HistoryTaskAttributes struct {
	HistoryTaskAttributes *HistoryTaskAttributes `` /* 132-byte string literal not displayed */
}

func (*ReplicationTask_HistoryTaskAttributes) Equal 

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

func (*ReplicationTask_HistoryTaskAttributes) GoString 

func (this *ReplicationTask_HistoryTaskAttributes) GoString() string

func (*ReplicationTask_HistoryTaskAttributes) MarshalTo 

func (m *ReplicationTask_HistoryTaskAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationTask_HistoryTaskAttributes) MarshalToSizedBuffer 

func (m *ReplicationTask_HistoryTaskAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationTask_HistoryTaskAttributes) Size 

func (m *ReplicationTask_HistoryTaskAttributes) Size() (n int)

func (*ReplicationTask_HistoryTaskAttributes) String 

func (this *ReplicationTask_HistoryTaskAttributes) String() string

type ReplicationTask_HistoryTaskV2Attributes 

type ReplicationTask_HistoryTaskV2Attributes struct {
	HistoryTaskV2Attributes *HistoryTaskV2Attributes `` /* 140-byte string literal not displayed */
}

func (*ReplicationTask_HistoryTaskV2Attributes) Equal 

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

func (*ReplicationTask_HistoryTaskV2Attributes) GoString 

func (this *ReplicationTask_HistoryTaskV2Attributes) GoString() string

func (*ReplicationTask_HistoryTaskV2Attributes) MarshalTo 

func (m *ReplicationTask_HistoryTaskV2Attributes) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationTask_HistoryTaskV2Attributes) MarshalToSizedBuffer 

func (m *ReplicationTask_HistoryTaskV2Attributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationTask_HistoryTaskV2Attributes) Size 

func (m *ReplicationTask_HistoryTaskV2Attributes) Size() (n int)

func (*ReplicationTask_HistoryTaskV2Attributes) String 

func (this *ReplicationTask_HistoryTaskV2Attributes) String() string

type ReplicationTask_NamespaceTaskAttributes 

type ReplicationTask_NamespaceTaskAttributes struct {
	NamespaceTaskAttributes *NamespaceTaskAttributes `` /* 138-byte string literal not displayed */
}

func (*ReplicationTask_NamespaceTaskAttributes) Equal 

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

func (*ReplicationTask_NamespaceTaskAttributes) GoString 

func (this *ReplicationTask_NamespaceTaskAttributes) GoString() string

func (*ReplicationTask_NamespaceTaskAttributes) MarshalTo 

func (m *ReplicationTask_NamespaceTaskAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationTask_NamespaceTaskAttributes) MarshalToSizedBuffer 

func (m *ReplicationTask_NamespaceTaskAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationTask_NamespaceTaskAttributes) Size 

func (m *ReplicationTask_NamespaceTaskAttributes) Size() (n int)

func (*ReplicationTask_NamespaceTaskAttributes) String 

func (this *ReplicationTask_NamespaceTaskAttributes) String() string

type ReplicationTask_SyncActivityTaskAttributes 

type ReplicationTask_SyncActivityTaskAttributes struct {
	SyncActivityTaskAttributes *SyncActivityTaskAttributes `` /* 149-byte string literal not displayed */
}

func (*ReplicationTask_SyncActivityTaskAttributes) Equal 

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

func (*ReplicationTask_SyncActivityTaskAttributes) GoString 

func (this *ReplicationTask_SyncActivityTaskAttributes) GoString() string

func (*ReplicationTask_SyncActivityTaskAttributes) MarshalTo 

func (m *ReplicationTask_SyncActivityTaskAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationTask_SyncActivityTaskAttributes) MarshalToSizedBuffer 

func (m *ReplicationTask_SyncActivityTaskAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationTask_SyncActivityTaskAttributes) Size 

func (m *ReplicationTask_SyncActivityTaskAttributes) Size() (n int)

func (*ReplicationTask_SyncActivityTaskAttributes) String 

func (this *ReplicationTask_SyncActivityTaskAttributes) String() string

type ReplicationTask_SyncShardStatusTaskAttributes 

type ReplicationTask_SyncShardStatusTaskAttributes struct {
	SyncShardStatusTaskAttributes *SyncShardStatusTaskAttributes `` /* 160-byte string literal not displayed */
}

func (*ReplicationTask_SyncShardStatusTaskAttributes) Equal 

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

func (*ReplicationTask_SyncShardStatusTaskAttributes) GoString 

func (this *ReplicationTask_SyncShardStatusTaskAttributes) GoString() string

func (*ReplicationTask_SyncShardStatusTaskAttributes) MarshalTo 

func (m *ReplicationTask_SyncShardStatusTaskAttributes) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationTask_SyncShardStatusTaskAttributes) MarshalToSizedBuffer 

func (m *ReplicationTask_SyncShardStatusTaskAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationTask_SyncShardStatusTaskAttributes) Size 

func (m *ReplicationTask_SyncShardStatusTaskAttributes) Size() (n int)

func (*ReplicationTask_SyncShardStatusTaskAttributes) String 

func (this *ReplicationTask_SyncShardStatusTaskAttributes) String() string

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 */
}

func (*ReplicationToken) Descriptor 

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

func (*ReplicationToken) Equal 

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

func (*ReplicationToken) GetLastProcessedMessageId 

func (m *ReplicationToken) GetLastProcessedMessageId() int64

func (*ReplicationToken) GetLastRetrievedMessageId 

func (m *ReplicationToken) GetLastRetrievedMessageId() int64

func (*ReplicationToken) GetShardId 

func (m *ReplicationToken) GetShardId() int32

func (*ReplicationToken) GoString 

func (this *ReplicationToken) GoString() string

func (*ReplicationToken) Marshal 

func (m *ReplicationToken) Marshal() (dAtA []byte, err error)

func (*ReplicationToken) MarshalTo 

func (m *ReplicationToken) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationToken) MarshalToSizedBuffer 

func (m *ReplicationToken) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationToken) ProtoMessage 

func (*ReplicationToken) ProtoMessage()

func (*ReplicationToken) Reset 

func (m *ReplicationToken) Reset()

func (*ReplicationToken) Size 

func (m *ReplicationToken) Size() (n int)

func (*ReplicationToken) String 

func (this *ReplicationToken) String() string

func (*ReplicationToken) Unmarshal 

func (m *ReplicationToken) Unmarshal(dAtA []byte) error

func (*ReplicationToken) XXX_DiscardUnknown 

func (m *ReplicationToken) XXX_DiscardUnknown()

func (*ReplicationToken) XXX_Marshal 

func (m *ReplicationToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationToken) XXX_Merge 

func (m *ReplicationToken) XXX_Merge(src proto.Message)

func (*ReplicationToken) XXX_Size 

func (m *ReplicationToken) XXX_Size() int

func (*ReplicationToken) XXX_Unmarshal 

func (m *ReplicationToken) XXX_Unmarshal(b []byte) error

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"`
	ScheduledId        int64               `protobuf:"varint,5,opt,name=scheduled_id,json=scheduledId,proto3" json:"scheduled_id,omitempty"`
	ScheduledTime      *time.Time          `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	StartedId          int64               `protobuf:"varint,7,opt,name=started_id,json=startedId,proto3" json:"started_id,omitempty"`
	StartedTime        *time.Time          `protobuf:"bytes,8,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	LastHeartbeatTime  *time.Time          `protobuf:"bytes,9,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3,stdtime" json:"last_heartbeat_time,omitempty"`
	Details            *v14.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"`
}

func (*SyncActivityTaskAttributes) Descriptor 

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

func (*SyncActivityTaskAttributes) Equal 

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

func (*SyncActivityTaskAttributes) GetAttempt 

func (m *SyncActivityTaskAttributes) GetAttempt() int32

func (*SyncActivityTaskAttributes) GetDetails 

func (m *SyncActivityTaskAttributes) GetDetails() *v14.Payloads

func (*SyncActivityTaskAttributes) GetLastFailure 

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

func (*SyncActivityTaskAttributes) GetLastHeartbeatTime 

func (m *SyncActivityTaskAttributes) GetLastHeartbeatTime() *time.Time

func (*SyncActivityTaskAttributes) GetLastWorkerIdentity 

func (m *SyncActivityTaskAttributes) GetLastWorkerIdentity() string

func (*SyncActivityTaskAttributes) GetNamespaceId 

func (m *SyncActivityTaskAttributes) GetNamespaceId() string

func (*SyncActivityTaskAttributes) GetRunId 

func (m *SyncActivityTaskAttributes) GetRunId() string

func (*SyncActivityTaskAttributes) GetScheduledId 

func (m *SyncActivityTaskAttributes) GetScheduledId() int64

func (*SyncActivityTaskAttributes) GetScheduledTime 

func (m *SyncActivityTaskAttributes) GetScheduledTime() *time.Time

func (*SyncActivityTaskAttributes) GetStartedId 

func (m *SyncActivityTaskAttributes) GetStartedId() int64

func (*SyncActivityTaskAttributes) GetStartedTime 

func (m *SyncActivityTaskAttributes) GetStartedTime() *time.Time

func (*SyncActivityTaskAttributes) GetVersion 

func (m *SyncActivityTaskAttributes) GetVersion() int64

func (*SyncActivityTaskAttributes) GetVersionHistory 

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

func (*SyncActivityTaskAttributes) GetWorkflowId 

func (m *SyncActivityTaskAttributes) GetWorkflowId() string

func (*SyncActivityTaskAttributes) GoString 

func (this *SyncActivityTaskAttributes) GoString() string

func (*SyncActivityTaskAttributes) Marshal 

func (m *SyncActivityTaskAttributes) Marshal() (dAtA []byte, err error)

func (*SyncActivityTaskAttributes) MarshalTo 

func (m *SyncActivityTaskAttributes) MarshalTo(dAtA []byte) (int, error)

func (*SyncActivityTaskAttributes) MarshalToSizedBuffer 

func (m *SyncActivityTaskAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncActivityTaskAttributes) ProtoMessage 

func (*SyncActivityTaskAttributes) ProtoMessage()

func (*SyncActivityTaskAttributes) Reset 

func (m *SyncActivityTaskAttributes) Reset()

func (*SyncActivityTaskAttributes) Size 

func (m *SyncActivityTaskAttributes) Size() (n int)

func (*SyncActivityTaskAttributes) String 

func (this *SyncActivityTaskAttributes) String() string

func (*SyncActivityTaskAttributes) Unmarshal 

func (m *SyncActivityTaskAttributes) Unmarshal(dAtA []byte) error

func (*SyncActivityTaskAttributes) XXX_DiscardUnknown 

func (m *SyncActivityTaskAttributes) XXX_DiscardUnknown()

func (*SyncActivityTaskAttributes) XXX_Marshal 

func (m *SyncActivityTaskAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncActivityTaskAttributes) XXX_Merge 

func (m *SyncActivityTaskAttributes) XXX_Merge(src proto.Message)

func (*SyncActivityTaskAttributes) XXX_Size 

func (m *SyncActivityTaskAttributes) XXX_Size() int

func (*SyncActivityTaskAttributes) XXX_Unmarshal 

func (m *SyncActivityTaskAttributes) XXX_Unmarshal(b []byte) error

type SyncShardStatus 

type SyncShardStatus struct {
	StatusTime *time.Time `protobuf:"bytes,1,opt,name=status_time,json=statusTime,proto3,stdtime" json:"status_time,omitempty"`
}

func (*SyncShardStatus) Descriptor 

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

func (*SyncShardStatus) Equal 

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

func (*SyncShardStatus) GetStatusTime added in v0.28.0 

func (m *SyncShardStatus) GetStatusTime() *time.Time

func (*SyncShardStatus) GoString 

func (this *SyncShardStatus) GoString() string

func (*SyncShardStatus) Marshal 

func (m *SyncShardStatus) Marshal() (dAtA []byte, err error)

func (*SyncShardStatus) MarshalTo 

func (m *SyncShardStatus) MarshalTo(dAtA []byte) (int, error)

func (*SyncShardStatus) MarshalToSizedBuffer 

func (m *SyncShardStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncShardStatus) ProtoMessage 

func (*SyncShardStatus) ProtoMessage()

func (*SyncShardStatus) Reset 

func (m *SyncShardStatus) Reset()

func (*SyncShardStatus) Size 

func (m *SyncShardStatus) Size() (n int)

func (*SyncShardStatus) String 

func (this *SyncShardStatus) String() string

func (*SyncShardStatus) Unmarshal 

func (m *SyncShardStatus) Unmarshal(dAtA []byte) error

func (*SyncShardStatus) XXX_DiscardUnknown 

func (m *SyncShardStatus) XXX_DiscardUnknown()

func (*SyncShardStatus) XXX_Marshal 

func (m *SyncShardStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncShardStatus) XXX_Merge 

func (m *SyncShardStatus) XXX_Merge(src proto.Message)

func (*SyncShardStatus) XXX_Size 

func (m *SyncShardStatus) XXX_Size() int

func (*SyncShardStatus) XXX_Unmarshal 

func (m *SyncShardStatus) XXX_Unmarshal(b []byte) error

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    *time.Time `protobuf:"bytes,3,opt,name=status_time,json=statusTime,proto3,stdtime" json:"status_time,omitempty"`
}

func (*SyncShardStatusTaskAttributes) Descriptor 

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

func (*SyncShardStatusTaskAttributes) Equal 

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

func (*SyncShardStatusTaskAttributes) GetShardId 

func (m *SyncShardStatusTaskAttributes) GetShardId() int32

func (*SyncShardStatusTaskAttributes) GetSourceCluster 

func (m *SyncShardStatusTaskAttributes) GetSourceCluster() string

func (*SyncShardStatusTaskAttributes) GetStatusTime added in v0.28.0 

func (m *SyncShardStatusTaskAttributes) GetStatusTime() *time.Time

func (*SyncShardStatusTaskAttributes) GoString 

func (this *SyncShardStatusTaskAttributes) GoString() string

func (*SyncShardStatusTaskAttributes) Marshal 

func (m *SyncShardStatusTaskAttributes) Marshal() (dAtA []byte, err error)

func (*SyncShardStatusTaskAttributes) MarshalTo 

func (m *SyncShardStatusTaskAttributes) MarshalTo(dAtA []byte) (int, error)

func (*SyncShardStatusTaskAttributes) MarshalToSizedBuffer 

func (m *SyncShardStatusTaskAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncShardStatusTaskAttributes) ProtoMessage 

func (*SyncShardStatusTaskAttributes) ProtoMessage()

func (*SyncShardStatusTaskAttributes) Reset 

func (m *SyncShardStatusTaskAttributes) Reset()

func (*SyncShardStatusTaskAttributes) Size 

func (m *SyncShardStatusTaskAttributes) Size() (n int)

func (*SyncShardStatusTaskAttributes) String 

func (this *SyncShardStatusTaskAttributes) String() string

func (*SyncShardStatusTaskAttributes) Unmarshal 

func (m *SyncShardStatusTaskAttributes) Unmarshal(dAtA []byte) error

func (*SyncShardStatusTaskAttributes) XXX_DiscardUnknown 

func (m *SyncShardStatusTaskAttributes) XXX_DiscardUnknown()

func (*SyncShardStatusTaskAttributes) XXX_Marshal 

func (m *SyncShardStatusTaskAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncShardStatusTaskAttributes) XXX_Merge 

func (m *SyncShardStatusTaskAttributes) XXX_Merge(src proto.Message)

func (*SyncShardStatusTaskAttributes) XXX_Size 

func (m *SyncShardStatusTaskAttributes) XXX_Size() int

func (*SyncShardStatusTaskAttributes) XXX_Unmarshal 

func (m *SyncShardStatusTaskAttributes) XXX_Unmarshal(b []byte) error

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.