package lockingpromise

import "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/promise/lockingpromise"

Index ¶

• func NewWriteMultiple(lock sync.Locker, activeCounter counter.GoRoutineCounter) promise.LockingWriteMultiple
• func NewWriteOnce(lock sync.Locker, activeCounter counter.GoRoutineCounter) promise.LockingWriteOnce

Functions ¶

func NewWriteMultiple ¶

func NewWriteMultiple(lock sync.Locker, activeCounter counter.GoRoutineCounter) promise.LockingWriteMultiple

NewWriteMultiple makes a new promise.LockingWriteMultiple

func NewWriteOnce ¶

func NewWriteOnce(lock sync.Locker, activeCounter counter.GoRoutineCounter) promise.LockingWriteOnce

NewWriteOnce makes a new promise.LockingWriteOnce

Source Files ¶

lockingpromise.go