stream

package

Go to main page

Versions in this module

v1

v1.1.1

Mar 17, 2026

v1.1.0

Mar 16, 2026

Changes in this version

+ type Backend string

+ const BatchJob

+ const CronJob

+ type BackendResource interface

+ CurrentConfiguration func() (string, error)

+ IsBackfill func() bool

+ IsCompleted func() bool

+ IsFailed func() bool

+ Name func() string

+ ToObject func() client.Object

+ UID func() types.UID

+ type BackendResourceManager interface

+ Apply func(ctx context.Context, definition Definition, ...) (reconcile.Result, error)

+ Get func(ctx context.Context, key client.ObjectKey) (BackendResource, error)

+ NoOp func(ctx context.Context, definition Definition, ...) (reconcile.Result, error)

+ Remove func(ctx context.Context, definition Definition, nextPhase Phase, ...) (reconcile.Result, error)

+ SetupWithController func(cache cache.Cache, scheme *runtime.Scheme, mapper meta.RESTMapper, ...) error

+ type BackfillBackendResourceManager interface

+ GetBackfillRequest func(ctx context.Context, definition Definition) (*v1.BackfillRequest, error)

+ type DefaultStatusManager struct

+ func NewDefaultStatusManager(client client.Client, gvk schema.GroupVersionKind, streamClass *v1.StreamClass, ...) *DefaultStatusManager

+ func (s *DefaultStatusManager) UpdateStreamPhase(ctx context.Context, definition Definition, ...) (reconcile.Result, error)

type Definition

+ GetBackend func() Backend

+ GetPreviousBackend func(ctx context.Context, client client.Client) (*Backend, error)

+ GetSchedule func() (string, error)

+ Validate func() error

+ type DefinitionParser func(*unstructured.Unstructured) (Definition, error)

type Phase

+ const Scheduled

+ type StatusManager interface

+ UpdateStreamPhase func(ctx context.Context, definition Definition, ...) (reconcile.Result, error)

v1.0.10

Feb 24, 2026

v1.0.9

Feb 13, 2026

Changes in this version

type Definition

+ func FromUnstructured(obj *unstructured.Unstructured) (Definition, error)

v1.0.8

Feb 12, 2026

Changes in this version

type Definition

+ func GetStreamForClass(ctx context.Context, client client.Client, sc *v1.StreamClass, ...) (Definition, error)

v1.0.7

Feb 12, 2026

v1.0.6

Feb 12, 2026

Changes in this version

+ func NewBackfillRequestFilter(streamClass string) predicate.TypedPredicate[*v1.BackfillRequest]

+ func NewJobFilter() predicate.TypedPredicate[*v1.Job]

+ func NewStreamControllerFactory(client client.Client, jobBuilder JobBuilder, manager manager.Manager, ...) stream_class.UnmanagedControllerFactory

+ func NewStreamMetadataService(streamClass *v1.StreamClass, streamDefinition Definition) job.ConfiguratorProvider

+ func NewStreamReconciler(client client.Client, gvk schema.GroupVersionKind, jobBuilder JobBuilder, ...) controllers.UnmanagedReconciler

+ type BackfillRequestFilter struct

+ func (j *BackfillRequestFilter) Create(e event.TypedCreateEvent[*v1.BackfillRequest]) bool

+ func (j *BackfillRequestFilter) Delete(e event.TypedDeleteEvent[*v1.BackfillRequest]) bool

+ func (j *BackfillRequestFilter) Generic(_ event.TypedGenericEvent[*v1.BackfillRequest]) bool

+ func (j *BackfillRequestFilter) Update(_ event.TypedUpdateEvent[*v1.BackfillRequest]) bool

+ type Definition interface

+ ComputeConditions func(bfr *v1.BackfillRequest) []metav1.Condition

+ CurrentConfiguration func(request *v1.BackfillRequest) (string, error)

+ GetJobTemplate func(request *v1.BackfillRequest) types.NamespacedName

+ GetPhase func() Phase

+ GetReferenceForSecret func(name string) (*corev1.LocalObjectReference, error)

+ LastAppliedConfiguration func() string

+ NamespacedName func() types.NamespacedName

+ RecomputeConfiguration func(request *v1.BackfillRequest) error

+ SetConditions func(conditions []metav1.Condition) error

+ SetPhase func(status Phase) error

+ SetSuspended func(suspended bool) error

+ StateString func() string

+ Suspended func() bool

+ ToConfiguratorProvider func() job.ConfiguratorProvider

+ ToOwnerReference func() metav1.OwnerReference

+ ToUnstructured func() *unstructured.Unstructured

+ type JobBuilder interface

+ BuildJob func(ctx context.Context, templateName types.NamespacedName, ...) (*batchv1.Job, error)

+ type JobFilter struct

+ func (j *JobFilter) Create(_ event.TypedCreateEvent[*v1.Job]) bool

+ func (j *JobFilter) Delete(_ event.TypedDeleteEvent[*v1.Job]) bool

+ func (j *JobFilter) Generic(_ event.TypedGenericEvent[*v1.Job]) bool

+ func (j *JobFilter) Update(e event.TypedUpdateEvent[*v1.Job]) bool

+ type Phase string

+ const Backfilling

+ const Failed

+ const New

+ const Pending

+ const Running

+ const Suspended

+ type StreamingJob v1.Job

+ func NewStreamingJobFromV1Job(job *v1.Job) StreamingJob

+ func (j StreamingJob) CurrentConfiguration() (string, error)

+ func (j StreamingJob) IsBackfill() bool

+ func (j StreamingJob) IsCompleted() bool

+ func (j StreamingJob) IsFailed() bool

+ func (j StreamingJob) ToV1Job() *v1.Job

+ type TypedSecondaryWatcher struct

+ func (w *TypedSecondaryWatcher[object]) SetupWithController(controller controller.Controller, obj object) error

+ type TypedSecondaryWatcherBuilder struct

+ func NewTypedSecondaryWatcherBuilder[object client.Object]() *TypedSecondaryWatcherBuilder[object]

+ func (b *TypedSecondaryWatcherBuilder[object]) Build() *TypedSecondaryWatcher[object]

+ func (b *TypedSecondaryWatcherBuilder[object]) WithCache(cache cache.Cache) *TypedSecondaryWatcherBuilder[object]

+ func (b *TypedSecondaryWatcherBuilder[object]) WithFilter(filter predicate.TypedPredicate[object]) *TypedSecondaryWatcherBuilder[object]

+ func (b *TypedSecondaryWatcherBuilder[object]) WithHandler(handler handler.TypedEventHandler[object, reconcile.Request]) *TypedSecondaryWatcherBuilder[object]

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL