net

Documentation

Index

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

Constants

const (
	DefaultPointerPrefixLength = 14
	KeyCachePrefix             = "IPNSPUBKEYCACHE_"
)

Variables

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,
}

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()