partition

Documentation

Index

• type DefaultPartition
  • func NewDefaultPartition(partition uint64, sitePool SitePool) *DefaultPartition
  • func (partition *DefaultPartition) Iterator() PartitionIterator
  • func (partition *DefaultPartition) LockReads()
  • func (partition *DefaultPartition) LockWrites()
  • func (partition *DefaultPartition) Partition() uint64
  • func (partition *DefaultPartition) Sites() SitePool
  • func (partition *DefaultPartition) UnlockReads()
  • func (partition *DefaultPartition) UnlockWrites()
• type DefaultPartitionFactory
  • func NewDefaultPartitionFactory() *DefaultPartitionFactory
  • func (partitionFactory *DefaultPartitionFactory) CreatePartition(partitionNumber uint64, sitePool SitePool) Partition
• type DefaultPartitionPool
  • func NewDefaultPartitionPool() *DefaultPartitionPool
  • func (partitionPool *DefaultPartitionPool) Add(partition Partition)
  • func (partitionPool *DefaultPartitionPool) Get(partitionNumber uint64) Partition
  • func (partitionPool *DefaultPartitionPool) Remove(partitionNumber uint64)
• type Partition
• type PartitionFactory
• type PartitionIterator
• type PartitionPool

Types

type DefaultPartition

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

func NewDefaultPartition

func NewDefaultPartition(partition uint64, sitePool SitePool) *DefaultPartition

func (*DefaultPartition) Iterator

func (partition *DefaultPartition) Iterator() PartitionIterator

func (*DefaultPartition) LockReads

func (partition *DefaultPartition) LockReads()

func (*DefaultPartition) LockWrites

func (partition *DefaultPartition) LockWrites()

func (*DefaultPartition) Partition

func (partition *DefaultPartition) Partition() uint64

func (*DefaultPartition) Sites

func (partition *DefaultPartition) Sites() SitePool

func (*DefaultPartition) UnlockReads

func (partition *DefaultPartition) UnlockReads()

func (*DefaultPartition) UnlockWrites

func (partition *DefaultPartition) UnlockWrites()

type DefaultPartitionFactory

type DefaultPartitionFactory struct {
}

func NewDefaultPartitionFactory

func NewDefaultPartitionFactory() *DefaultPartitionFactory

func (*DefaultPartitionFactory) CreatePartition

func (partitionFactory *DefaultPartitionFactory) CreatePartition(partitionNumber uint64, sitePool SitePool) Partition

type DefaultPartitionPool

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

func NewDefaultPartitionPool

func NewDefaultPartitionPool() *DefaultPartitionPool

func (*DefaultPartitionPool) Add

func (partitionPool *DefaultPartitionPool) Add(partition Partition)

func (*DefaultPartitionPool) Get

func (partitionPool *DefaultPartitionPool) Get(partitionNumber uint64) Partition

func (*DefaultPartitionPool) Remove

func (partitionPool *DefaultPartitionPool) Remove(partitionNumber uint64)

type Partition

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

type PartitionFactory

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

type PartitionIterator

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

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