controllers

Documentation

Overview

Package controllers implements controllers to handle allocations using in-cluster resources.

Index

• Constants
• type GlobalInClusterIPPoolReconciler
  • func (r *GlobalInClusterIPPoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *GlobalInClusterIPPoolReconciler) SetupWithManager(_ context.Context, mgr ctrl.Manager) error
• type IPAddressClaimHandler
  • func (h *IPAddressClaimHandler) EnsureAddress(ctx context.Context, address *ipamv1.IPAddress) (*ctrl.Result, error)
  • func (h *IPAddressClaimHandler) FetchPool(ctx context.Context) (client.Object, *ctrl.Result, error)
  • func (h *IPAddressClaimHandler) ReleaseAddress(_ context.Context) (*ctrl.Result, error)
• type InClusterIPPoolReconciler
  • func (r *InClusterIPPoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *InClusterIPPoolReconciler) SetupWithManager(_ context.Context, mgr ctrl.Manager) error
• type InClusterProviderAdapter
  • func (i *InClusterProviderAdapter) ClaimHandlerFor(_ client.Client, claim *ipamv1.IPAddressClaim) ipamutil.ClaimHandler
  • func (i *InClusterProviderAdapter) SetupWithManager(_ context.Context, b *ctrl.Builder) error

Constants

const (

	// ProtectPoolFinalizer is used to prevent deletion of a Pool object while its addresses have not been deleted.
	ProtectPoolFinalizer = "ipam.cluster.x-k8s.io/ProtectPool"
)

Types

type GlobalInClusterIPPoolReconciler

type GlobalInClusterIPPoolReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

GlobalInClusterIPPoolReconciler reconciles a GlobalInClusterIPPool object.

func (*GlobalInClusterIPPoolReconciler) Reconcile

func (r *GlobalInClusterIPPoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*GlobalInClusterIPPoolReconciler) SetupWithManager

func (r *GlobalInClusterIPPoolReconciler) SetupWithManager(_ context.Context, mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type IPAddressClaimHandler

type IPAddressClaimHandler struct {
	client.Client
	// contains filtered or unexported fields
}

IPAddressClaimHandler reconciles a InClusterIPPool object.

func (*IPAddressClaimHandler) EnsureAddress

func (h *IPAddressClaimHandler) EnsureAddress(ctx context.Context, address *ipamv1.IPAddress) (*ctrl.Result, error)

EnsureAddress ensures that the IPAddress contains a valid address.

func (*IPAddressClaimHandler) FetchPool

func (h *IPAddressClaimHandler) FetchPool(ctx context.Context) (client.Object, *ctrl.Result, error)

FetchPool fetches the (Global)InClusterIPPool.

func (*IPAddressClaimHandler) ReleaseAddress

func (h *IPAddressClaimHandler) ReleaseAddress(_ context.Context) (*ctrl.Result, error)

ReleaseAddress releases the ip address.

type InClusterIPPoolReconciler

type InClusterIPPoolReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

InClusterIPPoolReconciler reconciles a InClusterIPPool object.

func (*InClusterIPPoolReconciler) Reconcile

func (r *InClusterIPPoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*InClusterIPPoolReconciler) SetupWithManager

func (r *InClusterIPPoolReconciler) SetupWithManager(_ context.Context, mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type InClusterProviderAdapter

type InClusterProviderAdapter struct {
	Client           client.Client
	WatchFilterValue string
}

InClusterProviderAdapter is used as middle layer for provider integration.

func (*InClusterProviderAdapter) ClaimHandlerFor

func (i *InClusterProviderAdapter) ClaimHandlerFor(_ client.Client, claim *ipamv1.IPAddressClaim) ipamutil.ClaimHandler

ClaimHandlerFor returns a claim handler for a specific claim.

func (*InClusterProviderAdapter) SetupWithManager

func (i *InClusterProviderAdapter) SetupWithManager(_ context.Context, b *ctrl.Builder) error

SetupWithManager sets up the controller with the Manager.