v1

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

	Spec   BackfillRequestSpec   `json:"spec,omitempty"`
	Status BackfillRequestStatus `json:"status,omitempty"`
}

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

type BackfillRequestSpec struct {
	// StreamClass is the name of the stream class to backfill
	StreamClass string `json:"streamClass"`

	// StreamId is the ID of the stream to backfill
	StreamId string `json:"streamId"`

	// Completed indicates whether the backfill request has been completed
	// +kubebuilder:default=false
	Completed bool `json:"completed,omitempty"`

	// Payload is an unstructured JSON object with arbitrary nesting. This is used to generate the
	// `STREAMCONTEXT_OVERRIDE` environment variable for the backfill job. The payload is optional and can be nil.
	//+kubebuilder:validation:Type=object
	//+kubebuilder:validation:XPreserveUnknownFields
	//+kubebuilder:validation:Optional
	//+nullable
	Payload *runtime.RawExtension `json:"payload,omitempty"`
}

type BackfillRequestStatus struct {
	// Phase represents the current phase of the backfill request
	Phase Phase `json:"phase,omitempty"`

	// Conditions represent the latest available observations
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type Phase string

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

	Spec   StreamClassSpec   `json:"spec,omitempty"`
	Status StreamClassStatus `json:"status,omitempty"`
}

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

type StreamClassSpec struct {

	// APIGroupRef is the api group of the stream class to watch for
	APIGroupRef string `json:"apiGroupRef,omitempty"`

	// APIVersion is the API version of the stream class to watch for
	APIVersion string `json:"apiVersion"`

	// KindRef is the kind of the stream class to watch for
	KindRef string `json:"kindRef"`

	// PluralName is the plural name of the stream class to watch for
	PluralName string `json:"pluralName"`

	// SecretRefs is a list of fields to be extracted from the secret
	SecretRefs []string `json:"secretRefs,omitempty"`

	// OverridableFields is a nullable list of fields that can be overridden by stream definitions
	//+nullable
	OverridableFields []string `json:"overridableFields,omitempty"`
}

type StreamClassStatus struct {
	// Phase represents the current phase of the stream class
	Phase Phase `json:"phase,omitempty"`

	// Conditions represent the latest available observations
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

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

	Spec batchv1.Job `json:"spec,omitempty"`
}

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