testingutils

Documentation

Index

• Variables
• func DecodeMsg(codec sabuhp.Codec, data []byte) (*sabuhp.Message, error)
• func EncodedMsg(codec sabuhp.Codec, topic string, message string, fromAddr string) ([]byte, error)
• func GetWSMessage(t *testing.T, ws *websocket.Conn) ([]byte, error)
• func HttpToWS(t *testing.T, u string) string
• func Msg(topic string, message string, fromAddr string) sabuhp.Message
• func NewTestConn(r io.Reader, w io.Writer, isServer bool) *websocket.Conn
• func NewWSServer(t *testing.T, h http.Handler) (*httptest.Server, *websocket.Conn)
• func NewWSServerOnly(t *testing.T, h http.Handler) (*httptest.Server, string)
• func ReceiveMsg(t *testing.T, ws *websocket.Conn, codec sabuhp.Codec) (*sabuhp.Message, error)
• func ReceiveWSMessage(t *testing.T, ws *websocket.Conn) []byte
• func SendMessage(t *testing.T, ws *websocket.Conn, msg []byte)
• type FakeAddr
  • func (a FakeAddr) Network() string
  • func (a FakeAddr) String() string
• type FakeNetConn
  • func (c FakeNetConn) Close() error
  • func (c FakeNetConn) LocalAddr() net.Addr
  • func (c FakeNetConn) RemoteAddr() net.Addr
  • func (c FakeNetConn) SetDeadline(t time.Time) error
  • func (c FakeNetConn) SetReadDeadline(t time.Time) error
  • func (c FakeNetConn) SetWriteDeadline(t time.Time) error
• type LoggerPub
  • func (l LoggerPub) Log(cb *njson.JSON)
• type NetError
  • func (e *NetError) Error() string
  • func (e *NetError) Temporary() bool
  • func (e *NetError) Timeout() bool
• type NoPubSub
  • func (n NoPubSub) Conn() sabuhp.Conn
  • func (n NoPubSub) Listen(topic string, callback sabuhp.TransportResponse) sabuhp.Channel
  • func (n NoPubSub) SendToAll(message *sabuhp.Message, timeout time.Duration) error
  • func (n NoPubSub) SendToOne(message *sabuhp.Message, timeout time.Duration) error
• type NoPubSubChannel
  • func (n NoPubSubChannel) Close()
  • func (n NoPubSubChannel) Err() error
• type TransportImpl
  • func (t TransportImpl) Conn() sabuhp.Conn
  • func (t TransportImpl) Listen(topic string, handler sabuhp.TransportResponse) sabuhp.Channel
  • func (t TransportImpl) SendToAll(data *sabuhp.Message, timeout time.Duration) error
  • func (t TransportImpl) SendToOne(data *sabuhp.Message, timeout time.Duration) error

Variables

var (
	LocalAddr  = FakeAddr(1)
	RemoteAddr = FakeAddr(2)
)

var (
	ErrWriteTimeout = &NetError{msg: "websocket: write timeout", timeout: true, temporary: true}
)

Functions

func DecodeMsg

func DecodeMsg(codec sabuhp.Codec, data []byte) (*sabuhp.Message, error)

func EncodedMsg

func EncodedMsg(codec sabuhp.Codec, topic string, message string, fromAddr string) ([]byte, error)

func GetWSMessage

func GetWSMessage(t *testing.T, ws *websocket.Conn) ([]byte, error)

func HttpToWS

func HttpToWS(t *testing.T, u string) string

func Msg

func Msg(topic string, message string, fromAddr string) sabuhp.Message

func NewTestConn

func NewTestConn(r io.Reader, w io.Writer, isServer bool) *websocket.Conn

NewTestConn creates a connection backed by a fake network connection using default values for buffering.

func NewWSServer

func NewWSServer(t *testing.T, h http.Handler) (*httptest.Server, *websocket.Conn)

func NewWSServerOnly

func NewWSServerOnly(t *testing.T, h http.Handler) (*httptest.Server, string)

NewWSServerOnly returns websocket http server and url for connecting.

func ReceiveMsg

func ReceiveMsg(t *testing.T, ws *websocket.Conn, codec sabuhp.Codec) (*sabuhp.Message, error)

func ReceiveWSMessage

func ReceiveWSMessage(t *testing.T, ws *websocket.Conn) []byte

func SendMessage

func SendMessage(t *testing.T, ws *websocket.Conn, msg []byte)

Types

type FakeAddr

type FakeAddr int

func (FakeAddr) Network

func (a FakeAddr) Network() string

func (FakeAddr) String

func (a FakeAddr) String() string

type FakeNetConn

type FakeNetConn struct {
	io.Reader
	io.Writer
}

func (FakeNetConn) Close

func (c FakeNetConn) Close() error

func (FakeNetConn) LocalAddr

func (c FakeNetConn) LocalAddr() net.Addr

func (FakeNetConn) RemoteAddr

func (c FakeNetConn) RemoteAddr() net.Addr

func (FakeNetConn) SetDeadline

func (c FakeNetConn) SetDeadline(t time.Time) error

func (FakeNetConn) SetReadDeadline

func (c FakeNetConn) SetReadDeadline(t time.Time) error

func (FakeNetConn) SetWriteDeadline

func (c FakeNetConn) SetWriteDeadline(t time.Time) error

type LoggerPub

type LoggerPub struct{}

func (LoggerPub) Log

func (l LoggerPub) Log(cb *njson.JSON)

type NetError

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

NetError satisfies the net Error interface.

func (*NetError) Error

func (e *NetError) Error() string

func (*NetError) Temporary

func (e *NetError) Temporary() bool

func (*NetError) Timeout

func (e *NetError) Timeout() bool

type NoPubSub

type NoPubSub struct {
	DelegateFunc  func(message *sabuhp.Message, timeout time.Duration) error
	BroadcastFunc func(message *sabuhp.Message, timeout time.Duration) error
	ChannelFunc   func(topic string, callback sabuhp.TransportResponse) sabuhp.Channel
}

func (NoPubSub) Conn

func (n NoPubSub) Conn() sabuhp.Conn

func (NoPubSub) Listen

func (n NoPubSub) Listen(topic string, callback sabuhp.TransportResponse) sabuhp.Channel

func (NoPubSub) SendToAll

func (n NoPubSub) SendToAll(message *sabuhp.Message, timeout time.Duration) error

func (NoPubSub) SendToOne

func (n NoPubSub) SendToOne(message *sabuhp.Message, timeout time.Duration) error

type NoPubSubChannel

type NoPubSubChannel struct {
	Error error
}

func (NoPubSubChannel) Close

func (n NoPubSubChannel) Close()

func (NoPubSubChannel) Err

func (n NoPubSubChannel) Err() error

type TransportImpl

type TransportImpl struct {
	ConnFunc      func() sabuhp.Conn
	SendToOneFunc func(data *sabuhp.Message, timeout time.Duration) error
	SendToAllFunc func(data *sabuhp.Message, timeout time.Duration) error
	ListenFunc    func(topic string, handler sabuhp.TransportResponse) sabuhp.Channel
}

func (TransportImpl) Conn

func (t TransportImpl) Conn() sabuhp.Conn

func (TransportImpl) Listen

func (t TransportImpl) Listen(topic string, handler sabuhp.TransportResponse) sabuhp.Channel

func (TransportImpl) SendToAll

func (t TransportImpl) SendToAll(data *sabuhp.Message, timeout time.Duration) error

func (TransportImpl) SendToOne

func (t TransportImpl) SendToOne(data *sabuhp.Message, timeout time.Duration) error