reconcilers

package
v0.0.0-...-9d6de07 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	Title   string  `json:"title"`
	Type    string  `json:"type"`
	Queries []Query `json:"queries"`
}

type KserveAuthConfigReconciler 

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

func NewKserveAuthConfigReconciler 

func NewKserveAuthConfigReconciler(client client.Client) *KserveAuthConfigReconciler

func (*KserveAuthConfigReconciler) Cleanup 

func (r *KserveAuthConfigReconciler) Cleanup(_ context.Context, _ logr.Logger, _ string) error

func (*KserveAuthConfigReconciler) Delete 

func (r *KserveAuthConfigReconciler) Delete(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

func (*KserveAuthConfigReconciler) Reconcile 

func (r *KserveAuthConfigReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type KserveGatewayReconciler 

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

func NewKserveGatewayReconciler 

func NewKserveGatewayReconciler(client client.Client, clientReader client.Reader) *KserveGatewayReconciler

The clientReader uses the API server to retrieve Secrets that are not cached. By default, only Secrets with the specific label "opendatahub.io/managed: true" are cached.

func (*KserveGatewayReconciler) Cleanup 

func (r *KserveGatewayReconciler) Cleanup(ctx context.Context, log logr.Logger, isvcName string) error

func (*KserveGatewayReconciler) Delete 

func (r *KserveGatewayReconciler) Delete(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

func (*KserveGatewayReconciler) Reconcile 

func (r *KserveGatewayReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type KserveIstioPeerAuthenticationReconciler 

type KserveIstioPeerAuthenticationReconciler struct {
	SingleResourcePerNamespace
	// contains filtered or unexported fields
}

func NewKServeIstioPeerAuthenticationReconciler 

func NewKServeIstioPeerAuthenticationReconciler(client client.Client) *KserveIstioPeerAuthenticationReconciler

func (*KserveIstioPeerAuthenticationReconciler) Cleanup 

func (r *KserveIstioPeerAuthenticationReconciler) Cleanup(ctx context.Context, log logr.Logger, isvcNs string) error

func (*KserveIstioPeerAuthenticationReconciler) Reconcile 

func (r *KserveIstioPeerAuthenticationReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

TODO remove this reconcile loop in future versions

type KserveIstioPodMonitorReconciler 

type KserveIstioPodMonitorReconciler struct {
	SingleResourcePerNamespace
	// contains filtered or unexported fields
}

func NewKServeIstioPodMonitorReconciler 

func NewKServeIstioPodMonitorReconciler(client client.Client) *KserveIstioPodMonitorReconciler

func (*KserveIstioPodMonitorReconciler) Cleanup 

func (r *KserveIstioPodMonitorReconciler) Cleanup(ctx context.Context, log logr.Logger, isvcNs string) error

func (*KserveIstioPodMonitorReconciler) Reconcile 

func (r *KserveIstioPodMonitorReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type KserveIstioServiceMonitorReconciler 

type KserveIstioServiceMonitorReconciler struct {
	SingleResourcePerNamespace
	// contains filtered or unexported fields
}

func NewKServeIstioServiceMonitorReconciler 

func NewKServeIstioServiceMonitorReconciler(client client.Client) *KserveIstioServiceMonitorReconciler

func (*KserveIstioServiceMonitorReconciler) Cleanup 

func (r *KserveIstioServiceMonitorReconciler) Cleanup(ctx context.Context, log logr.Logger, isvcNs string) error

func (*KserveIstioServiceMonitorReconciler) Reconcile 

func (r *KserveIstioServiceMonitorReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type KserveIstioTelemetryReconciler 

type KserveIstioTelemetryReconciler struct {
	SingleResourcePerNamespace
	// contains filtered or unexported fields
}

func NewKServeIstioTelemetryReconciler 

func NewKServeIstioTelemetryReconciler(client client.Client) *KserveIstioTelemetryReconciler

func (*KserveIstioTelemetryReconciler) Cleanup 

func (r *KserveIstioTelemetryReconciler) Cleanup(ctx context.Context, log logr.Logger, isvcNs string) error

func (*KserveIstioTelemetryReconciler) Reconcile 

func (r *KserveIstioTelemetryReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type KserveIsvcServiceReconciler 

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

func NewKserveIsvcServiceReconciler 

func NewKserveIsvcServiceReconciler(client client.Client) *KserveIsvcServiceReconciler

func (*KserveIsvcServiceReconciler) Cleanup 

func (r *KserveIsvcServiceReconciler) Cleanup(_ context.Context, _ logr.Logger, _ string) error

func (*KserveIsvcServiceReconciler) Delete 

func (r *KserveIsvcServiceReconciler) Delete(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

func (*KserveIsvcServiceReconciler) Reconcile 

func (r *KserveIsvcServiceReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

To support KServe local gateway using HTTPS, each InferenceService (ISVC) needs a certificate. This reconciliation process helps add a serving certificate annotation to the ISVC service.

type KserveMetricsDashboardReconciler 

type KserveMetricsDashboardReconciler struct {
	NoResourceRemoval
	// contains filtered or unexported fields
}

func NewKserveMetricsDashboardReconciler 

func NewKserveMetricsDashboardReconciler(client client.Client) *KserveMetricsDashboardReconciler

func (*KserveMetricsDashboardReconciler) Reconcile 

func (r *KserveMetricsDashboardReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type KserveMetricsServiceMonitorReconciler 

type KserveMetricsServiceMonitorReconciler struct {
	NoResourceRemoval
	// contains filtered or unexported fields
}

func NewKServeMetricsServiceMonitorReconciler 

func NewKServeMetricsServiceMonitorReconciler(client client.Client) *KserveMetricsServiceMonitorReconciler

func (*KserveMetricsServiceMonitorReconciler) Reconcile 

func (r *KserveMetricsServiceMonitorReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

TODO remove this reconcile loop in future versions

type KserveMetricsServiceReconciler 

type KserveMetricsServiceReconciler struct {
	NoResourceRemoval
	// contains filtered or unexported fields
}

func NewKServeMetricsServiceReconciler 

func NewKServeMetricsServiceReconciler(client client.Client) *KserveMetricsServiceReconciler

func (*KserveMetricsServiceReconciler) Reconcile 

func (r *KserveMetricsServiceReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

TODO remove this reconcile loop in future versions

type KserveNetworkPolicyReconciler 

type KserveNetworkPolicyReconciler struct {
	SingleResourcePerNamespace
	// contains filtered or unexported fields
}

func NewKServeNetworkPolicyReconciler 

func NewKServeNetworkPolicyReconciler(client client.Client) *KserveNetworkPolicyReconciler

func (*KserveNetworkPolicyReconciler) Cleanup 

func (r *KserveNetworkPolicyReconciler) Cleanup(ctx context.Context, log logr.Logger, isvcNamespace string) error

func (*KserveNetworkPolicyReconciler) Reconcile 

func (r *KserveNetworkPolicyReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type KservePrometheusRoleBindingReconciler 

type KservePrometheusRoleBindingReconciler struct {
	SingleResourcePerNamespace
	// contains filtered or unexported fields
}

func NewKServePrometheusRoleBindingReconciler 

func NewKServePrometheusRoleBindingReconciler(client client.Client) *KservePrometheusRoleBindingReconciler

func (*KservePrometheusRoleBindingReconciler) Cleanup 

func (r *KservePrometheusRoleBindingReconciler) Cleanup(ctx context.Context, log logr.Logger, isvcNs string) error

func (*KservePrometheusRoleBindingReconciler) Reconcile 

func (r *KservePrometheusRoleBindingReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type KserveRawInferenceServiceReconciler 

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

func NewKServeRawInferenceServiceReconciler 

func NewKServeRawInferenceServiceReconciler(client client.Client) *KserveRawInferenceServiceReconciler

func (*KserveRawInferenceServiceReconciler) Reconcile 

func (r *KserveRawInferenceServiceReconciler) Reconcile(_ context.Context, log logr.Logger, _ *kservev1beta1.InferenceService) error

type KserveRouteReconciler 

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

func NewKserveRouteReconciler 

func NewKserveRouteReconciler(client client.Client) *KserveRouteReconciler

func (*KserveRouteReconciler) Cleanup 

func (r *KserveRouteReconciler) Cleanup(_ context.Context, _ logr.Logger, _ string) error

func (*KserveRouteReconciler) Delete 

func (r *KserveRouteReconciler) Delete(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

func (*KserveRouteReconciler) Reconcile 

func (r *KserveRouteReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type KserveServerlessInferenceServiceReconciler 

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

func NewKServeServerlessInferenceServiceReconciler 

func NewKServeServerlessInferenceServiceReconciler(client client.Client, clientReader client.Reader) *KserveServerlessInferenceServiceReconciler

func (*KserveServerlessInferenceServiceReconciler) CleanupNamespaceIfNoKserveIsvcExists 

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

func (*KserveServerlessInferenceServiceReconciler) OnDeletionOfKserveInferenceService 

func (r *KserveServerlessInferenceServiceReconciler) OnDeletionOfKserveInferenceService(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

func (*KserveServerlessInferenceServiceReconciler) Reconcile 

func (r *KserveServerlessInferenceServiceReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type KserveServiceMeshMemberReconciler 

type KserveServiceMeshMemberReconciler struct {
	SingleResourcePerNamespace
	// contains filtered or unexported fields
}

func NewKserveServiceMeshMemberReconciler 

func NewKserveServiceMeshMemberReconciler(client client.Client) *KserveServiceMeshMemberReconciler

func (*KserveServiceMeshMemberReconciler) Cleanup 

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

func (*KserveServiceMeshMemberReconciler) Reconcile 

func (r *KserveServiceMeshMemberReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type MetricsDashboardConfigMapData 

type MetricsDashboardConfigMapData struct {
	Data []Config `json:"data"`
}

type ModelMeshClusterRoleBindingReconciler 

type ModelMeshClusterRoleBindingReconciler struct {
	SingleResourcePerNamespace
	// contains filtered or unexported fields
}

func NewModelMeshClusterRoleBindingReconciler 

func NewModelMeshClusterRoleBindingReconciler(client client.Client) *ModelMeshClusterRoleBindingReconciler

func (*ModelMeshClusterRoleBindingReconciler) Cleanup 

func (r *ModelMeshClusterRoleBindingReconciler) Cleanup(ctx context.Context, log logr.Logger, isvcNs string) error

func (*ModelMeshClusterRoleBindingReconciler) Reconcile 

func (r *ModelMeshClusterRoleBindingReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type ModelMeshInferenceServiceReconciler 

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

func NewModelMeshInferenceServiceReconciler 

func NewModelMeshInferenceServiceReconciler(client client.Client) *ModelMeshInferenceServiceReconciler

func (*ModelMeshInferenceServiceReconciler) DeleteModelMeshResourcesIfNoMMIsvcExists 

func (r *ModelMeshInferenceServiceReconciler) DeleteModelMeshResourcesIfNoMMIsvcExists(ctx context.Context, log logr.Logger, isvcNs string) error

func (*ModelMeshInferenceServiceReconciler) Reconcile 

func (r *ModelMeshInferenceServiceReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type ModelMeshRouteReconciler 

type ModelMeshRouteReconciler struct {
	NoResourceRemoval
	// contains filtered or unexported fields
}

func NewModelMeshRouteReconciler 

func NewModelMeshRouteReconciler(client client.Client) *ModelMeshRouteReconciler

func (*ModelMeshRouteReconciler) Reconcile 

func (r *ModelMeshRouteReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

Reconcile will manage the creation, update and deletion of the TLS route when the predictor is reconciled.

type ModelMeshServiceAccountReconciler 

type ModelMeshServiceAccountReconciler struct {
	SingleResourcePerNamespace
	// contains filtered or unexported fields
}

func NewModelMeshServiceAccountReconciler 

func NewModelMeshServiceAccountReconciler(client client.Client) *ModelMeshServiceAccountReconciler

func (*ModelMeshServiceAccountReconciler) Cleanup 

func (r *ModelMeshServiceAccountReconciler) Cleanup(ctx context.Context, log logr.Logger, isvcNs string) error

func (*ModelMeshServiceAccountReconciler) Reconcile 

func (r *ModelMeshServiceAccountReconciler) Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error

type NoResourceRemoval 

type NoResourceRemoval struct{}

NoResourceRemoval is a trait to indicate that given reconciler is not supposed to delete any resources left.

func (*NoResourceRemoval) Cleanup 

func (r *NoResourceRemoval) Cleanup(_ context.Context, _ logr.Logger, _ string) error

func (*NoResourceRemoval) Delete 

func (r *NoResourceRemoval) Delete(_ context.Context, _ logr.Logger, _ *kservev1beta1.InferenceService) error

type Query 

type Query struct {
	Title string `json:"title"`
	Query string `json:"query"`
}

type Reconciler 

type Reconciler interface {
	// Reconcile ensures the resource related to given InferenceService is in the desired state.
	Reconcile(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error
}

type SingleResourcePerNamespace 

type SingleResourcePerNamespace struct{}

SingleResourcePerNamespace is a trait to indicate that given reconciler is only supposed to clean up owned resources when there is no relevant ISVC left.

func (*SingleResourcePerNamespace) Delete 

func (r *SingleResourcePerNamespace) Delete(_ context.Context, _ logr.Logger, _ *kservev1beta1.InferenceService) error

type SubResourceReconciler 

type SubResourceReconciler interface {
	Reconciler
	// Delete removes subresource owned by InferenceService.
	Delete(ctx context.Context, log logr.Logger, isvc *kservev1beta1.InferenceService) error
	// Cleanup ensures singleton resource (such as ServiceMonitor) is removed
	// when there is no InferenceServices left in the namespace.
	Cleanup(ctx context.Context, log logr.Logger, isvcNs string) error
}

Source Files

View all Source files

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.