shardpb

Documentation

Overview

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

Index

• Variables
• type ShardDistribution
  • func (*ShardDistribution) Descriptor() ([]byte, []int)
  • func (x *ShardDistribution) GetNodes() []*WireNodes
  • func (x *ShardDistribution) GetShards() []*WireShard
  • func (*ShardDistribution) ProtoMessage()
  • func (x *ShardDistribution) ProtoReflect() protoreflect.Message
  • func (x *ShardDistribution) Reset()
  • func (x *ShardDistribution) String() string
• type WireNodes
  • func (*WireNodes) Descriptor() ([]byte, []int)
  • func (x *WireNodes) GetNodeId() int32
  • func (x *WireNodes) GetNodeName() string
  • func (*WireNodes) ProtoMessage()
  • func (x *WireNodes) ProtoReflect() protoreflect.Message
  • func (x *WireNodes) Reset()
  • func (x *WireNodes) String() string
• type WireShard
  • func (*WireShard) Descriptor() ([]byte, []int)
  • func (x *WireShard) GetId() int32
  • func (x *WireShard) GetNodeId() int32
  • func (x *WireShard) GetWeight() int32
  • func (*WireShard) ProtoMessage()
  • func (x *WireShard) ProtoReflect() protoreflect.Message
  • func (x *WireShard) Reset()
  • func (x *WireShard) String() string

Variables

var File_sharding_proto protoreflect.FileDescriptor

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"`
	// contains filtered or unexported fields
}

func (*ShardDistribution) Descriptor

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

Deprecated: Use ShardDistribution.ProtoReflect.Descriptor instead.

func (*ShardDistribution) GetNodes

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

func (*ShardDistribution) GetShards

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

func (*ShardDistribution) ProtoMessage

func (*ShardDistribution) ProtoMessage()

func (*ShardDistribution) ProtoReflect

func (x *ShardDistribution) ProtoReflect() protoreflect.Message

func (*ShardDistribution) Reset

func (x *ShardDistribution) Reset()

func (*ShardDistribution) String

func (x *ShardDistribution) String() string

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"`
	// contains filtered or unexported fields
}

func (*WireNodes) Descriptor

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

Deprecated: Use WireNodes.ProtoReflect.Descriptor instead.

func (*WireNodes) GetNodeId

func (x *WireNodes) GetNodeId() int32

func (*WireNodes) GetNodeName

func (x *WireNodes) GetNodeName() string

func (*WireNodes) ProtoMessage

func (*WireNodes) ProtoMessage()

func (*WireNodes) ProtoReflect

func (x *WireNodes) ProtoReflect() protoreflect.Message

func (*WireNodes) Reset

func (x *WireNodes) Reset()

func (*WireNodes) String

func (x *WireNodes) String() string

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"`
	// contains filtered or unexported fields
}

func (*WireShard) Descriptor

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

Deprecated: Use WireShard.ProtoReflect.Descriptor instead.

func (*WireShard) GetId

func (x *WireShard) GetId() int32

func (*WireShard) GetNodeId

func (x *WireShard) GetNodeId() int32

func (*WireShard) GetWeight

func (x *WireShard) GetWeight() int32

func (*WireShard) ProtoMessage

func (*WireShard) ProtoMessage()

func (*WireShard) ProtoReflect

func (x *WireShard) ProtoReflect() protoreflect.Message

func (*WireShard) Reset

func (x *WireShard) Reset()

func (*WireShard) String

func (x *WireShard) String() string