Versions in this module Expand all Collapse all v1 v1.5.0 Jan 30, 2026 v1.4.2 Jan 19, 2026 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 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 struct + AdvertisedHost string + AdvertisedPort *int32 + Replicas *int32 + Resources BrokerResources + Service BrokerServiceSpec + 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 + ReadBucket string + ReadEndpoint string + ReadRegion 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)
Go to main page