datastore

package
v1.9.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 15, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// DuplicatedENIError is an error when caller tries to add an duplicate ENI to data store
	DuplicatedENIError = "data store: duplicate ENI"

	// IPAlreadyInStoreError is an error when caller tries to add an duplicate IP address to data store
	IPAlreadyInStoreError = "datastore: IP already in data store"

	// UnknownIPError is an error when caller tries to delete an IP which is unknown to data store
	UnknownIPError = "datastore: unknown IP"

	// IPInUseError is an error when caller tries to delete an IP where IP is still assigned to a Pod
	IPInUseError = "datastore: IP is used and can not be deleted"

	// ENIInUseError is an error when caller tries to delete an ENI where there are IP still assigned to a pod
	ENIInUseError = "datastore: ENI is used and can not be deleted"

	// UnknownENIError is an error when caller tries to access an ENI which is unknown to datastore
	UnknownENIError = "datastore: unknown ENI"
)
View Source 
const CheckpointFormatVersion = "vpc-cni-ipam/1"

CheckpointFormatVersion is the version stamp used on stored checkpoints.

Variables

View Source 
var ErrUnknownPod = errors.New("datastore: unknown pod")

ErrUnknownPod is an error when there is no pod in data store matching pod name, namespace, sandbox id

Functions

func DivCeil added in v1.9.0 

func DivCeil(x, y int) int

func GetPrefixDelegationDefaults added in v1.9.0 

func GetPrefixDelegationDefaults() (int, int, int)

Function to return PD defaults supported by VPC

Types

type AddressInfo 

type AddressInfo struct {
	IPAMKey        IPAMKey
	Address        string
	UnassignedTime time.Time
}

AddressInfo contains information about an IP, Exported fields will be marshaled for introspection.

func (AddressInfo) Assigned 

func (addr AddressInfo) Assigned() bool

Assigned returns true iff the address is allocated to a pod/sandbox.

type CheckpointData added in v1.6.4 

type CheckpointData struct {
	Version     string            `json:"version"`
	Allocations []CheckpointEntry `json:"allocations"`
}

CheckpointData is the format of stored checkpoints. Note this is deliberately a "dumb" format since efficiency is less important than version stability here.

type CheckpointEntry added in v1.6.4 

type CheckpointEntry struct {
	IPAMKey
	IPv4 string `json:"ipv4"`
}

CheckpointEntry is a "row" in the conceptual IPAM datastore, as stored in checkpoints.

type Checkpointer added in v1.6.4 

type Checkpointer interface {
	Checkpoint(data interface{}) error
	Restore(into interface{}) error
}

Checkpointer can persist data and (hopefully) restore it later

type CidrInfo added in v1.9.0 

type CidrInfo struct {
	//Cidr info /32 or /28 prefix
	Cidr net.IPNet
	//Key is the /32 IP either secondary IP or free /32 IP allocated from /28 prefix
	IPv4Addresses map[string]*AddressInfo
	//This block of addresses was allocated through PrefixDelegation
	IsPrefix bool
}

CidrInfo

func (*CidrInfo) AssignedIPv4AddressesInCidr added in v1.9.0 

func (cidr *CidrInfo) AssignedIPv4AddressesInCidr() int

AssignedIPv4AddressesInCidr is the number of IP addresses already assigned in the CIDR

func (*CidrInfo) Size added in v1.9.0 

func (cidr *CidrInfo) Size() int

type DataStore 

type DataStore struct {
	CheckpointMigrationPhase int
	// contains filtered or unexported fields
}

DataStore contains node level ENI/IP

func NewDataStore 

func NewDataStore(log logger.Logger, backingStore Checkpointer, isPDEnabled bool) *DataStore

NewDataStore returns DataStore structure

func (*DataStore) AddENI 

func (ds *DataStore) AddENI(eniID string, deviceNumber int, isPrimary, isTrunk, isEFA bool) error

AddENI add ENI to data store

func (*DataStore) AddIPv4CidrToStore added in v1.9.0 

func (ds *DataStore) AddIPv4CidrToStore(eniID string, ipv4Cidr net.IPNet, isPrefix bool) error

AddIPv4AddressToStore add CIDR of an ENI to data store

func (*DataStore) AllocatedIPs added in v1.6.4 

func (ds *DataStore) AllocatedIPs() []PodIPInfo

AllocatedIPs returns a recent snapshot of allocated sandbox<->IPs. Note result may already be stale by the time you look at it.

func (*DataStore) AssignPodIPv4Address 

