aimmodelcache

Documentation

Index

• func GenerateCachePvcName(mc *aimv1alpha1.AIMModelCache) string
• type ModelCacheFetchResult
  • func (result ModelCacheFetchResult) CheckSizeJobSucceeded() bool
  • func (result ModelCacheFetchResult) DownloadJobSucceeded() bool
• type ModelCacheObservation
  • func (obs ModelCacheObservation) GetComponentHealth(ctx context.Context, clientset kubernetes.Interface) []controllerutils.ComponentHealth
  • func (obs ModelCacheObservation) GetEffectiveSize() int64
  • func (obs ModelCacheObservation) IsSizeKnown() bool
• type ModelCacheReconciler
  • func (r *ModelCacheReconciler) ComposeState(ctx context.Context, ...) ModelCacheObservation
  • func (r *ModelCacheReconciler) DecorateStatus(status *aimv1alpha1.AIMModelCacheStatus, cm *controllerutils.ConditionManager, ...)
  • func (r *ModelCacheReconciler) FetchRemoteState(ctx context.Context, c client.Client, ...) ModelCacheFetchResult
  • func (r *ModelCacheReconciler) PlanResources(ctx context.Context, ...) controllerutils.PlanResult

Functions

func GenerateCachePvcName

func GenerateCachePvcName(mc *aimv1alpha1.AIMModelCache) string

Types

type ModelCacheFetchResult

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

func (ModelCacheFetchResult) CheckSizeJobSucceeded

func (result ModelCacheFetchResult) CheckSizeJobSucceeded() bool

CheckSizeJobSucceeded returns true if the check-size job completed successfully

func (ModelCacheFetchResult) DownloadJobSucceeded

func (result ModelCacheFetchResult) DownloadJobSucceeded() bool

type ModelCacheObservation

type ModelCacheObservation struct {
	ModelCacheFetchResult
	// contains filtered or unexported fields
}

func (ModelCacheObservation) GetComponentHealth

func (obs ModelCacheObservation) GetComponentHealth(ctx context.Context, clientset kubernetes.Interface) []controllerutils.ComponentHealth

func (ModelCacheObservation) GetEffectiveSize

func (obs ModelCacheObservation) GetEffectiveSize() int64

func (ModelCacheObservation) IsSizeKnown

func (obs ModelCacheObservation) IsSizeKnown() bool

type ModelCacheReconciler

type ModelCacheReconciler struct {
	Clientset kubernetes.Interface
	Scheme    *runtime.Scheme
}

func (*ModelCacheReconciler) ComposeState

func (r *ModelCacheReconciler) ComposeState(
	ctx context.Context,
	_ controllerutils.ReconcileContext[*aimv1alpha1.AIMModelCache],
	fetch ModelCacheFetchResult,
) ModelCacheObservation

func (*ModelCacheReconciler) DecorateStatus

func (r *ModelCacheReconciler) DecorateStatus(
	status *aimv1alpha1.AIMModelCacheStatus,
	cm *controllerutils.ConditionManager,
	obs ModelCacheObservation,
)

DecorateStatus implements StatusDecorator to update download status

func (*ModelCacheReconciler) FetchRemoteState

func (r *ModelCacheReconciler) FetchRemoteState(
	ctx context.Context,
	c client.Client,
	reconcileCtx controllerutils.ReconcileContext[*aimv1alpha1.AIMModelCache],
) ModelCacheFetchResult

func (*ModelCacheReconciler) PlanResources

func (r *ModelCacheReconciler) PlanResources(
	ctx context.Context,
	reconcileCtx controllerutils.ReconcileContext[*aimv1alpha1.AIMModelCache],
	obs ModelCacheObservation,
) controllerutils.PlanResult