Documentation
¶
Index ¶
- Constants
- func BestEffortSleeper() *corev1.Pod
- func DeleteAsync(ctx context.Context, f *framework.Framework, podMap map[string]*corev1.Pod)
- func DeleteSyncByName(ctx context.Context, f *framework.Framework, podName string)
- func GuaranteedSleeper(opts ...func(pod *corev1.Pod)) *corev1.Pod
- func NFDGCSpec(opts ...SpecOption) *corev1.PodSpec
- func NFDMaster(opts ...SpecOption) *corev1.Pod
- func NFDTopologyUpdaterSpec(kc utils.KubeletConfig, opts ...SpecOption) *corev1.PodSpec
- func NFDWorker(opts ...SpecOption) *corev1.Pod
- func WaitForReady(ctx context.Context, c clientset.Interface, ns, name string, ...) error
- func WithLimits(list corev1.ResourceList) func(p *corev1.Pod)
- type SpecOption
- func SpecWithConfigMap(name, mountPath string) SpecOption
- func SpecWithContainerExtraArgs(args ...string) SpecOption
- func SpecWithContainerImage(image string) SpecOption
- func SpecWithMasterNodeSelector(args ...string) SpecOption
- func SpecWithRestartPolicy(restartpolicy corev1.RestartPolicy) SpecOption
- func SpecWithTolerations(tolerations []corev1.Toleration) SpecOption
Constants ¶
const (
PauseImage = "registry.k8s.io/pause"
)
Variables ¶
This section is empty.
Functions ¶
func BestEffortSleeper ¶
BestEffortSleeper makes a Best Effort QoS class Pod object which sleeps long enough
func DeleteAsync ¶
DeleteAsync concurrently deletes all the pods in the given name:pod_object mapping. Returns when the longer operation ends.
func DeleteSyncByName ¶
DeleteSyncByName deletes the pod identified by `podName` in the current namespace
func GuaranteedSleeper ¶
GuaranteedSleeper makes a Guaranteed QoS class Pod object which long enough forever but requires `cpuLimit` exclusive CPUs.
func NFDGCSpec ¶
func NFDGCSpec(opts ...SpecOption) *corev1.PodSpec
func NFDMaster ¶
func NFDMaster(opts ...SpecOption) *corev1.Pod
NFDMaster provide NFD master pod definition
func NFDTopologyUpdaterSpec ¶
func NFDTopologyUpdaterSpec(kc utils.KubeletConfig, opts ...SpecOption) *corev1.PodSpec
func NFDWorker ¶
func NFDWorker(opts ...SpecOption) *corev1.Pod
NFDWorker provides NFD worker pod definition
func WaitForReady ¶
func WaitForReady(ctx context.Context, c clientset.Interface, ns, name string, minReadySeconds int) error
WaitForReady waits for the pods to become ready. NOTE: copied from k8s v1.22 after which is was removed from there. Convenient for checking that all pods of a daemonset are ready.
func WithLimits ¶
func WithLimits(list corev1.ResourceList) func(p *corev1.Pod)
Types ¶
type SpecOption ¶
func SpecWithConfigMap ¶
func SpecWithConfigMap(name, mountPath string) SpecOption
SpecWithConfigMap returns a SpecOption that mounts a configmap to the first container.
func SpecWithContainerExtraArgs ¶
func SpecWithContainerExtraArgs(args ...string) SpecOption
SpecWithContainerExtraArgs returns a SpecOption that adds extra args to the first container.
func SpecWithContainerImage ¶
func SpecWithContainerImage(image string) SpecOption
SpecWithContainerImage returns a SpecOption that sets the image used by the first container.
func SpecWithMasterNodeSelector ¶
func SpecWithMasterNodeSelector(args ...string) SpecOption
SpecWithMasterNodeSelector returns a SpecOption that modifies the pod to be run on a control plane node of the cluster.
func SpecWithRestartPolicy ¶
func SpecWithRestartPolicy(restartpolicy corev1.RestartPolicy) SpecOption
SpecWithRestartPolicy returns a SpecOption that sets the pod restart policy
func SpecWithTolerations ¶
func SpecWithTolerations(tolerations []corev1.Toleration) SpecOption
SpecWithTolerations returns a SpecOption that modifies the pod to be run on a node with NodeFeatureRule taints.
Source Files