partition

type DefaultPartition struct {
	// contains filtered or unexported fields
}

type DefaultPartitionFactory struct {
}

type DefaultPartitionPool struct {
	// contains filtered or unexported fields
}

type Partition interface {
	Partition() uint64
	Sites() SitePool
	Iterator() PartitionIterator
	LockWrites()
	UnlockWrites()
	LockReads()
	UnlockReads()
}

type PartitionFactory interface {
	CreatePartition(partitionNumber uint64, sitePool SitePool) Partition
}

type PartitionIterator interface {
	Next() bool
	// The site that the current entry belongs to
	Site() string
	// The bucket that the current entry belongs to within its site
	Bucket() string
	// The key of the current entry
	Key() string
	// The value of the current entry
	Value() *SiblingSet
	// The checksum of the current entry
	Release()
	Error() error
}

type PartitionPool interface {
	Add(partition Partition)
	Remove(partitionNumber uint64)
	Get(partitionNumber uint64) Partition
}