kubecontroller

Oct 1, 2020

Changes in this version

type CrdReconciler

+ IPAMPoolMonitor cns.IPAMPoolMonitor

Jul 24, 2020

Changes in this version

+ type APIDirectClient struct

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

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

+ type CRDDirectClient struct

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

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

+ type DirectAPIClient interface

+ ListPods func(cntxt context.Context, namespace, node string) (*corev1.PodList, error)

+ type DirectCRDClient interface

+ Get func(cntxt context.Context, name, namespace, typeName string) (*nnc.NodeNetworkConfig, error)

Jul 14, 2020

Changes in this version

+ func CNSToCRDSpec() (*nnc.NodeNetworkConfigSpec, error)

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

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

+ func NewCrdRequestController(restService *restserver.HTTPRestService, kubeconfig *rest.Config) (*crdRequestController, error)

+ func SetupSignalHandler(exitChan chan<- bool) (stopCh <-chan struct{})

+ type CrdReconciler struct

+ CNSClient cnsclient.APIClient

+ KubeClient KubeClient

+ NodeName string

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

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

+ type KubeClient interface

+ Get func(ctx context.Context, key client.ObjectKey, obj runtime.Object) error

+ Update func(ctx context.Context, obj runtime.Object, opts ...client.UpdateOption) error

+ type NodeNetworkConfigFilter struct

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

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

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

+ type ObjectKey = types.NamespacedName