repication

package
v1.17.6 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2022 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 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              *v13.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 *v13.DataBlob `protobuf:"bytes,7,opt,name=new_run_events,json=newRunEvents,proto3" json:"new_run_events,omitempty"`
}

func (*HistoryTaskAttributes) Descriptor 

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

func (*HistoryTaskAttributes) Equal 

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

func (*HistoryTaskAttributes) GetEvents added in v1.17.0 

func (m *HistoryTaskAttributes) GetEvents() *v13.DataBlob

func (*HistoryTaskAttributes) GetNamespaceId 

func (m *HistoryTaskAttributes) GetNamespaceId() string

func (*HistoryTaskAttributes) GetNewRunEvents added in v1.17.0 

func (m *HistoryTaskAttributes) GetNewRunEvents() *v13.DataBlob

func (*HistoryTaskAttributes) GetRunId 

func (m *HistoryTaskAttributes) GetRunId() string

func (*HistoryTaskAttributes) GetVersionHistoryItems added in v1.17.0 

func (m *HistoryTaskAttributes) GetVersionHistoryItems() []*v15.VersionHistoryItem

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 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_SyncShardStatusTaskAttributes
	//	*ReplicationTask_SyncActivityTaskAttributes
	//	*ReplicationTask_HistoryTaskAttributes
	//	*ReplicationTask_SyncWorkflowStateTaskAttributes
	Attributes     isReplicationTask_Attributes `protobuf_oneof:"attributes"`
	VisibilityTime *time.Time                   `protobuf:"bytes,9,opt,name=visibility_time,json=visibilityTime,proto3,stdtime" json:"visibility_time,omitempty"`
}

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

func (m *ReplicationTask) GetHistoryTaskAttributes() *HistoryTaskAttributes

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

func (m *ReplicationTask) GetSyncWorkflowStateTaskAttributes() *SyncWorkflowStateTaskAttributes

func (*ReplicationTask) GetTaskType 

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

func (*ReplicationTask) GetVisibilityTime added in v1.14.0 

func (m *ReplicationTask) GetVisibilityTime() *time.Time

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"`
	ScheduledEventId int64       `protobuf:"varint,9,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_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) GetScheduledEventId added in v1.17.0 

func (m *ReplicationTaskInfo) GetScheduledEventId() 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_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_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 ReplicationTask_SyncWorkflowStateTaskAttributes added in v1.17.0 

type ReplicationTask_SyncWorkflowStateTaskAttributes struct {
	SyncWorkflowStateTaskAttributes *SyncWorkflowStateTaskAttributes `` /* 167-byte string literal not displayed */
}

func (*ReplicationTask_SyncWorkflowStateTaskAttributes) Equal added in v1.17.0 

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

func (*ReplicationTask_SyncWorkflowStateTaskAttributes) GoString added in v1.17.0 

func (this *ReplicationTask_SyncWorkflowStateTaskAttributes) GoString() string

func (*ReplicationTask_SyncWorkflowStateTaskAttributes) MarshalTo added in v1.17.0 

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

func (*ReplicationTask_SyncWorkflowStateTaskAttributes) MarshalToSizedBuffer added in v1.17.0 

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

func (*ReplicationTask_SyncWorkflowStateTaskAttributes) Size added in v1.17.0 

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

func (*ReplicationTask_SyncWorkflowStateTaskAttributes) String added in v1.17.0 

func (this *ReplicationTask_SyncWorkflowStateTaskAttributes) 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 */
	// The VisibilityTime of last processed ReplicationTask
	LastProcessedVisibilityTime *time.Time `` /* 154-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) GetLastProcessedVisibilityTime added in v1.14.0 

func (m *ReplicationToken) GetLastProcessedVisibilityTime() *time.Time

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"`
	ScheduledEventId   int64               `protobuf:"varint,5,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	ScheduledTime      *time.Time          `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	StartedEventId     int64               `protobuf:"varint,7,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_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            *v13.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"`
}

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() *v13.Payloads

func (*SyncActivityTaskAttributes) GetLastFailure 

func (m *SyncActivityTaskAttributes) GetLastFailure() *v14.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) GetScheduledEventId added in v1.17.0 

func (m *SyncActivityTaskAttributes) GetScheduledEventId() int64

func (*SyncActivityTaskAttributes) GetScheduledTime 

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

func (*SyncActivityTaskAttributes) GetStartedEventId added in v1.17.0 

func (m *SyncActivityTaskAttributes) GetStartedEventId() 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() *v15.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

type SyncWorkflowStateTaskAttributes added in v1.17.0 

type SyncWorkflowStateTaskAttributes struct {
	WorkflowState *v16.WorkflowMutableState `protobuf:"bytes,1,opt,name=workflow_state,json=workflowState,proto3" json:"workflow_state,omitempty"`
}

func (*SyncWorkflowStateTaskAttributes) Descriptor added in v1.17.0 

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

func (*SyncWorkflowStateTaskAttributes) Equal added in v1.17.0 

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

func (*SyncWorkflowStateTaskAttributes) GetWorkflowState added in v1.17.0 

func (m *SyncWorkflowStateTaskAttributes) GetWorkflowState() *v16.WorkflowMutableState

func (*SyncWorkflowStateTaskAttributes) GoString added in v1.17.0 

func (this *SyncWorkflowStateTaskAttributes) GoString() string

func (*SyncWorkflowStateTaskAttributes) Marshal added in v1.17.0 

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

func (*SyncWorkflowStateTaskAttributes) MarshalTo added in v1.17.0 

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

func (*SyncWorkflowStateTaskAttributes) MarshalToSizedBuffer added in v1.17.0 

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

func (*SyncWorkflowStateTaskAttributes) ProtoMessage added in v1.17.0 

func (*SyncWorkflowStateTaskAttributes) ProtoMessage()

func (*SyncWorkflowStateTaskAttributes) Reset added in v1.17.0 

func (m *SyncWorkflowStateTaskAttributes) Reset()

func (*SyncWorkflowStateTaskAttributes) Size added in v1.17.0 

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

func (*SyncWorkflowStateTaskAttributes) String added in v1.17.0 

func (this *SyncWorkflowStateTaskAttributes) String() string

func (*SyncWorkflowStateTaskAttributes) Unmarshal added in v1.17.0 

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

func (*SyncWorkflowStateTaskAttributes) XXX_DiscardUnknown added in v1.17.0 

func (m *SyncWorkflowStateTaskAttributes) XXX_DiscardUnknown()

func (*SyncWorkflowStateTaskAttributes) XXX_Marshal added in v1.17.0 

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

func (*SyncWorkflowStateTaskAttributes) XXX_Merge added in v1.17.0 

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

func (*SyncWorkflowStateTaskAttributes) XXX_Size added in v1.17.0 

func (m *SyncWorkflowStateTaskAttributes) XXX_Size() int

func (*SyncWorkflowStateTaskAttributes) XXX_Unmarshal added in v1.17.0 

func (m *SyncWorkflowStateTaskAttributes) 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.