models

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 30, 2020

Changes in this version

type GraphiteRender

+ Optimizations string

type GraphiteTagFindSeries

+ Format string

+ Limit int

+ Meta bool

+ type GraphiteTagFindSeriesLastTsResp struct

+ Series []SeriesLastTs

+ Warnings []string

+ type GraphiteTagFindSeriesMetaResp struct

+ Series []string

+ Warnings []string

+ type GraphiteTagTerms struct

+ Expr []string

+ Tags []string

+ func (z *GraphiteTagTerms) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *GraphiteTagTerms) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *GraphiteTagTerms) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *GraphiteTagTerms) Msgsize() (s int)

+ func (z *GraphiteTagTerms) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type GraphiteTagTermsResp struct

+ Terms map[string]map[string]uint32

+ TotalSeries uint32

+ func (z *GraphiteTagTermsResp) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *GraphiteTagTermsResp) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *GraphiteTagTermsResp) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *GraphiteTagTermsResp) Msgsize() (s int)

+ func (z *GraphiteTagTermsResp) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type IndexTagTerms struct

+ Expr []string

+ OrgId uint32

+ Tags []string

+ func (i IndexTagTerms) TraceDebug(span opentracing.Span)

+ func (t IndexTagTerms) Trace(span opentracing.Span)

+ type PNGroup uint64

+ func (z *PNGroup) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *PNGroup) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z PNGroup) EncodeMsg(en *msgp.Writer) (err error)

+ func (z PNGroup) MarshalMsg(b []byte) (o []byte, err error)

+ func (z PNGroup) Msgsize() (s int)

type Req

+ PNGroup PNGroup

+ func (r *Req) AdjustTo(interval, from uint32, as archives.Archives)

+ func (r *Req) Init(archive idx.Archive, cons consolidation.Consolidator, node cluster.Node)

+ func (r *Req) Plan(i int, a archives.Archive)

+ func (r *Req) PlanNormalization(interval uint32)

+ func (r Req) PointsFetch() uint32

+ func (r Req) PointsReturn(planMDP uint32) uint32

type Series

+ QueryMDP uint32

+ QueryPNGroup PNGroup

+ func (s Series) IsCanonical() bool

+ type SeriesLastTs struct

+ Series string

+ Ts int64

v0

v0.13.1

Nov 28, 2019

Changes in this version

type Series

+ Meta SeriesMeta

+ func (s *Series) CopyTags() map[string]string

+ func (s *Series) CopyTagsWith(key, val string) map[string]string

type SeriesByTarget

+ func (series SeriesByTarget) MarshalJSONFastWithMeta(b []byte) ([]byte, error)

+ type SeriesMeta []SeriesMetaProperties

+ func (a SeriesMeta) Copy() SeriesMeta

+ func (a SeriesMeta) CopyWithChange(fn func(in SeriesMetaProperties) SeriesMetaProperties) SeriesMeta

+ func (a SeriesMeta) Merge(b SeriesMeta) SeriesMeta

+ func (meta SeriesMeta) MarshalJSONFast(b []byte) ([]byte, error)

+ func (z *SeriesMeta) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SeriesMeta) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z SeriesMeta) EncodeMsg(en *msgp.Writer) (err error)

+ func (z SeriesMeta) MarshalMsg(b []byte) (o []byte, err error)

+ func (z SeriesMeta) Msgsize() (s int)

+ type SeriesMetaProperties struct

+ AggNumNorm uint32

+ AggNumRC uint32

+ ArchInterval uint32

+ Archive uint8

+ ConsolidatorNormFetch consolidation.Consolidator

+ ConsolidatorRC consolidation.Consolidator

+ Count uint32

+ SchemaID uint16

+ func (smp SeriesMetaProperties) Export() SeriesMetaPropertiesExport

+ func (z *SeriesMetaProperties) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SeriesMetaProperties) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *SeriesMetaProperties) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *SeriesMetaProperties) Msgsize() (s int)

+ func (z *SeriesMetaProperties) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type SeriesMetaPropertiesExport struct

+ AggNumNorm uint32

+ AggNumRC uint32

+ ArchInterval uint32

+ ArchiveRead uint8

+ ConsolidatorNormFetch consolidation.Consolidator

