websocket

Documentation

Index

• Variables
• type RPCWebsocket
  • func CreateRPCWebsocket(config *config.Config, metrics *metrics.Metrics) *RPCWebsocket
  • func (c *RPCWebsocket) Call(ctx context.Context, nc *nats.Conn, metrics *metrics.Metrics, dongleID string, ...) (apimodels.RPCResponse, error)
  • func (c *RPCWebsocket) OnConnect(ctx context.Context, _ *http.Request, w websocket.Writer, ...)
  • func (c *RPCWebsocket) OnDisconnect(_ *http.Request, device *models.Device, _ *gorm.DB, metrics *metrics.Metrics)
  • func (c *RPCWebsocket) OnMessage(_ *http.Request, _ websocket.Writer, msg []byte, msgType int, ...)
  • func (c *RPCWebsocket) Stop(ctx context.Context) error

Variables

var (
	ErrNotConnected = errors.New("dongle not connected")
)

Types

type RPCWebsocket

type RPCWebsocket struct {
	websocket.Websocket
	// contains filtered or unexported fields
}

func CreateRPCWebsocket

func CreateRPCWebsocket(config *config.Config, metrics *metrics.Metrics) *RPCWebsocket

func (*RPCWebsocket) Call

func (c *RPCWebsocket) Call(ctx context.Context, nc *nats.Conn, metrics *metrics.Metrics, dongleID string, call apimodels.RPCCall) (apimodels.RPCResponse, error)

func (*RPCWebsocket) OnConnect

func (c *RPCWebsocket) OnConnect(ctx context.Context, _ *http.Request, w websocket.Writer, device *models.Device, _ *gorm.DB, nc *nats.Conn, metrics *metrics.Metrics, conn *gorillaWebsocket.Conn)

func (*RPCWebsocket) OnDisconnect

func (c *RPCWebsocket) OnDisconnect(_ *http.Request, device *models.Device, _ *gorm.DB, metrics *metrics.Metrics)

func (*RPCWebsocket) OnMessage

func (c *RPCWebsocket) OnMessage(_ *http.Request, _ websocket.Writer, msg []byte, msgType int, device *models.Device, _ *gorm.DB, metrics *metrics.Metrics)

func (*RPCWebsocket) Stop

func (c *RPCWebsocket) Stop(ctx context.Context) error