websocket

Documentation

Index

• Variables
• type RPCWebsocket
  • func CreateRPCWebsocket() *RPCWebsocket
  • func (c *RPCWebsocket) Call(ctx context.Context, redis *redis.Client, dongleID string, ...) (apimodels.RPCResponse, error)
  • func (c *RPCWebsocket) OnConnect(ctx context.Context, _ *http.Request, w websocket.Writer, ...)
  • func (c *RPCWebsocket) OnDisconnect(_ context.Context, _ *http.Request, device *models.Device, _ *gorm.DB)
  • func (c *RPCWebsocket) OnMessage(ctx context.Context, _ *http.Request, _ websocket.Writer, msg []byte, ...)

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() *RPCWebsocket

func (*RPCWebsocket) Call

func (c *RPCWebsocket) Call(ctx context.Context, redis *redis.Client, 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, redis *redis.Client)

func (*RPCWebsocket) OnDisconnect

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

func (*RPCWebsocket) OnMessage

func (c *RPCWebsocket) OnMessage(ctx context.Context, _ *http.Request, _ websocket.Writer, msg []byte, msgType int, device *models.Device, _ *gorm.DB, redis *redis.Client)