models

package
v0.13.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 28, 2019 License: AGPL-3.0 Imports: 25 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CCacheDelete 

type CCacheDelete struct {
	// patterns with name globbing
	Patterns []string `json:"patterns" form:"patterns" `
	// tag expressions to select series
	Expr      []string `json:"expr" form:"expr"`
	OrgId     uint32   `json:"orgId" form:"orgId" binding:"Required"`
	Propagate bool     `json:"propagate" form:"propagate"`
}

func (CCacheDelete) Trace 

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

func (CCacheDelete) TraceDebug 

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

type CCacheDeleteResp 

type CCacheDeleteResp struct {
	Errors          int                         `json:"errors"`
	FirstError      string                      `json:"firstError"`
	DeletedSeries   int                         `json:"deletedSeries"`
	DeletedArchives int                         `json:"deletedArchives"`
	Peers           map[string]CCacheDeleteResp `json:"peers"`
}

func (*CCacheDeleteResp) AddError added in v0.13.0 

func (c *CCacheDeleteResp) AddError(err error)

type ClusterMembers 

type ClusterMembers struct {
	Members []string `json:"members"`
}

type ClusterMembersResp 

type ClusterMembersResp struct {
	Status       string `json:"status"`
	MembersAdded int    `json:"membersAdded"`
}

type ClusterStatus 

type ClusterStatus struct {
	ClusterName string         `json:"clusterName"`
	NodeName    string         `json:"nodeName"`
	Members     []cluster.Node `json:"members"`
}

type FromTo 

type FromTo struct {
	From  string `json:"from" form:"from"`
	Until string `json:"until" form:"until"`
	To    string `json:"to" form:"to"` // graphite uses 'until' but we allow to alternatively cause it's shorter
	Tz    string `json:"tz" form:"tz"`
}

type GetData 

type GetData struct {
	Requests []Req `json:"requests" binding:"Required"`
}

func (GetData) Trace 

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

func (GetData) TraceDebug 

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

type GetDataRespV0 added in v0.13.0 

type GetDataRespV0 struct {
	Series []Series
}

func (*GetDataRespV0) DecodeMsg added in v0.13.0 

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

DecodeMsg implements msgp.Decodable

func (*GetDataRespV0) EncodeMsg added in v0.13.0 

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

EncodeMsg implements msgp.Encodable

func (*GetDataRespV0) MarshalMsg added in v0.13.0 

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

MarshalMsg implements msgp.Marshaler

func (*GetDataRespV0) Msgsize added in v0.13.0 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*GetDataRespV0) UnmarshalMsg added in v0.13.0 

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

UnmarshalMsg implements msgp.Unmarshaler

type GetDataRespV1 added in v0.13.0 

type GetDataRespV1 struct {
	Stats  StorageStats
	Series []Series
}

func (*GetDataRespV1) DecodeMsg added in v0.13.0 

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

DecodeMsg implements msgp.Decodable

func (*GetDataRespV1) EncodeMsg added in v0.13.0 

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

EncodeMsg implements msgp.Encodable

func (*GetDataRespV1) MarshalMsg added in v0.13.0 

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

MarshalMsg implements msgp.Marshaler

func (*GetDataRespV1) Msgsize added in v0.13.0 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*GetDataRespV1) UnmarshalMsg added in v0.13.0 

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

UnmarshalMsg implements msgp.Unmarshaler

type GraphiteAutoCompleteTagValues 

type GraphiteAutoCompleteTagValues struct {
	Tag    string   `json:"tag" form:"tag"`
	Prefix string   `json:"valuePrefix" form:"valuePrefix"`
	Expr   []string `json:"expr" form:"expr"`
	Limit  uint     `json:"limit" form:"limit"`
}

type GraphiteAutoCompleteTags 

type GraphiteAutoCompleteTags struct {
	Prefix string   `json:"tagPrefix" form:"tagPrefix"`
	Expr   []string `json:"expr" form:"expr"`
	Limit  uint     `json:"limit" form:"limit"`
}

