ws

Documentation

Index

• Constants
• func ConvertPositionUpdateToJSON(update *proto.PositionUpdate) ([]byte, error)
• func ConvertPositionsToJSON(updates []*proto.PositionUpdate) ([]byte, error)
• type MsgPayload
• type PositionMessage
• type WsHub
  • func NewWsHub(nodeID string, redisClient *redis.Client) *WsHub
  • func (h *WsHub) AddConnection(ctx context.Context, userID string, conn *websocket.Conn) error
  • func (h *WsHub) BroadcastMessage(ctx context.Context, message []byte) error
  • func (h *WsHub) RemoveConnection(ctx context.Context, userID string, conn *websocket.Conn)
  • func (h *WsHub) SendMessageToUser(ctx context.Context, userID string, message []byte) error

Constants

const (
	RedisChannel     = "ws-broadcast"
	UserNodeMapKey   = "user_node_map"
	BroadcastChannel = "broadcast-all"
)

Functions

func ConvertPositionUpdateToJSON

func ConvertPositionUpdateToJSON(update *proto.PositionUpdate) ([]byte, error)

func ConvertPositionsToJSON

func ConvertPositionsToJSON(updates []*proto.PositionUpdate) ([]byte, error)

Types

type MsgPayload

type MsgPayload struct {
	UserID  string `json:"user_id"`
	Message []byte `json:"message"`
	From    string `json:"from_node"`
	To      string `json:"to_node"`
}

type PositionMessage

type PositionMessage struct {
	Type      string  `json:"type"`
	UserID    string  `json:"user_id"`
	Lat       float64 `json:"lat"`
	Lon       float64 `json:"lon"`
	Speed     float64 `json:"speed"`
	Status    string  `json:"status"`
	Timestamp string  `json:"timestamp"`
}

type WsHub

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

func NewWsHub

func NewWsHub(nodeID string, redisClient *redis.Client) *WsHub

func (*WsHub) AddConnection

func (h *WsHub) AddConnection(ctx context.Context, userID string, conn *websocket.Conn) error

func (*WsHub) BroadcastMessage

func (h *WsHub) BroadcastMessage(ctx context.Context, message []byte) error

func (*WsHub) RemoveConnection

func (h *WsHub) RemoveConnection(ctx context.Context, userID string, conn *websocket.Conn)

func (*WsHub) SendMessageToUser

func (h *WsHub) SendMessageToUser(ctx context.Context, userID string, message []byte) error