Documentation
¶
Index ¶
Constants ¶
View Source
const DefaultPointerPrefixLength = 14
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_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, }
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.