Versions in this module Expand all Collapse all v1 v1.0.0 Feb 21, 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 Other modules containing this package github.com/elastic/apm-queue/v2
Go to main page