domain

Documentation

Index

• type Segment
  • func NewSegment(do *Segment, repo SegmentRepo) *Segment
  • func (s *Segment) FetchNext(ctx context.Context) (uint64, error)
• type SegmentRepo

Types

type Segment

type Segment struct {
	ID               string
	Step             uint32
	Seq              *atomic.Uint64
	Max              uint64
	PreloadThreshold float32
	// contains filtered or unexported fields
}

func NewSegment

func NewSegment(do *Segment, repo SegmentRepo) *Segment

func (*Segment) FetchNext

func (s *Segment) FetchNext(ctx context.Context) (uint64, error)

type SegmentRepo

type SegmentRepo interface {
	FetchNextSegment(ctx context.Context, ID string, maxID uint64) (*Segment, error)
	SaveSegment(ctx context.Context, ID string, seq, max uint64, step uint32, preloadThreshold float32)
}