requestmanger

Documentation

Index

• type ParallelRequestManger
  • func NewParGraphSyncRequestManger(exchange pargraphsync.ParallelGraphExchange, parent context.Context, ...) *ParallelRequestManger
  • func (m *ParallelRequestManger) Start(ctx context.Context) (<-chan graphsync.ResponseProgress, <-chan error)

Types

type ParallelRequestManger

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

func NewParGraphSyncRequestManger

func NewParGraphSyncRequestManger(exchange pargraphsync.ParallelGraphExchange, parent context.Context, peers []peer.ID,
	root ipld.Link, selector ipld.Node, extensions ...graphsync.ExtensionData) *ParallelRequestManger

func (*ParallelRequestManger) Start

func (m *ParallelRequestManger) Start(ctx context.Context) (<-chan graphsync.ResponseProgress, <-chan error)