type GraphiteFind 

type GraphiteFind struct {
	FromTo
	Query  string `json:"query" form:"query" binding:"Required"`
	Format string `json:"format" form:"format" binding:"In(,completer,json,treejson,msgpack,pickle)"`
	Jsonp  string `json:"jsonp" form:"jsonp"`
}

type GraphiteRender 

type GraphiteRender struct {
	FromTo
	MaxDataPoints uint32   `json:"maxDataPoints" form:"maxDataPoints" binding:"Default(800)"`
	Targets       []string `json:"target" form:"target"`
	TargetsRails  []string `form:"target[]"` // # Rails/PHP/jQuery common practice format: ?target[]=path.1&target[]=path.2 -> like graphite, we allow this.
	Format        string   `json:"format" form:"format" binding:"In(,json,msgp,msgpack,pickle)"`
	NoProxy       bool     `json:"local" form:"local"` //this is set to true by graphite-web when it passes request to cluster servers
	Meta          bool     `json:"meta" form:"meta"`   // request for meta data, which will be returned as long as the format is compatible (json) and we don't have to go via graphite
	Process       string   `json:"process" form:"process" binding:"In(,none,stable,any);Default(stable)"`
}

func (GraphiteRender) Validate 

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

type GraphiteTagDelSeries 

type GraphiteTagDelSeries struct {
	Paths     []string `json:"path" form:"path"`
	Propagate bool     `json:"propagate" form:"propagate" binding:"Default(true)"`
}

func (*GraphiteTagDelSeries) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*GraphiteTagDelSeries) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*GraphiteTagDelSeries) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*GraphiteTagDelSeries) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (GraphiteTagDelSeries) Trace 

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

func (GraphiteTagDelSeries) TraceDebug 

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

func (*GraphiteTagDelSeries) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type GraphiteTagDelSeriesResp 

type GraphiteTagDelSeriesResp struct {
	Count int            `json:"count"`
	Peers map[string]int `json:"peers"`
}

func (*GraphiteTagDelSeriesResp) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*GraphiteTagDelSeriesResp) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*GraphiteTagDelSeriesResp) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*GraphiteTagDelSeriesResp) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*GraphiteTagDelSeriesResp) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type GraphiteTagDetails 

type GraphiteTagDetails struct {
	Tag    string `json:"tag" form:"tag"`
	Filter string `json:"filter" form:"filter"`
}

type GraphiteTagDetailsResp 

type GraphiteTagDetailsResp struct {
	Tag    string                        `json:"tag"`
	Values []GraphiteTagDetailsValueResp `json:"values"`
}

type GraphiteTagDetailsValueResp 

type GraphiteTagDetailsValueResp struct {
	Count uint64 `json:"count"`
	Value string `json:"value"`
}

type GraphiteTagFindSeries 

type GraphiteTagFindSeries struct {
	Expr []string `json:"expr" form:"expr"`
	From int64    `json:"from" form:"from"`
}

type GraphiteTagFindSeriesResp 

type GraphiteTagFindSeriesResp struct {
	Series []string `json:"series"`
}

type GraphiteTagResp 

type GraphiteTagResp struct {
	Tag string `json:"tag"`
}

type GraphiteTags 

type GraphiteTags struct {
	Filter string `json:"filter" form:"filter"`
}

type GraphiteTagsResp 

type GraphiteTagsResp []GraphiteTagResp

type IndexAutoCompleteTagValues 

type IndexAutoCompleteTagValues struct {
	OrgId  uint32   `json:"orgId" binding:"Required"`
	Tag    string   `json:"tag"`
	Prefix string   `json:"prefix"`
	Expr   []string `json:"expressions"`
	Limit  uint     `json:"limit"`
}

func (IndexAutoCompleteTagValues) Trace 

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

