storage

Documentation

Index

• type AppNameGetter
• type Config
  • func NewConfig(server *config.Server) *Config
  • func (c *Config) WithInMemory() *Config
  • func (c *Config) WithPath(path string) *Config
• type DeleteInput
• type Enqueuer
• type GetInput
• type GetOutput
• type Getter
• type LabelValuesGetter
• type LabelsGetter
• type MergeProfilesInput
• type MergeProfilesOutput
• type Merger
• type MetricsExporter
• type PutInput
• type Putter
• type SampleObserver
• type Storage
  • func New(c *Config, logger *logrus.Logger, reg prometheus.Registerer, ...) (*Storage, error)
  • func (s *Storage) CacheStats() map[string]uint64
  • func (s *Storage) Cleanup(ctx context.Context) error
  • func (s *Storage) Close() error
  • func (s *Storage) DebugExport(w http.ResponseWriter, r *http.Request)
  • func (s *Storage) Delete(_ context.Context, di *DeleteInput) error
  • func (s *Storage) DeleteApp(_ context.Context, appname string) error
  • func (s *Storage) DiskUsage() map[string]bytesize.ByteSize
  • func (s *Storage) Enqueue(ctx context.Context, input *PutInput)
  • func (s *Storage) Get(ctx context.Context, gi *GetInput) (*GetOutput, error)
  • func (s *Storage) GetAppNames(ctx context.Context) []string
  • func (s *Storage) GetKeys(_ context.Context, cb func(string) bool)
  • func (s *Storage) GetKeysByQuery(_ context.Context, query string, cb func(_k string) bool) error
  • func (s *Storage) GetValues(_ context.Context, key string, cb func(v string) bool)
  • func (s *Storage) GetValuesByQuery(_ context.Context, label string, query string, cb func(v string) bool) error
  • func (s *Storage) InstallID() string
  • func (s *Storage) JWT() (string, error)
  • func (s *Storage) LoadAnalytics(a interface{}) error
  • func (s *Storage) MergeProfiles(ctx context.Context, mi MergeProfilesInput) (o MergeProfilesOutput, err error)
  • func (s *Storage) Put(_ context.Context, pi *PutInput) error
  • func (s *Storage) SaveAnalytics(a interface{}) error

Types

type AppNameGetter

type AppNameGetter interface {
	GetAppNames(ctx context.Context) []string
}

type Config

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

func NewConfig

func NewConfig(server *config.Server) *Config

NewConfig returns a new storage config from a server config

func (*Config) WithInMemory

func (c *Config) WithInMemory() *Config

WithInMemory makes the storage in-memory.

func (*Config) WithPath

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

WithPath sets the storage base path

type DeleteInput

type DeleteInput struct {
	// Key must match exactly one segment.
	Key *segment.Key
}

type Enqueuer

type Enqueuer interface {
	Enqueue(ctx context.Context, input *PutInput)
}

type GetInput

type GetInput struct {
	StartTime time.Time
	EndTime   time.Time
	Key       *segment.Key
	Query     *flameql.Query
}

type GetOutput

type GetOutput struct {
	Tree       *tree.Tree
	Timeline   *segment.Timeline
	SpyName    string
	SampleRate uint32
	Units      metadata.Units
}

type Getter

type Getter interface {
	Get(ctx context.Context, gi *GetInput) (*GetOutput, error)
}

type LabelValuesGetter

type LabelValuesGetter interface {
	GetValues(ctx context.Context, key string, cb func(v string) bool)
	GetValuesByQuery(ctx context.Context, label string, query string, cb func(v string) bool) error
}

type LabelsGetter

type LabelsGetter interface {
	GetKeys(ctx context.Context, cb func(string) bool)
	GetKeysByQuery(ctx context.Context, query string, cb func(_k string) bool) error
}

type MergeProfilesInput

type MergeProfilesInput struct {
	AppName  string
	Profiles []string
}

type MergeProfilesOutput

type MergeProfilesOutput struct {
	Tree *tree.Tree
}

type Merger

type Merger interface {
	MergeProfiles(ctx context.Context, mi MergeProfilesInput) (o MergeProfilesOutput, err error)
}

type MetricsExporter

type MetricsExporter interface {
	// Evaluate evaluates metrics export rules against the input key and creates
	// prometheus counters for new time series, if required. Returned observer can
	// be used to evaluate and observe particular samples.
	//
	// If there are no matching rules, the function returns false.
	Evaluate(*PutInput) (SampleObserver, bool)
}

MetricsExporter exports values of particular stack traces sample from profiling data as a Prometheus metrics.

type PutInput

type PutInput struct {
	StartTime       time.Time
	EndTime         time.Time
	Key             *segment.Key
	Val             *tree.Tree
	SpyName         string
	SampleRate      uint32
	Units           metadata.Units
	AggregationType metadata.AggregationType
}

type Putter

type Putter interface {
	Put(ctx context.Context, pi *PutInput) error
}

type SampleObserver

type SampleObserver interface {
	// Observe adds v to the matched counters if k satisfies node selector.
	// k is a sample stack trace where frames are delimited by semicolon.
	// v is the sample value.
	Observe(k []byte, v int)
}

type Storage

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

func New

func New(c *Config, logger *logrus.Logger, reg prometheus.Registerer, hc *health.Controller) (*Storage, error)

func (*Storage) CacheStats

func (s *Storage) CacheStats() map[string]uint64

func (*Storage) Cleanup

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

Cleanup removes malformed data from the storage.

func (*Storage) Close

func (s *Storage) Close() error

func (*Storage) DebugExport

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

func (*Storage) Delete

func (s *Storage) Delete(_ context.Context, di *DeleteInput) error

func (*Storage) DeleteApp

func (s *Storage) DeleteApp(_ context.Context, appname string) error

DeleteApp fully deletes an app It does so by deleting Segments, Dictionaries, Trees, Dimensions and Labels It's an idempotent call, ie. if the app already does not exist, no error is triggered. TODO cancelation?

func (*Storage) DiskUsage

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

func (*Storage) Enqueue

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

func (*Storage) Get

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

func (*Storage) GetAppNames

func (s *Storage) GetAppNames(ctx context.Context) []string

GetAppNames returns the list of all app's names

func (*Storage) GetKeys

func (s *Storage) GetKeys(_ context.Context, cb func(string) bool)

func (*Storage) GetKeysByQuery

func (s *Storage) GetKeysByQuery(_ context.Context, query string, cb func(_k string) bool) error

func (*Storage) GetValues

func (s *Storage) GetValues(_ context.Context, key string, cb func(v string) bool)

func (*Storage) GetValuesByQuery

func (s *Storage) GetValuesByQuery(_ context.Context, label string, query string, cb func(v string) bool) error

func (*Storage) InstallID

func (s *Storage) InstallID() string

func (*Storage) JWT

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

func (*Storage) LoadAnalytics

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

func (*Storage) MergeProfiles

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

func (*Storage) Put

func (s *Storage) Put(_ context.Context, pi *PutInput) error

func (*Storage) SaveAnalytics

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