remote

Oct 6, 2017

Changes in this version

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

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

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

+ func FromQueryResult(resp *QueryResult) model.Matrix

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

+ type ClientConfig struct

+ HTTPClientConfig config.HTTPClientConfig

+ Timeout model.Duration

+ URL *config.URL

type LabelPair

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

type Query

+ func ToQuery(from, to model.Time, matchers []*metric.LabelMatcher) (*Query, error)

type QueryResult

+ func ToQueryResult(matrix model.Matrix) *QueryResult

type ReadRequest

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

type WriteRequest

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

Apr 14, 2017

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 Client

+ func (c *Client) Read(ctx context.Context, from, through model.Time, matchers metric.LabelMatchers) (model.Matrix, 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 struct

+ func NewQueueManager(cfg QueueManagerConfig, externalLabels model.LabelSet, ...) *QueueManager

+ func (*QueueManager) NeedsThrottling() bool

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

+ func (t *QueueManager) Start()

+ func (t *QueueManager) Stop()

+ 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

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

Changes in this version

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

+ type Client struct

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

+ func (c *Client) Store(samples model.Samples) error

+ func (c Client) Name() string

+ 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 interface

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

+ func NewWriteClient(cc *grpc.ClientConn) WriteClient

+ 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

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 struct

+ func New(o *Options) *Storage

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

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

+ 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()