Package v1alpha1 contains API Schema definitions for the k8s.raptor.ml v1alpha1 API group +kubebuilder:object:generate=true +groupName=k8s.raptor.ml.

AliveWindowBuckets returns a list of all the *valid* buckets up until now.

BucketDeadTime returns the end time of a given bucket by its name.

BucketName returns a bucket name for a given timestamp and a bucket size.

BucketTime returns the start time of a given bucket by its name.

DataSourceFromManifest returns a DataSource from a manifests.DataSource.

DeadWindowBuckets returns a list of bucket names of *dead* bucket (bucket that is outside the window) that should be available.

FeatureDescriptorFromManifest returns a FeatureDescriptor from a manifests.Feature.

LoggerFromContext returns the logger from the context.

NormalizeFQN returns an FQN with the namespace.

NormalizeSelector returns a selector with the default namespace if not specified.

ToLowLevelValue returns the low level value of the feature.

TypeDetect detects the PrimitiveType of the value.

ContextKeyCacheFresh is a key to store the flag that indicate if the result from the cache was fresh.

ContextKeyCachePostGet is a key to store the flag to cache in the storage postGet value.

ContextKeyFromCache is a key to store the flag to indicate if the value is from the cache.

ContextKeyLogger is a key to store a logger.

ContextKeySelector is a key to store the requested Feature Selector.

DeadGracePeriod is the *extra* time that the bucket should be kept alive on top of the feature's Staleness.

ErrFeatureAlreadyExists is returned when a feature is already registered in the Core's engine manager.

ErrFeatureNotFound is returned when a feature is not found in the Core's engine manager.

ErrInvalidPipelineContext is returned when the context is invalid for pipelining.

ErrUnsupportedAggrError is returned when an aggregate function is not supported.

ErrUnsupportedPrimitiveError is returned when a primitive is not supported.

DataSource is a parsed abstracted representation of a manifests.DataSource.

DataSourceReconcileRequest contains metadata for the reconcile.

FeatureDescriptor is describing a feature definition for an internal use of the Core.

ModelReconcileRequest contains metadata for the reconcile.

RawBucket is the data that is stored in the raw bucket.

Value is storing a feature value.

DataSourceGetter is a simple interface that returns a DataSource.

DataSourceManager is managing DataSource(s) within Core It is responsible for maintaining the DataSource(s) in an internal store.

Engine is the main engine of the Core It is responsible for the low-level operation for the features against the feature store.

ExtendedManager is an Engine that has a DataSource.

FeatureManager is managing Feature(s) within Core It is responsible for managing features as well as operating on them.

Logger is a simple interface that returns a Logr.Logger.

LowLevelValue is a low level value that can be cast to any type.

ManagerEngine is the business-logic implementation of the Core.

ModelServer is the interface to be implemented by plugins that implements a Model Server.

Notifier is the interface to be implemented by plugins that want to provide a Queue implementation The Queue is used to sync notifications between instances.

Pipeliner is the interface that plugins can use to modify the Core's feature pipelines on creation time.

State is a feature state management layer.

AggrFn is an aggregation function.

BindConfig adds config flags for the plugin.

ContextKey is a key to store data in context.

DataSourceReconcile is the interface to be implemented by plugins that want to be reconciled in the operator.

FeatureApply applies changes on the feature abstraction.

NotifierFactory is the interface to be implemented by plugins that implements Notifier.

StateFactory is the interface to be implemented by plugins that implements storage providers.

StateMethod is a method that can be used with a State.

WindowResultMap is a map of AggrFn and their aggregated results.