resources

package
v0.0.0-...-94c4bcd Latest Latest
Warning

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

Go to latest
Published: Oct 17, 2025 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AuthPolicyDetector

type AuthPolicyDetector interface {
	Detect(ctx context.Context, annotations map[string]string) constants.AuthType
}

func NewKServeAuthPolicyDetector

func NewKServeAuthPolicyDetector(client client.Client) AuthPolicyDetector

type AuthPolicyMatcher

type AuthPolicyMatcher interface {
	FindLLMServiceFromHTTPRouteAuthPolicy(authPolicy *kuadrantv1.AuthPolicy) (types.NamespacedName, bool)
	FindLLMServiceFromGatewayAuthPolicy(ctx context.Context, authPolicy *kuadrantv1.AuthPolicy) ([]types.NamespacedName, error)
}

func NewKServeAuthPolicyMatcher

func NewKServeAuthPolicyMatcher(client client.Client) AuthPolicyMatcher

type AuthPolicyStore

type AuthPolicyStore interface {
	Get(ctx context.Context, key types.NamespacedName) (*kuadrantv1.AuthPolicy, error)
	Remove(ctx context.Context, key types.NamespacedName) error
	Create(ctx context.Context, authPolicy *kuadrantv1.AuthPolicy) error
	Update(ctx context.Context, authPolicy *kuadrantv1.AuthPolicy) error
}

func NewClientAuthPolicyStore

func NewClientAuthPolicyStore(client client.Client) AuthPolicyStore

type AuthPolicyTemplateLoader

type AuthPolicyTemplateLoader interface {
	Load(ctx context.Context, authType constants.AuthType, llmisvc *kservev1alpha1.LLMInferenceService) ([]*kuadrantv1.AuthPolicy, error)
}

func NewKServeAuthPolicyTemplateLoader

func NewKServeAuthPolicyTemplateLoader(client client.Client) AuthPolicyTemplateLoader

type ClusterRoleBindingHandler

type ClusterRoleBindingHandler interface {
	FetchClusterRoleBinding(ctx context.Context, log logr.Logger, key types.NamespacedName) (*v1.ClusterRoleBinding, error)
	DeleteClusterRoleBinding(ctx context.Context, key types.NamespacedName) error
	CreateDesiredClusterRoleBinding(crbName string, serviceAccountName string, namespace string) *v1.ClusterRoleBinding
	ProcessDelta(ctx context.Context, log logr.Logger, desiredCRB *v1.ClusterRoleBinding, existingCRB *v1.ClusterRoleBinding, deltaProcessor processors.DeltaProcessor) (err error)
	GetClusterRoleBindingName(isvcNamespace string, serviceAccountName string) string
}

func NewClusterRoleBindingHandler

func NewClusterRoleBindingHandler(client client.Client) ClusterRoleBindingHandler

type ConfigMapHandler

type ConfigMapHandler interface {
	FetchConfigMap(ctx context.Context, log logr.Logger, key types.NamespacedName) (*corev1.ConfigMap, error)
}

func NewConfigMapHandler

func NewConfigMapHandler(client client.Client) ConfigMapHandler

type EnvoyFilterDetector

type EnvoyFilterDetector interface {
	Detect(ctx context.Context, annotations map[string]string) bool
}

func NewKServeEnvoyFilterDetector

func NewKServeEnvoyFilterDetector(client client.Client) EnvoyFilterDetector

type EnvoyFilterMatcher

type EnvoyFilterMatcher interface {
	FindLLMServiceFromEnvoyFilter(ctx context.Context, envoyFilter *istioclientv1alpha3.EnvoyFilter) ([]types.NamespacedName, error)
}

func NewKServeEnvoyFilterMatcher

func NewKServeEnvoyFilterMatcher(client client.Client) EnvoyFilterMatcher

type EnvoyFilterStore