func (IndexAutoCompleteTagValues) TraceDebug 

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

type IndexAutoCompleteTags 

type IndexAutoCompleteTags struct {
	OrgId  uint32   `json:"orgId" binding:"Required"`
	Prefix string   `json:"Prefix"`
	Expr   []string `json:"expressions"`
	Limit  uint     `json:"limit"`
}

func (IndexAutoCompleteTags) Trace 

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

func (IndexAutoCompleteTags) TraceDebug 

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

type IndexDelete 

type IndexDelete struct {
	Query string `json:"query" form:"query" binding:"Required"`
	OrgId uint32 `json:"orgId" form:"orgId" binding:"Required"`
}

func (IndexDelete) Trace 

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

func (IndexDelete) TraceDebug 

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

type IndexFind 

type IndexFind struct {
	Patterns []string `json:"patterns" form:"patterns" binding:"Required"`
	OrgId    uint32   `json:"orgId" form:"orgId" binding:"Required"`
	From     int64    `json:"from" form:"from"`
}

func (IndexFind) Trace 

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

func (IndexFind) TraceDebug 

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

type IndexFindByTag 

type IndexFindByTag struct {
	OrgId uint32   `json:"orgId" binding:"Required"`
	Expr  []string `json:"expressions"`
	From  int64    `json:"from"`
}

func (IndexFindByTag) Trace 

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

func (IndexFindByTag) TraceDebug 

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

type IndexFindByTagResp 

type IndexFindByTagResp struct {
	Metrics []idx.Node `json:"metrics"`
}

func (*IndexFindByTagResp) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*IndexFindByTagResp) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*IndexFindByTagResp) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*IndexFindByTagResp) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*IndexFindByTagResp) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type IndexFindResp 

type IndexFindResp struct {
	Nodes map[string][]idx.Node
}

func NewIndexFindResp 

func NewIndexFindResp() *IndexFindResp

func (*IndexFindResp) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*IndexFindResp) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*IndexFindResp) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*IndexFindResp) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*IndexFindResp) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type IndexGet 

type IndexGet struct {
	MKey schema.MKey `json:"id" form:"id" binding:"Required"`
}

type IndexList 

type IndexList struct {
	OrgId uint32 `json:"orgId" form:"orgId" binding:"Required"`
}

func (IndexList) Trace 

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

func (IndexList) TraceDebug 

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

type IndexTagDelSeries 

type IndexTagDelSeries struct {
	OrgId uint32   `json:"orgId" binding:"Required"`
	Paths []string `json:"path" form:"path"`
}

func (IndexTagDelSeries) Trace 

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

func (IndexTagDelSeries) TraceDebug 

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

type IndexTagDelSeriesResp 

type IndexTagDelSeriesResp struct {
	Count int
}

func (*IndexTagDelSeriesResp) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (IndexTagDelSeriesResp) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (IndexTagDelSeriesResp) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (IndexTagDelSeriesResp) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*IndexTagDelSeriesResp) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type IndexTagDetails 

type IndexTagDetails struct {
	OrgId  uint32 `json:"orgId" binding:"Required"`
	Filter string `json:"filter"`
	Tag    string `json:"tag" binding:"Required"`
}

func (IndexTagDetails) Trace 

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

func (IndexTagDetails) TraceDebug 

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

type IndexTagDetailsResp 

type IndexTagDetailsResp struct {
	Values map[string]uint64 `json:"values"`
}

func (*IndexTagDetailsResp) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*IndexTagDetailsResp) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*IndexTagDetailsResp) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*IndexTagDetailsResp) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*IndexTagDetailsResp) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type IndexTags 

type IndexTags struct {
	OrgId  uint32 `json:"orgId" binding:"Required"`
	Filter string `json:"filter"`
}

func (IndexTags) Trace 

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

func (IndexTags) TraceDebug 

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

type IndexTagsResp 

