broker

Documentation

Index

• Constants
• func Creator(client *eventingtestlib.Client, version string) string
• func CreatorForClass(class string) func(*eventingtestlib.Client, string) string
• func CreatorWithBrokerOptions(client *eventingtestlib.Client, version string, ...) string
• func CreatorWithOptions(client *eventingtestlib.Client, version string, ...) string
• func GetKafkaClassFromEnv() (string, error)
• func WithBrokerClassFromEnvVar(b *eventingv1.Broker)
• type ConfigOptions

Constants

const BrokerClassEnvVarKey = "BROKER_CLASS"

Functions

func Creator

func Creator(client *eventingtestlib.Client, version string) string

Creator creates a Broker with the class that is specified in an environment variable.

func CreatorForClass

func CreatorForClass(class string) func(*eventingtestlib.Client, string) string

CreatorForClass creates a Broker with the given class.

func CreatorWithBrokerOptions

func CreatorWithBrokerOptions(client *eventingtestlib.Client, version string, brokerOptions ...resources.BrokerOption) string

func CreatorWithOptions

func CreatorWithOptions(client *eventingtestlib.Client, version string, brokerOptions []resources.BrokerOption, configOptions []ConfigOptions) string

func GetKafkaClassFromEnv

func GetKafkaClassFromEnv() (string, error)

func WithBrokerClassFromEnvVar

func WithBrokerClassFromEnvVar(b *eventingv1.Broker)

Types

type ConfigOptions

type ConfigOptions func(data map[string]string)