replication

package
v1.25.0 Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2023 License: MIT Imports: 11 Imported by: 19

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type ClusterReplicationConfig 

type ClusterReplicationConfig struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
}

func (*ClusterReplicationConfig) Descriptor 

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

func (*ClusterReplicationConfig) Equal 

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

func (*ClusterReplicationConfig) GetClusterName 

func (m *ClusterReplicationConfig) GetClusterName() string

func (*ClusterReplicationConfig) GoString 

func (this *ClusterReplicationConfig) GoString() string

func (*ClusterReplicationConfig) Marshal 

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

func (*ClusterReplicationConfig) MarshalTo 

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

func (*ClusterReplicationConfig) MarshalToSizedBuffer 

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

func (*ClusterReplicationConfig) ProtoMessage 

func (*ClusterReplicationConfig) ProtoMessage()

func (*ClusterReplicationConfig) Reset 

func (m *ClusterReplicationConfig) Reset()

func (*ClusterReplicationConfig) Size 

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

func (*ClusterReplicationConfig) String 

func (this *ClusterReplicationConfig) String() string

func (*ClusterReplicationConfig) Unmarshal 

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

func (*ClusterReplicationConfig) XXX_DiscardUnknown 

func (m *ClusterReplicationConfig) XXX_DiscardUnknown()

func (*ClusterReplicationConfig) XXX_Marshal 

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

func (*ClusterReplicationConfig) XXX_Merge 

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

func (*ClusterReplicationConfig) XXX_Size 

func (m *ClusterReplicationConfig) XXX_Size() int

func (*ClusterReplicationConfig) XXX_Unmarshal 

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

type FailoverStatus added in v1.11.0 

type FailoverStatus struct {
	// Timestamp when the Cluster switched to the following failover_version
	FailoverTime    *time.Time `protobuf:"bytes,1,opt,name=failover_time,json=failoverTime,proto3,stdtime" json:"failover_time,omitempty"`
	FailoverVersion int64      `protobuf:"varint,2,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
}

Represents a historical replication status of a Namespace

func (*FailoverStatus) Descriptor added in v1.11.0 

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

func (*FailoverStatus) Equal added in v1.11.0 

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

func (*FailoverStatus) GetFailoverTime added in v1.11.0 

func (m *FailoverStatus) GetFailoverTime() *time.Time

func (*FailoverStatus) GetFailoverVersion added in v1.11.0 

func (m *FailoverStatus) GetFailoverVersion() int64

func (*FailoverStatus) GoString added in v1.11.0 

func (this *FailoverStatus) GoString() string

func (*FailoverStatus) Marshal added in v1.11.0 

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

func (*FailoverStatus) MarshalTo added in v1.11.0 

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

func (*FailoverStatus) MarshalToSizedBuffer added in v1.11.0 

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

func (*FailoverStatus) ProtoMessage added in v1.11.0 

func (*FailoverStatus) ProtoMessage()

func (*FailoverStatus) Reset added in v1.11.0 

func (m *FailoverStatus) Reset()

func (*FailoverStatus) Size added in v1.11.0 

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

func (*FailoverStatus) String added in v1.11.0 

func (this *FailoverStatus) String() string

func (*FailoverStatus) Unmarshal added in v1.11.0 

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

func (*FailoverStatus) XXX_DiscardUnknown added in v1.11.0 

func (m *FailoverStatus) XXX_DiscardUnknown()

func (*FailoverStatus) XXX_Marshal added in v1.11.0 

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

func (*FailoverStatus) XXX_Merge added in v1.11.0 

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

func (*FailoverStatus) XXX_Size added in v1.11.0 

func (m *FailoverStatus) XXX_Size() int

func (*FailoverStatus) XXX_Unmarshal added in v1.11.0 

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

type NamespaceReplicationConfig 

type NamespaceReplicationConfig struct {
	ActiveClusterName string                      `protobuf:"bytes,1,opt,name=active_cluster_name,json=activeClusterName,proto3" json:"active_cluster_name,omitempty"`
	Clusters          []*ClusterReplicationConfig `protobuf:"bytes,2,rep,name=clusters,proto3" json:"clusters,omitempty"`
	State             v1.ReplicationState         `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.enums.v1.ReplicationState" json:"state,omitempty"`
}

func (*NamespaceReplicationConfig) Descriptor 

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

func (*NamespaceReplicationConfig) Equal 

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

func (*NamespaceReplicationConfig) GetActiveClusterName 

func (m *NamespaceReplicationConfig) GetActiveClusterName() string

func (*NamespaceReplicationConfig) GetClusters 

func (m *NamespaceReplicationConfig) GetClusters() []*ClusterReplicationConfig

func (*NamespaceReplicationConfig) GetState added in v1.7.0 

func (m *NamespaceReplicationConfig) GetState() v1.ReplicationState

func (*NamespaceReplicationConfig) GoString 

func (this *NamespaceReplicationConfig) GoString() string

func (*NamespaceReplicationConfig) Marshal 

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

func (*NamespaceReplicationConfig) MarshalTo 

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

func (*NamespaceReplicationConfig) MarshalToSizedBuffer 

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

func (*NamespaceReplicationConfig) ProtoMessage 

func (*NamespaceReplicationConfig) ProtoMessage()

func (*NamespaceReplicationConfig) Reset 

func (m *NamespaceReplicationConfig) Reset()

func (*NamespaceReplicationConfig) Size 

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

func (*NamespaceReplicationConfig) String 

func (this *NamespaceReplicationConfig) String() string

func (*NamespaceReplicationConfig) Unmarshal 

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

func (*NamespaceReplicationConfig) XXX_DiscardUnknown 

func (m *NamespaceReplicationConfig) XXX_DiscardUnknown()

func (*NamespaceReplicationConfig) XXX_Marshal 

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

func (*NamespaceReplicationConfig) XXX_Merge 

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

func (*NamespaceReplicationConfig) XXX_Size 

func (m *NamespaceReplicationConfig) XXX_Size() int

func (*NamespaceReplicationConfig) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.