Documentation ¶
Index ¶
- Variables
- func NewHTTPSender(name string, options spirit.Map) (sender spirit.Sender, err error)
- type HTTPReceiver
- func (p *HTTPReceiver) Group(path string, router func(martini.Router), middlerWares ...martini.Handler)
- func (p *HTTPReceiver) Handler(res gohttp.ResponseWriter, req *gohttp.Request)
- func (p *HTTPReceiver) SetDeliveryPutter(putter spirit.DeliveryPutter) (err error)
- func (p *HTTPReceiver) Start() (err error)
- func (p *HTTPReceiver) Status() spirit.Status
- func (p *HTTPReceiver) Stop() (err error)
- type HTTPReceiverConfig
- type HTTPRequestHandlerFunc
- type HTTPSender
- type HTTPSenderConfig
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrHTTPReceiverAlreadyStarted = errors.New("http receiver already started")
)
View Source
var (
ErrHTTPSenderAlreadyStarted = errors.New("http sender already started")
)
Functions ¶
Types ¶
type HTTPReceiver ¶
type HTTPReceiver struct {
// contains filtered or unexported fields
}
func NewHTTPReceiver ¶
func NewHTTPReceiver(conf HTTPReceiverConfig, requestHandler HTTPRequestHandlerFunc) (receiver *HTTPReceiver, err error)
func (*HTTPReceiver) Handler ¶
func (p *HTTPReceiver) Handler(res gohttp.ResponseWriter, req *gohttp.Request)
func (*HTTPReceiver) SetDeliveryPutter ¶
func (p *HTTPReceiver) SetDeliveryPutter(putter spirit.DeliveryPutter) (err error)
func (*HTTPReceiver) Start ¶
func (p *HTTPReceiver) Start() (err error)
func (*HTTPReceiver) Status ¶
func (p *HTTPReceiver) Status() spirit.Status
func (*HTTPReceiver) Stop ¶
func (p *HTTPReceiver) Stop() (err error)
type HTTPReceiverConfig ¶
type HTTPRequestHandlerFunc ¶
type HTTPSender ¶
type HTTPSender struct {
// contains filtered or unexported fields
}
func (*HTTPSender) Name ¶
func (p *HTTPSender) Name() string
func (*HTTPSender) SetDeliveryGetter ¶
func (p *HTTPSender) SetDeliveryGetter(getter spirit.DeliveryGetter) (err error)
func (*HTTPSender) Start ¶
func (p *HTTPSender) Start() (err error)
func (*HTTPSender) Status ¶
func (p *HTTPSender) Status() spirit.Status
func (*HTTPSender) Stop ¶
func (p *HTTPSender) Stop() (err error)
func (*HTTPSender) URN ¶
func (p *HTTPSender) URN() string
type HTTPSenderConfig ¶
type HTTPSenderConfig struct {
Timeout int `json:"timeout"`
}
Click to show internal directories.
Click to hide internal directories.