remote

Oct 6, 2017

retracted

Changes in this version

+ func FromLabelPairs(labelPairs []*LabelPair) model.Metric

+ func FromQuery(req *Query) (model.Time, model.Time, []*metric.LabelMatcher, error)

+ func IteratorsToMatrix(iters []local.SeriesIterator, interval metric.Interval) model.Matrix

type LabelPair

+ func ToLabelPairs(metric model.Metric) []*LabelPair

type WriteRequest

+ func ToWriteRequest(samples []*model.Sample) *WriteRequest

Apr 14, 2017

retracted

Changes in this version

+ var MatchType_name = map[int32]string

+ var MatchType_value = map[string]int32

+ func MatrixToIterators(m model.Matrix, err error) ([]local.SeriesIterator, error)

+ type LabelMatcher struct

+ Name string

+ Type MatchType

+ Value string

+ func (*LabelMatcher) Descriptor() ([]byte, []int)

+ func (*LabelMatcher) ProtoMessage()

+ func (m *LabelMatcher) GetName() string

+ func (m *LabelMatcher) GetType() MatchType

+ func (m *LabelMatcher) GetValue() string

+ func (m *LabelMatcher) Reset()

+ func (m *LabelMatcher) String() string

type LabelPair

+ func (m *LabelPair) GetName() string

+ func (m *LabelPair) GetValue() string

+ type MatchType int32

+ const MatchType_EQUAL

+ const MatchType_NOT_EQUAL

+ const MatchType_REGEX_MATCH

+ const MatchType_REGEX_NO_MATCH

+ func (MatchType) EnumDescriptor() ([]byte, []int)

+ func (x MatchType) String() string

+ type Query struct

+ EndTimestampMs int64

+ Matchers []*LabelMatcher

+ StartTimestampMs int64

+ func (*Query) Descriptor() ([]byte, []int)

+ func (*Query) ProtoMessage()

+ func (m *Query) GetEndTimestampMs() int64

+ func (m *Query) GetMatchers() []*LabelMatcher

+ func (m *Query) GetStartTimestampMs() int64

+ func (m *Query) Reset()

+ func (m *Query) String() string

+ type QueryResult struct

+ Timeseries []*TimeSeries

+ func (*QueryResult) Descriptor() ([]byte, []int)

+ func (*QueryResult) ProtoMessage()

+ func (m *QueryResult) GetTimeseries() []*TimeSeries

+ func (m *QueryResult) Reset()

+ func (m *QueryResult) String() string

type QueueManager

+ func (*QueueManager) NeedsThrottling() bool

+ type QueueManagerConfig struct

+ BatchSendDeadline time.Duration

+ MaxBackoff time.Duration

+ MaxRetries int

+ MaxSamplesPerSend int

+ MaxShards int

+ MinBackoff time.Duration

+ QueueCapacity int

+ type ReadRequest struct

+ Queries []*Query

+ func (*ReadRequest) Descriptor() ([]byte, []int)

+ func (*ReadRequest) ProtoMessage()

+ func (m *ReadRequest) GetQueries() []*Query

+ func (m *ReadRequest) Reset()

+ func (m *ReadRequest) String() string

+ type ReadResponse struct

+ Results []*QueryResult

+ func (*ReadResponse) Descriptor() ([]byte, []int)

+ func (*ReadResponse) ProtoMessage()

+ func (m *ReadResponse) GetResults() []*QueryResult

+ func (m *ReadResponse) Reset()

+ func (m *ReadResponse) String() string

+ type Reader struct

+ func (r *Reader) ApplyConfig(conf *config.Config) error

+ func (r *Reader) Queriers() []local.Querier

type Sample

+ func (m *Sample) GetTimestampMs() int64

+ func (m *Sample) GetValue() float64

+ type Writer struct

+ func (w *Writer) Append(smpl *model.Sample) error

+ func (w *Writer) ApplyConfig(conf *config.Config) error

+ func (w *Writer) NeedsThrottling() bool

+ func (w *Writer) Stop()

Oct 7, 2016

retracted

Changes in this version

+ type ReloadableStorage struct

+ func NewConfigurable() *ReloadableStorage

+ func (s *ReloadableStorage) Append(smpl *model.Sample) error

+ func (s *ReloadableStorage) ApplyConfig(conf *config.Config) error

+ func (s *ReloadableStorage) NeedsThrottling() bool

+ func (s *ReloadableStorage) Stop()

type Storage

+ func (s *Storage) Start()

type StorageQueueManager

+ func (t *StorageQueueManager) Start()

Sep 3, 2016

retracted

Changes in this version

+ func RegisterWriteServer(s *grpc.Server, srv WriteServer)

type Client

+ func NewClient(address string, timeout time.Duration) (*Client, error)

+ type LabelPair struct

+ Name string

+ Value string

+ func (*LabelPair) Descriptor() ([]byte, []int)

+ func (*LabelPair) ProtoMessage()

+ func (m *LabelPair) Reset()

+ func (m *LabelPair) String() string

type Options

+ Address string