type IndexTagsResp struct {
	Tags []string `json:"tags"`
}

func (*IndexTagsResp) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*IndexTagsResp) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*IndexTagsResp) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*IndexTagsResp) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*IndexTagsResp) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type MetaTagRecord added in v0.13.0 

type MetaTagRecord struct {
	MetaTags    []string `json:"metaTags" binding:"Required"`
	Expressions []string `json:"expressions" binding:"Required"`
}

type MetaTagRecordSwap added in v0.13.0 

type MetaTagRecordSwap struct {
	Records []MetaTagRecord `json:"records"`
}

func (MetaTagRecordSwap) Trace added in v0.13.0 

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

func (MetaTagRecordSwap) TraceDebug added in v0.13.0 

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

type MetaTagRecordUpsert added in v0.12.0 

type MetaTagRecordUpsert struct {
	MetaTags    []string `json:"metaTags"`
	Expressions []string `json:"expressions" binding:"Required"`
}

func (MetaTagRecordUpsert) Trace added in v0.12.0 

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

func (MetaTagRecordUpsert) TraceDebug added in v0.12.0 

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

type MetricNames 

type MetricNames []idx.Archive

func (MetricNames) MarshalJSON 

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

func (MetricNames) MarshalJSONFast 

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

type MetricsDelete 

type MetricsDelete struct {
	Query string `json:"query" form:"query" binding:"Required"`
}

type MetricsDeleteResp 

type MetricsDeleteResp struct {
	DeletedDefs int `json:"deletedDefs"`
}

func (*MetricsDeleteResp) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (MetricsDeleteResp) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (MetricsDeleteResp) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (MetricsDeleteResp) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*MetricsDeleteResp) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type NodeStatus 

type NodeStatus struct {
	Primary string `json:"primary" form:"primary" binding:"Required"`
}

type PrometheusQueryInstant 

type PrometheusQueryInstant struct {
	Query   string `form:"query"`   //<string>: Prometheus expression query string.
	Time    string `form:"time"`    //<rfc3339 | unix_timestamp>: Start timestamp.
	Timeout string `form:"timeout"` //<duration>: Evaluation timeout. Optional. Defaults to and is capped by the value of the -query.timeout flag.
}

type PrometheusRangeQuery 

type PrometheusRangeQuery struct {
	Query   string `form:"query"`   //<string>: Prometheus expression query string.
	Start   string `form:"start"`   //<rfc3339 | unix_timestamp>: Start timestamp.
	End     string `form:"end"`     //<rfc3339 | unix_timestamp>: End timestamp.
	Step    string `form:"step"`    //<duration>: Query resolution step width.
	Timeout string `form:"timeout"` //<duration>: Evaluation timeout. Optional. Defaults to and is capped by the value of the -query.timeout flag.
}

type PrometheusSeries 

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

func NewPrometheusSeries 

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

func (*PrometheusSeries) Iterator 

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

func (*PrometheusSeries) Labels 

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

type PrometheusSeriesIterator 

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

func (*PrometheusSeriesIterator) At 

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

func (*PrometheusSeriesIterator) Err 

func (c *PrometheusSeriesIterator) Err() error

func (*PrometheusSeriesIterator) Next 

func (c *PrometheusSeriesIterator) Next() bool

func (*PrometheusSeriesIterator) Seek 

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

type PrometheusSeriesQuery 

type PrometheusSeriesQuery struct {
	Match []string `form:"match[]"` //<string>: Prometheus expression query string.
	Start string   `form:"start"`   //<rfc3339 | unix_timestamp>: Start timestamp.
	End   string   `form:"end"`     //<rfc3339 | unix_timestamp>: End timestamp.
}

type PrometheusSeriesSet 

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

func NewPrometheusSeriesSet 

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

func (*PrometheusSeriesSet) At 

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

func (*PrometheusSeriesSet) Err 

func (p *PrometheusSeriesSet) Err() error