func (ds *DataStore) AssignPodIPv4Address(ipamKey IPAMKey) (ipv4address string, deviceNumber int, err error)

AssignPodIPv4Address assigns an IPv4 address to pod It returns the assigned IPv4 address, device number, error

func (*DataStore) CheckFreeableENIexists added in v1.9.0 

func (ds *DataStore) CheckFreeableENIexists() bool

CheckFreeableENIexists will return true if there is an ENI which is unused. Could have just called getDeletaleENI, this is just to optimize a bit.

func (*DataStore) DelIPv4CidrFromStore added in v1.9.0 

func (ds *DataStore) DelIPv4CidrFromStore(eniID string, cidr net.IPNet, force bool) error

func (*DataStore) FindFreeableCidrs added in v1.9.0 

func (ds *DataStore) FindFreeableCidrs(eniID string) []CidrInfo

FindFreeableCidrs finds and returns Cidrs that are not assigned to Pods but are attached to ENIs on the node.

func (*DataStore) FreeableIPs added in v1.6.4 

func (ds *DataStore) FreeableIPs(eniID string) []net.IPNet

FreeableIPs returns a list of unused and potentially freeable IPs. Note result may already be stale by the time you look at it.

func (*DataStore) FreeablePrefixes added in v1.9.0 

func (ds *DataStore) FreeablePrefixes(eniID string) []net.IPNet

FreeablePrefixes returns a list of unused and potentially freeable IPs. Note result may already be stale by the time you look at it.

func (*DataStore) GetEFAENIs added in v1.7.6 

func (ds *DataStore) GetEFAENIs() map[string]bool

GetEFAENIs returns the a map containing all attached EFA ENIs

func (*DataStore) GetENICIDRs added in v1.9.0 

func (ds *DataStore) GetENICIDRs(eniID string) ([]string, []string, error)

GetENICIDRs returns the known (allocated & unallocated) ENI secondary IPs and Prefixes

func (*DataStore) GetENIInfos 

func (ds *DataStore) GetENIInfos() *ENIInfos

GetENIInfos provides ENI and IP information about the datastore

func (*DataStore) GetENINeedsIP 

func (ds *DataStore) GetENINeedsIP(maxIPperENI int, skipPrimary bool) *ENI

GetENINeedsIP finds an ENI in the datastore that needs more IP addresses allocated

func (*DataStore) GetENIs 

func (ds *DataStore) GetENIs() int

GetENIs provides the number of ENI in the datastore

func (*DataStore) GetFreePrefixes added in v1.9.0 

func (ds *DataStore) GetFreePrefixes() int

GetFreePrefixes return free prefixes

func (*DataStore) GetStats 

func (ds *DataStore) GetStats() (int, int, int)

GetStats returns total number of IP addresses, number of assigned IP addresses and total prefixes

func (*DataStore) GetTrunkENI added in v1.6.4 

func (ds *DataStore) GetTrunkENI() string

GetTrunkENI returns the trunk ENI ID or an empty string

func (*DataStore) ReadBackingStore added in v1.6.4 

func (ds *DataStore) ReadBackingStore() error

ReadBackingStore initialises the IP allocation state from the configured backing store. Should be called before using data store.

func (*DataStore) RemoveENIFromDataStore 

func (ds *DataStore) RemoveENIFromDataStore(eniID string, force bool) error

RemoveENIFromDataStore removes an ENI from the datastore. It returns nil on success, or an error.

func (*DataStore) RemoveUnusedENIFromStore 

func (ds *DataStore) RemoveUnusedENIFromStore(warmIPTarget, minimumIPTarget, warmPrefixTarget int) string

RemoveUnusedENIFromStore removes a deletable ENI from the data store. It returns the name of the ENI which has been removed from the data store and needs to be deleted, or empty string if no ENI could be removed.

func (*DataStore) UnassignPodIPv4Address 

func (ds *DataStore) UnassignPodIPv4Address(ipamKey IPAMKey) (e *ENI, ip string, deviceNumber int, err error)

UnassignPodIPv4Address a) find out the IP address based on PodName and PodNameSpace b) mark IP address as unassigned c) returns IP address, ENI's device number, error

type ENI added in v1.6.4 

