test

package
v2.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 28, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewName

func NewName() string

Types

type QueueSuite

type QueueSuite struct {
	suite.Suite

	TxNotSupported bool
	BrokerURI      string

	Broker mq.Broker
	// contains filtered or unexported fields
}

func (*QueueSuite) SetupTest

func (s *QueueSuite) SetupTest()

func (*QueueSuite) TearDownTest

func (s *QueueSuite) TearDownTest()

func (*QueueSuite) TestConcurrent

func (s *QueueSuite) TestConcurrent()

func (*QueueSuite) TestConsume_empty

func (s *QueueSuite) TestConsume_empty()

func (*QueueSuite) TestConsumersCanShareJobIteratorConcurrently

func (s *QueueSuite) TestConsumersCanShareJobIteratorConcurrently()

func (*QueueSuite) TestDelayed

func (s *QueueSuite) TestDelayed()

func (*QueueSuite) TestJobIter_Next_closed

func (s *QueueSuite) TestJobIter_Next_closed()

func (*QueueSuite) TestJobIter_Next_empty

func (s *QueueSuite) TestJobIter_Next_empty()

func (*QueueSuite) TestJob_Reject_no_requeue

func (s *QueueSuite) TestJob_Reject_no_requeue()

func (*QueueSuite) TestJob_Reject_requeue

func (s *QueueSuite) TestJob_Reject_requeue()

func (*QueueSuite) TestPublishAndConsume_immediate_ack

func (s *QueueSuite) TestPublishAndConsume_immediate_ack()

func (*QueueSuite) TestPublishDelayed_empty

func (s *QueueSuite) TestPublishDelayed_empty()

func (*QueueSuite) TestPublishDelayed_nil

func (s *QueueSuite) TestPublishDelayed_nil()

func (*QueueSuite) TestPublish_empty

func (s *QueueSuite) TestPublish_empty()

func (*QueueSuite) TestPublish_nil

func (s *QueueSuite) TestPublish_nil()

func (*QueueSuite) TestRetryQueue

func (s *QueueSuite) TestRetryQueue()

func (*QueueSuite) TestTransaction

func (s *QueueSuite) TestTransaction()

func (*QueueSuite) TestTransaction_Error

func (s *QueueSuite) TestTransaction_Error()

func (*QueueSuite) TestTransaction_not_supported

func (s *QueueSuite) TestTransaction_not_supported()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL