wait

Documentation

Index

• Constants
• func AreDaemonSetPodsReady(newStatus *appsv1.DaemonSetStatus) bool
• func IsDeploymentComplete(dp *appsv1.Deployment, newStatus *appsv1.DeploymentStatus) bool
• func NRTIgnoreNothing(nrt *nrtv1alpha2.NodeResourceTopology) bool
• type NRTShouldIgnoreFunc
• type ObjectKey
  • func ObjectKeyFromObject(obj metav1.Object) ObjectKey
  • func (ok ObjectKey) AsKey() types.NamespacedName
  • func (ok ObjectKey) String() string
• type PFPCount
  • func (pc PFPCount) String() string
• type PFPState
  • func (ps PFPState) AllReady(threshold int) bool
  • func (ps PFPState) CountReady(threshold int) int
  • func (ps PFPState) Len() int
  • func (ps PFPState) Observe(nodeName, pfpValue string) int
• type Waiter
  • func With(cli client.Client) *Waiter
  • func (wt Waiter) ForDaemonSetReady(ctx context.Context, ds *appsv1.DaemonSet) (*appsv1.DaemonSet, error)
  • func (wt Waiter) ForDaemonSetReadyByKey(ctx context.Context, key ObjectKey) (*appsv1.DaemonSet, error)
  • func (wt Waiter) ForDaemonsetInNUMAResourcesOperatorStatus(ctx context.Context, nroObj *nropv1.NUMAResourcesOperator) (*nropv1.NUMAResourcesOperator, error)
  • func (wt Waiter) ForDaemonsetPodsCreation(ctx context.Context, ds *appsv1.DaemonSet, expectedPods int) (*appsv1.DaemonSet, error)
  • func (wt Waiter) ForDeploymentComplete(ctx context.Context, dp *appsv1.Deployment) (*appsv1.Deployment, error)
  • func (wt Waiter) ForDeploymentReplicasCreation(ctx context.Context, dp *appsv1.Deployment, expectedReplicas int32) (*appsv1.Deployment, error)
  • func (wt Waiter) ForJobCompleted(ctx context.Context, jobNamespace, jobName string) (*batchv1.Job, error)
  • func (wt Waiter) ForKubeletConfigDeleted(ctx context.Context, kc *machineconfigv1.KubeletConfig) error
  • func (wt Waiter) ForMachineConfigPoolCondition(ctx context.Context, mcp *machineconfigv1.MachineConfigPool, ...) error
  • func (wt Waiter) ForMachineConfigPoolDeleted(ctx context.Context, mcp *machineconfigv1.MachineConfigPool) error
  • func (wt Waiter) ForNUMAResourcesOperatorDeleted(ctx context.Context, nrop *nropv1.NUMAResourcesOperator) error
  • func (wt Waiter) ForNUMAResourcesSchedulerDeleted(ctx context.Context, nrSched *nropv1.NUMAResourcesScheduler) error
  • func (wt Waiter) ForNodeResourceTopologiesEqualTo(ctx context.Context, nrtListReference *nrtv1alpha2.NodeResourceTopologyList, ...) (nrtv1alpha2.NodeResourceTopologyList, error)
  • func (wt Waiter) ForNodeResourceTopologiesEqualToPostReboot(ctx context.Context, nrtListReference *nrtv1alpha2.NodeResourceTopologyList, ...) (nrtv1alpha2.NodeResourceTopologyList, error)
  • func (wt Waiter) ForNodeResourceTopologiesSettled(ctx context.Context, threshold int, nrtShouldIgnore NRTShouldIgnoreFunc) (nrtv1alpha2.NodeResourceTopologyList, error)
  • func (wt Waiter) ForNodeResourceTopologyToHave(ctx context.Context, nrtName string, ...) (nrtv1alpha2.NodeResourceTopology, error)
  • func (wt Waiter) ForPodDeleted(ctx context.Context, podNamespace, podName string) error
  • func (wt Waiter) ForPodListAllRunning(ctx context.Context, pods []*corev1.Pod) ([]*corev1.Pod, []*corev1.Pod)
  • func (wt Waiter) ForPodPhase(ctx context.Context, podNamespace, podName string, phase corev1.PodPhase) (*corev1.Pod, error)
  • func (wt Waiter) ForReplicasetComplete(ctx context.Context, rs *appsv1.ReplicaSet) (*appsv1.ReplicaSet, error)
  • func (wt *Waiter) Interval(iv time.Duration) *Waiter
  • func (wt *Waiter) Steps(st int) *Waiter
  • func (wt *Waiter) Timeout(tt time.Duration) *Waiter
  • func (wt Waiter) WhileInPodPhase(ctx context.Context, podNamespace, podName string, phase corev1.PodPhase) error

