informer

Documentation

Index

• type DaemonSetController
  • func NewDaemonSetController(kubeClient client.Client, cluster *state.Cluster) *DaemonSetController
  • func (c *DaemonSetController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *DaemonSetController) Register(_ context.Context, m manager.Manager) error
• type NodeClaimController
  • func NewNodeClaimController(kubeClient client.Client, cluster *state.Cluster) *NodeClaimController
  • func (c *NodeClaimController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *NodeClaimController) Register(_ context.Context, m manager.Manager) error
• type NodeController
  • func NewNodeController(kubeClient client.Client, cluster *state.Cluster) *NodeController
  • func (c *NodeController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *NodeController) Register(_ context.Context, m manager.Manager) error
• type NodePoolController
  • func NewNodePoolController(kubeClient client.Client, cluster *state.Cluster) *NodePoolController
  • func (c *NodePoolController) Reconcile(ctx context.Context, np *v1.NodePool) (reconcile.Result, error)
  • func (c *NodePoolController) Register(_ context.Context, m manager.Manager) error
• type PodController
  • func NewPodController(kubeClient client.Client, cluster *state.Cluster) *PodController
  • func (c *PodController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *PodController) Register(_ context.Context, m manager.Manager) error

Types

type DaemonSetController

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

func NewDaemonSetController

func NewDaemonSetController(kubeClient client.Client, cluster *state.Cluster) *DaemonSetController

func (*DaemonSetController) Reconcile

func (c *DaemonSetController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*DaemonSetController) Register

func (c *DaemonSetController) Register(_ context.Context, m manager.Manager) error

type NodeClaimController

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

NodeClaimController reconciles nodeclaim for the purpose of maintaining state.

func NewNodeClaimController

func NewNodeClaimController(kubeClient client.Client, cluster *state.Cluster) *NodeClaimController

NewNodeClaimController constructs a controller instance

func (*NodeClaimController) Reconcile

func (c *NodeClaimController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*NodeClaimController) Register

func (c *NodeClaimController) Register(_ context.Context, m manager.Manager) error

type NodeController

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

NodeController reconciles nodes for the purpose of maintaining state regarding nodes that is expensive to compute.

func NewNodeController

func NewNodeController(kubeClient client.Client, cluster *state.Cluster) *NodeController

NewNodeController constructs a controller instance

func (*NodeController) Reconcile

func (c *NodeController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*NodeController) Register

func (c *NodeController) Register(_ context.Context, m manager.Manager) error

type NodePoolController

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

NodePoolController reconciles NodePools to re-trigger consolidation on change.

func NewNodePoolController

func NewNodePoolController(kubeClient client.Client, cluster *state.Cluster) *NodePoolController

func (*NodePoolController) Reconcile

func (c *NodePoolController) Reconcile(ctx context.Context, np *v1.NodePool) (reconcile.Result, error)

func (*NodePoolController) Register

func (c *NodePoolController) Register(_ context.Context, m manager.Manager) error

type PodController

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

PodController reconciles pods for the purpose of maintaining state regarding pods that is expensive to compute.

func NewPodController

func NewPodController(kubeClient client.Client, cluster *state.Cluster) *PodController

func (*PodController) Reconcile

func (c *PodController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*PodController) Register

func (c *PodController) Register(_ context.Context, m manager.Manager) error