server

package

Go to main page

Versions in this module

v0

v0.12.0

Jan 27, 2023

v0.11.0

Dec 9, 2022 GO-2023-1766

GO-2023-1766: Denial of service from memory leak in github.com/ipfs/go-libipfs

v0.10.2

Sep 13, 2022 GO-2023-1766

GO-2023-1766: Denial of service from memory leak in github.com/ipfs/go-libipfs

v0.10.1

Sep 8, 2022 GO-2023-1766

GO-2023-1766: Denial of service from memory leak in github.com/ipfs/go-libipfs

v0.10.0

Sep 1, 2022 GO-2023-1766

GO-2023-1766: Denial of service from memory leak in github.com/ipfs/go-libipfs

v0.9.0

Aug 13, 2022 GO-2023-1766

GO-2023-1766: Denial of service from memory leak in github.com/ipfs/go-libipfs

Changes in this version

+ type Option func(*Server)

+ func EngineBlockstoreWorkerCount(count int) Option

+ func EngineTaskWorkerCount(count int) Option

+ func HasBlockBufferSize(count int) Option

+ func MaxOutstandingBytesPerPeer(count int) Option

+ func ProvideEnabled(enabled bool) Option

+ func SetSendDontHaves(send bool) Option

+ func TaskWorkerCount(count int) Option

+ func WithPeerBlockRequestFilter(pbrf decision.PeerBlockRequestFilter) Option

+ func WithScoreLedger(scoreLedger decision.ScoreLedger) Option

+ func WithTargetMessageSize(tms int) Option

+ func WithTaskComparator(comparator decision.TaskComparator) Option

+ func WithTracer(tap tracer.Tracer) Option

+ type PeerBlockRequestFilter = decision.PeerBlockRequestFilter

+ type Receipt = decision.Receipt

+ type ScoreLedger = decision.ScoreLedger

+ type ScorePeerFunc = decision.ScorePeerFunc

+ type Server struct

+ func New(ctx context.Context, network bsnet.BitSwapNetwork, ...) *Server

+ func (*Server) ReceiveError(err error)

+ func (bs *Server) Close() error

+ func (bs *Server) LedgerForPeer(p peer.ID) *decision.Receipt

+ func (bs *Server) NotifyNewBlocks(ctx context.Context, blks ...blocks.Block) error

+ func (bs *Server) PeerConnected(p peer.ID)

+ func (bs *Server) PeerDisconnected(p peer.ID)

+ func (bs *Server) ReceiveMessage(ctx context.Context, p peer.ID, incoming message.BitSwapMessage)

+ func (bs *Server) ReceivedBlocks(from peer.ID, blks []blocks.Block)

+ func (bs *Server) Stat() (Stat, error)

+ func (bs *Server) WantlistForPeer(p peer.ID) []cid.Cid

+ type Stat struct

+ BlocksSent uint64

+ DataSent uint64

+ Peers []string

+ ProvideBufLen int

+ type TaskComparator = decision.TaskComparator

+ type TaskInfo = decision.TaskInfo

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL