temporarystore

Documentation

Index

• type Store
  • func New(reg prometheus.Registerer, logger zerolog.Logger) *Store
  • func (s *Store) AddToTransfert(_ context.Context, ids []types.MetricID) error
  • func (s *Store) Append(_ context.Context, points []types.MetricData) ([]int, error)
  • func (s *Store) GetAllKnownMetrics(_ context.Context) (map[types.MetricID]time.Time, error)
  • func (s *Store) GetSetFlushDeadline(_ context.Context, deadlines map[types.MetricID]time.Time) (map[types.MetricID]time.Time, error)
  • func (s *Store) GetSetPointsAndOffset(_ context.Context, points []types.MetricData, offsets []int) ([]types.MetricData, error)
  • func (s *Store) GetTransfert(_ context.Context, count int) (map[types.MetricID]time.Time, error)
  • func (s *Store) MarkToExpire(_ context.Context, ids []types.MetricID, ttl time.Duration) error
  • func (s *Store) ReadPointsAndOffset(_ context.Context, ids []types.MetricID) ([]types.MetricData, []int, error)
  • func (s *Store) Run(ctx context.Context)

Types

type Store

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

func New

func New(reg prometheus.Registerer, logger zerolog.Logger) *Store

New creates a new Store object.

func (*Store) AddToTransfert

func (s *Store) AddToTransfert(_ context.Context, ids []types.MetricID) error

AddToTransfert implement batch.TemporaryStore interface.

func (*Store) Append

func (s *Store) Append(_ context.Context, points []types.MetricData) ([]int, error)

Append implement batch.TemporaryStore interface.

func (*Store) GetAllKnownMetrics

func (s *Store) GetAllKnownMetrics(_ context.Context) (map[types.MetricID]time.Time, error)

GetAllKnownMetrics implement batch.TemporaryStore interface.

func (*Store) GetSetFlushDeadline

func (s *Store) GetSetFlushDeadline(
	_ context.Context,
	deadlines map[types.MetricID]time.Time,
) (map[types.MetricID]time.Time, error)

GetSetFlushDeadline implement batch.TemporaryStore interface.

func (*Store) GetSetPointsAndOffset

func (s *Store) GetSetPointsAndOffset(
	_ context.Context,
	points []types.MetricData,
	offsets []int,
) ([]types.MetricData, error)

GetSetPointsAndOffset implement batch.TemporaryStore interface.

func (*Store) GetTransfert

func (s *Store) GetTransfert(_ context.Context, count int) (map[types.MetricID]time.Time, error)

GetTransfert implement batch.TemporaryStore interface.

func (*Store) MarkToExpire

func (s *Store) MarkToExpire(_ context.Context, ids []types.MetricID, ttl time.Duration) error

MarkToExpire implement batch.TemporaryStore interface.

func (*Store) ReadPointsAndOffset

func (s *Store) ReadPointsAndOffset(_ context.Context, ids []types.MetricID) ([]types.MetricData, []int, error)

ReadPointsAndOffset implement batch.TemporaryStore interface.

func (*Store) Run

func (s *Store) Run(ctx context.Context)

Run starts all Store services.