v2

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchBackendApplyConfiguration 

type BatchBackendApplyConfiguration struct {
	// Schedule represents the cron schedule for batch processing.
	Schedule *string `json:"schedule,omitempty"`
	// JobTemplateRef represents a reference to the job template.
	JobTemplateRef *v1.ObjectReference `json:"jobTemplateRef,omitempty"`
}

BatchBackendApplyConfiguration represents a declarative configuration of the BatchBackend type for use with apply.

BatchBackend represents the backend configuration for batch processing, including the cron schedule and a reference to the job template.

func BatchBackend 

func BatchBackend() *BatchBackendApplyConfiguration

BatchBackendApplyConfiguration constructs a declarative configuration of the BatchBackend type for use with apply.

func (*BatchBackendApplyConfiguration) WithJobTemplateRef 

func (b *BatchBackendApplyConfiguration) WithJobTemplateRef(value v1.ObjectReference) *BatchBackendApplyConfiguration

WithJobTemplateRef sets the JobTemplateRef field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the JobTemplateRef field is set to the value of the last call.

func (*BatchBackendApplyConfiguration) WithSchedule 

func (b *BatchBackendApplyConfiguration) WithSchedule(value string) *BatchBackendApplyConfiguration

WithSchedule sets the Schedule field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Schedule field is set to the value of the last call.

type ExecutionSettingsApplyConfiguration 

type ExecutionSettingsApplyConfiguration struct {
	// APIVersion represents the API version of the execution settings.
	APIVersion *string `json:"apiVersion,omitempty"`
	// Suspended indicates whether the stream is suspended.
	Suspended *bool `json:"suspended,omitempty"`
	// BackfillJobTemplateRef represents a reference to the job template.
	BackfillJobTemplateRef *v1.ObjectReference `json:"backfillJobTemplateRef,omitempty"`
	// StreamingBackend represents the backend configuration for streaming.
	StreamingBackend *StreamingBackendApplyConfiguration `json:"streamingBackend,omitempty"`
}

ExecutionSettingsApplyConfiguration represents a declarative configuration of the ExecutionSettings type for use with apply.

ExecutionSettings represents the execution settings for a stream, including suspension status and backend configuration.

func ExecutionSettings 

func ExecutionSettings() *ExecutionSettingsApplyConfiguration

ExecutionSettingsApplyConfiguration constructs a declarative configuration of the ExecutionSettings type for use with apply.

func (*ExecutionSettingsApplyConfiguration) WithAPIVersion 

func (b *ExecutionSettingsApplyConfiguration) WithAPIVersion(value string) *ExecutionSettingsApplyConfiguration

WithAPIVersion sets the APIVersion field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the APIVersion field is set to the value of the last call.

func (*ExecutionSettingsApplyConfiguration) WithBackfillJobTemplateRef 

func (b *ExecutionSettingsApplyConfiguration) WithBackfillJobTemplateRef(value v1.ObjectReference) *ExecutionSettingsApplyConfiguration

WithBackfillJobTemplateRef sets the BackfillJobTemplateRef field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the BackfillJobTemplateRef field is set to the value of the last call.

func (*ExecutionSettingsApplyConfiguration) WithStreamingBackend 

func (b *ExecutionSettingsApplyConfiguration) WithStreamingBackend(value *StreamingBackendApplyConfiguration) *ExecutionSettingsApplyConfiguration

WithStreamingBackend sets the StreamingBackend field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the StreamingBackend field is set to the value of the last call.

func (*ExecutionSettingsApplyConfiguration) WithSuspended 

func (b *ExecutionSettingsApplyConfiguration) WithSuspended(value bool) *ExecutionSettingsApplyConfiguration

WithSuspended sets the Suspended field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Suspended field is set to the value of the last call.

type MockStreamDefinitionApplyConfiguration 

type MockStreamDefinitionApplyConfiguration struct {
	v1.TypeMetaApplyConfiguration    `json:",inline"`
	*v1.ObjectMetaApplyConfiguration `json:"metadata,omitempty"`
	Spec                             *MockStreamDefinitionSpecApplyConfiguration   `json:"spec,omitempty"`
	Status                           *MockStreamDefinitionStatusApplyConfiguration `json:"status,omitempty"`
}

MockStreamDefinitionApplyConfiguration represents a declarative configuration of the MockStreamDefinition type for use with apply.

MockStreamDefinition is a mock implementation of the StreamDefinition for testing purposes.

