test

Documentation

Index

• func NewName() string
• type QueueSuite
  • func (s *QueueSuite) SetupTest()
  • func (s *QueueSuite) TearDownTest()
  • func (s *QueueSuite) TestConcurrent()
  • func (s *QueueSuite) TestConsume_empty()
  • func (s *QueueSuite) TestConsumersCanShareJobIteratorConcurrently()
  • func (s *QueueSuite) TestDelayed()
  • func (s *QueueSuite) TestJobIter_Next_closed()
  • func (s *QueueSuite) TestJobIter_Next_empty()
  • func (s *QueueSuite) TestJob_Reject_no_requeue()
  • func (s *QueueSuite) TestJob_Reject_requeue()
  • func (s *QueueSuite) TestPublishAndConsume_immediate_ack()
  • func (s *QueueSuite) TestPublishDelayed_empty()
  • func (s *QueueSuite) TestPublishDelayed_nil()
  • func (s *QueueSuite) TestPublish_empty()
  • func (s *QueueSuite) TestPublish_nil()
  • func (s *QueueSuite) TestRetryQueue()
  • func (s *QueueSuite) TestTransaction()
  • func (s *QueueSuite) TestTransaction_Error()
  • func (s *QueueSuite) TestTransaction_not_supported()

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()