net

package
v0.12.0 Latest Latest
Warning

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

 Go to latest Published: May 9, 2018 License: MIT Imports: 24 Imported by: 30

Documentation

Index

Constants

View Source 
const (
	DefaultPointerPrefixLength = 14
	KeyCachePrefix             = "IPNSPUBKEYCACHE_"
)

Variables

View Source 
var MessageProcessingOrder = []pb.Message_MessageType{
	pb.Message_ORDER,
	pb.Message_ORDER_CANCEL,
	pb.Message_ORDER_REJECT,
	pb.Message_ORDER_CONFIRMATION,
	pb.Message_ORDER_FULFILLMENT,
	pb.Message_ORDER_COMPLETION,
	pb.Message_DISPUTE_OPEN,
	pb.Message_DISPUTE_UPDATE,
	pb.Message_DISPUTE_CLOSE,
	pb.Message_REFUND,
	pb.Message_CHAT,
	pb.Message_FOLLOW,
	pb.Message_UNFOLLOW,
	pb.Message_MODERATOR_ADD,
	pb.Message_MODERATOR_REMOVE,
	pb.Message_OFFLINE_ACK,
}

Functions

This section is empty.

Types

type MRConfig added in v0.11.1 

type MRConfig struct {
	Db        repo.Datastore
	Ctx       commands.Context
	IPFSNode  *core.IpfsNode
	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()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.