v1alpha1

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 30, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects.
	GroupVersion = schema.GroupVersion{Group: "kafscale.io", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme.
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type BrokerResources 

type BrokerResources struct {
	Requests corev1.ResourceList `json:"requests,omitempty"`
	Limits   corev1.ResourceList `json:"limits,omitempty"`
}

func (*BrokerResources) DeepCopy 

func (in *BrokerResources) DeepCopy() *BrokerResources

func (*BrokerResources) DeepCopyInto 

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

type BrokerServiceSpec 

type BrokerServiceSpec struct {
	Type                     string            `json:"type,omitempty"`
	Annotations              map[string]string `json:"annotations,omitempty"`
	LoadBalancerIP           string            `json:"loadBalancerIP,omitempty"`
	LoadBalancerSourceRanges []string          `json:"loadBalancerSourceRanges,omitempty"`
	ExternalTrafficPolicy    string            `json:"externalTrafficPolicy,omitempty"`
	KafkaNodePort            *int32            `json:"kafkaNodePort,omitempty"`
	MetricsNodePort          *int32            `json:"metricsNodePort,omitempty"`
}

func (*BrokerServiceSpec) DeepCopy 

func (in *BrokerServiceSpec) DeepCopy() *BrokerServiceSpec

func (*BrokerServiceSpec) DeepCopyInto 

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

type BrokerSpec 

type BrokerSpec struct {
	Replicas       *int32            `json:"replicas,omitempty"`
	Resources      BrokerResources   `json:"resources,omitempty"`
	AdvertisedHost string            `json:"advertisedHost,omitempty"`
	AdvertisedPort *int32            `json:"advertisedPort,omitempty"`
	Service        BrokerServiceSpec `json:"service,omitempty"`
}

func (*BrokerSpec) DeepCopy 

func (in *BrokerSpec) DeepCopy() *BrokerSpec

func (*BrokerSpec) DeepCopyInto 

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

type ClusterConfigSpec 

type ClusterConfigSpec struct {
	SegmentBytes    int32  `json:"segmentBytes,omitempty"`
	FlushIntervalMs int32  `json:"flushIntervalMs,omitempty"`
	CacheSize       string `json:"cacheSize,omitempty"`
}

func (*ClusterConfigSpec) DeepCopy 

func (in *ClusterConfigSpec) DeepCopy() *ClusterConfigSpec

func (*ClusterConfigSpec) DeepCopyInto 

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

type EtcdSpec 

type EtcdSpec struct {
	Endpoints []string `json:"endpoints"`
}

type KafscaleCluster 

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

	Spec   KafscaleClusterSpec   `json:"spec,omitempty"`
	Status KafscaleClusterStatus `json:"status,omitempty"`
}

KafscaleCluster is the Schema for the kafscaleclusters API.

func (*KafscaleCluster) DeepCopy 

func (in *KafscaleCluster) DeepCopy() *KafscaleCluster

func (*KafscaleCluster) DeepCopyInto 

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

func (*KafscaleCluster) DeepCopyObject 

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

type KafscaleClusterList 

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

KafscaleClusterList contains a list of KafscaleCluster.

func (*KafscaleClusterList) DeepCopy 

func (in *KafscaleClusterList) DeepCopy() *KafscaleClusterList

func (*KafscaleClusterList) DeepCopyInto 

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

func (*KafscaleClusterList) DeepCopyObject 

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

type KafscaleClusterSpec 

type KafscaleClusterSpec struct {
	Brokers BrokerSpec        `json:"brokers"`
	S3      S3Spec            `json:"s3"`
	Etcd    EtcdSpec          `json:"etcd"`
	Config  ClusterConfigSpec `json:"config,omitempty"`
}

KafscaleClusterSpec defines the desired state of a Kafscale cluster.

func (*KafscaleClusterSpec) DeepCopy 

func (in *KafscaleClusterSpec) DeepCopy() *KafscaleClusterSpec

func (*KafscaleClusterSpec) DeepCopyInto 

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

type KafscaleClusterStatus 

type KafscaleClusterStatus struct {
	Phase      string             `json:"phase,omitempty"`
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

KafscaleClusterStatus captures observed state.

func (*KafscaleClusterStatus) DeepCopy 

func (in *KafscaleClusterStatus) DeepCopy() *KafscaleClusterStatus

func (*KafscaleClusterStatus) DeepCopyInto 

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

type KafscaleTopic 

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

	Spec   KafscaleTopicSpec   `json:"spec,omitempty"`
	Status KafscaleTopicStatus `json:"status,omitempty"`
}

KafscaleTopic declares a Kafka-compatible topic managed by the operator.

func (*KafscaleTopic) DeepCopy 

func (in *KafscaleTopic) DeepCopy() *KafscaleTopic

func (*KafscaleTopic) DeepCopyInto 

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

func (*KafscaleTopic) DeepCopyObject 

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

type KafscaleTopicList 

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

KafscaleTopicList contains multiple topics.

func (*KafscaleTopicList) DeepCopy 

func (in *KafscaleTopicList) DeepCopy() *KafscaleTopicList

func (*KafscaleTopicList) DeepCopyInto 

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

func (*KafscaleTopicList) DeepCopyObject 

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

type KafscaleTopicSpec 

type KafscaleTopicSpec struct {
	ClusterRef     string            `json:"clusterRef"`
	Partitions     int32             `json:"partitions"`
	RetentionMs    *int64            `json:"retentionMs,omitempty"`
	RetentionBytes *int64            `json:"retentionBytes,omitempty"`
	Config         map[string]string `json:"config,omitempty"`
}

KafscaleTopicSpec captures desired configuration for a topic that the operator will reconcile across etcd metadata and S3 layout.

func (*KafscaleTopicSpec) DeepCopy 

func (in *KafscaleTopicSpec) DeepCopy() *KafscaleTopicSpec

func (*KafscaleTopicSpec) DeepCopyInto 

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

type KafscaleTopicStatus 

type KafscaleTopicStatus struct {
	Phase      string                 `json:"phase,omitempty"`
	Conditions []metav1.Condition     `json:"conditions,omitempty"`
	Partitions []TopicPartitionStatus `json:"partitions,omitempty"`
}

KafscaleTopicStatus surfaces observed reconciliation details.

func (*KafscaleTopicStatus) DeepCopy 

func (in *KafscaleTopicStatus) DeepCopy() *KafscaleTopicStatus

func (*KafscaleTopicStatus) DeepCopyInto 

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

type S3Spec 

type S3Spec struct {
	Bucket               string `json:"bucket"`
	Region               string `json:"region"`
	Endpoint             string `json:"endpoint,omitempty"`
	ReadBucket           string `json:"readBucket,omitempty"`
	ReadRegion           string `json:"readRegion,omitempty"`
	ReadEndpoint         string `json:"readEndpoint,omitempty"`
	KMSKeyARN            string `json:"kmsKeyArn,omitempty"`
	CredentialsSecretRef string `json:"credentialsSecretRef"`
}

type TopicPartitionStatus 

type TopicPartitionStatus struct {
	ID             int32  `json:"id"`
	Leader         string `json:"leader"`
	LogEndOffset   int64  `json:"logEndOffset"`
	LogStartOffset int64  `json:"logStartOffset"`
}

TopicPartitionStatus describes the observed state of a topic partition.

func (*TopicPartitionStatus) DeepCopy 

func (in *TopicPartitionStatus) DeepCopy() *TopicPartitionStatus

func (*TopicPartitionStatus) DeepCopyInto 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.