tas

package
v1.30.0 Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2024 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	STORAGE_PVC      = "PVC"
	STORAGE_DATABASE = "DATABASE"
)

Allowed storage formats

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

OAuth constants

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

Status types

View Source 
const (
	StatusReasonInferenceServicesNotFound = "InferenceServicesNotFound"
	StatusReasonInferenceServicesFound    = "InferenceServicesFound"
	StatusReasonPVCNotFound               = "PVCNotFound"
	StatusReasonPVCFound                  = "PVCFound"
	StatusReasonRouteNotFound             = "RouteNotFound"
	StatusReasonRouteFound                = "RouteFound"
	StatusAvailable                       = "AllComponentsReady"
	StatusNotAvailable                    = "NotAllComponentsReady"
	StatusDBCredentialsNotFound           = "DBCredentialsNotFound"
	StatusDBCredentialsError              = "DBCredentialsError"
	StatusDBConnectionError               = "DBConnectionError"
	StatusDBAvailable                     = "DBAvailable"
)

Status reasons

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

Event reasons

View Source 
const (
	PhaseReady    = "Ready"
	PhaseNotReady = "Not Ready"
)

Phases

View Source 
const (
	DEPLOYMENT_MODE_MODELMESH  = "ModelMesh"
	DEPLOYMENT_MODE_RAW        = "RawDeployment"
	DEPLOYMENT_MODE_SERVERLESS = "Serverless"
)
View Source 
const (
	ServiceName = "TAS"
)
View Source 
const (
	StateReasonCrashLoopBackOff = "CrashLoopBackOff"
)

Variables

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

Functions

func ControllerSetUp 

func ControllerSetUp(mgr manager.Manager, ns, configmap string, recorder record.EventRecorder) error

func DoNotRequeue 

func DoNotRequeue() (reconcile.Result, error)

func Requeue 

func Requeue() (reconcile.Result, error)

func RequeueWithDelay 

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

func RequeueWithDelayAndError 

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

func RequeueWithDelayMessage 

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

func RequeueWithError 

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

func RequeueWithErrorMessage 

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

func UpdateDBAvailable 

func UpdateDBAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateDBConnectionError 

func UpdateDBConnectionError(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateDBCredentialsError 

func UpdateDBCredentialsError(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateDBCredentialsNotFound 

func UpdateDBCredentialsNotFound(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateInferenceServiceNotPresent 

func UpdateInferenceServiceNotPresent(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateInferenceServicePresent 

func UpdateInferenceServicePresent(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdatePVCAvailable 

func UpdatePVCAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdatePVCNotAvailable 

func UpdatePVCNotAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateRouteAvailable 

func UpdateRouteAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateRouteNotAvailable 

func UpdateRouteNotAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateTrustyAIServiceAvailable 

func UpdateTrustyAIServiceAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

func UpdateTrustyAIServiceNotAvailable 

func UpdateTrustyAIServiceNotAvailable(saved *trustyaiopendatahubiov1alpha1.TrustyAIService)

Types

type AvailabilityStatus 

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

AvailabilityStatus has the readiness status of various resources.

func (*AvailabilityStatus) IsAllReady 

func (rs *AvailabilityStatus) IsAllReady(mode string) bool

IsAllReady checks if all the necessary readiness fields are true for the specific mode

type CustomCertificatesBundle 

type CustomCertificatesBundle struct {
	IsDefined     bool
	VolumeName    string
	ConfigMapName string
}

type DeploymentConfig 

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

type DestinationRuleConfig 

type DestinationRuleConfig struct {
	Name                string
	Namespace           string
	DestinationRuleName string
}

DestinationRuleConfig has the variables for the DestinationRule template

type OAuthConfig 

type OAuthConfig struct {
	ProxyImage string
}

type RouteConfig 

type RouteConfig struct {
	Name      string
	Namespace string
	PortName  string
}

type ServiceConfig 

type ServiceConfig struct {
	Name      string
	Namespace string
	Version   string
}

type ServiceMonitorConfig 

type ServiceMonitorConfig struct {
	Namespace     string
	ComponentName string
	ServiceName   string
}

type ServiceTLSConfig 

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

type SubReconciler 

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

type TLSCertVolumes 

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

TLSCertVolumes holds the volume and volume mount for the TLS certificates

type TrustyAIServiceReconciler 

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

TrustyAIServiceReconciler reconciles a TrustyAIService object

func (*TrustyAIServiceReconciler) GetCustomCertificatesBundle 

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 

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.

type VirtualServiceConfig 

type VirtualServiceConfig struct {
	Name               string
	Namespace          string
	VirtualServiceName string
}

DestinationRuleConfig has the variables for the DestinationRule template

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.