package tests

import "github.com/Azure/azure-sdk-for-go/sdk/messaging/azservicebus/internal/stress/tests"

Index ¶

• func ConstantDetachment(remainingArgs []string)
• func ConstantDetachmentSender(remainingArgs []string)
• func EmptySessions(remainingArgs []string)
• func FinitePeeks(remainingArgs []string)
• func FiniteSendAndReceiveTest(remainingArgs []string)
• func FiniteSessions(remainingArgs []string)
• func IdleFastReconnect(remainingArgs []string)
• func InfiniteSendAndReceiveRun(remainingArgs []string)
• func LongRunningRenewLockTest(remainingArgs []string)
• func MostlyIdleReceiver(remainingArgs []string)
• func OpenCloseMeasurements(remainingArgs []string)
• func RapidOpenCloseTest(remainingArgs []string)
• func ReceiveCancellation(remainingArgs []string)
• func Run(remainingArgs []string)
• func SendAndReceiveDrain(remainingArgs []string)

Functions ¶

func ConstantDetachment ¶

func ConstantDetachment(remainingArgs []string)

func ConstantDetachmentSender ¶

func ConstantDetachmentSender(remainingArgs []string)

func EmptySessions ¶

func EmptySessions(remainingArgs []string)

EmptySessions attempts to get the next available session from a session-enabled subscription that has no available sessions. This makes sure the server-enforced timeout works properly in our code over a long period of time.

func FinitePeeks ¶

func FinitePeeks(remainingArgs []string)

func FiniteSendAndReceiveTest ¶

func FiniteSendAndReceiveTest(remainingArgs []string)

func FiniteSessions ¶

func FiniteSessions(remainingArgs []string)

func IdleFastReconnect ¶

func IdleFastReconnect(remainingArgs []string)

func InfiniteSendAndReceiveRun ¶

func InfiniteSendAndReceiveRun(remainingArgs []string)

func LongRunningRenewLockTest ¶

func LongRunningRenewLockTest(remainingArgs []string)

func MostlyIdleReceiver ¶

func MostlyIdleReceiver(remainingArgs []string)

MostlyIdleReceiver tests that if there are long idle periods that our connection continues to work and receive messages.

func OpenCloseMeasurements ¶

func OpenCloseMeasurements(remainingArgs []string)

OpenCloseMeasurements tests that we are able to consistently open and close our links and connections in a timely way. This test doesn't immediately fail, it's primary purpose is just to provide historical and measurable data on our performance.

The origin of this test was a bug we found in go-amqp where, if the frame was too small, it wouldn't parse and return it until we received more data (any data, just so long as it caused our total local buffer to exceed 8 bytes) [PR#320]

PR#320: https://github.com/Azure/go-amqp/pull/320

func RapidOpenCloseTest ¶

func RapidOpenCloseTest(remainingArgs []string)

func ReceiveCancellation ¶

func ReceiveCancellation(remainingArgs []string)

func Run ¶

func Run(remainingArgs []string)

func SendAndReceiveDrain ¶

func SendAndReceiveDrain(remainingArgs []string)

Source Files ¶

constant_detachment.go constant_detachment_sender.go empty_sessions.go finite_peeks.go finite_send_and_receive.go finite_sessions.go idle_fast_reconnect.go infinite_send_and_receive.go long_running_renew_lock.go mostly_idle_receiver.go open_close_measurements.go rapid_open_close.go receive_cancellation.go send_and_receive_drain.go tests.go

Directories ¶