epstream

Documentation

Index

• type Locator
  • func (l Locator) Compare(b basestream.Locator) int
  • func (l Locator) Inc() basestream.Locator
• type Metric
  • func (m Metric) String() string
• type Payload
  • func (p *Payload) AddEpochPacks(id Locator, epsB rlp.RawValue)
  • func (p Payload) Len() int
  • func (p Payload) TotalMemSize() int
  • func (p Payload) TotalSize() uint64
• type Request
• type Response
• type Session

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
}