func MockStreamDefinition 

func MockStreamDefinition(name, namespace string) *MockStreamDefinitionApplyConfiguration

MockStreamDefinition constructs a declarative configuration of the MockStreamDefinition type for use with apply.

func (*MockStreamDefinitionApplyConfiguration) GetAPIVersion 

func (b *MockStreamDefinitionApplyConfiguration) GetAPIVersion() *string

GetAPIVersion retrieves the value of the APIVersion field in the declarative configuration.

func (*MockStreamDefinitionApplyConfiguration) GetKind 

func (b *MockStreamDefinitionApplyConfiguration) GetKind() *string

GetKind retrieves the value of the Kind field in the declarative configuration.

func (*MockStreamDefinitionApplyConfiguration) GetName 

func (b *MockStreamDefinitionApplyConfiguration) GetName() *string

GetName retrieves the value of the Name field in the declarative configuration.

func (*MockStreamDefinitionApplyConfiguration) GetNamespace 

func (b *MockStreamDefinitionApplyConfiguration) GetNamespace() *string

GetNamespace retrieves the value of the Namespace field in the declarative configuration.

func (MockStreamDefinitionApplyConfiguration) IsApplyConfiguration 

func (b MockStreamDefinitionApplyConfiguration) IsApplyConfiguration()

func (*MockStreamDefinitionApplyConfiguration) WithAPIVersion 

func (b *MockStreamDefinitionApplyConfiguration) WithAPIVersion(value string) *MockStreamDefinitionApplyConfiguration

WithAPIVersion sets the APIVersion field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the APIVersion field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithAnnotations 

func (b *MockStreamDefinitionApplyConfiguration) WithAnnotations(entries map[string]string) *MockStreamDefinitionApplyConfiguration

WithAnnotations puts the entries into the Annotations field in the declarative configuration and returns the receiver, so that objects can be build by chaining "With" function invocations. If called multiple times, the entries provided by each call will be put on the Annotations field, overwriting an existing map entries in Annotations field with the same key.

func (*MockStreamDefinitionApplyConfiguration) WithCreationTimestamp 

func (b *MockStreamDefinitionApplyConfiguration) WithCreationTimestamp(value metav1.Time) *MockStreamDefinitionApplyConfiguration

WithCreationTimestamp sets the CreationTimestamp field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the CreationTimestamp field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithDeletionGracePeriodSeconds 

func (b *MockStreamDefinitionApplyConfiguration) WithDeletionGracePeriodSeconds(value int64) *MockStreamDefinitionApplyConfiguration

WithDeletionGracePeriodSeconds sets the DeletionGracePeriodSeconds field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the DeletionGracePeriodSeconds field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithDeletionTimestamp 

func (b *MockStreamDefinitionApplyConfiguration) WithDeletionTimestamp(value metav1.Time) *MockStreamDefinitionApplyConfiguration

WithDeletionTimestamp sets the DeletionTimestamp field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the DeletionTimestamp field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithFinalizers 

func (b *MockStreamDefinitionApplyConfiguration) WithFinalizers(values ...string) *MockStreamDefinitionApplyConfiguration

WithFinalizers adds the given value to the Finalizers field in the declarative configuration and returns the receiver, so that objects can be build by chaining "With" function invocations. If called multiple times, values provided by each call will be appended to the Finalizers field.

func (*MockStreamDefinitionApplyConfiguration) WithGenerateName 

func (b *MockStreamDefinitionApplyConfiguration) WithGenerateName(value string) *MockStreamDefinitionApplyConfiguration

WithGenerateName sets the GenerateName field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the GenerateName field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithGeneration 

func (b *MockStreamDefinitionApplyConfiguration) WithGeneration(value int64) *MockStreamDefinitionApplyConfiguration

WithGeneration sets the Generation field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Generation field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithKind 

func (b *MockStreamDefinitionApplyConfiguration) WithKind(value string) *MockStreamDefinitionApplyConfiguration

WithKind sets the Kind field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Kind field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithLabels 

func (b *MockStreamDefinitionApplyConfiguration) WithLabels(entries map[string]string) *MockStreamDefinitionApplyConfiguration

WithLabels puts the entries into the Labels field in the declarative configuration and returns the receiver, so that objects can be build by chaining "With" function invocations. If called multiple times, the entries provided by each call will be put on the Labels field, overwriting an existing map entries in Labels field with the same key.

