controllers

package
v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	OAuthServicePort     = 443
	OAuthName            = "oauth-proxy"
	OAuthServicePortName = "oauth-proxy"
)

OAuth constants

View Source 
const (
	StatusTypeInferenceServicesPresent = "InferenceServicesPresent"
	StatusTypePVCAvailable             = "PVCAvailable"
	StatusTypeRouteAvailable           = "RouteAvailable"
	StatusTypeAvailable                = "Available"
)

Status types

View Source 
const (
	StatusReasonInferenceServicesNotFound = "InferenceServicesNotFound"
	StatusReasonInferenceServicesFound    = "InferenceServicesFound"
	StatusReasonPVCNotFound               = "PVCNotFound"
	StatusReasonPVCFound                  = "PVCFound"
	StatusReasonRouteNotFound             = "RouteNotFound"
	StatusReasonRouteFound                = "RouteFound"
	StatusAvailable                       = "AllComponentsReady"
	StatusNotAvailable                    = "NotAllComponentsReady"
)

Status reasons

View Source 
const (
	EventReasonPVCCreated                 = "PVCCreated"
	EventReasonInferenceServiceConfigured = "InferenceServiceConfigured"
	EventReasonServiceMonitorCreated      = "ServiceMonitorCreated"
)

Event reasons

View Source 
const (
	Version = "1.17.0"
)

Variables

View Source 
var ErrPVCNotReady = goerrors.New("PVC is not ready")

Functions

func DoNotRequeue added in v1.9.0 

func DoNotRequeue() (reconcile.Result, error)

func GetNamespace 

func GetNamespace() (string, error)

GetNamespace returns the namespace of a pod

func Requeue added in v1.9.0 

func Requeue() (reconcile.Result, error)

func RequeueWithDelay added in v1.9.0 

func RequeueWithDelay(dur time.Duration) (reconcile.Result, error)

func RequeueWithDelayAndError added in v1.9.0 

func RequeueWithDelayAndError(dur time.Duration, e error) (reconcile.Result, error)

func RequeueWithDelayMessage added in v1.9.0 

func RequeueWithDelayMessage(ctx context.Context, dur time.Duration, message string) (reconcile.Result, error)

func RequeueWithError added in v1.9.0 

func RequeueWithError(e error) (reconcile.Result, error)

func RequeueWithErrorMessage added in v1.9.0 

func RequeueWithErrorMessage(ctx context.Context, e error, message string) (reconcile.Result, error)

func UpdateInferenceServiceNotPresent added in v1.10.3 

func UpdateInferenceServiceNotPresent(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateInferenceServicePresent added in v1.10.3 

func UpdateInferenceServicePresent(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdatePVCAvailable added in v1.10.3 

func UpdatePVCAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdatePVCNotAvailable added in v1.10.3 

func UpdatePVCNotAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateRouteAvailable added in v1.10.3 

func UpdateRouteAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateRouteNotAvailable added in v1.10.3 

func UpdateRouteNotAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateTrustyAIServiceAvailable added in v1.13.0 

func UpdateTrustyAIServiceAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateTrustyAIServiceNotAvailable added in v1.13.0 

func UpdateTrustyAIServiceNotAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

Types

type AvailabilityStatus added in v1.13.0 

type AvailabilityStatus struct {
	PVCReady              bool
	DeploymentReady       bool
	RouteReady            bool
	InferenceServiceReady bool
}

AvailabilityStatus holds the readiness status of various resources.

func (*AvailabilityStatus) IsAllReady added in v1.13.0 

func (rs *AvailabilityStatus) IsAllReady() bool

IsAllReady checks if all the necessary readiness fields are true.

type CustomCertificatesBundle added in v1.17.0 

type CustomCertificatesBundle struct {
	IsDefined     bool
	VolumeName    string
	ConfigMapName string
}

type DeploymentConfig added in v1.16.0 

type DeploymentConfig struct {
	Instance                 *trustyaiopendatahubiov1alpha1.TrustyAIService
	ServiceImage             string
	OAuthImage               string
	Schedule                 string
	VolumeMountName          string
	PVCClaimName             string
	CustomCertificatesBundle CustomCertificatesBundle
	Version                  string
}

type OAuthConfig added in v1.13.0 

type OAuthConfig struct {
	ProxyImage string
}

type RouteConfig added in v1.17.0 

type RouteConfig struct {
	Name      string
	Namespace string
	PortName  string
}

type ServiceConfig added in v1.17.0 

type ServiceConfig struct {
	Name      string
	Namespace string
	Version   string
}

type ServiceMonitorConfig added in v1.17.0 

type ServiceMonitorConfig struct {
	Namespace     string
	ComponentName string
	ServiceName   string
}

type ServiceTLSConfig added in v1.16.0 

type ServiceTLSConfig struct {
	Instance                 *trustyaiopendatahubiov1alpha1.TrustyAIService
	CustomCertificatesBundle CustomCertificatesBundle
	Version                  string
}

type SubReconciler added in v1.9.0 

type SubReconciler = func(context.Context, ctrl.Request, *trustyaiopendatahubiov1alpha1.TrustyAIService) (*ctrl.Result, error)

type TrustyAIServiceReconciler 

type TrustyAIServiceReconciler struct {
	client.Client
	Scheme        *runtime.Scheme
	Namespace     string
	EventRecorder record.EventRecorder
}

TrustyAIServiceReconciler reconciles a TrustyAIService object

func (*TrustyAIServiceReconciler) GetCustomCertificatesBundle added in v1.17.0 

func (r *TrustyAIServiceReconciler) GetCustomCertificatesBundle(ctx context.Context, instance *trustyaiopendatahubiov1alpha1.TrustyAIService) CustomCertificatesBundle

func (*TrustyAIServiceReconciler) GetDeploymentsByLabel 

func (r *TrustyAIServiceReconciler) GetDeploymentsByLabel(ctx context.Context, namespace string, labelKey string, labelValue string) ([]appsv1.Deployment, error)

GetDeploymentsByLabel returns a list of Deployments that match a label key-value pair

func (*TrustyAIServiceReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*TrustyAIServiceReconciler) ReconcileRoute added in v1.13.0 

func (r *TrustyAIServiceReconciler) ReconcileRoute(
	instance *trustyaiopendatahubiov1alpha1.TrustyAIService, ctx context.Context) error

ReconcileRoute will manage the creation, update and deletion of the TLS route when the service is reconciled

func (*TrustyAIServiceReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.