cni

package

v0.3.0 Latest Latest Go to latest Published: Feb 13, 2024 License: Apache-2.0 Imports: 17 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/MikeZappa87/libkni

Links

Open Source Insights

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
type KNIConfig
- func CreateDefaultConfig() KNIConfig
type NetworkStorage
type Store
- func New(dbName string) (*Store, error)

Constants ¶

View Source

const PodBucket = "pod"

Variables ¶

This section is empty.

Functions ¶

func Build ¶ added in v0.2.2

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 ¶ added in v0.2.2

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL