tests

package module
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 26, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package tests implements event tests.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Suite

type Suite struct {
	suite.Suite
	// contains filtered or unexported fields
}

Suite is our testsuite.

func New

func New(logger log.Logger, handler event.Client) *Suite

New creates a new testsuite.

func (*Suite) BenchmarkConsume added in v0.2.0

func (s *Suite) BenchmarkConsume(b *testing.B)

BenchmarkConsume runs a benchmark on consume operations.

func (*Suite) BenchmarkPublish added in v0.2.0

func (s *Suite) BenchmarkPublish(b *testing.B)

BenchmarkPublish runs a benchmark on publish operations.

func (*Suite) BenchmarkPublishLarge added in v0.2.0

func (s *Suite) BenchmarkPublishLarge(b *testing.B)

BenchmarkPublishLarge runs a benchmark on publish operations with large payloads.

func (*Suite) BenchmarkPublishMetadata added in v0.2.0

func (s *Suite) BenchmarkPublishMetadata(b *testing.B)

BenchmarkPublishMetadata runs a benchmark on publish operations with metadata.

func (*Suite) BenchmarkRequest

func (s *Suite) BenchmarkRequest(b *testing.B)

BenchmarkRequest runs a benchmark on requests.

func (*Suite) BenchmarkRequestAuth added in v0.2.0

func (s *Suite) BenchmarkRequestAuth(b *testing.B)

BenchmarkRequestAuth runs a benchmark on auth requests.

func (*Suite) BenchmarkRequestLarge added in v0.2.0

func (s *Suite) BenchmarkRequestLarge(b *testing.B)

BenchmarkRequestLarge runs a benchmark on requests with large payloads.

func (*Suite) BenchmarkRequestParallel added in v0.2.0

func (s *Suite) BenchmarkRequestParallel(b *testing.B)

BenchmarkRequestParallel runs a benchmark on requests with parallelism.

func (*Suite) SetupSuite

func (s *Suite) SetupSuite()

SetupSuite creates the handler.

func (*Suite) TearDownSuite

func (s *Suite) TearDownSuite()

TearDownSuite stops the handler.

func (*Suite) TestAuthorizedRequest

func (s *Suite) TestAuthorizedRequest()

TestAuthorizedRequest tests an authorized request.

func (*Suite) TestBadRequest

func (s *Suite) TestBadRequest()

TestBadRequest tests a bad 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.

func (*Suite) TestRequest

func (s *Suite) TestRequest()

TestRequest tests a request.

Directories

Path Synopsis
pb
Package pb ...
Package pb ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL