wsmapper

README

goWsMapper

WebSocket (gorilla-based) client with JSON routing

Documentation

Index

• func GzipDecode(in []byte) ([]byte, error)
• type Client
  • func Dial(ctx context.Context, url string, mapper TypeMapper, errorHandler func(WsError)) (*Client, error)
  • func (c *Client) Send(data []byte) error
  • func (c *Client) Stop()
• type TypeMapper
  • func NewTypeMapper() *TypeMapper
  • func NewTypeMapperWithDefault(defaultHandler func([]byte)) *TypeMapper
  • func (m *TypeMapper) RegisterProcessors(matchers ...*TypeMatcher)
  • func (m *TypeMapper) Route(JSON []byte) error
• type TypeMatcher
  • func NewTypeMatcher(callback, validator interface{}) *TypeMatcher
• type WsError
  • func (err *WsError) Error() string
• type WsErrorCode

Functions

func GzipDecode

func GzipDecode(in []byte) ([]byte, error)

Types

type Client

type Client struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func Dial

func Dial(ctx context.Context, url string, mapper TypeMapper, errorHandler func(WsError)) (*Client, error)

func (*Client) Send

func (c *Client) Send(data []byte) error

func (*Client) Stop

func (c *Client) Stop()

type TypeMapper

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

func NewTypeMapper

func NewTypeMapper() *TypeMapper

func NewTypeMapperWithDefault

func NewTypeMapperWithDefault(defaultHandler func([]byte)) *TypeMapper

func (*TypeMapper) RegisterProcessors

func (m *TypeMapper) RegisterProcessors(matchers ...*TypeMatcher)

func (*TypeMapper) Route

func (m *TypeMapper) Route(JSON []byte) error

type TypeMatcher

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

func NewTypeMatcher

func NewTypeMatcher(callback, validator interface{}) *TypeMatcher

type WsError

type WsError struct {
	Code         WsErrorCode
	Msg          string
	WrappedError error
}

func (*WsError) Error

func (err *WsError) Error() string

type WsErrorCode

type WsErrorCode int

const (
	NormalShutdown WsErrorCode = 0 + iota
	Disconnect
	Unknown
)