Versions in this module Expand all Collapse all v0 v0.1.0 Mar 12, 2021 Changes in this version + var Action_name = map[int32]string + var Action_value = map[string]int32 + var ChangePeerType_name = map[int32]string + var ChangePeerType_value = map[string]int32 + var CheckPolicy_name = map[int32]string + var CheckPolicy_value = map[string]int32 + var ContainerState_name = map[int32]string + var ContainerState_value = map[string]int32 + var ErrIntOverflowMetapb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMetapb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupMetapb = fmt.Errorf("proto: unexpected end of group") + var OperatorStatus_name = map[int32]string + var OperatorStatus_value = map[string]int32 + var PeerRole_name = map[int32]string + var PeerRole_value = map[string]int32 + var ResourceKind_name = map[int32]string + var ResourceKind_value = map[string]int32 + type Action int32 + const Action_None + const Action_ScaleOut + func (Action) EnumDescriptor() ([]byte, []int) + func (x Action) String() string + type ChangePeerType int32 + const ChangePeerType_AddLearnerNode + const ChangePeerType_AddNode + const ChangePeerType_RemoveNode + const ChangePeerType_ScalePeer + func (ChangePeerType) EnumDescriptor() ([]byte, []int) + func (x ChangePeerType) String() string + type CheckPolicy int32 + const CheckPolicy_APPROXIMATE + const CheckPolicy_SCAN + const CheckPolicy_USEKEY + func (CheckPolicy) EnumDescriptor() ([]byte, []int) + func (x CheckPolicy) String() string + type Cluster struct + ID uint64 + MaxPeerCount uint32 + func (*Cluster) Descriptor() ([]byte, []int) + func (*Cluster) ProtoMessage() + func (m *Cluster) GetID() uint64 + func (m *Cluster) GetMaxPeerCount() uint32 + func (m *Cluster) Marshal() (dAtA []byte, err error) + func (m *Cluster) MarshalTo(dAtA []byte) (int, error) + func (m *Cluster) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Cluster) Reset() + func (m *Cluster) Size() (n int) + func (m *Cluster) String() string + func (m *Cluster) Unmarshal(dAtA []byte) error + func (m *Cluster) XXX_DiscardUnknown() + func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Cluster) XXX_Merge(src proto.Message) + func (m *Cluster) XXX_Size() int + func (m *Cluster) XXX_Unmarshal(b []byte) error + type ContainerState int32 + const ContainerState_Offline + const ContainerState_Tombstone + const ContainerState_UP + func (ContainerState) EnumDescriptor() ([]byte, []int) + func (x ContainerState) String() string + type Member struct + Addr string + ID uint64 + Name string + func (*Member) Descriptor() ([]byte, []int) + func (*Member) ProtoMessage() + func (m *Member) GetAddr() string + func (m *Member) GetID() uint64 + func (m *Member) GetName() string + func (m *Member) Marshal() (dAtA []byte, err error) + func (m *Member) MarshalTo(dAtA []byte) (int, error) + func (m *Member) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Member) Reset() + func (m *Member) Size() (n int) + func (m *Member) String() string + func (m *Member) Unmarshal(dAtA []byte) error + func (m *Member) XXX_DiscardUnknown() + func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Member) XXX_Merge(src proto.Message) + func (m *Member) XXX_Size() int + func (m *Member) XXX_Unmarshal(b []byte) error + type OperatorStatus int32 + const OperatorStatus_CANCEL + const OperatorStatus_REPLACE + const OperatorStatus_RUNNING + const OperatorStatus_SUCCESS + const OperatorStatus_TIMEOUT + func (OperatorStatus) EnumDescriptor() ([]byte, []int) + func (x OperatorStatus) String() string + type Pair struct + Key string + Value string + func (*Pair) Descriptor() ([]byte, []int) + func (*Pair) ProtoMessage() + func (m *Pair) GetKey() string + func (m *Pair) GetValue() string + func (m *Pair) Marshal() (dAtA []byte, err error) + func (m *Pair) MarshalTo(dAtA []byte) (int, error) + func (m *Pair) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Pair) Reset() + func (m *Pair) Size() (n int) + func (m *Pair) String() string + func (m *Pair) Unmarshal(dAtA []byte) error + func (m *Pair) XXX_DiscardUnknown() + func (m *Pair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Pair) XXX_Merge(src proto.Message) + func (m *Pair) XXX_Size() int + func (m *Pair) XXX_Unmarshal(b []byte) error + type Peer struct + ContainerID uint64 + ID uint64 + Role PeerRole + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (m *Peer) GetContainerID() uint64 + func (m *Peer) GetID() uint64 + func (m *Peer) GetRole() PeerRole + func (m *Peer) Marshal() (dAtA []byte, err error) + func (m *Peer) MarshalTo(dAtA []byte) (int, error) + func (m *Peer) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Peer) Reset() + func (m *Peer) Size() (n int) + func (m *Peer) String() string + func (m *Peer) Unmarshal(dAtA []byte) error + func (m *Peer) XXX_DiscardUnknown() + func (m *Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Peer) XXX_Merge(src proto.Message) + func (m *Peer) XXX_Size() int + func (m *Peer) XXX_Unmarshal(b []byte) error + type PeerRole int32 + const PeerRole_DemotingVoter + const PeerRole_IncomingVoter + const PeerRole_Learner + const PeerRole_Voter + func (PeerRole) EnumDescriptor() ([]byte, []int) + func (x PeerRole) String() string + type PeerStats struct + DownSeconds uint64 + Peer Peer + func (*PeerStats) Descriptor() ([]byte, []int) + func (*PeerStats) ProtoMessage() + func (m *PeerStats) GetDownSeconds() uint64 + func (m *PeerStats) GetPeer() Peer + func (m *PeerStats) Marshal() (dAtA []byte, err error) + func (m *PeerStats) MarshalTo(dAtA []byte) (int, error) + func (m *PeerStats) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PeerStats) Reset() + func (m *PeerStats) Size() (n int) + func (m *PeerStats) String() string + func (m *PeerStats) Unmarshal(dAtA []byte) error + func (m *PeerStats) XXX_DiscardUnknown() + func (m *PeerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PeerStats) XXX_Merge(src proto.Message) + func (m *PeerStats) XXX_Size() int + func (m *PeerStats) XXX_Unmarshal(b []byte) error + type ResourceEpoch struct + ConfVer uint64 + Version uint64 + func (*ResourceEpoch) Descriptor() ([]byte, []int) + func (*ResourceEpoch) ProtoMessage() + func (m *ResourceEpoch) GetConfVer() uint64 + func (m *ResourceEpoch) GetVersion() uint64 + func (m *ResourceEpoch) Marshal() (dAtA []byte, err error) + func (m *ResourceEpoch) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceEpoch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceEpoch) Reset() + func (m *ResourceEpoch) Size() (n int) + func (m *ResourceEpoch) String() string + func (m *ResourceEpoch) Unmarshal(dAtA []byte) error + func (m *ResourceEpoch) XXX_DiscardUnknown() + func (m *ResourceEpoch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceEpoch) XXX_Merge(src proto.Message) + func (m *ResourceEpoch) XXX_Size() int + func (m *ResourceEpoch) XXX_Unmarshal(b []byte) error + type ResourceKind int32 + const ResourceKind_LeaderKind + const ResourceKind_ReplicaKind + func (ResourceKind) EnumDescriptor() ([]byte, []int) + func (x ResourceKind) String() string + type ResourceStat struct + BytesRead uint64 + BytesWritten uint64 + KeysRead uint64 + KeysWritten uint64 + func (*ResourceStat) Descriptor() ([]byte, []int) + func (*ResourceStat) ProtoMessage() + func (m *ResourceStat) GetBytesRead() uint64 + func (m *ResourceStat) GetBytesWritten() uint64 + func (m *ResourceStat) GetKeysRead() uint64 + func (m *ResourceStat) GetKeysWritten() uint64 + func (m *ResourceStat) Marshal() (dAtA []byte, err error) + func (m *ResourceStat) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceStat) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceStat) Reset() + func (m *ResourceStat) Size() (n int) + func (m *ResourceStat) String() string + func (m *ResourceStat) Unmarshal(dAtA []byte) error + func (m *ResourceStat) XXX_DiscardUnknown() + func (m *ResourceStat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceStat) XXX_Merge(src proto.Message) + func (m *ResourceStat) XXX_Size() int + func (m *ResourceStat) XXX_Unmarshal(b []byte) error + type Timestamp struct + Logical int64 + Physical int64 + func (*Timestamp) Descriptor() ([]byte, []int) + func (*Timestamp) ProtoMessage() + func (m *Timestamp) GetLogical() int64 + func (m *Timestamp) GetPhysical() int64 + func (m *Timestamp) Marshal() (dAtA []byte, err error) + func (m *Timestamp) MarshalTo(dAtA []byte) (int, error) + func (m *Timestamp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Timestamp) Reset() + func (m *Timestamp) Size() (n int) + func (m *Timestamp) String() string + func (m *Timestamp) Unmarshal(dAtA []byte) error + func (m *Timestamp) XXX_DiscardUnknown() + func (m *Timestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Timestamp) XXX_Merge(src proto.Message) + func (m *Timestamp) XXX_Size() int + func (m *Timestamp) XXX_Unmarshal(b []byte) error