storage

Documentation

Index

• Variables
• type DeleteInput
• type GetInput
• type GetOutput
• type Ingester
• type IngestionObserver
  • func NewIngestionObserver(storage *Storage, exporter *exporter.MetricsExporter) IngestionObserver
  • func (o IngestionObserver) Put(i *PutInput) error
• type PutInput
• type Storage
  • func New(c *config.Server) (*Storage, error)
  • func (s *Storage) CacheStats() map[string]interface{}
  • func (s *Storage) Close() error
  • func (s *Storage) CollectLocalProfiles() error
  • func (s *Storage) Delete(di *DeleteInput) error
  • func (s *Storage) DeleteDataBefore(threshold time.Time) error
  • func (s *Storage) DiskUsage() map[string]bytesize.ByteSize
  • func (s *Storage) Get(gi *GetInput) (*GetOutput, 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(po *PutInput) error
  • func (s *Storage) PutLocal(po *PutInput) error

Variables

var OutOfSpaceThreshold = 512 * bytesize.MB

Types

type DeleteInput

type DeleteInput struct {
	Key *segment.Key
}

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      string
}

type Ingester

type Ingester interface {
	Put(*PutInput) error
}

type IngestionObserver

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

func NewIngestionObserver

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

func (IngestionObserver) Put

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

type PutInput

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

type Storage

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

func New

func New(c *config.Server) (*Storage, error)

func (*Storage) CacheStats

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

func (*Storage) Close

func (s *Storage) Close() error

func (*Storage) CollectLocalProfiles

func (s *Storage) CollectLocalProfiles() error

func (*Storage) Delete

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

func (*Storage) DeleteDataBefore

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

func (*Storage) DiskUsage

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

func (*Storage) Get

func (s *Storage) Get(gi *GetInput) (*GetOutput, error)

func (*Storage) GetKeys

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

func (*Storage) GetValues

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

func (*Storage) InstallID

func (s *Storage) InstallID() string

func (*Storage) Put

func (s *Storage) Put(po *PutInput) error

func (*Storage) PutLocal

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