stats

May 7, 2021

Changes in this version

+ var ErrCacheCorrupt = fmt.Errorf("stats: cache is corrupt")

type Cache

+ func NewLocalCache(rootDir string, maxSize int64) (Cache, error)

+ GetStats func(ctx context.Context, key string) (sa *dataset.Stats, err error)

+ PutStats func(ctx context.Context, key string, sa *dataset.Stats) error

+ type Props = didmod.Props

+ type Service struct

+ func (s *Service) Stats(ctx context.Context, ds *dataset.Dataset) (*dataset.Stats, error)

Nov 18, 2019

Changes in this version

+ var ErrCacheMiss = fmt.Errorf("stats: cache miss")

+ var ErrNoCache = fmt.Errorf("stats: no cache")

+ var StopFreqCountThreshold = 10000

+ func ToMap(s Statser) []map[string]interface

+ type Accumulator struct

+ func NewAccumulator(r dsio.EntryReader) *Accumulator

+ func (r *Accumulator) Close() error

+ func (r *Accumulator) ReadEntry() (dsio.Entry, error)

+ func (r *Accumulator) Stats() []Stat

+ func (r *Accumulator) Structure() *dataset.Structure

+ type Cache interface

+ JSON func(ctx context.Context, path string) (r io.Reader, err error)

+ PutJSON func(ctx context.Context, path string, r io.Reader) error

+ func NewOSCache(rootDir string, maxSize uint64) Cache

+ type Stat interface

+ Map func() map[string]interface{}

+ Type func() string

+ type Stats struct

+ func New(cache Cache) *Stats

+ func (s *Stats) JSON(ctx context.Context, ds *dataset.Dataset) (r io.Reader, err error)

+ type Statser interface

+ Stats func() []Stat