epstream

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 31, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Locator

type Locator idx.Epoch

func (Locator) Compare

func (l Locator) Compare(b basestream.Locator) int

func (Locator) Inc

func (l Locator) Inc() basestream.Locator

type Metric

type Metric struct {
	Num  idx.Epoch
	Size uint64
}

func (Metric) String

func (m Metric) String() string

type Payload

type Payload struct {
	Items []rlp.RawValue
	Keys  []Locator
	Size  uint64
}

func (*Payload) AddEpochPacks

func (p *Payload) AddEpochPacks(id Locator, epsB rlp.RawValue)

func (Payload) Len

func (p Payload) Len() int

func (Payload) TotalMemSize

func (p Payload) TotalMemSize() int

func (Payload) TotalSize

func (p Payload) TotalSize() uint64

type Request

type Request struct {
	Session   Session
	Limit     Metric
	Type      basestream.RequestType
	MaxChunks uint32
}

type Response

type Response struct {
	SessionID uint32
	Done      bool
	Payload   []rlp.RawValue
}

type Session

type Session struct {
	ID    uint32
	Start Locator
	Stop  Locator
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL