Documentation ¶
Index ¶
- Constants
- type Config
- type Endpoint
- type RequestMessage
- func (r *RequestMessage) Body() []byte
- func (r RequestMessage) From() string
- func (r *RequestMessage) GetError() error
- func (r *RequestMessage) GetMsg() *types.RuleMsg
- func (r *RequestMessage) GetParam(key string) string
- func (r *RequestMessage) Headers() textproto.MIMEHeader
- func (r *RequestMessage) Request() *http.Request
- func (r *RequestMessage) SetBody(body []byte)
- func (r *RequestMessage) SetError(err error)
- func (r *RequestMessage) SetMsg(msg *types.RuleMsg)
- func (r *RequestMessage) SetStatusCode(statusCode int)
- type ResponseMessage
- func (r *ResponseMessage) Body() []byte
- func (r *ResponseMessage) From() string
- func (r *ResponseMessage) GetError() error
- func (r *ResponseMessage) GetMsg() *types.RuleMsg
- func (r *ResponseMessage) GetParam(key string) string
- func (r *ResponseMessage) Headers() textproto.MIMEHeader
- func (r *ResponseMessage) SetBody(body []byte)
- func (r *ResponseMessage) SetError(err error)
- func (r *ResponseMessage) SetMsg(msg *types.RuleMsg)
- func (r *ResponseMessage) SetStatusCode(statusCode int)
- type Websocket
- func (ws *Websocket) AddRouter(router *endpoint.Router, params ...interface{}) (string, error)
- func (ws *Websocket) Close() error
- func (ws *Websocket) Destroy()
- func (ws *Websocket) Id() string
- func (ws *Websocket) Init(ruleConfig types.Config, configuration types.Configuration) error
- func (ws *Websocket) New() types.Node
- func (ws *Websocket) Printf(format string, v ...interface{})
- func (ws *Websocket) RemoveRouter(routerId string, params ...interface{}) error
- func (ws *Websocket) Router() *httprouter.Router
- func (ws *Websocket) Start() error
- func (ws *Websocket) Type() string
Constants ¶
View Source
const Type = "ws"
Type 组件类型
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RequestMessage ¶
type RequestMessage struct { //路径参数 Params httprouter.Params // contains filtered or unexported fields }
RequestMessage websocket请求消息
func (*RequestMessage) Body ¶
func (r *RequestMessage) Body() []byte
func (RequestMessage) From ¶
func (r RequestMessage) From() string
func (*RequestMessage) GetError ¶
func (r *RequestMessage) GetError() error
func (*RequestMessage) GetMsg ¶
func (r *RequestMessage) GetMsg() *types.RuleMsg
func (*RequestMessage) GetParam ¶
func (r *RequestMessage) GetParam(key string) string
func (*RequestMessage) Headers ¶
func (r *RequestMessage) Headers() textproto.MIMEHeader
func (*RequestMessage) Request ¶
func (r *RequestMessage) Request() *http.Request
func (*RequestMessage) SetBody ¶
func (r *RequestMessage) SetBody(body []byte)
func (*RequestMessage) SetError ¶
func (r *RequestMessage) SetError(err error)
func (*RequestMessage) SetMsg ¶
func (r *RequestMessage) SetMsg(msg *types.RuleMsg)
func (*RequestMessage) SetStatusCode ¶
func (r *RequestMessage) SetStatusCode(statusCode int)
type ResponseMessage ¶
type ResponseMessage struct {
// contains filtered or unexported fields
}
ResponseMessage websocket响应消息
func (*ResponseMessage) Body ¶
func (r *ResponseMessage) Body() []byte
func (*ResponseMessage) From ¶
func (r *ResponseMessage) From() string
func (*ResponseMessage) GetError ¶
func (r *ResponseMessage) GetError() error
func (*ResponseMessage) GetMsg ¶
func (r *ResponseMessage) GetMsg() *types.RuleMsg
func (*ResponseMessage) GetParam ¶
func (r *ResponseMessage) GetParam(key string) string
func (*ResponseMessage) Headers ¶
func (r *ResponseMessage) Headers() textproto.MIMEHeader
func (*ResponseMessage) SetBody ¶
func (r *ResponseMessage) SetBody(body []byte)
func (*ResponseMessage) SetError ¶
func (r *ResponseMessage) SetError(err error)
func (*ResponseMessage) SetMsg ¶
func (r *ResponseMessage) SetMsg(msg *types.RuleMsg)
func (*ResponseMessage) SetStatusCode ¶
func (r *ResponseMessage) SetStatusCode(statusCode int)
SetStatusCode 不提供设置状态码
type Websocket ¶
type Websocket struct { endpoint.BaseEndpoint //配置 Config Config RuleConfig types.Config OnEventFunc endpoint.OnEvent RestEndpoint *rest.Rest Upgrader websocket.Upgrader // contains filtered or unexported fields }
Websocket 接收端端点
func (*Websocket) RemoveRouter ¶
func (*Websocket) Router ¶
func (ws *Websocket) Router() *httprouter.Router
Click to show internal directories.
Click to hide internal directories.