controllers

Documentation

Overview

Package controllers contains code common for the device plugin controllers.

Index

• Variables
• func GetDevicePluginCount(pluginKind string) int
• func SetupWithManager(mgr ctrl.Manager, controller DevicePluginController, ...) error
• func UpgradeImages(ctx context.Context, image *string, initimage *string) (upgrade bool)
• type DefaultServiceAccountFactory
  • func (d *DefaultServiceAccountFactory) NewClusterRoleBinding(rawObj client.Object) *rbacv1.ClusterRoleBinding
  • func (d *DefaultServiceAccountFactory) NewServiceAccount(rawObj client.Object) *v1.ServiceAccount
• type DevicePluginController
• type ServiceAccountFactory

Variables

var (
	ImageMinVersion = versionutil.MustParseSemantic("0.28.0")
)

Functions

func GetDevicePluginCount

func GetDevicePluginCount(pluginKind string) int

GetDevicePluginCount returns number of device plugin CRs registered.

func SetupWithManager

func SetupWithManager(mgr ctrl.Manager, controller DevicePluginController, apiGVString, pluginKind, ownerKey string) error

SetupWithManager sets up a reconciler for a given device plugin controller.

func UpgradeImages

func UpgradeImages(ctx context.Context, image *string, initimage *string) (upgrade bool)

Types

type DefaultServiceAccountFactory

type DefaultServiceAccountFactory struct{}

DefaultServiceAccountFactory is an empty ServiceAccountFactory. "default" will be used for the service account then.

func (*DefaultServiceAccountFactory) NewClusterRoleBinding

func (d *DefaultServiceAccountFactory) NewClusterRoleBinding(rawObj client.Object) *rbacv1.ClusterRoleBinding

func (*DefaultServiceAccountFactory) NewServiceAccount

func (d *DefaultServiceAccountFactory) NewServiceAccount(rawObj client.Object) *v1.ServiceAccount

type DevicePluginController

type DevicePluginController interface {
	ServiceAccountFactory
	CreateEmptyObject() (devicePlugin client.Object)
	GetTotalObjectCount(ctx context.Context, client client.Client) (count int, err error)
	NewDaemonSet(devicePlugin client.Object) *apps.DaemonSet
	UpdateDaemonSet(client.Object, *apps.DaemonSet) (updated bool)
	UpdateStatus(client.Object, *apps.DaemonSet, []string) (updated bool, err error)
	Upgrade(ctx context.Context, obj client.Object) (upgrade bool)
}

DevicePluginController provides functionality for manipulating actual device plugin CRD objects.

type ServiceAccountFactory

type ServiceAccountFactory interface {
	NewServiceAccount(rawObj client.Object) *v1.ServiceAccount
	NewClusterRoleBinding(rawObj client.Object) *rbacv1.ClusterRoleBinding
}

ServiceAccountFactory provides functions for creating a service account and related objects Note that the rbac Role can be generated from kubebuilder:rbac comment (some examples above), which is the reason why this interface does not yet have a NewRole function.