Documentation ¶
Index ¶
- Constants
- 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) 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 Schedule
- func (schedule *Schedule) AddRouter(router *endpoint.Router, params ...interface{}) (string, error)
- func (schedule *Schedule) Close() error
- func (schedule *Schedule) Destroy()
- func (schedule *Schedule) Id() string
- func (schedule *Schedule) Init(ruleConfig types.Config, configuration types.Configuration) error
- func (schedule *Schedule) New() types.Node
- func (schedule *Schedule) Printf(format string, v ...interface{})
- func (schedule *Schedule) RemoveRouter(routeId string, params ...interface{}) error
- func (schedule *Schedule) Start() error
- func (schedule *Schedule) Type() string
Constants ¶
View Source
const Type = "schedule"
Type 组件类型
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RequestMessage ¶
type RequestMessage struct {
// contains filtered or unexported fields
}
RequestMessage http请求消息
func (*RequestMessage) Body ¶
func (r *RequestMessage) Body() []byte
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
GetParam 不提供获取参数
func (*RequestMessage) Headers ¶
func (r *RequestMessage) Headers() textproto.MIMEHeader
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)
SetStatusCode 不提供设置状态码
type ResponseMessage ¶
type ResponseMessage struct {
// contains filtered or unexported fields
}
ResponseMessage 响应消息
func (*ResponseMessage) Body ¶
func (r *ResponseMessage) Body() []byte
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
GetParam 不提供获取参数
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 不提供设置状态码
Click to show internal directories.
Click to hide internal directories.