Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

remote

package

Go to main page

Versions in this module

v2

v2.25.1

Jan 27, 2021

v2.25.0

Jan 27, 2021

Changes in this version

+ const DefaultChunkedReadLimit

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

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

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

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

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

+ func StreamChunkedReadResponses(stream io.Writer, queryIndex int64, ss storage.ChunkSeriesSet, ...) (storage.Warnings, 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

+ Client *http.Client

+ func (c Client) Endpoint() string

+ 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

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

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

+ 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

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

+ type Watchable interface

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

+ type WriteClient interface

+ Endpoint func() string

+ Name func() string

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

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

v2.12.3

Jan 28, 2021

v2.12.2

Jan 28, 2021

Changes in this version

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

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

+ func ExternalLabelsHandler(next storage.Queryable, externalLabels labels.Labels) storage.Queryable

+ func FromQuery(req *prompb.Query) (int64, int64, []*labels.Matcher, *storage.SelectParams, error)

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

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

+ func PreferLocalStorageFilter(next storage.Queryable, cb startTimeCallback) storage.Queryable

+ func QueryableClient(c *Client) storage.Queryable

+ func RequiredMatchersFilter(next storage.Queryable, required []*labels.Matcher) storage.Queryable

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

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

+ type Client struct

+ func NewClient(index int, conf *ClientConfig) (*Client, error)

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

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

+ func (c Client) Name() string

+ type ClientConfig struct

+ HTTPClientConfig config_util.HTTPClientConfig

+ Timeout model.Duration

+ URL *config_util.URL

+ type HTTPError struct

+ func (e HTTPError) Error() string

+ func (e HTTPError) Status() int

+ type QueueManager struct

+ func NewQueueManager(logger log.Logger, walDir string, samplesIn *ewmaRate, cfg config.QueueConfig, ...) *QueueManager

+ func (t *QueueManager) Append(s []tsdb.RefSample) bool

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

+ func (t *QueueManager) Start()

+ func (t *QueueManager) Stop()

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

+ type Storage struct

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

+ func (s *Storage) Appender() (storage.Appender, error)

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

+ func (s *Storage) Close() error

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

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

+ type StorageClient interface

+ Name func() string

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

+ type WALWatcher struct

+ func NewWALWatcher(logger log.Logger, name string, writer writeTo, walDir string) *WALWatcher

+ func (w *WALWatcher) Start()

+ func (w *WALWatcher) Stop()

+ type WriteStorage struct

+ func NewWriteStorage(logger log.Logger, walDir string, flushDeadline time.Duration) *WriteStorage

+ func (rws *WriteStorage) Appender() (storage.Appender, error)

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

+ func (rws *WriteStorage) Close() error

Other modules containing this package

github.com/pmalek-sumo/prometheus