+ ConsolidatorRC consolidation.Consolidator

+ Count uint32

+ SchemaName string

+ SchemaRetentions string

v0.13.0

Sep 17, 2019

Changes in this version

type CCacheDeleteResp

+ func (c *CCacheDeleteResp) AddError(err error)

+ type GetDataRespV0 struct

+ Series []Series

+ func (z *GetDataRespV0) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *GetDataRespV0) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *GetDataRespV0) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *GetDataRespV0) Msgsize() (s int)

+ func (z *GetDataRespV0) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type GetDataRespV1 struct

+ Series []Series

+ Stats StorageStats

+ func (z *GetDataRespV1) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *GetDataRespV1) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *GetDataRespV1) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *GetDataRespV1) Msgsize() (s int)

+ func (z *GetDataRespV1) UnmarshalMsg(bts []byte) (o []byte, err error)

type GraphiteRender

+ Meta bool

+ type IndexMetaTagRecordSwap struct

+ OrgId uint32

+ Records []MetaTagRecord

+ func (m IndexMetaTagRecordSwap) Trace(span opentracing.Span)

+ func (m IndexMetaTagRecordSwap) TraceDebug(span opentracing.Span)

+ func (z *IndexMetaTagRecordSwap) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *IndexMetaTagRecordSwap) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *IndexMetaTagRecordSwap) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *IndexMetaTagRecordSwap) Msgsize() (s int)

+ func (z *IndexMetaTagRecordSwap) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type MetaTagRecord struct

+ Expressions []string

+ MetaTags []string

+ func (z *MetaTagRecord) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MetaTagRecord) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MetaTagRecord) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MetaTagRecord) Msgsize() (s int)

+ func (z *MetaTagRecord) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type MetaTagRecordSwap struct

+ Propagate bool

+ Records []MetaTagRecord

+ func (m MetaTagRecordSwap) Trace(span opentracing.Span)

+ func (m MetaTagRecordSwap) TraceDebug(span opentracing.Span)

+ func (z *MetaTagRecordSwap) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MetaTagRecordSwap) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MetaTagRecordSwap) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MetaTagRecordSwap) Msgsize() (s int)

+ func (z *MetaTagRecordSwap) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type MetaTagRecordSwapResult struct

+ Added uint32

+ Deleted uint32

+ func (z *MetaTagRecordSwapResult) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MetaTagRecordSwapResult) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z MetaTagRecordSwapResult) EncodeMsg(en *msgp.Writer) (err error)

+ func (z MetaTagRecordSwapResult) MarshalMsg(b []byte) (o []byte, err error)

+ func (z MetaTagRecordSwapResult) Msgsize() (s int)

+ type MetaTagRecordSwapResultByNode struct

+ Local MetaTagRecordSwapResult

+ PeerErrors map[string]string

+ PeerResults map[string]MetaTagRecordSwapResult

+ func (z *MetaTagRecordSwapResultByNode) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MetaTagRecordSwapResultByNode) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MetaTagRecordSwapResultByNode) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MetaTagRecordSwapResultByNode) Msgsize() (s int)

+ func (z *MetaTagRecordSwapResultByNode) UnmarshalMsg(bts []byte) (o []byte, err error)

type MetaTagRecordUpsert

+ Expressions []string

+ type RenderMeta struct

+ func (rm RenderMeta) MarshalJSONFast(b []byte) ([]byte, error)

+ type RenderStats struct

+ GetTargetsDuration time.Duration

+ PlanRunDuration time.Duration

+ PointsFetch uint32

+ PointsReturn uint32

+ PrepareSeriesDuration time.Duration

+ ResolveSeriesDuration time.Duration

+ SeriesFetch uint32

+ func (s RenderStats) MarshalJSONFast(b []byte) ([]byte, error)

+ func (s RenderStats) MarshalJSONFastRaw(b []byte) ([]byte, error)

+ type ResponseWithMeta struct

+ Meta RenderMeta

+ Series SeriesByTarget

+ func (rwm ResponseWithMeta) MarshalJSONFast(b []byte) ([]byte, error)

type Series

+ func (s *Series) EnrichWithTags(tags tagquery.Tags)

+ type StorageStats struct

+ CacheHit uint32

