testsuite

Documentation

Overview

Package testsuite contains a common test suite for brokers.

Index

• type CommonBrokerSuite
  • func (s *CommonBrokerSuite) SetUpTest(c *C)
  • func (s *CommonBrokerSuite) TestBroadcast(c *C)
  • func (s *CommonBrokerSuite) TestBroadcastFail(c *C)
  • func (s *CommonBrokerSuite) TestGetAndDrop(c *C)
  • func (s *CommonBrokerSuite) TestGetAndDropErrors(c *C)
  • func (s *CommonBrokerSuite) TestRegistration(c *C)
  • func (s *CommonBrokerSuite) TestRegistrationBrokenLevels(c *C)
  • func (s *CommonBrokerSuite) TestRegistrationFeedPending(c *C)
  • func (s *CommonBrokerSuite) TestRegistrationFeedPendingError(c *C)
  • func (s *CommonBrokerSuite) TestRegistrationInfoErrors(c *C)
  • func (s *CommonBrokerSuite) TestRegistrationLastWins(c *C)
  • func (s *CommonBrokerSuite) TestSanity(c *C)
  • func (s *CommonBrokerSuite) TestSessionFeed(c *C)
  • func (s *CommonBrokerSuite) TestStartStop(c *C)
  • func (s *CommonBrokerSuite) TestUnicast(c *C)
• type FullBroker

Types

type CommonBrokerSuite

type CommonBrokerSuite struct {
	// Build the broker for testing.
	MakeBroker func(store.PendingStore, broker.BrokerConfig, logger.Logger) FullBroker
	// Build a session tracker for testing.
	MakeTracker func(sessionId string) broker.SessionTracker
	// Let us get to a session under the broker.
	RevealSession func(broker.Broker, string) broker.BrokerSession
	// Let us get to a broker.BroadcastExchange from an Exchange.
	RevealBroadcastExchange func(broker.Exchange) *broker.BroadcastExchange
	// Let us get to a broker.UnicastExchange from an Exchange.
	RevealUnicastExchange func(broker.Exchange) *broker.UnicastExchange
	// contains filtered or unexported fields
}

The common brokers' test suite.

func (*CommonBrokerSuite) SetUpTest

func (s *CommonBrokerSuite) SetUpTest(c *C)

func (*CommonBrokerSuite) TestBroadcast

func (s *CommonBrokerSuite) TestBroadcast(c *C)

func (*CommonBrokerSuite) TestBroadcastFail

func (s *CommonBrokerSuite) TestBroadcastFail(c *C)

func (*CommonBrokerSuite) TestGetAndDrop

func (s *CommonBrokerSuite) TestGetAndDrop(c *C)

func (*CommonBrokerSuite) TestGetAndDropErrors

func (s *CommonBrokerSuite) TestGetAndDropErrors(c *C)

func (*CommonBrokerSuite) TestRegistration

func (s *CommonBrokerSuite) TestRegistration(c *C)

func (*CommonBrokerSuite) TestRegistrationBrokenLevels

func (s *CommonBrokerSuite) TestRegistrationBrokenLevels(c *C)

func (*CommonBrokerSuite) TestRegistrationFeedPending

func (s *CommonBrokerSuite) TestRegistrationFeedPending(c *C)

func (*CommonBrokerSuite) TestRegistrationFeedPendingError

func (s *CommonBrokerSuite) TestRegistrationFeedPendingError(c *C)

func (*CommonBrokerSuite) TestRegistrationInfoErrors

func (s *CommonBrokerSuite) TestRegistrationInfoErrors(c *C)

func (*CommonBrokerSuite) TestRegistrationLastWins

func (s *CommonBrokerSuite) TestRegistrationLastWins(c *C)

func (*CommonBrokerSuite) TestSanity

func (s *CommonBrokerSuite) TestSanity(c *C)

func (*CommonBrokerSuite) TestSessionFeed

func (s *CommonBrokerSuite) TestSessionFeed(c *C)

func (*CommonBrokerSuite) TestStartStop

func (s *CommonBrokerSuite) TestStartStop(c *C)

func (*CommonBrokerSuite) TestUnicast

func (s *CommonBrokerSuite) TestUnicast(c *C)

type FullBroker

type FullBroker interface {
	broker.Broker
	broker.BrokerSending
	Start()
	Stop()
	Running() bool
}

The expected interface for tested brokers.