Versions in this module Expand all Collapse all v0 v0.14.0 May 8, 2020 Changes in this version + func ChannelDnsSafeName(kafkaSecretName string) string + func ChannelHostName(channelName, channelNamespace string) string + func ChannelKey(channel *kafkav1alpha1.KafkaChannel) string + func ChannelLogger(logger *zap.Logger, channel *kafkav1alpha1.KafkaChannel) *zap.Logger + func DispatcherDnsSafeName(channel *kafkav1alpha1.KafkaChannel) string + func GenerateValidDnsName(name string, length int, prefix bool, suffix bool) string + func KubernetesResourceFinalizerName(finalizerSuffix string) string + func NewChannelOwnerReference(channel *kafkav1alpha1.KafkaChannel) metav1.OwnerReference + func NewSecretOwnerReference(secret *corev1.Secret) metav1.OwnerReference + func NewSubscriptionControllerRef(subscription *messagingv1alpha1.Subscription) metav1.OwnerReference + func NumPartitions(channel *kafkav1alpha1.KafkaChannel, environment *env.Environment, ...) int + func ReplicationFactor(channel *kafkav1alpha1.KafkaChannel, environment *env.Environment, ...) int + func RetentionMillis(channel *kafkav1alpha1.KafkaChannel, environment *env.Environment, ...) int64 + func SecretLogger(logger *zap.Logger, secret *corev1.Secret) *zap.Logger + func SubscriptionLogger(logger *zap.Logger, subscription *messagingv1alpha1.Subscription) *zap.Logger + func TopicName(channel *kafkav1alpha1.KafkaChannel) string
Go to main page