+ CacheHitPartial uint32

+ CacheMiss uint32

+ ChunksFromCache uint32

+ ChunksFromStore uint32

+ ChunksFromTank uint32

+ func (ss *StorageStats) Add(a *StorageStats)

+ func (ss *StorageStats) IncCacheResult(t cache.ResultType)

+ func (ss *StorageStats) IncChunksFromCache(n uint32)

+ func (ss *StorageStats) IncChunksFromStore(n uint32)

+ func (ss *StorageStats) IncChunksFromTank(n uint32)

+ func (ss *StorageStats) MarshalJSONFast(b []byte) ([]byte, error)

+ func (ss *StorageStats) MarshalJSONFastRaw(b []byte) ([]byte, error)

+ func (ss *StorageStats) Trace(span opentracing.Span)

+ func (z *StorageStats) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *StorageStats) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *StorageStats) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *StorageStats) Msgsize() (s int)

+ func (z *StorageStats) UnmarshalMsg(bts []byte) (o []byte, err error)

v0.12.0

May 14, 2019

Changes in this version

+ type IndexMetaTagRecordUpsert struct

+ MetaTags []string

+ OrgId uint32

+ Queries []string

+ func (m IndexMetaTagRecordUpsert) Trace(span opentracing.Span)

+ func (m IndexMetaTagRecordUpsert) TraceDebug(span opentracing.Span)

+ func (z *IndexMetaTagRecordUpsert) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *IndexMetaTagRecordUpsert) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *IndexMetaTagRecordUpsert) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *IndexMetaTagRecordUpsert) Msgsize() (s int)

+ func (z *IndexMetaTagRecordUpsert) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type MetaTagRecordUpsert struct

+ MetaTags []string

+ Propagate bool

+ Queries []string

+ func (m MetaTagRecordUpsert) Trace(span opentracing.Span)

+ func (m MetaTagRecordUpsert) TraceDebug(span opentracing.Span)

+ func (z *MetaTagRecordUpsert) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MetaTagRecordUpsert) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MetaTagRecordUpsert) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MetaTagRecordUpsert) Msgsize() (s int)

+ func (z *MetaTagRecordUpsert) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type MetaTagRecordUpsertResult struct

+ Created bool

+ MetaTags []string

+ Queries []string

+ func (z *MetaTagRecordUpsertResult) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MetaTagRecordUpsertResult) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MetaTagRecordUpsertResult) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MetaTagRecordUpsertResult) Msgsize() (s int)

+ func (z *MetaTagRecordUpsertResult) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type MetaTagRecordUpsertResultByNode struct

+ Local MetaTagRecordUpsertResult

+ PeerErrors map[string]string

+ PeerResults map[string]MetaTagRecordUpsertResult

+ func (z *MetaTagRecordUpsertResultByNode) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MetaTagRecordUpsertResultByNode) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MetaTagRecordUpsertResultByNode) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MetaTagRecordUpsertResultByNode) Msgsize() (s int)

+ func (z *MetaTagRecordUpsertResultByNode) UnmarshalMsg(bts []byte) (o []byte, err error)

v0.11.0

Dec 19, 2018

Changes in this version

+ type CCacheDelete struct

+ Expr []string

+ OrgId uint32

+ Patterns []string

+ Propagate bool

+ func (cd CCacheDelete) Trace(span opentracing.Span)

+ func (cd CCacheDelete) TraceDebug(span opentracing.Span)

+ type CCacheDeleteResp struct

+ DeletedArchives int

+ DeletedSeries int

+ Errors int

+ FirstError string

+ Peers map[string]CCacheDeleteResp

+ type ClusterMembers struct

+ Members []string

+ type ClusterMembersResp struct

+ MembersAdded int

+ Status string

+ type ClusterStatus struct

+ ClusterName string

+ Members []cluster.Node

+ NodeName string

+ type FromTo struct

+ From string

+ To string

+ Tz string

+ Until string

+ type GetData struct

+ Requests []Req

+ func (g GetData) Trace(span opentracing.Span)

+ func (g GetData) TraceDebug(span opentracing.Span)

+ type GetDataResp struct

+ Series []Series

+ func (z *GetDataResp) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *GetDataResp) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *GetDataResp) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *GetDataResp) Msgsize() (s int)

