kubecontroller

Documentation

Index

• func CRDStatusToNCRequest(crdStatus nnc.NodeNetworkConfigStatus) (cns.CreateNetworkContainerRequest, error)
• func GetKubeConfig() (*rest.Config, error)
• func New(cfg Config) (*requestController, error)
• type APIDirectClient
  • func NewAPIDirectClient(kubeconfig *rest.Config) (*APIDirectClient, error)
  • func (apiClient *APIDirectClient) ListPods(ctx context.Context, namespace, node string) (*corev1.PodList, error)
• type CRDDirectClient
  • func NewCRDDirectClient(kubeconfig *rest.Config, groupVersion *schema.GroupVersion) (*CRDDirectClient, error)
  • func (crdClient *CRDDirectClient) Get(ctx context.Context, name, namespace, typeName string) (*nnc.NodeNetworkConfig, error)
• type Config
• type CrdReconciler
  • func (r *CrdReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (r *CrdReconciler) SetupWithManager(mgr ctrl.Manager) error
• type DirectAPIClient
• type DirectCRDClient
• type KubeClient
• type NodeNetworkConfigFilter
  • func (n NodeNetworkConfigFilter) Create(e event.CreateEvent) bool
  • func (n NodeNetworkConfigFilter) Delete(e event.DeleteEvent) bool
  • func (n NodeNetworkConfigFilter) Update(e event.UpdateEvent) bool

Functions

func CRDStatusToNCRequest

func CRDStatusToNCRequest(crdStatus nnc.NodeNetworkConfigStatus) (cns.CreateNetworkContainerRequest, error)

CRDStatusToNCRequest translates a crd status to createnetworkcontainer request

func GetKubeConfig

func GetKubeConfig() (*rest.Config, error)

GetKubeConfig precedence * --kubeconfig flag pointing at a file at this cmd line * KUBECONFIG environment variable pointing at a file * In-cluster config if running in cluster * $HOME/.kube/config if exists

func New

func New(cfg Config) (*requestController, error)

NewCrdRequestController given a reference to CNS's HTTPRestService state, returns a crdRequestController struct

Types

type APIDirectClient

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

APIDirectClient is a direct client to a kubernetes API server

func NewAPIDirectClient

func NewAPIDirectClient(kubeconfig *rest.Config) (*APIDirectClient, error)

NewAPIDirectClient creates a new APIDirectClient

func (*APIDirectClient) ListPods

func (apiClient *APIDirectClient) ListPods(ctx context.Context, namespace, node string) (*corev1.PodList, error)

ListPods lists all pods in the given namespace and node

type CRDDirectClient

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

CRDDirectClient is a direct client to CRDs in the API Server.

func NewCRDDirectClient

func NewCRDDirectClient(kubeconfig *rest.Config, groupVersion *schema.GroupVersion) (*CRDDirectClient, error)

NewCRDDirectClient creates a new direct crd client to the api server

func (*CRDDirectClient) Get

func (crdClient *CRDDirectClient) Get(ctx context.Context, name, namespace, typeName string) (*nnc.NodeNetworkConfig, error)

Get gets a crd

type Config

type Config struct {
	// InitializeFromCNI whether or not to initialize CNS state from k8s/CRDs
	InitializeFromCNI bool
	KubeConfig        *rest.Config
	Service           *restserver.HTTPRestService
}

Config has crdRequestController options

type CrdReconciler

type CrdReconciler struct {
	KubeClient      KubeClient
	NodeName        string
	CNSClient       cnsclient.APIClient
	IPAMPoolMonitor cns.IPAMPoolMonitor
}

CrdReconciler watches for CRD status changes

func (*CrdReconciler) Reconcile

func (r *CrdReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile is called on CRD status changes

func (*CrdReconciler) SetupWithManager

func (r *CrdReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager Sets up the reconciler with a new manager, filtering using NodeNetworkConfigFilter

type DirectAPIClient

type DirectAPIClient interface {
	ListPods(ctx context.Context, namespace, node string) (*corev1.PodList, error)
}

DirectAPIClient is an interface to talk directly with API Server without cache

type DirectCRDClient

type DirectCRDClient interface {
	Get(ctx context.Context, name, namespace, typeName string) (*nnc.NodeNetworkConfig, error)
}

DirectCRDClient is an interface to get CRDs directly, without cache

type KubeClient

type KubeClient interface {
	Get(ctx context.Context, key client.ObjectKey, obj runtime.Object) error
	Update(ctx context.Context, obj runtime.Object, opts ...client.UpdateOption) error
}

KubeClient is an interface that talks to the API server

type NodeNetworkConfigFilter

type NodeNetworkConfigFilter struct {
	predicate.Funcs
	// contains filtered or unexported fields
}

func (NodeNetworkConfigFilter) Create

func (n NodeNetworkConfigFilter) Create(e event.CreateEvent) bool

Only process create events if CRD name equals this host's name

func (NodeNetworkConfigFilter) Delete

func (n NodeNetworkConfigFilter) Delete(e event.DeleteEvent) bool

TODO: Decide what deleteing crd means with DNC Ignore all for now

func (NodeNetworkConfigFilter) Update

func (n NodeNetworkConfigFilter) Update(e event.UpdateEvent) bool

Returns true if request is to be processed by Reconciler Checks that old generation equals new generation because status changes don't change generation number