controller

Documentation

Index

• func ShouldInQueue(pod *corev1.Pod) bool
• func StartReconciler() error
• type AppController
  • func NewAppController(client *k8sclient.K8sClient) *AppController
  • func (a *AppController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (a *AppController) SetupWithManager(mgr ctrl.Manager) error
• type JobController
  • func NewJobController(client *k8sclient.K8sClient) *JobController
  • func (m *JobController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (m *JobController) SetupWithManager(mgr ctrl.Manager) error
• type MountController
  • func NewMountController(client *k8sclient.K8sClient) *MountController
  • func (m MountController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (m *MountController) SetupWithManager(mgr ctrl.Manager) error
• type PodController
  • func NewPodController(client *k8sclient.K8sClient) *PodController
  • func (m *PodController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (m *PodController) SetupWithManager(mgr ctrl.Manager) error
• type PodDriver
  • func NewPodDriver(client *k8sclient.K8sClient, mounter mount.SafeFormatAndMount) *PodDriver
  • func (p *PodDriver) CleanUpCache(ctx context.Context, pod *corev1.Pod)
  • func (p *PodDriver) Run(ctx context.Context, current *corev1.Pod) error
  • func (p *PodDriver) SetMountInfo(mit mountInfoTable)
• type PodReconciler
• type PodStatus

Functions

func ShouldInQueue

func ShouldInQueue(pod *corev1.Pod) bool

func StartReconciler

func StartReconciler() error

Types

type AppController

type AppController struct {
	*k8sclient.K8sClient
}

func NewAppController

func NewAppController(client *k8sclient.K8sClient) *AppController

func (*AppController) Reconcile

func (a *AppController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*AppController) SetupWithManager

func (a *AppController) SetupWithManager(mgr ctrl.Manager) error

type JobController

type JobController struct {
	*k8sclient.K8sClient
}

func NewJobController

func NewJobController(client *k8sclient.K8sClient) *JobController

func (*JobController) Reconcile

func (m *JobController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*JobController) SetupWithManager

func (m *JobController) SetupWithManager(mgr ctrl.Manager) error

type MountController

type MountController struct {
	*k8sclient.K8sClient
}

func NewMountController

func NewMountController(client *k8sclient.K8sClient) *MountController

func (MountController) Reconcile

func (m MountController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*MountController) SetupWithManager

func (m *MountController) SetupWithManager(mgr ctrl.Manager) error

type PodController

type PodController struct {
	*k8sclient.K8sClient
}

func NewPodController

func NewPodController(client *k8sclient.K8sClient) *PodController

func (*PodController) Reconcile

func (m *PodController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

func (*PodController) SetupWithManager

func (m *PodController) SetupWithManager(mgr ctrl.Manager) error

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) CleanUpCache

func (p *PodDriver) CleanUpCache(ctx context.Context, pod *corev1.Pod)

CleanUpCache clean up cache

func (*PodDriver) Run

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

func (*PodDriver) SetMountInfo

func (p *PodDriver) SetMountInfo(mit mountInfoTable)

type PodReconciler

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

type PodStatus

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