daemonset

Documentation

Index

• func WaitFor(name string, namespace string) features.Func
• func WaitForPodsDeletion(ownerName string, namespace string) ...
• type PodConsumer
• type Query
  • func NewQuery(ctx context.Context, resource *resources.Resources, objectKey client.ObjectKey) *Query
  • func (query *Query) ForEachPod(consumer PodConsumer) error
  • func (query *Query) Get() (appsv1.DaemonSet, error)

Functions

func WaitFor

func WaitFor(name string, namespace string) features.Func

func WaitForPodsDeletion

func WaitForPodsDeletion(ownerName string, namespace string) func(ctx context.Context, environmentConfig *envconf.Config, t *testing.T) (context.Context, error)

Types

type PodConsumer

type PodConsumer func(pod corev1.Pod)

type Query

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

func NewQuery

func NewQuery(ctx context.Context, resource *resources.Resources, objectKey client.ObjectKey) *Query

func (*Query) ForEachPod

func (query *Query) ForEachPod(consumer PodConsumer) error

func (*Query) Get

func (query *Query) Get() (appsv1.DaemonSet, error)