infrastructure

Documentation

Index

• func BenchSubscriber(b *testing.B, pubSubConstructor BenchmarkPubSubConstructor)
• 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, ...)
• type BenchmarkPubSubConstructor
• type ConsumerGroupPubSubConstructor
• type Features
• type NoGroupSubscriberConstructor
• type PubSubConstructor
• type SimpleMessage

Functions

func BenchSubscriber

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

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,
)

Types

type BenchmarkPubSubConstructor

type BenchmarkPubSubConstructor func(n int) message.PubSub

type ConsumerGroupPubSubConstructor

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

type Features

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

	// RequireSingleInstance should be true,
	// if subscriber doesn't use external storage and to work publisher and subscriber needs to be one instance.
	RequireSingleInstance bool
}

type NoGroupSubscriberConstructor

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

type PubSubConstructor

type PubSubConstructor func(t *testing.T) message.PubSub

type SimpleMessage

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