+ func (z *GetDataResp) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type GraphiteAutoCompleteTagValues struct

+ Expr []string

+ From int64

+ Limit uint

+ Prefix string

+ Tag string

+ type GraphiteAutoCompleteTags struct

+ Expr []string

+ From int64

+ Limit uint

+ Prefix string

+ type GraphiteFind struct

+ Format string

+ Jsonp string

+ Query string

+ type GraphiteRender struct

+ Format string

+ MaxDataPoints uint32

+ NoProxy bool

+ Process string

+ Targets []string

+ TargetsRails []string

+ func (gr GraphiteRender) Validate(ctx *macaron.Context, errs binding.Errors) binding.Errors

+ type GraphiteTagDelSeries struct

+ Paths []string

+ Propagate bool

+ func (g GraphiteTagDelSeries) Trace(span opentracing.Span)

+ func (g GraphiteTagDelSeries) TraceDebug(span opentracing.Span)

+ func (z *GraphiteTagDelSeries) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *GraphiteTagDelSeries) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *GraphiteTagDelSeries) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *GraphiteTagDelSeries) Msgsize() (s int)

+ func (z *GraphiteTagDelSeries) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type GraphiteTagDelSeriesResp struct

+ Count int

+ Peers map[string]int

+ func (z *GraphiteTagDelSeriesResp) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *GraphiteTagDelSeriesResp) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *GraphiteTagDelSeriesResp) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *GraphiteTagDelSeriesResp) Msgsize() (s int)

+ func (z *GraphiteTagDelSeriesResp) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type GraphiteTagDetails struct

+ Filter string

+ From int64

+ Tag string

+ type GraphiteTagDetailsResp struct

+ Tag string

+ Values []GraphiteTagDetailsValueResp

+ type GraphiteTagDetailsValueResp struct

+ Count uint64

+ Value string

+ type GraphiteTagFindSeries struct

+ Expr []string

+ From int64

+ type GraphiteTagFindSeriesResp struct

+ Series []string

+ type GraphiteTagResp struct

+ Tag string

+ type GraphiteTags struct

+ Filter string

+ From int64

+ type GraphiteTagsResp []GraphiteTagResp

+ type IndexAutoCompleteTagValues struct

+ Expr []string

+ From int64

+ Limit uint

+ OrgId uint32

+ Prefix string

+ Tag string

+ func (i IndexAutoCompleteTagValues) TraceDebug(span opentracing.Span)

+ func (t IndexAutoCompleteTagValues) Trace(span opentracing.Span)

+ type IndexAutoCompleteTags struct

+ Expr []string

+ From int64

+ Limit uint

+ OrgId uint32

+ Prefix string

+ func (i IndexAutoCompleteTags) TraceDebug(span opentracing.Span)

+ func (t IndexAutoCompleteTags) Trace(span opentracing.Span)

+ type IndexDelete struct

+ OrgId uint32

+ Query string

+ func (i IndexDelete) Trace(span opentracing.Span)

+ func (i IndexDelete) TraceDebug(span opentracing.Span)

+ type IndexFind struct

+ From int64

+ OrgId uint32

+ Patterns []string

+ func (i IndexFind) Trace(span opentracing.Span)

+ func (i IndexFind) TraceDebug(span opentracing.Span)

+ type IndexFindByTag struct

+ Expr []string

+ From int64

+ OrgId uint32

+ func (i IndexFindByTag) TraceDebug(span opentracing.Span)

+ func (t IndexFindByTag) Trace(span opentracing.Span)

+ type IndexFindByTagResp struct

+ Metrics []idx.Node

+ func (z *IndexFindByTagResp) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *IndexFindByTagResp) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *IndexFindByTagResp) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *IndexFindByTagResp) Msgsize() (s int)

+ func (z *IndexFindByTagResp) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type IndexFindResp struct

+ Nodes map[string][]idx.Node

+ func NewIndexFindResp() *IndexFindResp

+ func (z *IndexFindResp) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *IndexFindResp) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *IndexFindResp) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *IndexFindResp) Msgsize() (s int)

+ func (z *IndexFindResp) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type IndexGet struct

+ MKey schema.MKey

+ type IndexList struct

+ OrgId uint32

+ func (i IndexList) Trace(span opentracing.Span)

+ func (i IndexList) TraceDebug(span opentracing.Span)

+ type IndexTagDelSeries struct

+ OrgId uint32

+ Paths []string

+ func (i IndexTagDelSeries) TraceDebug(span opentracing.Span)

+ func (t IndexTagDelSeries) Trace(span opentracing.Span)

+ type IndexTagDelSeriesResp struct

+ Count int

+ func (z *IndexTagDelSeriesResp) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *IndexTagDelSeriesResp) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z IndexTagDelSeriesResp) EncodeMsg(en *msgp.Writer) (err error)

+ func (z IndexTagDelSeriesResp) MarshalMsg(b []byte) (o []byte, err error)

+ func (z IndexTagDelSeriesResp) Msgsize() (s int)

+ type IndexTagDetails struct

+ Filter string

+ From int64

+ OrgId uint32

+ Tag string

+ func (i IndexTagDetails) TraceDebug(span opentracing.Span)

+ func (t IndexTagDetails) Trace(span opentracing.Span)

+ type IndexTagDetailsResp struct

+ Values map[string]uint64

+ func (z *IndexTagDetailsResp) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *IndexTagDetailsResp) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *IndexTagDetailsResp) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *IndexTagDetailsResp) Msgsize() (s int)

+ func (z *IndexTagDetailsResp) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type IndexTags struct

+ Filter string

+ From int64

+ OrgId uint32

+ func (i IndexTags) TraceDebug(span opentracing.Span)

+ func (t IndexTags) Trace(span opentracing.Span)

+ type IndexTagsResp struct

+ Tags []string

+ func (z *IndexTagsResp) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *IndexTagsResp) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *IndexTagsResp) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *IndexTagsResp) Msgsize() (s int)

+ func (z *IndexTagsResp) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type MetricNames []idx.Archive

+ func (defs MetricNames) MarshalJSON() ([]byte, error)

+ func (defs MetricNames) MarshalJSONFast(b []byte) ([]byte, error)

+ type MetricsDelete struct

+ Query string

+ type MetricsDeleteResp struct

+ DeletedDefs int

+ func (z *MetricsDeleteResp) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MetricsDeleteResp) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z MetricsDeleteResp) EncodeMsg(en *msgp.Writer) (err error)

+ func (z MetricsDeleteResp) MarshalMsg(b []byte) (o []byte, err error)

+ func (z MetricsDeleteResp) Msgsize() (s int)

+ type NodeStatus struct

+ Primary string

+ type PrometheusQueryInstant struct

+ Query string

+ Time string

+ Timeout string

+ type PrometheusRangeQuery struct

+ End string

+ Query string

+ Start string

+ Step string

+ Timeout string

+ type PrometheusSeries struct

+ func NewPrometheusSeries(tags map[string]string, samples []model.SamplePair) *PrometheusSeries

+ func (p *PrometheusSeries) Iterator() storage.SeriesIterator

+ func (p *PrometheusSeries) Labels() labels.Labels

+ type PrometheusSeriesIterator struct

+ func (c *PrometheusSeriesIterator) At() (t int64, v float64)

+ func (c *PrometheusSeriesIterator) Err() error

+ func (c *PrometheusSeriesIterator) Next() bool

+ func (c *PrometheusSeriesIterator) Seek(t int64) bool

+ type PrometheusSeriesQuery struct

+ End string

+ Match []string

+ Start string

+ type PrometheusSeriesSet struct

+ func NewPrometheusSeriesSet(series []storage.Series) *PrometheusSeriesSet

+ func (p *PrometheusSeriesSet) At() storage.Series

+ func (p *PrometheusSeriesSet) Err() error

+ func (p *PrometheusSeriesSet) Next() bool

+ type Req struct

+ AggId uint16

+ AggNum uint32

+ ArchInterval uint32

+ Archive int

+ ConsReq consolidation.Consolidator

+ Consolidator consolidation.Consolidator

+ From uint32

+ MKey schema.MKey

+ MaxPoints uint32

+ Node cluster.Node

+ OutInterval uint32

+ Pattern string

+ RawInterval uint32

+ SchemaId uint16

+ TTL uint32

