ipam

Documentation

Index

• Constants
• func ClearGlobalNetChains(ipt *iptables.IPTables)
• func CreateGlobalNetMarkingChain(ipt *iptables.IPTables) error
• func MarkRemoteClusterTraffic(ipt *iptables.IPTables, remoteCidr string, addRules bool)
• type Controller
  • func NewController(spec *SubmarinerIpamControllerSpecification, config *InformerConfigStruct, ...) (*Controller, error)
  • func (i *Controller) Run(stopCh <-chan struct{}) error
• type GatewayMonitor
  • func NewGatewayMonitor(spec *SubmarinerIpamControllerSpecification, cfg *rest.Config, ...) (*GatewayMonitor, error)
  • func (i *GatewayMonitor) Run(stopCh <-chan struct{}) error
• type InformerConfigStruct
• type IpPool
  • 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 Operation
• type SubmarinerIpamControllerSpecification

Constants

const (
	AddRules    = true
	DeleteRules = false

	Process = "Process"
	Ignore  = "Ignore"
	Requeue = "Requeue"
)

Functions

func ClearGlobalNetChains

func ClearGlobalNetChains(ipt *iptables.IPTables)

func CreateGlobalNetMarkingChain

func CreateGlobalNetMarkingChain(ipt *iptables.IPTables) error

func MarkRemoteClusterTraffic

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

Types

type Controller

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

func NewController

func NewController(spec *SubmarinerIpamControllerSpecification, config *InformerConfigStruct, globalCIDR string) (*Controller, error)

func (*Controller) Run

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

type GatewayMonitor

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

func NewGatewayMonitor

func NewGatewayMonitor(spec *SubmarinerIpamControllerSpecification, cfg *rest.Config, stopCh <-chan struct{}) (*GatewayMonitor, error)

func (*GatewayMonitor) Run

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

type InformerConfigStruct

type InformerConfigStruct struct {
	KubeClientSet   kubernetes.Interface
	ServiceInformer kubeInformers.ServiceInformer
	PodInformer     kubeInformers.PodInformer
	NodeInformer    kubeInformers.NodeInformer
}

type IpPool

type IpPool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewIpPool

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

func (*IpPool) Allocate

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

func (*IpPool) GetAllocatedIp

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

func (*IpPool) IsAvailable

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

func (*IpPool) Release

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

func (*IpPool) RequestIp

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

type Operation

type Operation string

type SubmarinerIpamControllerSpecification

type SubmarinerIpamControllerSpecification struct {
	ClusterID  string
	ExcludeNS  []string
	Namespace  string
	GlobalCIDR []string
}