run

package
v0.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 7, 2020 License: Apache-2.0 Imports: 21 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config added in v0.7.0

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL