bhmetapb

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBhmetapb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBhmetapb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ShardsPoolCmdType_name = map[int32]string{
	0: "CreateShard",
	1: "AllocShard",
}
View Source 
var ShardsPoolCmdType_value = map[string]int32{
	"CreateShard": 0,
	"AllocShard":  1,
}

Functions

This section is empty.

Types

type AllocatedShard 

type AllocatedShard struct {
	ShardID              uint64   `protobuf:"varint,1,opt,name=shardID,proto3" json:"shardID,omitempty"`
	AllocatedAt          uint64   `protobuf:"varint,2,opt,name=allocatedAt,proto3" json:"allocatedAt,omitempty"`
	Purpose              []byte   `protobuf:"bytes,3,opt,name=purpose,proto3" json:"purpose,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AllocatedShard allocated shard info

func (*AllocatedShard) Descriptor 

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

func (*AllocatedShard) GetAllocatedAt 

func (m *AllocatedShard) GetAllocatedAt() uint64

func (*AllocatedShard) GetPurpose 

func (m *AllocatedShard) GetPurpose() []byte

func (*AllocatedShard) GetShardID 

func (m *AllocatedShard) GetShardID() uint64

func (*AllocatedShard) Marshal 

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

func (*AllocatedShard) MarshalTo 

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

func (*AllocatedShard) ProtoMessage 

func (*AllocatedShard) ProtoMessage()

func (*AllocatedShard) Reset 

func (m *AllocatedShard) Reset()

func (*AllocatedShard) Size 

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

func (*AllocatedShard) String 

func (m *AllocatedShard) String() string

func (*AllocatedShard) Unmarshal 

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

func (*AllocatedShard) XXX_DiscardUnknown 

func (m *AllocatedShard) XXX_DiscardUnknown()

func (*AllocatedShard) XXX_Marshal 

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

func (*AllocatedShard) XXX_Merge 

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

func (*AllocatedShard) XXX_Size 

func (m *AllocatedShard) XXX_Size() int

func (*AllocatedShard) XXX_Unmarshal 

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

type Cluster 

type Cluster struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	MaxReplicas          uint32   `protobuf:"varint,2,opt,name=maxReplicas,proto3" json:"maxReplicas,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Cluster the cluster info

func (*Cluster) Descriptor 

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

func (*Cluster) GetID 

func (m *Cluster) GetID() uint64

func (*Cluster) GetMaxReplicas 

func (m *Cluster) GetMaxReplicas() 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) 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 Shard 