+ type Sample struct

+ TimestampMs int64

+ Value float64

+ func (*Sample) Descriptor() ([]byte, []int)

+ func (*Sample) ProtoMessage()

+ func (m *Sample) Reset()

+ func (m *Sample) String() string

type StorageQueueManager

+ func (*StorageQueueManager) NeedsThrottling() bool

+ type StorageQueueManagerConfig struct

+ BatchSendDeadline time.Duration

+ MaxSamplesPerSend int

+ QueueCapacity int

+ Shards int

+ type TimeSeries struct

+ Labels []*LabelPair

+ Samples []*Sample

+ func (*TimeSeries) Descriptor() ([]byte, []int)

+ func (*TimeSeries) ProtoMessage()

+ func (m *TimeSeries) GetLabels() []*LabelPair

+ func (m *TimeSeries) GetSamples() []*Sample

+ func (m *TimeSeries) Reset()

+ func (m *TimeSeries) String() string

type WriteClient

+ Write func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)

+ type WriteRequest struct

+ Timeseries []*TimeSeries

+ func (*WriteRequest) Descriptor() ([]byte, []int)

+ func (*WriteRequest) ProtoMessage()

+ func (m *WriteRequest) GetTimeseries() []*TimeSeries

+ func (m *WriteRequest) Reset()

+ func (m *WriteRequest) String() string

+ type WriteResponse struct

+ func (*WriteResponse) Descriptor() ([]byte, []int)

+ func (*WriteResponse) ProtoMessage()

+ func (m *WriteResponse) Reset()

+ func (m *WriteResponse) String() string

+ type WriteServer interface

+ Write func(context.Context, *WriteRequest) (*WriteResponse, error)

Jul 18, 2016

retracted

Changes in this version

+ type Options struct

+ GraphiteAddress string

+ GraphitePrefix string

+ GraphiteTransport string

+ InfluxdbDatabase string

+ InfluxdbPassword string

+ InfluxdbRetentionPolicy string

+ InfluxdbURL *url.URL

+ InfluxdbUsername string

+ OpentsdbURL string

+ StorageTimeout time.Duration

type Storage

+ func New(o *Options) *Storage

+ func (s *Storage) Append(smpl *model.Sample) error

+ func (s *Storage) Collect(ch chan<- prometheus.Metric)

+ func (s *Storage) Describe(ch chan<- *prometheus.Desc)

+ func (s *Storage) NeedsThrottling() bool

+ func (s *Storage) Run()

+ func (s *Storage) Stop()

+ type StorageClient interface

+ Name func() string

+ Store func(model.Samples) error

+ type StorageQueueManager struct

+ func NewStorageQueueManager(tsdb StorageClient, queueCapacity int) *StorageQueueManager

+ func (t *StorageQueueManager) Append(s *model.Sample) error

+ func (t *StorageQueueManager) Collect(ch chan<- prometheus.Metric)

+ func (t *StorageQueueManager) Describe(ch chan<- *prometheus.Desc)

+ func (t *StorageQueueManager) Run()

+ func (t *StorageQueueManager) Stop()

Feb 9, 2024

Changes in this version

+ const DefaultChunkedReadLimit

+ var UserAgent = fmt.Sprintf("Prometheus/%s", version.Version)

+ func DecodeOTLPWriteRequest(r *http.Request) (pmetricotlp.ExportRequest, error)

+ func DecodeReadRequest(r *http.Request) (*prompb.ReadRequest, error)

+ func DecodeWriteRequest(r io.Reader) (*prompb.WriteRequest, error)

+ func EncodeReadResponse(resp *prompb.ReadResponse, w http.ResponseWriter) error

+ func FloatHistogramProtoToFloatHistogram(hp prompb.Histogram) *histogram.FloatHistogram

+ func FloatHistogramToHistogramProto(timestamp int64, fh *histogram.FloatHistogram) prompb.Histogram

+ func FromLabelMatchers(matchers []*prompb.LabelMatcher) ([]*labels.Matcher, error)

+ func FromQueryResult(sortSeries bool, res *prompb.QueryResult) storage.SeriesSet

+ func HistogramProtoToFloatHistogram(hp prompb.Histogram) *histogram.FloatHistogram

+ func HistogramProtoToHistogram(hp prompb.Histogram) *histogram.Histogram

+ func HistogramToHistogramProto(timestamp int64, h *histogram.Histogram) prompb.Histogram

+ func LabelProtosToMetric(labelPairs []*prompb.Label) model.Metric

+ func MergeLabels(primary, secondary []prompb.Label) []prompb.Label

+ func NegotiateResponseType(accepted []prompb.ReadRequest_ResponseType) (prompb.ReadRequest_ResponseType, error)

+ func NewOTLPWriteHandler(logger log.Logger, appendable storage.Appendable) http.Handler

+ func NewReadHandler(logger log.Logger, r prometheus.Registerer, ...) http.Handler

+ func NewSampleAndChunkQueryableClient(c ReadClient, externalLabels labels.Labels, requiredMatchers []*labels.Matcher, ...) storage.SampleAndChunkQueryable

