net

Documentation

Index

• Constants
• Variables
• type MRConfig
• type MessageRetriever
  • func NewMessageRetriever(cfg MRConfig) *MessageRetriever
  • func (m *MessageRetriever) Run()
  • func (m *MessageRetriever) RunOnce()

Constants

const DefaultPointerPrefixLength = 14

Variables

var MessageProcessingOrder = []pb.Message_MessageType{
	pb.Message_ORDER,
	pb.Message_ORDER_CANCEL,
	pb.Message_ORDER_REJECT,
	pb.Message_ORDER_CONFIRMATION,
	pb.Message_ORDER_PAYMENT,
	pb.Message_ORDER_FULFILLMENT,
	pb.Message_ORDER_COMPLETION,
	pb.Message_DISPUTE_OPEN,
	pb.Message_DISPUTE_UPDATE,
	pb.Message_VENDOR_FINALIZED_PAYMENT,
	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,
	pb.Message_OFFLINE_RELAY,
}

Types

type MRConfig

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

func (m *MessageRetriever) RunOnce()

RunOnce - used to fetch messages only once