Documentation
¶
Overview ¶
Package tests implements event tests.
Index ¶
- type Suite
- func (s *Suite) BenchmarkConsume(b *testing.B)
- func (s *Suite) BenchmarkPublish(b *testing.B)
- func (s *Suite) BenchmarkPublishLarge(b *testing.B)
- func (s *Suite) BenchmarkPublishMetadata(b *testing.B)
- func (s *Suite) BenchmarkRequest(b *testing.B)
- func (s *Suite) BenchmarkRequestAuth(b *testing.B)
- func (s *Suite) BenchmarkRequestLarge(b *testing.B)
- func (s *Suite) BenchmarkRequestParallel(b *testing.B)
- func (s *Suite) SetupSuite()
- func (s *Suite) TearDownSuite()
- func (s *Suite) TestAuthorizedRequest()
- func (s *Suite) TestBadRequest()
- func (s *Suite) TestConcurrentPublishConsume()
- func (s *Suite) TestConsume()
- func (s *Suite) TestConsumeWithAckWait()
- func (s *Suite) TestConsumeWithGroup()
- func (s *Suite) TestConsumeWithRetries()
- func (s *Suite) TestErrorHandling()
- func (s *Suite) TestFailingAuthorization()
- func (s *Suite) TestMultipleConsumers()
- func (s *Suite) TestPublish()
- func (s *Suite) TestRequest()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Suite ¶
Suite is our testsuite.
func (*Suite) BenchmarkConsume ¶ added in v0.2.0
BenchmarkConsume runs a benchmark on consume operations.
func (*Suite) BenchmarkPublish ¶ added in v0.2.0
BenchmarkPublish runs a benchmark on publish operations.
func (*Suite) BenchmarkPublishLarge ¶ added in v0.2.0
BenchmarkPublishLarge runs a benchmark on publish operations with large payloads.
func (*Suite) BenchmarkPublishMetadata ¶ added in v0.2.0
BenchmarkPublishMetadata runs a benchmark on publish operations with metadata.
func (*Suite) BenchmarkRequest ¶
BenchmarkRequest runs a benchmark on requests.
func (*Suite) BenchmarkRequestAuth ¶ added in v0.2.0
BenchmarkRequestAuth runs a benchmark on auth requests.
func (*Suite) BenchmarkRequestLarge ¶ added in v0.2.0
BenchmarkRequestLarge runs a benchmark on requests with large payloads.
func (*Suite) BenchmarkRequestParallel ¶ added in v0.2.0
BenchmarkRequestParallel runs a benchmark on requests with parallelism.
func (*Suite) TestAuthorizedRequest ¶
func (s *Suite) TestAuthorizedRequest()
TestAuthorizedRequest tests an authorized request.
func (*Suite) TestConcurrentPublishConsume ¶ added in v0.2.0
func (s *Suite) TestConcurrentPublishConsume()
TestConcurrentPublishConsume tests concurrent publishing and consuming.
func (*Suite) TestConsume ¶ added in v0.2.0
func (s *Suite) TestConsume()
TestConsume tests consuming events.
func (*Suite) TestConsumeWithAckWait ¶ added in v0.2.0
func (s *Suite) TestConsumeWithAckWait()
TestConsumeWithAckWait tests the acknowledgement wait time.
func (*Suite) TestConsumeWithGroup ¶ added in v0.2.0
func (s *Suite) TestConsumeWithGroup()
TestConsumeWithGroup tests consuming events with a consumer group.
func (*Suite) TestConsumeWithRetries ¶ added in v0.2.0
func (s *Suite) TestConsumeWithRetries()
TestConsumeWithRetries tests the retry behavior with manual acknowledgment.
func (*Suite) TestErrorHandling ¶ added in v0.2.0
func (s *Suite) TestErrorHandling()
TestErrorHandling tests error conditions.
func (*Suite) TestFailingAuthorization ¶
func (s *Suite) TestFailingAuthorization()
TestFailingAuthorization tests an authorization call that must fail.
func (*Suite) TestMultipleConsumers ¶ added in v0.2.0
func (s *Suite) TestMultipleConsumers()
TestMultipleConsumers tests multiple independent consumers on the same topic.
func (*Suite) TestPublish ¶ added in v0.2.0
func (s *Suite) TestPublish()
TestPublish tests publishing an event.