api

Documentation

Index

• type EventType
• type NamespaceEvent
• type NetNamespace
• type NetNamespaceEvent
• type Node
• type NodeEvent
• type Pod
• type Service
• type ServiceEvent
• type ServiceProtocol
• type Subnet
• type SubnetEvent
• type SubnetRegistry

Types

type EventType

type EventType string

const (
	Added   EventType = "ADDED"
	Deleted EventType = "DELETED"
)

type NamespaceEvent

type NamespaceEvent struct {
	Type EventType
	Name string
}

type NetNamespace

type NetNamespace struct {
	Name  string
	NetID uint
}

type NetNamespaceEvent

type NetNamespaceEvent struct {
	Type  EventType
	Name  string
	NetID uint
}

type Node

type Node struct {
	Name string
	IP   string
}

type NodeEvent

type NodeEvent struct {
	Type EventType
	Node Node
}

type Pod

type Pod struct {
	Name        string
	Namespace   string
	ContainerID string
}

type Service

type Service struct {
	Name      string
	Namespace string
	IP        string
	Protocol  ServiceProtocol
	Port      uint
}

type ServiceEvent

type ServiceEvent struct {
	Type    EventType
	Service Service
}

type ServiceProtocol

type ServiceProtocol string

const (
	TCP ServiceProtocol = "TCP"
	UDP ServiceProtocol = "UDP"
)

type Subnet

type Subnet struct {
	NodeIP     string
	SubnetCIDR string
}

type SubnetEvent

type SubnetEvent struct {
	Type     EventType
	NodeName string
	Subnet   Subnet
}

type SubnetRegistry

type SubnetRegistry interface {
	GetSubnets() ([]Subnet, string, error)
	GetSubnet(nodeName string) (*Subnet, error)
	DeleteSubnet(nodeName string) error
	CreateSubnet(sn string, sub *Subnet) error
	WatchSubnets(receiver chan<- *SubnetEvent, ready chan<- bool, startVersion <-chan string, stop <-chan bool) error

	GetNodes() ([]Node, string, error)
	WatchNodes(receiver chan<- *NodeEvent, ready chan<- bool, startVersion <-chan string, stop <-chan bool) error

	WriteNetworkConfig(clusterNetworkCIDR string, clusterBitsPerSubnet uint, serviceNetworkCIDR string) error
	GetClusterNetworkCIDR() (string, error)

	GetNamespaces() ([]string, string, error)
	WatchNamespaces(receiver chan<- *NamespaceEvent, ready chan<- bool, startVersion <-chan string, stop <-chan bool) error

	WatchNetNamespaces(receiver chan<- *NetNamespaceEvent, ready chan<- bool, startVersion <-chan string, stop <-chan bool) error
	GetNetNamespaces() ([]NetNamespace, string, error)
	GetNetNamespace(name string) (NetNamespace, error)
	WriteNetNamespace(name string, id uint) error
	DeleteNetNamespace(name string) error

	GetServicesNetworkCIDR() (string, error)
	GetServices() ([]Service, string, error)
	WatchServices(receiver chan<- *ServiceEvent, ready chan<- bool, startVersion <-chan string, stop <-chan bool) error
	GetServicesForNamespace(namespace string) ([]Service, error)

	GetPods() ([]Pod, string, error)
	WatchPods(ready chan<- bool, startVersion <-chan string, stop <-chan bool) error
	GetRunningPods(nodeName, namespace string) ([]Pod, error)
}