net

Documentation

Index

• Constants
• type MessageRetriever
  • func NewMessageRetriever(db repo.Datastore, ctx commands.Context, node *core.IpfsNode, ...) *MessageRetriever
  • func (m *MessageRetriever) Run()

Constants

const DefaultPointerPrefixLength = 14

Types

type MessageRetriever

type MessageRetriever struct {
	DoneChan chan struct{}
	*sync.WaitGroup
	// contains filtered or unexported fields
}

func NewMessageRetriever

func NewMessageRetriever(db repo.Datastore, ctx commands.Context, node *core.IpfsNode, bm *net.BanManager, service net.NetworkService, prefixLen int, pushNodes []peer.ID, dialer proxy.Dialer, sendAck func(peerId string, pointerID peer.ID) error) *MessageRetriever

func (*MessageRetriever) Run

func (m *MessageRetriever) Run()