Documentation
¶
Overview ¶
Package pubsubtest is the conformance suite every pubsub.Broker implementation must pass. Backend packages call Run from their tests:
func TestConformance(t *testing.T) {
pubsubtest.Run(t, func(t *testing.T) pubsub.Broker { return newBroker(t) })
}
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Run ¶
Run executes the conformance suite. newBroker must return a new, open broker each time it is called; all brokers returned during one Run must share a backend (the same Redis server and prefix, the same Postgres database and channel, or memory peers of one bus) so that cross-broker delivery can be tested. The suite closes every broker it opens; Close must be idempotent. Topics are unique per subtest, so brokers may share a backend with other tests running concurrently.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.