func (*PrometheusSeriesSet) Next 

func (p *PrometheusSeriesSet) Next() bool

type RenderMeta added in v0.13.0 

type RenderMeta struct {
	RenderStats
	StorageStats
}

RenderMeta holds metadata about a render request/response

func (RenderMeta) MarshalJSONFast added in v0.13.0 

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

type RenderStats added in v0.13.0 

type RenderStats struct {
	ResolveSeriesDuration time.Duration `json:"executeplan.resolve-series.ms"`
	GetTargetsDuration    time.Duration `json:"executeplan.get-targets.ms"`
	PrepareSeriesDuration time.Duration `json:"executeplan.prepare-series.ms"`
	PlanRunDuration       time.Duration `json:"executeplan.plan-run.ms"`
	SeriesFetch           uint32        `json:"executeplan.series-fetch.count"`
	PointsFetch           uint32        `json:"executeplan.points-fetch.count"`
	PointsReturn          uint32        `json:"executeplan.points-return.count"`
}

func (RenderStats) MarshalJSONFast added in v0.13.0 

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

func (RenderStats) MarshalJSONFastRaw added in v0.13.0 

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

type Req 

type Req struct {
	// these fields can be set straight away:
	MKey        schema.MKey `json:"key"`     // metric key aka metric definition id (orgid.<hash>), often same as target for graphite-metrictank requests
	Target      string      `json:"target"`  // the target we should return either to graphite or as if we're graphite.  simply the graphite metric key from the index
	Pattern     string      `json:"pattern"` // the original query pattern specified by user (not wrapped by any functions). e.g. `foo.b*`. To be able to tie the result data back to the data need as requested
	From        uint32      `json:"from"`
	To          uint32      `json:"to"`
	MaxPoints   uint32      `json:"maxPoints"`
	RawInterval uint32      `json:"rawInterval"` // the interval of the raw metric before any consolidation
	// the consolidation method for rollup archive and normalization. (not runtime consolidation)
	// ConsReq 0 -> configured value
	// Conseq != 0 -> closest value we can offer based on config
	Consolidator consolidation.Consolidator `json:"consolidator"`
	// requested consolidation method via consolidateBy(), if any.
	// could be 0 if it was not specified or reset by a "special" functions. in which case, we use the configured default.
	// we need to make this differentiation to tie back to the original request (and we can't just fill in the concrete consolidation in the request,
	// because one request may result in multiple series with different consolidators)
	ConsReq  consolidation.Consolidator `json:"consolidator_req"`
	Node     cluster.Node               `json:"-"`
	SchemaId uint16                     `json:"schemaId"`
	AggId    uint16                     `json:"aggId"`

	// these fields need some more coordination and are typically set later (after request alignment)
	Archive      uint8  `json:"archive"`      // 0 means original data, 1 means first agg level, 2 means 2nd, etc.
	ArchInterval uint32 `json:"archInterval"` // the interval corresponding to the archive we'll fetch
	TTL          uint32 `json:"ttl"`          // the ttl of the archive we'll fetch
	OutInterval  uint32 `json:"outInterval"`  // the interval of the output data, after any runtime consolidation
	AggNum       uint32 `json:"aggNum"`       // how many points to consolidate together at runtime, after fetching from the archive (normalization)
}

Req is a request for data by MKey and parameters such as consolidator, max points, etc

func NewReq 

func NewReq(key schema.MKey, target, patt string, from, to, maxPoints, rawInterval uint32, cons, consReq consolidation.Consolidator, node cluster.Node, schemaId, aggId uint16) Req

NewReq creates a new request. It sets all properties minus the ones that need request alignment

func (Req) DebugString 

func (r Req) DebugString() string

func (Req) Equals 

func (a Req) Equals(b Req) bool

Equals compares all fields of a to b for equality. Except

  • TTL (because alignRequests may change it) for 100% correctness we may want to fix this in the future but for now, should be harmless since the field is not that important for archive fetching
  • For the Node field we just compare the node.Name

