run

Documentation

Index

• type Config
• type Runtime
  • func NewRunner(env *setup.Environment, conf *Config) (*Runtime, error)
  • func (r *Runtime) DeleteAPIManifests(namespaces *corev1.NamespaceList) error
  • func (r *Runtime) GetKubeletPods() ([]v1.Pod, error)
  • func (r *Runtime) GetKubeletRunningPods() ([]v1.Pod, error)
  • func (r *Runtime) GetKubeletStaticPods() ([]v1.Pod, error)
  • func (r *Runtime) Run() error
  • func (r *Runtime) Stop(withError error) error

Types

type Config

type Config struct {
	// RunTimeout is the total time to run
	RunTimeout time.Duration

	// KubeletGCTimeout is the duration period to wait until the kubelet is garbage collected
	KubeletGCTimeout time.Duration

	// ReadinessDNSQueries are the dns query to execute to ack the readiness
	ReadinessDNSQueries []string

	// SkipProbes allows to discard any check on the environment to keep running
	SkipProbes bool
}

Config for the Runtime

type Runtime

type Runtime struct {
	SigChan chan os.Signal

	ApplyChan chan struct{}
	// contains filtered or unexported fields
}

Runtime is the main state to execute a managed pupernetes Run

func NewRunner

func NewRunner(env *setup.Environment, conf *Config) (*Runtime, error)

NewRunner instantiate a new Runtimer with the given Environment

func (*Runtime) DeleteAPIManifests

func (r *Runtime) DeleteAPIManifests(namespaces *corev1.NamespaceList) error

DeleteAPIManifests execute Kubernetes delete API calls to delete the following resources: - services - Jobs - Deployments - Daemonset - ReplicationController - ReplicaSets - Pods - Endpoints - ConfigMaps - Secrets - ServiceAccounts

func (*Runtime) GetKubeletPods

func (r *Runtime) GetKubeletPods() ([]v1.Pod, error)

GetKubeletPods returns the pods reported by the kubelet API /pods The certificate setup needs to be valid

func (*Runtime) GetKubeletRunningPods

func (r *Runtime) GetKubeletRunningPods() ([]v1.Pod, error)

GetKubeletRunningPods run GetKubeletPods and then only filter the running ones. It excludes static pods

func (*Runtime) GetKubeletStaticPods

func (r *Runtime) GetKubeletStaticPods() ([]v1.Pod, error)

GetKubeletStaticPods returns the kubelet running static pods

func (*Runtime) Run

func (r *Runtime) Run() error

Run daemonise pupernetes

func (*Runtime) Stop

func (r *Runtime) Stop(withError error) error

Stop drain and tear down the current runtime, if withError is set, this error will be returned