admission2

Nov 18, 2024

Changes in this version

+ var ErrRequestTooLarge = status.Errorf(grpccodes.InvalidArgument, "rejecting request, request is too large")

+ var ErrTooMuchWaiting = status.Error(grpccodes.ResourceExhausted, "rejecting request, too much pending data")

+ type BoundedQueue struct

+ func (bq *BoundedQueue) Acquire(ctx context.Context, pending uint64) (ReleaseFunc, error)

+ type N struct

+ func (n *N) Chan() <-chan struct{}

+ func (n *N) HasBeenNotified() bool

+ func (n *N) Notify()

+ func (n *N) WaitForNotification()

+ type Queue interface

+ Acquire func(ctx context.Context, weight uint64) (ReleaseFunc, error)

+ func NewBoundedQueue(id component.ID, ts component.TelemetrySettings, ...) (Queue, error)

+ func NewUnboundedQueue() Queue

+ type ReleaseFunc func()