api

Documentation

Index

• Variables
• func ConfigProcess()
• func ConfigSetup()
• func Fix(in []schema.Point, from, to, interval uint32) []schema.Point
• func NewGraphiteProxy(u *url.URL) *httputil.ReverseProxy
• type GenericPeerResponse
• type GroupData
  • func NewGroupData() GroupData
  • func (gd GroupData) Len() int
• type PeerResponse
• type PrioritySetter
• type ReqMap
  • func NewReqMap() *ReqMap
  • func (r *ReqMap) Add(req models.Req)
  • func (r ReqMap) Dump() string
• type ReqsByArchives
  • func (rba *ReqsByArchives) Add(idx int, r models.Req)
  • func (rba ReqsByArchives) HasData() bool
  • func (rba ReqsByArchives) Len() int
  • func (rba ReqsByArchives) OutInterval() uint32
• type ReqsPlan
  • func NewReqsPlan(reqs ReqMap) ReqsPlan
  • func (rp ReqsPlan) Dump() string
  • func (rp ReqsPlan) List() []models.Req
  • func (rp ReqsPlan) PointsFetch() uint32
  • func (rp ReqsPlan) PointsReturn(planMDP uint32) uint32
• type Series
• type Server
  • func NewServer() (*Server, error)
  • func (s *Server) BindBackendStore(store mdata.Store)
  • func (s *Server) BindCache(cache cache.Cache)
  • func (s *Server) BindMemoryStore(store mdata.Metrics)
  • func (s *Server) BindMetaRecords(mr idx.MetaRecordIdx)
  • func (s *Server) BindMetricIndex(i idx.MetricIndex)
  • func (s *Server) BindPrioritySetter(p PrioritySetter)
  • func (s *Server) BindTracer(tracer opentracing.Tracer)
  • func (s *Server) IndexTagTerms(ctx *middleware.Context, req models.IndexTagTerms)
  • func (s *Server) RegisterRoutes()
  • func (s *Server) Run()
  • func (s *Server) Stop()

Variables

var (
	Addr   string
	UseSSL bool
)

var InvalidFormatErr = errors.New("invalid format specified")

var InvalidTimeRangeErr = errors.New("invalid time range requested")

var MissingOrgHeaderErr = errors.New("orgId not set in headers")

var MissingQueryErr = errors.New("missing query param")

var NotFoundErr = errors.New("not found")

Functions

func ConfigProcess

func ConfigProcess()

func ConfigSetup

func ConfigSetup()

func Fix

func Fix(in []schema.Point, from, to, interval uint32) []schema.Point

Fix assures a series is in quantized form: all points are nicely aligned (quantized) and padded with nulls in case there's gaps in data graphite does this quantization before storing, we may want to do that as well at some point note: values are quantized to the right because we can't lie about the future: e.g. if interval is 10 and we have a point at 8 or at 2, it will be quantized to 10, we should never move values to earlier in time.

func NewGraphiteProxy

func NewGraphiteProxy(u *url.URL) *httputil.ReverseProxy

Types

type GenericPeerResponse

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

type GroupData

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

GroupData embodies a set of requests broken down by whether requests are MDP-optimizable, and by archivesID

func NewGroupData

func NewGroupData() GroupData

func (GroupData) Len

func (gd GroupData) Len() int

type PeerResponse

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

type PrioritySetter

type PrioritySetter interface {
	ExplainPriority() interface{}
}

type ReqMap

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

ReqMap is a map of requests of data, it has single requests for which no pre-normalization effort will be performed, and requests that can be pre-normalized together to the same resolution, bundled by their PNGroup

func NewReqMap

func NewReqMap() *ReqMap

func (*ReqMap) Add

func (r *ReqMap) Add(req models.Req)

Add adds a models.Req to the ReqMap

func (ReqMap) Dump

func (r ReqMap) Dump() string

Dump provides a human readable string representation of the ReqsMap

type ReqsByArchives

type ReqsByArchives [][]models.Req

Requests indexed by their ArchivesID

func (*ReqsByArchives) Add

func (rba *ReqsByArchives) Add(idx int, r models.Req)

func (ReqsByArchives) HasData

func (rba ReqsByArchives) HasData() bool

func (ReqsByArchives) Len

func (rba ReqsByArchives) Len() int

func (ReqsByArchives) OutInterval

func (rba ReqsByArchives) OutInterval() uint32

OutInterval returns the outinterval of the ReqsByArchives this assumes that all requests have been planned to a consistent out interval, of course.

type ReqsPlan

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

ReqsPlan holds requests that have been planned, broken down by PNGroup and MDP-optimizability

func NewReqsPlan

func NewReqsPlan(reqs ReqMap) ReqsPlan

NewReqsPlan generates a ReqsPlan based on the provided ReqMap.

func (ReqsPlan) Dump

func (rp ReqsPlan) Dump() string

Dump provides a human readable string representation of the ReqsPlan

func (ReqsPlan) List

func (rp ReqsPlan) List() []models.Req

List returns the requests contained within the plan as a slice

func (ReqsPlan) PointsFetch

func (rp ReqsPlan) PointsFetch() uint32

PointsFetch returns how many points this plan will fetch when executed

func (ReqsPlan) PointsReturn

func (rp ReqsPlan) PointsReturn(planMDP uint32) uint32

PointsReturn estimates the amount of points that will be returned for this request best effort: not aware of summarize(), aggregation functions, runtime normalization. but does account for runtime consolidation

type Series

type Series struct {
	Pattern string // pattern used for index lookup. typically user input like foo.{b,a}r.*
	Series  []idx.Node
	Node    cluster.Node
}

type Server

type Server struct {
	Addr string
	SSL  bool

	Macaron      *macaron.Macaron
	MetricIndex  idx.MetricIndex
	MemoryStore  mdata.Metrics
	BackendStore mdata.Store
	MetaRecords  idx.MetaRecordIdx
	Cache        cache.Cache

	Tracer opentracing.Tracer
	// contains filtered or unexported fields
}

func NewServer

func NewServer() (*Server, error)

func (*Server) BindBackendStore

func (s *Server) BindBackendStore(store mdata.Store)

func (*Server) BindCache

func (s *Server) BindCache(cache cache.Cache)

func (*Server) BindMemoryStore

func (s *Server) BindMemoryStore(store mdata.Metrics)

func (*Server) BindMetaRecords

func (s *Server) BindMetaRecords(mr idx.MetaRecordIdx)

func (*Server) BindMetricIndex

func (s *Server) BindMetricIndex(i idx.MetricIndex)

func (*Server) BindPrioritySetter

func (s *Server) BindPrioritySetter(p PrioritySetter)

func (*Server) BindTracer

func (s *Server) BindTracer(tracer opentracing.Tracer)

func (*Server) IndexTagTerms

func (s *Server) IndexTagTerms(ctx *middleware.Context, req models.IndexTagTerms)

func (*Server) RegisterRoutes

func (s *Server) RegisterRoutes()

func (*Server) Run

func (s *Server) Run()

func (*Server) Stop

func (s *Server) Stop()