util

Documentation

Index

• func NodesFromContext(client *kubernetes.Clientset, ctx context.Context, key string) ([]corev1.Node, bool, error)
• type Factory
  • func New(ctx context.Context, log *logrus.Entry, client *kubernetes.Clientset) *Factory
  • func (f *Factory) CheckKnetStress() error
  • func (f *Factory) CreateDaemonSet(filePath, namespace, name string) error
  • func (f *Factory) Delete(resources *config.Resources) error
  • func (f *Factory) DeletePodsOnNode(nodeName string) error
  • func (f *Factory) DeleteResource(filePath, namespace string) error
  • func (f *Factory) Has(resources *config.Resources) (bool, error)
  • func (f *Factory) RollNode(dryrun bool, nodeName string, watchResources *config.Resources) error
  • func (f *Factory) RunCommand(stdout io.Writer, args ...string) error
  • func (f *Factory) WaitAllReady(resources *config.Resources) error
  • func (f *Factory) WaitDaemonSetReady(namespace, name string) error

Functions

func NodesFromContext

func NodesFromContext(client *kubernetes.Clientset, ctx context.Context, key string) ([]corev1.Node, bool, error)

Types

type Factory

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

func New

func New(ctx context.Context, log *logrus.Entry, client *kubernetes.Clientset) *Factory

func (*Factory) CheckKnetStress

func (f *Factory) CheckKnetStress() error

func (*Factory) CreateDaemonSet

func (f *Factory) CreateDaemonSet(filePath, namespace, name string) error

func (*Factory) Delete

func (f *Factory) Delete(resources *config.Resources) error

func (*Factory) DeletePodsOnNode

func (f *Factory) DeletePodsOnNode(nodeName string) error

func (*Factory) DeleteResource

func (f *Factory) DeleteResource(filePath, namespace string) error

func (*Factory) Has

func (f *Factory) Has(resources *config.Resources) (bool, error)

func (*Factory) RollNode

func (f *Factory) RollNode(dryrun bool, nodeName string, watchResources *config.Resources) error

func (*Factory) RunCommand

func (f *Factory) RunCommand(stdout io.Writer, args ...string) error

func (*Factory) WaitAllReady

func (f *Factory) WaitAllReady(resources *config.Resources) error

func (*Factory) WaitDaemonSetReady

func (f *Factory) WaitDaemonSetReady(namespace, name string) error

waitDaemonSetReadynamespace will wait for a all pods in a DaemonSet to become ready