mocks

Documentation

Index

• type MockConn
  • func NewMockConn(ctrl *gomock.Controller) *MockConn
  • func (_m *MockConn) Close()
  • func (_m *MockConn) CloseWithError(_param0 *gonatsd.NATSError)
  • func (_m *MockConn) Closed() bool
  • func (_m *MockConn) EXPECT() *_MockConnRecorder
  • func (_m *MockConn) HeartbeatHelper() gonatsd.HeartbeatHelper
  • func (_m *MockConn) Options() *gonatsd.ConnOptions
  • func (_m *MockConn) Read(_param0 []byte) (int, error)
  • func (_m *MockConn) ReadControlLine() (string, error)
  • func (_m *MockConn) RemoteAddr() net.Addr
  • func (_m *MockConn) SendServerCmd(_param0 gonatsd.ServerCmd)
  • func (_m *MockConn) ServeCommand(_param0 gonatsd.ClientCmd)
  • func (_m *MockConn) ServeMessage(_param0 *gonatsd.SubscribedMessage)
  • func (_m *MockConn) ServeRequest(_param0 gonatsd.Request)
  • func (_m *MockConn) Server() gonatsd.Server
  • func (_m *MockConn) Start()
  • func (_m *MockConn) Subscriptions() map[int]*gonatsd.Subscription
  • func (_m *MockConn) Write(_param0 *gonatsd.Response)
• type MockHeartbeatHelper
  • func NewMockHeartbeatHelper(ctrl *gomock.Controller) *MockHeartbeatHelper
  • func (_m *MockHeartbeatHelper) EXPECT() *_MockHeartbeatHelperRecorder
  • func (_m *MockHeartbeatHelper) Ping()
  • func (_m *MockHeartbeatHelper) Pong()
  • func (_m *MockHeartbeatHelper) Stop()
  • func (_m *MockHeartbeatHelper) Ticker() <-chan time.Time
• type MockServer
  • func NewMockServer(ctrl *gomock.Controller) *MockServer
  • func (_m *MockServer) Commands() chan<- gonatsd.ServerCmd
  • func (_m *MockServer) Config() *gonatsd.Config
  • func (_m *MockServer) DeliverMessage(_param0 *gonatsd.Subscription, _param1 *gonatsd.Message)
  • func (_m *MockServer) EXPECT() *_MockServerRecorder
  • func (_m *MockServer) Info() *[]byte
  • func (_m *MockServer) Start()
  • func (_m *MockServer) Stats() *gonatsd.Stats
  • func (_m *MockServer) Subscriptions() *gonatsd.Trie

Types

type MockConn

type MockConn struct {
	// contains filtered or unexported fields
}

Mock of Conn interface

func NewMockConn

func NewMockConn(ctrl *gomock.Controller) *MockConn

func (*MockConn) Close

func (_m *MockConn) Close()

func (*MockConn) CloseWithError

func (_m *MockConn) CloseWithError(_param0 *gonatsd.NATSError)

func (*MockConn) Closed

func (_m *MockConn) Closed() bool

func (*MockConn) EXPECT

func (_m *MockConn) EXPECT() *_MockConnRecorder

func (*MockConn) HeartbeatHelper

func (_m *MockConn) HeartbeatHelper() gonatsd.HeartbeatHelper

func (*MockConn) Options

func (_m *MockConn) Options() *gonatsd.ConnOptions

func (*MockConn) Read

func (_m *MockConn) Read(_param0 []byte) (int, error)

func (*MockConn) ReadControlLine

func (_m *MockConn) ReadControlLine() (string, error)

func (*MockConn) RemoteAddr

func (_m *MockConn) RemoteAddr() net.Addr

func (*MockConn) SendServerCmd

func (_m *MockConn) SendServerCmd(_param0 gonatsd.ServerCmd)

func (*MockConn) ServeCommand

func (_m *MockConn) ServeCommand(_param0 gonatsd.ClientCmd)

func (*MockConn) ServeMessage

func (_m *MockConn) ServeMessage(_param0 *gonatsd.SubscribedMessage)

func (*MockConn) ServeRequest

func (_m *MockConn) ServeRequest(_param0 gonatsd.Request)

func (*MockConn) Server

func (_m *MockConn) Server() gonatsd.Server

func (*MockConn) Start

func (_m *MockConn) Start()

func (*MockConn) Subscriptions

func (_m *MockConn) Subscriptions() map[int]*gonatsd.Subscription

func (*MockConn) Write

func (_m *MockConn) Write(_param0 *gonatsd.Response)

type MockHeartbeatHelper

type MockHeartbeatHelper struct {
	// contains filtered or unexported fields
}

Mock of HeartbeatHelper interface

func NewMockHeartbeatHelper

func NewMockHeartbeatHelper(ctrl *gomock.Controller) *MockHeartbeatHelper

func (*MockHeartbeatHelper) EXPECT

func (_m *MockHeartbeatHelper) EXPECT() *_MockHeartbeatHelperRecorder

func (*MockHeartbeatHelper) Ping

func (_m *MockHeartbeatHelper) Ping()

func (*MockHeartbeatHelper) Pong

func (_m *MockHeartbeatHelper) Pong()

func (*MockHeartbeatHelper) Stop

func (_m *MockHeartbeatHelper) Stop()

func (*MockHeartbeatHelper) Ticker

func (_m *MockHeartbeatHelper) Ticker() <-chan time.Time

type MockServer

type MockServer struct {
	// contains filtered or unexported fields
}

Mock of Server interface

func NewMockServer

func NewMockServer(ctrl *gomock.Controller) *MockServer

func (*MockServer) Commands

func (_m *MockServer) Commands() chan<- gonatsd.ServerCmd

func (*MockServer) Config

func (_m *MockServer) Config() *gonatsd.Config

func (*MockServer) DeliverMessage

func (_m *MockServer) DeliverMessage(_param0 *gonatsd.Subscription, _param1 *gonatsd.Message)

func (*MockServer) EXPECT

func (_m *MockServer) EXPECT() *_MockServerRecorder

func (*MockServer) Info

func (_m *MockServer) Info() *[]byte

func (*MockServer) Start

func (_m *MockServer) Start()

func (*MockServer) Stats

func (_m *MockServer) Stats() *gonatsd.Stats

func (*MockServer) Subscriptions

func (_m *MockServer) Subscriptions() *gonatsd.Trie