+ Target string

+ To uint32

+ func NewReq(key schema.MKey, target, patt string, from, to, maxPoints, rawInterval uint32, ...) Req

+ func (a Req) Equals(b Req) bool

+ func (r Req) DebugString() string

+ func (r Req) String() string

+ func (r Req) Trace(span opentracing.Span)

+ func (r Req) TraceLog(span opentracing.Span)

+ type Series struct

+ Consolidator consolidation.Consolidator

+ Datapoints []schema.Point

+ Interval uint32

+ QueryCons consolidation.Consolidator

+ QueryFrom uint32

+ QueryPatt string

+ QueryTo uint32

+ Tags map[string]string

+ Target string

+ func (s *Series) SetTags()

+ func (s Series) Copy(emptyDatapoints []schema.Point) Series

+ func (z *Series) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Series) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Series) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Series) Msgsize() (s int)

+ func (z *Series) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type SeriesByTarget []Series

+ func (g SeriesByTarget) Len() int

+ func (g SeriesByTarget) Less(i, j int) bool

+ func (g SeriesByTarget) Swap(i, j int)

+ func (series SeriesByTarget) ForGraphite(format string) SeriesListForPickle

+ func (series SeriesByTarget) MarshalJSON() ([]byte, error)

+ func (series SeriesByTarget) MarshalJSONFast(b []byte) ([]byte, error)

+ func (series SeriesByTarget) Pickle(buf []byte) ([]byte, error)

+ func (z *SeriesByTarget) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SeriesByTarget) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z SeriesByTarget) EncodeMsg(en *msgp.Writer) (err error)

+ func (z SeriesByTarget) MarshalMsg(b []byte) (o []byte, err error)

+ func (z SeriesByTarget) Msgsize() (s int)

+ type SeriesCompleter map[string][]SeriesCompleterItem

+ func NewSeriesCompleter() SeriesCompleter

+ func (c SeriesCompleter) Add(e SeriesCompleterItem)

+ type SeriesCompleterItem struct

+ IsLeaf string

+ Name string

+ Path string

+ type SeriesForPickle struct

+ End uint32

+ Name string

+ PathExpression string

+ Start uint32

+ Step uint32

+ Values []interface{}

+ func (z *SeriesForPickle) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SeriesForPickle) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *SeriesForPickle) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *SeriesForPickle) Msgsize() (s int)

+ func (z *SeriesForPickle) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type SeriesListForPickle []SeriesForPickle

+ func (z *SeriesListForPickle) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SeriesListForPickle) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z SeriesListForPickle) EncodeMsg(en *msgp.Writer) (err error)

+ func (z SeriesListForPickle) MarshalMsg(b []byte) (o []byte, err error)

+ func (z SeriesListForPickle) Msgsize() (s int)

+ type SeriesPickle []SeriesPickleItem

+ func (s SeriesPickle) Pickle(buf []byte) ([]byte, error)

+ func (z *SeriesPickle) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SeriesPickle) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z SeriesPickle) EncodeMsg(en *msgp.Writer) (err error)

+ func (z SeriesPickle) MarshalMsg(b []byte) (o []byte, err error)

+ func (z SeriesPickle) Msgsize() (s int)

+ type SeriesPickleItem struct

+ Intervals [][]int64

+ IsLeaf bool

+ Path string

+ func NewSeriesPickleItem(path string, isLeaf bool, intervals [][]int64) SeriesPickleItem

+ func (z *SeriesPickleItem) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SeriesPickleItem) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *SeriesPickleItem) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *SeriesPickleItem) Msgsize() (s int)

+ func (z *SeriesPickleItem) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type SeriesTree []SeriesTreeItem

+ func NewSeriesTree() *SeriesTree

+ func (s *SeriesTree) Add(i *SeriesTreeItem)

+ type SeriesTreeItem struct

+ AllowChildren int

+ Context map[string]int

+ Expandable int

+ ID string

+ Leaf int

+ Text string

+ type StringList []string

+ func (z *StringList) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *StringList) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z StringList) EncodeMsg(en *msgp.Writer) (err error)

+ func (z StringList) MarshalMsg(b []byte) (o []byte, err error)

+ func (z StringList) Msgsize() (s int)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL