net

package
v0.13.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 7, 2019 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source
const DefaultPointerPrefixLength = 14

Variables

Functions

This section is empty.

Types

type MRConfig added in v0.11.1

type MRConfig struct {
	Db        repo.Datastore
	IPFSNode  *core.IpfsNode
	DHT       *routing.IpfsDHT
	BanManger *net.BanManager
	Service   net.NetworkService
	PrefixLen int
	PushNodes []peer.ID
	Dialer    proxy.Dialer
	SendAck   func(peerId string, pointerID peer.ID) error
	SendError func(peerId string, k *libp2p.PubKey, errorMessage pb.Message) error
}

type MessageRetriever

type MessageRetriever struct {
	DoneChan chan struct{}

	*sync.WaitGroup
	// contains filtered or unexported fields
}

func NewMessageRetriever

func NewMessageRetriever(cfg MRConfig) *MessageRetriever

func (*MessageRetriever) Run

func (m *MessageRetriever) Run()

func (*MessageRetriever) RunOnce added in v0.13.5

func (m *MessageRetriever) RunOnce()

RunOnce - used to fetch messages only once

Jump to

Keyboard shortcuts

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