Constants

const (
	DefaultPollInterval = 1 * time.Second
	// DefaultPollTimeout was computed by trial and error, not scientifically,
	// so it may adjusted in the future any time.
	// Roughly match the time it takes for pods to go running in CI.
	DefaultPollTimeout = 3 * time.Minute
)

Functions

func AreDaemonSetPodsReady

func AreDaemonSetPodsReady(newStatus *appsv1.DaemonSetStatus) bool

func IsDeploymentComplete

func IsDeploymentComplete(dp *appsv1.Deployment, newStatus *appsv1.DeploymentStatus) bool

func NRTIgnoreNothing

func NRTIgnoreNothing(nrt *nrtv1alpha2.NodeResourceTopology) bool

Types

type NRTShouldIgnoreFunc

type NRTShouldIgnoreFunc func(nrt *nrtv1alpha2.NodeResourceTopology) bool

type ObjectKey

type ObjectKey struct {
	Namespace string
	Name      string
}

func ObjectKeyFromObject

func ObjectKeyFromObject(obj metav1.Object) ObjectKey

func (ObjectKey) AsKey

func (ok ObjectKey) AsKey() types.NamespacedName

func (ObjectKey) String

func (ok ObjectKey) String() string

type PFPCount

type PFPCount struct {
	Value string
	Count int
}

func (PFPCount) String

func (pc PFPCount) String() string

type PFPState

type PFPState map[string]PFPCount

map nodeName -> PFPCount

func (PFPState) AllReady

func (ps PFPState) AllReady(threshold int) bool

func (PFPState) CountReady

func (ps PFPState) CountReady(threshold int) int

func (PFPState) Len

func (ps PFPState) Len() int

func (PFPState) Observe

func (ps PFPState) Observe(nodeName, pfpValue string) int

type Waiter

type Waiter struct {
	Cli          client.Client
	PollTimeout  time.Duration
	PollInterval time.Duration
	PollSteps    int // alternative to Timeout
}

func With

func With(cli client.Client) *Waiter

func (Waiter) ForDaemonSetReady

func (wt Waiter) ForDaemonSetReady(ctx context.Context, ds *appsv1.DaemonSet) (*appsv1.DaemonSet, error)

func (Waiter) ForDaemonSetReadyByKey

func (wt Waiter) ForDaemonSetReadyByKey(ctx context.Context, key ObjectKey) (*appsv1.DaemonSet, error)

func (Waiter) ForDaemonsetInNUMAResourcesOperatorStatus

func (wt Waiter) ForDaemonsetInNUMAResourcesOperatorStatus(ctx context.Context, nroObj *nropv1.NUMAResourcesOperator) (*nropv1.NUMAResourcesOperator, error)

func (Waiter) ForDaemonsetPodsCreation

func (wt Waiter) ForDaemonsetPodsCreation(ctx context.Context, ds *appsv1.DaemonSet, expectedPods int) (*appsv1.DaemonSet, error)

func (Waiter) ForDeploymentComplete

func (wt Waiter) ForDeploymentComplete(ctx context.Context, dp *appsv1.Deployment) (*appsv1.Deployment, error)

func (Waiter) ForDeploymentReplicasCreation

