setup

Documentation

Index

• Constants
• type Environment
  • func NewConfigSetup(givenRootPath string) (*Environment, error)
  • func (e *Environment) Clean() error
  • func (e *Environment) GetDBUSClient() *dbus.Conn
  • func (e *Environment) GetHostname() string
  • func (e *Environment) GetHyperkubePath() string
  • func (e *Environment) GetKubeconfigAuthPath() string
  • func (e *Environment) GetKubeconfigInsecurePath() string
  • func (e *Environment) GetKubeletClient() *http.Client
  • func (e *Environment) GetKubeletHealthzPort() int
  • func (e *Environment) GetKubeletPodListReq() *http.Request
  • func (e *Environment) GetKubernetesClient() *kubernetes.Clientset
  • func (e *Environment) GetManifestsABSPathToApply() string
  • func (e *Environment) GetPublicIP() string
  • func (e *Environment) GetResolvConfPath() string
  • func (e *Environment) GetStaticPodPaths() ([]string, error)
  • func (e *Environment) GetSystemdUnits() []string
  • func (e *Environment) IsCleaningIptables() bool
  • func (e *Environment) IsDrainingPods() bool
  • func (e *Environment) IsSkippingStop() bool
  • func (e *Environment) IsWaitingKubeletGC() bool
  • func (e *Environment) Setup() error

Constants

const (
	KubeletCRILogPath = "/var/log/pods/"
)

const (
	UnitPath = "/run/systemd/system/"
)

Types

type Environment

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

func NewConfigSetup

func NewConfigSetup(givenRootPath string) (*Environment, error)

func (*Environment) Clean

func (e *Environment) Clean() error

func (*Environment) GetDBUSClient

func (e *Environment) GetDBUSClient() *dbus.Conn

func (*Environment) GetHostname

func (e *Environment) GetHostname() string

func (*Environment) GetHyperkubePath

func (e *Environment) GetHyperkubePath() string

func (*Environment) GetKubeconfigAuthPath

func (e *Environment) GetKubeconfigAuthPath() string

func (*Environment) GetKubeconfigInsecurePath

func (e *Environment) GetKubeconfigInsecurePath() string

func (*Environment) GetKubeletClient

func (e *Environment) GetKubeletClient() *http.Client

func (*Environment) GetKubeletHealthzPort

func (e *Environment) GetKubeletHealthzPort() int

TODO conf this

func (*Environment) GetKubeletPodListReq

func (e *Environment) GetKubeletPodListReq() *http.Request

func (*Environment) GetKubernetesClient

func (e *Environment) GetKubernetesClient() *kubernetes.Clientset

func (*Environment) GetManifestsABSPathToApply

func (e *Environment) GetManifestsABSPathToApply() string

func (*Environment) GetPublicIP

func (e *Environment) GetPublicIP() string

GetPublicIP should panic if nil

func (*Environment) GetResolvConfPath

func (e *Environment) GetResolvConfPath() string

func (*Environment) GetStaticPodPaths

func (e *Environment) GetStaticPodPaths() ([]string, error)

func (*Environment) GetSystemdUnits

func (e *Environment) GetSystemdUnits() []string

func (*Environment) IsCleaningIptables

func (e *Environment) IsCleaningIptables() bool

func (*Environment) IsDrainingPods

func (e *Environment) IsDrainingPods() bool

func (*Environment) IsSkippingStop

func (e *Environment) IsSkippingStop() bool

func (*Environment) IsWaitingKubeletGC

func (e *Environment) IsWaitingKubeletGC() bool

func (*Environment) Setup

func (e *Environment) Setup() error