websocketHelper

Documentation

Index

• func Broadcast(namespace, room, event string, content string)
• func InitMq()
• func PubMsg(data commDomain.MqMsg)
• func SendExecMsg(msg, isRunning string, category commConsts.WsMsgCategory, info iris.Map, ...)
• func SendExecMsgIfNeed(msg, isRunning string, category commConsts.WsMsgCategory, info iris.Map, ...)
• func SendOutputMsg(msg, isRunning string, info iris.Map, wsMsg *websocket.Message)
• func SendOutputMsgIfNeed(msg, isRunning string, info iris.Map, wsMsg *websocket.Message)
• func SetConn(conn *neffos.Conn)
• func SubMsg()
• type PrefixedLogger
  • func (s *PrefixedLogger) Log(msg string)

Functions

func Broadcast

func Broadcast(namespace, room, event string, content string)

func InitMq

func InitMq()

func PubMsg

func PubMsg(data commDomain.MqMsg)

func SendExecMsg

func SendExecMsg(msg, isRunning string, category commConsts.WsMsgCategory, info iris.Map, wsMsg *websocket.Message)

func SendExecMsgIfNeed

func SendExecMsgIfNeed(msg, isRunning string, category commConsts.WsMsgCategory, info iris.Map, wsMsg *websocket.Message)

func SendOutputMsg

func SendOutputMsg(msg, isRunning string, info iris.Map, wsMsg *websocket.Message)

func SendOutputMsgIfNeed

func SendOutputMsgIfNeed(msg, isRunning string, info iris.Map, wsMsg *websocket.Message)

func SetConn

func SetConn(conn *neffos.Conn)

func SubMsg

func SubMsg()

Types

type PrefixedLogger

type PrefixedLogger struct {
	Prefix string
}

func (*PrefixedLogger) Log

func (s *PrefixedLogger) Log(msg string)