http

Documentation

Index

• type HTTP
  • func (rcv *HTTP) Addr() net.Addr
  • func (rcv *HTTP) InitPrometheus(reg prometheus.Registerer)
  • func (rcv *HTTP) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (rcv *HTTP) Stat(send helper.StatCallback)
  • func (rcv *HTTP) Stop()
• type Options
  • func NewOptions() *Options

Types

type HTTP

type HTTP struct {
	// contains filtered or unexported fields
}

HTTP receive metrics from HTTP requests

func (*HTTP) Addr

func (rcv *HTTP) Addr() net.Addr

Addr returns binded socket address. For bind port 0 in tests

func (*HTTP) InitPrometheus

func (rcv *HTTP) InitPrometheus(reg prometheus.Registerer)

InitPrometheus is a stub for the receiver prom metrics. Required to satisfy Receiver interface.

func (*HTTP) ServeHTTP

func (rcv *HTTP) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*HTTP) Stat

func (rcv *HTTP) Stat(send helper.StatCallback)

func (*HTTP) Stop

func (rcv *HTTP) Stop()

type Options

type Options struct {
	Listen         string `toml:"listen"`
	MaxMessageSize uint32 `toml:"max-message-size"`
}

func NewOptions

func NewOptions() *Options