backends

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KVCacheAnnotationRDMAPort         = "hpkv.kvcache.orchestration.aibrix.ai/rdma-port"
	KVCacheAnnotationAdminPort        = "hpkv.kvcache.orchestration.aibrix.ai/admin-port"
	KVCacheAnnotationBlockSize        = "hpkv.kvcache.orchestration.aibrix.ai/block-size-bytes"
	KVCacheAnnotationBlockCount       = "hpkv.kvcache.orchestration.aibrix.ai/block-count"
	KVCacheAnnotationTotalSlots       = "hpkv.kvcache.orchestration.aibrix.ai/total-slots"
	KVCacheAnnotationVirtualNodeCount = "hpkv.kvcache.orchestration.aibrix.ai/virtual-node-count"
)
View Source 
const (
	KVCacheAnnotationLinkType     = "infinistore.kvcache.orchestration.aibrix.ai/link-type"
	KVCacheAnnotationHintGidIndex = "infinistore.kvcache.orchestration.aibrix.ai/hint-gid-index"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BackendReconciler 

type BackendReconciler interface {
	Reconcile(ctx context.Context, kv *orchestrationv1alpha1.KVCache) (reconcile.Result, error)
}

type BaseReconciler 

type BaseReconciler struct {
	client.Client
}

func (*BaseReconciler) ReconcileDeploymentObject 

func (r *BaseReconciler) ReconcileDeploymentObject(ctx context.Context, desired *appsv1.Deployment) error

func (*BaseReconciler) ReconcilePodObject 

func (r *BaseReconciler) ReconcilePodObject(ctx context.Context, desired *corev1.Pod) error

func (*BaseReconciler) ReconcileServiceObject 

func (r *BaseReconciler) ReconcileServiceObject(ctx context.Context, service *corev1.Service) error

func (*BaseReconciler) ReconcileStatefulsetObject 

func (r *BaseReconciler) ReconcileStatefulsetObject(ctx context.Context, sts *appsv1.StatefulSet) error

type DistributedReconciler 

type DistributedReconciler struct {
	client.Client
	*BaseReconciler
	Backend KVCacheBackend
}

func NewDistributedReconciler 

func NewDistributedReconciler(c client.Client, backend string) *DistributedReconciler

func (*DistributedReconciler) Reconcile 

func (r *DistributedReconciler) Reconcile(ctx context.Context, kvCache *orchestrationv1alpha1.KVCache) (ctrl.Result, error)

type HpKVBackend 

type HpKVBackend struct{}

func (HpKVBackend) BuildCacheStatefulSet 

func (HpKVBackend) BuildCacheStatefulSet(kvCache *orchestrationv1alpha1.KVCache) *appsv1.StatefulSet

func (HpKVBackend) BuildMetadataPod 

func (b HpKVBackend) BuildMetadataPod(kvCache *orchestrationv1alpha1.KVCache) *corev1.Pod

func (HpKVBackend) BuildMetadataService 

func (b HpKVBackend) BuildMetadataService(kvCache *orchestrationv1alpha1.KVCache) *corev1.Service

func (HpKVBackend) BuildService 

func (HpKVBackend) BuildService(kvCache *orchestrationv1alpha1.KVCache) *corev1.Service

func (HpKVBackend) BuildWatcherPod 

func (HpKVBackend) BuildWatcherPod(kvCache *orchestrationv1alpha1.KVCache) *corev1.Pod

func (HpKVBackend) BuildWatcherPodRole 

func (b HpKVBackend) BuildWatcherPodRole(kvCache *orchestrationv1alpha1.KVCache) *rbacv1.Role

func (HpKVBackend) BuildWatcherPodRoleBinding 

func (b HpKVBackend) BuildWatcherPodRoleBinding(kvCache *orchestrationv1alpha1.KVCache) *rbacv1.RoleBinding

func (HpKVBackend) BuildWatcherPodServiceAccount 

func (b HpKVBackend) BuildWatcherPodServiceAccount(kvCache *orchestrationv1alpha1.KVCache) *corev1.ServiceAccount

func (HpKVBackend) Name 

func (HpKVBackend) Name() string

func (HpKVBackend) ValidateObject 

func (HpKVBackend) ValidateObject(kvCache *orchestrationv1alpha1.KVCache) error

type HpKVClusterParams 

type HpKVClusterParams struct {
	RdmaPort         int
	AdminPort        int
	BlockSizeInBytes int
	BlockCount       int
	TotalSlots       int
	VirtualNodeCount int
}

type InfiniStoreBackend 

type InfiniStoreBackend struct{}

func (InfiniStoreBackend) BuildCacheStatefulSet 

func (InfiniStoreBackend) BuildCacheStatefulSet(kvCache *orchestrationv1alpha1.KVCache) *appsv1.StatefulSet

func (InfiniStoreBackend) BuildMetadataPod 

func (b InfiniStoreBackend) BuildMetadataPod(kvCache *orchestrationv1alpha1.KVCache) *corev1.Pod

func (InfiniStoreBackend) BuildMetadataService 

func (b InfiniStoreBackend) BuildMetadataService(kvCache *orchestrationv1alpha1.KVCache) *corev1.Service

func (InfiniStoreBackend) BuildService 

func (InfiniStoreBackend) BuildService(kvCache *orchestrationv1alpha1.KVCache) *corev1.Service

func (InfiniStoreBackend) BuildWatcherPod 

func (InfiniStoreBackend) BuildWatcherPod(kvCache *orchestrationv1alpha1.KVCache) *corev1.Pod

func (InfiniStoreBackend) BuildWatcherPodRole 

func (b InfiniStoreBackend) BuildWatcherPodRole(kvCache *orchestrationv1alpha1.KVCache) *rbacv1.Role

func (InfiniStoreBackend) BuildWatcherPodRoleBinding 

func (b InfiniStoreBackend) BuildWatcherPodRoleBinding(kvCache *orchestrationv1alpha1.KVCache) *rbacv1.RoleBinding

func (InfiniStoreBackend) BuildWatcherPodServiceAccount 

func (b InfiniStoreBackend) BuildWatcherPodServiceAccount(kvCache *orchestrationv1alpha1.KVCache) *corev1.ServiceAccount

func (InfiniStoreBackend) Name 

func (InfiniStoreBackend) Name() string

func (InfiniStoreBackend) ValidateObject 

func (InfiniStoreBackend) ValidateObject(kvCache *orchestrationv1alpha1.KVCache) error

type InfiniStoreParams 

type InfiniStoreParams struct {
	RdmaPort         int
	AdminPort        int
	LinkType         string
	TotalSlots       int
	VirtualNodeCount int
	HintGIDIndex     int
}

type KVCacheBackend 

type KVCacheBackend interface {
	Name() string
	ValidateObject(*orchestrationv1alpha1.KVCache) error
	BuildMetadataPod(*orchestrationv1alpha1.KVCache) *corev1.Pod
	BuildMetadataService(*orchestrationv1alpha1.KVCache) *corev1.Service
	BuildWatcherPodServiceAccount(*orchestrationv1alpha1.KVCache) *corev1.ServiceAccount
	BuildWatcherPodRole(*orchestrationv1alpha1.KVCache) *rbacv1.Role
	BuildWatcherPodRoleBinding(*orchestrationv1alpha1.KVCache) *rbacv1.RoleBinding
	BuildWatcherPod(*orchestrationv1alpha1.KVCache) *corev1.Pod
	BuildCacheStatefulSet(*orchestrationv1alpha1.KVCache) *appsv1.StatefulSet
	BuildService(*orchestrationv1alpha1.KVCache) *corev1.Service
}

type VineyardReconciler 

type VineyardReconciler struct {
	*BaseReconciler
}

func NewVineyardReconciler 

func NewVineyardReconciler(c client.Client) *VineyardReconciler

func (VineyardReconciler) Reconcile 

func (r VineyardReconciler) Reconcile(ctx context.Context, kvCache *orchestrationv1alpha1.KVCache) (reconcile.Result, 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.