carbonserver

Nov 5, 2023

Changes in this version

type CarbonserverListener

+ func (listener *CarbonserverListener) SetDoNotLog404s(doNotLog404s bool)

Feb 15, 2023

Changes in this version

+ var BlockedRatelimitError = RatelimiterError("blocked by api per path rate limiter")

+ var TraceGrpcMetadata = map[string]string

+ func ReadFileListCache(p string, version FLCVersion, writer io.Writer) error

+ type ApiPerPathRatelimiter struct

+ func NewApiPerPathRatelimiter(maxInflightRequests uint, timeout time.Duration) *ApiPerPathRatelimiter

+ func (a *ApiPerPathRatelimiter) Enter() error

+ func (a *ApiPerPathRatelimiter) Exit()

type CarbonserverListener

+ func (listener *CarbonserverListener) Find(ctx context.Context, req *protov2.GlobRequest) (*protov2.GlobResponse, error)

+ func (listener *CarbonserverListener) Info(ctx context.Context, req *protov2.InfoRequest) (*protov2.InfoResponse, error)

+ func (listener *CarbonserverListener) ListenGRPC(listen string) error

+ func (listener *CarbonserverListener) Render(req *protov2.MultiFetchRequest, stream grpcv2.CarbonV2_RenderServer) (rpcErr error)

+ func (listener *CarbonserverListener) SetAPIPerPathRateLimiter(rls map[string]*ApiPerPathRatelimiter)

+ func (listener *CarbonserverListener) SetEmptyResultOk(emptyResultOk bool)

+ func (listener *CarbonserverListener) SetFileListCacheVersion(version int)

+ func (listener *CarbonserverListener) SetHeavyGlobQueryRateLimiters(rls []*GlobQueryRateLimiter)

+ func (listener *CarbonserverListener) SetMaxCreatesPerSecond(maxCreatesPerSecond int)

+ func (listener *CarbonserverListener) SetRenderTraceLoggingEnabled(enabled bool)

+ func (listener *CarbonserverListener) SetRequestTimeout(requestTimeout time.Duration)

+ func (listener *CarbonserverListener) SetStreamingQueryCacheEnabled(enabled bool)

+ func (listener *CarbonserverListener) StreamServerRatelimitHandler() grpc.StreamServerInterceptor

+ func (listener *CarbonserverListener) UnaryServerRatelimitHandler() grpc.UnaryServerInterceptor

type ExpandedGlobResponse

+ Lookups uint32

+ TrieNodes []*trieNode

+ type FLCEntry struct

+ DataPoints int64

+ FirstSeenAt int64

+ LogicalSize int64

+ Path string

+ PhysicalSize int64

+ type FLCVersion int

+ const FLCVersion1

+ const FLCVersion2

+ const FLCVersionUnspecified

+ type FileListCache interface

+ Close func() error

+ GetVersion func() FLCVersion

+ Read func() (*FLCEntry, error)

+ Write func(*FLCEntry) error

+ func NewFileListCache(p string, version FLCVersion, mode byte) (FileListCache, error)

+ type GlobQueryRateLimiter struct

+ func NewGlobQueryRateLimiter(pattern string, max uint) (*GlobQueryRateLimiter, error)

+ type RatelimiterError string

+ func (re RatelimiterError) Error() string

Feb 18, 2022

Changes in this version

type CarbonserverListener

+ MaxInflightRequests uint64

+ NoServiceWhenIndexIsNotReady bool

+ func (listener *CarbonserverListener) RegisterInternalInfoHandler(name string, f func() map[string]interface{})

+ func (listener *CarbonserverListener) SetEstimateSize(f func(metric string) (size, dataPoints int64))

+ func (listener *CarbonserverListener) SetMaxInflightRequests(max uint64)

+ func (listener *CarbonserverListener) SetNoServiceWhenIndexIsNotReady(no bool)

+ func (listener *CarbonserverListener) SetQuotaUsageReportFrequency(quotaUsageReportFrequency time.Duration)

+ func (listener *CarbonserverListener) SetQuotas(quotas []*Quota)

+ func (listener *CarbonserverListener) ShouldThrottleMetric(ps *points.Points, inCache bool) bool

+ type ListMetricInfo struct

+ LogicalSize int64

+ Name string

+ PhysicalSize int64

+ type ListQueryResult struct

+ Count int

+ LogicalSize int64

+ Metrics []ListMetricInfo

+ PhysicalSize int64

+ type Quota struct

+ DataPoints int64

+ DroppingPolicy QuotaDroppingPolicy

+ LogicalSize int64

+ Metrics int64

+ Namespaces int64

+ Pattern string

+ PhysicalSize int64

+ StatMetricPrefix string

+ Throughput int64

+ func (q *Quota) String() string

+ type QuotaDroppingPolicy int8

+ const QDPNew

+ const QDPNone

+ func ParseQuotaDroppingPolicy(policy string) QuotaDroppingPolicy

+ func (qdp QuotaDroppingPolicy) String() string

