tests

Documentation

Index

• 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]interface{}, ...) bool
• func MissingMessages(expected message.Messages, received message.Messages) []string

Functions

func AssertAllMessagesReceived

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

func AssertMessagesMetadata

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

func AssertMessagesPayloads

func AssertMessagesPayloads(
	t *testing.T,
	expectedPayloads map[string]interface{},
	received []*message.Message,
) bool

func MissingMessages

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