dagstream

Documentation

Index

• Constants
• type Locator
  • func (l Locator) Compare(b basestream.Locator) int
  • func (l Locator) Inc() basestream.Locator
• type Payload
  • func (p *Payload) AddEvent(id hash.Event, eventB rlp.RawValue)
  • func (p *Payload) AddID(id hash.Event, size int)
  • func (p Payload) Len() int
  • func (p Payload) TotalMemSize() int
  • func (p Payload) TotalSize() uint64
• type Request
• type Response
• type Session

Constants

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

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
}