testing

Documentation

Index

• Constants
• func NewKafkaConfigMap(options ...KafkaConfigMapOption) *corev1.ConfigMap
• func WithModifiedSaramaAdmin(configMap *corev1.ConfigMap)
• func WithModifiedSaramaConsumer(configMap *corev1.ConfigMap)
• func WithModifiedSaramaMetadata(configMap *corev1.ConfigMap)
• func WithModifiedSaramaNet(configMap *corev1.ConfigMap)
• func WithModifiedSaramaProducer(configMap *corev1.ConfigMap)
• func WithoutEventingKafkaConfiguration(configMap *corev1.ConfigMap)
• type KafkaConfigMapOption

Constants

const (
	DefaultSaramaConfigYaml = `` /* 425-byte string literal not displayed */

	DefaultEventingKafkaConfigYaml = `` /* 297-byte string literal not displayed */

)

Constants

Functions

func NewKafkaConfigMap

func NewKafkaConfigMap(options ...KafkaConfigMapOption) *corev1.ConfigMap

Create A New Eventing-Kafka ConfigMap For Testing

func WithModifiedSaramaAdmin

func WithModifiedSaramaAdmin(configMap *corev1.ConfigMap)

Modify The Default "Admin" Section Of The Sarama Config YAML

func WithModifiedSaramaConsumer

func WithModifiedSaramaConsumer(configMap *corev1.ConfigMap)

Modify The Default "Consumer" Section Of The Sarama Config YAML

func WithModifiedSaramaMetadata

func WithModifiedSaramaMetadata(configMap *corev1.ConfigMap)

Modify The Default "Net" Section Of The Sarama Config YAML

func WithModifiedSaramaNet

func WithModifiedSaramaNet(configMap *corev1.ConfigMap)

Modify The Default "Net" Section Of The Sarama Config YAML

func WithModifiedSaramaProducer

func WithModifiedSaramaProducer(configMap *corev1.ConfigMap)

Modify The Default "Producer" Section Of The Sarama Config YAML

func WithoutEventingKafkaConfiguration

func WithoutEventingKafkaConfiguration(configMap *corev1.ConfigMap)

Remove The Entire Eventing-Kafka Configuration

Types

type KafkaConfigMapOption

type KafkaConfigMapOption func(configMap *corev1.ConfigMap)

KafkaConfigMapOption Enables Customization Of An Eventing-Kafka ConfigMap