type EnvoyFilterStore interface {
	Get(ctx context.Context, key types.NamespacedName) (*istioclientv1alpha3.EnvoyFilter, error)
	Remove(ctx context.Context, key types.NamespacedName) error
	Create(ctx context.Context, envoyFilter *istioclientv1alpha3.EnvoyFilter) error
	Update(ctx context.Context, envoyFilter *istioclientv1alpha3.EnvoyFilter) error
}

func NewClientEnvoyFilterStore

func NewClientEnvoyFilterStore(client client.Client) EnvoyFilterStore

type EnvoyFilterTemplateLoader

type EnvoyFilterTemplateLoader interface {
	Load(ctx context.Context, llmisvc *kservev1alpha1.LLMInferenceService) ([]*istioclientv1alpha3.EnvoyFilter, error)
}

func NewKServeEnvoyFilterTemplateLoader

func NewKServeEnvoyFilterTemplateLoader(client client.Client) EnvoyFilterTemplateLoader

type NetworkPolicyHandler

type NetworkPolicyHandler interface {
	FetchNetworkPolicy(ctx context.Context, log logr.Logger, key types.NamespacedName) (*v1.NetworkPolicy, error)
	DeleteNetworkPolicy(ctx context.Context, key types.NamespacedName) error
}

func NewNetworkPolicyHandler

func NewNetworkPolicyHandler(client client.Client) NetworkPolicyHandler

type PodMonitorHandler

type PodMonitorHandler interface {
	FetchPodMonitor(ctx context.Context, log logr.Logger, key types.NamespacedName) (*v1.PodMonitor, error)
	DeletePodMonitor(ctx context.Context, key types.NamespacedName) error
}

func NewPodMonitorHandler

func NewPodMonitorHandler(client client.Client) PodMonitorHandler

type RoleBindingHandler

type RoleBindingHandler interface {
	FetchRoleBinding(ctx context.Context, log logr.Logger, key types.NamespacedName) (*v1.RoleBinding, error)
	DeleteRoleBinding(ctx context.Context, log logr.Logger, key types.NamespacedName) error
}

func NewRoleBindingHandler

func NewRoleBindingHandler(client client.Client) RoleBindingHandler

type RoleHandler

type RoleHandler interface {
	FetchRole(ctx context.Context, log logr.Logger, key types.NamespacedName) (*v1.Role, error)
	DeleteRole(ctx context.Context, key types.NamespacedName) error
}

func NewRoleHandler

func NewRoleHandler(client client.Client) RoleHandler

type RouteHandler

type RouteHandler interface {
	FetchRoute(ctx context.Context, log logr.Logger, key types.NamespacedName) (*v1.Route, error)
	DeleteRoute(ctx context.Context, key types.NamespacedName) error
}

RouteHandler to provide route specific implementation.

func NewRouteHandler

func NewRouteHandler(client client.Client) RouteHandler

type SecretHandler

type SecretHandler interface {
	Get(ctx context.Context, key types.NamespacedName) (*v1.Secret, error)
}

func NewSecretHandler

func NewSecretHandler(client client.Client) SecretHandler

type ServiceAccountHandler

type ServiceAccountHandler interface {
	FetchServiceAccount(ctx context.Context, log logr.Logger, key types.NamespacedName) (*v1.ServiceAccount, error)
	DeleteServiceAccount(ctx context.Context, key types.NamespacedName) error
}

func NewServiceAccountHandler

func NewServiceAccountHandler(client client.Client) ServiceAccountHandler

type ServiceHandler

type ServiceHandler interface {
	FetchService(ctx context.Context, log logr.Logger, key types.NamespacedName) (*v1.Service, error)
}

func NewServiceHandler

func NewServiceHandler(client client.Client) ServiceHandler

type ServiceMonitorHandler

type ServiceMonitorHandler interface {
	FetchServiceMonitor(ctx context.Context, log logr.Logger, key types.NamespacedName) (*v1.ServiceMonitor, error)
	DeleteServiceMonitor(ctx context.Context, key types.NamespacedName) error
}

func NewServiceMonitorHandler

func NewServiceMonitorHandler(client client.Client) ServiceMonitorHandler

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL