incoming

Documentation

Index

• func RunIncomingPeer(ctx context.Context, params IncomingPeerParams) error
• type DuplicateChecker
• type IncomingPeerParams

Functions

func RunIncomingPeer

func RunIncomingPeer(ctx context.Context, params IncomingPeerParams) error

Types

type DuplicateChecker

type DuplicateChecker interface {
	Add([]byte) bool
}

type IncomingPeerParams

type IncomingPeerParams struct {
	WavesNetwork     string
	Conn             net.Conn
	Parent           peer.Parent
	DeclAddr         proto.TCPAddr
	Pool             bytespool.Pool
	Skip             conn.SkipFilter
	NodeName         string
	NodeNonce        uint64
	Version          proto.Version
	DuplicateChecker DuplicateChecker
}