Documentation
¶
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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConstantDetachment ¶
func ConstantDetachment(remainingArgs []string)
func ConstantDetachmentSender ¶ added in v0.3.3
func ConstantDetachmentSender(remainingArgs []string)
func EmptySessions ¶ added in v1.1.4
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 ¶ added in v0.3.4
func FinitePeeks(remainingArgs []string)
func FiniteSendAndReceiveTest ¶
func FiniteSendAndReceiveTest(remainingArgs []string)
func FiniteSessions ¶ added in v1.1.4
func FiniteSessions(remainingArgs []string)
func IdleFastReconnect ¶ added in v0.3.6
func IdleFastReconnect(remainingArgs []string)
func InfiniteSendAndReceiveRun ¶
func InfiniteSendAndReceiveRun(remainingArgs []string)
func LongRunningRenewLockTest ¶
func LongRunningRenewLockTest(remainingArgs []string)
func MostlyIdleReceiver ¶ added in v0.4.0
func MostlyIdleReceiver(remainingArgs []string)
MostlyIdleReceiver tests that if there are long idle periods that our connection continues to work and receive messages.
func OpenCloseMeasurements ¶ added in v1.6.1
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]
func RapidOpenCloseTest ¶
func RapidOpenCloseTest(remainingArgs []string)
func ReceiveCancellation ¶ added in v0.3.4
func ReceiveCancellation(remainingArgs []string)
func SendAndReceiveDrain ¶ added in v1.0.0
func SendAndReceiveDrain(remainingArgs []string)
Types ¶
This section is empty.
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