MCPcopy Create free account

hub / github.com/armon/go-chord / functions

Functions204 in github.com/armon/go-chord

⨍ Functions 204◇ Types & classes 25
↓ 31 callersMethodString
Converts the ID to string
vnode.go:11
↓ 22 callersFunctionmakeRing
()
ring_test.go:27
↓ 15 callersMethodinit
(conf *Config, trans Transport)
ring.go:9
↓ 14 callersMethodNext
()
iter_closest.go:23
↓ 13 callersMethodFindSuccessors
(int, []byte)
chord.go:45
↓ 13 callersMethodRegister
Register for an RPC callbacks
chord.go:38
↓ 13 callersFunctionmakeVnode
()
vnode_test.go:11
↓ 11 callersMethodNotify
(*Vnode)
chord.go:44
↓ 10 callersMethodClearPredecessor
(*Vnode)
chord.go:46
↓ 10 callersMethodGetPredecessor
()
chord.go:43
↓ 10 callersMethodPing
Ping a Vnode, check for liveness
chord.go:20
↓ 10 callersMethodSkipSuccessor
(*Vnode)
chord.go:47
↓ 10 callersFunctionbetween
Checks if a key is STRICTLY between two ID's exclusively
util.go:20
↓ 10 callersFunctionmakeLocal
()
transport_test.go:40
↓ 9 callersMethodDeregister
(v *Vnode)
transport.go:158
↓ 9 callersFunctionfastConf
()
chord_test.go:118
↓ 8 callersMethodShutdown
()
chord.go:56
↓ 8 callersMethodcheckNewSuccessor
Checks for a new successor
vnode.go:88
↓ 7 callersFunctionCreate
Creates a new Chord ring given the config and transport
chord.go:113
↓ 7 callersMethodgetConn
Gets an outbound connection to a host
net.go:139
↓ 7 callersMethodreturnConn
Returns an outbound TCP connection to the pool
net.go:181
↓ 6 callersFunctionJoin
Joins an existing Chord ring
chord.go:126
↓ 6 callersMethodListVnodes
Gets a list of the vnodes on the box
chord.go:17
↓ 6 callersMethodget
Checks for a local vnode
transport.go:36
↓ 6 callersMethodget
Checks for a local vnode
net.go:126
↓ 6 callersMethodinvokeDelegate
Invokes a function on the delegate and returns completion channel
ring.go:94
↓ 6 callersMethodknownSuccessors
Determine how many successors we know of
vnode.go:346
↓ 6 callersFunctionmergeErrors
Merges errors together
util.go:104
↓ 6 callersMethodnearestVnode
Returns the nearest local vnode to the key
ring.go:45
↓ 6 callersMethodschedule
Schedules each vnode in the ring
ring.go:56
↓ 5 callersFunctionInitLocalTransport
Creates a local transport to wrap a remote transport
transport.go:25
↓ 5 callersFunctionInitMLTransport
()
chord_test.go:14
↓ 5 callersFunctionbetweenRightIncl
Checks if a key is between two ID's, right inclusive
util.go:33
↓ 5 callersFunctiondistance
Computes the forward distance from a to b modulus a ring size
iter_closest.go:100
↓ 4 callersFunctionDefaultConfig
Returns the default Ring configuration
chord.go:99
↓ 4 callersMethodcheckPredecessor
Checks the health of our predecessor
vnode.go:231
↓ 4 callersMethodinit
(vn *localVnode, key []byte)
iter_closest.go:15
↓ 4 callersFunctionpowerOffset
Computes the offset by (n + 2^exp) % (2^mod)
util.go:45
↓ 4 callersFunctionprepRing
(port int)
net_test.go:9
↓ 4 callersMethodsetLocalSuccessors
Initializes the vnodes with their local successors
ring.go:83
↓ 3 callersMethodLookup
Does a key lookup for up to N successors of a key
chord.go:199
↓ 3 callersFunctionclosest_preceeding_vnode
Returns the closest preceeding Vnode to the key
iter_closest.go:89
↓ 3 callersMethodfixFingerTable
Fixes up the finger table
vnode.go:188
↓ 3 callersFunctionmin
min returns the min of two ints
util.go:84
↓ 3 callersFunctionnearestVnodeToKey
Returns the vnode nearest a key
util.go:93
↓ 3 callersMethodnotifySuccessor
Notifies our successor of us, updates successor list
vnode.go:141
↓ 3 callersMethodstabilize
Called to periodically stabilize the vnode
vnode.go:50
↓ 3 callersMethodstopDelegate
Stops the delegate handler
ring.go:74
↓ 3 callersMethodstopVnodes
Wait for all the vnodes to shutdown
ring.go:66
↓ 3 callersFunctiontrimSlice
Trims the slice to remove nil elements
net.go:813
↓ 2 callersMethodLeave
Leaves a given Chord ring and shuts down the local vnodes
chord.go:176
↓ 2 callersMethoddelegateHandler
This handler runs in a go routine to invoke methods on the delegate
ring.go:112
↓ 2 callersMethodgenId
Generates an ID for the node
vnode.go:38
↓ 2 callersMethodleave
Instructs the vnode to leave
vnode.go:292
↓ 2 callersFunctionmax
max returns the max of two ints
util.go:75
↓ 2 callersFunctionrandStabilize
Generates a random stabilization time
util.go:12
↓ 2 callersMethodsetupConn
Setup a connection
net.go:197
↓ 1 callersMethodClearPredecessor
(target, self *Vnode)
transport.go:190
↓ 1 callersMethodDeregister
(host string)
chord_test.go:86
↓ 1 callersMethodFindSuccessors
Finds next N successors. N must be <= NumSuccessors
vnode.go:248
↓ 1 callersMethodFindSuccessors
(vn *Vnode, n int, key []byte)
transport.go:186
↓ 1 callersMethodGetPredecessor
(vn *Vnode)
transport.go:178
↓ 1 callersFunctionInitTCPTransport
Creates a new TCP transport on the given listen address with the configured timeout duration.
net.go:92
↓ 1 callersMethodLeaving
(local, pred, succ *Vnode)
chord.go:53
↓ 1 callersMethodLen
Len is the number of vnodes
ring.go:29
↓ 1 callersMethodListVnodes
(host string)
transport.go:170
↓ 1 callersMethodNewPredecessor
(local, remoteNew, remotePrev *Vnode)
chord.go:52
↓ 1 callersMethodNotify
(vn, self *Vnode)
transport.go:182
↓ 1 callersMethodPing
(vn *Vnode)
transport.go:174
↓ 1 callersMethodPredecessorLeaving
(local, remote *Vnode)
chord.go:54
↓ 1 callersMethodSkipSuccessor
(target, self *Vnode)
transport.go:194
↓ 1 callersMethodSuccessorLeaving
(local, remote *Vnode)
chord.go:55
↓ 1 callersMethodhandleConn
Handles inbound TCP connections
net.go:640
↓ 1 callersMethodinit
Initializes a local vnode
vnode.go:16
↓ 1 callersMethodlisten
Listens for inbound connections
net.go:614
↓ 1 callersMethodreapOld
Closes old outbound connections
net.go:585
↓ 1 callersMethodreapOnce
()
net.go:595
↓ 1 callersMethodsafeInvoke
Called to safely call a function on the delegate
ring.go:123
↓ 1 callersMethodschedule
Schedules the Vnode to do regular maintenence
vnode.go:32
MethodClearPredecessor
Used to clear our predecessor when a node is leaving
vnode.go:314
MethodClearPredecessor
(p *Vnode)
transport_test.go:30
MethodClearPredecessor
Clears a predecessor if it matches a given vnode. Used to leave.
chord_test.go:62
MethodClearPredecessor
(target, self *Vnode)
transport.go:120
MethodClearPredecessor
Clears a predecessor if it matches a given vnode. Used to leave.
chord.go:32
MethodClearPredecessor
Clears a predecessor if it matches a given vnode. Used to leave.
net.go:454
MethodFindSuccessors
(n int, key []byte)
transport_test.go:25
MethodFindSuccessors
Find a successor
chord_test.go:54
MethodFindSuccessors
(vn *Vnode, n int, key []byte)
transport.go:107
MethodFindSuccessors
Find a successor
chord.go:29
MethodFindSuccessors
Find a successor
net.go:404
MethodGetPredecessor
RPC: Invoked to return out predecessor
vnode.go:136
MethodGetPredecessor
()
transport_test.go:18
MethodGetPredecessor
Request a nodes predecessor
chord_test.go:38
MethodGetPredecessor
(vn *Vnode)
transport.go:81
MethodGetPredecessor
Request a nodes predecessor
chord.go:23
MethodGetPredecessor
Request a nodes predecessor
net.go:304
MethodLeaving
(local, pred, succ *Vnode)
ring_test.go:17
MethodLess
Less returns whether the vnode with index i should sort before the vnode with index j.
ring.go:35
MethodListVnodes
(host string)
chord_test.go:22
MethodListVnodes
(host string)
transport.go:48
next →1–100 of 204, ranked by callers