Documentation ¶
Index ¶
- Constants
- type Environment
- func (e *Environment) Clean() error
- func (e *Environment) GetDBUSClient() *dbus.Conn
- func (e *Environment) GetDNSClusterIP() string
- 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) GetManifestsPathToApply() string
- func (e *Environment) GetPublicIP() string
- func (e *Environment) GetResolvConfPath() string
- func (e *Environment) GetStaticPodPaths() ([]string, error)
- func (e *Environment) GetSystemdUnitPrefix() string
- 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 isn't configurable, it's a directory where the kubelet // store Pods/containers logs KubeletCRILogPath = "/var/log/pods/" )
const (
// UnitPath is the systemd target where systemd links are created
UnitPath = "/run/systemd/system/"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Environment ¶
type Environment struct {
// contains filtered or unexported fields
}
Environment is the main structure to configure the project
func NewConfigSetup ¶
func NewConfigSetup(givenRootPath string) (*Environment, error)
NewConfigSetup creates an Environment TODO this should be refactored with the viper migration TODO see https://github.com/DataDog/pupernetes/issues/40
func (*Environment) Clean ¶
func (e *Environment) Clean() error
Clean the current environment on given cleanOptions
func (*Environment) GetDBUSClient ¶
func (e *Environment) GetDBUSClient() *dbus.Conn
GetDBUSClient returns a connected dbus client
func (*Environment) GetDNSClusterIP ¶ added in v0.6.0
func (e *Environment) GetDNSClusterIP() string
GetDNSClusterIP returns the dns cluster ip
func (*Environment) GetHostname ¶
func (e *Environment) GetHostname() string
GetHostname returns the currently used hostname
func (*Environment) GetHyperkubePath ¶
func (e *Environment) GetHyperkubePath() string
GetHyperkubePath returns the hyperkube binary abstract path
func (*Environment) GetKubeconfigAuthPath ¶
func (e *Environment) GetKubeconfigAuthPath() string
GetKubeconfigAuthPath returns the kube-config abstract path containing secrets to connect to the kube-apiserver
func (*Environment) GetKubeconfigInsecurePath ¶
func (e *Environment) GetKubeconfigInsecurePath() string
GetKubeconfigInsecurePath returns the kube-config abstract path to reach the kube-apiserver without any authN/Z
func (*Environment) GetKubeletClient ¶
func (e *Environment) GetKubeletClient() *http.Client
GetKubeletClient returns a http client intended to query the kubelet API
func (*Environment) GetKubeletHealthzPort ¶
func (e *Environment) GetKubeletHealthzPort() int
GetKubeletHealthzPort returns the healthz kubelet port TODO conf this
func (*Environment) GetKubeletPodListReq ¶
func (e *Environment) GetKubeletPodListReq() *http.Request
GetKubeletPodListReq returns an http request to query the kubelet API
func (*Environment) GetKubernetesClient ¶
func (e *Environment) GetKubernetesClient() *kubernetes.Clientset
GetKubernetesClient returns a configured kubernetes client
func (*Environment) GetManifestsPathToApply ¶ added in v0.6.0
func (e *Environment) GetManifestsPathToApply() string
GetManifestsPathToApply returns the abstract path where Kubernetes manifests to apply are
func (*Environment) GetPublicIP ¶
func (e *Environment) GetPublicIP() string
GetPublicIP returns the public ip address
func (*Environment) GetResolvConfPath ¶
func (e *Environment) GetResolvConfPath() string
GetResolvConfPath returns an abstract path of the resolv.conf file
func (*Environment) GetStaticPodPaths ¶
func (e *Environment) GetStaticPodPaths() ([]string, error)
GetStaticPodPaths returns the abstract path where static pods are stored
func (*Environment) GetSystemdUnitPrefix ¶ added in v0.5.0
func (e *Environment) GetSystemdUnitPrefix() string
GetSystemdUnitPrefix returns the prefix used with systemd units
func (*Environment) GetSystemdUnits ¶ added in v0.3.0
func (e *Environment) GetSystemdUnits() []string
GetSystemdUnits returns the systemd units to manage: - etcd - kube-apiserver - kubelet
func (*Environment) IsCleaningIptables ¶
func (e *Environment) IsCleaningIptables() bool
IsCleaningIptables is a getter over the drainOptions
func (*Environment) IsDrainingPods ¶
func (e *Environment) IsDrainingPods() bool
IsDrainingPods is a getter over the drainOptions
func (*Environment) IsSkippingStop ¶
func (e *Environment) IsSkippingStop() bool
IsSkippingStop is a getter over the drainOptions
func (*Environment) IsWaitingKubeletGC ¶
func (e *Environment) IsWaitingKubeletGC() bool
IsWaitingKubeletGC is a getter over the drainOptions