rangedlooptest

Mar 6, 2023

Changes in this version

type InfiniteSegmentProvider

+ func (m *InfiniteSegmentProvider) Range() rangedloop.UUIDRange

type SegmentProvider

+ func (m *SegmentProvider) Range() rangedloop.UUIDRange

Jan 23, 2023

Changes in this version

+ type CallbackObserver struct

+ OnFinish func(context.Context) error

+ OnFork func(context.Context) (rangedloop.Partial, error)

+ OnJoin func(context.Context, rangedloop.Partial) error

+ OnProcess func(context.Context, []segmentloop.Segment) error

+ OnStart func(context.Context, time.Time) error

+ func (c *CallbackObserver) Finish(ctx context.Context) error

+ func (c *CallbackObserver) Fork(ctx context.Context) (rangedloop.Partial, error)

+ func (c *CallbackObserver) Join(ctx context.Context, partial rangedloop.Partial) error

+ func (c *CallbackObserver) Process(ctx context.Context, segments []segmentloop.Segment) error

+ func (c *CallbackObserver) Start(ctx context.Context, time time.Time) error

+ type InfiniteSegmentProvider struct

+ func (m *InfiniteSegmentProvider) CreateRanges(nRanges int, batchSize int) (segmentsProviders []rangedloop.SegmentProvider, err error)

+ func (m *InfiniteSegmentProvider) Iterate(ctx context.Context, fn func([]segmentloop.Segment) error) error

Jan 10, 2023

Changes in this version

+ type CountObserver struct

+ NumSegments int

+ func (c *CountObserver) Finish(ctx context.Context) error

+ func (c *CountObserver) Fork(ctx context.Context) (rangedloop.Partial, error)

+ func (c *CountObserver) Join(ctx context.Context, partial rangedloop.Partial) error

+ func (c *CountObserver) Process(ctx context.Context, segments []segmentloop.Segment) error

+ func (c *CountObserver) Start(ctx context.Context, time time.Time) error

+ type RangeSplitter struct

+ Segments []segmentloop.Segment

+ func (m *RangeSplitter) CreateRanges(nRanges int, batchSize int) ([]rangedloop.SegmentProvider, error)

+ type SegmentProvider struct

+ Segments []segmentloop.Segment

+ func (m *SegmentProvider) Iterate(ctx context.Context, fn func([]segmentloop.Segment) error) error

+ type SleepObserver struct

+ Duration time.Duration

+ func (c *SleepObserver) Finish(ctx context.Context) error

+ func (c *SleepObserver) Fork(ctx context.Context) (rangedloop.Partial, error)

+ func (c *SleepObserver) Join(ctx context.Context, partial rangedloop.Partial) error

+ func (c *SleepObserver) Process(ctx context.Context, segments []segmentloop.Segment) error

+ func (c *SleepObserver) Start(ctx context.Context, time time.Time) error