Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

tests

package

Go to main page

Versions in this module

v1

v1.4.0

Dec 20, 2023

v1.3.0

Dec 20, 2023

v1.2.0

Dec 20, 2023

v1.1.0

Dec 20, 2023

v1.0.0

Dec 20, 2023

Changes in this version

+ func AddSimpleMessagesParallel(t *testing.T, messagesCount int, publisher message.Publisher, topicName string, ...) message.Messages

+ func AssertAllMessagesReceived(t *testing.T, sent message.Messages, received message.Messages) bool

+ func AssertMessagesMetadata(t *testing.T, key string, expectedValues map[string]string, ...) bool

+ func AssertMessagesPayloads(t *testing.T, expectedPayloads map[string][]byte, received []*message.Message) bool

+ func BenchSubscriber(b *testing.B, pubSubConstructor BenchmarkPubSubConstructor)

+ func MissingMessages(expected message.Messages, received message.Messages) []string

+ func PublishSimpleMessages(t *testing.T, messagesCount int, publisher message.Publisher, topicName string) message.Messages

+ func RunOnlyFastTests() bool

+ func TestConcurrentClose(t *testing.T, tCtx TestContext, createPubSub PubSubConstructor)

+ func TestConcurrentSubscribe(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestConcurrentSubscribeMultipleTopics(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestConsumerGroups(t *testing.T, tCtx TestContext, ...)

+ func TestContinueAfterErrors(t *testing.T, tCtx TestContext, createPubSub PubSubConstructor)

+ func TestContinueAfterSubscribeClose(t *testing.T, tCtx TestContext, createPubSub PubSubConstructor)

+ func TestMessageCtx(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestNewSubscriberReceivesOldMessages(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestNoAck(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestPubSub(t *testing.T, features Features, pubSubConstructor PubSubConstructor, ...)

+ func TestPubSubStressTest(t *testing.T, features Features, pubSubConstructor PubSubConstructor, ...)

+ func TestPublishSubscribe(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestPublishSubscribeInOrder(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestPublisherClose(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestReconnect(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestResendOnError(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestSubscribeCtx(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ func TestTopic(t *testing.T, tCtx TestContext, pubSubConstructor PubSubConstructor)

+ type BenchmarkPubSubConstructor func(n int) (message.Publisher, message.Subscriber)

+ type ConsumerGroupPubSubConstructor func(t *testing.T, consumerGroup string) (message.Publisher, message.Subscriber)

+ type Features struct

+ ConsumerGroups bool

+ ExactlyOnceDelivery bool

+ GuaranteedOrder bool

+ GuaranteedOrderWithSingleSubscriber bool

+ NewSubscriberReceivesOldMessages bool

+ Persistent bool

+ RequireSingleInstance bool

+ RestartServiceCommand []string

+ type PubSubConstructor func(t *testing.T) (message.Publisher, message.Subscriber)

+ type SimpleMessage struct

+ Num int

+ type TestContext struct

+ Features Features

+ TestID TestID

+ type TestID string

+ func NewTestID() TestID