run

package

v0.3.0 Latest Latest Go to latest Published: Jun 7, 2018 License: Apache-2.0 Imports: 22 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Runtime struct {
	SigChan chan os.Signal

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

func NewRunner(env *setup.Environment) *Runtime

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) SearchStaticPods(pods []v1.Pod) []v1.Pod

func (r *Runtime) Stop() error

type State struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (s *State) GetKubeletLogsPodRunning() int

func (s *State) GetKubeletProbeFail() int

func (s *State) IncKubeletProbeFailures()

func (s *State) IsReady() bool

func (s *State) SetAPIServerProbeLastError(msg string)

func (s *State) SetKubeletAPIPodRunning(nb int)

func (s *State) SetKubeletLogsPodRunning(nb int)

func (s *State) SetReady()