websocket

Documentation

Index

• func CreateHandler(ws Websocket, config *config.Config) func(*gin.Context)
• type Message
• type WSHandler
• type Websocket
• type Writer

Functions

func CreateHandler

func CreateHandler(ws Websocket, config *config.Config) func(*gin.Context)

Types

type Message

type Message struct {
	Type int
	Data []byte
}

type WSHandler

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

type Websocket

type Websocket interface {
	OnMessage(r *http.Request, w Writer, msg []byte, t int, device *models.Device, db *gorm.DB, metrics *metrics.Metrics)
	OnConnect(ctx context.Context, r *http.Request, w Writer, device *models.Device, db *gorm.DB, nats *nats.Conn, metrics *metrics.Metrics, conn *websocket.Conn)
	OnDisconnect(r *http.Request, device *models.Device, db *gorm.DB, metrics *metrics.Metrics)
}

type Writer

type Writer interface {
	WriteMessage(message Message)
	Error(message string)
}