metapb

package
v0.0.0-...-4a3e17f Latest Latest
Warning

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

Go to latest
Published: Sep 24, 2024 License: Apache-2.0 Imports: 7 Imported by: 2,097

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthMetapb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetapb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetapb = fmt.Errorf("proto: unexpected end of group")
)
View Source
var NodeState_name = map[int32]string{
	0: "Preparing",
	1: "Serving",
	2: "Removing",
	3: "Removed",
}
View Source
var NodeState_value = map[string]int32{
	"Preparing": 0,
	"Serving":   1,
	"Removing":  2,
	"Removed":   3,
}
View Source
var PeerRole_name = map[int32]string{
	0: "Voter",
	1: "Learner",
	2: "IncomingVoter",
	3: "DemotingVoter",
}
View Source
var PeerRole_value = map[string]int32{
	"Voter":         0,
	"Learner":       1,
	"IncomingVoter": 2,
	"DemotingVoter": 3,
}
View Source
var StoreState_name = map[int32]string{
	0: "Up",
	1: "Offline",
	2: "Tombstone",
}
View Source
var StoreState_value = map[string]int32{
	"Up":        0,
	"Offline":   1,
	"Tombstone": 2,
}

Functions

This section is empty.

Types

type BucketStats

type BucketStats struct {
	// total read in bytes of each bucket
	ReadBytes []uint64 `protobuf:"varint,1,rep,packed,name=read_bytes,json=readBytes,proto3" json:"read_bytes,omitempty"`
	// total write in bytes of each bucket
	WriteBytes []uint64 `protobuf:"varint,2,rep,packed,name=write_bytes,json=writeBytes,proto3" json:"write_bytes,omitempty"`
	// total read qps of each bucket
	ReadQps []uint64 `protobuf:"varint,3,rep,packed,name=read_qps,json=readQps,proto3" json:"read_qps,omitempty"`
	// total write qps of each bucket
	WriteQps []uint64 `protobuf:"varint,4,rep,packed,name=write_qps,json=writeQps,proto3" json:"write_qps,omitempty"`
	// total read keys of each bucket
	ReadKeys []uint64 `protobuf:"varint,5,rep,packed,name=read_keys,json=readKeys,proto3" json:"read_keys,omitempty"`
	// total write keys of each bucket
	WriteKeys            []uint64 `protobuf:"varint,6,rep,packed,name=write_keys,json=writeKeys,proto3" json:"write_keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BucketStats) Descriptor

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

func (*BucketStats) GetReadBytes

func (m *BucketStats) GetReadBytes() []uint64

func (*BucketStats) GetReadKeys

func (m *BucketStats) GetReadKeys() []uint64

func (*BucketStats) GetReadQps

func (m *BucketStats) GetReadQps() []uint64

func (*BucketStats) GetWriteBytes

func (m *BucketStats) GetWriteBytes() []uint64

func (*BucketStats) GetWriteKeys

func (m *BucketStats) GetWriteKeys() []uint64

func (*BucketStats) GetWriteQps

func (m *BucketStats) GetWriteQps() []uint64

func (*BucketStats) Marshal

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

func (*BucketStats) MarshalTo

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

func (*BucketStats) MarshalToSizedBuffer

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

func (*BucketStats) ProtoMessage

func (*BucketStats) ProtoMessage()

func (*BucketStats) Reset

func (m *BucketStats) Reset()

func (*BucketStats) Size

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

func (*BucketStats) String

func (m *BucketStats) String() string

func (*BucketStats) Unmarshal

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

func (*BucketStats) XXX_DiscardUnknown

func (m *BucketStats) XXX_DiscardUnknown()

func (*BucketStats) XXX_Marshal

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

func (*BucketStats) XXX_Merge

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

func (*BucketStats) XXX_Size

func (m *BucketStats) XXX_Size() int

func (*BucketStats) XXX_Unmarshal

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

type Buckets

type Buckets struct {
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	// A hint indicate if keys have changed.
	Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// keys of buckets, include start/end key of region
	Keys [][]byte `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"`
	// bucket stats
	Stats *BucketStats `protobuf:"bytes,4,opt,name=stats,proto3" json:"stats,omitempty"`
	// The period in milliseconds that stats are collected with in
	PeriodInMs           uint64   `protobuf:"varint,5,opt,name=period_in_ms,json=periodInMs,proto3" json:"period_in_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Buckets) Descriptor

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

func (*Buckets) GetKeys

func (m *Buckets) GetKeys() [][]byte

func (*Buckets) GetPeriodInMs

func (m *Buckets) GetPeriodInMs() uint64

func (*Buckets) GetRegionId

func (m *Buckets) GetRegionId() uint64

func (*Buckets) GetStats

func (m *Buckets) GetStats() *BucketStats

func (*Buckets) GetVersion

func (m *Buckets) GetVersion() uint64

func (*Buckets) Marshal

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

func (*Buckets) MarshalTo

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

func (*Buckets) MarshalToSizedBuffer

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

func (*Buckets) ProtoMessage

func (*Buckets) ProtoMessage()

func (*Buckets) Reset

func (m *Buckets) Reset()

func (*Buckets) Size

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

func (*Buckets) String

func (m *Buckets) String() string

func (*Buckets) Unmarshal

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

func (*Buckets) XXX_DiscardUnknown

func (m *Buckets) XXX_DiscardUnknown()

func (*Buckets) XXX_Marshal

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

func (*Buckets) XXX_Merge

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

func (*Buckets) XXX_Size

func (m *Buckets) XXX_Size() int

func (*Buckets) XXX_Unmarshal

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

type Cluster

type Cluster struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// max peer count for a region.
	// pd will do the auto-balance if region peer count mismatches.
	MaxPeerCount         uint32   `protobuf:"varint,2,opt,name=max_peer_count,json=maxPeerCount,proto3" json:"max_peer_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Cluster) Descriptor

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

func (*Cluster) GetId

func (m *Cluster) GetId() uint64

func (*Cluster) GetMaxPeerCount

func (m *Cluster) GetMaxPeerCount() uint32

func (*Cluster) Marshal

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

func (*Cluster) MarshalTo

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

func (*Cluster) MarshalToSizedBuffer

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

func (*Cluster) ProtoMessage

func (*Cluster) ProtoMessage()

func (*Cluster) Reset

func (m *Cluster) Reset()

func (*Cluster) Size

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

func (*Cluster) String

func (m *Cluster) String() string

func (*Cluster) Unmarshal

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

func (*Cluster) XXX_DiscardUnknown

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal

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

func (*Cluster) XXX_Merge

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

func (*Cluster) XXX_Size

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal

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

type NodeState

type NodeState int32

NodeState is going to replace StoreState to make the state concept more clear. "Up" is devided into "Preparing" and "Serving" stages so that we can better describe the online process. "Removing" is just like previous `Offline` which is more accurate. "Removed" has the same meaning with `Tombstone`.

const (
	NodeState_Preparing NodeState = 0
	NodeState_Serving   NodeState = 1
	NodeState_Removing  NodeState = 2
	NodeState_Removed   NodeState = 3
)

func (NodeState) EnumDescriptor

func (NodeState) EnumDescriptor() ([]byte, []int)

func (NodeState) String

func (x NodeState) String() string

type Peer

type Peer struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	StoreId              uint64   `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	Role                 PeerRole `protobuf:"varint,3,opt,name=role,proto3,enum=metapb.PeerRole" json:"role,omitempty"`
	IsWitness            bool     `protobuf:"varint,4,opt,name=is_witness,json=isWitness,proto3" json:"is_witness,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Peer) Descriptor

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

func (*Peer) GetId

func (m *Peer) GetId() uint64

func (*Peer) GetIsWitness

func (m *Peer) GetIsWitness() bool

func (*Peer) GetRole

func (m *Peer) GetRole() PeerRole

func (*Peer) GetStoreId

func (m *Peer) GetStoreId() uint64

func (*Peer) Marshal

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

func (*Peer) MarshalTo

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

func (*Peer) MarshalToSizedBuffer

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

func (*Peer) ProtoMessage

func (*Peer) ProtoMessage()

func (*Peer) Reset

func (m *Peer) Reset()

func (*Peer) Size

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

func (*Peer) String

func (m *Peer) String() string

func (*Peer) Unmarshal

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

func (*Peer) XXX_DiscardUnknown

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal

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

func (*Peer) XXX_Merge

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

func (*Peer) XXX_Size

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal

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

type PeerRole

type PeerRole int32
const (
	// Voter -> Voter
	PeerRole_Voter PeerRole = 0
	// Learner/None -> Learner
	PeerRole_Learner PeerRole = 1
	// Learner/None -> Voter
	PeerRole_IncomingVoter PeerRole = 2
	// Voter -> Learner
	PeerRole_DemotingVoter PeerRole = 3
)

func (PeerRole) EnumDescriptor

func (PeerRole) EnumDescriptor() ([]byte, []int)

func (PeerRole) String

func (x PeerRole) String() string

type Region

type Region struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Region key range [start_key, end_key).
	StartKey    []byte       `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey      []byte       `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	RegionEpoch *RegionEpoch `protobuf:"bytes,4,opt,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"`
	Peers       []*Peer      `protobuf:"bytes,5,rep,name=peers,proto3" json:"peers,omitempty"`
	// Encryption metadata for start_key and end_key. encryption_meta.iv is IV for start_key.
	// IV for end_key is calculated from (encryption_meta.iv + len(start_key)).
	// The field is only used by PD and should be ignored otherwise.
	// If encryption_meta is empty (i.e. nil), it means start_key and end_key are unencrypted.
	EncryptionMeta *encryptionpb.EncryptionMeta `protobuf:"bytes,6,opt,name=encryption_meta,json=encryptionMeta,proto3" json:"encryption_meta,omitempty"`
	// The flashback state indicates whether this region is in the flashback state.
	// TODO: only check by `flashback_start_ts` in the future. Keep for compatibility now.
	IsInFlashback bool `protobuf:"varint,7,opt,name=is_in_flashback,json=isInFlashback,proto3" json:"is_in_flashback,omitempty"`
	// The start_ts that the current flashback progress is using.
	FlashbackStartTs     uint64   `protobuf:"varint,8,opt,name=flashback_start_ts,json=flashbackStartTs,proto3" json:"flashback_start_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Region) Descriptor

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

func (*Region) GetEncryptionMeta

func (m *Region) GetEncryptionMeta() *encryptionpb.EncryptionMeta

func (*Region) GetEndKey

func (m *Region) GetEndKey() []byte

func (*Region) GetFlashbackStartTs

func (m *Region) GetFlashbackStartTs() uint64

func (*Region) GetId

func (m *Region) GetId() uint64

func (*Region) GetIsInFlashback

func (m *Region) GetIsInFlashback() bool

func (*Region) GetPeers

func (m *Region) GetPeers() []*Peer

func (*Region) GetRegionEpoch

func (m *Region) GetRegionEpoch() *RegionEpoch

func (*Region) GetStartKey

func (m *Region) GetStartKey() []byte

func (*Region) Marshal

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

func (*Region) MarshalTo

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

func (*Region) MarshalToSizedBuffer

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

func (*Region) ProtoMessage

func (*Region) ProtoMessage()

func (*Region) Reset

func (m *Region) Reset()

func (*Region) Size

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

func (*Region) String

func (m *Region) String() string

func (*Region) Unmarshal

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

func (*Region) XXX_DiscardUnknown

func (m *Region) XXX_DiscardUnknown()

func (*Region) XXX_Marshal

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

func (*Region) XXX_Merge

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

func (*Region) XXX_Size

func (m *Region) XXX_Size() int

func (*Region) XXX_Unmarshal

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

type RegionEpoch

type RegionEpoch struct {
	// Conf change version, auto increment when add or remove peer
	ConfVer uint64 `protobuf:"varint,1,opt,name=conf_ver,json=confVer,proto3" json:"conf_ver,omitempty"`
	// Region version, auto increment when split or merge
	Version              uint64   `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegionEpoch) Descriptor

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

