controllers

Documentation

Index

• func FindNewIRIDisks(desiredIRIDisks, existingIRIDisks []*iri.Disk) []*iri.Disk
• func FindNewIRINetworkInterfaces(desiredIRINics, existingIRINics []*iri.NetworkInterface) []*iri.NetworkInterface
• func InstanceRunsInFleet(instance *corev1alpha1.Instance, instancePoolName string) bool
• func InstanceRunsInFleetPredicate(fleetName string) predicate.Predicate
• type FleetAnnotatorReconciler
  • func (r *FleetAnnotatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *FleetAnnotatorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type FleetInit
  • func (i *FleetInit) SetupWithManager(mgr ctrl.Manager) error
  • func (i *FleetInit) Start(ctx context.Context) error
• type FleetReconciler
  • func (r *FleetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *FleetReconciler) SetupWithManager(mgr ctrl.Manager) error
• type InstanceAnnotatorReconciler
  • func (r *InstanceAnnotatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *InstanceAnnotatorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type InstanceReconciler
  • func (r *InstanceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *InstanceReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func FindNewIRIDisks

func FindNewIRIDisks(desiredIRIDisks, existingIRIDisks []*iri.Disk) []*iri.Disk

func FindNewIRINetworkInterfaces

func FindNewIRINetworkInterfaces(desiredIRINics, existingIRINics []*iri.NetworkInterface) []*iri.NetworkInterface

func InstanceRunsInFleet

func InstanceRunsInFleet(instance *corev1alpha1.Instance, instancePoolName string) bool

func InstanceRunsInFleetPredicate

func InstanceRunsInFleetPredicate(fleetName string) predicate.Predicate

Types

type FleetAnnotatorReconciler

type FleetAnnotatorReconciler struct {
	client.Client

	FleetName     string
	RuntimeEvents runtimeevent.Source
}

func (*FleetAnnotatorReconciler) Reconcile

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

func (*FleetAnnotatorReconciler) SetupWithManager

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

type FleetInit

type FleetInit struct {
	client.Client

	FleetName  string
	ProviderID string

	OnInitialized func(ctx context.Context) error
	OnFailed      func(ctx context.Context, reason error) error
}

func (*FleetInit) SetupWithManager

func (i *FleetInit) SetupWithManager(mgr ctrl.Manager) error

func (*FleetInit) Start

func (i *FleetInit) Start(ctx context.Context) error

type FleetReconciler

type FleetReconciler struct {
	client.Client

	// FleetName is the name of the Fleet to report / update.
	FleetName string
	// Addresses are the addresses the spherelet server is available on.
	Addresses []corev1alpha1.FleetAddress
	// Port is the port the spherelet server is available on.
	Port int32

	InstanceRuntime instance.RuntimeService
}

func (*FleetReconciler) Reconcile

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

func (*FleetReconciler) SetupWithManager

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

type InstanceAnnotatorReconciler

type InstanceAnnotatorReconciler struct {
	client.Client

	InstanceEvents sphereletevent.Source
}

func (*InstanceAnnotatorReconciler) Reconcile

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

func (*InstanceAnnotatorReconciler) SetupWithManager

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

type InstanceReconciler

type InstanceReconciler struct {
	record.EventRecorder
	client.Client

	InstanceRuntime        iriinstance.RuntimeService
	InstanceRuntimeName    string
	InstanceRuntimeVersion string

	FleetName string

	DownwardAPILabels      map[string]string
	DownwardAPIAnnotations map[string]string

	WatchFilterValue string
}

func (*InstanceReconciler) Reconcile

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

func (*InstanceReconciler) SetupWithManager

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