cni

Documentation

Index

• Constants
• func Build(config *KNIConfig) (beta.KNIServer, error)
• func ExtractPodBandwidthResources(podAnnotations map[string]string) (ingress, egress *resource.Quantity, err error)
• func NewKniService(config *KNIConfig) (beta.KNIServer, error)
• func NewKniServiceWithAllConfigs(config *KNIConfig) (beta.KNIServer, error)
• type KNICNIService
  • func (k *KNICNIService) AttachInterface(ctx context.Context, req *beta.AttachInterfaceRequest) (*beta.AttachInterfaceResponse, error)
  • func (k *KNICNIService) CreateNetwork(ctx context.Context, req *beta.CreateNetworkRequest) (*beta.CreateNetworkResponse, error)
  • func (k *KNICNIService) DeleteNetwork(ctx context.Context, req *beta.DeleteNetworkRequest) (*beta.DeleteNetworkResponse, error)
  • func (k *KNICNIService) DetachInterface(ctx context.Context, req *beta.DetachInterfaceRequest) (*beta.DetachInterfaceResponse, error)
  • func (k *KNICNIService) QueryNodeNetworks(ctx context.Context, req *beta.QueryNodeNetworksRequest) (*beta.QueryNodeNetworksResponse, error)
  • func (k *KNICNIService) QueryPodNetwork(ctx context.Context, req *beta.QueryPodNetworkRequest) (*beta.QueryPodNetworkResponse, error)
  • func (k *KNICNIService) SetupNodeNetwork(context.Context, *beta.SetupNodeNetworkRequest) (*beta.SetupNodeNetworkResponse, error)
• type KNIConfig
  • func CreateDefaultConfig() KNIConfig
• type NetworkStorage
• type Store
  • func New(dbName string) (*Store, error)
  • func (s *Store) Delete(id string) error
  • func (s *Store) Query(id string) (*NetworkStorage, error)
  • func (s *Store) Save(id string, netstore NetworkStorage) error

Constants

const PodBucket = "pod"

Functions

func Build

func Build(config *KNIConfig) (beta.KNIServer, error)

func ExtractPodBandwidthResources

func ExtractPodBandwidthResources(podAnnotations map[string]string) (ingress, egress *resource.Quantity, err error)

ExtractPodBandwidthResources extracts the ingress and egress from the given pod annotations

func NewKniService

func NewKniService(config *KNIConfig) (beta.KNIServer, error)

func NewKniServiceWithAllConfigs

func NewKniServiceWithAllConfigs(config *KNIConfig) (beta.KNIServer, error)

Types

type KNICNIService

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

func (*KNICNIService) AttachInterface

func (k *KNICNIService) AttachInterface(ctx context.Context, req *beta.AttachInterfaceRequest) (*beta.AttachInterfaceResponse, error)

func (*KNICNIService) CreateNetwork

func (k *KNICNIService) CreateNetwork(ctx context.Context, req *beta.CreateNetworkRequest) (*beta.CreateNetworkResponse, error)

func (*KNICNIService) DeleteNetwork

func (k *KNICNIService) DeleteNetwork(ctx context.Context, req *beta.DeleteNetworkRequest) (*beta.DeleteNetworkResponse, error)

func (*KNICNIService) DetachInterface

func (k *KNICNIService) DetachInterface(ctx context.Context, req *beta.DetachInterfaceRequest) (*beta.DetachInterfaceResponse, error)

func (*KNICNIService) QueryNodeNetworks

func (k *KNICNIService) QueryNodeNetworks(ctx context.Context, req *beta.QueryNodeNetworksRequest) (*beta.QueryNodeNetworksResponse, error)

func (*KNICNIService) QueryPodNetwork

func (k *KNICNIService) QueryPodNetwork(ctx context.Context, req *beta.QueryPodNetworkRequest) (*beta.QueryPodNetworkResponse, error)

func (*KNICNIService) SetupNodeNetwork

func (k *KNICNIService) SetupNodeNetwork(context.Context, *beta.SetupNodeNetworkRequest) (*beta.SetupNodeNetworkResponse, error)

type KNIConfig

type KNIConfig struct {
	IfPrefix       string
	Db             string
	CNIBin         string
	CNIConf        string
	LoadAllConfigs bool
}

func CreateDefaultConfig

func CreateDefaultConfig() KNIConfig

type NetworkStorage

type NetworkStorage struct {
	IP           map[string]*beta.IPConfig
	Annotations  map[string]string
	Extradata    map[string]string
	Uid          string
	Netns_path   string
	PodName      string
	PodNamespace string
}

type Store

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

func New

func New(dbName string) (*Store, error)

func (*Store) Delete

func (s *Store) Delete(id string) error

func (*Store) Query

func (s *Store) Query(id string) (*NetworkStorage, error)

func (*Store) Save

func (s *Store) Save(id string, netstore NetworkStorage) error