Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Partitioner ¶
type Partitioner struct {
// contains filtered or unexported fields
}
func (*Partitioner) Insert ¶
func (p *Partitioner) Insert(name []byte)
func (*Partitioner) Remove ¶
func (p *Partitioner) Remove(name []byte)
func (*Partitioner) RingRange ¶
func (p *Partitioner) RingRange(id []byte) [][]byte
func (*Partitioner) RingRanges ¶
func (p *Partitioner) RingRanges(scs []SplitCollumn, sizePerRange int)
type SplitCollumn ¶
func SplittenMessage ¶
func SplittenMessage(msg []byte) []SplitCollumn
func (SplitCollumn) String ¶
func (s SplitCollumn) String() string
Click to show internal directories.
Click to hide internal directories.