testing

Documentation

Index

• Constants
• func GetTestSaramaConfigMap(version string, saramaConfig string, configuration string) *corev1.ConfigMap
• func GetTestSaramaConfigMapNamespaced(version, name, namespace, saramaConfig, configuration string) *corev1.ConfigMap
• func GetTestSaramaSecret(name string, username string, password string, namespace string, ...) *corev1.Secret
• func SetTestEnvironment(t *testing.T)

Constants

const (
	SystemNamespace = "eventing-test-ns"
	SecretName      = "test-secret-name"

	NewClientId = "TestNewClientId"
	OldUsername = "TestOldUsername"
	NewUsername = "TestNewUsername"
	OldPassword = "TestOldPassword"
	NewPassword = "TestNewPassword"

	ReceiverCpuLimit        = "501m"
	ReceiverCpuRequest      = "301m"
	ReceiverMemoryLimit     = "129Mi"
	ReceiverMemoryRequest   = "51Mi"
	ReceiverReplicas        = "4"
	DispatcherReplicas      = "3"
	DispatcherCpuLimit      = "500m"
	DispatcherCpuRequest    = "300m"
	DispatcherMemoryLimit   = "128Mi"
	DispatcherMemoryRequest = "50Mi"
	BrokerString            = "test-broker-string"

	TestEKConfig = `
channel:
  adminType: kafka # One of "kafka", "azure", "custom"
  receiver:
    cpuRequest: ` + ReceiverCpuRequest + `
    memoryRequest: ` + ReceiverMemoryRequest + `
    cpuLimit: ` + ReceiverCpuLimit + `
    memoryLimit: ` + ReceiverMemoryLimit + `
    replicas: ` + ReceiverReplicas + `
  dispatcher:
    cpuRequest: ` + DispatcherCpuRequest + `
    memoryRequest: ` + DispatcherMemoryRequest + `
    cpuLimit: ` + DispatcherCpuLimit + `
    memoryLimit: ` + DispatcherMemoryLimit + `
    replicas: ` + DispatcherReplicas + `
kafka:
  brokers: ` + BrokerString + `
  topic:
    defaultNumPartitions: 4
    defaultReplicationFactor: 1 # Cannot exceed the number of Kafka Brokers!
    defaultRetentionMillis: 604800000  # 1 week
`

	OldSaramaConfig = `
enableLogging: false
config: |
  Net:
    TLS:
      Enable: true
    SASL:
      Enable: true
      Mechanism: PLAIN
      Version: 1
      User: ` + OldUsername + `
      Password: ` + OldPassword + `
  Metadata:
    RefreshFrequency: 300000000000
`

	NewSaramaConfig = `
enableLogging: false
config: |
  Version: 2.3.0
  Net:
    TLS:
      Enable: true
    SASL:
      Enable: true
      Mechanism: PLAIN
      Version: 1
      User: ` + NewUsername + `
      Password: ` + NewPassword + `
  Metadata:
    RefreshFrequency: 300000000000
  ClientID: ` + NewClientId + `
`

	OldAuthNamespace = "TestOldNamespace"
	OldAuthPassword  = "TestOldPassword"
	OldAuthSaslType  = "TestOldAuthSaslType"
	OldAuthUsername  = "TestOldAuthUsername"

	NewAuthNamespace = "TestNewNamespace"
	NewAuthPassword  = "TestNewPassword"
	NewAuthSaslType  = "TestNewAuthSaslType"
	NewAuthUsername  = "TestNewAuthUsername"
)

Functions

func GetTestSaramaConfigMap

func GetTestSaramaConfigMap(version string, saramaConfig string, configuration string) *corev1.ConfigMap

GetTestSaramaConfigMap Returns A ConfigMap Containing The Desired Sarama Config YAML

func GetTestSaramaConfigMapNamespaced

func GetTestSaramaConfigMapNamespaced(version, name, namespace, saramaConfig, configuration string) *corev1.ConfigMap

GetTestSaramaConfigMapNamespaced Returns A ConfigMap Containing The Desired Sarama Config YAML, Name And Namespace

func GetTestSaramaSecret

func GetTestSaramaSecret(name string, username string, password string, namespace string, saslType string) *corev1.Secret

GetTestSaramaSecret Returns A Secret Containing The Desired Fields

func SetTestEnvironment

func SetTestEnvironment(t *testing.T)

SetTestEnvironment Sets the environment variables that are necessary for common components