rather then doing a deep comparison.

func (Req) String 

func (r Req) String() string

func (Req) TraceLog 

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

TraceLog puts all request properties in a span log entry good for when a span deals with multiple requests note that the amount of data generated here can be up to 1000~1500 bytes

type ResponseWithMeta added in v0.13.0 

type ResponseWithMeta struct {
	Meta   RenderMeta
	Series SeriesByTarget
}

ResponseWithMeta is a graphite render response with metadata

func (ResponseWithMeta) MarshalJSONFast added in v0.13.0 

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

type Series 

type Series struct {
	Target       string            // for fetched data, set from models.Req.Target, i.e. the metric graphite key. for function output, whatever should be shown as target string (legend)
	Tags         map[string]string // Must be set initially via call to `SetTags()`
	Interval     uint32
	QueryPatt    string                     // to tie series back to request it came from. e.g. foo.bar.*, or if series outputted by func it would be e.g. scale(foo.bar.*,0.123456)
	QueryFrom    uint32                     // to tie series back to request it came from
	QueryTo      uint32                     // to tie series back to request it came from
	QueryCons    consolidation.Consolidator // to tie series back to request it came from (may be 0 to mean use configured default)
	Consolidator consolidation.Consolidator // consolidator to actually use (for fetched series this may not be 0, default must be resolved. if series created by function, may be 0)
	Meta         SeriesMeta                 // note: this series could be a "just fetched" series, or one derived from many other series
	Datapoints   []schema.Point
}

func (Series) Copy 

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

Copy returns a deep copy. The returned value does not link to the same memory space for any of the properties

func (*Series) CopyTags added in v0.13.1 

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

CopyTags makes a deep copy of the tags

func (*Series) CopyTagsWith added in v0.13.1 

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

CopyTagsWith makes a deep copy of the tags and sets the given tag

func (*Series) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*Series) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*Series) EnrichWithTags added in v0.13.0 

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

func (*Series) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*Series) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Series) SetTags 

func (s *Series) SetTags()

func (*Series) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type SeriesByTarget 

type SeriesByTarget []Series

func (*SeriesByTarget) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (SeriesByTarget) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (SeriesByTarget) ForGraphite 

func (series SeriesByTarget) ForGraphite(format string) SeriesListForPickle

func (SeriesByTarget) Len 

func (g SeriesByTarget) Len() int

func (SeriesByTarget) Less 

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

func (SeriesByTarget) MarshalJSON 

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

func (SeriesByTarget) MarshalJSONFast 

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

regular graphite output

func (SeriesByTarget) MarshalJSONFastWithMeta added in v0.13.1 

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

func (SeriesByTarget) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (SeriesByTarget) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (SeriesByTarget) Pickle 

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

func (SeriesByTarget) Swap 

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

func (*SeriesByTarget) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type SeriesCompleter 

type SeriesCompleter map[string][]SeriesCompleterItem

func NewSeriesCompleter 

func NewSeriesCompleter() SeriesCompleter

func (SeriesCompleter) Add 

func (c SeriesCompleter) Add(e SeriesCompleterItem)

type SeriesCompleterItem 

type SeriesCompleterItem struct {
	Path   string `json:"path"`
	Name   string `json:"name"`
	IsLeaf string `json:"is_leaf"`
}

type SeriesForPickle 

type SeriesForPickle struct {
	Name           string        `pickle:"name" msg:"name"`
	Start          uint32        `pickle:"start" msg:"start"`
	End            uint32        `pickle:"end" msg:"end"`
	Step           uint32        `pickle:"step" msg:"step"`
	Values         []interface{} `pickle:"values" msg:"values"`
	PathExpression string        `pickle:"pathExpression" msg:"pathExpression"`
}