func (wt Waiter) ForDeploymentReplicasCreation(ctx context.Context, dp *appsv1.Deployment, expectedReplicas int32) (*appsv1.Deployment, error)

func (Waiter) ForJobCompleted

func (wt Waiter) ForJobCompleted(ctx context.Context, jobNamespace, jobName string) (*batchv1.Job, error)

func (Waiter) ForKubeletConfigDeleted

func (wt Waiter) ForKubeletConfigDeleted(ctx context.Context, kc *machineconfigv1.KubeletConfig) error

func (Waiter) ForMachineConfigPoolCondition

func (wt Waiter) ForMachineConfigPoolCondition(ctx context.Context, mcp *machineconfigv1.MachineConfigPool, condType machineconfigv1.MachineConfigPoolConditionType) error

func (Waiter) ForMachineConfigPoolDeleted

func (wt Waiter) ForMachineConfigPoolDeleted(ctx context.Context, mcp *machineconfigv1.MachineConfigPool) error

func (Waiter) ForNUMAResourcesOperatorDeleted

func (wt Waiter) ForNUMAResourcesOperatorDeleted(ctx context.Context, nrop *nropv1.NUMAResourcesOperator) error

func (Waiter) ForNUMAResourcesSchedulerDeleted

func (wt Waiter) ForNUMAResourcesSchedulerDeleted(ctx context.Context, nrSched *nropv1.NUMAResourcesScheduler) error

func (Waiter) ForNodeResourceTopologiesEqualTo

func (wt Waiter) ForNodeResourceTopologiesEqualTo(ctx context.Context, nrtListReference *nrtv1alpha2.NodeResourceTopologyList, nrtShouldIgnore NRTShouldIgnoreFunc) (nrtv1alpha2.NodeResourceTopologyList, error)

func (Waiter) ForNodeResourceTopologiesEqualToPostReboot

func (wt Waiter) ForNodeResourceTopologiesEqualToPostReboot(ctx context.Context, nrtListReference *nrtv1alpha2.NodeResourceTopologyList, nrtShouldIgnore NRTShouldIgnoreFunc, isRebootTest bool) (nrtv1alpha2.NodeResourceTopologyList, error)

func (Waiter) ForNodeResourceTopologiesSettled

func (wt Waiter) ForNodeResourceTopologiesSettled(ctx context.Context, threshold int, nrtShouldIgnore NRTShouldIgnoreFunc) (nrtv1alpha2.NodeResourceTopologyList, error)

func (Waiter) ForNodeResourceTopologyToHave

func (wt Waiter) ForNodeResourceTopologyToHave(ctx context.Context, nrtName string, haveResourceFunc func(resInfo nrtv1alpha2.ResourceInfo) bool) (nrtv1alpha2.NodeResourceTopology, error)

func (Waiter) ForPodDeleted

func (wt Waiter) ForPodDeleted(ctx context.Context, podNamespace, podName string) error

func (Waiter) ForPodListAllRunning

func (wt Waiter) ForPodListAllRunning(ctx context.Context, pods []*corev1.Pod) ([]*corev1.Pod, []*corev1.Pod)

func (Waiter) ForPodPhase

func (wt Waiter) ForPodPhase(ctx context.Context, podNamespace, podName string, phase corev1.PodPhase) (*corev1.Pod, error)

func (Waiter) ForReplicasetComplete

func (wt Waiter) ForReplicasetComplete(ctx context.Context, rs *appsv1.ReplicaSet) (*appsv1.ReplicaSet, error)

func (*Waiter) Interval

func (wt *Waiter) Interval(iv time.Duration) *Waiter

func (*Waiter) Steps

func (wt *Waiter) Steps(st int) *Waiter

func (*Waiter) Timeout

func (wt *Waiter) Timeout(tt time.Duration) *Waiter

func (Waiter) WhileInPodPhase

func (wt Waiter) WhileInPodPhase(ctx context.Context, podNamespace, podName string, phase corev1.PodPhase) error