testing

Documentation

Overview

Package testing contains simple test implementations of some broker interfaces.

Index

• type TestBrokerConfig
  • func (tbc *TestBrokerConfig) BrokerQueueSize() uint
  • func (tbc *TestBrokerConfig) SessionQueueSize() uint
• type TestBrokerSession
  • func (tbs *TestBrokerSession) DeviceIdentifier() string
  • func (tbs *TestBrokerSession) ExchangeScratchArea() *broker.ExchangesScratchArea
  • func (tbs *TestBrokerSession) Levels() broker.LevelsMap
  • func (tbs *TestBrokerSession) SessionChannel() <-chan broker.Exchange

Types

type TestBrokerConfig

type TestBrokerConfig struct {
	ConfigSessionQueueSize uint
	ConfigBrokerQueueSize  uint
}

Test implementation of BrokerConfig.

func (*TestBrokerConfig) BrokerQueueSize

func (tbc *TestBrokerConfig) BrokerQueueSize() uint

func (*TestBrokerConfig) SessionQueueSize

func (tbc *TestBrokerConfig) SessionQueueSize() uint

type TestBrokerSession

type TestBrokerSession struct {
	DeviceId  string
	Exchanges chan broker.Exchange
	LevelsMap broker.LevelsMap
	// contains filtered or unexported fields
}

Test implementation of BrokerSession.

func (*TestBrokerSession) DeviceIdentifier

func (tbs *TestBrokerSession) DeviceIdentifier() string

func (*TestBrokerSession) ExchangeScratchArea

func (tbs *TestBrokerSession) ExchangeScratchArea() *broker.ExchangesScratchArea

func (*TestBrokerSession) Levels

func (tbs *TestBrokerSession) Levels() broker.LevelsMap

func (*TestBrokerSession) SessionChannel

func (tbs *TestBrokerSession) SessionChannel() <-chan broker.Exchange