websocketHelper

Documentation

Index

• func Broadcast(namespace, room, event string, content string)
• func InitMq()
• func PubMsg(data _domain.MqMsg)
• func SendExecMsg(msg string, log interface{}, category consts.WsMsgCategory, ...)
• func SendExecResult(data interface{}, wsMsg *websocket.Message)
• func SendExecStatus(category consts.WsMsgCategory, wsMsg *websocket.Message)
• func SendInitializeMsg(data interface{}, wsMsg *websocket.Message)
• func SendStatInfo(data agentDomain.InterfaceStat, 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 _domain.MqMsg)

func SendExecMsg

func SendExecMsg(msg string, log interface{}, category consts.WsMsgCategory, wsMsg *websocket.Message)

func SendExecResult

func SendExecResult(data interface{}, wsMsg *websocket.Message)

func SendExecStatus

func SendExecStatus(category consts.WsMsgCategory, wsMsg *websocket.Message)

func SendInitializeMsg

func SendInitializeMsg(data interface{}, wsMsg *websocket.Message)

func SendStatInfo

func SendStatInfo(data agentDomain.InterfaceStat, 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)