storage

Nov 16, 2022

Changes in this version

+ type ApplicationMetadata struct

+ AggregationType metadata.AggregationType

+ FQName string

+ SampleRate uint32

+ SpyName string

+ Units metadata.Units

+ type ApplicationMetadataSaver interface

+ CreateOrUpdate func(ctx context.Context, application ApplicationMetadata) error

+ type NoopApplicationMetadataService struct

+ func (NoopApplicationMetadataService) CreateOrUpdate(context.Context, ApplicationMetadata) error

+ func (NoopApplicationMetadataService) Delete(context.Context, string) error

+ func (NoopApplicationMetadataService) Get(context.Context, string) (app ApplicationMetadata, err error)

+ func (NoopApplicationMetadataService) List(context.Context, ApplicationMetadata) (apps []ApplicationMetadata, err error)

Sep 14, 2022

Changes in this version

+ type ExemplarsSelection struct

+ EndTime time.Time

+ MaxValue uint64

+ MinValue uint64

+ StartTime time.Time

type HeatmapParams

+ MaxValue uint64

+ MinValue uint64

type MergeExemplarsInput

+ ExemplarsSelection ExemplarsSelection

type QueryExemplarsInput

+ ExemplarsSelection ExemplarsSelection

Sep 6, 2022

Changes in this version

+ type ExemplarsQuerier interface

+ QueryExemplars func(context.Context, QueryExemplarsInput) (QueryExemplarsOutput, error)

type GetExemplarOutput

+ Metadata metadata.Metadata

+ type Heatmap struct

+ EndTime time.Time

+ MaxDepth uint64

+ MaxValue uint64

+ MinDepth uint64

+ MinValue uint64

+ StartTime time.Time

+ TimeBuckets int64

+ ValueBuckets int64

+ Values [][]uint64

+ type HeatmapColumn struct

+ Counts []uint64

+ Values []uint64

+ type HeatmapParams struct

+ EndTime time.Time

+ StartTime time.Time

+ TimeBuckets int64

+ ValueBuckets int64

+ type HeatmapSketch struct

+ Columns []HeatmapColumn

type MergeExemplarsInput

+ HeatmapParams HeatmapParams

+ MaxValue uint64

+ MinValue uint64

type MergeExemplarsOutput

+ HeatmapSketch HeatmapSketch

+ Metadata metadata.Metadata

+ type QueryExemplarsInput struct

+ EndTime time.Time

+ HeatmapParams HeatmapParams

+ MaxValue uint64

+ MinValue uint64

+ Query *flameql.Query

+ StartTime time.Time

+ type QueryExemplarsOutput struct

+ Count uint64

+ HeatmapSketch HeatmapSketch

+ Metadata metadata.Metadata

+ Telemetry map[string]interface{}

+ Tree *tree.Tree

type Storage

+ func (*Storage) QueryExemplars(context.Context, QueryExemplarsInput) (QueryExemplarsOutput, error)

Aug 8, 2022

Changes in this version

+ type AppDeleter interface

+ DeleteApp func(ctx context.Context, appName string) error

+ type AppGetter interface

+ GetApps func(ctx context.Context) (GetAppsOutput, error)

+ type AppInfo struct

+ Name string

+ type DeleteAppInput struct

+ Name string

+ type GetAppsOutput struct

+ Apps []AppInfo

type Storage

+ func (s *Storage) GetApps(ctx context.Context) (GetAppsOutput, error)

Jul 19, 2022

Changes in this version

+ type ExemplarsGetter interface

+ GetExemplar func(context.Context, GetExemplarInput) (GetExemplarOutput, error)

+ type ExemplarsMerger interface

+ MergeExemplars func(context.Context, MergeExemplarsInput) (MergeExemplarsOutput, error)

+ type GetExemplarInput struct

+ AppName string

+ EndTime time.Time

+ ProfileID string

+ StartTime time.Time

+ type GetExemplarOutput struct

+ AggregationType metadata.AggregationType

+ EndTime time.Time

+ Labels map[string]string

+ SampleRate uint32

+ SpyName string

+ StartTime time.Time

+ Telemetry map[string]interface{}

+ Tree *tree.Tree

+ Units metadata.Units

+ type MergeExemplarsInput struct

+ AppName string

+ EndTime time.Time

+ ProfileIDs []string

+ StartTime time.Time

+ type MergeExemplarsOutput struct

+ AggregationType metadata.AggregationType

+ Count uint64

+ SampleRate uint32

+ SpyName string

