Documentation
¶
Index ¶
- func AddSearch(p2p *dep2p.DeP2P, pubsub *pubsub.DeP2PPubSub, cache *ristretto.Cache, ...) (string, error)
- func HandleAddSearchRequestPubSub(p2p *dep2p.DeP2P, pubsub *pubsub.DeP2PPubSub, db *sqlites.SqliteDB, ...)
- func HandleAddSearchResponsePubSub(p2p *dep2p.DeP2P, pubsub *pubsub.DeP2PPubSub, db *sqlites.SqliteDB, ...)
- type FileAddSearchRequestPayload
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddSearch ¶
func AddSearch( p2p *dep2p.DeP2P, pubsub *pubsub.DeP2PPubSub, cache *ristretto.Cache, key string, value string, userPubHash []byte, ) (string, error)
AddSearch 新增搜索
func HandleAddSearchRequestPubSub ¶
func HandleAddSearchRequestPubSub(p2p *dep2p.DeP2P, pubsub *pubsub.DeP2PPubSub, db *sqlites.SqliteDB, res *streams.RequestMessage)
HandleAddSearchRequestPubSub 处理新增搜索请求的订阅消息
func HandleAddSearchResponsePubSub ¶
func HandleAddSearchResponsePubSub(p2p *dep2p.DeP2P, pubsub *pubsub.DeP2PPubSub, db *sqlites.SqliteDB, searchChan chan *core.SearchChan, res *streams.RequestMessage)
HandleAddSearchResponsePubSub 处理新增搜索响应的订阅消息
Types ¶
type FileAddSearchRequestPayload ¶
type FileAddSearchRequestPayload struct {
Value string // 搜索值
MD5 string // 请求值的MD5哈希
UserPubHash []byte // 用户的公钥哈希
}
文件新增搜索请求
Source Files
Click to show internal directories.
Click to hide internal directories.