persistentips

Documentation

Index

• Variables
• type IPAMClaimReconciler
  • func NewIPAMClaimReconciler(kube kube.InterfaceOVN, netConfig util.NetInfo, ...) *IPAMClaimReconciler
  • func (icr *IPAMClaimReconciler) FindIPAMClaim(claimName string, namespace string) (*ipamclaimsapi.IPAMClaim, error)
  • func (icr *IPAMClaimReconciler) Reconcile(oldIPAMClaim *ipamclaimsapi.IPAMClaim, newIPAMClaim *ipamclaimsapi.IPAMClaim, ...) error
  • func (icr *IPAMClaimReconciler) Sync(objs []interface{}, ipAllocator IPAllocator) error
• type IPAllocator
• type IPReleaser
• type PersistentAllocations

Variables

var (
	ErrIgnoredIPAMClaim                   = errors.New("ignored IPAMClaim: it belongs to other network")
	ErrPersistentIPsNotAvailableOnNetwork = errors.New("ipam claims not supported on this network")
)

Types

type IPAMClaimReconciler

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

IPAMClaimReconciler acts on IPAMClaim events handed off by the cluster network controller and allocates or releases IPs for IPAMClaims.

func NewIPAMClaimReconciler

func NewIPAMClaimReconciler(kube kube.InterfaceOVN, netConfig util.NetInfo, lister ipamclaimslister.IPAMClaimLister) *IPAMClaimReconciler

NewIPAMClaimReconciler builds a new PersistentIPsAllocator

func (*IPAMClaimReconciler) FindIPAMClaim

func (icr *IPAMClaimReconciler) FindIPAMClaim(claimName string, namespace string) (*ipamclaimsapi.IPAMClaim, error)

func (*IPAMClaimReconciler) Reconcile

func (icr *IPAMClaimReconciler) Reconcile(
	oldIPAMClaim *ipamclaimsapi.IPAMClaim,
	newIPAMClaim *ipamclaimsapi.IPAMClaim,
	ipReleaser IPReleaser,
) error

Reconcile updates an IPAMClaim with the IP addresses allocated to the pod's interface

func (*IPAMClaimReconciler) Sync

func (icr *IPAMClaimReconciler) Sync(objs []interface{}, ipAllocator IPAllocator) error

Sync initializes the IPs allocator with the IPAMClaims already existing on the cluster. For live pods, therse are already allocated, so no error will be thrown (e.g. we ignore the `ipam.IsErrAllocated` error

type IPAllocator

type IPAllocator interface {
	AllocateIPs(ips []*net.IPNet) error
}

type IPReleaser

type IPReleaser interface {
	ReleaseIPs(ips []*net.IPNet) error
}

type PersistentAllocations

type PersistentAllocations interface {
	FindIPAMClaim(claimName string, namespace string) (*ipamclaimsapi.IPAMClaim, error)

	Reconcile(oldIPAMClaim *ipamclaimsapi.IPAMClaim, newIPAMClaim *ipamclaimsapi.IPAMClaim, ipReleaser IPReleaser) error
}