resources

Documentation

Index

• Constants
• type AuthConfigStore
  • func NewClientAuthConfigStore(client client.Client) AuthConfigStore
• type AuthConfigTemplateLoader
  • func NewConfigMapTemplateLoader(client client.Client, fallback AuthConfigTemplateLoader) AuthConfigTemplateLoader
  • func NewStaticTemplateLoader() AuthConfigTemplateLoader
• type AuthType
• type AuthTypeDetector
  • func NewKServeAuthTypeDetector(client client.Client) AuthTypeDetector
• type ClusterRoleBindingHandler
  • func NewClusterRoleBindingHandler(client client.Client) ClusterRoleBindingHandler
• type InferenceServiceHostExtractor
  • func NewKServeInferenceServiceHostExtractor() InferenceServiceHostExtractor
• type NetworkPolicyHandler
  • func NewNetworkPolicyHandler(client client.Client) NetworkPolicyHandler
• type PeerAuthenticationHandler
  • func NewPeerAuthenticationHandler(client client.Client) PeerAuthenticationHandler
• type PodMonitorHandler
  • func NewPodMonitorHandler(client client.Client) PodMonitorHandler
• type RoleBindingHandler
  • func NewRoleBindingHandler(client client.Client) RoleBindingHandler
• type RouteHandler
  • func NewRouteHandler(client client.Client) RouteHandler
• type ServiceAccountHandler
  • func NewServiceAccountHandler(client client.Client) ServiceAccountHandler
• type ServiceHandler
  • func NewServiceHandler(client client.Client) ServiceHandler
• type ServiceMeshMemberRollHandler
  • func NewServiceMeshMemberRole(client client.Client) ServiceMeshMemberRollHandler
• type ServiceMonitorHandler
  • func NewServiceMonitorHandler(client client.Client) ServiceMonitorHandler
• type TelemetryHandler
  • func NewTelemetryHandler(client client.Client) TelemetryHandler

Constants

const (
	UserDefined    AuthType = "userdefined"
	Anonymous      AuthType = "anonymous"
	AuthAudience            = "AUTH_AUDIENCE"
	AuthorinoLabel          = "AUTHORINO_LABEL"
)

Types

type AuthConfigStore

type AuthConfigStore interface {
	Get(ctx context.Context, key types.NamespacedName) (*authorinov1beta2.AuthConfig, error)
	Remove(ctx context.Context, key types.NamespacedName) error
	Create(ctx context.Context, authConfig *authorinov1beta2.AuthConfig) error
	Update(ctx context.Context, authConfig *authorinov1beta2.AuthConfig) error
}

func NewClientAuthConfigStore

func NewClientAuthConfigStore(client client.Client) AuthConfigStore

type AuthConfigTemplateLoader

type AuthConfigTemplateLoader interface {
	Load(ctx context.Context, authType AuthType, key types.NamespacedName) (authorinov1beta2.AuthConfig, error)
}

func NewConfigMapTemplateLoader

func NewConfigMapTemplateLoader(client client.Client, fallback AuthConfigTemplateLoader) AuthConfigTemplateLoader

func NewStaticTemplateLoader

func NewStaticTemplateLoader() AuthConfigTemplateLoader

type AuthType

type AuthType string

type AuthTypeDetector

type AuthTypeDetector interface {
	Detect(ctx context.Context, isvc *kservev1beta1.InferenceService) (AuthType, error)
}

func NewKServeAuthTypeDetector

func NewKServeAuthTypeDetector(client client.Client) AuthTypeDetector

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
}

func NewClusterRoleBindingHandler

func NewClusterRoleBindingHandler(client client.Client) ClusterRoleBindingHandler

type InferenceServiceHostExtractor

type InferenceServiceHostExtractor interface {
	Extract(isvc *kservev1beta1.InferenceService) []string
}

func NewKServeInferenceServiceHostExtractor

func NewKServeInferenceServiceHostExtractor() InferenceServiceHostExtractor

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 PeerAuthenticationHandler

type PeerAuthenticationHandler interface {
	FetchPeerAuthentication(ctx context.Context, log logr.Logger, key types.NamespacedName) (*istiosecv1beta1.PeerAuthentication, error)
	DeletePeerAuthentication(ctx context.Context, key types.NamespacedName) error
}

func NewPeerAuthenticationHandler

func NewPeerAuthenticationHandler(client client.Client) PeerAuthenticationHandler

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, key types.NamespacedName) error
}

func NewRoleBindingHandler

func NewRoleBindingHandler(client client.Client) RoleBindingHandler

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

type ServiceMeshMemberRollHandler interface {
	FetchSMMR(ctx context.Context, log logr.Logger, key types.NamespacedName) (*v1.ServiceMeshMemberRoll, error)
	RemoveMemberFromSMMR(ctx context.Context, key types.NamespacedName, member string) error
}

func NewServiceMeshMemberRole

func NewServiceMeshMemberRole(client client.Client) ServiceMeshMemberRollHandler

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

type TelemetryHandler

type TelemetryHandler interface {
	FetchTelemetry(ctx context.Context, log logr.Logger, key types.NamespacedName) (*telemetryv1alpha1.Telemetry, error)
	DeleteTelemetry(ctx context.Context, key types.NamespacedName) error
}

TelemetryHandler to provide telemetry specific implementation.

func NewTelemetryHandler

func NewTelemetryHandler(client client.Client) TelemetryHandler