Documentation
¶
Index ¶
- func Certificates(t T) (clientCert, clientKey, caCert string)
- func ConfigMap() map[string]string
- func ConfigWithIntegrationTestOptions(cfg common.Config) common.Config
- func Consume(t T, servers []string, topic string, limit int) []*kgo.Record
- func CreateTopics(t T, servers []string, topics []string)
- func DestinationConfigMap(t T) map[string]string
- func GenerateFranzRecords(from, to int, topicOpt ...string) []*kgo.Record
- func GenerateSDKRecords(from, to int, topicOpt ...string) []sdk.Record
- func ParseConfigMap[C any](t T, cfg map[string]string) C
- func Produce(t T, servers []string, topic string, records []*kgo.Record, ...)
- func SourceConfigMap(t T, multipleTopics bool) map[string]string
- type T
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Certificates ¶
func CreateTopics ¶ added in v0.8.0
func DestinationConfigMap ¶
func GenerateFranzRecords ¶
Types ¶
type T ¶
type T interface {
// Fail indicates that the test has failed but
// allowed execution to continue.
Fail()
// FailNow indicates that the test has failed and
// aborts the test.
FailNow()
// Name returns the name of the running (sub-) test or benchmark.
Name() string
// Logf formats its arguments according to the format, analogous to Printf, and
// records the text in the error log.
Logf(string, ...any)
// Cleanup registers a function to be called when the test (or subtest) and all its
// subtests complete. Cleanup functions will be called in last added,
// first called order.
Cleanup(func())
}
T reports when failures occur. testing.T and testing.B implement this interface.
Source Files
Click to show internal directories.
Click to hide internal directories.