controller

package

Go to main page

Versions in this module

v0

v0.1.30

Feb 20, 2026

v0.1.29

Dec 10, 2025

Changes in this version

type NnfNodeBlockStorageReconciler

+ FenceEvents chan event.GenericEvent

type NnfNodeReconciler

+ func (r *NnfNodeReconciler) GetBlockStorageEvents() chan event.GenericEvent

+ func (r *NnfNodeReconciler) InitializeBlockStorageEvents()

v0.1.28

Sep 11, 2025

v0.1.27

Sep 5, 2025

v0.1.26

Aug 29, 2025

v0.1.25

Jul 8, 2025

v0.1.24

Jun 3, 2025

v0.1.23

May 8, 2025

v0.1.22

Apr 28, 2025

v0.1.21

Apr 25, 2025

v0.1.20

Mar 20, 2025

Changes in this version

type NnfLustreMGTReconciler

+ func (r *NnfLustreMGTReconciler) HandleNewCommands(ctx context.Context, nnfLustreMgt *nnfv1alpha6.NnfLustreMGT) (*ctrl.Result, error)

+ func (r *NnfLustreMGTReconciler) RemoveOldCommands(ctx context.Context, nnfLustreMgt *nnfv1alpha6.NnfLustreMGT) error

+ func (r *NnfLustreMGTReconciler) RunCommands(nnfLustreMgt *nnfv1alpha6.NnfLustreMGT, commandLines []string) error

v0.1.19

Feb 6, 2025

v0.1.18

Dec 11, 2024

v0.1.17

Dec 9, 2024

v0.1.16

Oct 21, 2024

v0.1.15

Sep 25, 2024

v0.1.14

Sep 16, 2024

Changes in this version

type NnfAccessReconciler

+ func (r *NnfAccessReconciler) ComputesEnqueueRequests(ctx context.Context, o client.Object) []reconcile.Request

type NnfNodeBlockStorageReconciler

+ Events chan event.GenericEvent

+ Options *nnfec.Options

+ func (r *NnfNodeBlockStorageReconciler) EventHandler(e nnfevent.Event) error

+ func (r *NnfNodeBlockStorageReconciler) NnfEcEventEnqueueHandler(ctx context.Context, o client.Object) []reconcile.Request

type NnfNodeReconciler

+ Events chan event.GenericEvent

type NnfSystemStorageReconciler

+ func (r *NnfSystemStorageReconciler) NnfSystemStorageEnqueueAll(ctx context.Context, o client.Object) []reconcile.Request

v0.1.13

Sep 3, 2024

v0.1.12

Aug 30, 2024

Changes in this version

+ type NnfSystemStorageReconciler struct

+ ChildObjects []dwsv1alpha2.ObjectList

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *NnfSystemStorageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

v0.1.11

Aug 22, 2024

Changes in this version

+ type ControllerType string

+ const ControllerRabbit

+ const ControllerTest

+ const ControllerWorker

+ type K8sNodeState struct

+ type NnfLustreMGTReconciler struct

+ ChildObjects []dwsv1alpha2.ObjectList

+ ControllerType ControllerType

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *NnfLustreMGTReconciler) EraseOldFsName(nnfLustreMgt *nnfv1alpha1.NnfLustreMGT, fsname string) error

+ func (r *NnfLustreMGTReconciler) HandleNewClaims(ctx context.Context, nnfLustreMgt *nnfv1alpha1.NnfLustreMGT) (*ctrl.Result, error)

