package progress

import "k8s.io/apiserver/pkg/storage/cacher/progress"

Index ¶

• type ConditionalProgressRequester
• func NewConditionalProgressRequester(requestWatchProgress WatchProgressRequester, clock TickerFactory, contextMetadata metadata.MD) *ConditionalProgressRequester
• func (pr *ConditionalProgressRequester) Add()
• func (pr *ConditionalProgressRequester) Remove()
• func (pr *ConditionalProgressRequester) Run(stopCh <-chan struct{})
• type TickerFactory
• type WatchProgressRequester

Types ¶

type ConditionalProgressRequester ¶

type ConditionalProgressRequester struct {
	// contains filtered or unexported fields
}

ConditionalProgressRequester will request progress notification if there is a request waiting for watch cache to be fresh.

func NewConditionalProgressRequester ¶

func NewConditionalProgressRequester(requestWatchProgress WatchProgressRequester, clock TickerFactory, contextMetadata metadata.MD) *ConditionalProgressRequester

func (*ConditionalProgressRequester) Add ¶

func (pr *ConditionalProgressRequester) Add()

func (*ConditionalProgressRequester) Remove ¶

func (pr *ConditionalProgressRequester) Remove()

func (*ConditionalProgressRequester) Run ¶

func (pr *ConditionalProgressRequester) Run(stopCh <-chan struct{})

type TickerFactory ¶

type TickerFactory interface {
	NewTimer(time.Duration) clock.Timer
}

type WatchProgressRequester ¶

type WatchProgressRequester func(ctx context.Context) error

Source Files ¶

watch_progress.go