kubelet

Documentation

Index

• func InitNodeAuthorizedClient(kubeletKubeConfigPath string) (*kubernetes.Clientset, error)
• func ReadAll(r io.Reader) ([]byte, error)
• type KubeletClient
  • func NewKubeletClient(config *KubeletClientConfig) (*KubeletClient, error)
  • func (k *KubeletClient) GetNodeRunningPods() (*v1.PodList, error)
• type KubeletClientConfig

Functions

func InitNodeAuthorizedClient

func InitNodeAuthorizedClient(kubeletKubeConfigPath string) (*kubernetes.Clientset, error)

InitNodeAuthorizedClient initializes node authorized client with kubelet's kube config. This is now an available workaround to implement a node-scoped daemonset. See discussion https://github.com/kubernetes/enhancements/pull/944#issuecomment-490242290

func ReadAll

func ReadAll(r io.Reader) ([]byte, error)

Types

type KubeletClient

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

func NewKubeletClient

func NewKubeletClient(config *KubeletClientConfig) (*KubeletClient, error)

func (*KubeletClient) GetNodeRunningPods

func (k *KubeletClient) GetNodeRunningPods() (*v1.PodList, error)

type KubeletClientConfig

type KubeletClientConfig struct {
	// Address specifies the kubelet address
	Address string

	// Port specifies the default port - used if no information about Kubelet port can be found in Node.NodeStatus.DaemonEndpoints.
	Port uint

	// TLSClientConfig contains settings to enable transport layer security
	restclient.TLSClientConfig

	// Server requires Bearer authentication
	BearerToken string

	// HTTPTimeout is used by the client to timeout http requests to Kubelet.
	HTTPTimeout time.Duration
}

KubeletClientConfig defines config parameters for the kubelet client