+ func (r *NnfLustreMGTReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

+ func (r *NnfLustreMGTReconciler) RemoveOldClaims(ctx context.Context, nnfLustreMgt *nnfv1alpha1.NnfLustreMGT) error

+ func (r *NnfLustreMGTReconciler) SetFsNameNext(ctx context.Context, nnfLustreMgt *nnfv1alpha1.NnfLustreMGT, fsname string) (*ctrl.Result, error)

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

v0.1.10

Jul 16, 2024

v0.1.9

Jun 25, 2024

v0.1.8

Jun 14, 2024

Changes in this version

+ type ClientType string

+ const ClientCompute

+ const ClientRabbit

type NnfClientMountReconciler

+ ClientType ClientType

v0.1.7

May 1, 2024

v0.1.6

Apr 8, 2024

v0.1.5

Apr 3, 2024

Changes in this version

type NnfClientMountReconciler

+ SemaphoreForStart chan int

+ func (r *NnfClientMountReconciler) Start(ctx context.Context) error

type NnfNodeBlockStorageReconciler

+ SemaphoreForDone chan int

+ SemaphoreForStart chan int

+ func (r *NnfNodeBlockStorageReconciler) Start(ctx context.Context) error

type NnfNodeECDataReconciler

+ SemaphoreForDone chan int

+ SemaphoreForStart chan int

type NnfNodeReconciler

+ SemaphoreForDone chan int

type NnfNodeStorageReconciler

+ SemaphoreForDone chan int

+ SemaphoreForStart chan int

+ func (r *NnfNodeStorageReconciler) Start(ctx context.Context) error

v0.1.4

Feb 28, 2024

v0.1.3

Feb 21, 2024

v0.1.2

Feb 9, 2024

v0.1.1

Jan 16, 2024

v0.1.0

Jan 12, 2024

Changes in this version

+ const ConditionFalse

+ const ConditionTrue

+ const NnfAccessAnnotation

+ const NnfNlcResourceName

+ const NnfNodeECDataResourceName

+ func Requeue(reason string) *result

+ type AllocationSpec = nnfv1alpha1.NnfPortManagerAllocationSpec

+ type AllocationStatus = nnfv1alpha1.NnfPortManagerAllocationStatus

+ type DWSServersReconciler struct

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *DWSServersReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type DWSStorageReconciler struct

+ Log logr.Logger

+ Scheme *runtime.Scheme

+ func (r *DWSStorageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type DirectiveBreakdownReconciler struct

+ ChildObjects []dwsv1alpha2.ObjectList

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *DirectiveBreakdownReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type NnfAccessReconciler struct

+ ChildObjects []dwsv1alpha2.ObjectList

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *NnfAccessReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type NnfClientMountReconciler struct

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *NnfClientMountReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type NnfNodeBlockStorageReconciler struct

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *NnfNodeBlockStorageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type NnfNodeECDataReconciler struct

+ Options *nnfec.Options

+ RawLog logr.Logger

+ Scheme *runtime.Scheme

+ func (r *NnfNodeECDataReconciler) NewPersistentStorageInterface(name string, readOnly bool) (persistent.PersistentStorageApi, error)

+ func (r *NnfNodeECDataReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

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

+ func (r *NnfNodeECDataReconciler) Start(ctx context.Context) error

+ type NnfNodeReconciler struct

+ Log logr.Logger

+ Options *nnfec.Options

+ Scheme *kruntime.Scheme

+ func (r *NnfNodeReconciler) EventHandler(e event.Event) error

+ func (r *NnfNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ func (r *NnfNodeReconciler) Start(ctx context.Context) error

+ type NnfNodeStorageReconciler struct

+ ChildObjects []dwsv1alpha2.ObjectList

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *NnfNodeStorageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type NnfPortManagerReconciler struct

+ Scheme *runtime.Scheme

+ func (r *NnfPortManagerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type NnfStorageReconciler struct

+ ChildObjects []dwsv1alpha2.ObjectList

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *NnfStorageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type NnfSystemConfigurationReconciler struct

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *NnfSystemConfigurationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type NnfWorkflowReconciler struct

+ ChildObjects []dwsv1alpha2.ObjectList

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *NnfWorkflowReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

+ type PersistentStorageReconciler struct

+ ChildObjects []dwsv1alpha2.ObjectList

+ Log logr.Logger

+ Scheme *kruntime.Scheme

+ func (r *PersistentStorageReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

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

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