mock

Documentation

Index

• func NewBrokerMockError() rabbitmq.BrokerInterface
• func NewBrokerMockOk() rabbitmq.BrokerInterface
• func NewCentrifugoTransportStatusOk() *http.Client
• type BrokerMockError
  • func (b *BrokerMockError) Publish(topic string, msg proto.Message, h amqp.Table) error
  • func (b *BrokerMockError) RegisterSubscriber(topic string, fn interface{}) error
  • func (b *BrokerMockError) SetExchangeName(name string)
  • func (b *BrokerMockError) Subscribe(exit chan bool) error
• type BrokerMockOk
  • func (b *BrokerMockOk) Publish(topic string, msg proto.Message, h amqp.Table) error
  • func (b *BrokerMockOk) RegisterSubscriber(topic string, fn interface{}) error
  • func (b *BrokerMockOk) SetExchangeName(name string)
  • func (b *BrokerMockOk) Subscribe(exit chan bool) error
• type CentrifugoTransportStatusOk
  • func (h *CentrifugoTransportStatusOk) RoundTrip(req *http.Request) (*http.Response, error)

Functions

func NewBrokerMockError

func NewBrokerMockError() rabbitmq.BrokerInterface

func NewBrokerMockOk

func NewBrokerMockOk() rabbitmq.BrokerInterface

func NewCentrifugoTransportStatusOk

func NewCentrifugoTransportStatusOk() *http.Client

Types

type BrokerMockError

type BrokerMockError struct{}

func (*BrokerMockError) Publish

func (b *BrokerMockError) Publish(topic string, msg proto.Message, h amqp.Table) error

func (*BrokerMockError) RegisterSubscriber

func (b *BrokerMockError) RegisterSubscriber(topic string, fn interface{}) error

func (*BrokerMockError) SetExchangeName

func (b *BrokerMockError) SetExchangeName(name string)

func (*BrokerMockError) Subscribe

func (b *BrokerMockError) Subscribe(exit chan bool) error

type BrokerMockOk

type BrokerMockOk struct{}

func (*BrokerMockOk) Publish

func (b *BrokerMockOk) Publish(topic string, msg proto.Message, h amqp.Table) error

func (*BrokerMockOk) RegisterSubscriber

func (b *BrokerMockOk) RegisterSubscriber(topic string, fn interface{}) error

func (*BrokerMockOk) SetExchangeName

func (b *BrokerMockOk) SetExchangeName(name string)

func (*BrokerMockOk) Subscribe

func (b *BrokerMockOk) Subscribe(exit chan bool) error

type CentrifugoTransportStatusOk

type CentrifugoTransportStatusOk struct {
	Transport http.RoundTripper
	Msg       map[string]interface{}
}

func (*CentrifugoTransportStatusOk) RoundTrip

func (h *CentrifugoTransportStatusOk) RoundTrip(req *http.Request) (*http.Response, error)