streamseeder

Documentation

Index

• Variables
• type Callbacks
• type Config
  • func DefaultConfig(scale cachescale.Func) Config
• type Peer
• type Seeder
  • 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

Variables

var (
	ErrWrongType        = errors.New("wrong request type")
	ErrWrongSelectorLen = errors.New("wrong event selector length")
	ErrSelectorMismatch = errors.New("session selector mismatch")
	ErrTooManyChunks    = errors.New("too many request chunks")
)

Types

type Callbacks

type Callbacks struct {
	ForEachEvent func(start []byte, onEvent func(key hash.Event, event interface{}, size uint64) bool)
}

type Config

type Config struct {
	SenderThreads           int
	MaxSenderTasks          int
	MaxPendingResponsesSize int32
	MaxResponseChunks       uint32
}

func DefaultConfig

func DefaultConfig(scale cachescale.Func) Config

type Peer

type Peer struct {
	ID           string
	SendChunk    func(dagstream.Response, hash.Events) error
	Misbehaviour func(error)
}

type Seeder

type Seeder struct {
	// contains filtered or unexported fields
}

func New

func New(cfg Config, callbacks Callbacks) *Seeder

func (*Seeder) NotifyRequestReceived

func (s *Seeder) NotifyRequestReceived(peer Peer, r dagstream.Request) (err error, peerErr error)

func (*Seeder) Start

func (s *Seeder) Start()

func (*Seeder) Stop

func (s *Seeder) Stop()

Stop interrupts the seeder, canceling all the pending operations. Stop waits until all the internal goroutines have finished.

func (*Seeder) UnregisterPeer

func (s *Seeder) UnregisterPeer(peer string) error