Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrPartitionsMustBeGreaterThanZero = errors.New("partitions must be greater than 0")
Functions ¶
This section is empty.
Types ¶
type HashSumPartitioner ¶
type HashSumPartitioner struct {
// contains filtered or unexported fields
}
HashSumPartitioner implements a Partitioner using a hash sum.
type PartMap ¶
type PartMap struct {
// contains filtered or unexported fields
}
PartMap is a concurrent map with separate partitions to reduce lock contention.
func New ¶
func New(partitioner Partitioner, partitions uint) (*PartMap, error)
New creates a new PartMap with the given number of partitions and Partitioner.
type Partitioner ¶
Partitioner defines the interface for partition finding strategies.
Click to show internal directories.
Click to hide internal directories.