websocketactions

Documentation

Index

• Variables
• type Connection
  • func NewConnection(conn *websocket.Conn, id int, attributes map[string]string) *Connection
  • func (c *Connection) AttributesContained(attributes map[string]string) bool
  • func (c *Connection) Close()
  • func (c *Connection) GetAttributes() map[string]string
• type IWebsocketActions
• type WebsocketActions
  • func NewWebsocketActions() *WebsocketActions
  • func (wa *WebsocketActions) Close(conn *Connection) error
  • func (wa *WebsocketActions) ConnectWebsocket(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)
  • func (wa *WebsocketActions) DefaultDialer(host string) (*websocket.Conn, *http.Response, error)
  • func (wa *WebsocketActions) ReadMessage(conn *Connection) (int, []byte, error)
  • func (wa *WebsocketActions) WriteBinaryMessage(conn *Connection, readBuffer []byte) error
  • func (wa *WebsocketActions) WritePingMessage(conn *Connection) error
  • func (wa *WebsocketActions) WritePongMessage(conn *Connection) error
  • func (wa *WebsocketActions) WritePreparedMessage(conn *Connection, preparedMessage *websocket.PreparedMessage) error
• type WebsocketActionsMock
  • func (wam *WebsocketActionsMock) Close(conn *Connection) error
  • func (wam *WebsocketActionsMock) ConnectWebsocket(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)
  • func (wam *WebsocketActionsMock) DefaultDialer(host string) (*websocket.Conn, *http.Response, error)
  • func (wam *WebsocketActionsMock) ReadMessage(conn *Connection) (int, []byte, error)
  • func (wam *WebsocketActionsMock) WriteBinaryMessage(conn *Connection, readBuffer []byte) error
  • func (wam *WebsocketActionsMock) WritePingMessage(conn *Connection) error
  • func (wam *WebsocketActionsMock) WritePongMessage(conn *Connection) error
  • func (wam *WebsocketActionsMock) WritePreparedMessage(conn *Connection, preparedMessage *websocket.PreparedMessage) error

Variables

var ReadMessageTypeMock = websocket.CloseMessage

ReadMessageTypeMock mock message

Types

type Connection

type Connection struct {
	ID int
	// contains filtered or unexported fields
}

Connection -

func NewConnection

func NewConnection(conn *websocket.Conn, id int, attributes map[string]string) *Connection

NewConnection -

func (*Connection) AttributesContained

func (c *Connection) AttributesContained(attributes map[string]string) bool

AttributesContained -

func (*Connection) Close

func (c *Connection) Close()

GetAttributes -

func (*Connection) GetAttributes

func (c *Connection) GetAttributes() map[string]string

GetAttributes -

type IWebsocketActions

type IWebsocketActions interface {
	ConnectWebsocket(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)
	WriteBinaryMessage(conn *Connection, readBuffer []byte) error
	WritePongMessage(conn *Connection) error
	WritePingMessage(conn *Connection) error
	WritePreparedMessage(conn *Connection, preparedMessage *websocket.PreparedMessage) error
	ReadMessage(conn *Connection) (int, []byte, error)
	Close(conn *Connection) error
	DefaultDialer(host string) (*websocket.Conn, *http.Response, error)
}

IWebsocketActions -

type WebsocketActions

type WebsocketActions struct {
}

WebsocketActions -

func NewWebsocketActions

func NewWebsocketActions() *WebsocketActions

NewWebsocketActions -

func (*WebsocketActions) Close

func (wa *WebsocketActions) Close(conn *Connection) error

Close -

func (*WebsocketActions) ConnectWebsocket

func (wa *WebsocketActions) ConnectWebsocket(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)

ConnectWebsocket -

func (*WebsocketActions) DefaultDialer

func (wa *WebsocketActions) DefaultDialer(host string) (*websocket.Conn, *http.Response, error)

DefaultDialer -

func (*WebsocketActions) ReadMessage

func (wa *WebsocketActions) ReadMessage(conn *Connection) (int, []byte, error)

ReadMessage -

func (*WebsocketActions) WriteBinaryMessage

func (wa *WebsocketActions) WriteBinaryMessage(conn *Connection, readBuffer []byte) error

WriteBinaryMessage -

func (*WebsocketActions) WritePingMessage

func (wa *WebsocketActions) WritePingMessage(conn *Connection) error

WritePingMessage -

func (*WebsocketActions) WritePongMessage

func (wa *WebsocketActions) WritePongMessage(conn *Connection) error

WritePongMessage -

func (*WebsocketActions) WritePreparedMessage

func (wa *WebsocketActions) WritePreparedMessage(conn *Connection, preparedMessage *websocket.PreparedMessage) error

WritePreparedMessage -

type WebsocketActionsMock

type WebsocketActionsMock struct {
}

WebsocketActionsMock -

func (*WebsocketActionsMock) Close

func (wam *WebsocketActionsMock) Close(conn *Connection) error

Close -

func (*WebsocketActionsMock) ConnectWebsocket

func (wam *WebsocketActionsMock) ConnectWebsocket(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)

ConnectWebsocket -

func (*WebsocketActionsMock) DefaultDialer

func (wam *WebsocketActionsMock) DefaultDialer(host string) (*websocket.Conn, *http.Response, error)

DefaultDialer -

func (*WebsocketActionsMock) ReadMessage

func (wam *WebsocketActionsMock) ReadMessage(conn *Connection) (int, []byte, error)

ReadMessage -

func (*WebsocketActionsMock) WriteBinaryMessage

func (wam *WebsocketActionsMock) WriteBinaryMessage(conn *Connection, readBuffer []byte) error

WriteBinaryMessage -

func (*WebsocketActionsMock) WritePingMessage

func (wam *WebsocketActionsMock) WritePingMessage(conn *Connection) error

WritePingMessage -

func (*WebsocketActionsMock) WritePongMessage

func (wam *WebsocketActionsMock) WritePongMessage(conn *Connection) error

WritePongMessage -

func (*WebsocketActionsMock) WritePreparedMessage

func (wam *WebsocketActionsMock) WritePreparedMessage(conn *Connection, preparedMessage *websocket.PreparedMessage) error

WritePreparedMessage -