testingutils

package

v0.6.3 Latest Latest Go to latest Published: Jun 26, 2021 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ewe-studios/sabuhp

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func DecodeMsg(codec sabuhp.Codec, data []byte) (sabuhp.Message, error)
func EncodedMsg(codec sabuhp.Codec, topic sabuhp.Topic, 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 sabuhp.Topic, 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 SubChannel
- func (s SubChannel) Close()
- func (s SubChannel) Err() error
- func (s SubChannel) Group() string
- func (s SubChannel) Topic() string
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

Constants ¶

This section is empty.

Variables ¶

View Source

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

View Source

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 sabuhp.Topic, 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 sabuhp.Topic, 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 SubChannel ¶

type SubChannel struct {
	T       string
	G       string
	Handler sabuhp.TransportResponse
}

func (SubChannel) Close ¶

func (s SubChannel) Close()

func (SubChannel) Err ¶

func (s SubChannel) Err() error

func (SubChannel) Group ¶

func (s SubChannel) Group() string

func (SubChannel) Topic ¶

func (s SubChannel) Topic() string

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL