ipam

Apr 30, 2021

Changes in this version

+ const SubmarinerIPAMGlobalIP

+ func RecordAllocateGlobalIP(cidr string)

+ func RecordAvailability(cidr string, count int)

+ func RecordDeallocateGlobalIP(cidr string)

type Controller

+ func (i *Controller) Start(stopCh <-chan struct{}) error

type GatewayMonitor

+ func (gm *GatewayMonitor) Start(stopCh <-chan struct{}) error

+ func (gm *GatewayMonitor) Stop()

+ type IPPool struct

+ func NewIPPool(cidr string) (*IPPool, error)

+ func (p *IPPool) Allocate(key string) (string, error)

+ func (p *IPPool) GetAllocatedIP(key string) string

+ func (p *IPPool) IsAvailable(ip string) bool

+ func (p *IPPool) Release(key string) string

+ func (p *IPPool) RequestIP(key, ip string) (string, error)

type InformerConfigStruct

+ DynamicClientSet dynamic.Interface

+ SvcExGvr schema.GroupVersionResource

+ SvcExInformer informers.GenericInformer

+ type SubmarinerIPAMControllerSpecification struct

+ ClusterID string

+ ExcludeNS []string

+ GlobalCIDR []string

+ Namespace string

Jun 23, 2020

Changes in this version

+ func ClearGlobalNetChains(ipt *iptables.IPTables)

type SubmarinerIpamControllerSpecification

+ GlobalCIDR []string

May 8, 2020

Changes in this version

type InformerConfigStruct

+ NodeInformer kubeInformers.NodeInformer

Feb 17, 2020

Changes in this version

+ const AddRules

+ const DeleteRules

+ const Ignore

+ const Process

+ const Requeue

+ func ClearGlobalNetMarkingChain(ipt *iptables.IPTables)

+ func CreateGlobalNetMarkingChain(ipt *iptables.IPTables) error

+ func MarkRemoteClusterTraffic(ipt *iptables.IPTables, remoteCidr string, addRules bool)

+ type Controller struct

+ func NewController(spec *SubmarinerIpamControllerSpecification, config *InformerConfigStruct, ...) (*Controller, error)

+ func (i *Controller) Run(stopCh <-chan struct{}) error

+ type GatewayMonitor struct

+ func NewGatewayMonitor(spec *SubmarinerIpamControllerSpecification, cfg *rest.Config, ...) (*GatewayMonitor, error)

+ func (i *GatewayMonitor) Run(stopCh <-chan struct{}) error

+ type InformerConfigStruct struct

+ KubeClientSet kubernetes.Interface

+ PodInformer kubeInformers.PodInformer

+ ServiceInformer kubeInformers.ServiceInformer

+ type IpPool struct

+ func NewIpPool(cidr string) (*IpPool, error)

+ func (p *IpPool) Allocate(key string) (string, error)

+ func (p *IpPool) GetAllocatedIp(key string) string

+ func (p *IpPool) IsAvailable(ip string) bool

+ func (p *IpPool) Release(key string) string

+ func (p *IpPool) RequestIp(key string, ip string) (string, error)

+ type Operation string

+ type SubmarinerIpamControllerSpecification struct

+ ClusterID string

+ ExcludeNS []string

+ Namespace string