ws

Documentation

Index

• func AddReadCallback(msgType string, callback interface{})
• func BroadcastAll(data string)
• func BroadcastTopic(topic string, data string)
• func HandlerFunc(context echo.Context) error
• func Init() error
• func NewAlert(level string, title string, message string) (string, error)
• func Subscribe(s *melody.Session, topic string)
• func Unsubscribe(s *melody.Session, topic string)
• func UnsubscribeAll(s *melody.Session)
• type WebsocketAlert
• type WebsocketMessage
  • func (whMessage WebsocketMessage) ToJsonString() (string, error)

Functions

func AddReadCallback

func AddReadCallback(msgType string, callback interface{})

func BroadcastAll

func BroadcastAll(data string)

func BroadcastTopic

func BroadcastTopic(topic string, data string)

func HandlerFunc

func HandlerFunc(context echo.Context) error

func Init

func Init() error

func NewAlert

func NewAlert(level string, title string, message string) (string, error)

func Subscribe

func Subscribe(s *melody.Session, topic string)

func Unsubscribe

func Unsubscribe(s *melody.Session, topic string)

func UnsubscribeAll

func UnsubscribeAll(s *melody.Session)

Types

type WebsocketAlert

type WebsocketAlert struct {
	Level   string `json:"level"`
	Title   string `json:"title"`
	Message string `json:"msg"`
}

type WebsocketMessage

type WebsocketMessage struct {
	Type string      `json:"type"`
	Data interface{} `json:"data"`
}

func (WebsocketMessage) ToJsonString

func (whMessage WebsocketMessage) ToJsonString() (string, error)