type ENI struct {
	// AWS ENI ID
	ID string

	// IsPrimary indicates whether ENI is a primary ENI
	IsPrimary bool
	// IsTrunk indicates whether this ENI is used to provide pods with dedicated ENIs
	IsTrunk bool
	// IsEFA indicates whether this ENI is tagged as an EFA
	IsEFA bool
	// DeviceNumber is the device number of ENI (0 means the primary ENI)
	DeviceNumber int
	// IPv4Addresses shows whether each address is assigned, the key is IP address, which must
	// be in dot-decimal notation with no leading zeros and no whitespace(eg: "10.1.0.253")
	// Key is the IP address - PD: "IP/28" and SIP: "IP/32"
	AvailableIPv4Cidrs map[string]*CidrInfo
	// contains filtered or unexported fields
}

ENI represents a single ENI. Exported fields will be marshaled for introspection.

func (*ENI) AssignedIPv4Addresses added in v1.6.4 

func (e *ENI) AssignedIPv4Addresses() int

AssignedIPv4Addresses is the number of IP addresses already assigned

type ENIInfos 

type ENIInfos struct {
	// TotalIPs is the total number of IP addresses
	TotalIPs int
	// assigned is the number of IP addresses that has been assigned
	AssignedIPs int
	// ENIs contains ENI IP pool information
	ENIs map[string]ENI
}

ENIInfos contains ENI IP information

type ENIPool added in v1.6.4 

type ENIPool map[string]*ENI

ENIPool is a collection of ENI, keyed by ENI ID

func (*ENIPool) AssignedIPv4Addresses added in v1.6.4 

func (p *ENIPool) AssignedIPv4Addresses() int

AssignedIPv4Addresses is the number of IP addresses already assigned

func (*ENIPool) FindAddressForSandbox added in v1.6.4 

func (p *ENIPool) FindAddressForSandbox(ipamKey IPAMKey) (*ENI, *CidrInfo, *AddressInfo)

FindAddressForSandbox returns ENI and AddressInfo or (nil, nil) if not found

type IPAMKey added in v1.6.4 

type IPAMKey struct {
	NetworkName string `json:"networkName"`
	ContainerID string `json:"containerID"`
	IfName      string `json:"ifName"`
}

IPAMKey is the IPAM primary key. Quoting CNI spec: 

Plugins that store state should do so using a primary key of
(network name, CNI_CONTAINERID, CNI_IFNAME).

func (IPAMKey) IsZero added in v1.6.4 

func (k IPAMKey) IsZero() bool

IsZero returns true iff object is equal to the golang zero/null value.

func (IPAMKey) String added in v1.6.4 

func (k IPAMKey) String() string

String() implements the fmt.Stringer interface.

type JSONFile added in v1.6.4 

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

JSONFile is a checkpointer that writes to a JSON file

func NewJSONFile added in v1.6.4 

func NewJSONFile(path string) *JSONFile

NewJSONFile creates a new JsonFile

func (*JSONFile) Checkpoint added in v1.6.4 

func (c *JSONFile) Checkpoint(data interface{}) error

Checkpoint implements the Checkpointer interface

func (*JSONFile) Restore added in v1.6.4 

func (c *JSONFile) Restore(into interface{}) error

Restore implements the Checkpointer interface

type NullCheckpoint added in v1.6.4 

type NullCheckpoint struct{}

NullCheckpoint discards data and always returns "not found". For testing only!

func (NullCheckpoint) Checkpoint added in v1.6.4 

func (c NullCheckpoint) Checkpoint(data interface{}) error

Checkpoint implements the Checkpointer interface in the most trivial sense, by just discarding data.

func (NullCheckpoint) Restore added in v1.6.4 

func (c NullCheckpoint) Restore(into interface{}) error

Restore implements the Checkpointer interface in the most trivial sense, by always returning "not found".

type PodIPInfo 

type PodIPInfo struct {
	IPAMKey IPAMKey
	// IP is the IPv4 address of pod
	IP string
	// DeviceNumber is the device number of the ENI
	DeviceNumber int
}

PodIPInfo contains pod's IP and the device number of the ENI

type TestCheckpoint added in v1.6.4 

type TestCheckpoint struct {
	Error error
	Data  interface{}
}

TestCheckpoint maintains a snapshot in memory.

func NewTestCheckpoint added in v1.6.4 

func NewTestCheckpoint(data interface{}) *TestCheckpoint

NewTestCheckpoint creates a new TestCheckpoint.

func (*TestCheckpoint) Checkpoint added in v1.6.4 

func (c *TestCheckpoint) Checkpoint(data interface{}) error

Checkpoint implements the Checkpointer interface.

func (*TestCheckpoint) Restore added in v1.6.4 

func (c *TestCheckpoint) Restore(into interface{}) error

Restore implements the Checkpointer interface.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.