+ Telemetry map[string]interface{}

+ Tree *tree.Tree

+ Units metadata.Units

type Storage

+ func (s *Storage) GetExemplar(ctx context.Context, gi GetExemplarInput) (out GetExemplarOutput, err error)

+ func (s *Storage) MergeExemplars(ctx context.Context, mi MergeExemplarsInput) (out MergeExemplarsOutput, err error)

Jul 16, 2022

Changes in this version

type GetInput

+ GroupBy string

type GetOutput

+ Groups map[string]*segment.Timeline

Jun 27, 2022

Changes in this version

type Storage

+ func (s *Storage) ExemplarsInternals() (*badger.DB, func())

Jun 13, 2022

Changes in this version

type GetOutput

+ Telemetry map[string]interface{}

May 26, 2022

Changes in this version

+ func IsIngestionError(err error) bool

+ type BadgerDB interface

+ MaxBatchCount func() int64

+ NewWriteBatch func() *badger.WriteBatch

+ Update func(func(txn *badger.Txn) error) error

+ View func(func(txn *badger.Txn) error) error

+ type BadgerDBWithCache interface

+ CacheInstance func() *cache.Cache

+ CacheSize func() uint64

+ Close func()

+ DBInstance func() *badger.DB

+ Name func() string

+ Size func() bytesize.ByteSize

+ type CacheLayer interface

+ Delete func(key string) error

+ Discard func(key string)

+ DiscardPrefix func(prefix string) error

+ Evict func(percent float64)

+ GetOrCreate func(key string) (interface{}, error)

+ Lookup func(key string) (interface{}, bool)

+ Put func(key string, val interface{})

+ WriteBack func()

type Config

+ NewBadger func(name string, p Prefix, codec cache.Codec) (BadgerDBWithCache, error)

+ type GetLabelKeysByQueryInput struct

+ EndTime time.Time

+ Query string

+ StartTime time.Time

+ type GetLabelKeysByQueryOutput struct

+ Keys []string

+ type GetLabelValuesByQueryInput struct

+ EndTime time.Time

+ Label string

+ Query string

+ StartTime time.Time

+ type GetLabelValuesByQueryOutput struct

+ Values []string

+ type IngestionError struct

+ Err error

+ func (e IngestionError) Error() string

+ func (e IngestionError) Unwrap() error

+ type IngestionQueue struct

+ func NewIngestionQueue(logger logrus.FieldLogger, putter Putter, r prometheus.Registerer, ...) *IngestionQueue

+ func (s *IngestionQueue) Put(ctx context.Context, input *PutInput) error

+ func (s *IngestionQueue) Stop()

+ type Prefix string

+ func (p Prefix) String() string

May 12, 2022

Changes in this version

type GetOutput

+ AggregationType metadata.AggregationType

+ Count uint64

type Storage

+ func (s *Storage) DictsInternals() (*badger.DB, *cache.Cache)

+ func (s *Storage) DimensionsInternals() (*badger.DB, *cache.Cache)

+ func (s *Storage) MainInternals() (*badger.DB, *cache.Cache)

+ func (s *Storage) SegmentsInternals() (*badger.DB, *cache.Cache)

+ func (s *Storage) TreesInternals() (*badger.DB, *cache.Cache)

Apr 8, 2022

Changes in this version

+ type AppNameGetter interface

+ GetAppNames func(ctx context.Context) []string

+ type Enqueuer interface

+ Enqueue func(ctx context.Context, input *PutInput)

+ type Getter interface

+ Get func(ctx context.Context, gi *GetInput) (*GetOutput, error)

+ type LabelValuesGetter interface

+ GetValues func(ctx context.Context, key string, cb func(v string) bool)

+ GetValuesByQuery func(ctx context.Context, label string, query string, cb func(v string) bool) error

+ type LabelsGetter interface

+ GetKeys func(ctx context.Context, cb func(string) bool)

+ GetKeysByQuery func(ctx context.Context, query string, cb func(_k string) bool) error

+ type Merger interface

+ MergeProfiles func(ctx context.Context, mi MergeProfilesInput) (o MergeProfilesOutput, err error)

+ type Putter interface

+ Put func(ctx context.Context, pi *PutInput) error

Mar 10, 2022

Changes in this version

+ type MergeProfilesInput struct

+ AppName string

+ Profiles []string

+ type MergeProfilesOutput struct

+ Tree *tree.Tree

type Storage

+ func (s *Storage) Cleanup(ctx context.Context) error