+ func NewWriteHandler(logger log.Logger, reg prometheus.Registerer, appendable storage.Appendable) http.Handler

+ func StreamChunkedReadResponses(stream io.Writer, queryIndex int64, ss storage.ChunkSeriesSet, ...) (annotations.Annotations, error)

+ func ToQuery(from, to int64, matchers []*labels.Matcher, hints *storage.SelectHints) (*prompb.Query, error)

+ func ToQueryResult(ss storage.SeriesSet, sampleLimit int) (*prompb.QueryResult, annotations.Annotations, error)

+ type ChunkedReader struct

+ func NewChunkedReader(r io.Reader, sizeLimit uint64, data []byte) *ChunkedReader

+ func (r *ChunkedReader) Next() ([]byte, error)

+ func (r *ChunkedReader) NextProto(pb proto.Message) error

+ type ChunkedWriter struct

+ func NewChunkedWriter(w io.Writer, f http.Flusher) *ChunkedWriter

+ func (w *ChunkedWriter) Write(b []byte) (int, error)

+ type Client struct

+ Client *http.Client

+ func (c *Client) Read(ctx context.Context, query *prompb.Query) (*prompb.QueryResult, error)

+ func (c *Client) Store(ctx context.Context, req []byte, attempt int) error

+ func (c Client) Endpoint() string

+ func (c Client) Name() string

+ type ClientConfig struct

+ AzureADConfig *azuread.AzureADConfig

+ HTTPClientConfig config_util.HTTPClientConfig

+ Headers map[string]string

+ RetryOnRateLimit bool

+ SigV4Config *sigv4.SigV4Config

+ Timeout model.Duration

+ URL *config_util.URL

+ type HTTPError struct

+ func (e HTTPError) Error() string

+ func (e HTTPError) Status() int

+ type MetadataAppender interface

+ AppendMetadata func(context.Context, []scrape.MetricMetadata)

+ type MetadataWatcher struct

+ func NewMetadataWatcher(l log.Logger, mg ReadyScrapeManager, name string, w MetadataAppender, ...) *MetadataWatcher

+ func (mw *MetadataWatcher) Start()

+ func (mw *MetadataWatcher) Stop()

+ type QueueManager struct

+ func NewQueueManager(metrics *queueManagerMetrics, watcherMetrics *wlog.WatcherMetrics, ...) *QueueManager

+ func (t *QueueManager) Append(samples []record.RefSample) bool

+ func (t *QueueManager) AppendExemplars(exemplars []record.RefExemplar) bool

+ func (t *QueueManager) AppendFloatHistograms(floatHistograms []record.RefFloatHistogramSample) bool

+ func (t *QueueManager) AppendHistograms(histograms []record.RefHistogramSample) bool

+ func (t *QueueManager) AppendMetadata(ctx context.Context, metadata []scrape.MetricMetadata)

+ func (t *QueueManager) SeriesReset(index int)

+ func (t *QueueManager) SetClient(c WriteClient)

+ func (t *QueueManager) Start()

+ func (t *QueueManager) Stop()

+ func (t *QueueManager) StoreSeries(series []record.RefSeries, index int)

+ func (t *QueueManager) UpdateSeriesSegment(series []record.RefSeries, index int)

+ type ReadClient interface

+ Read func(ctx context.Context, query *prompb.Query) (*prompb.QueryResult, error)

+ func NewReadClient(name string, conf *ClientConfig) (ReadClient, error)

+ type ReadyScrapeManager interface

+ Get func() (*scrape.Manager, error)

+ type RecoverableError struct

+ type Storage struct

+ func NewStorage(l log.Logger, reg prometheus.Registerer, stCallback startTimeCallback, ...) *Storage

+ func (s *Storage) Appender(ctx context.Context) storage.Appender

+ func (s *Storage) ApplyConfig(conf *config.Config) error

+ func (s *Storage) ChunkQuerier(mint, maxt int64) (storage.ChunkQuerier, error)

+ func (s *Storage) Close() error

+ func (s *Storage) LowestSentTimestamp() int64

+ func (s *Storage) Notify()

+ func (s *Storage) Querier(mint, maxt int64) (storage.Querier, error)

+ func (s *Storage) StartTime() (int64, error)

+ type Watchable interface

+ TargetsActive func() map[string][]*scrape.Target

+ type WriteClient interface

+ Endpoint func() string

+ Name func() string

+ Store func(context.Context, []byte, int) error

+ func NewWriteClient(name string, conf *ClientConfig) (WriteClient, error)

+ type WriteStorage struct

+ func NewWriteStorage(logger log.Logger, reg prometheus.Registerer, dir string, ...) *WriteStorage

+ func (rws *WriteStorage) Appender(_ context.Context) storage.Appender

+ func (rws *WriteStorage) ApplyConfig(conf *config.Config) error

+ func (rws *WriteStorage) Close() error

+ func (rws *WriteStorage) LowestSentTimestamp() int64

+ func (rws *WriteStorage) Notify()