Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WorkqueuePuller ¶
type WorkqueuePuller[T comparable] struct { // contains filtered or unexported fields }
func NewWorkqueuePuller ¶
func NewWorkqueuePuller[T comparable](workqueue workqueue.TypedRateLimitingInterface[T]) *WorkqueuePuller[T]
func (*WorkqueuePuller[T]) Run ¶
func (p *WorkqueuePuller[T]) Run(ctx context.Context)
func (*WorkqueuePuller[T]) Work ¶
func (p *WorkqueuePuller[T]) Work() <-chan T
Source Files
Click to show internal directories.
Click to hide internal directories.