job

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromResource 

func FromResource(job client.Object) (stream.BackendResource, error)

func NewBackfillRequestFilter 

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

func NewPredicate 

func NewPredicate() predicate.TypedPredicate[*v1.Job]

Types

type Backend 

type Backend struct {
	backend.BaseResourceManager
	backend.ResourceReader
	// contains filtered or unexported fields
}

func NewJobBackend 

func NewJobBackend(client client.Client, jobBuilder stream.JobBuilder, eventRecorder record.EventRecorder, phaseManager stream.StatusManager) *Backend

func (*Backend) Apply 

func (j *Backend) Apply(ctx context.Context, definition stream.Definition, backfillRequest *v1.BackfillRequest, nextPhase stream.Phase, streamClass *v1.StreamClass, eventFunc controllers.EventFunc) (reconcile.Result, error)

func (*Backend) Get 

func (j *Backend) Get(ctx context.Context, name types.NamespacedName) (stream.BackendResource, error)

func (*Backend) NoOp 

func (j *Backend) NoOp(ctx context.Context, definition stream.Definition, backfillRequest *v1.BackfillRequest, nextPhase stream.Phase, eventFunc controllers.EventFunc) (reconcile.Result, error)

func (*Backend) Remove 

func (j *Backend) Remove(ctx context.Context, definition stream.Definition, nextPhase stream.Phase, eventFunc controllers.EventFunc) (reconcile.Result, error)

func (*Backend) SetupWithController 

func (j *Backend) SetupWithController(cache cache.Cache, scheme *runtime.Scheme, mapper meta.RESTMapper, controller controller.Controller, primaryGvk schema.GroupVersionKind) error

type BackendResource 

type BackendResource struct {
	*v1.Job
}

func (*BackendResource) CurrentConfiguration 

func (j *BackendResource) CurrentConfiguration() (string, error)

func (*BackendResource) IsBackfill 

func (j *BackendResource) IsBackfill() bool

func (*BackendResource) IsCompleted 

func (j *BackendResource) IsCompleted() bool

func (*BackendResource) IsFailed 

func (j *BackendResource) IsFailed() bool

func (*BackendResource) Name 

func (j *BackendResource) Name() string

func (*BackendResource) ToObject 

func (j *BackendResource) ToObject() client.Object

func (*BackendResource) UID 

func (j *BackendResource) UID() types.UID

type BackfillBackend 

type BackfillBackend struct {
	backend.BaseResourceManager
	// contains filtered or unexported fields
}

func NewBackfillBackendResourceManager 

func NewBackfillBackendResourceManager(class *v1.StreamClass, client client.Client, manager stream.StatusManager, eventRecorder record.EventRecorder) *BackfillBackend

func (*BackfillBackend) Apply 

func (b *BackfillBackend) Apply(ctx context.Context, definition stream.Definition, backfillRequest *v1.BackfillRequest, nextPhase stream.Phase, _ *v1.StreamClass, eventFunc controllers.EventFunc) (reconcile.Result, error)

func (*BackfillBackend) Get 

func (b *BackfillBackend) Get(ctx context.Context, name types.NamespacedName) (stream.BackendResource, error)

func (*BackfillBackend) GetBackfillRequest 

func (b *BackfillBackend) GetBackfillRequest(ctx context.Context, definition stream.Definition) (*v1.BackfillRequest, error)

func (*BackfillBackend) NoOp 

func (b *BackfillBackend) NoOp(ctx context.Context, definition stream.Definition, backfillRequest *v1.BackfillRequest, nextPhase stream.Phase, eventFunc controllers.EventFunc) (reconcile.Result, error)

func (*BackfillBackend) Remove 

func (b *BackfillBackend) Remove(ctx context.Context, definition stream.Definition, nextPhase stream.Phase, eventFunc controllers.EventFunc) (reconcile.Result, error)

func (*BackfillBackend) SetupWithController 

func (b *BackfillBackend) SetupWithController(cache cache.Cache, _ *runtime.Scheme, _ meta.RESTMapper, controller controller.Controller, _ schema.GroupVersionKind) error

type BackfillRequestFilter 

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

func (*BackfillRequestFilter) Create 

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

Create filters BackfillRequests that are not completed and match the specified stream class.

func (*BackfillRequestFilter) Delete 

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

Delete filters BackfillRequests that are not completed and match the specified stream class.

func (*BackfillRequestFilter) Generic 

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

Generic always returns false to ignore generic events.

func (*BackfillRequestFilter) Update 

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

Update always returns false to ignore update events.

type Predicate 

type Predicate struct {
	backend.SecondaryResourcePredicate[*v1.Job]
}

Predicate is a predicate that allows job events to pass through to the Stream controller.

func (*Predicate) Update 

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

Update is called when an object is updated.

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.