infrastructure

Documentation

Index

• func AddSimpleMessages(t *testing.T, messagesCount int, publisher message.Publisher, topicName string) message.Messages
• func AddSimpleMessagesParallel(t *testing.T, messagesCount int, publisher message.Publisher, topicName string, ...) message.Messages
• func BenchSubscriber(b *testing.B, pubSubConstructor BenchmarkPubSubConstructor)
• func RunOnlyFastTests() bool
• func TestConcurrentClose(t *testing.T, createPubSub PubSubConstructor, features Features)
• func TestConsumerGroups(t *testing.T, pubSubConstructor ConsumerGroupPubSubConstructor, ...)
• func TestContinueAfterErrors(t *testing.T, createPubSub PubSubConstructor, features Features)
• func TestContinueAfterSubscribeClose(t *testing.T, createPubSub PubSubConstructor, features Features)
• func TestMessageCtx(t *testing.T, pubSub PubSub, features Features)
• func TestNoAck(t *testing.T, pubSub PubSub, features Features)
• func TestNoGroupSubscriber(t *testing.T, 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, pubSub PubSub, features Features)
• func TestPublishSubscribeInOrder(t *testing.T, pubSub PubSub, features Features)
• func TestPublisherClose(t *testing.T, pubSub PubSub, features Features)
• func TestReconnect(t *testing.T, pubSub PubSub, features Features)
• func TestResendOnError(t *testing.T, pubSub PubSub, features Features)
• func TestSubscribeCtx(t *testing.T, pubSub PubSub, features Features)
• func TestTopic(t *testing.T, pubSub PubSub, features Features)
• type BenchmarkPubSubConstructor
• type ConsumerGroupPubSubConstructor
• type Features
• type NoGroupSubscriberConstructor
• type PubSub
• type PubSubConstructor
• type SimpleMessage

Functions

func AddSimpleMessages

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

func AddSimpleMessagesParallel

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

func BenchSubscriber

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

func RunOnlyFastTests

func RunOnlyFastTests() bool

RunOnlyFastTests returns true if -short flag was provided -race was not provided. Useful for excluding some slow tests.

func TestConcurrentClose

func TestConcurrentClose(t *testing.T, createPubSub PubSubConstructor, features Features)

func TestConsumerGroups

func TestConsumerGroups(t *testing.T, pubSubConstructor ConsumerGroupPubSubConstructor, features Features)

func TestContinueAfterErrors

func TestContinueAfterErrors(t *testing.T, createPubSub PubSubConstructor, features Features)

func TestContinueAfterSubscribeClose

func TestContinueAfterSubscribeClose(t *testing.T, createPubSub PubSubConstructor, features Features)

TestContinueAfterSubscribeClose checks, that we don't lose messages after closing subscriber.

func TestMessageCtx

func TestMessageCtx(t *testing.T, pubSub PubSub, features Features)

func TestNoAck

func TestNoAck(t *testing.T, pubSub PubSub, features Features)

func TestNoGroupSubscriber

func TestNoGroupSubscriber(
	t *testing.T,
	pubSubConstructor PubSubConstructor,
	noGroupSubscriberConstructor NoGroupSubscriberConstructor,
)

func TestPubSub

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

func TestPubSubStressTest

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

func TestPublishSubscribe

func TestPublishSubscribe(t *testing.T, pubSub PubSub, features Features)

func TestPublishSubscribeInOrder

func TestPublishSubscribeInOrder(t *testing.T, pubSub PubSub, features Features)

func TestPublisherClose

func TestPublisherClose(t *testing.T, pubSub PubSub, features Features)

TestPublisherClose sends big amount of messages and them run close to ensure that messages are not lost during adding.

func TestReconnect

func TestReconnect(t *testing.T, pubSub PubSub, features Features)

func TestResendOnError

func TestResendOnError(t *testing.T, pubSub PubSub, features Features)

func TestSubscribeCtx

func TestSubscribeCtx(t *testing.T, pubSub PubSub, features Features)

func TestTopic

func TestTopic(t *testing.T, pubSub PubSub, features Features)

Types

type BenchmarkPubSubConstructor

type BenchmarkPubSubConstructor func(n int) message.PubSub

type ConsumerGroupPubSubConstructor

type ConsumerGroupPubSubConstructor func(t *testing.T, consumerGroup string) PubSub

type Features

type Features struct {
	ConsumerGroups      bool
	ExactlyOnceDelivery bool
	GuaranteedOrder     bool
	Persistent          bool

	RestartServiceCommand []string
}

type NoGroupSubscriberConstructor

type NoGroupSubscriberConstructor func(t *testing.T) message.Subscriber

type PubSub

type PubSub interface {
	message.PubSub

	// Subscriber is needed for unwrapped message.PubSub's subscriber, containing SubscribeInitializer.
	Subscriber() message.Subscriber
}

type PubSubConstructor

type PubSubConstructor func(t *testing.T) PubSub

type SimpleMessage

type SimpleMessage struct {
	Num int `json:"num"`
}