buckets

Documentation

Index

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

Functions

func NewBucketWorker

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

Types

type BucketWorker

type BucketWorker interface {
	Stop()

	Doc(string) *api.OpenShiftClusterDocument
	DeleteDoc(*api.OpenShiftClusterDocument)
	UpsertDoc(*api.OpenShiftClusterDocument)
}

type WorkerFunc

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