globalnet

Documentation

Index

• Constants
• func AllocateAndUpdateGlobalCIDRConfigMap(brokerAdminClientset kubernetes.Interface, brokerNamespace string, ...) error
• func AllocateGlobalCIDR(globalnetInfo *Info) (string, error)
• func AssignGlobalnetIPs(globalnetInfo *Info, netconfig Config, status reporter.Interface) (string, error)
• func CheckOverlappingCidrs(globalnetInfo *Info, netconfig Config) error
• func CreateConfigMap(kubeClient kubernetes.Interface, globalnetEnabled bool, ...) error
• func DeleteConfigMap(kubeClient kubernetes.Interface, namespace string) error
• func GetConfigMap(kubeClient kubernetes.Interface, namespace string) (*v1.ConfigMap, error)
• func GetValidClusterSize(cidrRange string, clusterSize uint) (uint, error)
• func IsValidCIDR(cidr string) error
• func LastIP(network *net.IPNet) uint
• func NewGlobalnetConfigMap(globalnetEnabled bool, defaultGlobalCidrRange string, ...) (*v1.ConfigMap, error)
• func ValidateExistingGlobalNetworks(kubeClient kubernetes.Interface, namespace string) error
• func ValidateGlobalnetConfiguration(globalnetInfo *Info, netconfig Config, status reporter.Interface) (string, error)
• type CIDR
  • func NewCIDR(cidr string) (CIDR, error)
• type Config
• type GlobalCIDR
• type GlobalNetwork
• type Info
  • func GetGlobalNetworks(kubeClient kubernetes.Interface, brokerNamespace string) (*Info, *v1.ConfigMap, error)

Constants

const (
	DefaultGlobalnetCIDR        = "242.0.0.0/8"
	DefaultGlobalnetClusterSize = 65536 // i.e., x.x.x.x/16 subnet mask
)

Functions

func AllocateAndUpdateGlobalCIDRConfigMap

func AllocateAndUpdateGlobalCIDRConfigMap(brokerAdminClientset kubernetes.Interface, brokerNamespace string,
	netconfig *Config, status reporter.Interface,
) error

func AllocateGlobalCIDR

func AllocateGlobalCIDR(globalnetInfo *Info) (string, error)

func AssignGlobalnetIPs

func AssignGlobalnetIPs(globalnetInfo *Info, netconfig Config, status reporter.Interface) (string, error)

func CheckOverlappingCidrs

func CheckOverlappingCidrs(globalnetInfo *Info, netconfig Config) error

func CreateConfigMap

func CreateConfigMap(kubeClient kubernetes.Interface, globalnetEnabled bool, defaultGlobalCidrRange string,
	defaultGlobalClusterSize uint, namespace string,
) error

func DeleteConfigMap

func DeleteConfigMap(kubeClient kubernetes.Interface, namespace string) error

nolint:wrapcheck // No need to wrap here

func GetConfigMap

func GetConfigMap(kubeClient kubernetes.Interface, namespace string) (*v1.ConfigMap, error)

nolint:wrapcheck // No need to wrap here

func GetValidClusterSize

func GetValidClusterSize(cidrRange string, clusterSize uint) (uint, error)

func IsValidCIDR

func IsValidCIDR(cidr string) error

func LastIP

func LastIP(network *net.IPNet) uint

func NewGlobalnetConfigMap

func NewGlobalnetConfigMap(globalnetEnabled bool, defaultGlobalCidrRange string,
	defaultGlobalClusterSize uint, namespace string,
) (*v1.ConfigMap, error)

func ValidateExistingGlobalNetworks

func ValidateExistingGlobalNetworks(kubeClient kubernetes.Interface, namespace string) error

func ValidateGlobalnetConfiguration

func ValidateGlobalnetConfiguration(globalnetInfo *Info, netconfig Config, status reporter.Interface) (string, error)

Types

type CIDR

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

func NewCIDR

func NewCIDR(cidr string) (CIDR, error)

type Config

type Config struct {
	ClusterID   string
	GlobalCIDR  string
	ClusterSize uint
}

type GlobalCIDR

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

type GlobalNetwork

type GlobalNetwork struct {
	GlobalCIDRs []string
	ClusterID   string
}

type Info

type Info struct {
	Enabled     bool
	CidrRange   string
	ClusterSize uint
	CidrInfo    map[string]*GlobalNetwork
}

func GetGlobalNetworks

func GetGlobalNetworks(kubeClient kubernetes.Interface, brokerNamespace string) (*Info, *v1.ConfigMap, error)