func (*MockStreamDefinitionApplyConfiguration) WithName 

func (b *MockStreamDefinitionApplyConfiguration) WithName(value string) *MockStreamDefinitionApplyConfiguration

WithName sets the Name field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Name field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithNamespace 

func (b *MockStreamDefinitionApplyConfiguration) WithNamespace(value string) *MockStreamDefinitionApplyConfiguration

WithNamespace sets the Namespace field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Namespace field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithOwnerReferences 

func (b *MockStreamDefinitionApplyConfiguration) WithOwnerReferences(values ...*v1.OwnerReferenceApplyConfiguration) *MockStreamDefinitionApplyConfiguration

WithOwnerReferences adds the given value to the OwnerReferences field in the declarative configuration and returns the receiver, so that objects can be build by chaining "With" function invocations. If called multiple times, values provided by each call will be appended to the OwnerReferences field.

func (*MockStreamDefinitionApplyConfiguration) WithResourceVersion 

func (b *MockStreamDefinitionApplyConfiguration) WithResourceVersion(value string) *MockStreamDefinitionApplyConfiguration

WithResourceVersion sets the ResourceVersion field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the ResourceVersion field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithSpec 

func (b *MockStreamDefinitionApplyConfiguration) WithSpec(value *MockStreamDefinitionSpecApplyConfiguration) *MockStreamDefinitionApplyConfiguration

WithSpec sets the Spec field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Spec field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithStatus 

func (b *MockStreamDefinitionApplyConfiguration) WithStatus(value *MockStreamDefinitionStatusApplyConfiguration) *MockStreamDefinitionApplyConfiguration

WithStatus sets the Status field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Status field is set to the value of the last call.

func (*MockStreamDefinitionApplyConfiguration) WithUID 

func (b *MockStreamDefinitionApplyConfiguration) WithUID(value types.UID) *MockStreamDefinitionApplyConfiguration

WithUID sets the UID field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the UID field is set to the value of the last call.

type MockStreamDefinitionSpecApplyConfiguration 

type MockStreamDefinitionSpecApplyConfiguration struct {
	// Execution represents the execution settings of the stream.
	ExecutionSettings *ExecutionSettingsApplyConfiguration `json:"execution,omitempty"`
	// Source represents the source of the stream.
	Source *string `json:"source,omitempty"`
	// Destination represents the destination of the stream.
	Destination *string `json:"destination,omitempty"`
	// SecretRef
	SecretRef *v1.LocalObjectReference `json:"secretRef,omitempty"`
}

MockStreamDefinitionSpecApplyConfiguration represents a declarative configuration of the MockStreamDefinitionSpec type for use with apply.

MockStreamDefinitionSpec is a mock implementation of the StreamDefinitionSpec for testing purposes.

func MockStreamDefinitionSpec 

func MockStreamDefinitionSpec() *MockStreamDefinitionSpecApplyConfiguration

MockStreamDefinitionSpecApplyConfiguration constructs a declarative configuration of the MockStreamDefinitionSpec type for use with apply.

func (*MockStreamDefinitionSpecApplyConfiguration) WithDestination 

func (b *MockStreamDefinitionSpecApplyConfiguration) WithDestination(value string) *MockStreamDefinitionSpecApplyConfiguration

WithDestination sets the Destination field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Destination field is set to the value of the last call.

func (*MockStreamDefinitionSpecApplyConfiguration) WithExecutionSettings 

func (b *MockStreamDefinitionSpecApplyConfiguration) WithExecutionSettings(value *ExecutionSettingsApplyConfiguration) *MockStreamDefinitionSpecApplyConfiguration

WithExecutionSettings sets the ExecutionSettings field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the ExecutionSettings field is set to the value of the last call.

func (*MockStreamDefinitionSpecApplyConfiguration) WithSecretRef 

func (b *MockStreamDefinitionSpecApplyConfiguration) WithSecretRef(value v1.LocalObjectReference) *MockStreamDefinitionSpecApplyConfiguration

WithSecretRef sets the SecretRef field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the SecretRef field is set to the value of the last call.

func (*MockStreamDefinitionSpecApplyConfiguration) WithSource 

func (b *MockStreamDefinitionSpecApplyConfiguration) WithSource(value string) *MockStreamDefinitionSpecApplyConfiguration

WithSource sets the Source field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Source field is set to the value of the last call.

type MockStreamDefinitionStatusApplyConfiguration 

