metapb

package
v0.0.0-...-3b3056d Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

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"`
	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) 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"`
	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) GetId 

func (m *Region) GetId() uint64

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

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.