tests

Documentation

Overview

Package tests implements event tests.

Index

• type Suite
  • func New(logger log.Logger, handler event.Client) *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()

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

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

BenchmarkConsume runs a benchmark on consume operations.

func (*Suite) BenchmarkPublish

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

BenchmarkPublish runs a benchmark on publish operations.

func (*Suite) BenchmarkPublishLarge

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

BenchmarkPublishLarge runs a benchmark on publish operations with large payloads.

func (*Suite) BenchmarkPublishMetadata

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

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

BenchmarkRequestAuth runs a benchmark on auth requests.

func (*Suite) BenchmarkRequestLarge

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

BenchmarkRequestLarge runs a benchmark on requests with large payloads.

func (*Suite) BenchmarkRequestParallel

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

func (s *Suite) TestConcurrentPublishConsume()

TestConcurrentPublishConsume tests concurrent publishing and consuming.

func (*Suite) TestConsume

func (s *Suite) TestConsume()

TestConsume tests consuming events.

func (*Suite) TestConsumeWithAckWait

func (s *Suite) TestConsumeWithAckWait()

TestConsumeWithAckWait tests the acknowledgement wait time.

func (*Suite) TestConsumeWithGroup

func (s *Suite) TestConsumeWithGroup()

TestConsumeWithGroup tests consuming events with a consumer group.

func (*Suite) TestConsumeWithRetries

func (s *Suite) TestConsumeWithRetries()

TestConsumeWithRetries tests the retry behavior with manual acknowledgment.

func (*Suite) TestErrorHandling

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

func (s *Suite) TestMultipleConsumers()

TestMultipleConsumers tests multiple independent consumers on the same topic.

func (*Suite) TestPublish

func (s *Suite) TestPublish()

TestPublish tests publishing an event.

func (*Suite) TestRequest

func (s *Suite) TestRequest()

TestRequest tests a request.