Documentation
¶
Index ¶
- func NewPublishingBenchmark(p message.Publisher) func(*testing.B)
- func NewSubscriptionBenchmark(s message.Subscriber) func(*testing.B)
- func OfficialImplementationAcceptance(fixture PubSubFixture) func(t *testing.T)
- func TestBasicSendRecieve(setup PubSubFixture) func(t *testing.T)
- func TestHungOperations(setup PubSubFixture) func(t *testing.T)
- func TestNilPayloadMessagePublishingAndReceiving(fixture PubSubFixture) func(t *testing.T)
- func TestOnePublisherThreeSubscribers(setup PubSubFixture, messageCount int) func(t *testing.T)
- type PubSubFixture
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSubscriptionBenchmark ¶
func NewSubscriptionBenchmark(s message.Subscriber) func(*testing.B)
func OfficialImplementationAcceptance ¶
func OfficialImplementationAcceptance(fixture PubSubFixture) func(t *testing.T)
func TestBasicSendRecieve ¶
func TestBasicSendRecieve(setup PubSubFixture) func(t *testing.T)
func TestHungOperations ¶
func TestHungOperations(setup PubSubFixture) func(t *testing.T)
func TestNilPayloadMessagePublishingAndReceiving ¶ added in v0.0.6
func TestNilPayloadMessagePublishingAndReceiving(fixture PubSubFixture) func(t *testing.T)
TestNilPayloadMessagePublishingAndReceiving ensures that a publisher may publish messages without any payload, that is a nil payload.
Clarification: https://github.com/ThreeDotsLabs/watermill/issues/565#issuecomment-2885938295
func TestOnePublisherThreeSubscribers ¶
func TestOnePublisherThreeSubscribers(setup PubSubFixture, messageCount int) func(t *testing.T)
Types ¶
type PubSubFixture ¶
func (PubSubFixture) WithConsumerGroup ¶
func (f PubSubFixture) WithConsumerGroup(consumerGroup string) func(t *testing.T) (message.Publisher, message.Subscriber)
Source Files
Click to show internal directories.
Click to hide internal directories.