dagstream

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: 7 Imported by: 0

Documentation

Index

Constants

View Source
const (
	RequestIDs    basestream.RequestType = 0
	RequestEvents basestream.RequestType = 2
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Locator

type Locator []byte

func (Locator) Compare

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

func (Locator) Inc

func (l Locator) Inc() basestream.Locator

type Payload

type Payload struct {
	IDs    hash.Events
	Events []rlp.RawValue
	Size   uint64
}

func (*Payload) AddEvent

func (p *Payload) AddEvent(id hash.Event, eventB rlp.RawValue)

func (*Payload) AddID

func (p *Payload) AddID(id hash.Event, size int)

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     dag.Metric
	Type      basestream.RequestType
	MaxChunks uint32
}

type Response

type Response struct {
	SessionID uint32
	Done      bool
	IDs       hash.Events
	Events    []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