setupclientoptions

Documentation

Index

• func KafkaSourceV1B1ClientSetupOption(name string, kafkaClusterName string, kafkaClusterNamespace string, ...) testlib.SetupClientOption

Functions

func KafkaSourceV1B1ClientSetupOption

func KafkaSourceV1B1ClientSetupOption(name string, kafkaClusterName string, kafkaClusterNamespace string, kafkaBootstrapUrl string, recordEventsPodName string) testlib.SetupClientOption

KafkaSourceV1B1ClientSetupOption returns a ClientSetupOption that can be used to create a new KafkaSource. It creates a ServiceAccount, a Role, a RoleBinding, a RecordEvents pod and an ApiServerSource object with the event mode and RecordEvent pod as its sink.