Help us shape the future of Go! Take the 2026 Go Developer Survey

v1

package
v1.1.15 Latest Latest
Warning

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

Go to latest
Published: Oct 20, 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"`
	LayoutVersion          string                   `json:"layoutVersion"`
	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