ipam

Documentation

Index

• Variables
• type IP
  • func (a IP) Add(num int64) IP
  • func (a IP) Equal(b IP) bool
  • func (a IP) GreaterThan(b IP) bool
  • func (a IP) LessThan(b IP) bool
  • func (a IP) Sub(num int64) IP
• type IPAM
  • func NewIPAM() *IPAM
  • func (ipam *IPAM) AddOrUpdateSubnet(name, cidrStr, gw string, excludeIps []string) error
  • func (ipam *IPAM) ContainAddress(address string) bool
  • func (ipam *IPAM) DeleteSubnet(subnetName string)
  • func (ipam *IPAM) GetPodAddress(podName string) []*SubnetAddress
  • func (ipam *IPAM) GetRandomAddress(podName, nicName, mac, subnetName string, skippedAddrs []string, ...) (string, string, string, error)
  • func (ipam *IPAM) GetStaticAddress(podName, nicName, ip, mac, subnetName string, checkConflict bool) (string, string, string, error)
  • func (ipam *IPAM) GetSubnetV4Mask(subnetName string) (string, error)
  • func (ipam *IPAM) IsIPAssignedToOtherPod(ip, subnetName, podName string) (string, bool)
  • func (ipam *IPAM) ReleaseAddressByPod(podName, subnetName string)
• type IPRange
  • func (ipr IPRange) IPExist(ip IP) bool
• type IPRangeList
  • func (iprl IPRangeList) Contains(ip IP) bool
• type Subnet
  • func NewSubnet(name, cidrStr string, excludeIps []string) (*Subnet, error)
  • func (subnet *Subnet) ContainAddress(address IP) bool
  • func (subnet *Subnet) GetPodAddress(podName, nicName string) (IP, IP, string, string)
  • func (subnet *Subnet) GetRandomAddress(podName, nicName string, mac string, skippedAddrs []string, checkConflict bool) (IP, IP, string, error)
  • func (subnet *Subnet) GetRandomMac(podName, nicName string) string
  • func (subnet *Subnet) GetStaticAddress(podName, nicName string, ip IP, mac string, force bool, checkConflict bool) (IP, string, error)
  • func (subnet *Subnet) GetStaticMac(podName, nicName, mac string, checkConflict bool) error
  • func (subnet *Subnet) ReleaseAddress(podName string)
• type SubnetAddress

Variables

var (
	ErrOutOfRange  = errors.New("AddressOutOfRange")
	ErrConflict    = errors.New("AddressConflict")
	ErrNoAvailable = errors.New("NoAvailableAddress")
	ErrInvalidCIDR = errors.New("CIDRInvalid")
)

Types

type IP

type IP string

func (IP) Add

func (a IP) Add(num int64) IP

func (IP) Equal

func (a IP) Equal(b IP) bool

func (IP) GreaterThan

func (a IP) GreaterThan(b IP) bool

func (IP) LessThan

func (a IP) LessThan(b IP) bool

func (IP) Sub

func (a IP) Sub(num int64) IP

type IPAM

type IPAM struct {
	Subnets map[string]*Subnet
	// contains filtered or unexported fields
}

func NewIPAM

func NewIPAM() *IPAM

func (*IPAM) AddOrUpdateSubnet

func (ipam *IPAM) AddOrUpdateSubnet(name, cidrStr, gw string, excludeIps []string) error

func (*IPAM) ContainAddress

func (ipam *IPAM) ContainAddress(address string) bool

func (*IPAM) DeleteSubnet

func (ipam *IPAM) DeleteSubnet(subnetName string)

func (*IPAM) GetPodAddress

func (ipam *IPAM) GetPodAddress(podName string) []*SubnetAddress

func (*IPAM) GetRandomAddress

func (ipam *IPAM) GetRandomAddress(podName, nicName, mac, subnetName string, skippedAddrs []string, checkConflict bool) (string, string, string, error)

func (*IPAM) GetStaticAddress

func (ipam *IPAM) GetStaticAddress(podName, nicName, ip, mac, subnetName string, checkConflict bool) (string, string, string, error)

func (*IPAM) GetSubnetV4Mask

func (ipam *IPAM) GetSubnetV4Mask(subnetName string) (string, error)

func (*IPAM) IsIPAssignedToOtherPod

func (ipam *IPAM) IsIPAssignedToOtherPod(ip, subnetName, podName string) (string, bool)

func (*IPAM) ReleaseAddressByPod

func (ipam *IPAM) ReleaseAddressByPod(podName, subnetName string)

type IPRange

type IPRange struct {
	Start IP
	End   IP
}

func (IPRange) IPExist

func (ipr IPRange) IPExist(ip IP) bool

type IPRangeList

type IPRangeList []*IPRange

func (IPRangeList) Contains

func (iprl IPRangeList) Contains(ip IP) bool

type Subnet

type Subnet struct {
	Name string

	Protocol         string
	V4CIDR           *net.IPNet
	V4FreeIPList     IPRangeList
	V4ReleasedIPList IPRangeList
	V4ReservedIPList IPRangeList
	V4NicToIP        map[string]IP
	V4IPToPod        map[IP]string
	V6CIDR           *net.IPNet
	V6FreeIPList     IPRangeList
	V6ReleasedIPList IPRangeList
	V6ReservedIPList IPRangeList
	V6NicToIP        map[string]IP
	V6IPToPod        map[IP]string
	NicToMac         map[string]string
	MacToPod         map[string]string
	PodToNicList     map[string][]string
	V4Gw             string
	V6Gw             string
	// contains filtered or unexported fields
}

func NewSubnet

func NewSubnet(name, cidrStr string, excludeIps []string) (*Subnet, error)

func (*Subnet) ContainAddress

func (subnet *Subnet) ContainAddress(address IP) bool

func (*Subnet) GetPodAddress

func (subnet *Subnet) GetPodAddress(podName, nicName string) (IP, IP, string, string)

This func is only called in ipam.GetPodAddress, move mutex to caller

func (*Subnet) GetRandomAddress

func (subnet *Subnet) GetRandomAddress(podName, nicName string, mac string, skippedAddrs []string, checkConflict bool) (IP, IP, string, error)

func (*Subnet) GetRandomMac

func (subnet *Subnet) GetRandomMac(podName, nicName string) string

func (*Subnet) GetStaticAddress

func (subnet *Subnet) GetStaticAddress(podName, nicName string, ip IP, mac string, force bool, checkConflict bool) (IP, string, error)

func (*Subnet) GetStaticMac

func (subnet *Subnet) GetStaticMac(podName, nicName, mac string, checkConflict bool) error

func (*Subnet) ReleaseAddress

func (subnet *Subnet) ReleaseAddress(podName string)

type SubnetAddress

type SubnetAddress struct {
	Subnet *Subnet
	Ip     string
	Mac    string
}