Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/distributed/malus
/ functions
Functions
84 in github.com/distributed/malus
⨍
Functions
84
◇
Types & classes
26
↓ 14 callers
Method
Len
()
lib/routing.go:80
↓ 11 callers
Method
At
(i int)
lib/routing.go:122
↓ 9 callers
Function
XOR
(a, b string)
lib/utility.go:39
↓ 8 callers
Method
Push
(h *RTHost)
lib/routing.go:78
↓ 8 callers
Method
String
()
lib/host.go:26
↓ 5 callers
Method
Call
(addr net.Addr, name string, args []interface{})
lib/callmanager.go:579
↓ 4 callers
Function
NewRTHostList
()
lib/routing.go:60
↓ 4 callers
Method
Sort
()
lib/routing.go:102
↓ 4 callers
Method
Write
(p []byte)
lib/callmanager.go:30
↓ 3 callers
Method
AddRPC
(name string, fun interface{})
lib/callmanager.go:292
↓ 3 callers
Function
BucketNo
Returns into which bucket the given Distance d falls. BucketNo counts upwards from MSB to LSB, from d[0] to d[len(d)-1], e.g. if the MSB of d[0] is se
lib/utility.go:59
↓ 3 callers
Method
Copy
Copies an RTHost and computes the Distance of rh.Host to newref. If newref is "", the old distance is used
lib/routing.go:68
↓ 3 callers
Function
SHA1String
Hashes a string and returns a 20 byte string.
lib/utility.go:32
↓ 3 callers
Method
Sleep
(howlong uint64)
lib/sleepqueue.go:23
↓ 3 callers
Method
Slice
(i, j int)
lib/routing.go:96
↓ 2 callers
Method
Data
()
lib/routing.go:112
↓ 2 callers
Method
EncodeRPC
(rpc *RPC)
lib/callmanager.go:445
↓ 2 callers
Method
GetClosest
(t string, n uint)
lib/routing.go:20
↓ 2 callers
Method
SeeHost
(h *Host)
lib/routing.go:15
↓ 2 callers
Method
SendRPC
(rpc *RPC)
lib/callmanager.go:36
↓ 2 callers
Method
findHost
(h *Host)
lib/routing.go:242
↓ 1 callers
Method
DecodePayload
(h *Header, raw []byte, payloadpos int)
lib/callmanager.go:348
↓ 1 callers
Method
DispatchAnswer
(rpc *RPC)
lib/callmanager.go:286
↓ 1 callers
Method
DispatchPacket
(packet *Packet)
lib/callmanager.go:520
↓ 1 callers
Method
DispatchRPC
TODO: errors...
lib/callmanager.go:212
↓ 1 callers
Method
DispatchRequest
(rpc *RPC)
lib/callmanager.go:237
↓ 1 callers
Method
EncodeHeader
(rpc *RPC)
lib/callmanager.go:470
↓ 1 callers
Method
EncodePayload
TODO: this is a misnomer...
lib/callmanager.go:504
↓ 1 callers
Method
GetClosest
goroutine safe. not for internal use!
lib/routing.go:375
↓ 1 callers
Method
GetHTML
may return "", subject to change
lib/routing.go:19
↓ 1 callers
Method
GetReceiveChannel
()
lib/callmanager.go:37
↓ 1 callers
Method
Less
(b Distance)
lib/utility.go:80
↓ 1 callers
Function
NewHost
(addr net.Addr, id string)
lib/host.go:15
↓ 1 callers
Method
ParseHeader
(raw []byte)
lib/callmanager.go:308
↓ 1 callers
Method
PopFront
()
lib/routing.go:106
↓ 1 callers
Method
ReadRPC
(h *Header, payload interface{})
lib/callmanager.go:371
↓ 1 callers
Method
Run
()
lib/webinterface.go:37
↓ 1 callers
Method
Run
()
lib/callmanager.go:643
↓ 1 callers
Method
Run
()
lib/udp.go:81
↓ 1 callers
Method
Run
()
lib/sleepqueue.go:62
↓ 1 callers
Method
balanceleftright
(lefti uint)
lib/routing.go:273
↓ 1 callers
Method
constructAnswer
(req *RPC, retcall uint8, retis []interface{})
lib/callmanager.go:192
↓ 1 callers
Function
find
bootstrap is used destructively. you have been warned.
lib/find.go:111
↓ 1 callers
Method
find
(c *http.Conn, r *http.Request)
lib/webinterface.go:115
↓ 1 callers
Method
getClosest
not goroutine safe. for internal use!
lib/routing.go:383
↓ 1 callers
Method
getDummy
()
lib/webinterface.go:54
↓ 1 callers
Method
html
not goroutine safe
lib/routing.go:334
↓ 1 callers
Method
main
()
lib/routing.go:157
↓ 1 callers
Method
manageRunning
()
lib/callmanager.go:161
↓ 1 callers
Method
newBucket
()
lib/routing.go:227
↓ 1 callers
Method
receiveLoop
()
lib/udp.go:61
↓ 1 callers
Function
robot
(oid string, t string, rh *RTHost, retchan chan *robotReturn, cm *CallManager)
lib/find.go:89
↓ 1 callers
Function
robotParse
(oid string, t string, retis []interface{})
lib/find.go:17
↓ 1 callers
Method
seeHost
(h *Host)
lib/routing.go:178
↓ 1 callers
Method
sendLoop
()
lib/udp.go:51
↓ 1 callers
Method
server
()
lib/sleepqueue.go:34
↓ 1 callers
Method
sleeper
()
lib/sleepqueue.go:46
↓ 1 callers
Method
string
not goroutine safe
lib/routing.go:318
Method
Append
(m *RTHostList)
lib/routing.go:126
Function
FarthestNode
(oid string)
lib/utility.go:103
Method
GetHTML
goroutine safe. not for internal use!
lib/routing.go:368
Method
GetReceiveChannel
()
lib/udp.go:46
Method
GetString
may return ""
lib/routing.go:17
Method
GetString
goroutine safe. not for internal use!
lib/routing.go:361
Method
Less
(i, j int)
lib/routing.go:86
Function
NewBRoutingTable
(id string)
lib/routing.go:130
Function
NewCallManager
(transceiver Transceiver, rt RoutingTable)
lib/callmanager.go:144
Function
NewSleepQueue
()
lib/sleepqueue.go:74
Function
NewUDPTransceiver
(snet string, laddr *net.UDPAddr)
lib/udp.go:26
Function
NewWebInterface
(addr string, cm *CallManager, rt RoutingTable)
lib/webinterface.go:23
Function
Ping
* */
lib/callmanager.go:668
Function
SHA1Bytes
Hashes a byte slice and returns a 20 byte string.
lib/utility.go:25
Method
SeeHost
(h *Host)
lib/routing.go:175
Method
SendRPC
(rpc *RPC)
lib/udp.go:40
Method
Stop
()
lib/sleepqueue.go:68
Function
Store
(rpc *RPC, hash string, data string)
lib/callmanager.go:670
Method
String
()
lib/callmanager.go:51
Method
String
()
lib/callmanager.go:88
Method
String
()
lib/callmanager.go:92
Method
String
()
lib/udp.go:17
Method
String
()
lib/utility.go:12
Method
Swap
(i, j int)
lib/routing.go:91
Function
main
()
main/main.go:16
Method
wrapHandler
this function wraps handlers defined as methods of a WebInterface struct and binds them to a provided *WebInterface
lib/webinterface.go:45