metaloop

Apr 14, 2021

Changes in this version

+ type LoopInfo struct

+ Started time.Time

type NullObserver

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

type Observer

+ LoopStarted func(context.Context, LoopInfo) error

Apr 5, 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 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) 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

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

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

+ type Segment struct

+ CreationDate time.Time

+ ExpirationDate time.Time

+ LastRepaired 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()