+ type QuotaUsage struct

+ DataPoints int64

+ LogicalSize int64

+ Metrics int64

+ Namespaces int64

+ PhysicalSize int64

+ Throttled int64

+ func (q *QuotaUsage) String() string

Oct 20, 2020

Changes in this version

type CarbonserverListener

+ func (c *CarbonserverListener) InitTracing(jaegerEndpoint string, sendtoStdout bool, version string, ...) func()

+ func (listener *CarbonserverListener) SetConcurrentIndex(enabled bool)

+ func (listener *CarbonserverListener) SetFileListCache(path string)

+ func (listener *CarbonserverListener) SetRealtimeIndex(num int) chan string

Jul 12, 2020

Changes in this version

type CarbonserverListener

+ func (listener *CarbonserverListener) SetCacheGetMetricsFunc(recentMetricsFunc func() []map[string]struct{})

+ func (listener *CarbonserverListener) SetCompressed(compressed bool)

+ func (listener *CarbonserverListener) SetConfigRetriever(retriever configRetriever)

+ func (listener *CarbonserverListener) SetMaxMetricsGlobbed(max int)

+ func (listener *CarbonserverListener) SetMaxMetricsRendered(max int)

+ func (listener *CarbonserverListener) SetRemoveEmptyFile(remove bool)

+ func (listener *CarbonserverListener) SetTrieIndex(enabled bool)

+ type ExpandedGlobResponse struct

+ Err error

+ Files []string

+ Leafs []bool

+ Name string

May 17, 2019

Changes in this version

type CarbonserverListener

+ func (c *CarbonserverListener) InitPrometheus(reg prom.Registerer)

Aug 1, 2018

Changes in this version

+ type Metadata struct

+ ConsolidationFunc string

+ XFilesFactor float32

Mar 10, 2018

Changes in this version

type CarbonserverListener

+ func (listener *CarbonserverListener) SetFLock(flock bool)

+ func (listener *CarbonserverListener) SetFailOnMaxGlobs(failOnMaxGlobs bool)

Sep 6, 2017

Changes in this version

type CarbonserverListener

+ func (listener *CarbonserverListener) SetInternalStatsDir(dbPath string)

+ func (listener *CarbonserverListener) SetPercentiles(percentiles []int)

+ func (listener *CarbonserverListener) UpdateMetricsAccessTimesByRequest(metrics []string)

Jun 14, 2017

Changes in this version

+ const DataIsAvailable

+ const QueryIsPending

+ var TraceHeaders = map[string]string

+ func TraceContextToZap(ctx context.Context, logger *zap.Logger) *zap.Logger

+ func TraceHandler(h http.HandlerFunc) http.HandlerFunc

type CarbonserverListener

+ func (listener *CarbonserverListener) SetFindCacheEnabled(enabled bool)

+ func (listener *CarbonserverListener) SetGraphiteWeb10(enabled bool)

+ func (listener *CarbonserverListener) SetIdleTimeout(idleTimeout time.Duration)

+ func (listener *CarbonserverListener) SetQueryCacheEnabled(enabled bool)

+ func (listener *CarbonserverListener) SetQueryCacheSizeMB(size int)

+ func (listener *CarbonserverListener) SetTrigramIndex(enabled bool)

+ func (listener *CarbonserverListener) UpdateMetricsAccessTimes(metrics []string)

+ type QueryItem struct

+ Data atomic.Value

+ Flags uint64

+ QueryFinished chan struct{}

+ func (q *QueryItem) FetchOrLock() (interface{}, bool)

+ func (q *QueryItem) StoreAbort()

+ func (q *QueryItem) StoreAndUnlock(data interface{})

Jan 10, 2017

Changes in this version

+ type CarbonserverListener struct

+ func NewCarbonserverListener(cacheGetFunc func(key string) []points.Point) *CarbonserverListener

+ func (listener *CarbonserverListener) CurrentFileIndex() *fileIndex

+ func (listener *CarbonserverListener) Listen(listen string) error

+ func (listener *CarbonserverListener) SetBuckets(buckets int)

+ func (listener *CarbonserverListener) SetMaxGlobs(maxGlobs int)

+ func (listener *CarbonserverListener) SetMetricsAsCounters(metricsAsCounters bool)

+ func (listener *CarbonserverListener) SetReadTimeout(readTimeout time.Duration)

+ func (listener *CarbonserverListener) SetScanFrequency(scanFrequency time.Duration)

+ func (listener *CarbonserverListener) SetWhisperData(whisperData string)

+ func (listener *CarbonserverListener) SetWriteTimeout(writeTimeout time.Duration)

+ func (listener *CarbonserverListener) Stat(send helper.StatCallback)

+ func (listener *CarbonserverListener) Stop() error

+ func (listener *CarbonserverListener) UpdateFileIndex(fidx *fileIndex)

+ type IntervalSet struct

+ End int32

+ Start int32

+ func (i *IntervalSet) MarshalPickle() ([]byte, error)