func (*RegionEpoch) GetConfVer

func (m *RegionEpoch) GetConfVer() uint64

func (*RegionEpoch) GetVersion

func (m *RegionEpoch) GetVersion() uint64

func (*RegionEpoch) Marshal

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

func (*RegionEpoch) MarshalTo

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

func (*RegionEpoch) MarshalToSizedBuffer

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

func (*RegionEpoch) ProtoMessage

func (*RegionEpoch) ProtoMessage()

func (*RegionEpoch) Reset

func (m *RegionEpoch) Reset()

func (*RegionEpoch) Size

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

func (*RegionEpoch) String

func (m *RegionEpoch) String() string

func (*RegionEpoch) Unmarshal

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

func (*RegionEpoch) XXX_DiscardUnknown

func (m *RegionEpoch) XXX_DiscardUnknown()

func (*RegionEpoch) XXX_Marshal

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

func (*RegionEpoch) XXX_Merge

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

func (*RegionEpoch) XXX_Size

func (m *RegionEpoch) XXX_Size() int

func (*RegionEpoch) XXX_Unmarshal

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

type Store

type Store struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Address to handle client requests (kv, cop, etc.)
	Address string        `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	State   StoreState    `protobuf:"varint,3,opt,name=state,proto3,enum=metapb.StoreState" json:"state,omitempty"`
	Labels  []*StoreLabel `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"`
	Version string        `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// Address to handle peer requests (raft messages from other store).
	// Empty means same as address.
	PeerAddress string `protobuf:"bytes,6,opt,name=peer_address,json=peerAddress,proto3" json:"peer_address,omitempty"`
	// Status address provides the HTTP service for external components
	StatusAddress string `protobuf:"bytes,7,opt,name=status_address,json=statusAddress,proto3" json:"status_address,omitempty"`
	GitHash       string `protobuf:"bytes,8,opt,name=git_hash,json=gitHash,proto3" json:"git_hash,omitempty"`
	// The start timestamp of the current store
	StartTimestamp int64  `protobuf:"varint,9,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	DeployPath     string `protobuf:"bytes,10,opt,name=deploy_path,json=deployPath,proto3" json:"deploy_path,omitempty"`
	// The last heartbeat timestamp of the store.
	LastHeartbeat int64 `protobuf:"varint,11,opt,name=last_heartbeat,json=lastHeartbeat,proto3" json:"last_heartbeat,omitempty"`
	// If the store is physically destroyed, which means it can never up again.
	PhysicallyDestroyed bool `protobuf:"varint,12,opt,name=physically_destroyed,json=physicallyDestroyed,proto3" json:"physically_destroyed,omitempty"`
	// NodeState is used to replace StoreState which will be deprecated in the future.
	NodeState            NodeState `protobuf:"varint,13,opt,name=node_state,json=nodeState,proto3,enum=metapb.NodeState" json:"node_state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Store) Descriptor

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

func (*Store) GetAddress

func (m *Store) GetAddress() string

func (*Store) GetDeployPath

func (m *Store) GetDeployPath() string

func (*Store) GetGitHash

func (m *Store) GetGitHash() string

func (*Store) GetId

func (m *Store) GetId() uint64

func (*Store) GetLabels

func (m *Store) GetLabels() []*StoreLabel

func (*Store) GetLastHeartbeat

func (m *Store) GetLastHeartbeat() int64

func (*Store) GetNodeState

func (m *Store) GetNodeState() NodeState

func (*Store) GetPeerAddress

func (m *Store) GetPeerAddress() string

func (*Store) GetPhysicallyDestroyed

func (m *Store) GetPhysicallyDestroyed() bool

func (*Store) GetStartTimestamp

func (m *Store) GetStartTimestamp() int64

func (*Store) GetState

func (m *Store) GetState() StoreState

func (*Store) GetStatusAddress

func (m *Store) GetStatusAddress() string

func (*Store) GetVersion

func (m *Store) GetVersion() string

func (*Store) Marshal

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

func (*Store) MarshalTo

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

func (*Store) MarshalToSizedBuffer

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

func (*Store) ProtoMessage

func (*Store) ProtoMessage()

func (*Store) Reset

func (m *Store) Reset()

func (*Store) Size

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

func (*Store) String

func (m *Store) String() string

func (*Store) Unmarshal

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

func (*Store) XXX_DiscardUnknown

func (m *Store) XXX_DiscardUnknown()

func (*Store) XXX_Marshal

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

func (*Store) XXX_Merge

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

func (*Store) XXX_Size

func (m *Store) XXX_Size() int

func (*Store) XXX_Unmarshal

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

type StoreLabel

type StoreLabel struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Case insensitive key/value for replica constraints.

func (*StoreLabel) Descriptor

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

func (*StoreLabel) GetKey

func (m *StoreLabel) GetKey() string

func (*StoreLabel) GetValue

func (m *StoreLabel) GetValue() string

func (*StoreLabel) Marshal

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

func (*StoreLabel) MarshalTo

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

func (*StoreLabel) MarshalToSizedBuffer

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

func (*StoreLabel) ProtoMessage

func (*StoreLabel) ProtoMessage()

func (*StoreLabel) Reset

func (m *StoreLabel) Reset()

func (*StoreLabel) Size

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

func (*StoreLabel) String

func (m *StoreLabel) String() string

func (*StoreLabel) Unmarshal

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

func (*StoreLabel) XXX_DiscardUnknown

func (m *StoreLabel) XXX_DiscardUnknown()

func (*StoreLabel) XXX_Marshal

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

func (*StoreLabel) XXX_Merge

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

func (*StoreLabel) XXX_Size

func (m *StoreLabel) XXX_Size() int

func (*StoreLabel) XXX_Unmarshal

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

type StoreState

type StoreState int32
const (
	StoreState_Up        StoreState = 0
	StoreState_Offline   StoreState = 1
	StoreState_Tombstone StoreState = 2
)

func (StoreState) EnumDescriptor

func (StoreState) EnumDescriptor() ([]byte, []int)

func (StoreState) String

func (x StoreState) String() string

Jump to

Keyboard shortcuts

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