systemtest

Mar 6, 2024

Changes in this version

+ func CreateKafkaTopics(ctx context.Context, t testing.TB, partitions int, topics ...apmqueue.Topic)

+ func CreatePubsubTopicSubscriptions(ctx context.Context, t testing.TB, consumer string, topics ...apmqueue.Topic)

+ func CreatePubsubTopics(ctx context.Context, t testing.TB, partitions int, topics ...apmqueue.Topic)

+ func DestroyKafka(ctx context.Context) error

+ func DestroyPubSubLite(ctx context.Context) error

+ func InitKafka() (ProvisionInfraFunc, DestroyInfraFunc, error)

+ func InitPubSubLite() (ProvisionInfraFunc, DestroyInfraFunc, error)

+ func KafkaCommonConfig(t testing.TB, cfg kafka.CommonConfig) kafka.CommonConfig

+ func NewKafkaManager(t testing.TB) *kafka.Manager

+ func ProvisionKafka(ctx context.Context) error

+ func ProvisionPubSubLite(ctx context.Context) error

+ func PubSubLiteCommonConfig(cfg pubsublite.CommonConfig) pubsublite.CommonConfig

+ func RandomSuffix() string

+ func SuffixTopics(topics ...apmqueue.Topic) []apmqueue.Topic

+ func TestLogger(t testing.TB) *zap.Logger

+ type DestroyInfraFunc func(context.Context) error

+ type ProvisionInfraFunc func(context.Context) error