controllers

Documentation

Index

• Constants
• func CompareStorageSecrets(s1 corev1.Secret, s2 corev1.Secret) bool
• func IgnoreDeletingErrors(err error) error
• func RoleBindingsAreEqual(sm1 k8srbacv1.RoleBinding, sm2 k8srbacv1.RoleBinding) bool
• type KServeCustomCACertReconciler
  • func (r *KServeCustomCACertReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KServeCustomCACertReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ModelRegistryInferenceServiceReconciler
  • func NewModelRegistryInferenceServiceReconciler(client client.Client, log logr.Logger) *ModelRegistryInferenceServiceReconciler
  • func (r *ModelRegistryInferenceServiceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ModelRegistryInferenceServiceReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MonitoringReconciler
  • func (r *MonitoringReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MonitoringReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NimAccountReconciler
  • func (r *NimAccountReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NimAccountReconciler) SetupWithManager(mgr ctrl.Manager, ctx context.Context) error
• type OpenshiftInferenceServiceReconciler
  • func NewOpenshiftInferenceServiceReconciler(client client.Client, clientReader client.Reader, log logr.Logger, ...) *OpenshiftInferenceServiceReconciler
  • func (r *OpenshiftInferenceServiceReconciler) DeleteResourcesIfNoIsvcExists(ctx context.Context, log logr.Logger, namespace string) error
  • func (r *OpenshiftInferenceServiceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *OpenshiftInferenceServiceReconciler) SetupWithManager(mgr ctrl.Manager) error
• type StorageSecretReconciler
  • func (r *StorageSecretReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *StorageSecretReconciler) ReconcileStorageSecret(secret *corev1.Secret, ctx context.Context) error
  • func (r *StorageSecretReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	RoleBindingName       = "prometheus-ns-access"
	OpenshiftMonitoringNS = "openshift-monitoring"
	// PrometheusClusterRole & MonitoringSA specified within odh-manifests
	PrometheusClusterRole = "prometheus-ns-access"
	MonitoringSA          = "prometheus-custom"
)

Functions

func CompareStorageSecrets

func CompareStorageSecrets(s1 corev1.Secret, s2 corev1.Secret) bool

CompareStorageSecrets checks if two secrets are equal, if not return false

func IgnoreDeletingErrors

func IgnoreDeletingErrors(err error) error

func RoleBindingsAreEqual

func RoleBindingsAreEqual(sm1 k8srbacv1.RoleBinding, sm2 k8srbacv1.RoleBinding) bool

RoleBindingsAreEqual checks if RoleBinding are equal, if not return false

Types

type KServeCustomCACertReconciler

type KServeCustomCACertReconciler struct {
	client.Client
	Log logr.Logger
}

func (*KServeCustomCACertReconciler) Reconcile

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

func (*KServeCustomCACertReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type ModelRegistryInferenceServiceReconciler

type ModelRegistryInferenceServiceReconciler struct {
	// contains filtered or unexported fields
}

ModelRegistryInferenceServiceReconciler holds the controller configuration.

func NewModelRegistryInferenceServiceReconciler

func NewModelRegistryInferenceServiceReconciler(client client.Client, log logr.Logger) *ModelRegistryInferenceServiceReconciler

func (*ModelRegistryInferenceServiceReconciler) Reconcile

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

Reconcile performs the reconciliation of the model registry based on Kubeflow InferenceService CRs

func (*ModelRegistryInferenceServiceReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type MonitoringReconciler

type MonitoringReconciler struct {
	client.Client
	Log          logr.Logger
	MonitoringNS string
}

func (*MonitoringReconciler) Reconcile

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

Reconcile will manage the creation, update and deletion of the ModelMesh monitoring resources

func (*MonitoringReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type NimAccountReconciler

type NimAccountReconciler struct {
	client.Client
	Log     logr.Logger
	KClient kubernetes.Interface
}

func (*NimAccountReconciler) Reconcile

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

func (*NimAccountReconciler) SetupWithManager

func (r *NimAccountReconciler) SetupWithManager(mgr ctrl.Manager, ctx context.Context) error

type OpenshiftInferenceServiceReconciler

type OpenshiftInferenceServiceReconciler struct {
	MeshDisabled bool
	// contains filtered or unexported fields
}

OpenshiftInferenceServiceReconciler holds the controller configuration.

func NewOpenshiftInferenceServiceReconciler

func NewOpenshiftInferenceServiceReconciler(client client.Client, clientReader client.Reader, log logr.Logger, meshDisabled bool) *OpenshiftInferenceServiceReconciler

func (*OpenshiftInferenceServiceReconciler) DeleteResourcesIfNoIsvcExists

func (r *OpenshiftInferenceServiceReconciler) DeleteResourcesIfNoIsvcExists(ctx context.Context, log logr.Logger, namespace string) error

func (*OpenshiftInferenceServiceReconciler) Reconcile

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

Reconcile performs the reconciling of the Openshift objects for a Kubeflow InferenceService.

func (*OpenshiftInferenceServiceReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type StorageSecretReconciler

type StorageSecretReconciler struct {
	client.Client
	Log logr.Logger
}

func (*StorageSecretReconciler) Reconcile

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

func (*StorageSecretReconciler) ReconcileStorageSecret

func (r *StorageSecretReconciler) ReconcileStorageSecret(
	secret *corev1.Secret, ctx context.Context) error

ReconcileStorageSecret will manage the creation, update and deletion of the Storage Config Secret

func (*StorageSecretReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.