Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func TestAll ¶
func TestAll(t *testing.T, ts TestServer)
TestAll is the main entrypoint from the backend implmenentation tests to call, and will run each test as a sub-test.
Types ¶
type TestServer ¶
type TestServer interface { NewConsumer(topic string, groupID string) substrate.AsyncMessageSource NewProducer(topic string) substrate.AsyncMessageSink TestEnd() }
TestServer represents the server under test, and is expected to be implemented by each backend broker implementation wishing to benefit from these shared tests.
Click to show internal directories.
Click to hide internal directories.