daemonset

Documentation

Index

• func CheckDaemonPodOnNodes(f *framework.Framework, ds *appsv1.DaemonSet, nodeNames []string) func(ctx context.Context) (bool, error)
• func CheckDaemonStatus(ctx context.Context, f *framework.Framework, dsName string) error
• func CheckPresentOnNodes(ctx context.Context, c clientset.Interface, ds *appsv1.DaemonSet, ns string, ...) (bool, error)
• func CheckRunningOnAllNodes(ctx context.Context, f *framework.Framework, ds *appsv1.DaemonSet) (bool, error)
• func NewDaemonSet(dsName, image string, labels map[string]string, volumes []v1.Volume, ...) *appsv1.DaemonSet
• func SchedulableNodes(ctx context.Context, c clientset.Interface, ds *appsv1.DaemonSet) []string

Functions

func CheckDaemonPodOnNodes

func CheckDaemonPodOnNodes(f *framework.Framework, ds *appsv1.DaemonSet, nodeNames []string) func(ctx context.Context) (bool, error)

func CheckDaemonStatus

func CheckDaemonStatus(ctx context.Context, f *framework.Framework, dsName string) error

CheckDaemonStatus ensures that eventually the daemon set has the desired number of pods scheduled and ready. It returns a descriptive error if that state is not reached in the amount of time it takes to start pods. f.Timeouts.PodStart can be changed to influence that timeout.

func CheckPresentOnNodes

func CheckPresentOnNodes(ctx context.Context, c clientset.Interface, ds *appsv1.DaemonSet, ns string, numNodes int) (bool, error)

CheckPresentOnNodes will check that the daemonset will be present on at least the given number of schedulable nodes.

func CheckRunningOnAllNodes

func CheckRunningOnAllNodes(ctx context.Context, f *framework.Framework, ds *appsv1.DaemonSet) (bool, error)

func NewDaemonSet

func NewDaemonSet(dsName, image string, labels map[string]string, volumes []v1.Volume, mounts []v1.VolumeMount, ports []v1.ContainerPort, args ...string) *appsv1.DaemonSet

func SchedulableNodes

func SchedulableNodes(ctx context.Context, c clientset.Interface, ds *appsv1.DaemonSet) []string