testing

Documentation

Index

• Constants
• func NewKafkaConfigMap(options ...KafkaConfigMapOption) *corev1.ConfigMap
• func NewKafkaSecret(options ...KafkaSecretOption) *corev1.Secret
• func WithEmptyUsername(secret *corev1.Secret)
• func WithMissingConfig(secret *corev1.Secret)
• func WithModifiedNamespace(secret *corev1.Secret)
• func WithModifiedPassword(secret *corev1.Secret)
• 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 WithModifiedSaslType(secret *corev1.Secret)
• func WithModifiedUsername(secret *corev1.Secret)
• func WithoutEventingKafkaConfiguration(configMap *corev1.ConfigMap)
• type KafkaConfigMapOption
• type KafkaSecretOption

Constants

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

	DefaultEventingKafkaConfigYaml = `
receiver:
  cpuRequest: 100m
  memoryRequest: 64Mi
  replicas: 1
dispatcher:
  cpuRequest: 300m
  memoryRequest: 64Mi
  replicas: 1
kafka:
  enableSaramaLogging: false
  brokers: ` + DefaultKafkaBroker + `
  topic:
    defaultNumPartitions: 4
    defaultReplicationFactor: 1
    defaultRetentionMillis: 604800000
    adminType: kafka
`
	DefaultKafkaBroker     = "TestBroker"
	DefaultSecretUsername  = "TestUsername"
	DefaultSecretPassword  = "TestPassword"
	DefaultSecretSaslType  = "PLAIN"
	DefaultSecretNamespace = "TestNamespace"
)

Constants

Functions

func NewKafkaConfigMap

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

Create A New Eventing-Kafka ConfigMap For Testing

func NewKafkaSecret

func NewKafkaSecret(options ...KafkaSecretOption) *corev1.Secret

Create A New Eventing-Kafka Secret For Testing

func WithEmptyUsername

func WithEmptyUsername(secret *corev1.Secret)

Empty The Default Username Section Of The Secret Data

func WithMissingConfig

func WithMissingConfig(secret *corev1.Secret)

Remove the Data From The Secret

func WithModifiedNamespace

func WithModifiedNamespace(secret *corev1.Secret)

Modify The Default Namespace Section Of The Secret Data

func WithModifiedPassword

func WithModifiedPassword(secret *corev1.Secret)

Modify The Default Password Section Of The Secret Data

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 WithModifiedSaslType

func WithModifiedSaslType(secret *corev1.Secret)

Modify The Default SaslType Section Of The Secret Data

func WithModifiedUsername

func WithModifiedUsername(secret *corev1.Secret)

Modify The Default Username Section Of The Secret Data

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

type KafkaSecretOption

type KafkaSecretOption func(secret *corev1.Secret)

KafkaConfigMapOption Enables Customization Of An Eventing-Kafka Secret