replication

Documentation

Index

• Variables
• type ClusterReplicationConfig
  • func (*ClusterReplicationConfig) Descriptor() ([]byte, []int)
  • func (this *ClusterReplicationConfig) Equal(that interface{}) bool
  • func (m *ClusterReplicationConfig) GetClusterName() string
  • func (this *ClusterReplicationConfig) GoString() string
  • func (m *ClusterReplicationConfig) Marshal() (dAtA []byte, err error)
  • func (m *ClusterReplicationConfig) MarshalTo(dAtA []byte) (int, error)
  • func (m *ClusterReplicationConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ClusterReplicationConfig) ProtoMessage()
  • func (m *ClusterReplicationConfig) Reset()
  • func (m *ClusterReplicationConfig) Size() (n int)
  • func (this *ClusterReplicationConfig) String() string
  • func (m *ClusterReplicationConfig) Unmarshal(dAtA []byte) error
  • func (m *ClusterReplicationConfig) XXX_DiscardUnknown()
  • func (m *ClusterReplicationConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ClusterReplicationConfig) XXX_Merge(src proto.Message)
  • func (m *ClusterReplicationConfig) XXX_Size() int
  • func (m *ClusterReplicationConfig) XXX_Unmarshal(b []byte) error
• type NamespaceReplicationConfig
  • func (*NamespaceReplicationConfig) Descriptor() ([]byte, []int)
  • func (this *NamespaceReplicationConfig) Equal(that interface{}) bool
  • func (m *NamespaceReplicationConfig) GetActiveClusterName() string
  • func (m *NamespaceReplicationConfig) GetClusters() []*ClusterReplicationConfig
  • func (m *NamespaceReplicationConfig) GetState() v1.ReplicationState
  • func (this *NamespaceReplicationConfig) GoString() string
  • func (m *NamespaceReplicationConfig) Marshal() (dAtA []byte, err error)
  • func (m *NamespaceReplicationConfig) MarshalTo(dAtA []byte) (int, error)
  • func (m *NamespaceReplicationConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*NamespaceReplicationConfig) ProtoMessage()
  • func (m *NamespaceReplicationConfig) Reset()
  • func (m *NamespaceReplicationConfig) Size() (n int)
  • func (this *NamespaceReplicationConfig) String() string
  • func (m *NamespaceReplicationConfig) Unmarshal(dAtA []byte) error
  • func (m *NamespaceReplicationConfig) XXX_DiscardUnknown()
  • func (m *NamespaceReplicationConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *NamespaceReplicationConfig) XXX_Merge(src proto.Message)
  • func (m *NamespaceReplicationConfig) XXX_Size() int
  • func (m *NamespaceReplicationConfig) XXX_Unmarshal(b []byte) error

Variables

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

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

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