dagstream

package
v0.0.0-...-34d0e24 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 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
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.