v1alpha2

Documentation

Index

• type IPPoolManager
  • func NewIPPoolManager(config *rest.Config, clusterNS string) (*IPPoolManager, error)
  • func NewIPPoolManagerWithClients(clients vpcnetworkingclients.Interface, clusterNS string) (*IPPoolManager, error)
  • func (p *IPPoolManager) AddSubnetToIPPool(node *corev1.Node, ippool helper.NSXIPPool, ownerRef *metav1.OwnerReference) error
  • func (p *IPPoolManager) CreateIPPool(clusterNS, clusterName string, ownerRef *metav1.OwnerReference) (helper.NSXIPPool, error)
  • func (p *IPPoolManager) DeleteSubnetFromIPPool(subnetName string, ippool helper.NSXIPPool) error
  • func (p *IPPoolManager) DiffIPPoolSubnets(old, cur helper.NSXIPPool) bool
  • func (p *IPPoolManager) GetIPPool(clusterNS, clusterName string) (helper.NSXIPPool, error)
  • func (p *IPPoolManager) GetIPPoolFromIndexer(key string) (helper.NSXIPPool, error)
  • func (p *IPPoolManager) GetIPPoolInformer() cache.SharedIndexInformer
  • func (p *IPPoolManager) GetIPPoolListerSynced() cache.InformerSynced
  • func (p *IPPoolManager) GetIPPoolSubnets(ippool helper.NSXIPPool) (map[string]string, error)
  • func (p *IPPoolManager) StartIPPoolInformers()
  • func (p *IPPoolManager) UpdateIPPool(ippool *vpcnetworkingapis.IPPool) (*vpcnetworkingapis.IPPool, error)

Types

type IPPoolManager

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

IPPoolManager defines an ippool manager working with v1alpha2 ippool CR

func NewIPPoolManager

func NewIPPoolManager(config *rest.Config, clusterNS string) (*IPPoolManager, error)

NewIPPoolManager initializes a IPPoolManager

func NewIPPoolManagerWithClients

func NewIPPoolManagerWithClients(clients vpcnetworkingclients.Interface, clusterNS string) (*IPPoolManager, error)

NewIPPoolManagerWithClients initializes a IPPoolManager with clientset

func (*IPPoolManager) AddSubnetToIPPool

func (p *IPPoolManager) AddSubnetToIPPool(node *corev1.Node, ippool helper.NSXIPPool, ownerRef *metav1.OwnerReference) error

AddSubnetToIPPool adds the subnet for specific node to ippool CR. The subnet name is the node name

func (*IPPoolManager) CreateIPPool

func (p *IPPoolManager) CreateIPPool(clusterNS, clusterName string, ownerRef *metav1.OwnerReference) (helper.NSXIPPool, error)

CreateIPPool creates an ippool CR to a namespace, for a workload cluster

func (*IPPoolManager) DeleteSubnetFromIPPool

func (p *IPPoolManager) DeleteSubnetFromIPPool(subnetName string, ippool helper.NSXIPPool) error

DeleteSubnetFromIPPool removes the subnet for specific node from ippool CR

func (*IPPoolManager) DiffIPPoolSubnets

func (p *IPPoolManager) DiffIPPoolSubnets(old, cur helper.NSXIPPool) bool

DiffIPPoolSubnets validates if subnets of status in ippool CR changes

func (*IPPoolManager) GetIPPool

func (p *IPPoolManager) GetIPPool(clusterNS, clusterName string) (helper.NSXIPPool, error)

GetIPPool gets the ippool CR from a namespace, belonged to a workload cluster

func (*IPPoolManager) GetIPPoolFromIndexer

func (p *IPPoolManager) GetIPPoolFromIndexer(key string) (helper.NSXIPPool, error)

GetIPPoolFromIndexer gets an ippool CR from cache store

func (*IPPoolManager) GetIPPoolInformer

func (p *IPPoolManager) GetIPPoolInformer() cache.SharedIndexInformer

GetIPPoolInformer gets ippool informer

func (*IPPoolManager) GetIPPoolListerSynced

func (p *IPPoolManager) GetIPPoolListerSynced() cache.InformerSynced

GetIPPoolListerSynced gets HasSynced function

func (*IPPoolManager) GetIPPoolSubnets

func (p *IPPoolManager) GetIPPoolSubnets(ippool helper.NSXIPPool) (map[string]string, error)

GetIPPoolSubnets gets the subnets from realized status in ippool CR

func (*IPPoolManager) StartIPPoolInformers

func (p *IPPoolManager) StartIPPoolInformers()

StartIPPoolInformers starts ippool informer

func (*IPPoolManager) UpdateIPPool

func (p *IPPoolManager) UpdateIPPool(ippool *vpcnetworkingapis.IPPool) (*vpcnetworkingapis.IPPool, error)

UpdateIPPool updates a kubernetes ippool