receive

package

v0.5.0 Latest Latest Go to latest Published: Jun 6, 2019 License: Apache-2.0 Imports: 24 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Appendable interface {
	Appender() (storage.Appender, error)
}

Appendable returns an Appender.

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

Handler serves a Prometheus remote write receiving HTTP endpoint.

func NewHandler(logger log.Logger, o *Options) *Handler

func (h *Handler) Quit() <-chan struct{}

Quit returns the receive-only quit channel.

func (h *Handler) Ready()

Ready sets Handler to be ready.

func (h *Handler) Run(ctx context.Context) error

Run serves the HTTP endpoints.

type Options struct {
	Receiver      *Writer
	ListenAddress string
	Registry      prometheus.Registerer
	ReadyStorage  *promtsdb.ReadyStorage
}

Options for the web Handler.

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

func NewWriter(logger log.Logger, app Appendable) *Writer

func (r *Writer) Receive(wreq *prompb.WriteRequest) error