controllers

Documentation

Index

• Constants
• Variables
• func FilteredLogger(logger logr.Logger) logr.Logger
• func RCCUniqueName(s string) string
• func SetupRayClusterWebhookWithManager(mgr ctrl.Manager, cfg *config.KubeRayConfiguration, operatorVersion string) error
• type RayClusterReconciler
  • func (r *RayClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *RayClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	CAPrivateKeyKey = "ca.key"
	CACertKey       = "ca.crt"

	RayClusterNameLabel = "ray.openshift.ai/cluster-name"
)

Variables

var (
	CertGeneratorImage = getEnv("CERT_GENERATOR_IMAGE", "registry.redhat.io/ubi9@sha256:770cf07083e1c85ae69c25181a205b7cdef63c11b794c89b3b487d4670b4c328")
	OAuthProxyImage    = getEnv("OAUTH_PROXY_IMAGE", "registry.redhat.io/openshift4/ose-oauth-proxy@sha256:1ea6a01bf3e63cdcf125c6064cbd4a4a270deaf0f157b3eabb78f60556840366")
)

Functions

func FilteredLogger

func FilteredLogger(logger logr.Logger) logr.Logger

FilteredLogger returns a copy of the logger with an error log filter

func RCCUniqueName

func RCCUniqueName(s string) string

func SetupRayClusterWebhookWithManager

func SetupRayClusterWebhookWithManager(mgr ctrl.Manager, cfg *config.KubeRayConfiguration, operatorVersion string) error

Types

type RayClusterReconciler

type RayClusterReconciler struct {
	client.Client

	Scheme      *runtime.Scheme
	CookieSalt  string
	Config      *config.KubeRayConfiguration
	IsOpenShift bool
	// contains filtered or unexported fields
}

RayClusterReconciler reconciles a RayCluster object

func (*RayClusterReconciler) Reconcile

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

func (*RayClusterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.