controller

Documentation

Index

• func StartReconciler() error
• type KubeletClientConfig
• type PodDriver
  • func NewPodDriver(client *k8sclient.K8sClient, mounter mount.SafeFormatAndMount) *PodDriver
  • func (p *PodDriver) Run(ctx context.Context, current *corev1.Pod) error
• type PodReconciler

Functions

func StartReconciler

func StartReconciler() error

Types

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 int

	// 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

type PodDriver

type PodDriver struct {
	Client *k8sclient.K8sClient

	mount.SafeFormatAndMount
	// contains filtered or unexported fields
}

func NewPodDriver

func NewPodDriver(client *k8sclient.K8sClient, mounter mount.SafeFormatAndMount) *PodDriver

func (*PodDriver) Run

func (p *PodDriver) Run(ctx context.Context, current *corev1.Pod) error

type PodReconciler

type PodReconciler struct {
	mount.SafeFormatAndMount
	*k8sclient.K8sClient
}