daemon

package
v0.0.0-...-1803088 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 21, 2022 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ConditionConfigured       string                       = "Configured"
	ConfigurationInProgress   ConfigurationConditionReason = "InProgress"
	ConfigurationFailed       ConfigurationConditionReason = "Failed"
	ConfigurationNotRequested ConfigurationConditionReason = "NotRequested"
	ConfigurationSucceeded    ConfigurationConditionReason = "Succeeded"
)

Variables

This section is empty.

Functions

func CreateManager

func CreateManager(config *rest.Config, namespace string, scheme *runtime.Scheme) (manager.Manager, error)

func GetSriovInventory

func GetSriovInventory(log *logrus.Logger) (*sriovv2.NodeInventory, error)

Types

type ConfigurationConditionReason

type ConfigurationConditionReason string

type Drainer

type Drainer func(configurer func(ctx context.Context) bool, drain bool) error

type NodeConfigReconciler

type NodeConfigReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

func NewNodeConfigReconciler

func NewNodeConfigReconciler(k8sClient client.Client, configurer NodeConfigurer, nodeNameRef types.NamespacedName) (r *NodeConfigReconciler, err error)

func (*NodeConfigReconciler) CreateEmptyNodeConfigIfNeeded

func (r *NodeConfigReconciler) CreateEmptyNodeConfigIfNeeded(c client.Client) error

CreateEmptyNodeConfigIfNeeded creates empty CR to be Reconciled in near future and filled with Status. If invoked before manager's Start, it'll need a direct API client (Manager's/Controller's client is cached and cache is not initialized yet).

func (*NodeConfigReconciler) Reconcile

func (r *NodeConfigReconciler) Reconcile(_ context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NodeConfigReconciler) SetupWithManager

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

type NodeConfigurator

type NodeConfigurator struct {
	Log *logrus.Logger
	// contains filtered or unexported fields
}

type NodeConfigurer

type NodeConfigurer interface {
	// contains filtered or unexported methods
}

func NewNodeConfigurer

func NewNodeConfigurer(drainer Drainer, client client.Client, nodeNameRef types.NamespacedName) (NodeConfigurer, error)

type ResourceNamePredicate

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

func (ResourceNamePredicate) Create

func (ResourceNamePredicate) Update

Jump to

Keyboard shortcuts

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