reconcilers

package
v0.0.0-...-b411720 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 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

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 KserveIstioSMMRReconciler 

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

func NewKServeIstioSMMRReconciler 

func NewKServeIstioSMMRReconciler(client client.Client) *KserveIstioSMMRReconciler

func (*KserveIstioSMMRReconciler) Cleanup 

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

func (*KserveIstioSMMRReconciler) Reconcile 

func (r *KserveIstioSMMRReconciler) 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 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

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

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) *KserveServerlessInferenceServiceReconciler

func (*KserveServerlessInferenceServiceReconciler) DeleteKserveMetricsResourcesIfNoKserveIsvcExists 

func (r *KserveServerlessInferenceServiceReconciler) DeleteKserveMetricsResourcesIfNoKserveIsvcExists(ctx context.Context, log logr.Logger, isvcNamespace 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 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 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.