shardpb

Documentation

Overview

Package shardpb contains the protobuf-generated code for the internal cluster communication

Index

• type ShardDistribution
  • func (*ShardDistribution) Descriptor() ([]byte, []int)
  • func (m *ShardDistribution) GetNodes() []*WireNodes
  • func (m *ShardDistribution) GetShards() []*WireShard
  • func (*ShardDistribution) ProtoMessage()
  • func (m *ShardDistribution) Reset()
  • func (m *ShardDistribution) String() string
  • func (m *ShardDistribution) XXX_DiscardUnknown()
  • func (m *ShardDistribution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ShardDistribution) XXX_Merge(src proto.Message)
  • func (m *ShardDistribution) XXX_Size() int
  • func (m *ShardDistribution) XXX_Unmarshal(b []byte) error
• type WireNodes
  • func (*WireNodes) Descriptor() ([]byte, []int)
  • func (m *WireNodes) GetNodeId() int32
  • func (m *WireNodes) GetNodeName() string
  • func (*WireNodes) ProtoMessage()
  • func (m *WireNodes) Reset()
  • func (m *WireNodes) String() string
  • func (m *WireNodes) XXX_DiscardUnknown()
  • func (m *WireNodes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *WireNodes) XXX_Merge(src proto.Message)
  • func (m *WireNodes) XXX_Size() int
  • func (m *WireNodes) XXX_Unmarshal(b []byte) error
• type WireShard
  • func (*WireShard) Descriptor() ([]byte, []int)
  • func (m *WireShard) GetId() int32
  • func (m *WireShard) GetNodeId() int32
  • func (m *WireShard) GetWeight() int32
  • func (*WireShard) ProtoMessage()
  • func (m *WireShard) Reset()
  • func (m *WireShard) String() string
  • func (m *WireShard) XXX_DiscardUnknown()
  • func (m *WireShard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *WireShard) XXX_Merge(src proto.Message)
  • func (m *WireShard) XXX_Size() int
  • func (m *WireShard) XXX_Unmarshal(b []byte) error

Types

type ShardDistribution

type ShardDistribution struct {
	Nodes                []*WireNodes `protobuf:"bytes,1,rep,name=Nodes,proto3" json:"Nodes,omitempty"`
	Shards               []*WireShard `protobuf:"bytes,2,rep,name=Shards,proto3" json:"Shards,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ShardDistribution) Descriptor

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

func (*ShardDistribution) GetNodes

func (m *ShardDistribution) GetNodes() []*WireNodes

func (*ShardDistribution) GetShards

func (m *ShardDistribution) GetShards() []*WireShard

func (*ShardDistribution) ProtoMessage

func (*ShardDistribution) ProtoMessage()

func (*ShardDistribution) Reset

func (m *ShardDistribution) Reset()

func (*ShardDistribution) String

func (m *ShardDistribution) String() string

func (*ShardDistribution) XXX_DiscardUnknown

func (m *ShardDistribution) XXX_DiscardUnknown()

func (*ShardDistribution) XXX_Marshal

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

func (*ShardDistribution) XXX_Merge

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

func (*ShardDistribution) XXX_Size

func (m *ShardDistribution) XXX_Size() int

func (*ShardDistribution) XXX_Unmarshal

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

type WireNodes

type WireNodes struct {
	NodeId               int32    `protobuf:"varint,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	NodeName             string   `protobuf:"bytes,2,opt,name=NodeName,proto3" json:"NodeName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WireNodes) Descriptor

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

func (*WireNodes) GetNodeId

func (m *WireNodes) GetNodeId() int32

func (*WireNodes) GetNodeName

func (m *WireNodes) GetNodeName() string

func (*WireNodes) ProtoMessage

func (*WireNodes) ProtoMessage()

func (*WireNodes) Reset

func (m *WireNodes) Reset()

func (*WireNodes) String

func (m *WireNodes) String() string

func (*WireNodes) XXX_DiscardUnknown

func (m *WireNodes) XXX_DiscardUnknown()

func (*WireNodes) XXX_Marshal

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

func (*WireNodes) XXX_Merge

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

func (*WireNodes) XXX_Size

func (m *WireNodes) XXX_Size() int

func (*WireNodes) XXX_Unmarshal

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

type WireShard

type WireShard struct {
	Id                   int32    `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Weight               int32    `protobuf:"varint,2,opt,name=Weight,proto3" json:"Weight,omitempty"`
	NodeId               int32    `protobuf:"varint,3,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WireShard) Descriptor

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

func (*WireShard) GetId

func (m *WireShard) GetId() int32

func (*WireShard) GetNodeId

func (m *WireShard) GetNodeId() int32

func (*WireShard) GetWeight

func (m *WireShard) GetWeight() int32

func (*WireShard) ProtoMessage

func (*WireShard) ProtoMessage()

func (*WireShard) Reset

func (m *WireShard) Reset()

func (*WireShard) String

func (m *WireShard) String() string

func (*WireShard) XXX_DiscardUnknown

func (m *WireShard) XXX_DiscardUnknown()

func (*WireShard) XXX_Marshal

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

func (*WireShard) XXX_Merge

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

func (*WireShard) XXX_Size

func (m *WireShard) XXX_Size() int

func (*WireShard) XXX_Unmarshal

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