Versions in this module Expand all Collapse all v0 v0.1.1 Nov 12, 2018 Changes in this version + func BenchSubscriber(b *testing.B, pubSubConstructor BenchmarkPubSubConstructor) + func TestNoGroupSubscriber(t *testing.T, pubSubConstructor PubSubConstructor, ...) + func TestPubSub(t *testing.T, features Features, pubSubConstructor PubSubConstructor, ...) + func TestPubSubStressTest(t *testing.T, features Features, pubSubConstructor PubSubConstructor, ...) + type BenchmarkPubSubConstructor func(n int) message.PubSub + type ConsumerGroupPubSubConstructor func(t *testing.T, consumerGroup string) message.PubSub + type Features struct + ConsumerGroups bool + ExactlyOnceDelivery bool + GuaranteedOrder bool + Persistent bool + RequireSingleInstance bool + type NoGroupSubscriberConstructor func(t *testing.T) message.Subscriber + type PubSubConstructor func(t *testing.T) message.PubSub + type SimpleMessage struct + Num int v0.1.0 Nov 12, 2018