func (*SeriesForPickle) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*SeriesForPickle) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*SeriesForPickle) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*SeriesForPickle) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*SeriesForPickle) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type SeriesListForPickle 

type SeriesListForPickle []SeriesForPickle

func (*SeriesListForPickle) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (SeriesListForPickle) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (SeriesListForPickle) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (SeriesListForPickle) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*SeriesListForPickle) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type SeriesMeta added in v0.13.1 

type SeriesMeta []SeriesMetaProperties

SeriesMeta counts the number of series for each set of meta properties note: it's illegal for SeriesMeta to include multiple entries that include the same properties

func (SeriesMeta) Copy added in v0.13.1 

func (a SeriesMeta) Copy() SeriesMeta

Copy creates a copy of SeriesMeta

func (SeriesMeta) CopyWithChange added in v0.13.1 

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

CopyWithChange creates a copy of SeriesMeta, but executes the requested change on each SeriesMetaProperties

func (*SeriesMeta) DecodeMsg added in v0.13.1 

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

DecodeMsg implements msgp.Decodable

func (SeriesMeta) EncodeMsg added in v0.13.1 

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

EncodeMsg implements msgp.Encodable

func (SeriesMeta) MarshalJSONFast added in v0.13.1 

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

func (SeriesMeta) MarshalMsg added in v0.13.1 

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

MarshalMsg implements msgp.Marshaler

func (SeriesMeta) Merge added in v0.13.1 

func (a SeriesMeta) Merge(b SeriesMeta) SeriesMeta

Merge merges SeriesMeta b into a counts for identical properties get added together

func (SeriesMeta) Msgsize added in v0.13.1 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*SeriesMeta) UnmarshalMsg added in v0.13.1 

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

UnmarshalMsg implements msgp.Unmarshaler

type SeriesMetaProperties added in v0.13.1 

type SeriesMetaProperties struct {
	SchemaID              uint16                     // id of storage-schemas rule this series corresponds to
	Archive               uint8                      // which archive was being read from
	ArchInterval          uint32                     // the interval of the archive we fetch
	AggNumNorm            uint32                     // aggNum for normalization
	AggNumRC              uint32                     // aggNum runtime consolidation
	ConsolidatorNormFetch consolidation.Consolidator // consolidator used for normalization and reading from store (if applicable)
	ConsolidatorRC        consolidation.Consolidator // consolidator used for runtime consolidation to honor maxdatapoints (if applicable).
	Count                 uint32                     // number of series corresponding to these properties
}

SeriesMetaProperties describes the properties of a series (fetching and normalization and the count of series corresponding to them)

func (*SeriesMetaProperties) DecodeMsg added in v0.13.1 

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

DecodeMsg implements msgp.Decodable

func (*SeriesMetaProperties) EncodeMsg added in v0.13.1 

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

EncodeMsg implements msgp.Encodable

func (SeriesMetaProperties) Export added in v0.13.1 

func (smp SeriesMetaProperties) Export() SeriesMetaPropertiesExport

Export returns a human-friendly version of the SeriesMetaProperties.

func (*SeriesMetaProperties) MarshalMsg added in v0.13.1 

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

MarshalMsg implements msgp.Marshaler

func (*SeriesMetaProperties) Msgsize added in v0.13.1 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*SeriesMetaProperties) UnmarshalMsg added in v0.13.1 

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

UnmarshalMsg implements msgp.Unmarshaler

type SeriesMetaPropertiesExport added in v0.13.1 

type SeriesMetaPropertiesExport struct {
	SchemaName            string                     // name of schema rule used
	SchemaRetentions      string                     // schema retentions used
	ArchiveRead           uint8                      // which archive was being read from
	ArchInterval          uint32                     // the interval of the archive we fetch
	AggNumNorm            uint32                     // aggNum for normalization
	AggNumRC              uint32                     // aggNum runtime consolidation
	ConsolidatorNormFetch consolidation.Consolidator // consolidator used for normalization and reading from store (if applicable)
	ConsolidatorRC        consolidation.Consolidator // consolidator used for runtime consolidation to honor maxdatapoints (if applicable).
	Count                 uint32                     // number of series corresponding to these properties
}

