v2

type BatchJobBackend struct {
	// ChangeCaptureInterval represents the interval at which changes are captured for real-time processing.
	ChangeCaptureInterval string `json:"changeCaptureInterval"`

	// JobTemplateRef represents a reference to the job template.
	JobTemplateRef v1.ObjectReference `json:"jobTemplateRef"`
}

type CronJobBackend struct {

	// Schedule represents the cron schedule for batch processing.
	Schedule string `json:"schedule"`

	// JobTemplateRef represents a reference to the job template.
	JobTemplateRef v1.ObjectReference `json:"jobTemplateRef"`
}

type ExecutionSettings struct {
	// APIVersion represents the API version of the execution settings.
	APIVersion string `json:"apiVersion"`

	// Suspended indicates whether the stream is suspended.
	Suspended bool `json:"suspended"`

	// BackfillJobTemplateRef represents a reference to the job template.
	BackfillJobTemplateRef v1.ObjectReference `json:"backfillJobTemplateRef"`

	// StreamingBackend represents the backend configuration for streaming.
	StreamingBackend StreamingBackend `json:"streamingBackend"`
}

type MockStreamDefinition struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   MockStreamDefinitionSpec   `json:"spec,omitempty"`
	Status MockStreamDefinitionStatus `json:"status,omitempty"`
}

type MockStreamDefinitionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []MockStreamDefinition `json:"items"`
}

type MockStreamDefinitionSpec struct {

	// Execution represents the execution settings of the stream.
	ExecutionSettings ExecutionSettings `json:"execution"`

	// Source represents the source of the stream.
	Source string `json:"source"`

	// Destination represents the destination of the stream.
	Destination string `json:"destination"`

	// SecretRef
	SecretRef v1.LocalObjectReference `json:"secretRef,omitempty"`
}

type MockStreamDefinitionStatus struct {
	// Phase represents the current phase of the stream.
	Phase string `json:"phase"`

	// ConfigurationHash represents the hash of the current configuration.
	ConfigurationHash string `json:"configurationHash"`
}

type StreamingBackend struct {
	// BatchJobBackend represents the backend configuration for real-time streaming.
	BatchJobBackend *BatchJobBackend `json:"changeCapture,omitempty"`

	// CronJobBackend represents the backend configuration for batch processing.
	CronJobBackend *CronJobBackend `json:"batch,omitempty"`
}