remotewrite

Documentation

Index

• Variables
• type Client
  • func NewClient(logger logrus.FieldLogger, reg prometheus.Registerer, targetName string, ...) *Client
  • func (r *Client) Ingest(ctx context.Context, in *ingestion.IngestInput) error
• type IngestionQueue
  • func NewIngestionQueue(logger logrus.FieldLogger, reg prometheus.Registerer, ...) *IngestionQueue
  • func (q *IngestionQueue) Ingest(ctx context.Context, input *ingestion.IngestInput) error
  • func (q *IngestionQueue) Stop()

Variables

var (
	ErrConvertPutInputToRequest = errors.New("failed to convert putInput into a http.Request")
	ErrMakingRequest            = errors.New("failed to make request")
	ErrNotOkResponse            = errors.New("response not ok")
)

Types

type Client

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

func NewClient

func NewClient(logger logrus.FieldLogger, reg prometheus.Registerer, targetName string, cfg config.RemoteWriteTarget) *Client

func (*Client) Ingest

func (r *Client) Ingest(ctx context.Context, in *ingestion.IngestInput) error

type IngestionQueue

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

this queue was based off storage/queue.go TODO(eh-am): merge with that one

func NewIngestionQueue

func NewIngestionQueue(logger logrus.FieldLogger, reg prometheus.Registerer, ingester ingestion.Ingester, targetName string, cfg config.RemoteWriteTarget) *IngestionQueue

NewIngestionQueue creates an IngestionQueue Notice how a config.RemoteWriteTarget is taken as argument, even though not all fields are used. This is done to simplify the API, as the alternative is to take multiple arguments

func (*IngestionQueue) Ingest

func (q *IngestionQueue) Ingest(ctx context.Context, input *ingestion.IngestInput) error

func (*IngestionQueue) Stop

func (q *IngestionQueue) Stop()