String returns the bit sequence string of the bitmap.

RawString returns the string value of bitmap.data.

KBucket returns the bucket routingTableNode holds.

Set sets the bit at idnex to 1.

send sends data to the udp.

Get returns the value mapped to key.

Iter returns a chan which output all items.

Bit returns the bit at index.

Len returns the length of syncedMap.

ParseKey parses the key in dict data. `t` is type of the keyed value. It's one of "int", "string", "map", "list".

Delete deletes the key in the map.

id returns a id near to target if target is not null, otherwise it returns the dht's node id.

makeError returns a err-formed data.

newSyncedMap returns a syncedMap pointer.

Child returns routingTableNode's left or right child.

PushBack pushs an element to the tail of slist.

newBitmapFromString returns a bitmap pointer created from a string.

Decode decodes a bencoded string to string, int, list or map.

Insert inserts node to the bucket. It returns whether the node is new in the bucket.

validate checks whether ip-port pair is in the block nodes list.

makeResponse returns a response-formed data.

newBitmap returns a size-length bitmap pointer.

Clear resets the data.

Front returns the first element of slist.

ParseKeys parses keys. It just wraps ParseKey.

Remove deletes the node whose id is `id`.

insert adds a transaction to transactionManager.

insert adds a blocked item to the blacklist.

newKeyedDeque returns a newKeyedDeque pointer.

Compare compares the prefixLen-prefix of two bitmap. - If bitmap.data[:prefixLen] < other.data[:prefixLen], return -1. - If bitmap.data[:prefixLen] >

Has returns whether key already exists.

genAddress returns a ip:port address.

genKey returns a key. If port is less than 0, the key wil be ip. Ohterwise it will be `ip:port` format.

newNode returns a node pointer.

randomString generates a size-length string randomly.

sendQuery send query-formed data to the chan.

CompactIPPortInfo returns "Compact IP-address/port info". See http://www.bittorrent.org/beps/bep_0005.html.

DeleteMulti deletes keys in batch.

Encode encodes a string, int, dict or list value to a bencoded string.

EncodeString encodes a string value.

GetNeighbors returns the size-length nodes closest to id.

IsStandardMode returns whether mode is StandardMode.

Remove removes e from the slist.

Remove deletes the node whose address is `ip:port`.

UpdateTimestamp update bucket's last changed time..

clear removes expired tokens.

decodeCompactIPPortInfo decodes compactIP-address/port info in BitTorrent DHT Protocol. It returns the ip and port number.

decodeItem decodes an item of dict or list.

encodeCompactIPPortInfo encodes an ip and a port number to compactIP-address/port info.

findNode sends find_node query to the chan.

int2bytes returns the byte array it represents.

newBlackList returns a blackList pointer.

newSyncedList returns a syncedList pointer.

read reads size-length bytes from conn to data.

token returns a token. If it doesn't exist or is expired, it will add a new token.

Back returns the last element of slist.

CompactNodeInfo returns "Compact node info". See http://www.bittorrent.org/beps/bep_0005.html.

EncodeDict encodes a dict value.

EncodeInt encodes a int value.

EncodeList encodes a list value.

Fresh pings the expired nodes in the bucket.

GetNeighborIds return the size-length compact node info closest to id.

GetNodeKBucktById returns node whose id is `id` and the bucket it belongs to.

Has returns whether the syncedMap contains the key.

IsCrawlMode returns whether mode is CrawlMode.

NewStandardConfig returns a Config pointer with default values.

Xor returns the xor value of two bitmap.

bytes2int returns the int value it represents.

delete removes a transaction from transactionManager.

EncodeItem encodes an item of dict or list.

transaction gets the proper transaction with whose id is transId and address is addr.

find returns the index of first target in data starting from `start`. It returns -1 if target not found.

findOn puts nodes in the response to the routingTable, then if target is in the nodes or all nodes are in the routingTable, it stops. Otherwise it con

genIndexKey generates an indexed key which consists of queryType and address.

genIndexKeyByTrans generates an indexed key by a transaction.

getPeers sends get_peers query to the chan.

join makes current node join the dht network.

newBitmapFrom returns a new copyed bitmap pointer which newBitmap.data = other.data[:size].

newBitmapFromBytes returns a bitmap pointer created from a byte array.

newPeer returns a new peer pointer.

newRoutingTableNode returns a new routingTableNode pointer.

sendMessage sends data to the connection.

set sets the bit at index `index`. If bit is true, set 1, otherwise set 0.

transaction returns a transaction. keyType should be one of 0, 1 which represents transId and index each.

DecodeDict decodes a map value.

DecodeString decodes a string in the data. It returns a tuple (decoded result, the end position, error).

Delete deletes a value named key.

Get returns the keyed value.

GetNodeByAddress finds node by address.

GetPeers returns peers who have announced having infoHash.

InsertBefore inserts v before mark.

LastChanged return the last time when it changes.

process data from redis message queue by indexing them to elastic search

Push pushs a keyed-value to the end of deque.