modeldeployment

Documentation

Index

• Constants
• func Add(mgr manager.Manager) error
• type DockerSecret
• type EnqueueRequestForImplicitOwner
  • func (e *EnqueueRequestForImplicitOwner) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForImplicitOwner) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForImplicitOwner) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForImplicitOwner) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type ReconcileModelDeployment
  • func (r *ReconcileModelDeployment) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (r *ReconcileModelDeployment) ReconcileKnativeConfiguration(log logr.Logger, modelDeploymentCR *legionv1alpha1.ModelDeployment) error
  • func (r *ReconcileModelDeployment) ReconcileModelRoute(log logr.Logger, modelDeploymentCR *legionv1alpha1.ModelDeployment, ...) error

Constants

const (
	DockerConfigSecretKey                = ".dockercfg"
	PeriodUpdatingDockerConnectionToken  = 6 * time.Hour
	PeriodVerifyingDockerConnectionToken = 10 * time.Minute
)

Functions

func Add

func Add(mgr manager.Manager) error

Types

type DockerSecret

type DockerSecret struct {
	Email    string `json:"email"`
	Username string `json:"username"`
	Password string `json:"password"`
}

type EnqueueRequestForImplicitOwner

type EnqueueRequestForImplicitOwner struct{}

func (*EnqueueRequestForImplicitOwner) Create

func (e *EnqueueRequestForImplicitOwner) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*EnqueueRequestForImplicitOwner) Delete

func (e *EnqueueRequestForImplicitOwner) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*EnqueueRequestForImplicitOwner) Generic

func (e *EnqueueRequestForImplicitOwner) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

Generic implements EventHandler

func (*EnqueueRequestForImplicitOwner) Update

func (e *EnqueueRequestForImplicitOwner) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type ReconcileModelDeployment

type ReconcileModelDeployment struct {
	client.Client
	// contains filtered or unexported fields
}

ReconcileModelDeployment reconciles a ModelDeployment object

func (*ReconcileModelDeployment) Reconcile

func (r *ReconcileModelDeployment) Reconcile(request reconcile.Request) (reconcile.Result, error)

+kubebuilder:rbac:groups=apps,resources=deployments,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=apps,resources=deployments/status,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups="",resources=services,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups="",resources=services/status,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups="",resources=endpoints,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups="",resources=endpoints/status,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=authentication.istio.io,resources=policies,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=authentication.istio.io,resources=policies/status,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=legion.legion-platform.org,resources=modeldeployments,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=legion.legion-platform.org,resources=modeldeployments/status,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=serving.knative.dev,resources=configurations,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=serving.knative.dev,resources=revisions,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=serving.knative.dev,resources=services,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=serving.knative.dev,resources=routes,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=networking.internal.knative.dev,resources=certificates,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=networking.internal.knative.dev,resources=serverlessservices,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=networking.internal.knative.dev,resources=clusteringresses,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=caching.internal.knative.dev,resources=images,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=autoscaling.internal.knative.dev,resources=podautoscalers,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=networking.istio.io,resources=envoyfilters,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups="",resources=events,verbs=create;patch +kubebuilder:rbac:groups=core,resources=secrets,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=core,resources=secrets/status,verbs=get;update;patch +kubebuilder:rbac:groups=core,resources=serviceaccounts,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=core,resources=serviceaccounts/status,verbs=get;update;patch +kubebuilder:rbac:groups=legion.legion-platform.org,resources=connections,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=legion.legion-platform.org,resources=connections/status,verbs=get;update;patch

func (*ReconcileModelDeployment) ReconcileKnativeConfiguration

func (r *ReconcileModelDeployment) ReconcileKnativeConfiguration(
	log logr.Logger,
	modelDeploymentCR *legionv1alpha1.ModelDeployment,
) error

func (*ReconcileModelDeployment) ReconcileModelRoute

func (r *ReconcileModelDeployment) ReconcileModelRoute(
	log logr.Logger,
	modelDeploymentCR *legionv1alpha1.ModelDeployment,
	latestReadyRevision string,
) error