repication

package
v1.20.2 Latest Latest
Warning

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

Go to latest
Published: Apr 17, 2023 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"`
	FailoverHistory    []*v12.FailoverStatus           `protobuf:"bytes,8,rep,name=failover_history,json=failoverHistory,proto3" json:"failover_history,omitempty"`
}

func (*NamespaceTaskAttributes) Descriptor

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

func (*NamespaceTaskAttributes) Equal

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

func (*NamespaceTaskAttributes) GetConfig

func (*NamespaceTaskAttributes) GetConfigVersion

func (m *NamespaceTaskAttributes) GetConfigVersion() int64

func (*NamespaceTaskAttributes) GetFailoverHistory added in v1.18.1

func (m *NamespaceTaskAttributes) GetFailoverHistory() []*v12.FailoverStatus

func (*NamespaceTaskAttributes) GetFailoverVersion

func (m *NamespaceTaskAttributes) GetFailoverVersion() int64

func (*NamespaceTaskAttributes) GetId

func (m *NamespaceTaskAttributes) GetId() string

func (*NamespaceTaskAttributes) GetInfo

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 (*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 (*ReplicationTask_HistoryTaskAttributes) 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 (*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 (*ReplicationTask_NamespaceTaskAttributes) 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 (*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 (*ReplicationTask_SyncActivityTaskAttributes) 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 (*ReplicationTask_SyncShardStatusTaskAttributes) MarshalTo

func (*ReplicationTask_SyncShardStatusTaskAttributes) MarshalToSizedBuffer

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

func (*ReplicationTask_SyncShardStatusTaskAttributes) Size

func (*ReplicationTask_SyncShardStatusTaskAttributes) 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 (*ReplicationTask_SyncWorkflowStateTaskAttributes) MarshalTo added in v1.17.0

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 (*ReplicationTask_SyncWorkflowStateTaskAttributes) String added in v1.17.0

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 (*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 (*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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL