mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
Will DuanandGitHub
232820a8cb
## What changed? Fix State based replication first task handling ## Why? Previously, we made an assumption that it is always safe to return mutation for first replication task, but it is not true. When there is replication lag, the workflow may make some progress and tombstone batch is capped. If we still blindly return mutation, completed statemachine may still looked pending on the passive side. ## How did you test it? - [x] built - [ ] run locally and tested manually - [x] covered by existing tests - [ ] added new unit test(s) - [ ] added new functional test(s) ## Potential risks No risk, the feature is not launched yet.
2344 lines
99 KiB
Go
2344 lines
99 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// plugins:
|
|
// protoc-gen-go
|
|
// protoc
|
|
// source: temporal/server/api/replication/v1/message.proto
|
|
|
|
package repication
|
|
|
|
import (
|
|
reflect "reflect"
|
|
sync "sync"
|
|
unsafe "unsafe"
|
|
|
|
v11 "go.temporal.io/api/common/v1"
|
|
v15 "go.temporal.io/api/failure/v1"
|
|
v13 "go.temporal.io/api/namespace/v1"
|
|
v14 "go.temporal.io/api/replication/v1"
|
|
v1 "go.temporal.io/server/api/enums/v1"
|
|
v16 "go.temporal.io/server/api/history/v1"
|
|
v12 "go.temporal.io/server/api/persistence/v1"
|
|
v17 "go.temporal.io/server/api/workflow/v1"
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
durationpb "google.golang.org/protobuf/types/known/durationpb"
|
|
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
|
|
)
|
|
|
|
const (
|
|
// Verify that this generated code is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
|
)
|
|
|
|
type ReplicationTask struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
TaskType v1.ReplicationTaskType `protobuf:"varint,1,opt,name=task_type,json=taskType,proto3,enum=temporal.server.api.enums.v1.ReplicationTaskType" json:"task_type,omitempty"`
|
|
SourceTaskId int64 `protobuf:"varint,2,opt,name=source_task_id,json=sourceTaskId,proto3" json:"source_task_id,omitempty"`
|
|
// Types that are valid to be assigned to Attributes:
|
|
//
|
|
// *ReplicationTask_NamespaceTaskAttributes
|
|
// *ReplicationTask_SyncShardStatusTaskAttributes
|
|
// *ReplicationTask_SyncActivityTaskAttributes
|
|
// *ReplicationTask_HistoryTaskAttributes
|
|
// *ReplicationTask_SyncWorkflowStateTaskAttributes
|
|
// *ReplicationTask_TaskQueueUserDataAttributes
|
|
// *ReplicationTask_SyncHsmAttributes
|
|
// *ReplicationTask_BackfillHistoryTaskAttributes
|
|
// *ReplicationTask_VerifyVersionedTransitionTaskAttributes
|
|
// *ReplicationTask_SyncVersionedTransitionTaskAttributes
|
|
Attributes isReplicationTask_Attributes `protobuf_oneof:"attributes"`
|
|
// All attributes should be deprecated and replaced by this field.
|
|
// The task_type + data provide more flexibility in future use cases.
|
|
Data *v11.DataBlob `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"`
|
|
VisibilityTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
|
|
Priority v1.TaskPriority `protobuf:"varint,13,opt,name=priority,proto3,enum=temporal.server.api.enums.v1.TaskPriority" json:"priority,omitempty"`
|
|
VersionedTransition *v12.VersionedTransition `protobuf:"bytes,15,opt,name=versioned_transition,json=versionedTransition,proto3" json:"versioned_transition,omitempty"`
|
|
RawTaskInfo *v12.ReplicationTaskInfo `protobuf:"bytes,17,opt,name=raw_task_info,json=rawTaskInfo,proto3" json:"raw_task_info,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ReplicationTask) Reset() {
|
|
*x = ReplicationTask{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ReplicationTask) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ReplicationTask) ProtoMessage() {}
|
|
|
|
func (x *ReplicationTask) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[0]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ReplicationTask.ProtoReflect.Descriptor instead.
|
|
func (*ReplicationTask) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *ReplicationTask) GetTaskType() v1.ReplicationTaskType {
|
|
if x != nil {
|
|
return x.TaskType
|
|
}
|
|
return v1.ReplicationTaskType(0)
|
|
}
|
|
|
|
func (x *ReplicationTask) GetSourceTaskId() int64 {
|
|
if x != nil {
|
|
return x.SourceTaskId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationTask) GetAttributes() isReplicationTask_Attributes {
|
|
if x != nil {
|
|
return x.Attributes
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetNamespaceTaskAttributes() *NamespaceTaskAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*ReplicationTask_NamespaceTaskAttributes); ok {
|
|
return x.NamespaceTaskAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetSyncShardStatusTaskAttributes() *SyncShardStatusTaskAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*ReplicationTask_SyncShardStatusTaskAttributes); ok {
|
|
return x.SyncShardStatusTaskAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetSyncActivityTaskAttributes() *SyncActivityTaskAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*ReplicationTask_SyncActivityTaskAttributes); ok {
|
|
return x.SyncActivityTaskAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetHistoryTaskAttributes() *HistoryTaskAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*ReplicationTask_HistoryTaskAttributes); ok {
|
|
return x.HistoryTaskAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetSyncWorkflowStateTaskAttributes() *SyncWorkflowStateTaskAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*ReplicationTask_SyncWorkflowStateTaskAttributes); ok {
|
|
return x.SyncWorkflowStateTaskAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetTaskQueueUserDataAttributes() *TaskQueueUserDataAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*ReplicationTask_TaskQueueUserDataAttributes); ok {
|
|
return x.TaskQueueUserDataAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetSyncHsmAttributes() *SyncHSMAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*ReplicationTask_SyncHsmAttributes); ok {
|
|
return x.SyncHsmAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetBackfillHistoryTaskAttributes() *BackfillHistoryTaskAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*ReplicationTask_BackfillHistoryTaskAttributes); ok {
|
|
return x.BackfillHistoryTaskAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetVerifyVersionedTransitionTaskAttributes() *VerifyVersionedTransitionTaskAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*ReplicationTask_VerifyVersionedTransitionTaskAttributes); ok {
|
|
return x.VerifyVersionedTransitionTaskAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetSyncVersionedTransitionTaskAttributes() *SyncVersionedTransitionTaskAttributes {
|
|
if x != nil {
|
|
if x, ok := x.Attributes.(*ReplicationTask_SyncVersionedTransitionTaskAttributes); ok {
|
|
return x.SyncVersionedTransitionTaskAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetData() *v11.DataBlob {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetVisibilityTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.VisibilityTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetPriority() v1.TaskPriority {
|
|
if x != nil {
|
|
return x.Priority
|
|
}
|
|
return v1.TaskPriority(0)
|
|
}
|
|
|
|
func (x *ReplicationTask) GetVersionedTransition() *v12.VersionedTransition {
|
|
if x != nil {
|
|
return x.VersionedTransition
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationTask) GetRawTaskInfo() *v12.ReplicationTaskInfo {
|
|
if x != nil {
|
|
return x.RawTaskInfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type isReplicationTask_Attributes interface {
|
|
isReplicationTask_Attributes()
|
|
}
|
|
|
|
type ReplicationTask_NamespaceTaskAttributes struct {
|
|
NamespaceTaskAttributes *NamespaceTaskAttributes `protobuf:"bytes,3,opt,name=namespace_task_attributes,json=namespaceTaskAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type ReplicationTask_SyncShardStatusTaskAttributes struct {
|
|
SyncShardStatusTaskAttributes *SyncShardStatusTaskAttributes `protobuf:"bytes,5,opt,name=sync_shard_status_task_attributes,json=syncShardStatusTaskAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type ReplicationTask_SyncActivityTaskAttributes struct {
|
|
SyncActivityTaskAttributes *SyncActivityTaskAttributes `protobuf:"bytes,6,opt,name=sync_activity_task_attributes,json=syncActivityTaskAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type ReplicationTask_HistoryTaskAttributes struct {
|
|
HistoryTaskAttributes *HistoryTaskAttributes `protobuf:"bytes,8,opt,name=history_task_attributes,json=historyTaskAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type ReplicationTask_SyncWorkflowStateTaskAttributes struct {
|
|
SyncWorkflowStateTaskAttributes *SyncWorkflowStateTaskAttributes `protobuf:"bytes,10,opt,name=sync_workflow_state_task_attributes,json=syncWorkflowStateTaskAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type ReplicationTask_TaskQueueUserDataAttributes struct {
|
|
TaskQueueUserDataAttributes *TaskQueueUserDataAttributes `protobuf:"bytes,11,opt,name=task_queue_user_data_attributes,json=taskQueueUserDataAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type ReplicationTask_SyncHsmAttributes struct {
|
|
SyncHsmAttributes *SyncHSMAttributes `protobuf:"bytes,14,opt,name=sync_hsm_attributes,json=syncHsmAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type ReplicationTask_BackfillHistoryTaskAttributes struct {
|
|
BackfillHistoryTaskAttributes *BackfillHistoryTaskAttributes `protobuf:"bytes,16,opt,name=backfill_history_task_attributes,json=backfillHistoryTaskAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type ReplicationTask_VerifyVersionedTransitionTaskAttributes struct {
|
|
VerifyVersionedTransitionTaskAttributes *VerifyVersionedTransitionTaskAttributes `protobuf:"bytes,18,opt,name=verify_versioned_transition_task_attributes,json=verifyVersionedTransitionTaskAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type ReplicationTask_SyncVersionedTransitionTaskAttributes struct {
|
|
SyncVersionedTransitionTaskAttributes *SyncVersionedTransitionTaskAttributes `protobuf:"bytes,19,opt,name=sync_versioned_transition_task_attributes,json=syncVersionedTransitionTaskAttributes,proto3,oneof"`
|
|
}
|
|
|
|
func (*ReplicationTask_NamespaceTaskAttributes) isReplicationTask_Attributes() {}
|
|
|
|
func (*ReplicationTask_SyncShardStatusTaskAttributes) isReplicationTask_Attributes() {}
|
|
|
|
func (*ReplicationTask_SyncActivityTaskAttributes) isReplicationTask_Attributes() {}
|
|
|
|
func (*ReplicationTask_HistoryTaskAttributes) isReplicationTask_Attributes() {}
|
|
|
|
func (*ReplicationTask_SyncWorkflowStateTaskAttributes) isReplicationTask_Attributes() {}
|
|
|
|
func (*ReplicationTask_TaskQueueUserDataAttributes) isReplicationTask_Attributes() {}
|
|
|
|
func (*ReplicationTask_SyncHsmAttributes) isReplicationTask_Attributes() {}
|
|
|
|
func (*ReplicationTask_BackfillHistoryTaskAttributes) isReplicationTask_Attributes() {}
|
|
|
|
func (*ReplicationTask_VerifyVersionedTransitionTaskAttributes) isReplicationTask_Attributes() {}
|
|
|
|
func (*ReplicationTask_SyncVersionedTransitionTaskAttributes) isReplicationTask_Attributes() {}
|
|
|
|
type ReplicationToken struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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 `protobuf:"varint,2,opt,name=last_retrieved_message_id,json=lastRetrievedMessageId,proto3" json:"last_retrieved_message_id,omitempty"`
|
|
// 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 `protobuf:"varint,3,opt,name=last_processed_message_id,json=lastProcessedMessageId,proto3" json:"last_processed_message_id,omitempty"`
|
|
// The VisibilityTime of last processed ReplicationTask
|
|
LastProcessedVisibilityTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_processed_visibility_time,json=lastProcessedVisibilityTime,proto3" json:"last_processed_visibility_time,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ReplicationToken) Reset() {
|
|
*x = ReplicationToken{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ReplicationToken) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ReplicationToken) ProtoMessage() {}
|
|
|
|
func (x *ReplicationToken) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[1]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ReplicationToken.ProtoReflect.Descriptor instead.
|
|
func (*ReplicationToken) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *ReplicationToken) GetShardId() int32 {
|
|
if x != nil {
|
|
return x.ShardId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationToken) GetLastRetrievedMessageId() int64 {
|
|
if x != nil {
|
|
return x.LastRetrievedMessageId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationToken) GetLastProcessedMessageId() int64 {
|
|
if x != nil {
|
|
return x.LastProcessedMessageId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationToken) GetLastProcessedVisibilityTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.LastProcessedVisibilityTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SyncShardStatus struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
StatusTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=status_time,json=statusTime,proto3" json:"status_time,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncShardStatus) Reset() {
|
|
*x = SyncShardStatus{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncShardStatus) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncShardStatus) ProtoMessage() {}
|
|
|
|
func (x *SyncShardStatus) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[2]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncShardStatus.ProtoReflect.Descriptor instead.
|
|
func (*SyncShardStatus) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
func (x *SyncShardStatus) GetStatusTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.StatusTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SyncReplicationState struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// deprecated in favor of using ReplicationState object
|
|
InclusiveLowWatermark int64 `protobuf:"varint,1,opt,name=inclusive_low_watermark,json=inclusiveLowWatermark,proto3" json:"inclusive_low_watermark,omitempty"`
|
|
// deprecated in favor of using ReplicationState object
|
|
InclusiveLowWatermarkTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=inclusive_low_watermark_time,json=inclusiveLowWatermarkTime,proto3" json:"inclusive_low_watermark_time,omitempty"`
|
|
HighPriorityState *ReplicationState `protobuf:"bytes,3,opt,name=high_priority_state,json=highPriorityState,proto3" json:"high_priority_state,omitempty"`
|
|
LowPriorityState *ReplicationState `protobuf:"bytes,4,opt,name=low_priority_state,json=lowPriorityState,proto3" json:"low_priority_state,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncReplicationState) Reset() {
|
|
*x = SyncReplicationState{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncReplicationState) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncReplicationState) ProtoMessage() {}
|
|
|
|
func (x *SyncReplicationState) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[3]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncReplicationState.ProtoReflect.Descriptor instead.
|
|
func (*SyncReplicationState) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *SyncReplicationState) GetInclusiveLowWatermark() int64 {
|
|
if x != nil {
|
|
return x.InclusiveLowWatermark
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SyncReplicationState) GetInclusiveLowWatermarkTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.InclusiveLowWatermarkTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncReplicationState) GetHighPriorityState() *ReplicationState {
|
|
if x != nil {
|
|
return x.HighPriorityState
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncReplicationState) GetLowPriorityState() *ReplicationState {
|
|
if x != nil {
|
|
return x.LowPriorityState
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ReplicationState struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
InclusiveLowWatermark int64 `protobuf:"varint,1,opt,name=inclusive_low_watermark,json=inclusiveLowWatermark,proto3" json:"inclusive_low_watermark,omitempty"`
|
|
InclusiveLowWatermarkTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=inclusive_low_watermark_time,json=inclusiveLowWatermarkTime,proto3" json:"inclusive_low_watermark_time,omitempty"`
|
|
FlowControlCommand v1.ReplicationFlowControlCommand `protobuf:"varint,3,opt,name=flow_control_command,json=flowControlCommand,proto3,enum=temporal.server.api.enums.v1.ReplicationFlowControlCommand" json:"flow_control_command,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ReplicationState) Reset() {
|
|
*x = ReplicationState{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ReplicationState) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ReplicationState) ProtoMessage() {}
|
|
|
|
func (x *ReplicationState) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[4]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ReplicationState.ProtoReflect.Descriptor instead.
|
|
func (*ReplicationState) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
func (x *ReplicationState) GetInclusiveLowWatermark() int64 {
|
|
if x != nil {
|
|
return x.InclusiveLowWatermark
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationState) GetInclusiveLowWatermarkTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.InclusiveLowWatermarkTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationState) GetFlowControlCommand() v1.ReplicationFlowControlCommand {
|
|
if x != nil {
|
|
return x.FlowControlCommand
|
|
}
|
|
return v1.ReplicationFlowControlCommand(0)
|
|
}
|
|
|
|
type ReplicationMessages struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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 `protobuf:"varint,2,opt,name=last_retrieved_message_id,json=lastRetrievedMessageId,proto3" json:"last_retrieved_message_id,omitempty"`
|
|
// 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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ReplicationMessages) Reset() {
|
|
*x = ReplicationMessages{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[5]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ReplicationMessages) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ReplicationMessages) ProtoMessage() {}
|
|
|
|
func (x *ReplicationMessages) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[5]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ReplicationMessages.ProtoReflect.Descriptor instead.
|
|
func (*ReplicationMessages) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{5}
|
|
}
|
|
|
|
func (x *ReplicationMessages) GetReplicationTasks() []*ReplicationTask {
|
|
if x != nil {
|
|
return x.ReplicationTasks
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ReplicationMessages) GetLastRetrievedMessageId() int64 {
|
|
if x != nil {
|
|
return x.LastRetrievedMessageId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationMessages) GetHasMore() bool {
|
|
if x != nil {
|
|
return x.HasMore
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *ReplicationMessages) GetSyncShardStatus() *SyncShardStatus {
|
|
if x != nil {
|
|
return x.SyncShardStatus
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type WorkflowReplicationMessages struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
ReplicationTasks []*ReplicationTask `protobuf:"bytes,1,rep,name=replication_tasks,json=replicationTasks,proto3" json:"replication_tasks,omitempty"`
|
|
// This can be different than the last taskId in the above list, because sender can decide to skip tasks (e.g. for completed workflows).
|
|
ExclusiveHighWatermark int64 `protobuf:"varint,2,opt,name=exclusive_high_watermark,json=exclusiveHighWatermark,proto3" json:"exclusive_high_watermark,omitempty"`
|
|
ExclusiveHighWatermarkTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=exclusive_high_watermark_time,json=exclusiveHighWatermarkTime,proto3" json:"exclusive_high_watermark_time,omitempty"`
|
|
Priority v1.TaskPriority `protobuf:"varint,4,opt,name=priority,proto3,enum=temporal.server.api.enums.v1.TaskPriority" json:"priority,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *WorkflowReplicationMessages) Reset() {
|
|
*x = WorkflowReplicationMessages{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[6]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *WorkflowReplicationMessages) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*WorkflowReplicationMessages) ProtoMessage() {}
|
|
|
|
func (x *WorkflowReplicationMessages) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[6]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use WorkflowReplicationMessages.ProtoReflect.Descriptor instead.
|
|
func (*WorkflowReplicationMessages) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{6}
|
|
}
|
|
|
|
func (x *WorkflowReplicationMessages) GetReplicationTasks() []*ReplicationTask {
|
|
if x != nil {
|
|
return x.ReplicationTasks
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkflowReplicationMessages) GetExclusiveHighWatermark() int64 {
|
|
if x != nil {
|
|
return x.ExclusiveHighWatermark
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *WorkflowReplicationMessages) GetExclusiveHighWatermarkTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.ExclusiveHighWatermarkTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkflowReplicationMessages) GetPriority() v1.TaskPriority {
|
|
if x != nil {
|
|
return x.Priority
|
|
}
|
|
return v1.TaskPriority(0)
|
|
}
|
|
|
|
// TODO: Deprecate this definition, it only used by the deprecated replication DLQ v1 logic
|
|
type ReplicationTaskInfo struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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 `protobuf:"varint,4,opt,name=task_type,json=taskType,proto3,enum=temporal.server.api.enums.v1.TaskType" json:"task_type,omitempty"`
|
|
TaskId int64 `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
|
|
Version int64 `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
|
|
FirstEventId int64 `protobuf:"varint,7,opt,name=first_event_id,json=firstEventId,proto3" json:"first_event_id,omitempty"`
|
|
NextEventId int64 `protobuf:"varint,8,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
|
|
ScheduledEventId int64 `protobuf:"varint,9,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
|
|
Priority v1.TaskPriority `protobuf:"varint,10,opt,name=priority,proto3,enum=temporal.server.api.enums.v1.TaskPriority" json:"priority,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) Reset() {
|
|
*x = ReplicationTaskInfo{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[7]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ReplicationTaskInfo) ProtoMessage() {}
|
|
|
|
func (x *ReplicationTaskInfo) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[7]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ReplicationTaskInfo.ProtoReflect.Descriptor instead.
|
|
func (*ReplicationTaskInfo) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{7}
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) GetWorkflowId() string {
|
|
if x != nil {
|
|
return x.WorkflowId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) GetRunId() string {
|
|
if x != nil {
|
|
return x.RunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) GetTaskType() v1.TaskType {
|
|
if x != nil {
|
|
return x.TaskType
|
|
}
|
|
return v1.TaskType(0)
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) GetTaskId() int64 {
|
|
if x != nil {
|
|
return x.TaskId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) GetVersion() int64 {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) GetFirstEventId() int64 {
|
|
if x != nil {
|
|
return x.FirstEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) GetNextEventId() int64 {
|
|
if x != nil {
|
|
return x.NextEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) GetScheduledEventId() int64 {
|
|
if x != nil {
|
|
return x.ScheduledEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *ReplicationTaskInfo) GetPriority() v1.TaskPriority {
|
|
if x != nil {
|
|
return x.Priority
|
|
}
|
|
return v1.TaskPriority(0)
|
|
}
|
|
|
|
type NamespaceTaskAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
NamespaceOperation v1.NamespaceOperation `protobuf:"varint,1,opt,name=namespace_operation,json=namespaceOperation,proto3,enum=temporal.server.api.enums.v1.NamespaceOperation" json:"namespace_operation,omitempty"`
|
|
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
|
|
Info *v13.NamespaceInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
|
|
Config *v13.NamespaceConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
|
|
ReplicationConfig *v14.NamespaceReplicationConfig `protobuf:"bytes,5,opt,name=replication_config,json=replicationConfig,proto3" json:"replication_config,omitempty"`
|
|
ConfigVersion int64 `protobuf:"varint,6,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
|
|
FailoverVersion int64 `protobuf:"varint,7,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
|
|
FailoverHistory []*v14.FailoverStatus `protobuf:"bytes,8,rep,name=failover_history,json=failoverHistory,proto3" json:"failover_history,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *NamespaceTaskAttributes) Reset() {
|
|
*x = NamespaceTaskAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[8]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *NamespaceTaskAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*NamespaceTaskAttributes) ProtoMessage() {}
|
|
|
|
func (x *NamespaceTaskAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[8]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use NamespaceTaskAttributes.ProtoReflect.Descriptor instead.
|
|
func (*NamespaceTaskAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{8}
|
|
}
|
|
|
|
func (x *NamespaceTaskAttributes) GetNamespaceOperation() v1.NamespaceOperation {
|
|
if x != nil {
|
|
return x.NamespaceOperation
|
|
}
|
|
return v1.NamespaceOperation(0)
|
|
}
|
|
|
|
func (x *NamespaceTaskAttributes) GetId() string {
|
|
if x != nil {
|
|
return x.Id
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *NamespaceTaskAttributes) GetInfo() *v13.NamespaceInfo {
|
|
if x != nil {
|
|
return x.Info
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *NamespaceTaskAttributes) GetConfig() *v13.NamespaceConfig {
|
|
if x != nil {
|
|
return x.Config
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *NamespaceTaskAttributes) GetReplicationConfig() *v14.NamespaceReplicationConfig {
|
|
if x != nil {
|
|
return x.ReplicationConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *NamespaceTaskAttributes) GetConfigVersion() int64 {
|
|
if x != nil {
|
|
return x.ConfigVersion
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *NamespaceTaskAttributes) GetFailoverVersion() int64 {
|
|
if x != nil {
|
|
return x.FailoverVersion
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *NamespaceTaskAttributes) GetFailoverHistory() []*v14.FailoverStatus {
|
|
if x != nil {
|
|
return x.FailoverHistory
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SyncShardStatusTaskAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
SourceCluster string `protobuf:"bytes,1,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
|
|
ShardId int32 `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
|
|
StatusTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=status_time,json=statusTime,proto3" json:"status_time,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncShardStatusTaskAttributes) Reset() {
|
|
*x = SyncShardStatusTaskAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[9]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncShardStatusTaskAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncShardStatusTaskAttributes) ProtoMessage() {}
|
|
|
|
func (x *SyncShardStatusTaskAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[9]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncShardStatusTaskAttributes.ProtoReflect.Descriptor instead.
|
|
func (*SyncShardStatusTaskAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{9}
|
|
}
|
|
|
|
func (x *SyncShardStatusTaskAttributes) GetSourceCluster() string {
|
|
if x != nil {
|
|
return x.SourceCluster
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncShardStatusTaskAttributes) GetShardId() int32 {
|
|
if x != nil {
|
|
return x.ShardId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SyncShardStatusTaskAttributes) GetStatusTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.StatusTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SyncActivityTaskAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
|
|
RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
|
|
Version int64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
|
|
ScheduledEventId int64 `protobuf:"varint,5,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
|
|
ScheduledTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
|
|
StartedEventId int64 `protobuf:"varint,7,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
|
|
StartedTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`
|
|
LastHeartbeatTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3" json:"last_heartbeat_time,omitempty"`
|
|
Details *v11.Payloads `protobuf:"bytes,10,opt,name=details,proto3" json:"details,omitempty"`
|
|
Attempt int32 `protobuf:"varint,11,opt,name=attempt,proto3" json:"attempt,omitempty"`
|
|
LastFailure *v15.Failure `protobuf:"bytes,12,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
|
|
LastWorkerIdentity string `protobuf:"bytes,13,opt,name=last_worker_identity,json=lastWorkerIdentity,proto3" json:"last_worker_identity,omitempty"`
|
|
VersionHistory *v16.VersionHistory `protobuf:"bytes,14,opt,name=version_history,json=versionHistory,proto3" json:"version_history,omitempty"`
|
|
BaseExecutionInfo *v17.BaseExecutionInfo `protobuf:"bytes,15,opt,name=base_execution_info,json=baseExecutionInfo,proto3" json:"base_execution_info,omitempty"`
|
|
// build ID of the worker who received this activity last time
|
|
LastStartedBuildId string `protobuf:"bytes,16,opt,name=last_started_build_id,json=lastStartedBuildId,proto3" json:"last_started_build_id,omitempty"`
|
|
// workflows redirect_counter value when this activity started last time
|
|
LastStartedRedirectCounter int64 `protobuf:"varint,17,opt,name=last_started_redirect_counter,json=lastStartedRedirectCounter,proto3" json:"last_started_redirect_counter,omitempty"`
|
|
// The first time the activity was scheduled.
|
|
FirstScheduledTime *timestamppb.Timestamp `protobuf:"bytes,18,opt,name=first_scheduled_time,json=firstScheduledTime,proto3" json:"first_scheduled_time,omitempty"`
|
|
// The last time an activity attempt completion was recorded by the server.
|
|
LastAttemptCompleteTime *timestamppb.Timestamp `protobuf:"bytes,19,opt,name=last_attempt_complete_time,json=lastAttemptCompleteTime,proto3" json:"last_attempt_complete_time,omitempty"`
|
|
// Stamp represents the internal “version” of the activity options and can/will be changed with Activity API.
|
|
// It monotonically increments when the activity options are changed.
|
|
Stamp int32 `protobuf:"varint,20,opt,name=stamp,proto3" json:"stamp,omitempty"`
|
|
// Flag indicating whether the activity is currently paused.
|
|
Paused bool `protobuf:"varint,21,opt,name=paused,proto3" json:"paused,omitempty"`
|
|
// Retry policy for the activity. It needs to be replicated now, since the activity properties can be updated.
|
|
RetryInitialInterval *durationpb.Duration `protobuf:"bytes,22,opt,name=retry_initial_interval,json=retryInitialInterval,proto3" json:"retry_initial_interval,omitempty"`
|
|
RetryMaximumInterval *durationpb.Duration `protobuf:"bytes,23,opt,name=retry_maximum_interval,json=retryMaximumInterval,proto3" json:"retry_maximum_interval,omitempty"`
|
|
RetryMaximumAttempts int32 `protobuf:"varint,24,opt,name=retry_maximum_attempts,json=retryMaximumAttempts,proto3" json:"retry_maximum_attempts,omitempty"`
|
|
RetryBackoffCoefficient float64 `protobuf:"fixed64,25,opt,name=retry_backoff_coefficient,json=retryBackoffCoefficient,proto3" json:"retry_backoff_coefficient,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) Reset() {
|
|
*x = SyncActivityTaskAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[10]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncActivityTaskAttributes) ProtoMessage() {}
|
|
|
|
func (x *SyncActivityTaskAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[10]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncActivityTaskAttributes.ProtoReflect.Descriptor instead.
|
|
func (*SyncActivityTaskAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{10}
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetWorkflowId() string {
|
|
if x != nil {
|
|
return x.WorkflowId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetRunId() string {
|
|
if x != nil {
|
|
return x.RunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetVersion() int64 {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetScheduledEventId() int64 {
|
|
if x != nil {
|
|
return x.ScheduledEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetScheduledTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.ScheduledTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetStartedEventId() int64 {
|
|
if x != nil {
|
|
return x.StartedEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetStartedTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.StartedTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetLastHeartbeatTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.LastHeartbeatTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetDetails() *v11.Payloads {
|
|
if x != nil {
|
|
return x.Details
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetAttempt() int32 {
|
|
if x != nil {
|
|
return x.Attempt
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetLastFailure() *v15.Failure {
|
|
if x != nil {
|
|
return x.LastFailure
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetLastWorkerIdentity() string {
|
|
if x != nil {
|
|
return x.LastWorkerIdentity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetVersionHistory() *v16.VersionHistory {
|
|
if x != nil {
|
|
return x.VersionHistory
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetBaseExecutionInfo() *v17.BaseExecutionInfo {
|
|
if x != nil {
|
|
return x.BaseExecutionInfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetLastStartedBuildId() string {
|
|
if x != nil {
|
|
return x.LastStartedBuildId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetLastStartedRedirectCounter() int64 {
|
|
if x != nil {
|
|
return x.LastStartedRedirectCounter
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetFirstScheduledTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.FirstScheduledTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetLastAttemptCompleteTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.LastAttemptCompleteTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetStamp() int32 {
|
|
if x != nil {
|
|
return x.Stamp
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetPaused() bool {
|
|
if x != nil {
|
|
return x.Paused
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetRetryInitialInterval() *durationpb.Duration {
|
|
if x != nil {
|
|
return x.RetryInitialInterval
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetRetryMaximumInterval() *durationpb.Duration {
|
|
if x != nil {
|
|
return x.RetryMaximumInterval
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetRetryMaximumAttempts() int32 {
|
|
if x != nil {
|
|
return x.RetryMaximumAttempts
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SyncActivityTaskAttributes) GetRetryBackoffCoefficient() float64 {
|
|
if x != nil {
|
|
return x.RetryBackoffCoefficient
|
|
}
|
|
return 0
|
|
}
|
|
|
|
type HistoryTaskAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
NamespaceId string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
WorkflowId string `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
|
|
RunId string `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
|
|
VersionHistoryItems []*v16.VersionHistoryItem `protobuf:"bytes,5,rep,name=version_history_items,json=versionHistoryItems,proto3" json:"version_history_items,omitempty"`
|
|
// to be deprecated in favor of using events_batches
|
|
Events *v11.DataBlob `protobuf:"bytes,6,opt,name=events,proto3" json:"events,omitempty"`
|
|
// New run events does not need version history since there is no prior events.
|
|
NewRunEvents *v11.DataBlob `protobuf:"bytes,7,opt,name=new_run_events,json=newRunEvents,proto3" json:"new_run_events,omitempty"`
|
|
BaseExecutionInfo *v17.BaseExecutionInfo `protobuf:"bytes,8,opt,name=base_execution_info,json=baseExecutionInfo,proto3" json:"base_execution_info,omitempty"`
|
|
NewRunId string `protobuf:"bytes,9,opt,name=new_run_id,json=newRunId,proto3" json:"new_run_id,omitempty"`
|
|
EventsBatches []*v11.DataBlob `protobuf:"bytes,10,rep,name=events_batches,json=eventsBatches,proto3" json:"events_batches,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) Reset() {
|
|
*x = HistoryTaskAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[11]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*HistoryTaskAttributes) ProtoMessage() {}
|
|
|
|
func (x *HistoryTaskAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[11]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use HistoryTaskAttributes.ProtoReflect.Descriptor instead.
|
|
func (*HistoryTaskAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{11}
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) GetWorkflowId() string {
|
|
if x != nil {
|
|
return x.WorkflowId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) GetRunId() string {
|
|
if x != nil {
|
|
return x.RunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) GetVersionHistoryItems() []*v16.VersionHistoryItem {
|
|
if x != nil {
|
|
return x.VersionHistoryItems
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) GetEvents() *v11.DataBlob {
|
|
if x != nil {
|
|
return x.Events
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) GetNewRunEvents() *v11.DataBlob {
|
|
if x != nil {
|
|
return x.NewRunEvents
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) GetBaseExecutionInfo() *v17.BaseExecutionInfo {
|
|
if x != nil {
|
|
return x.BaseExecutionInfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) GetNewRunId() string {
|
|
if x != nil {
|
|
return x.NewRunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *HistoryTaskAttributes) GetEventsBatches() []*v11.DataBlob {
|
|
if x != nil {
|
|
return x.EventsBatches
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SyncWorkflowStateTaskAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
WorkflowState *v12.WorkflowMutableState `protobuf:"bytes,1,opt,name=workflow_state,json=workflowState,proto3" json:"workflow_state,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncWorkflowStateTaskAttributes) Reset() {
|
|
*x = SyncWorkflowStateTaskAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[12]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncWorkflowStateTaskAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncWorkflowStateTaskAttributes) ProtoMessage() {}
|
|
|
|
func (x *SyncWorkflowStateTaskAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[12]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncWorkflowStateTaskAttributes.ProtoReflect.Descriptor instead.
|
|
func (*SyncWorkflowStateTaskAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{12}
|
|
}
|
|
|
|
func (x *SyncWorkflowStateTaskAttributes) GetWorkflowState() *v12.WorkflowMutableState {
|
|
if x != nil {
|
|
return x.WorkflowState
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type TaskQueueUserDataAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
TaskQueueName string `protobuf:"bytes,2,opt,name=task_queue_name,json=taskQueueName,proto3" json:"task_queue_name,omitempty"`
|
|
UserData *v12.TaskQueueUserData `protobuf:"bytes,3,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *TaskQueueUserDataAttributes) Reset() {
|
|
*x = TaskQueueUserDataAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[13]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *TaskQueueUserDataAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*TaskQueueUserDataAttributes) ProtoMessage() {}
|
|
|
|
func (x *TaskQueueUserDataAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[13]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use TaskQueueUserDataAttributes.ProtoReflect.Descriptor instead.
|
|
func (*TaskQueueUserDataAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{13}
|
|
}
|
|
|
|
func (x *TaskQueueUserDataAttributes) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *TaskQueueUserDataAttributes) GetTaskQueueName() string {
|
|
if x != nil {
|
|
return x.TaskQueueName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *TaskQueueUserDataAttributes) GetUserData() *v12.TaskQueueUserData {
|
|
if x != nil {
|
|
return x.UserData
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SyncHSMAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
|
|
RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
|
|
VersionHistory *v16.VersionHistory `protobuf:"bytes,4,opt,name=version_history,json=versionHistory,proto3" json:"version_history,omitempty"`
|
|
StateMachineNode *v12.StateMachineNode `protobuf:"bytes,5,opt,name=state_machine_node,json=stateMachineNode,proto3" json:"state_machine_node,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncHSMAttributes) Reset() {
|
|
*x = SyncHSMAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[14]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncHSMAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncHSMAttributes) ProtoMessage() {}
|
|
|
|
func (x *SyncHSMAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[14]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncHSMAttributes.ProtoReflect.Descriptor instead.
|
|
func (*SyncHSMAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{14}
|
|
}
|
|
|
|
func (x *SyncHSMAttributes) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncHSMAttributes) GetWorkflowId() string {
|
|
if x != nil {
|
|
return x.WorkflowId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncHSMAttributes) GetRunId() string {
|
|
if x != nil {
|
|
return x.RunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncHSMAttributes) GetVersionHistory() *v16.VersionHistory {
|
|
if x != nil {
|
|
return x.VersionHistory
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncHSMAttributes) GetStateMachineNode() *v12.StateMachineNode {
|
|
if x != nil {
|
|
return x.StateMachineNode
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type BackfillHistoryTaskAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
|
|
RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
|
|
EventVersionHistory []*v16.VersionHistoryItem `protobuf:"bytes,5,rep,name=event_version_history,json=eventVersionHistory,proto3" json:"event_version_history,omitempty"`
|
|
EventBatches []*v11.DataBlob `protobuf:"bytes,6,rep,name=event_batches,json=eventBatches,proto3" json:"event_batches,omitempty"`
|
|
NewRunInfo *NewRunInfo `protobuf:"bytes,7,opt,name=new_run_info,json=newRunInfo,proto3" json:"new_run_info,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *BackfillHistoryTaskAttributes) Reset() {
|
|
*x = BackfillHistoryTaskAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[15]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *BackfillHistoryTaskAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*BackfillHistoryTaskAttributes) ProtoMessage() {}
|
|
|
|
func (x *BackfillHistoryTaskAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[15]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use BackfillHistoryTaskAttributes.ProtoReflect.Descriptor instead.
|
|
func (*BackfillHistoryTaskAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{15}
|
|
}
|
|
|
|
func (x *BackfillHistoryTaskAttributes) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *BackfillHistoryTaskAttributes) GetWorkflowId() string {
|
|
if x != nil {
|
|
return x.WorkflowId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *BackfillHistoryTaskAttributes) GetRunId() string {
|
|
if x != nil {
|
|
return x.RunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *BackfillHistoryTaskAttributes) GetEventVersionHistory() []*v16.VersionHistoryItem {
|
|
if x != nil {
|
|
return x.EventVersionHistory
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *BackfillHistoryTaskAttributes) GetEventBatches() []*v11.DataBlob {
|
|
if x != nil {
|
|
return x.EventBatches
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *BackfillHistoryTaskAttributes) GetNewRunInfo() *NewRunInfo {
|
|
if x != nil {
|
|
return x.NewRunInfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type NewRunInfo struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
|
|
EventBatch *v11.DataBlob `protobuf:"bytes,2,opt,name=event_batch,json=eventBatch,proto3" json:"event_batch,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *NewRunInfo) Reset() {
|
|
*x = NewRunInfo{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[16]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *NewRunInfo) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*NewRunInfo) ProtoMessage() {}
|
|
|
|
func (x *NewRunInfo) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[16]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use NewRunInfo.ProtoReflect.Descriptor instead.
|
|
func (*NewRunInfo) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{16}
|
|
}
|
|
|
|
func (x *NewRunInfo) GetRunId() string {
|
|
if x != nil {
|
|
return x.RunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *NewRunInfo) GetEventBatch() *v11.DataBlob {
|
|
if x != nil {
|
|
return x.EventBatch
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SyncWorkflowStateMutationAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
ExclusiveStartVersionedTransition *v12.VersionedTransition `protobuf:"bytes,1,opt,name=exclusive_start_versioned_transition,json=exclusiveStartVersionedTransition,proto3" json:"exclusive_start_versioned_transition,omitempty"`
|
|
StateMutation *v12.WorkflowMutableStateMutation `protobuf:"bytes,2,opt,name=state_mutation,json=stateMutation,proto3" json:"state_mutation,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncWorkflowStateMutationAttributes) Reset() {
|
|
*x = SyncWorkflowStateMutationAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[17]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncWorkflowStateMutationAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncWorkflowStateMutationAttributes) ProtoMessage() {}
|
|
|
|
func (x *SyncWorkflowStateMutationAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[17]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncWorkflowStateMutationAttributes.ProtoReflect.Descriptor instead.
|
|
func (*SyncWorkflowStateMutationAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{17}
|
|
}
|
|
|
|
func (x *SyncWorkflowStateMutationAttributes) GetExclusiveStartVersionedTransition() *v12.VersionedTransition {
|
|
if x != nil {
|
|
return x.ExclusiveStartVersionedTransition
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncWorkflowStateMutationAttributes) GetStateMutation() *v12.WorkflowMutableStateMutation {
|
|
if x != nil {
|
|
return x.StateMutation
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SyncWorkflowStateSnapshotAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
State *v12.WorkflowMutableState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncWorkflowStateSnapshotAttributes) Reset() {
|
|
*x = SyncWorkflowStateSnapshotAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[18]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncWorkflowStateSnapshotAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncWorkflowStateSnapshotAttributes) ProtoMessage() {}
|
|
|
|
func (x *SyncWorkflowStateSnapshotAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[18]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncWorkflowStateSnapshotAttributes.ProtoReflect.Descriptor instead.
|
|
func (*SyncWorkflowStateSnapshotAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{18}
|
|
}
|
|
|
|
func (x *SyncWorkflowStateSnapshotAttributes) GetState() *v12.WorkflowMutableState {
|
|
if x != nil {
|
|
return x.State
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type VerifyVersionedTransitionTaskAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
|
|
RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
|
|
NextEventId int64 `protobuf:"varint,4,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
|
|
EventVersionHistory []*v16.VersionHistoryItem `protobuf:"bytes,5,rep,name=event_version_history,json=eventVersionHistory,proto3" json:"event_version_history,omitempty"`
|
|
NewRunId string `protobuf:"bytes,6,opt,name=new_run_id,json=newRunId,proto3" json:"new_run_id,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *VerifyVersionedTransitionTaskAttributes) Reset() {
|
|
*x = VerifyVersionedTransitionTaskAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[19]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *VerifyVersionedTransitionTaskAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*VerifyVersionedTransitionTaskAttributes) ProtoMessage() {}
|
|
|
|
func (x *VerifyVersionedTransitionTaskAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[19]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use VerifyVersionedTransitionTaskAttributes.ProtoReflect.Descriptor instead.
|
|
func (*VerifyVersionedTransitionTaskAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{19}
|
|
}
|
|
|
|
func (x *VerifyVersionedTransitionTaskAttributes) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *VerifyVersionedTransitionTaskAttributes) GetWorkflowId() string {
|
|
if x != nil {
|
|
return x.WorkflowId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *VerifyVersionedTransitionTaskAttributes) GetRunId() string {
|
|
if x != nil {
|
|
return x.RunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *VerifyVersionedTransitionTaskAttributes) GetNextEventId() int64 {
|
|
if x != nil {
|
|
return x.NextEventId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *VerifyVersionedTransitionTaskAttributes) GetEventVersionHistory() []*v16.VersionHistoryItem {
|
|
if x != nil {
|
|
return x.EventVersionHistory
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VerifyVersionedTransitionTaskAttributes) GetNewRunId() string {
|
|
if x != nil {
|
|
return x.NewRunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type SyncVersionedTransitionTaskAttributes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
VersionedTransitionArtifact *VersionedTransitionArtifact `protobuf:"bytes,5,opt,name=versioned_transition_artifact,json=versionedTransitionArtifact,proto3" json:"versioned_transition_artifact,omitempty"`
|
|
NamespaceId string `protobuf:"bytes,6,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
|
|
WorkflowId string `protobuf:"bytes,7,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
|
|
RunId string `protobuf:"bytes,8,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncVersionedTransitionTaskAttributes) Reset() {
|
|
*x = SyncVersionedTransitionTaskAttributes{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[20]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncVersionedTransitionTaskAttributes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncVersionedTransitionTaskAttributes) ProtoMessage() {}
|
|
|
|
func (x *SyncVersionedTransitionTaskAttributes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[20]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncVersionedTransitionTaskAttributes.ProtoReflect.Descriptor instead.
|
|
func (*SyncVersionedTransitionTaskAttributes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{20}
|
|
}
|
|
|
|
func (x *SyncVersionedTransitionTaskAttributes) GetVersionedTransitionArtifact() *VersionedTransitionArtifact {
|
|
if x != nil {
|
|
return x.VersionedTransitionArtifact
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncVersionedTransitionTaskAttributes) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncVersionedTransitionTaskAttributes) GetWorkflowId() string {
|
|
if x != nil {
|
|
return x.WorkflowId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncVersionedTransitionTaskAttributes) GetRunId() string {
|
|
if x != nil {
|
|
return x.RunId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type VersionedTransitionArtifact struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Types that are valid to be assigned to StateAttributes:
|
|
//
|
|
// *VersionedTransitionArtifact_SyncWorkflowStateMutationAttributes
|
|
// *VersionedTransitionArtifact_SyncWorkflowStateSnapshotAttributes
|
|
StateAttributes isVersionedTransitionArtifact_StateAttributes `protobuf_oneof:"state_attributes"`
|
|
EventBatches []*v11.DataBlob `protobuf:"bytes,3,rep,name=event_batches,json=eventBatches,proto3" json:"event_batches,omitempty"`
|
|
NewRunInfo *NewRunInfo `protobuf:"bytes,4,opt,name=new_run_info,json=newRunInfo,proto3" json:"new_run_info,omitempty"`
|
|
IsFirstSync bool `protobuf:"varint,5,opt,name=is_first_sync,json=isFirstSync,proto3" json:"is_first_sync,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *VersionedTransitionArtifact) Reset() {
|
|
*x = VersionedTransitionArtifact{}
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[21]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *VersionedTransitionArtifact) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*VersionedTransitionArtifact) ProtoMessage() {}
|
|
|
|
func (x *VersionedTransitionArtifact) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_replication_v1_message_proto_msgTypes[21]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use VersionedTransitionArtifact.ProtoReflect.Descriptor instead.
|
|
func (*VersionedTransitionArtifact) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescGZIP(), []int{21}
|
|
}
|
|
|
|
func (x *VersionedTransitionArtifact) GetStateAttributes() isVersionedTransitionArtifact_StateAttributes {
|
|
if x != nil {
|
|
return x.StateAttributes
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionedTransitionArtifact) GetSyncWorkflowStateMutationAttributes() *SyncWorkflowStateMutationAttributes {
|
|
if x != nil {
|
|
if x, ok := x.StateAttributes.(*VersionedTransitionArtifact_SyncWorkflowStateMutationAttributes); ok {
|
|
return x.SyncWorkflowStateMutationAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionedTransitionArtifact) GetSyncWorkflowStateSnapshotAttributes() *SyncWorkflowStateSnapshotAttributes {
|
|
if x != nil {
|
|
if x, ok := x.StateAttributes.(*VersionedTransitionArtifact_SyncWorkflowStateSnapshotAttributes); ok {
|
|
return x.SyncWorkflowStateSnapshotAttributes
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionedTransitionArtifact) GetEventBatches() []*v11.DataBlob {
|
|
if x != nil {
|
|
return x.EventBatches
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionedTransitionArtifact) GetNewRunInfo() *NewRunInfo {
|
|
if x != nil {
|
|
return x.NewRunInfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionedTransitionArtifact) GetIsFirstSync() bool {
|
|
if x != nil {
|
|
return x.IsFirstSync
|
|
}
|
|
return false
|
|
}
|
|
|
|
type isVersionedTransitionArtifact_StateAttributes interface {
|
|
isVersionedTransitionArtifact_StateAttributes()
|
|
}
|
|
|
|
type VersionedTransitionArtifact_SyncWorkflowStateMutationAttributes struct {
|
|
SyncWorkflowStateMutationAttributes *SyncWorkflowStateMutationAttributes `protobuf:"bytes,1,opt,name=sync_workflow_state_mutation_attributes,json=syncWorkflowStateMutationAttributes,proto3,oneof"`
|
|
}
|
|
|
|
type VersionedTransitionArtifact_SyncWorkflowStateSnapshotAttributes struct {
|
|
SyncWorkflowStateSnapshotAttributes *SyncWorkflowStateSnapshotAttributes `protobuf:"bytes,2,opt,name=sync_workflow_state_snapshot_attributes,json=syncWorkflowStateSnapshotAttributes,proto3,oneof"`
|
|
}
|
|
|
|
func (*VersionedTransitionArtifact_SyncWorkflowStateMutationAttributes) isVersionedTransitionArtifact_StateAttributes() {
|
|
}
|
|
|
|
func (*VersionedTransitionArtifact_SyncWorkflowStateSnapshotAttributes) isVersionedTransitionArtifact_StateAttributes() {
|
|
}
|
|
|
|
var File_temporal_server_api_replication_v1_message_proto protoreflect.FileDescriptor
|
|
|
|
const file_temporal_server_api_replication_v1_message_proto_rawDesc = "" +
|
|
"\n" +
|
|
"0temporal/server/api/replication/v1/message.proto\x12\"temporal.server.api.replication.v1\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/duration.proto\x1a.temporal/server/api/enums/v1/replication.proto\x1a'temporal/server/api/enums/v1/task.proto\x1a,temporal/server/api/history/v1/message.proto\x1a3temporal/server/api/persistence/v1/executions.proto\x1a,temporal/server/api/persistence/v1/hsm.proto\x1a4temporal/server/api/persistence/v1/task_queues.proto\x1a?temporal/server/api/persistence/v1/workflow_mutable_state.proto\x1a$temporal/api/common/v1/message.proto\x1a'temporal/api/namespace/v1/message.proto\x1a)temporal/api/replication/v1/message.proto\x1a%temporal/api/failure/v1/message.proto\x1a-temporal/server/api/workflow/v1/message.proto\"\xa1\x0f\n" +
|
|
"\x0fReplicationTask\x12N\n" +
|
|
"\ttask_type\x18\x01 \x01(\x0e21.temporal.server.api.enums.v1.ReplicationTaskTypeR\btaskType\x12$\n" +
|
|
"\x0esource_task_id\x18\x02 \x01(\x03R\fsourceTaskId\x12y\n" +
|
|
"\x19namespace_task_attributes\x18\x03 \x01(\v2;.temporal.server.api.replication.v1.NamespaceTaskAttributesH\x00R\x17namespaceTaskAttributes\x12\x8d\x01\n" +
|
|
"!sync_shard_status_task_attributes\x18\x05 \x01(\v2A.temporal.server.api.replication.v1.SyncShardStatusTaskAttributesH\x00R\x1dsyncShardStatusTaskAttributes\x12\x83\x01\n" +
|
|
"\x1dsync_activity_task_attributes\x18\x06 \x01(\v2>.temporal.server.api.replication.v1.SyncActivityTaskAttributesH\x00R\x1asyncActivityTaskAttributes\x12s\n" +
|
|
"\x17history_task_attributes\x18\b \x01(\v29.temporal.server.api.replication.v1.HistoryTaskAttributesH\x00R\x15historyTaskAttributes\x12\x93\x01\n" +
|
|
"#sync_workflow_state_task_attributes\x18\n" +
|
|
" \x01(\v2C.temporal.server.api.replication.v1.SyncWorkflowStateTaskAttributesH\x00R\x1fsyncWorkflowStateTaskAttributes\x12\x87\x01\n" +
|
|
"\x1ftask_queue_user_data_attributes\x18\v \x01(\v2?.temporal.server.api.replication.v1.TaskQueueUserDataAttributesH\x00R\x1btaskQueueUserDataAttributes\x12g\n" +
|
|
"\x13sync_hsm_attributes\x18\x0e \x01(\v25.temporal.server.api.replication.v1.SyncHSMAttributesH\x00R\x11syncHsmAttributes\x12\x8c\x01\n" +
|
|
" backfill_history_task_attributes\x18\x10 \x01(\v2A.temporal.server.api.replication.v1.BackfillHistoryTaskAttributesH\x00R\x1dbackfillHistoryTaskAttributes\x12\xab\x01\n" +
|
|
"+verify_versioned_transition_task_attributes\x18\x12 \x01(\v2K.temporal.server.api.replication.v1.VerifyVersionedTransitionTaskAttributesH\x00R'verifyVersionedTransitionTaskAttributes\x12\xa5\x01\n" +
|
|
")sync_versioned_transition_task_attributes\x18\x13 \x01(\v2I.temporal.server.api.replication.v1.SyncVersionedTransitionTaskAttributesH\x00R%syncVersionedTransitionTaskAttributes\x124\n" +
|
|
"\x04data\x18\f \x01(\v2 .temporal.api.common.v1.DataBlobR\x04data\x12C\n" +
|
|
"\x0fvisibility_time\x18\t \x01(\v2\x1a.google.protobuf.TimestampR\x0evisibilityTime\x12F\n" +
|
|
"\bpriority\x18\r \x01(\x0e2*.temporal.server.api.enums.v1.TaskPriorityR\bpriority\x12j\n" +
|
|
"\x14versioned_transition\x18\x0f \x01(\v27.temporal.server.api.persistence.v1.VersionedTransitionR\x13versionedTransition\x12[\n" +
|
|
"\rraw_task_info\x18\x11 \x01(\v27.temporal.server.api.persistence.v1.ReplicationTaskInfoR\vrawTaskInfoB\f\n" +
|
|
"\n" +
|
|
"attributesJ\x04\b\x04\x10\x05J\x04\b\a\x10\b\"\x84\x02\n" +
|
|
"\x10ReplicationToken\x12\x19\n" +
|
|
"\bshard_id\x18\x01 \x01(\x05R\ashardId\x129\n" +
|
|
"\x19last_retrieved_message_id\x18\x02 \x01(\x03R\x16lastRetrievedMessageId\x129\n" +
|
|
"\x19last_processed_message_id\x18\x03 \x01(\x03R\x16lastProcessedMessageId\x12_\n" +
|
|
"\x1elast_processed_visibility_time\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\x1blastProcessedVisibilityTime\"N\n" +
|
|
"\x0fSyncShardStatus\x12;\n" +
|
|
"\vstatus_time\x18\x01 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"statusTime\"\xf5\x02\n" +
|
|
"\x14SyncReplicationState\x126\n" +
|
|
"\x17inclusive_low_watermark\x18\x01 \x01(\x03R\x15inclusiveLowWatermark\x12[\n" +
|
|
"\x1cinclusive_low_watermark_time\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\x19inclusiveLowWatermarkTime\x12d\n" +
|
|
"\x13high_priority_state\x18\x03 \x01(\v24.temporal.server.api.replication.v1.ReplicationStateR\x11highPriorityState\x12b\n" +
|
|
"\x12low_priority_state\x18\x04 \x01(\v24.temporal.server.api.replication.v1.ReplicationStateR\x10lowPriorityState\"\x96\x02\n" +
|
|
"\x10ReplicationState\x126\n" +
|
|
"\x17inclusive_low_watermark\x18\x01 \x01(\x03R\x15inclusiveLowWatermark\x12[\n" +
|
|
"\x1cinclusive_low_watermark_time\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\x19inclusiveLowWatermarkTime\x12m\n" +
|
|
"\x14flow_control_command\x18\x03 \x01(\x0e2;.temporal.server.api.enums.v1.ReplicationFlowControlCommandR\x12flowControlCommand\"\xae\x02\n" +
|
|
"\x13ReplicationMessages\x12`\n" +
|
|
"\x11replication_tasks\x18\x01 \x03(\v23.temporal.server.api.replication.v1.ReplicationTaskR\x10replicationTasks\x129\n" +
|
|
"\x19last_retrieved_message_id\x18\x02 \x01(\x03R\x16lastRetrievedMessageId\x12\x19\n" +
|
|
"\bhas_more\x18\x03 \x01(\bR\ahasMore\x12_\n" +
|
|
"\x11sync_shard_status\x18\x04 \x01(\v23.temporal.server.api.replication.v1.SyncShardStatusR\x0fsyncShardStatus\"\xe0\x02\n" +
|
|
"\x1bWorkflowReplicationMessages\x12`\n" +
|
|
"\x11replication_tasks\x18\x01 \x03(\v23.temporal.server.api.replication.v1.ReplicationTaskR\x10replicationTasks\x128\n" +
|
|
"\x18exclusive_high_watermark\x18\x02 \x01(\x03R\x16exclusiveHighWatermark\x12]\n" +
|
|
"\x1dexclusive_high_watermark_time\x18\x03 \x01(\v2\x1a.google.protobuf.TimestampR\x1aexclusiveHighWatermarkTime\x12F\n" +
|
|
"\bpriority\x18\x04 \x01(\x0e2*.temporal.server.api.enums.v1.TaskPriorityR\bpriority\"\xa8\x03\n" +
|
|
"\x13ReplicationTaskInfo\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1f\n" +
|
|
"\vworkflow_id\x18\x02 \x01(\tR\n" +
|
|
"workflowId\x12\x15\n" +
|
|
"\x06run_id\x18\x03 \x01(\tR\x05runId\x12C\n" +
|
|
"\ttask_type\x18\x04 \x01(\x0e2&.temporal.server.api.enums.v1.TaskTypeR\btaskType\x12\x17\n" +
|
|
"\atask_id\x18\x05 \x01(\x03R\x06taskId\x12\x18\n" +
|
|
"\aversion\x18\x06 \x01(\x03R\aversion\x12$\n" +
|
|
"\x0efirst_event_id\x18\a \x01(\x03R\ffirstEventId\x12\"\n" +
|
|
"\rnext_event_id\x18\b \x01(\x03R\vnextEventId\x12,\n" +
|
|
"\x12scheduled_event_id\x18\t \x01(\x03R\x10scheduledEventId\x12F\n" +
|
|
"\bpriority\x18\n" +
|
|
" \x01(\x0e2*.temporal.server.api.enums.v1.TaskPriorityR\bpriority\"\xa0\x04\n" +
|
|
"\x17NamespaceTaskAttributes\x12a\n" +
|
|
"\x13namespace_operation\x18\x01 \x01(\x0e20.temporal.server.api.enums.v1.NamespaceOperationR\x12namespaceOperation\x12\x0e\n" +
|
|
"\x02id\x18\x02 \x01(\tR\x02id\x12<\n" +
|
|
"\x04info\x18\x03 \x01(\v2(.temporal.api.namespace.v1.NamespaceInfoR\x04info\x12B\n" +
|
|
"\x06config\x18\x04 \x01(\v2*.temporal.api.namespace.v1.NamespaceConfigR\x06config\x12f\n" +
|
|
"\x12replication_config\x18\x05 \x01(\v27.temporal.api.replication.v1.NamespaceReplicationConfigR\x11replicationConfig\x12%\n" +
|
|
"\x0econfig_version\x18\x06 \x01(\x03R\rconfigVersion\x12)\n" +
|
|
"\x10failover_version\x18\a \x01(\x03R\x0ffailoverVersion\x12V\n" +
|
|
"\x10failover_history\x18\b \x03(\v2+.temporal.api.replication.v1.FailoverStatusR\x0ffailoverHistory\"\x9e\x01\n" +
|
|
"\x1dSyncShardStatusTaskAttributes\x12%\n" +
|
|
"\x0esource_cluster\x18\x01 \x01(\tR\rsourceCluster\x12\x19\n" +
|
|
"\bshard_id\x18\x02 \x01(\x05R\ashardId\x12;\n" +
|
|
"\vstatus_time\x18\x03 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"statusTime\"\xa0\v\n" +
|
|
"\x1aSyncActivityTaskAttributes\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1f\n" +
|
|
"\vworkflow_id\x18\x02 \x01(\tR\n" +
|
|
"workflowId\x12\x15\n" +
|
|
"\x06run_id\x18\x03 \x01(\tR\x05runId\x12\x18\n" +
|
|
"\aversion\x18\x04 \x01(\x03R\aversion\x12,\n" +
|
|
"\x12scheduled_event_id\x18\x05 \x01(\x03R\x10scheduledEventId\x12A\n" +
|
|
"\x0escheduled_time\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\rscheduledTime\x12(\n" +
|
|
"\x10started_event_id\x18\a \x01(\x03R\x0estartedEventId\x12=\n" +
|
|
"\fstarted_time\x18\b \x01(\v2\x1a.google.protobuf.TimestampR\vstartedTime\x12J\n" +
|
|
"\x13last_heartbeat_time\x18\t \x01(\v2\x1a.google.protobuf.TimestampR\x11lastHeartbeatTime\x12:\n" +
|
|
"\adetails\x18\n" +
|
|
" \x01(\v2 .temporal.api.common.v1.PayloadsR\adetails\x12\x18\n" +
|
|
"\aattempt\x18\v \x01(\x05R\aattempt\x12C\n" +
|
|
"\flast_failure\x18\f \x01(\v2 .temporal.api.failure.v1.FailureR\vlastFailure\x120\n" +
|
|
"\x14last_worker_identity\x18\r \x01(\tR\x12lastWorkerIdentity\x12W\n" +
|
|
"\x0fversion_history\x18\x0e \x01(\v2..temporal.server.api.history.v1.VersionHistoryR\x0eversionHistory\x12b\n" +
|
|
"\x13base_execution_info\x18\x0f \x01(\v22.temporal.server.api.workflow.v1.BaseExecutionInfoR\x11baseExecutionInfo\x121\n" +
|
|
"\x15last_started_build_id\x18\x10 \x01(\tR\x12lastStartedBuildId\x12A\n" +
|
|
"\x1dlast_started_redirect_counter\x18\x11 \x01(\x03R\x1alastStartedRedirectCounter\x12L\n" +
|
|
"\x14first_scheduled_time\x18\x12 \x01(\v2\x1a.google.protobuf.TimestampR\x12firstScheduledTime\x12W\n" +
|
|
"\x1alast_attempt_complete_time\x18\x13 \x01(\v2\x1a.google.protobuf.TimestampR\x17lastAttemptCompleteTime\x12\x14\n" +
|
|
"\x05stamp\x18\x14 \x01(\x05R\x05stamp\x12\x16\n" +
|
|
"\x06paused\x18\x15 \x01(\bR\x06paused\x12O\n" +
|
|
"\x16retry_initial_interval\x18\x16 \x01(\v2\x19.google.protobuf.DurationR\x14retryInitialInterval\x12O\n" +
|
|
"\x16retry_maximum_interval\x18\x17 \x01(\v2\x19.google.protobuf.DurationR\x14retryMaximumInterval\x124\n" +
|
|
"\x16retry_maximum_attempts\x18\x18 \x01(\x05R\x14retryMaximumAttempts\x12:\n" +
|
|
"\x19retry_backoff_coefficient\x18\x19 \x01(\x01R\x17retryBackoffCoefficient\"\xad\x04\n" +
|
|
"\x15HistoryTaskAttributes\x12!\n" +
|
|
"\fnamespace_id\x18\x02 \x01(\tR\vnamespaceId\x12\x1f\n" +
|
|
"\vworkflow_id\x18\x03 \x01(\tR\n" +
|
|
"workflowId\x12\x15\n" +
|
|
"\x06run_id\x18\x04 \x01(\tR\x05runId\x12f\n" +
|
|
"\x15version_history_items\x18\x05 \x03(\v22.temporal.server.api.history.v1.VersionHistoryItemR\x13versionHistoryItems\x128\n" +
|
|
"\x06events\x18\x06 \x01(\v2 .temporal.api.common.v1.DataBlobR\x06events\x12F\n" +
|
|
"\x0enew_run_events\x18\a \x01(\v2 .temporal.api.common.v1.DataBlobR\fnewRunEvents\x12b\n" +
|
|
"\x13base_execution_info\x18\b \x01(\v22.temporal.server.api.workflow.v1.BaseExecutionInfoR\x11baseExecutionInfo\x12\x1c\n" +
|
|
"\n" +
|
|
"new_run_id\x18\t \x01(\tR\bnewRunId\x12G\n" +
|
|
"\x0eevents_batches\x18\n" +
|
|
" \x03(\v2 .temporal.api.common.v1.DataBlobR\reventsBatchesJ\x04\b\x01\x10\x02\"\x82\x01\n" +
|
|
"\x1fSyncWorkflowStateTaskAttributes\x12_\n" +
|
|
"\x0eworkflow_state\x18\x01 \x01(\v28.temporal.server.api.persistence.v1.WorkflowMutableStateR\rworkflowState\"\xbc\x01\n" +
|
|
"\x1bTaskQueueUserDataAttributes\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12&\n" +
|
|
"\x0ftask_queue_name\x18\x02 \x01(\tR\rtaskQueueName\x12R\n" +
|
|
"\tuser_data\x18\x03 \x01(\v25.temporal.server.api.persistence.v1.TaskQueueUserDataR\buserData\"\xab\x02\n" +
|
|
"\x11SyncHSMAttributes\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1f\n" +
|
|
"\vworkflow_id\x18\x02 \x01(\tR\n" +
|
|
"workflowId\x12\x15\n" +
|
|
"\x06run_id\x18\x03 \x01(\tR\x05runId\x12W\n" +
|
|
"\x0fversion_history\x18\x04 \x01(\v2..temporal.server.api.history.v1.VersionHistoryR\x0eversionHistory\x12b\n" +
|
|
"\x12state_machine_node\x18\x05 \x01(\v24.temporal.server.api.persistence.v1.StateMachineNodeR\x10stateMachineNode\"\xfb\x02\n" +
|
|
"\x1dBackfillHistoryTaskAttributes\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1f\n" +
|
|
"\vworkflow_id\x18\x02 \x01(\tR\n" +
|
|
"workflowId\x12\x15\n" +
|
|
"\x06run_id\x18\x03 \x01(\tR\x05runId\x12f\n" +
|
|
"\x15event_version_history\x18\x05 \x03(\v22.temporal.server.api.history.v1.VersionHistoryItemR\x13eventVersionHistory\x12E\n" +
|
|
"\revent_batches\x18\x06 \x03(\v2 .temporal.api.common.v1.DataBlobR\feventBatches\x12P\n" +
|
|
"\fnew_run_info\x18\a \x01(\v2..temporal.server.api.replication.v1.NewRunInfoR\n" +
|
|
"newRunInfo\"f\n" +
|
|
"\n" +
|
|
"NewRunInfo\x12\x15\n" +
|
|
"\x06run_id\x18\x01 \x01(\tR\x05runId\x12A\n" +
|
|
"\vevent_batch\x18\x02 \x01(\v2 .temporal.api.common.v1.DataBlobR\n" +
|
|
"eventBatch\"\x99\x02\n" +
|
|
"#SyncWorkflowStateMutationAttributes\x12\x88\x01\n" +
|
|
"$exclusive_start_versioned_transition\x18\x01 \x01(\v27.temporal.server.api.persistence.v1.VersionedTransitionR!exclusiveStartVersionedTransition\x12g\n" +
|
|
"\x0estate_mutation\x18\x02 \x01(\v2@.temporal.server.api.persistence.v1.WorkflowMutableStateMutationR\rstateMutation\"u\n" +
|
|
"#SyncWorkflowStateSnapshotAttributes\x12N\n" +
|
|
"\x05state\x18\x01 \x01(\v28.temporal.server.api.persistence.v1.WorkflowMutableStateR\x05state\"\xae\x02\n" +
|
|
"'VerifyVersionedTransitionTaskAttributes\x12!\n" +
|
|
"\fnamespace_id\x18\x01 \x01(\tR\vnamespaceId\x12\x1f\n" +
|
|
"\vworkflow_id\x18\x02 \x01(\tR\n" +
|
|
"workflowId\x12\x15\n" +
|
|
"\x06run_id\x18\x03 \x01(\tR\x05runId\x12\"\n" +
|
|
"\rnext_event_id\x18\x04 \x01(\x03R\vnextEventId\x12f\n" +
|
|
"\x15event_version_history\x18\x05 \x03(\v22.temporal.server.api.history.v1.VersionHistoryItemR\x13eventVersionHistory\x12\x1c\n" +
|
|
"\n" +
|
|
"new_run_id\x18\x06 \x01(\tR\bnewRunId\"\xa0\x02\n" +
|
|
"%SyncVersionedTransitionTaskAttributes\x12\x83\x01\n" +
|
|
"\x1dversioned_transition_artifact\x18\x05 \x01(\v2?.temporal.server.api.replication.v1.VersionedTransitionArtifactR\x1bversionedTransitionArtifact\x12!\n" +
|
|
"\fnamespace_id\x18\x06 \x01(\tR\vnamespaceId\x12\x1f\n" +
|
|
"\vworkflow_id\x18\a \x01(\tR\n" +
|
|
"workflowId\x12\x15\n" +
|
|
"\x06run_id\x18\b \x01(\tR\x05runIdJ\x04\b\x01\x10\x02J\x04\b\x02\x10\x03J\x04\b\x03\x10\x04J\x04\b\x04\x10\x05\"\xb2\x04\n" +
|
|
"\x1bVersionedTransitionArtifact\x12\x9f\x01\n" +
|
|
"'sync_workflow_state_mutation_attributes\x18\x01 \x01(\v2G.temporal.server.api.replication.v1.SyncWorkflowStateMutationAttributesH\x00R#syncWorkflowStateMutationAttributes\x12\x9f\x01\n" +
|
|
"'sync_workflow_state_snapshot_attributes\x18\x02 \x01(\v2G.temporal.server.api.replication.v1.SyncWorkflowStateSnapshotAttributesH\x00R#syncWorkflowStateSnapshotAttributes\x12E\n" +
|
|
"\revent_batches\x18\x03 \x03(\v2 .temporal.api.common.v1.DataBlobR\feventBatches\x12P\n" +
|
|
"\fnew_run_info\x18\x04 \x01(\v2..temporal.server.api.replication.v1.NewRunInfoR\n" +
|
|
"newRunInfo\x12\"\n" +
|
|
"\ris_first_sync\x18\x05 \x01(\bR\visFirstSyncB\x12\n" +
|
|
"\x10state_attributesB5Z3go.temporal.io/server/api/replication/v1;repicationb\x06proto3"
|
|
|
|
var (
|
|
file_temporal_server_api_replication_v1_message_proto_rawDescOnce sync.Once
|
|
file_temporal_server_api_replication_v1_message_proto_rawDescData []byte
|
|
)
|
|
|
|
func file_temporal_server_api_replication_v1_message_proto_rawDescGZIP() []byte {
|
|
file_temporal_server_api_replication_v1_message_proto_rawDescOnce.Do(func() {
|
|
file_temporal_server_api_replication_v1_message_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_temporal_server_api_replication_v1_message_proto_rawDesc), len(file_temporal_server_api_replication_v1_message_proto_rawDesc)))
|
|
})
|
|
return file_temporal_server_api_replication_v1_message_proto_rawDescData
|
|
}
|
|
|
|
var file_temporal_server_api_replication_v1_message_proto_msgTypes = make([]protoimpl.MessageInfo, 22)
|
|
var file_temporal_server_api_replication_v1_message_proto_goTypes = []any{
|
|
(*ReplicationTask)(nil), // 0: temporal.server.api.replication.v1.ReplicationTask
|
|
(*ReplicationToken)(nil), // 1: temporal.server.api.replication.v1.ReplicationToken
|
|
(*SyncShardStatus)(nil), // 2: temporal.server.api.replication.v1.SyncShardStatus
|
|
(*SyncReplicationState)(nil), // 3: temporal.server.api.replication.v1.SyncReplicationState
|
|
(*ReplicationState)(nil), // 4: temporal.server.api.replication.v1.ReplicationState
|
|
(*ReplicationMessages)(nil), // 5: temporal.server.api.replication.v1.ReplicationMessages
|
|
(*WorkflowReplicationMessages)(nil), // 6: temporal.server.api.replication.v1.WorkflowReplicationMessages
|
|
(*ReplicationTaskInfo)(nil), // 7: temporal.server.api.replication.v1.ReplicationTaskInfo
|
|
(*NamespaceTaskAttributes)(nil), // 8: temporal.server.api.replication.v1.NamespaceTaskAttributes
|
|
(*SyncShardStatusTaskAttributes)(nil), // 9: temporal.server.api.replication.v1.SyncShardStatusTaskAttributes
|
|
(*SyncActivityTaskAttributes)(nil), // 10: temporal.server.api.replication.v1.SyncActivityTaskAttributes
|
|
(*HistoryTaskAttributes)(nil), // 11: temporal.server.api.replication.v1.HistoryTaskAttributes
|
|
(*SyncWorkflowStateTaskAttributes)(nil), // 12: temporal.server.api.replication.v1.SyncWorkflowStateTaskAttributes
|
|
(*TaskQueueUserDataAttributes)(nil), // 13: temporal.server.api.replication.v1.TaskQueueUserDataAttributes
|
|
(*SyncHSMAttributes)(nil), // 14: temporal.server.api.replication.v1.SyncHSMAttributes
|
|
(*BackfillHistoryTaskAttributes)(nil), // 15: temporal.server.api.replication.v1.BackfillHistoryTaskAttributes
|
|
(*NewRunInfo)(nil), // 16: temporal.server.api.replication.v1.NewRunInfo
|
|
(*SyncWorkflowStateMutationAttributes)(nil), // 17: temporal.server.api.replication.v1.SyncWorkflowStateMutationAttributes
|
|
(*SyncWorkflowStateSnapshotAttributes)(nil), // 18: temporal.server.api.replication.v1.SyncWorkflowStateSnapshotAttributes
|
|
(*VerifyVersionedTransitionTaskAttributes)(nil), // 19: temporal.server.api.replication.v1.VerifyVersionedTransitionTaskAttributes
|
|
(*SyncVersionedTransitionTaskAttributes)(nil), // 20: temporal.server.api.replication.v1.SyncVersionedTransitionTaskAttributes
|
|
(*VersionedTransitionArtifact)(nil), // 21: temporal.server.api.replication.v1.VersionedTransitionArtifact
|
|
(v1.ReplicationTaskType)(0), // 22: temporal.server.api.enums.v1.ReplicationTaskType
|
|
(*v11.DataBlob)(nil), // 23: temporal.api.common.v1.DataBlob
|
|
(*timestamppb.Timestamp)(nil), // 24: google.protobuf.Timestamp
|
|
(v1.TaskPriority)(0), // 25: temporal.server.api.enums.v1.TaskPriority
|
|
(*v12.VersionedTransition)(nil), // 26: temporal.server.api.persistence.v1.VersionedTransition
|
|
(*v12.ReplicationTaskInfo)(nil), // 27: temporal.server.api.persistence.v1.ReplicationTaskInfo
|
|
(v1.ReplicationFlowControlCommand)(0), // 28: temporal.server.api.enums.v1.ReplicationFlowControlCommand
|
|
(v1.TaskType)(0), // 29: temporal.server.api.enums.v1.TaskType
|
|
(v1.NamespaceOperation)(0), // 30: temporal.server.api.enums.v1.NamespaceOperation
|
|
(*v13.NamespaceInfo)(nil), // 31: temporal.api.namespace.v1.NamespaceInfo
|
|
(*v13.NamespaceConfig)(nil), // 32: temporal.api.namespace.v1.NamespaceConfig
|
|
(*v14.NamespaceReplicationConfig)(nil), // 33: temporal.api.replication.v1.NamespaceReplicationConfig
|
|
(*v14.FailoverStatus)(nil), // 34: temporal.api.replication.v1.FailoverStatus
|
|
(*v11.Payloads)(nil), // 35: temporal.api.common.v1.Payloads
|
|
(*v15.Failure)(nil), // 36: temporal.api.failure.v1.Failure
|
|
(*v16.VersionHistory)(nil), // 37: temporal.server.api.history.v1.VersionHistory
|
|
(*v17.BaseExecutionInfo)(nil), // 38: temporal.server.api.workflow.v1.BaseExecutionInfo
|
|
(*durationpb.Duration)(nil), // 39: google.protobuf.Duration
|
|
(*v16.VersionHistoryItem)(nil), // 40: temporal.server.api.history.v1.VersionHistoryItem
|
|
(*v12.WorkflowMutableState)(nil), // 41: temporal.server.api.persistence.v1.WorkflowMutableState
|
|
(*v12.TaskQueueUserData)(nil), // 42: temporal.server.api.persistence.v1.TaskQueueUserData
|
|
(*v12.StateMachineNode)(nil), // 43: temporal.server.api.persistence.v1.StateMachineNode
|
|
(*v12.WorkflowMutableStateMutation)(nil), // 44: temporal.server.api.persistence.v1.WorkflowMutableStateMutation
|
|
}
|
|
var file_temporal_server_api_replication_v1_message_proto_depIdxs = []int32{
|
|
22, // 0: temporal.server.api.replication.v1.ReplicationTask.task_type:type_name -> temporal.server.api.enums.v1.ReplicationTaskType
|
|
8, // 1: temporal.server.api.replication.v1.ReplicationTask.namespace_task_attributes:type_name -> temporal.server.api.replication.v1.NamespaceTaskAttributes
|
|
9, // 2: temporal.server.api.replication.v1.ReplicationTask.sync_shard_status_task_attributes:type_name -> temporal.server.api.replication.v1.SyncShardStatusTaskAttributes
|
|
10, // 3: temporal.server.api.replication.v1.ReplicationTask.sync_activity_task_attributes:type_name -> temporal.server.api.replication.v1.SyncActivityTaskAttributes
|
|
11, // 4: temporal.server.api.replication.v1.ReplicationTask.history_task_attributes:type_name -> temporal.server.api.replication.v1.HistoryTaskAttributes
|
|
12, // 5: temporal.server.api.replication.v1.ReplicationTask.sync_workflow_state_task_attributes:type_name -> temporal.server.api.replication.v1.SyncWorkflowStateTaskAttributes
|
|
13, // 6: temporal.server.api.replication.v1.ReplicationTask.task_queue_user_data_attributes:type_name -> temporal.server.api.replication.v1.TaskQueueUserDataAttributes
|
|
14, // 7: temporal.server.api.replication.v1.ReplicationTask.sync_hsm_attributes:type_name -> temporal.server.api.replication.v1.SyncHSMAttributes
|
|
15, // 8: temporal.server.api.replication.v1.ReplicationTask.backfill_history_task_attributes:type_name -> temporal.server.api.replication.v1.BackfillHistoryTaskAttributes
|
|
19, // 9: temporal.server.api.replication.v1.ReplicationTask.verify_versioned_transition_task_attributes:type_name -> temporal.server.api.replication.v1.VerifyVersionedTransitionTaskAttributes
|
|
20, // 10: temporal.server.api.replication.v1.ReplicationTask.sync_versioned_transition_task_attributes:type_name -> temporal.server.api.replication.v1.SyncVersionedTransitionTaskAttributes
|
|
23, // 11: temporal.server.api.replication.v1.ReplicationTask.data:type_name -> temporal.api.common.v1.DataBlob
|
|
24, // 12: temporal.server.api.replication.v1.ReplicationTask.visibility_time:type_name -> google.protobuf.Timestamp
|
|
25, // 13: temporal.server.api.replication.v1.ReplicationTask.priority:type_name -> temporal.server.api.enums.v1.TaskPriority
|
|
26, // 14: temporal.server.api.replication.v1.ReplicationTask.versioned_transition:type_name -> temporal.server.api.persistence.v1.VersionedTransition
|
|
27, // 15: temporal.server.api.replication.v1.ReplicationTask.raw_task_info:type_name -> temporal.server.api.persistence.v1.ReplicationTaskInfo
|
|
24, // 16: temporal.server.api.replication.v1.ReplicationToken.last_processed_visibility_time:type_name -> google.protobuf.Timestamp
|
|
24, // 17: temporal.server.api.replication.v1.SyncShardStatus.status_time:type_name -> google.protobuf.Timestamp
|
|
24, // 18: temporal.server.api.replication.v1.SyncReplicationState.inclusive_low_watermark_time:type_name -> google.protobuf.Timestamp
|
|
4, // 19: temporal.server.api.replication.v1.SyncReplicationState.high_priority_state:type_name -> temporal.server.api.replication.v1.ReplicationState
|
|
4, // 20: temporal.server.api.replication.v1.SyncReplicationState.low_priority_state:type_name -> temporal.server.api.replication.v1.ReplicationState
|
|
24, // 21: temporal.server.api.replication.v1.ReplicationState.inclusive_low_watermark_time:type_name -> google.protobuf.Timestamp
|
|
28, // 22: temporal.server.api.replication.v1.ReplicationState.flow_control_command:type_name -> temporal.server.api.enums.v1.ReplicationFlowControlCommand
|
|
0, // 23: temporal.server.api.replication.v1.ReplicationMessages.replication_tasks:type_name -> temporal.server.api.replication.v1.ReplicationTask
|
|
2, // 24: temporal.server.api.replication.v1.ReplicationMessages.sync_shard_status:type_name -> temporal.server.api.replication.v1.SyncShardStatus
|
|
0, // 25: temporal.server.api.replication.v1.WorkflowReplicationMessages.replication_tasks:type_name -> temporal.server.api.replication.v1.ReplicationTask
|
|
24, // 26: temporal.server.api.replication.v1.WorkflowReplicationMessages.exclusive_high_watermark_time:type_name -> google.protobuf.Timestamp
|
|
25, // 27: temporal.server.api.replication.v1.WorkflowReplicationMessages.priority:type_name -> temporal.server.api.enums.v1.TaskPriority
|
|
29, // 28: temporal.server.api.replication.v1.ReplicationTaskInfo.task_type:type_name -> temporal.server.api.enums.v1.TaskType
|
|
25, // 29: temporal.server.api.replication.v1.ReplicationTaskInfo.priority:type_name -> temporal.server.api.enums.v1.TaskPriority
|
|
30, // 30: temporal.server.api.replication.v1.NamespaceTaskAttributes.namespace_operation:type_name -> temporal.server.api.enums.v1.NamespaceOperation
|
|
31, // 31: temporal.server.api.replication.v1.NamespaceTaskAttributes.info:type_name -> temporal.api.namespace.v1.NamespaceInfo
|
|
32, // 32: temporal.server.api.replication.v1.NamespaceTaskAttributes.config:type_name -> temporal.api.namespace.v1.NamespaceConfig
|
|
33, // 33: temporal.server.api.replication.v1.NamespaceTaskAttributes.replication_config:type_name -> temporal.api.replication.v1.NamespaceReplicationConfig
|
|
34, // 34: temporal.server.api.replication.v1.NamespaceTaskAttributes.failover_history:type_name -> temporal.api.replication.v1.FailoverStatus
|
|
24, // 35: temporal.server.api.replication.v1.SyncShardStatusTaskAttributes.status_time:type_name -> google.protobuf.Timestamp
|
|
24, // 36: temporal.server.api.replication.v1.SyncActivityTaskAttributes.scheduled_time:type_name -> google.protobuf.Timestamp
|
|
24, // 37: temporal.server.api.replication.v1.SyncActivityTaskAttributes.started_time:type_name -> google.protobuf.Timestamp
|
|
24, // 38: temporal.server.api.replication.v1.SyncActivityTaskAttributes.last_heartbeat_time:type_name -> google.protobuf.Timestamp
|
|
35, // 39: temporal.server.api.replication.v1.SyncActivityTaskAttributes.details:type_name -> temporal.api.common.v1.Payloads
|
|
36, // 40: temporal.server.api.replication.v1.SyncActivityTaskAttributes.last_failure:type_name -> temporal.api.failure.v1.Failure
|
|
37, // 41: temporal.server.api.replication.v1.SyncActivityTaskAttributes.version_history:type_name -> temporal.server.api.history.v1.VersionHistory
|
|
38, // 42: temporal.server.api.replication.v1.SyncActivityTaskAttributes.base_execution_info:type_name -> temporal.server.api.workflow.v1.BaseExecutionInfo
|
|
24, // 43: temporal.server.api.replication.v1.SyncActivityTaskAttributes.first_scheduled_time:type_name -> google.protobuf.Timestamp
|
|
24, // 44: temporal.server.api.replication.v1.SyncActivityTaskAttributes.last_attempt_complete_time:type_name -> google.protobuf.Timestamp
|
|
39, // 45: temporal.server.api.replication.v1.SyncActivityTaskAttributes.retry_initial_interval:type_name -> google.protobuf.Duration
|
|
39, // 46: temporal.server.api.replication.v1.SyncActivityTaskAttributes.retry_maximum_interval:type_name -> google.protobuf.Duration
|
|
40, // 47: temporal.server.api.replication.v1.HistoryTaskAttributes.version_history_items:type_name -> temporal.server.api.history.v1.VersionHistoryItem
|
|
23, // 48: temporal.server.api.replication.v1.HistoryTaskAttributes.events:type_name -> temporal.api.common.v1.DataBlob
|
|
23, // 49: temporal.server.api.replication.v1.HistoryTaskAttributes.new_run_events:type_name -> temporal.api.common.v1.DataBlob
|
|
38, // 50: temporal.server.api.replication.v1.HistoryTaskAttributes.base_execution_info:type_name -> temporal.server.api.workflow.v1.BaseExecutionInfo
|
|
23, // 51: temporal.server.api.replication.v1.HistoryTaskAttributes.events_batches:type_name -> temporal.api.common.v1.DataBlob
|
|
41, // 52: temporal.server.api.replication.v1.SyncWorkflowStateTaskAttributes.workflow_state:type_name -> temporal.server.api.persistence.v1.WorkflowMutableState
|
|
42, // 53: temporal.server.api.replication.v1.TaskQueueUserDataAttributes.user_data:type_name -> temporal.server.api.persistence.v1.TaskQueueUserData
|
|
37, // 54: temporal.server.api.replication.v1.SyncHSMAttributes.version_history:type_name -> temporal.server.api.history.v1.VersionHistory
|
|
43, // 55: temporal.server.api.replication.v1.SyncHSMAttributes.state_machine_node:type_name -> temporal.server.api.persistence.v1.StateMachineNode
|
|
40, // 56: temporal.server.api.replication.v1.BackfillHistoryTaskAttributes.event_version_history:type_name -> temporal.server.api.history.v1.VersionHistoryItem
|
|
23, // 57: temporal.server.api.replication.v1.BackfillHistoryTaskAttributes.event_batches:type_name -> temporal.api.common.v1.DataBlob
|
|
16, // 58: temporal.server.api.replication.v1.BackfillHistoryTaskAttributes.new_run_info:type_name -> temporal.server.api.replication.v1.NewRunInfo
|
|
23, // 59: temporal.server.api.replication.v1.NewRunInfo.event_batch:type_name -> temporal.api.common.v1.DataBlob
|
|
26, // 60: temporal.server.api.replication.v1.SyncWorkflowStateMutationAttributes.exclusive_start_versioned_transition:type_name -> temporal.server.api.persistence.v1.VersionedTransition
|
|
44, // 61: temporal.server.api.replication.v1.SyncWorkflowStateMutationAttributes.state_mutation:type_name -> temporal.server.api.persistence.v1.WorkflowMutableStateMutation
|
|
41, // 62: temporal.server.api.replication.v1.SyncWorkflowStateSnapshotAttributes.state:type_name -> temporal.server.api.persistence.v1.WorkflowMutableState
|
|
40, // 63: temporal.server.api.replication.v1.VerifyVersionedTransitionTaskAttributes.event_version_history:type_name -> temporal.server.api.history.v1.VersionHistoryItem
|
|
21, // 64: temporal.server.api.replication.v1.SyncVersionedTransitionTaskAttributes.versioned_transition_artifact:type_name -> temporal.server.api.replication.v1.VersionedTransitionArtifact
|
|
17, // 65: temporal.server.api.replication.v1.VersionedTransitionArtifact.sync_workflow_state_mutation_attributes:type_name -> temporal.server.api.replication.v1.SyncWorkflowStateMutationAttributes
|
|
18, // 66: temporal.server.api.replication.v1.VersionedTransitionArtifact.sync_workflow_state_snapshot_attributes:type_name -> temporal.server.api.replication.v1.SyncWorkflowStateSnapshotAttributes
|
|
23, // 67: temporal.server.api.replication.v1.VersionedTransitionArtifact.event_batches:type_name -> temporal.api.common.v1.DataBlob
|
|
16, // 68: temporal.server.api.replication.v1.VersionedTransitionArtifact.new_run_info:type_name -> temporal.server.api.replication.v1.NewRunInfo
|
|
69, // [69:69] is the sub-list for method output_type
|
|
69, // [69:69] is the sub-list for method input_type
|
|
69, // [69:69] is the sub-list for extension type_name
|
|
69, // [69:69] is the sub-list for extension extendee
|
|
0, // [0:69] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_temporal_server_api_replication_v1_message_proto_init() }
|
|
func file_temporal_server_api_replication_v1_message_proto_init() {
|
|
if File_temporal_server_api_replication_v1_message_proto != nil {
|
|
return
|
|
}
|
|
file_temporal_server_api_replication_v1_message_proto_msgTypes[0].OneofWrappers = []any{
|
|
(*ReplicationTask_NamespaceTaskAttributes)(nil),
|
|
(*ReplicationTask_SyncShardStatusTaskAttributes)(nil),
|
|
(*ReplicationTask_SyncActivityTaskAttributes)(nil),
|
|
(*ReplicationTask_HistoryTaskAttributes)(nil),
|
|
(*ReplicationTask_SyncWorkflowStateTaskAttributes)(nil),
|
|
(*ReplicationTask_TaskQueueUserDataAttributes)(nil),
|
|
(*ReplicationTask_SyncHsmAttributes)(nil),
|
|
(*ReplicationTask_BackfillHistoryTaskAttributes)(nil),
|
|
(*ReplicationTask_VerifyVersionedTransitionTaskAttributes)(nil),
|
|
(*ReplicationTask_SyncVersionedTransitionTaskAttributes)(nil),
|
|
}
|
|
file_temporal_server_api_replication_v1_message_proto_msgTypes[21].OneofWrappers = []any{
|
|
(*VersionedTransitionArtifact_SyncWorkflowStateMutationAttributes)(nil),
|
|
(*VersionedTransitionArtifact_SyncWorkflowStateSnapshotAttributes)(nil),
|
|
}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_replication_v1_message_proto_rawDesc), len(file_temporal_server_api_replication_v1_message_proto_rawDesc)),
|
|
NumEnums: 0,
|
|
NumMessages: 22,
|
|
NumExtensions: 0,
|
|
NumServices: 0,
|
|
},
|
|
GoTypes: file_temporal_server_api_replication_v1_message_proto_goTypes,
|
|
DependencyIndexes: file_temporal_server_api_replication_v1_message_proto_depIdxs,
|
|
MessageInfos: file_temporal_server_api_replication_v1_message_proto_msgTypes,
|
|
}.Build()
|
|
File_temporal_server_api_replication_v1_message_proto = out.File
|
|
file_temporal_server_api_replication_v1_message_proto_goTypes = nil
|
|
file_temporal_server_api_replication_v1_message_proto_depIdxs = nil
|
|
}
|