mwebsockets

Documentation

Index

• type ReceivedMessage
• type Websocket
  • func NewWebsocket(eCtx echo.Context, allowedOrigins []string, id string) (*Websocket, error)
  • func (ws *Websocket) Close() error
  • func (ws *Websocket) Pump(eCtx echo.Context)
  • func (ws *Websocket) SendCloseMessage() error
  • func (ws *Websocket) SendMessage(kind int, msg []byte) error
• type WebsocketMessage

Types

type ReceivedMessage

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

ReceivedMessage ...

type Websocket

type Websocket struct {
	Websocket *websocket.Conn
	Send      chan WebsocketMessage
	Receive   chan ReceivedMessage
	Handler   chan []byte
	Interrupt chan struct{}
	EndPump   chan struct{}

	ID string
}

Websocket ...

func NewWebsocket

func NewWebsocket(
	eCtx echo.Context,
	allowedOrigins []string,
	id string,
) (*Websocket, error)

NewWebsocket ...

func (*Websocket) Close

func (ws *Websocket) Close() error

Close ...

func (*Websocket) Pump

func (ws *Websocket) Pump(eCtx echo.Context)

Pump ...

func (*Websocket) SendCloseMessage

func (ws *Websocket) SendCloseMessage() error

SendCloseMessage ...

func (*Websocket) SendMessage

func (ws *Websocket) SendMessage(kind int, msg []byte) error

SendMessage ...

type WebsocketMessage

type WebsocketMessage struct {
	Msg string
}

WebsocketMessage ...