block

Documentation

Index

• type BoundedRange
  • func NewBoundedRange(...) *BoundedRange
  • func (r *BoundedRange) AlignsWithBoundaries() bool
  • func (r *BoundedRange) AlignsWithLowerBound() bool
  • func (r *BoundedRange) AlignsWithUpperBound() bool
  • func (r *BoundedRange) IsPartial() bool
  • func (r *BoundedRange) NextBoundary() *BoundedRange
• 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) String() string
  • func (r Ranges) Swap(i, j int)

Types

type BoundedRange

type BoundedRange struct {
	*Range
	// contains filtered or unexported fields
}

BoundedRange is used to track corresponding ranges in chunks, respecting the boundaries

func NewBoundedRange

func NewBoundedRange(moduleInitBlock, boundInterval, requestStartBlock, requestExclusiveEndBlock uint64) *BoundedRange

func (*BoundedRange) AlignsWithBoundaries

func (r *BoundedRange) AlignsWithBoundaries() bool

Whether both sides of the range are aligned with interval boundaries.

func (*BoundedRange) AlignsWithLowerBound

func (r *BoundedRange) AlignsWithLowerBound() bool

func (*BoundedRange) AlignsWithUpperBound

func (r *BoundedRange) AlignsWithUpperBound() bool

func (*BoundedRange) IsPartial

func (r *BoundedRange) IsPartial() bool

func (*BoundedRange) NextBoundary

func (r *BoundedRange) NextBoundary() *BoundedRange

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) String

func (r Ranges) String() string

func (Ranges) Swap

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