type Shard struct {
	ID                   uint64               `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Start                []byte               `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	End                  []byte               `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	Epoch                metapb.ResourceEpoch `protobuf:"bytes,4,opt,name=epoch,proto3" json:"epoch"`
	State                metapb.ResourceState `protobuf:"varint,5,opt,name=state,proto3,enum=metapb.ResourceState" json:"state,omitempty"`
	Peers                []metapb.Peer        `protobuf:"bytes,6,rep,name=peers,proto3" json:"peers"`
	DisableSplit         bool                 `protobuf:"varint,7,opt,name=disableSplit,proto3" json:"disableSplit,omitempty"`
	Group                uint64               `protobuf:"varint,8,opt,name=group,proto3" json:"group,omitempty"`
	Unique               string               `protobuf:"bytes,10,opt,name=unique,proto3" json:"unique,omitempty"`
	RuleGroups           []string             `protobuf:"bytes,11,rep,name=ruleGroups,proto3" json:"ruleGroups,omitempty"`
	Data                 []byte               `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Shard a shard [start,end) of the data

func (*Shard) Descriptor 

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

func (*Shard) GetData 

func (m *Shard) GetData() []byte

func (*Shard) GetDisableSplit 

func (m *Shard) GetDisableSplit() bool

func (*Shard) GetEnd 

func (m *Shard) GetEnd() []byte

func (*Shard) GetEpoch 

func (m *Shard) GetEpoch() metapb.ResourceEpoch

func (*Shard) GetGroup 

func (m *Shard) GetGroup() uint64

func (*Shard) GetID 

func (m *Shard) GetID() uint64

func (*Shard) GetPeers 

func (m *Shard) GetPeers() []metapb.Peer

func (*Shard) GetRuleGroups 

func (m *Shard) GetRuleGroups() []string

func (*Shard) GetStart 

func (m *Shard) GetStart() []byte

func (*Shard) GetState 

func (m *Shard) GetState() metapb.ResourceState

func (*Shard) GetUnique 

func (m *Shard) GetUnique() string

func (*Shard) Marshal 

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

func (*Shard) MarshalTo 

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

func (*Shard) ProtoMessage 

func (*Shard) ProtoMessage()

func (*Shard) Reset 

func (m *Shard) Reset()

func (*Shard) Size 

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

func (*Shard) String 

func (m *Shard) String() string

func (*Shard) Unmarshal 

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

func (*Shard) XXX_DiscardUnknown 

func (m *Shard) XXX_DiscardUnknown()

func (*Shard) XXX_Marshal 

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

func (*Shard) XXX_Merge 

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

func (*Shard) XXX_Size 

func (m *Shard) XXX_Size() int

func (*Shard) XXX_Unmarshal 

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

type ShardPool 

type ShardPool struct {
	Capacity             uint64            `protobuf:"varint,1,opt,name=capacity,proto3" json:"capacity,omitempty"`
	RangePrefix          []byte            `protobuf:"bytes,2,opt,name=rangePrefix,proto3" json:"rangePrefix,omitempty"`
	AllocatedShards      []*AllocatedShard `protobuf:"bytes,3,rep,name=allocatedShards,proto3" json:"allocatedShards,omitempty"`
	Seq                  uint64            `protobuf:"varint,4,opt,name=seq,proto3" json:"seq,omitempty"`
	AllocatedOffset      uint64            `protobuf:"varint,5,opt,name=allocatedOffset,proto3" json:"allocatedOffset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

ShardPool shard pool

func (*ShardPool) Descriptor 

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

func (*ShardPool) GetAllocatedOffset 

func (m *ShardPool) GetAllocatedOffset() uint64

func (*ShardPool) GetAllocatedShards 

func (m *ShardPool) GetAllocatedShards() []*AllocatedShard

func (*ShardPool) GetCapacity 

func (m *ShardPool) GetCapacity() uint64

func (*ShardPool) GetRangePrefix 

func (m *ShardPool) GetRangePrefix() []byte

func (*ShardPool) GetSeq 

func (m *ShardPool) GetSeq() uint64

func (*ShardPool) Marshal 

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

func (*ShardPool) MarshalTo 

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

func (*ShardPool) ProtoMessage 

func (*ShardPool) ProtoMessage()

func (*ShardPool) Reset 

func (m *ShardPool) Reset()

func (*ShardPool) Size 

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

func (*ShardPool) String 

func (m *ShardPool) String() string

func (*ShardPool) Unmarshal 

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

func (*ShardPool) XXX_DiscardUnknown 

func (m *ShardPool) XXX_DiscardUnknown()

func (*ShardPool) XXX_Marshal 

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

func (*ShardPool) XXX_Merge 

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

func (*ShardPool) XXX_Size 

func (m *ShardPool) XXX_Size() int

func (*ShardPool) XXX_Unmarshal 

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

type ShardsPool 

type ShardsPool struct {
	Pools                map[uint64]*ShardPool `` /* 152-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ShardsPool shards pool

func (*ShardsPool) Descriptor 

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

func (*ShardsPool) GetPools 

func (m *ShardsPool) GetPools() map[uint64]*ShardPool

func (*ShardsPool) Marshal 

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

func (*ShardsPool) MarshalTo 

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

func (*ShardsPool) ProtoMessage 

func (*ShardsPool) ProtoMessage()

func (*ShardsPool) Reset 

func (m *ShardsPool) Reset()

func (*ShardsPool) Size 

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

func (*ShardsPool) String 

func (m *ShardsPool) String() string

func (*ShardsPool) Unmarshal 

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

func (*ShardsPool) XXX_DiscardUnknown 

func (m *ShardsPool) XXX_DiscardUnknown()

func (*ShardsPool) XXX_Marshal 

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

func (*ShardsPool) XXX_Merge 

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

func (*ShardsPool) XXX_Size 

func (m *ShardsPool) XXX_Size() int

func (*ShardsPool) XXX_Unmarshal 

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

type ShardsPoolAllocCmd 

type ShardsPoolAllocCmd struct {
	Group                uint64   `protobuf:"varint,1,opt,name=group,proto3" json:"group,omitempty"`
	Purpose              []byte   `protobuf:"bytes,2,opt,name=purpose,proto3" json:"purpose,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ShardsPoolAllocCmd shards pool create cmd

func (*ShardsPoolAllocCmd) Descriptor 

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

func (*ShardsPoolAllocCmd) GetGroup 

func (m *ShardsPoolAllocCmd) GetGroup() uint64

func (*ShardsPoolAllocCmd) GetPurpose 

func (m *ShardsPoolAllocCmd) GetPurpose() []byte

func (*ShardsPoolAllocCmd) Marshal 

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

func (*ShardsPoolAllocCmd) MarshalTo 

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

func (*ShardsPoolAllocCmd) ProtoMessage 

func (*ShardsPoolAllocCmd) ProtoMessage()

func (*ShardsPoolAllocCmd) Reset 

func (m *ShardsPoolAllocCmd) Reset()

func (*ShardsPoolAllocCmd) Size 

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

func (*ShardsPoolAllocCmd) String 

func (m *ShardsPoolAllocCmd) String() string

func (*ShardsPoolAllocCmd) Unmarshal 

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

func (*ShardsPoolAllocCmd) XXX_DiscardUnknown 

func (m *ShardsPoolAllocCmd) XXX_DiscardUnknown()

func (*ShardsPoolAllocCmd) XXX_Marshal 

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

func (*ShardsPoolAllocCmd) XXX_Merge 

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

func (*ShardsPoolAllocCmd) XXX_Size 

func (m *ShardsPoolAllocCmd) XXX_Size() int

func (*ShardsPoolAllocCmd) XXX_Unmarshal 

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

type ShardsPoolCmd 

type ShardsPoolCmd struct {
	Type                 ShardsPoolCmdType    `protobuf:"varint,1,opt,name=type,proto3,enum=bhmetapb.ShardsPoolCmdType" json:"type,omitempty"`
	Create               *ShardsPoolCreateCmd `protobuf:"bytes,2,opt,name=create,proto3" json:"create,omitempty"`
	Alloc                *ShardsPoolAllocCmd  `protobuf:"bytes,3,opt,name=alloc,proto3" json:"alloc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

ShardsPoolCmd shards pool cmd

func (*ShardsPoolCmd) Descriptor 

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

func (*ShardsPoolCmd) GetAlloc 

func (m *ShardsPoolCmd) GetAlloc() *ShardsPoolAllocCmd

func (*ShardsPoolCmd) GetCreate 

func (m *ShardsPoolCmd) GetCreate() *ShardsPoolCreateCmd

func (*ShardsPoolCmd) GetType 

func (m *ShardsPoolCmd) GetType() ShardsPoolCmdType

func (*ShardsPoolCmd) Marshal 

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

func (*ShardsPoolCmd) MarshalTo 

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

func (*ShardsPoolCmd) ProtoMessage 

func (*ShardsPoolCmd) ProtoMessage()

func (*ShardsPoolCmd) Reset 

func (m *ShardsPoolCmd) Reset()

func (*ShardsPoolCmd) Size 

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

func (*ShardsPoolCmd) String 

func (m *ShardsPoolCmd) String() string

func (*ShardsPoolCmd) Unmarshal 

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

func (*ShardsPoolCmd) XXX_DiscardUnknown 

func (m *ShardsPoolCmd) XXX_DiscardUnknown()

func (*ShardsPoolCmd) XXX_Marshal 

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

func (*ShardsPoolCmd) XXX_Merge 

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

func (*ShardsPoolCmd) XXX_Size 

func (m *ShardsPoolCmd) XXX_Size() int

func (*ShardsPoolCmd) XXX_Unmarshal 

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

type ShardsPoolCmdType 

type ShardsPoolCmdType int32

ShardsPoolCmdType shards pool cmd 

const (
	ShardsPoolCmdType_CreateShard ShardsPoolCmdType = 0
	ShardsPoolCmdType_AllocShard  ShardsPoolCmdType = 1
)

func (ShardsPoolCmdType) EnumDescriptor 

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

func (ShardsPoolCmdType) String 

func (x ShardsPoolCmdType) String() string

type ShardsPoolCreateCmd 

type ShardsPoolCreateCmd struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ShardsPoolCreateCmd shards pool create cmd

func (*ShardsPoolCreateCmd) Descriptor 

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

func (*ShardsPoolCreateCmd) Marshal 

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

func (*ShardsPoolCreateCmd) MarshalTo 

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

func (*ShardsPoolCreateCmd) ProtoMessage 

func (*ShardsPoolCreateCmd) ProtoMessage()

func (*ShardsPoolCreateCmd) Reset 

func (m *ShardsPoolCreateCmd) Reset()

func (*ShardsPoolCreateCmd) Size 

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

func (*ShardsPoolCreateCmd) String 

func (m *ShardsPoolCreateCmd) String() string

func (*ShardsPoolCreateCmd) Unmarshal 

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

func (*ShardsPoolCreateCmd) XXX_DiscardUnknown 

func (m *ShardsPoolCreateCmd) XXX_DiscardUnknown()

func (*ShardsPoolCreateCmd) XXX_Marshal 

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

func (*ShardsPoolCreateCmd) XXX_Merge 

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

func (*ShardsPoolCreateCmd) XXX_Size 

func (m *ShardsPoolCreateCmd) XXX_Size() int

func (*ShardsPoolCreateCmd) XXX_Unmarshal 

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

type Store 

type Store struct {
	ID                   uint64                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	RaftAddr             string                `protobuf:"bytes,2,opt,name=raftAddr,proto3" json:"raftAddr,omitempty"`
	ClientAddr           string                `protobuf:"bytes,3,opt,name=clientAddr,proto3" json:"clientAddr,omitempty"`
	Labels               []metapb.Pair         `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels"`
	State                metapb.ContainerState `protobuf:"varint,5,opt,name=state,proto3,enum=metapb.ContainerState" json:"state,omitempty"`
	StartTime            int64                 `protobuf:"varint,6,opt,name=startTime,proto3" json:"startTime,omitempty"`
	LastHeartbeatTime    int64                 `protobuf:"varint,7,opt,name=lastHeartbeatTime,proto3" json:"lastHeartbeatTime,omitempty"`
	Version              string                `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"`
	GitHash              string                `protobuf:"bytes,9,opt,name=gitHash,proto3" json:"gitHash,omitempty"`
	DeployPath           string                `protobuf:"bytes,10,opt,name=deployPath,proto3" json:"deployPath,omitempty"`
	PhysicallyDestroyed  bool                  `protobuf:"varint,11,opt,name=physicallyDestroyed,proto3" json:"physicallyDestroyed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Store the host store metadata

func (*Store) Descriptor 

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

func (*Store) GetClientAddr 

func (m *Store) GetClientAddr() 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() []metapb.Pair

func (*Store) GetLastHeartbeatTime 

func (m *Store) GetLastHeartbeatTime() int64

func (*Store) GetPhysicallyDestroyed 

func (m *Store) GetPhysicallyDestroyed() bool

func (*Store) GetRaftAddr 

func (m *Store) GetRaftAddr() string

func (*Store) GetStartTime 

func (m *Store) GetStartTime() int64

func (*Store) GetState 

func (m *Store) GetState() metapb.ContainerState

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

type StoreIdent struct {
	ClusterID            uint64   `protobuf:"varint,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"`
	StoreID              uint64   `protobuf:"varint,2,opt,name=storeID,proto3" json:"storeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StoreIdent store ident

func (*StoreIdent) Descriptor 

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

func (*StoreIdent) GetClusterID 

func (m *StoreIdent) GetClusterID() uint64

func (*StoreIdent) GetStoreID 

func (m *StoreIdent) GetStoreID() uint64

func (*StoreIdent) Marshal 

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

func (*StoreIdent) MarshalTo 

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

func (*StoreIdent) ProtoMessage 

func (*StoreIdent) ProtoMessage()

func (*StoreIdent) Reset 

func (m *StoreIdent) Reset()

func (*StoreIdent) Size 

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

func (*StoreIdent) String 

func (m *StoreIdent) String() string

func (*StoreIdent) Unmarshal 

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

func (*StoreIdent) XXX_DiscardUnknown 

func (m *StoreIdent) XXX_DiscardUnknown()

func (*StoreIdent) XXX_Marshal 

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

func (*StoreIdent) XXX_Merge 

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

func (*StoreIdent) XXX_Size 

func (m *StoreIdent) XXX_Size() int

func (*StoreIdent) XXX_Unmarshal 

func (m *StoreIdent) 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.