Documentation ¶
Index ¶
- Constants
- type Endpoint
- type Mqtt
- func (m *Mqtt) AddRouter(router *endpoint.Router, params ...interface{}) (string, error)
- func (m *Mqtt) Close() error
- func (m *Mqtt) Destroy()
- func (m *Mqtt) Id() string
- func (m *Mqtt) Init(ruleConfig types.Config, configuration types.Configuration) error
- func (m *Mqtt) New() types.Node
- func (m *Mqtt) Printf(format string, v ...interface{})
- func (m *Mqtt) RemoveRouter(routerId string, params ...interface{}) error
- func (m *Mqtt) Start() error
- func (m *Mqtt) Type() string
- 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() paho.Message
- 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) Response() paho.Client
- 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)
Constants ¶
View Source
const Type = "mqtt"
Type 组件类型
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Mqtt ¶
type Mqtt struct { endpoint.BaseEndpoint RuleConfig types.Config Config mqtt.Config // contains filtered or unexported fields }
Mqtt MQTT 接收端端点
func (*Mqtt) RemoveRouter ¶ added in v0.17.0
type RequestMessage ¶
type RequestMessage struct {
// contains filtered or unexported fields
}
RequestMessage http请求消息
func (*RequestMessage) GetError ¶ added in v0.15.0
func (r *RequestMessage) GetError() error
func (*RequestMessage) GetMsg ¶
func (r *RequestMessage) GetMsg() *types.RuleMsg
func (*RequestMessage) GetParam ¶
func (r *RequestMessage) GetParam(key string) string
GetParam 不提供获取参数
func (*RequestMessage) Headers ¶
func (r *RequestMessage) Headers() textproto.MIMEHeader
func (*RequestMessage) Request ¶
func (r *RequestMessage) Request() paho.Message
func (*RequestMessage) SetError ¶ added in v0.15.0
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)
SetStatusCode 不提供设置状态码
type ResponseMessage ¶
type ResponseMessage struct {
// contains filtered or unexported fields
}
ResponseMessage http响应消息
func (*ResponseMessage) Body ¶
func (r *ResponseMessage) Body() []byte
func (*ResponseMessage) From ¶
func (r *ResponseMessage) From() string
func (*ResponseMessage) GetError ¶ added in v0.15.0
func (r *ResponseMessage) GetError() error
func (*ResponseMessage) GetMsg ¶
func (r *ResponseMessage) GetMsg() *types.RuleMsg
func (*ResponseMessage) GetParam ¶
func (r *ResponseMessage) GetParam(key string) string
GetParam 不提供获取参数
func (*ResponseMessage) Headers ¶
func (r *ResponseMessage) Headers() textproto.MIMEHeader
func (*ResponseMessage) Response ¶
func (r *ResponseMessage) Response() paho.Client
func (*ResponseMessage) SetBody ¶
func (r *ResponseMessage) SetBody(body []byte)
func (*ResponseMessage) SetError ¶ added in v0.15.0
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)
Click to show internal directories.
Click to hide internal directories.