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
- type PeerResponse
- type PrioritySetter
- type ReqMap
- type ReqsByArchives
- type ReqsPlan
- type Series
- type Server
- 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()
Constants ¶
This section is empty.
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 ¶
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
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
type ReqsByArchives ¶
Requests indexed by their ArchivesID
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 ¶
NewReqsPlan generates a ReqsPlan based on the provided ReqMap.
func (ReqsPlan) PointsFetch ¶
PointsFetch returns how many points this plan will fetch when executed
func (ReqsPlan) PointsReturn ¶
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 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 (*Server) BindBackendStore ¶
func (*Server) BindMemoryStore ¶
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()
Source Files
Directories