segmentloop

Mar 6, 2023

Changes in this version

type Segment

+ func (s Segment) PieceSize() int64

Jun 22, 2021

Changes in this version

type Config

+ SuspiciousProcessedRatio float64

type MetabaseDB

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

type Segment

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

Jun 14, 2021

Changes in this version

type Config

+ AsOfSystemInterval time.Duration

Jun 8, 2021

Changes in this version

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

+ var Error = errs.Class("segments loop")

+ type Config struct

+ CoalesceDuration time.Duration

+ ListLimit int

+ RateLimit float64

+ type LoopInfo struct

+ Started time.Time

+ type MetabaseDB interface

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

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

+ type NullObserver struct

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

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

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

+ type Observer interface

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

+ LoopStarted func(context.Context, LoopInfo) error

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

+ type Segment metabase.LoopSegmentEntry

+ func (s Segment) Inline() bool

+ type Service struct

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

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

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

+ func (loop *Service) Monitor(ctx context.Context, observer 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()