models

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Jul 30, 2020 License: AGPL-3.0 Imports: 24 Imported by: 0

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)"`
	Optimizations string   `json:"optimizations" form:"optimizations"`
}

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"`
}

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"`
	Format string   `json:"format" form:"format" binding:"In(,series-json,lastts-json);Default(series-json)"`
	Limit  int      `json:"limit" binding:"Default(0)"`
	Meta   bool     `json:"meta" binding:"Default(false)"`
}

type GraphiteTagFindSeriesLastTsResp added in v1.0.0

type GraphiteTagFindSeriesLastTsResp struct {
	Series   []SeriesLastTs `json:"series"`
	Warnings []string       `json:"warnings,omitempty"`
}

type GraphiteTagFindSeriesMetaResp added in v1.0.0

type GraphiteTagFindSeriesMetaResp struct {
	Series   []string `json:"series"`
	Warnings []string `json:"warnings,omitempty"`
}

type GraphiteTagFindSeriesResp

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

type GraphiteTagResp

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

type GraphiteTagTerms added in v1.0.0

type GraphiteTagTerms struct {
	Tags []string `json:"tags"`
	Expr []string `json:"expressions"`
}

func (*GraphiteTagTerms) DecodeMsg added in v1.0.0

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

DecodeMsg implements msgp.Decodable

func (*GraphiteTagTerms) EncodeMsg added in v1.0.0

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

EncodeMsg implements msgp.Encodable

func (*GraphiteTagTerms) MarshalMsg added in v1.0.0

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

MarshalMsg implements msgp.Marshaler

func (*GraphiteTagTerms) Msgsize added in v1.0.0

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

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

func (*GraphiteTagTerms) UnmarshalMsg added in v1.0.0

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

UnmarshalMsg implements msgp.Unmarshaler

type GraphiteTagTermsResp added in v1.0.0

type GraphiteTagTermsResp struct {
	TotalSeries uint32                       `json:"totalSeries"`
	Terms       map[string]map[string]uint32 `json:"terms"`
}

func (*GraphiteTagTermsResp) DecodeMsg added in v1.0.0

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

DecodeMsg implements msgp.Decodable

func (*GraphiteTagTermsResp) EncodeMsg added in v1.0.0

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

EncodeMsg implements msgp.Encodable

func (*GraphiteTagTermsResp) MarshalMsg added in v1.0.0

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

MarshalMsg implements msgp.Marshaler

func (*GraphiteTagTermsResp) Msgsize added in v1.0.0

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

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

func (*GraphiteTagTermsResp) UnmarshalMsg added in v1.0.0

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

UnmarshalMsg implements msgp.Unmarshaler

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 (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 IndexTagTerms added in v1.0.0

type IndexTagTerms struct {
	OrgId uint32   `json:"orgId" binding:"Required"`
	Tags  []string `json:"tags"`
	Expr  []string `json:"expressions"`
}

func (IndexTagTerms) Trace added in v1.0.0

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

func (IndexTagTerms) TraceDebug added in v1.0.0

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

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 PNGroup added in v1.0.0

type PNGroup uint64

PNGroup is an identifier for a pre-normalization group: data that can be pre-normalized together

func (*PNGroup) DecodeMsg added in v1.0.0

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

DecodeMsg implements msgp.Decodable

func (PNGroup) EncodeMsg added in v1.0.0

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

EncodeMsg implements msgp.Encodable

func (PNGroup) MarshalMsg added in v1.0.0

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

MarshalMsg implements msgp.Marshaler

func (PNGroup) Msgsize added in v1.0.0

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

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

func (*PNGroup) UnmarshalMsg added in v1.0.0

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

UnmarshalMsg implements msgp.Unmarshaler

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"`
	PNGroup     PNGroup     `json:"pngroup"`
	RawInterval uint32      `json:"rawInterval"` // the interval of the raw metric before any consolidation
	// the consolidation method for rollup archive and normalization (pre-normalization and runtime normalization). (but not runtime consolidation). Is never 0/None
	// if ConsReq == 0 -> configured value
	// if 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 planning)
	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 series after fetching (possibly with pre-normalization) and after-fetch runtime normalization. not aware of further normalization or runtime consolidation
	AggNum       uint32 `json:"aggNum"`       // how many points to consolidate together for after-fetch runtime normalization (see docs/consolidation.md)
}

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, pngroup PNGroup, cons, consReq consolidation.Consolidator, node cluster.Node, schemaId, aggId uint16) Req

NewReq creates a new request. It sets all properties except the ones that need request planning

func (*Req) AdjustTo added in v1.0.0

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

AdjustTo adjusts the request to accommodate the requested interval notes: * the Req MUST have been Plan()'d already! * interval MUST be a multiple of the ArchInterval (so we can normalize if needed) * the TTL of lower resolution archives is always assumed to be at least as long as the current archive

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 the Node field: we just compare the node.Name rather then doing a deep comparison.

func (*Req) Init added in v1.0.0

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

Init initializes a request based on the metadata that we know of. It sets all properties except the ones that need request planning

func (*Req) Plan added in v1.0.0

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

Plan updates the planning parameters to match the i'th archive in its retention rules

func (*Req) PlanNormalization added in v1.0.0

func (r *Req) PlanNormalization(interval uint32)

PlanNormalization updates the planning parameters to accommodate after-fetch runtime normalization to the specified interval

func (Req) PointsFetch added in v1.0.0

func (r Req) PointsFetch() uint32

PointsFetch returns how many points this request will fetch when executed

func (Req) PointsReturn added in v1.0.0

func (r Req) PointsReturn(planMDP uint32) uint32

PointsReturn estimates the amount of points that will be returned for this request It is not aware of summarize() or on-demand runtime normalization. but does account for after-fetch runtime normalization and runtime consolidation

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)
	QueryMDP     uint32                     // to tie series back to request it came from
	QueryPNGroup PNGroup                    // to tie series back to request it came from
	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) IsCanonical added in v1.0.0

func (s Series) IsCanonical() bool

IsCanonical checks whether the series is canonical wrt to its interval and from/to

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

SetTags fills in the Tags property with tags parsed out of s.Target the "name" tag is always set from s.Target, overriding any attempted override

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

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 SeriesLastTs added in v1.0.0

type SeriesLastTs struct {
	Series string `json:"val"`
	Ts     int64  `json:"lastTs"`
}

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 and returns the modified 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

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

Jump to

Keyboard shortcuts

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