controller

May 5, 2026

Changes in this version

+ const TraceparentAnnotation

+ const TracestateAnnotation

type PipelineInstanceReconciler

+ TelemetryExporterOTLPEndpoint string

+ TelemetryExporterType string

Apr 3, 2026

Changes in this version

+ const FinalizerStreamingCleanup

Apr 2, 2026

Changes in this version

type PipelineInstanceReconciler

+ GPUBinPath string

+ GPULibraryPath string

Mar 31, 2026

Changes in this version

+ const DefaultValkeyNSSecretName

+ const FinalizerValkeyCredentials

type PipelineInstanceReconciler

+ ValkeyNSSecretName string

type ValkeyClientInterface

+ DeleteACLUser func(ctx context.Context, username string) error

+ EnsureACLUser func(ctx context.Context, username, password, namespace string) error

Mar 30, 2026

Changes in this version

type PipelineInstanceReconciler

+ GPUNodeSelectorLabels map[string]string

+ ValkeyPasswordSecret string

+ ValkeyPasswordSecretKey string

Mar 17, 2026

Changes in this version

type ValkeyClientInterface

+ ClaimMessages func(ctx context.Context, streamKey, groupName, consumerName string, ...) ([]queue.XMessage, error)

+ GetPendingEntryDetails func(ctx context.Context, streamKey, groupName string, minIdleTime int64, ...) ([]queue.PendingEntry, error)

Jan 8, 2026

Changes in this version

+ type PipelineInstanceReconciler struct

+ ClaimerImage string

+ Scheme *runtime.Scheme

+ ValkeyAddr string

+ ValkeyClient ValkeyClientInterface

+ ValkeyPassword string

+ func (r *PipelineInstanceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *PipelineInstanceReconciler) SetupWithManager(mgr ctrl.Manager) error

Oct 30, 2025

Changes in this version

+ const AnnotationAttempts

+ const AnnotationFile

+ const AnnotationMessageID

+ const AnnotationValueTrue

+ const ConditionTypeDegraded

+ const ConditionTypeProgressing

+ const ConditionTypeSucceeded

+ const DefaultVideoInputPath

+ const StatusUpdateInterval

+ type PipelineReconciler struct

+ Scheme *runtime.Scheme

+ func (r *PipelineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *PipelineReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type PipelineRunReconciler struct

+ ClaimerImage string

+ Scheme *runtime.Scheme

+ ValkeyAddr string

+ ValkeyClient ValkeyClientInterface

+ ValkeyPassword string

+ func (r *PipelineRunReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *PipelineRunReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type ValkeyClientInterface interface

+ AckMessage func(ctx context.Context, streamKey, groupName, messageID string) error

+ AddToDLQ func(ctx context.Context, dlqKey, runID, filepath string, attempts int, ...) error

+ AutoClaim func(ctx context.Context, streamKey, groupName, consumerName string, ...) ([]queue.XMessage, error)

+ CreateStreamAndGroup func(ctx context.Context, streamKey, groupName string) error

+ DeleteMessages func(ctx context.Context, streamKey string, messageIDs ...string) error

+ EnqueueFileWithAttempts func(ctx context.Context, streamKey, runID, filepath string, attempts int) (string, error)

+ GetConsumerGroupLag func(ctx context.Context, streamKey, groupName string) (int64, error)

+ GetPendingCount func(ctx context.Context, streamKey, groupName string) (int64, error)

+ GetPendingForConsumer func(ctx context.Context, streamKey, groupName, consumer string, count int64) ([]string, error)

+ GetStreamLength func(ctx context.Context, streamKey string) (int64, error)

+ ReadRange func(ctx context.Context, streamKey, start, end string, count int64) ([]queue.XMessage, error)