Versions in this module Expand all Collapse all v0 v0.2.0 May 20, 2019 Changes in this version + type LogFn = runhttp.LogFn + var LoggerFromContext LogFn = runhttp.LoggerFromContext + type Logger = runhttp.Logger + type Stat = runhttp.Stat + type StatFn = runhttp.StatFn + var StatFromContext StatFn = runhttp.StatFromContext v0.1.0 Feb 26, 2019 Changes in this version + type DigesterProvider func(start, stop time.Time) vpcflow.Digester + type ErrInProgress struct + Key string + func (e ErrInProgress) Error() string + type ErrNotFound struct + ID string + func (e ErrNotFound) Error() string + type ExitSignal func() chan error + type LoggerProvider func(ctx context.Context) logevent.Logger + type Marker interface + Mark func(ctx context.Context, key string) error + Unmark func(ctx context.Context, key string) error + type Queuer interface + Queue func(ctx context.Context, id string, start, stop time.Time) error + type StatsProvider func(ctx context.Context) xstats.XStater + type Storage interface + Exists func(ctx context.Context, key string) (bool, error) + Get func(ctx context.Context, key string) (io.ReadCloser, error) + Store func(ctx context.Context, key string, data io.ReadCloser) error