type MockStreamDefinitionStatusApplyConfiguration struct {
	// Phase represents the current phase of the stream.
	Phase *string `json:"phase,omitempty"`
	// ConfigurationHash represents the hash of the current configuration.
	ConfigurationHash *string `json:"configurationHash,omitempty"`
}

MockStreamDefinitionStatusApplyConfiguration represents a declarative configuration of the MockStreamDefinitionStatus type for use with apply.

func MockStreamDefinitionStatus 

func MockStreamDefinitionStatus() *MockStreamDefinitionStatusApplyConfiguration

MockStreamDefinitionStatusApplyConfiguration constructs a declarative configuration of the MockStreamDefinitionStatus type for use with apply.

func (*MockStreamDefinitionStatusApplyConfiguration) WithConfigurationHash 

func (b *MockStreamDefinitionStatusApplyConfiguration) WithConfigurationHash(value string) *MockStreamDefinitionStatusApplyConfiguration

WithConfigurationHash sets the ConfigurationHash field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the ConfigurationHash field is set to the value of the last call.

func (*MockStreamDefinitionStatusApplyConfiguration) WithPhase 

func (b *MockStreamDefinitionStatusApplyConfiguration) WithPhase(value string) *MockStreamDefinitionStatusApplyConfiguration

WithPhase sets the Phase field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Phase field is set to the value of the last call.

type RealtimeBackendApplyConfiguration 

type RealtimeBackendApplyConfiguration struct {
	// ChangeCaptureInterval represents the interval at which changes are captured for real-time processing.
	ChangeCaptureInterval *string `json:"changeCaptureInterval,omitempty"`
	// JobTemplateRef represents a reference to the job template.
	JobTemplateRef *v1.ObjectReference `json:"jobTemplateRef,omitempty"`
}

RealtimeBackendApplyConfiguration represents a declarative configuration of the RealtimeBackend type for use with apply.

RealtimeBackend represents the backend configuration for real-time streaming, including the change capture interval and a reference to the job template.

func RealtimeBackend 

func RealtimeBackend() *RealtimeBackendApplyConfiguration

RealtimeBackendApplyConfiguration constructs a declarative configuration of the RealtimeBackend type for use with apply.

func (*RealtimeBackendApplyConfiguration) WithChangeCaptureInterval 

func (b *RealtimeBackendApplyConfiguration) WithChangeCaptureInterval(value string) *RealtimeBackendApplyConfiguration

WithChangeCaptureInterval sets the ChangeCaptureInterval field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the ChangeCaptureInterval field is set to the value of the last call.

func (*RealtimeBackendApplyConfiguration) WithJobTemplateRef 

func (b *RealtimeBackendApplyConfiguration) WithJobTemplateRef(value v1.ObjectReference) *RealtimeBackendApplyConfiguration

WithJobTemplateRef sets the JobTemplateRef field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the JobTemplateRef field is set to the value of the last call.

type StreamingBackendApplyConfiguration 

type StreamingBackendApplyConfiguration struct {
	// Realtime represents the backend configuration for real-time streaming.
	Realtime *RealtimeBackendApplyConfiguration `json:"realtime,omitempty"`
	// Batch represents the backend configuration for batch processing.
	Batch *BatchBackendApplyConfiguration `json:"batch,omitempty"`
}

StreamingBackendApplyConfiguration represents a declarative configuration of the StreamingBackend type for use with apply.

StreamingBackend represents the backend configuration for streaming, including both real-time and batch processing options.

func StreamingBackend 

func StreamingBackend() *StreamingBackendApplyConfiguration

StreamingBackendApplyConfiguration constructs a declarative configuration of the StreamingBackend type for use with apply.

func (*StreamingBackendApplyConfiguration) WithBatch 

func (b *StreamingBackendApplyConfiguration) WithBatch(value *BatchBackendApplyConfiguration) *StreamingBackendApplyConfiguration

WithBatch sets the Batch field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Batch field is set to the value of the last call.

func (*StreamingBackendApplyConfiguration) WithRealtime 

func (b *StreamingBackendApplyConfiguration) WithRealtime(value *RealtimeBackendApplyConfiguration) *StreamingBackendApplyConfiguration

WithRealtime sets the Realtime field in the declarative configuration to the given value and returns the receiver, so that objects can be built by chaining "With" function invocations. If called multiple times, the Realtime field is set to the value of the last call.

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.