+ func (s *Storage) MergeProfiles(ctx context.Context, mi MergeProfilesInput) (o MergeProfilesOutput, err error)

Jan 25, 2022

Changes in this version

type Storage

+ func (s *Storage) DebugExport(w http.ResponseWriter, r *http.Request)

+ func (s *Storage) LoadAnalytics(a interface{}) error

+ func (s *Storage) SaveAnalytics(a interface{}) error

Jan 14, 2022

Changes in this version

type Storage

+ func (s *Storage) GetContext(ctx context.Context, gi *GetInput) (*GetOutput, error)

Jan 13, 2022

Changes in this version

type Storage

+ func (s *Storage) Enqueue(input *PutInput)

Dec 1, 2021

Changes in this version

type Storage

+ func (s *Storage) DeleteApp(appname string) error

Nov 29, 2021

Changes in this version

type Config

+ func (c *Config) WithInMemory() *Config

type Storage

+ func (s *Storage) GetAppNames() []string

Nov 9, 2021

Changes in this version

+ type Config struct

+ func NewConfig(server *config.Server) *Config

+ func (c *Config) WithPath(path string) *Config

type Storage

+ func (s *Storage) EnforceRetentionPolicy(rp *segment.RetentionPolicy) error

Oct 18, 2021

Changes in this version

+ type MetricsExporter interface

+ Evaluate func(*PutInput) (SampleObserver, bool)

+ type SampleObserver interface

+ Observe func(k []byte, v int)

Aug 31, 2021

Changes in this version

type Storage

+ func (s *Storage) GetKeysByQuery(query string, cb func(_k string) bool) error

+ func (s *Storage) GetValuesByQuery(label string, query string, cb func(v string) bool) error

+ func (s *Storage) JWT() (string, error)

Aug 4, 2021

Changes in this version

type GetInput

+ Query *flameql.Query

+ type Ingester interface

+ Put func(*PutInput) error

+ type IngestionObserver struct

+ func NewIngestionObserver(storage *Storage, exporter *exporter.MetricsExporter) IngestionObserver

+ func (o IngestionObserver) Put(i *PutInput) error

Jun 23, 2021

Changes in this version

+ func FromTreeToDictKey(k string) string

Jun 17, 2021

Changes in this version

+ var ErrAlreadyClosed = errors.New("the db is already closed")

+ var ErrClosing = errors.New("the db is in closing state")

+ var OutOfSpaceThreshold = 512 * bytesize.MB

+ type DeleteInput struct

+ Key *Key

type Storage

+ func (s *Storage) CacheStats() map[string]interface{}

+ func (s *Storage) CollectLocalProfiles() error

+ func (s *Storage) Delete(di *DeleteInput) error

+ func (s *Storage) DeleteDataBefore(threshold time.Time) error

+ func (s *Storage) IsClosing() bool

+ func (s *Storage) PutLocal(po *PutInput) error

Apr 26, 2021

Changes in this version

+ type GetInput struct

+ EndTime time.Time

+ Key *Key

+ StartTime time.Time

+ type GetOutput struct

+ SampleRate int

+ SpyName string

+ Timeline *segment.Timeline

+ Tree *tree.Tree

+ Units string

+ type PutInput struct

+ AggregationType string

+ EndTime time.Time

+ Key *Key

+ SampleRate int

+ SpyName string

+ StartTime time.Time

+ Units string

+ Val *tree.Tree

Jan 19, 2021

Changes in this version

type Key

+ func (k *Key) AppName() string

Jan 2, 2021

Changes in this version

+ func FromTreeToMainKey(k string) string

+ type Key struct

+ func ParseKey(name string) (*Key, error)

+ func (k *Key) DictKey() string

+ func (k *Key) Hashed() []byte

+ func (k *Key) Normalized() string

+ func (k *Key) SegmentKey() string

+ func (k *Key) TreeKey(depth int, t time.Time) string

+ type ParserState int

+ type Storage struct

+ func New(cfg *config.Config) (*Storage, error)

+ func (s *Storage) Close() error

+ func (s *Storage) DiskUsage() map[string]bytesize.ByteSize

+ func (s *Storage) Get(startTime, endTime time.Time, key *Key) (*tree.Tree, *segment.Timeline, string, int, error)

+ func (s *Storage) GetKeys(cb func(_k string) bool)

+ func (s *Storage) GetValues(key string, cb func(v string) bool)

+ func (s *Storage) InstallID() string

+ func (s *Storage) Put(startTime, endTime time.Time, key *Key, val *tree.Tree, spyName string, ...) error