Versions in this module Expand all Collapse all v1 v1.0.0 Nov 7, 2021 Changes in this version + var ErrSelectorMismatch = errors.New("session selector mismatch") + var ErrTooManyChunks = errors.New("too many request chunks") + var ErrWrongSelectorLen = errors.New("wrong event selector length") + var ErrWrongType = errors.New("wrong request type") + type Callbacks struct + ForEachEvent func(start []byte, ...) + type Config struct + MaxPendingResponsesSize int32 + MaxResponseChunks uint32 + MaxSenderTasks int + SenderThreads int + func DefaultConfig(scale cachescale.Func) Config + type Peer struct + ID string + Misbehaviour func(error) + SendChunk func(dagstream.Response, hash.Events) error + type Seeder struct + func New(cfg Config, callbacks Callbacks) *Seeder + func (s *Seeder) NotifyRequestReceived(peer Peer, r dagstream.Request) (err error, peerErr error) + func (s *Seeder) Start() + func (s *Seeder) Stop() + func (s *Seeder) UnregisterPeer(peer string) error
Go to main page