kafka_nais_io_v1

type Config struct {
	// CleanupPolicy is either "delete" or "compact" or both.
	// This designates the retention policy to use on old log segments.
	// +nais:doc:Default="delete"
	// +nais:doc:Link="https://kafka.apache.org/33/documentation.html#topicconfigs_cleanup.policy"
	// +kubebuilder:validation:Enum=delete;compact;"compact,delete"
	CleanupPolicy *string `json:"cleanupPolicy,omitempty"`

	// When a producer sets acks to "all" (or "-1"), `min.insync.replicas` specifies the minimum number of replicas
	// that must acknowledge a write for the write to be considered successful.
	// +nais:doc:Default="2"
	// +nais:doc:Link="https://kafka.apache.org/33/documentation.html#topicconfigs_min.insync.replicas"
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=7
	MinimumInSyncReplicas *int `json:"minimumInSyncReplicas,omitempty"`

	// The default number of log partitions per topic.
	// +nais:doc:Default="1"
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=1000000
	Partitions *int `json:"partitions,omitempty"`

	// The default replication factor for created topics.
	// +nais:doc:Default="3"
	// +nais:doc:Link="https://kafka.apache.org/33/documentation.html#replication"
	// +kubebuilder:validation:Minimum=2
	Replication *int `json:"replication,omitempty"`

	// Configuration controls the maximum size a partition can grow to before we will discard old log segments
	// to free up space if we are using the "delete" retention policy. By default there is no size limit only a time limit.
	// Since this limit is enforced at the partition level, multiply it by the number of partitions to compute the topic retention in bytes.
	// +nais:doc:Default="-1"
	// +nais:doc:Link="https://kafka.apache.org/33/documentation.html#topicconfigs_retention.bytes"
	RetentionBytes *int `json:"retentionBytes,omitempty"`

	// The number of hours to keep a log file before deleting it.
	// +nais:doc:Default="168"
	// +nais:doc:Link="https://kafka.apache.org/33/documentation.html#topicconfigs_retention.ms"
	// +kubebuilder:validation:Maximum=2562047788015
	RetentionHours *int `json:"retentionHours,omitempty"`

	// The number of hours after which Kafka will force the log to roll even if the segment file isn't full to ensure
	// that retention can delete or compact old data.
	// +nais:doc:Default="168"
	// +nais:doc:Link="https://kafka.apache.org/33/documentation.html#topicconfigs_segment.ms"
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=8760
	SegmentHours *int `json:"segmentHours,omitempty"`

	// The largest record batch size allowed by Kafka (after compression if compression is enabled).
	// If this is increased and there are consumers older than 0.10.2, the consumers' fetch size must also be increased
	// so that they can fetch record batches this large. In the latest message format version, records are always grouped
	// into batches for efficiency. In previous message format versions, uncompressed records are not grouped into
	// batches and this limit only applies to a single record in that case.
	// +nais:doc:Default="1048588"
	// +nais:doc:Link="https://kafka.apache.org/33/documentation.html#topicconfigs_max.message.bytes"
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:validation:Maximum=5242880
	MaxMessageBytes *int `json:"maxMessageBytes,omitempty"`

	// MinCompactionLagMs indicates the minimum time a message will remain uncompacted in the log
	// +nais:doc:Default="0"
	// +nais:doc:Link="https://kafka.apache.org/33/documentation.html#topicconfigs_min.compaction.lag.ms"
	// +kubebuilder:validation:Minimum=0
	MinCompactionLagMs *int `json:"minCompactionLagMs,omitempty"`

	// MaxCompactionLagMs indicates the maximum time a message will remain ineligible for compaction in the log
	// +nais:doc:Default="Inf"
	// +nais:doc:Link="https://kafka.apache.org/33/documentation.html#topicconfigs_max.compaction.lag.ms"
	// +kubebuilder:validation:Minimum=0
	MaxCompactionLagMs *int `json:"maxCompactionLagMs,omitempty"`

	// MinCleanableDirtyRatio indicates the minimum ratio of dirty log to retention size to initiate log compaction
	// +nais:doc:Default="50%"
	// +nais:doc:Link="https://kafka.apache.org/33/documentation.html#topicconfigs_min.cleanable.dirty.ratio"
	MinCleanableDirtyRatioPercent *intstr.IntOrString `json:"minCleanableDirtyRatioPercent,omitempty"`
}

type Stream struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              StreamSpec    `json:"spec"`
	Status            *StreamStatus `json:"status,omitempty"`
}

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

type StreamSpec struct {
	Pool string `json:"pool"`
}

type StreamStatus struct {
	SynchronizationState      string   `json:"synchronizationState,omitempty"`
	SynchronizationHash       string   `json:"synchronizationHash,omitempty"`
	SynchronizationTime       string   `json:"synchronizationTime,omitempty"`
	Errors                    []string `json:"errors,omitempty"`
	Message                   string   `json:"message,omitempty"`
	FullyQualifiedTopicPrefix string   `json:"fullyQualifiedTopicPrefix,omitempty"`
}

type Topic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              TopicSpec    `json:"spec"`
	Status            *TopicStatus `json:"status,omitempty"`
}

type TopicACL struct {
	// Access type granted for a application.
	// Defaults to `readwrite`.
	// +kubebuilder:validation:Enum=read;write;readwrite
	Access string `json:"access"`
	// The name of the specified application
	Application string `json:"application"`
	// The team of the specified application
	Team string `json:"team"`
}

type TopicACLs []TopicACL

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

type TopicSpec struct {
	Pool   string    `json:"pool"`
	Config *Config   `json:"config,omitempty"`
	ACL    TopicACLs `json:"acl"`
}

type TopicStatus struct {
	SynchronizationState   string   `json:"synchronizationState,omitempty"`
	SynchronizationHash    string   `json:"synchronizationHash,omitempty"`
	SynchronizationTime    string   `json:"synchronizationTime,omitempty"`
	CredentialsExpiryTime  string   `json:"credentialsExpiryTime,omitempty"`
	Errors                 []string `json:"errors,omitempty"`
	Message                string   `json:"message,omitempty"`
	FullyQualifiedName     string   `json:"fullyQualifiedName,omitempty"`
	LatestAivenSyncFailure string   `json:"latestAivenSyncFailure,omitempty"`
}

type User struct {
	Username    string
	Application string
	Team        string
}