dryrun

Documentation

Index

• func NewWaiter() apiclient.Waiter
• func PrintDryRunFiles(files []FileToPrint, w io.Writer) error
• type FileToPrint
  • func NewFileToPrint(realPath, printPath string) FileToPrint
• type Waiter
  • func (w *Waiter) SetTimeout(_ time.Duration)
  • func (w *Waiter) WaitForAPI() error
  • func (w *Waiter) WaitForHealthyKubelet(_ time.Duration, healthzEndpoint string) error
  • func (w *Waiter) WaitForPodToDisappear(podName string) error
  • func (w *Waiter) WaitForPodsWithLabel(kvLabel string) error
  • func (w *Waiter) WaitForStaticPodControlPlaneHashChange(_, _, _ string) error
  • func (w *Waiter) WaitForStaticPodControlPlaneHashes(_ string) (map[string]string, error)
  • func (w *Waiter) WaitForStaticPodSingleHash(_ string, _ string) (string, error)

Functions

func NewWaiter

func NewWaiter() apiclient.Waiter

NewWaiter returns a new Waiter object that talks to the given Kubernetes cluster

func PrintDryRunFiles

func PrintDryRunFiles(files []FileToPrint, w io.Writer) error

PrintDryRunFiles prints the contents of the FileToPrints given to it to the writer w

Types

type FileToPrint

type FileToPrint struct {
	RealPath  string
	PrintPath string
}

FileToPrint represents a temporary file on disk that might want to be aliased when printing Useful for things like loading a file from /tmp/ but saying to the user "Would write file foo to /etc/kubernetes/..."

func NewFileToPrint

func NewFileToPrint(realPath, printPath string) FileToPrint

NewFileToPrint makes a new instance of FileToPrint with the specified arguments

type Waiter

type Waiter struct{}

Waiter is an implementation of apiclient.Waiter that should be used for dry-running

func (*Waiter) SetTimeout

func (w *Waiter) SetTimeout(_ time.Duration)

SetTimeout is a no-op; we don't wait in this implementation

func (*Waiter) WaitForAPI

func (w *Waiter) WaitForAPI() error

WaitForAPI just returns a dummy nil, to indicate that the program should just proceed

func (*Waiter) WaitForHealthyKubelet

func (w *Waiter) WaitForHealthyKubelet(_ time.Duration, healthzEndpoint string) error

WaitForHealthyKubelet blocks until the kubelet /healthz endpoint returns 'ok'

func (*Waiter) WaitForPodToDisappear

func (w *Waiter) WaitForPodToDisappear(podName string) error

WaitForPodToDisappear just returns a dummy nil, to indicate that the program should just proceed

func (*Waiter) WaitForPodsWithLabel

func (w *Waiter) WaitForPodsWithLabel(kvLabel string) error

WaitForPodsWithLabel just returns a dummy nil, to indicate that the program should just proceed

func (*Waiter) WaitForStaticPodControlPlaneHashChange

func (w *Waiter) WaitForStaticPodControlPlaneHashChange(_, _, _ string) error

WaitForStaticPodControlPlaneHashChange returns a dummy nil error in order for the flow to just continue as we're dryrunning

func (*Waiter) WaitForStaticPodControlPlaneHashes

func (w *Waiter) WaitForStaticPodControlPlaneHashes(_ string) (map[string]string, error)

WaitForStaticPodControlPlaneHashes returns an empty hash for all control plane images; WaitForStaticPodControlPlaneHashChange won't block in any case but the empty strings there are needed

func (*Waiter) WaitForStaticPodSingleHash

func (w *Waiter) WaitForStaticPodSingleHash(_ string, _ string) (string, error)

WaitForStaticPodSingleHash returns an empty hash but the empty strings there are needed