test

Documentation

Index

• Constants
• Variables
• func CaptureLogsForTest(echo bool) func() []string
• func CaptureLogsForTestWithChannel(messagesCh chan string, echo bool) func() []string
• func CreateExpiringQueue(t *testing.T, qd *atom.QueueDescription) (string, func())
• func EnableStdoutLogging(t *testing.T)
• func GetConnectionString(t *testing.T) string
• func GetConnectionStringForPremiumSB(t *testing.T) string
• func GetConnectionStringListenOnly(t *testing.T) string
• func GetConnectionStringSendOnly(t *testing.T) string
• func GetConnectionStringWithoutManagePerms(t *testing.T) string
• func GetIdentityVars(t *testing.T) ...
• func MustAMQPUUID() amqp.UUID
• func RandomString(prefix string, length int) string
• func RequireClose(t *testing.T, closeable interface{ ... })
• func RequireLinksClose(t *testing.T, closeable interface{ ... })
• func RequireNSClose(t *testing.T, closeable interface{ ... })

Constants

const (
	BuiltInTestQueue             = "testQueue"
	BuildInTestQueueWithSessions = "testQueueWithSessions"
)

these are created by the test-resources.bicep template - they're useful for tests where we don't need to guaranteee any state, just existence, like our connectivity/recovery tests.

Variables

var LoggingChannelValue atomic.Value

Functions

func CaptureLogsForTest

func CaptureLogsForTest(echo bool) func() []string

CaptureLogsForTest adds a logging listener which captures messages to an internal channel. Returns a function that ends log capturing and returns any captured messages. It's safe to call endCapture() multiple times, so a simple call pattern is:

endCapture := CaptureLogsForTest()
defer endCapture()				// ensure cleanup in case of test assert failures

/* some test code */

messages := endCapture()
/* do inspection of log messages */

func CaptureLogsForTestWithChannel

func CaptureLogsForTestWithChannel(messagesCh chan string, echo bool) func() []string

func CreateExpiringQueue

func CreateExpiringQueue(t *testing.T, qd *atom.QueueDescription) (string, func())

func EnableStdoutLogging

func EnableStdoutLogging(t *testing.T)

EnableStdoutLogging turns on logging to stdout for diagnostics.

func GetConnectionString

func GetConnectionString(t *testing.T) string

func GetConnectionStringForPremiumSB

func GetConnectionStringForPremiumSB(t *testing.T) string

func GetConnectionStringListenOnly

func GetConnectionStringListenOnly(t *testing.T) string

func GetConnectionStringSendOnly

func GetConnectionStringSendOnly(t *testing.T) string

func GetConnectionStringWithoutManagePerms

func GetConnectionStringWithoutManagePerms(t *testing.T) string

func GetIdentityVars

func GetIdentityVars(t *testing.T) *struct {
	TenantID string
	ClientID string
	Secret   string
	Endpoint string
}

func MustAMQPUUID

func MustAMQPUUID() amqp.UUID

func RandomString

func RandomString(prefix string, length int) string

RandomString generates a random string with prefix

func RequireClose

func RequireClose(t *testing.T, closeable interface {
	Close(ctx context.Context) error
})

func RequireLinksClose

func RequireLinksClose(t *testing.T, closeable interface {
	Close(ctx context.Context, permanent bool) error
})

func RequireNSClose

func RequireNSClose(t *testing.T, closeable interface {
	Close(permanent bool) error
})