Versions in this module Expand all Collapse all v0 v0.4.0 Jun 7, 2022 Changes in this version + func AddAnnotations(obj metav1.Object, annotations map[string]string) + func CreateNamespaceIfNotExist(ctx context.Context, k8sClient client.Client, namespace string) error + func DeleteObject(ctx context.Context, k8sClient client.Client, obj *unstructured.Unstructured) (bool, error) + func HasAnnotation(obj metav1.Object, annotation string) bool + func HasLabel(obj metav1.Object, label string) bool + func UpdateObject(ctx context.Context, k8sClient client.Client, obj *unstructured.Unstructured) error + type ConfigManager struct + Kafka *KafkaConfig + LeafHubName string + PodNameSpace string + SpecEnforceHohRbac bool + SpecWorkPoolSize int + StatusDeltaCountSwitchFactor int + SyncService *SyncServiceConfig + TransportCompressionType string + TransportType string + func NewConfigManager() (*ConfigManager, error) + func (configManager *ConfigManager) GetKafkaConfigMap() (*kafka.ConfigMap, error) + func (configManager *ConfigManager) GetProducerKafkaConfigMap() (*kafka.ConfigMap, error) + type KafkaConfig struct + BootstrapServers string + ComsumerTopic string + ProducerId string + ProducerMessageLimit int + ProducerTopic string + SslCa string + type LabelsField struct + Labels map[string]struct{} + type MetadataField struct + type SyncServiceConfig struct + ConsumerHost string + ConsumerPollingInterval int + ConsumerPort int + ProducerHost string + ProducerPort int + Protocol string
Go to main page