backend

package

v1.1.1 Latest Latest Go to latest Published: Mar 17, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/SneaksAndData/arcane-operator

Links

Open Source Insights

Documentation ¶

Index ¶

type BaseResourceManager
- func (j *BaseResourceManager) BuildJob(ctx context.Context, definition stream.Definition, request *v1.BackfillRequest, ...) (*batchv1.Job, error)
- func (j *BaseResourceManager) Remove(ctx context.Context, object client.Object, ...) (reconcile.Result, error)
type ResourceConverter
type ResourceReader
- func (j *ResourceReader) CompareConfigurations(ctx context.Context, object client.Object, definition stream.Definition, ...) (bool, error)
- func (c *ResourceReader) Get(ctx context.Context, name client.ObjectKey, object client.Object, ...) (stream.BackendResource, error)
type SecondaryResourcePredicate

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BaseResourceManager ¶

type BaseResourceManager struct {
	Client        client.Client
	JobBuilder    stream.JobBuilder
	EventRecorder record.EventRecorder
}

func (*BaseResourceManager) BuildJob ¶

func (j *BaseResourceManager) BuildJob(ctx context.Context, definition stream.Definition, request *v1.BackfillRequest, streamClass *v1.StreamClass) (*batchv1.Job, error)

func (*BaseResourceManager) Remove ¶

func (j *BaseResourceManager) Remove(ctx context.Context, object client.Object, updatePhase func() (reconcile.Result, error)) (reconcile.Result, error)

type ResourceConverter ¶

type ResourceConverter func(object client.Object) (stream.BackendResource, error)

type ResourceReader ¶

type ResourceReader struct {
	Client client.Client
}

func (*ResourceReader) CompareConfigurations ¶

func (j *ResourceReader) CompareConfigurations(ctx context.Context, object client.Object, definition stream.Definition, fromObject ResourceConverter) (bool, error)

func (*ResourceReader) Get ¶

func (c *ResourceReader) Get(ctx context.Context, name client.ObjectKey, object client.Object, fromObject ResourceConverter) (stream.BackendResource, error)

type SecondaryResourcePredicate ¶

type SecondaryResourcePredicate[object any] struct{}

func (*SecondaryResourcePredicate[object]) Create ¶

func (b *SecondaryResourcePredicate[object]) Create(_ event.TypedCreateEvent[object]) bool

func (*SecondaryResourcePredicate[object]) Delete ¶

func (b *SecondaryResourcePredicate[object]) Delete(_ event.TypedDeleteEvent[object]) bool

func (*SecondaryResourcePredicate[object]) Generic ¶

func (b *SecondaryResourcePredicate[object]) Generic(_ event.TypedGenericEvent[object]) bool

func (*SecondaryResourcePredicate[object]) Update ¶

func (b *SecondaryResourcePredicate[object]) Update(_ event.TypedUpdateEvent[object]) bool

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cron_job
job

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