Versions in this module Expand all Collapse all v0 v0.2.0 Aug 11, 2017 Changes in this version + const CRDGroupName + const CRDName + const CRDRessourcePlural + const CRDVersion + var AddToScheme = SchemeBuilder.AddToScheme + var CRDFullName = CRDRessourcePlural + "." + CRDGroupName + var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) + var SchemeGroupVersion = schema.GroupVersion + func GetGeneratedDeepCopyFuncs() []conversion.GeneratedDeepCopyFunc + func PrintCluster(cluster *Kafkacluster) string + func Resource(resource string) schema.GroupResource + type BrokerState struct + ID string + State string + type KafkaBrokerSpec struct + BrokerID int32 + ClientPort int32 + Topics map[string]string + type KafkaBrokerState string + const EMPTY_BROKER + const NORMAL_STATE + const REBALANCE_BROKER + type KafkaEventType int32 + const BROKER_CONFIG_CHANGE + const CHANGE_BROKER_RESOURCES + const CHANGE_IMAGE + const CHANGE_NAME + const CHANGE_ZOOKEEPER_CONNECT + const CLEANUP_EVENT + const DELETE_CLUSTER + const DOWNSIZE_CLUSTER + const DOWNSIZE_EVENT + const ERROR_STATE + const KAKFA_EVENT + const NEW_CLUSTER + const SCALE_CHANGE + const STATE_CHANGE + const UNKNOWN_CHANGE + const UPSIZE_CLUSTER + type KafkaOption struct + Name string + Type interface{} + Value string + type KafkaOptions struct + AutoCreateTopicsEnable *bool + AutoLeaderRebalanceEnable *bool + BackgroundThreads *int32 + CompressionType *string + DeleteTopicEnable *bool + LeaderImbalanceBrokerPercentage *int32 + LeaderImbalanceCheckIntervalSeconds *int32 + LogFlushIntervalMessages *int64 + LogFlushIntervalMs *int64 + LogFlushOffsetCheckpointIntervalMs *int32 + LogFlushSchedulerIntervalMs *int64 + LogRetentionBytes *string + LogRetentionHours *int32 + LogRollHours *int32 + LogRollJitterHours *int32 + LogSegmentBytes *int32 + LogSegmentDeleteDelayMS *int64 + MessagesMaxBytes *int32 + MinInsyncReplicas *int32 + NumIOThreads *int32 + NumNetworkThreads *int32 + NumRecoveryThreadsPerDataDir *int32 + NumReplicaFetchers *int32 + OffsetCommitTimeoutMs *int32 + OffsetLoadBufferSize *int32 + OffsetMetadataMaxBytes *int32 + OffsetRetentionCheckIntervalMs *int64 + OffsetRetentionMinutes *int32 + OffsetTopicNumPartitions *int32 + OffsetTopicReplicationFactor *int32 + OffsetTopicSegmentsBytes *int32 + QueuedMaxRequest *int32 + ReplicaFetchMinBytes *int32 + ReplicaFetchWaitMaxMs *int32 + ReplicaHighWatermarkCheckpointIntervalMs *int64 + ReplicaLagTimeMaxMs *int64 + ReplicaSocketReceiveBufferBytes *int32 + ReplicaSocketTimeoutMs *int32 + RequestTimeoutMs *int32 + UncleanLeaderElectionEnable *bool + ZookeeperConnectionTimeoutMs *int32 + ZookeeperSessionTimeoutMs *int32 + type KafkaPartition struct + Partition int32 + Replicas []int32 + type KafkaReassignmentConfig struct + Partition []KafkaPartition + Version string + type KafkaTopic struct + PartitionFactor int32 + Partitions []KafkaPartition + ReplicationFactor int32 + Topic string + type KafkaTopicSpec struct + Name string + Partitions int32 + ReplicationFactor int32 + type Kafkacluster struct + Scale KafkaclusterScale + Spec KafkaclusterSpec + State KafkaclusterState + func (e *Kafkacluster) GetObjectKind() schema.ObjectKind + func (in *Kafkacluster) DeepCopyInto(out *Kafkacluster) + func (x *Kafkacluster) DeepCopy() *Kafkacluster + func (x *Kafkacluster) DeepCopyObject() runtime.Object + type KafkaclusterEvent struct + Cluster Kafkacluster + OldCluster Kafkacluster + Type KafkaEventType + type KafkaclusterList struct + Items []Kafkacluster + func (el *KafkaclusterList) GetObjectKind() schema.ObjectKind + func (in *KafkaclusterList) DeepCopyInto(out *KafkaclusterList) + func (x *KafkaclusterList) DeepCopy() *KafkaclusterList + func (x *KafkaclusterList) DeepCopyObject() runtime.Object + type KafkaclusterScale struct + CurrentScale int32 + DesiredScale int32 + type KafkaclusterSpec struct + BrokerCount int32 + Image string + JmxSidecar bool + KafkaOptions KafkaOptions + LeaderImbalanceInterval int32 + LeaderImbalanceRatio float32 + MinimumGracePeriod int64 + NodeSelector map[string]string + Resources ResourceSpec + StorageClass string + Topics []KafkaTopicSpec + ZookeeperConnect string + func (in *KafkaclusterSpec) DeepCopyInto(out *KafkaclusterSpec) + func (x *KafkaclusterSpec) DeepCopy() *KafkaclusterSpec + type KafkaclusterState struct + Brokers []BrokerState + Status string + Topics []string + type KafkaclusterWatchEvent struct + Object Kafkacluster + OldObject Kafkacluster + Type string + type ResourceSpec struct + CPU string + DiskSpace string + Memory string