SeriesMetaPropertiesExport is an "export" of a SeriesMetaProperties it is a more user friendly representation

type SeriesPickle 

type SeriesPickle []SeriesPickleItem

func (*SeriesPickle) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (SeriesPickle) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (SeriesPickle) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (SeriesPickle) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (SeriesPickle) Pickle 

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

func (*SeriesPickle) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type SeriesPickleItem 

type SeriesPickleItem struct {
	Path      string    `pickle:"path" msg:"path"`
	IsLeaf    bool      `pickle:"isLeaf" msg:"isLeaf"`
	Intervals [][]int64 `pickle:"intervals" msg:"intervals"` // list of (start,end) tuples
}

func NewSeriesPickleItem 

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

func (*SeriesPickleItem) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (*SeriesPickleItem) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (*SeriesPickleItem) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (*SeriesPickleItem) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*SeriesPickleItem) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

type SeriesTree 

type SeriesTree []SeriesTreeItem

func (*SeriesTree) Add 

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

type SeriesTreeItem 

type SeriesTreeItem struct {
	AllowChildren int            `json:"allowChildren"`
	Expandable    int            `json:"expandable"`
	Leaf          int            `json:"leaf"`
	ID            string         `json:"id"`
	Text          string         `json:"text"`
	Context       map[string]int `json:"context"` // unused
}

type StorageStats added in v0.13.0 

type StorageStats struct {
	CacheMiss       uint32 `json:"executeplan.cache-miss.count"`
	CacheHitPartial uint32 `json:"executeplan.cache-hit-partial.count"`
	CacheHit        uint32 `json:"executeplan.cache-hit.count"`
	ChunksFromTank  uint32 `json:"executeplan.chunks-from-tank.count"`
	ChunksFromCache uint32 `json:"executeplan.chunks-from-cache.count"`
	ChunksFromStore uint32 `json:"executeplan.chunks-from-store.count"`
}

func (*StorageStats) Add added in v0.13.0 

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

Add adds a to ss.

func (*StorageStats) DecodeMsg added in v0.13.0 

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

DecodeMsg implements msgp.Decodable

func (*StorageStats) EncodeMsg added in v0.13.0 

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

EncodeMsg implements msgp.Encodable

func (*StorageStats) IncCacheResult added in v0.13.0 

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

func (*StorageStats) IncChunksFromCache added in v0.13.0 

func (ss *StorageStats) IncChunksFromCache(n uint32)

func (*StorageStats) IncChunksFromStore added in v0.13.0 

func (ss *StorageStats) IncChunksFromStore(n uint32)

func (*StorageStats) IncChunksFromTank added in v0.13.0 

func (ss *StorageStats) IncChunksFromTank(n uint32)

func (*StorageStats) MarshalJSONFast added in v0.13.0 

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

func (*StorageStats) MarshalJSONFastRaw added in v0.13.0 

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

func (*StorageStats) MarshalMsg added in v0.13.0 

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

MarshalMsg implements msgp.Marshaler

func (*StorageStats) Msgsize added in v0.13.0 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*StorageStats) Trace added in v0.13.0 

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

func (*StorageStats) UnmarshalMsg added in v0.13.0 

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

UnmarshalMsg implements msgp.Unmarshaler

type StringList 

type StringList []string

func (*StringList) DecodeMsg 

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

DecodeMsg implements msgp.Decodable

func (StringList) EncodeMsg 

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

EncodeMsg implements msgp.Encodable

func (StringList) MarshalMsg 

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

MarshalMsg implements msgp.Marshaler

func (StringList) Msgsize 

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

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*StringList) UnmarshalMsg 

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

UnmarshalMsg implements msgp.Unmarshaler

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.