v1alpha1

package

Go to main page

Versions in this module

v1

v1.4.0

Jan 6, 2026

v1.3.0

Dec 28, 2025

Changes in this version

+ type BrokerServiceSpec struct

+ Annotations map[string]string

+ ExternalTrafficPolicy string

+ KafkaNodePort *int32

+ LoadBalancerIP string

+ LoadBalancerSourceRanges []string

+ MetricsNodePort *int32

+ Type string

+ func (in *BrokerServiceSpec) DeepCopy() *BrokerServiceSpec

+ func (in *BrokerServiceSpec) DeepCopyInto(out *BrokerServiceSpec)

type BrokerSpec

+ AdvertisedHost string

+ AdvertisedPort *int32

+ Service BrokerServiceSpec

v1.2.0

Dec 24, 2025

Changes in this version

type S3Spec

+ ReadBucket string

+ ReadEndpoint string

+ ReadRegion string

v1.1.0

Dec 21, 2025

v1.0.0

Dec 20, 2025

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type BrokerResources struct

+ Limits corev1.ResourceList

+ Requests corev1.ResourceList

+ func (in *BrokerResources) DeepCopy() *BrokerResources

+ func (in *BrokerResources) DeepCopyInto(out *BrokerResources)

+ type BrokerSpec struct

+ Replicas *int32

+ Resources BrokerResources

+ func (in *BrokerSpec) DeepCopy() *BrokerSpec

+ func (in *BrokerSpec) DeepCopyInto(out *BrokerSpec)

+ type ClusterConfigSpec struct

+ CacheSize string

+ FlushIntervalMs int32

+ SegmentBytes int32

+ func (in *ClusterConfigSpec) DeepCopy() *ClusterConfigSpec

+ func (in *ClusterConfigSpec) DeepCopyInto(out *ClusterConfigSpec)

+ type EtcdSpec struct

+ Endpoints []string

+ type KafscaleCluster struct

+ Spec KafscaleClusterSpec

+ Status KafscaleClusterStatus

+ func (in *KafscaleCluster) DeepCopy() *KafscaleCluster

+ func (in *KafscaleCluster) DeepCopyInto(out *KafscaleCluster)

+ func (in *KafscaleCluster) DeepCopyObject() runtime.Object

+ type KafscaleClusterList struct

+ Items []KafscaleCluster

+ func (in *KafscaleClusterList) DeepCopy() *KafscaleClusterList

+ func (in *KafscaleClusterList) DeepCopyInto(out *KafscaleClusterList)

+ func (in *KafscaleClusterList) DeepCopyObject() runtime.Object

+ type KafscaleClusterSpec struct

+ Brokers BrokerSpec

+ Config ClusterConfigSpec

+ Etcd EtcdSpec

+ S3 S3Spec

+ func (in *KafscaleClusterSpec) DeepCopy() *KafscaleClusterSpec

+ func (in *KafscaleClusterSpec) DeepCopyInto(out *KafscaleClusterSpec)

+ type KafscaleClusterStatus struct

+ Conditions []metav1.Condition

+ Phase string

+ func (in *KafscaleClusterStatus) DeepCopy() *KafscaleClusterStatus

+ func (in *KafscaleClusterStatus) DeepCopyInto(out *KafscaleClusterStatus)

+ type KafscaleTopic struct

+ Spec KafscaleTopicSpec

+ Status KafscaleTopicStatus

+ func (in *KafscaleTopic) DeepCopy() *KafscaleTopic

+ func (in *KafscaleTopic) DeepCopyInto(out *KafscaleTopic)

+ func (in *KafscaleTopic) DeepCopyObject() runtime.Object

+ type KafscaleTopicList struct

+ Items []KafscaleTopic

+ func (in *KafscaleTopicList) DeepCopy() *KafscaleTopicList

+ func (in *KafscaleTopicList) DeepCopyInto(out *KafscaleTopicList)

+ func (in *KafscaleTopicList) DeepCopyObject() runtime.Object

+ type KafscaleTopicSpec struct

+ ClusterRef string

+ Config map[string]string

+ Partitions int32

+ RetentionBytes *int64

+ RetentionMs *int64

+ func (in *KafscaleTopicSpec) DeepCopy() *KafscaleTopicSpec

+ func (in *KafscaleTopicSpec) DeepCopyInto(out *KafscaleTopicSpec)

+ type KafscaleTopicStatus struct

+ Conditions []metav1.Condition

+ Partitions []TopicPartitionStatus

+ Phase string

+ func (in *KafscaleTopicStatus) DeepCopy() *KafscaleTopicStatus

+ func (in *KafscaleTopicStatus) DeepCopyInto(out *KafscaleTopicStatus)

+ type S3Spec struct

+ Bucket string

+ CredentialsSecretRef string

+ Endpoint string

+ KMSKeyARN string

+ Region string

+ type TopicPartitionStatus struct

+ ID int32

+ Leader string

+ LogEndOffset int64

+ LogStartOffset int64

+ func (in *TopicPartitionStatus) DeepCopy() *TopicPartitionStatus

+ func (in *TopicPartitionStatus) DeepCopyInto(out *TopicPartitionStatus)

v0

v0.9.0-dev.2

Dec 20, 2025

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL