keycollector

Documentation

Overview

Package keycollector features a utility that is used for testing scheduler-related logic.

Index

• type SchedulerWorkqueueKeyCollector
  • func NewSchedulerWorkqueueKeyCollector(wq queue.ClusterResourcePlacementSchedulingQueue) *SchedulerWorkqueueKeyCollector
  • func (kc *SchedulerWorkqueueKeyCollector) IsPresent(keys ...string) (isAllPresent bool, absentKeys []string)
  • func (kc *SchedulerWorkqueueKeyCollector) Len() int
  • func (kc *SchedulerWorkqueueKeyCollector) Reset()
  • func (kc *SchedulerWorkqueueKeyCollector) Run(ctx context.Context)

Types

type SchedulerWorkqueueKeyCollector

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

SchedulerWorkqueueKeyCollector helps collect keys from a scheduler work queue for testing purposes.

func NewSchedulerWorkqueueKeyCollector

func NewSchedulerWorkqueueKeyCollector(wq queue.ClusterResourcePlacementSchedulingQueue) *SchedulerWorkqueueKeyCollector

NewSchedulerWorkqueueKeyCollector returns a new SchedulerWorkqueueKeyCollector.

func (*SchedulerWorkqueueKeyCollector) IsPresent

func (kc *SchedulerWorkqueueKeyCollector) IsPresent(keys ...string) (isAllPresent bool, absentKeys []string)

IsPresent returns whether a given key is has been collected.

func (*SchedulerWorkqueueKeyCollector) Len

func (kc *SchedulerWorkqueueKeyCollector) Len() int

Len returns the count of collected keys.

func (*SchedulerWorkqueueKeyCollector) Reset

func (kc *SchedulerWorkqueueKeyCollector) Reset()

Reset clears all the collected keys.

func (*SchedulerWorkqueueKeyCollector) Run

func (kc *SchedulerWorkqueueKeyCollector) Run(ctx context.Context)

Run runs the SchedulerWorkqueueKeyCollector.