MCPcopy Create free account

hub / github.com/armon/relay / functions

Functions134 in github.com/armon/relay

FunctionTestCustomRoutingKey
(t *testing.T)
relay_test.go:690
FunctionTestDoubleConsume
(t *testing.T)
relay_test.go:478
FunctionTestExchangeType_Fanout
(t *testing.T)
relay_test.go:787
FunctionTestExclusiveQueue
(t *testing.T)
relay_test.go:739
FunctionTestGOBSerializer
(t *testing.T)
serialization_test.go:10
FunctionTestInmemBroker
(t *testing.T)
inmem/inmem_test.go:10
FunctionTestIsDecodeFailure
(t *testing.T)
relay_test.go:678
FunctionTestJSONSerializer
(t *testing.T)
serialization_test.go:43
FunctionTestMessageExpires
(t *testing.T)
relay_test.go:584
FunctionTestMultiConsume
(t *testing.T)
relay_test.go:218
FunctionTestNoHost
(t *testing.T)
relay_test.go:562
FunctionTestPriorityQueue
(t *testing.T)
pq/pq_test.go:12
FunctionTestPriorityQueueConsume
(t *testing.T)
pq/pq_test.go:160
FunctionTestPriorityQueueConsumer
(t *testing.T)
pq/pq_test.go:75
FunctionTestPriorityQueueInterrupt
(t *testing.T)
pq/pq_test.go:280
FunctionTestPriorityQueueMinQuietPeriod
(t *testing.T)
pq/pq_test.go:251
FunctionTestPriorityQueuePublishConsume
(t *testing.T)
pq/pq_test.go:38
FunctionTestPriorityQueuePublisher
(t *testing.T)
pq/pq_test.go:99
FunctionTestPriorityQueueQuietPeriod
(t *testing.T)
pq/pq_test.go:200
FunctionTestPriorityQueueShutdown
(t *testing.T)
pq/pq_test.go:129
FunctionTestPublishNoConfirm
(t *testing.T)
relay_test.go:119
FunctionTestPublishNoPersist
(t *testing.T)
relay_test.go:132
FunctionTestPublisherMultiClose
(t *testing.T)
relay_test.go:196
FunctionTestPublisherThreadSafety
(t *testing.T)
relay_test.go:859
FunctionTestQueueName
(t *testing.T)
util_test.go:7
FunctionTestQueueTTL
(t *testing.T)
relay_test.go:647
FunctionTestRelayMultiClose
(t *testing.T)
relay_test.go:158
FunctionTestRetryBroker
(t *testing.T)
retry_test.go:17
FunctionTestRetryBrokerInteg
(t *testing.T)
retry_test.go:129
FunctionTestRetryBroker_BadConfig
(t *testing.T)
retry_test.go:40
FunctionTestRetryBroker_Consumer
(t *testing.T)
retry_test.go:67
FunctionTestRetryBroker_Publisher
(t *testing.T)
retry_test.go:98
FunctionTestRetryBroker_implements
(t *testing.T)
retry_test.go:13
FunctionTestSimplePublishConsume
(t *testing.T)
relay_test.go:106
← previous101–134 of 134, ranked by callers