import "github.com/goodrain/rainbond/eventlog/exit/web"
getter.go manager.go pusher.go
type Chan struct {
// contains filtered or unexported fields
}
Chan handle
PubContext websocket context
func NewPubContext(upgrader websocket.Upgrader, httpWriter http.ResponseWriter, httpRequest *http.Request, s *SocketServer, ) *PubContext
NewPubContext create context
func (p *PubContext) Close()
Close close the context
func (p *PubContext) SendMessage(message WebsocketMessage) error
SendMessage send websocket message
func (p *PubContext) SendWebsocketMessage(message int) error
SendWebsocketMessage send websocket message
func (p *PubContext) Start()
Start start context
func (p *PubContext) Stop()
Stop close context
type ResponseBody struct { Bean interface{} `json:"bean,omitempty"` List []interface{} `json:"list,omitempty"` PageNum int `json:"pageNumber,omitempty"` PageSize int `json:"pageSize,omitempty"` Total int `json:"total,omitempty"` }
ResponseBody 返回主体
type ResponseType struct { Code int `json:"code"` Message string `json:"msg"` MessageCN string `json:"msgcn"` Body ResponseBody `json:"body,omitempty"` }
ResponseType 返回内容
func NewResponseType(code int, message string, messageCN string, bean interface{}, list []interface{}) ResponseType
NewResponseType 构建返回结构
func NewSuccessResponse(bean interface{}, list []interface{}) ResponseType
NewSuccessResponse 创建成功返回结构
type SocketServer struct {
// contains filtered or unexported fields
}
SocketServer socket 服务
func NewSocket(conf conf.WebSocketConf, log *logrus.Entry, storeManager store.Manager, c cluster.Cluster, healthInfo map[string]string) *SocketServer
NewSocket 创建zmq sub客户端
func (s *SocketServer) ListenError() chan error
ListenError 返回错误通道
func (s *SocketServer) Run() error
Run 执行
func (s *SocketServer) Stop()
Stop 停止
type WebsocketMessage struct { Event string `json:"event"` Data interface{} `json:"data"` Channel string `json:"channel,omitempty"` }
WebsocketMessage websocket message
func (w *WebsocketMessage) Encode() []byte
Encode return json encode data
Package web imports 25 packages (graph) and is imported by 1 packages. Updated 2019-12-05. Refresh now. Tools for package owners.