client

Jan 31, 2019

Changes in this version

+ func OptSetHTTPTransport(transport *http.Transport) func(*Type)

Dec 19, 2018

Changes in this version

type Config

+ MaxBackoff string

+ Retry string

+ Timeout string

Sep 16, 2018

Changes in this version

+ func OptSetManager(mgr types.Manager) func(*Type)

type Config

+ RateLimit string

Jul 31, 2018

Changes in this version

type Config

+ TLS tls.Config

Jul 12, 2018

Changes in this version

+ func OptSetLogger(log log.Modular) func(*Type)

+ func OptSetStats(stats metrics.Type) func(*Type)

type Type

+ func (h *Type) CreateRequestWithURL(url string, msg types.Message) (req *http.Request, err error)

+ func (h *Type) DoWithURL(url string, msg types.Message) (res *http.Response, err error)

+ func (h *Type) SendWithURL(url string, msg types.Message) (types.Message, error)

Jul 9, 2018

Changes in this version

type Type

+ URL string

Jul 9, 2018

Changes in this version

type Config

+ Headers map[string]string

type Type

+ func (h *Type) CreateRequest(msg types.Message) (req *http.Request, err error)

+ func (h *Type) Do(msg types.Message) (res *http.Response, err error)

+ func (h *Type) ParseResponse(res *http.Response) (resMsg types.Message, err error)

Jul 4, 2018

Changes in this version

+ func OptSetCloseChan(c <-chan struct{}) func(*Type)

+ type Config struct

+ BackoffOn []int

+ ContentType string

+ DropOn []int

+ MaxBackoffMS int64

+ NumRetries int

+ RetryMS int64

+ SkipCertVerify bool

+ TimeoutMS int64

+ URL string

+ Verb string

+ func NewConfig() Config

+ type Type struct

+ func New(conf Config, opts ...func(*Type)) *Type

+ func (h *Type) Send(msg types.Message) (types.Message, error)