watcher

package
v0.12.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 21, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Copyright 2025 NVIDIA CORPORATION SPDX-License-Identifier: Apache-2.0

Copyright 2025 NVIDIA CORPORATION SPDX-License-Identifier: Apache-2.0

Copyright 2025 NVIDIA CORPORATION SPDX-License-Identifier: Apache-2.0

Copyright 2025 NVIDIA CORPORATION SPDX-License-Identifier: Apache-2.0

Index

Constants

This section is empty.

Variables

View Source
var (
	FlowTimeout = 5 * time.Minute
)

Functions

func ForEvent

func ForEvent(ctx context.Context, client runtimeClient.WithWatch, eventWatcher Interface) bool

func ForEventCustomTimeout

func ForEventCustomTimeout(ctx context.Context, client runtimeClient.WithWatch, eventWatcher Interface,
	waitTime time.Duration) bool

Types

type CheckCondition

type CheckCondition func(watch.Event) bool

type GenericWatcher

type GenericWatcher[T any, PT interface {
	*T
	runtimeClient.ObjectList
}] struct {
	// contains filtered or unexported fields
}

func NewGenericWatcher

func NewGenericWatcher[T any, PT interface {
	*T
	runtimeClient.ObjectList
}](
	client runtimeClient.WithWatch, condition CheckCondition, listOptions ...runtimeClient.ListOption,
) *GenericWatcher[T, PT]

type Interface

type Interface interface {
	// contains filtered or unexported methods
}

type PodsWatcher

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

func NewPodsWatcher

func NewPodsWatcher(
	client runtimeClient.WithWatch, condition CheckCondition, namespace string, pods []*corev1.Pod, minRequired int,
) *PodsWatcher

type PollCondition

type PollCondition func() bool

type PollWatcher

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

func NewPollWatcher

func NewPollWatcher(client runtimeClient.WithWatch, condition PollCondition) *PollWatcher

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL