block

Documentation

Index

• type Range
  • func NewRange(startBlock, exclusiveEndBlock uint64) *Range
  • func ParseRange(in string) *Range
  • func (r *Range) Contains(blockNum uint64) bool
  • func (r *Range) Equals(other *Range) bool
  • func (r *Range) IsAbove(blockNum uint64) bool
  • func (r *Range) IsBelow(blockNum uint64) bool
  • func (r *Range) IsEmpty() bool
  • func (r *Range) IsOutOfBounds(blockNum uint64) bool
  • func (r *Range) Len() uint64
  • func (r *Range) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (r *Range) Size() uint64
  • func (r *Range) Split(chunkSize uint64) []*Range
  • func (r *Range) String() string
• type Ranges
  • func ParseRanges(in string) (out Ranges)
  • func (r Ranges) Contains(input *Range) bool
  • func (r Ranges) Len() int
  • func (r Ranges) Less(i, j int) bool
  • func (r Ranges) Merged() (out Ranges)
  • func (r Ranges) MergedBuckets(maxBucketSize uint64) (out Ranges)
  • func (r Ranges) SortAndDedupe() (out Ranges)
  • func (r Ranges) String() string
  • func (r Ranges) Swap(i, j int)
• type Segmenter
  • func NewSegmenter(interval uint64, initialBlock uint64, exclusiveEndBlock uint64) *Segmenter
  • func (s *Segmenter) Count() int
  • func (s *Segmenter) EndsOnInterval(segmentIndex int) bool
  • func (s *Segmenter) ExclusiveEndBlock() uint64
  • func (s *Segmenter) FirstIndex() int
  • func (s *Segmenter) IndexForEndBlock(blockNum uint64) int
  • func (s *Segmenter) IndexForStartBlock(blockNum uint64) int
  • func (s *Segmenter) InitialBlock() uint64
  • func (s *Segmenter) LastIndex() int
  • func (s *Segmenter) Range(idx int) *Range
  • func (s *Segmenter) WithExclusiveEndBlock(newExclusiveEndBlock uint64) *Segmenter
  • func (s *Segmenter) WithInitialBlock(newInitialBlock uint64) *Segmenter

Types

type Range

type Range struct {
	StartBlock        uint64 `json:"start_block"`
	ExclusiveEndBlock uint64 `json:"exclusive_end_block"`
}

func NewRange

func NewRange(startBlock, exclusiveEndBlock uint64) *Range

func ParseRange

func ParseRange(in string) *Range

func (*Range) Contains

func (r *Range) Contains(blockNum uint64) bool

func (*Range) Equals

func (r *Range) Equals(other *Range) bool

func (*Range) IsAbove

func (r *Range) IsAbove(blockNum uint64) bool

func (*Range) IsBelow

func (r *Range) IsBelow(blockNum uint64) bool

func (*Range) IsEmpty

func (r *Range) IsEmpty() bool

func (*Range) IsOutOfBounds

func (r *Range) IsOutOfBounds(blockNum uint64) bool

func (*Range) Len

func (r *Range) Len() uint64

func (*Range) MarshalLogObject

func (r *Range) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Range) Size

func (r *Range) Size() uint64

func (*Range) Split

func (r *Range) Split(chunkSize uint64) []*Range

func (*Range) String

func (r *Range) String() string

type Ranges

type Ranges []*Range

func ParseRanges

func ParseRanges(in string) (out Ranges)

func (Ranges) Contains

func (r Ranges) Contains(input *Range) bool

func (Ranges) Len

func (r Ranges) Len() int

func (Ranges) Less

func (r Ranges) Less(i, j int) bool

func (Ranges) Merged

func (r Ranges) Merged() (out Ranges)

func (Ranges) MergedBuckets

func (r Ranges) MergedBuckets(maxBucketSize uint64) (out Ranges)

func (Ranges) SortAndDedupe

func (r Ranges) SortAndDedupe() (out Ranges)

func (Ranges) String

func (r Ranges) String() string

func (Ranges) Swap

func (r Ranges) Swap(i, j int)

type Segmenter

type Segmenter struct {
	// contains filtered or unexported fields
}

func NewSegmenter

func NewSegmenter(interval uint64, initialBlock uint64, exclusiveEndBlock uint64) *Segmenter

func (*Segmenter) Count

func (s *Segmenter) Count() int

Count returns the number of valid segments for the internal range. Use LastIndex to know about the highest index.

func (*Segmenter) EndsOnInterval

func (s *Segmenter) EndsOnInterval(segmentIndex int) bool

func (*Segmenter) ExclusiveEndBlock

func (s *Segmenter) ExclusiveEndBlock() uint64

func (*Segmenter) FirstIndex

func (s *Segmenter) FirstIndex() int

func (*Segmenter) IndexForEndBlock

func (s *Segmenter) IndexForEndBlock(blockNum uint64) int

func (*Segmenter) IndexForStartBlock

func (s *Segmenter) IndexForStartBlock(blockNum uint64) int

func (*Segmenter) InitialBlock

func (s *Segmenter) InitialBlock() uint64

func (*Segmenter) LastIndex

func (s *Segmenter) LastIndex() int

func (*Segmenter) Range

func (s *Segmenter) Range(idx int) *Range

func (*Segmenter) WithExclusiveEndBlock

func (s *Segmenter) WithExclusiveEndBlock(newExclusiveEndBlock uint64) *Segmenter

func (*Segmenter) WithInitialBlock

func (s *Segmenter) WithInitialBlock(newInitialBlock uint64) *Segmenter