buckets

Documentation

Index

• func NewBucketWorker[E Bucketable](log *logrus.Entry, worker WorkerFunc, mu *sync.RWMutex) *monitor[E]
• type BucketWorker
• type Bucketable
• type WorkerFunc

Functions

func NewBucketWorker

func NewBucketWorker[E Bucketable](log *logrus.Entry, worker WorkerFunc, mu *sync.RWMutex) *monitor[E]

Types

type BucketWorker

type BucketWorker[E Bucketable] interface {
	Stop()
	Size() int
	SetBuckets([]int)

	Doc(string) (E, bool)
	DeleteDoc(E)
	UpsertDoc(E)
}

type Bucketable

type Bucketable interface {
	GetID() string
	GetBucket() int
	GetKey() string
}

type WorkerFunc

type WorkerFunc func(<-chan struct{}, string)