metaloop

Jun 22, 2021

Changes in this version

type Config

+ SuspiciousProcessedRatio float64

type MetabaseDB

+ GetTableStats func(context.Context, metabase.GetTableStats) (metabase.TableStats, error)

Jun 8, 2021

Changes in this version

type Config

+ AsOfSystemInterval time.Duration

May 30, 2021

Changes in this version

type Config

+ MaxAsOfSystemDuration time.Duration

May 18, 2021

Changes in this version

type MetabaseDB

+ Now func(ctx context.Context) (time.Time, error)

May 3, 2021

Changes in this version

type Service

+ func (loop *Service) Monitor(ctx context.Context, observer Observer) (err error)

Apr 26, 2021

Changes in this version

+ var ErrClosed = Error.New("loop closed")

+ var Error = errs.Class("metainfo loop error")

+ type Config struct

+ CoalesceDuration time.Duration

+ ListLimit int

+ RateLimit float64

+ type LoopInfo struct

+ Started time.Time

+ type MetabaseDB interface

+ IterateLoopObjects func(ctx context.Context, opts metabase.IterateLoopObjects, ...) (err error)

+ IterateLoopStreams func(ctx context.Context, opts metabase.IterateLoopStreams, ...) (err error)

+ type NullObserver struct

+ func (NullObserver) InlineSegment(context.Context, *Segment) error

+ func (NullObserver) LoopStarted(context.Context, LoopInfo) error

+ func (NullObserver) Object(context.Context, *Object) error

+ func (NullObserver) RemoteSegment(context.Context, *Segment) error

+ type Object metabase.LoopObjectEntry

+ func (object *Object) Expired(now time.Time) bool

+ type Observer interface

+ InlineSegment func(context.Context, *Segment) error

+ LoopStarted func(context.Context, LoopInfo) error

+ Object func(context.Context, *Object) error

+ RemoteSegment func(context.Context, *Segment) error

+ type Segment struct

+ ExpirationDate time.Time

+ Location metabase.SegmentLocation

+ func (segment *Segment) Expired(now time.Time) bool

+ type Service struct

+ func New(config Config, metabaseDB MetabaseDB) *Service

+ func (loop *Service) Close() (err error)

+ func (loop *Service) Join(ctx context.Context, observers ...Observer) (err error)

+ func (loop *Service) Run(ctx context.Context) (err error)

+ func (loop *Service) RunOnce(ctx context.Context) (err error)

+ func (loop *Service) Wait()