Versions in this module Expand all Collapse all v1 v1.5.0 Apr 16, 2021 Changes in this version + const KafkaConditionTypeReady + const KafkaLastTransitionTimeLayout + var SchemeBuilder = &scheme.Builder + var SchemeGroupVersion = schema.GroupVersion + type EntityOperatorSpec struct + TopicOperator EntityTopicOperatorSpec + UserOperator EntityUserOperatorSpec + func (in *EntityOperatorSpec) DeepCopy() *EntityOperatorSpec + func (in *EntityOperatorSpec) DeepCopyInto(out *EntityOperatorSpec) + type EntityTopicOperatorSpec struct + func (in *EntityTopicOperatorSpec) DeepCopy() *EntityTopicOperatorSpec + func (in *EntityTopicOperatorSpec) DeepCopyInto(out *EntityTopicOperatorSpec) + type EntityUserOperatorSpec struct + func (in *EntityUserOperatorSpec) DeepCopy() *EntityUserOperatorSpec + func (in *EntityUserOperatorSpec) DeepCopyInto(out *EntityUserOperatorSpec) + type Kafka struct + Spec KafkaSpec + Status KafkaStatus + func (in *Kafka) DeepCopy() *Kafka + func (in *Kafka) DeepCopyInto(out *Kafka) + func (in *Kafka) DeepCopyObject() runtime.Object + type KafkaClusterSpec struct + Config KafkaMap + JvmOptions KafkaMap + Listeners KafkaListeners + Replicas int32 + Storage KafkaStorage + func (in *KafkaClusterSpec) DeepCopy() *KafkaClusterSpec + func (in *KafkaClusterSpec) DeepCopyInto(out *KafkaClusterSpec) + type KafkaCondition struct + LastTransitionTime string + Message string + Reason string + Status corev1.ConditionStatus + Type string + func (in *KafkaCondition) DeepCopy() *KafkaCondition + func (in *KafkaCondition) DeepCopyInto(out *KafkaCondition) + type KafkaList struct + Items []Kafka + func (in *KafkaList) DeepCopy() *KafkaList + func (in *KafkaList) DeepCopyInto(out *KafkaList) + func (in *KafkaList) DeepCopyObject() runtime.Object + type KafkaListenerPlain struct + func (in *KafkaListenerPlain) DeepCopy() *KafkaListenerPlain + func (in *KafkaListenerPlain) DeepCopyInto(out *KafkaListenerPlain) + type KafkaListeners struct + Plain KafkaListenerPlain + func (in *KafkaListeners) DeepCopy() *KafkaListeners + func (in *KafkaListeners) DeepCopyInto(out *KafkaListeners) + type KafkaMap map[string]interface + func (in KafkaMap) DeepCopyInto(out *KafkaMap) + func (kafkaMap *KafkaMap) DeepCopy() *KafkaMap + type KafkaSpec struct + EntityOperator EntityOperatorSpec + Kafka KafkaClusterSpec + Zookeeper ZookeeperClusterSpec + func (in *KafkaSpec) DeepCopy() *KafkaSpec + func (in *KafkaSpec) DeepCopyInto(out *KafkaSpec) + type KafkaStatus struct + Conditions []KafkaCondition + Listeners []ListenerStatus + func (in *KafkaStatus) DeepCopy() *KafkaStatus + func (in *KafkaStatus) DeepCopyInto(out *KafkaStatus) + type KafkaStorage struct + StorageType KafkaStorageType + func (in *KafkaStorage) DeepCopy() *KafkaStorage + func (in *KafkaStorage) DeepCopyInto(out *KafkaStorage) + type KafkaStorageType string + const KafkaEphemeralStorage + type KafkaTopic struct + Spec KafkaTopicSpec + Status KafkaTopicStatus + func (in *KafkaTopic) DeepCopy() *KafkaTopic + func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic) + func (in *KafkaTopic) DeepCopyObject() runtime.Object + type KafkaTopicList struct + Items []KafkaTopic + func (in *KafkaTopicList) DeepCopy() *KafkaTopicList + func (in *KafkaTopicList) DeepCopyInto(out *KafkaTopicList) + func (in *KafkaTopicList) DeepCopyObject() runtime.Object + type KafkaTopicSpec struct + Config map[string]string + Partitions int32 + Replicas int32 + TopicName string + func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec + func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec) + type KafkaTopicStatus struct + func (in *KafkaTopicStatus) DeepCopy() *KafkaTopicStatus + func (in *KafkaTopicStatus) DeepCopyInto(out *KafkaTopicStatus) + type ListenerAddress struct + Host string + Port int32 + func (in *ListenerAddress) DeepCopy() *ListenerAddress + func (in *ListenerAddress) DeepCopyInto(out *ListenerAddress) + type ListenerStatus struct + Addresses []ListenerAddress + Type string + func (in *ListenerStatus) DeepCopy() *ListenerStatus + func (in *ListenerStatus) DeepCopyInto(out *ListenerStatus) + type ZookeeperClusterSpec struct + Replicas int32 + Storage KafkaStorage + func (in *ZookeeperClusterSpec) DeepCopy() *ZookeeperClusterSpec + func (in *ZookeeperClusterSpec) DeepCopyInto(out *ZookeeperClusterSpec)
Go to main page