v1

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: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchJobBackendSettings

type BatchJobBackendSettings struct {
	JobTemplateRef corev1.ObjectReference `json:"jobTemplateRef"`
}

type CronJobBackendSettings

type CronJobBackendSettings struct {
	Schedule       string                 `json:"schedule"`
	JobTemplateRef corev1.ObjectReference `json:"jobTemplateRef"`
}

type ExecutionSettings

type ExecutionSettings struct {
	Suspended              bool                     `json:"suspended"`
	APIVersion             string                   `json:"apiVersion"`
	BackfillJobTemplateRef *corev1.ObjectReference  `json:"backfillJobTemplateRef,omitempty"`
	StreamingBackend       StreamingBackendSettings `json:"streamingBackend"`
}

type ExecutionSettingsWrapper

type ExecutionSettingsWrapper struct {
	common.SecretReferenceReader
	*status_v0.StatusWrapper
	*common.ConfiguratorProvider
	*common.OwnerReferenceProvider
	Underlying *unstructured.Unstructured
	// contains filtered or unexported fields
}

func (*ExecutionSettingsWrapper) GetBackend

func (e *ExecutionSettingsWrapper) GetBackend() stream.Backend

func (*ExecutionSettingsWrapper) GetJobTemplate

func (e *ExecutionSettingsWrapper) GetJobTemplate(request *v1.BackfillRequest) types.NamespacedName

func (*ExecutionSettingsWrapper) GetPreviousBackend

func (e *ExecutionSettingsWrapper) GetPreviousBackend(ctx context.Context, c client.Client) (*stream.Backend, error)

func (*ExecutionSettingsWrapper) GetSchedule

func (e *ExecutionSettingsWrapper) GetSchedule() (string, error)

func (*ExecutionSettingsWrapper) NamespacedName

func (e *ExecutionSettingsWrapper) NamespacedName() types.NamespacedName

func (*ExecutionSettingsWrapper) SetSuspended

func (e *ExecutionSettingsWrapper) SetSuspended(suspended bool) error

func (*ExecutionSettingsWrapper) StateString

func (e *ExecutionSettingsWrapper) StateString() string

func (*ExecutionSettingsWrapper) Suspended

func (e *ExecutionSettingsWrapper) Suspended() bool

func (*ExecutionSettingsWrapper) ToUnstructured

func (e *ExecutionSettingsWrapper) ToUnstructured() *unstructured.Unstructured

func (*ExecutionSettingsWrapper) Validate

func (e *ExecutionSettingsWrapper) Validate() error

type StreamingBackendSettings

type StreamingBackendSettings struct {
	BatchJobBackend *BatchJobBackendSettings `json:"changeCapture,omitempty"`
	CronJobBackend  *CronJobBackendSettings  `json:"batch,omitempty"`
}

Jump to

Keyboard shortcuts

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