MCPcopy Create free account

hub / github.com/ailidani/paxi / functions

Functions575 in github.com/ailidani/paxi

⨍ Functions 575◇ Types & classes 177
↓ 208 callersMethodID
()
node.go:16
↓ 159 callersMethodRegister
(m interface{}, f interface{})
node.go:20
↓ 61 callersFunctionDebugf
(format string, v ...interface{})
log/log.go:134
↓ 38 callersFunctionError
(v ...interface{})
log/log.go:164
↓ 38 callersMethodZone
Zone returns Zond ID component
id.go:26
↓ 30 callersMethodSend
Send put message to outbound queue
socket.go:15
↓ 28 callersMethodACK
ACK adds id to quorum ack records
quorum.go:22
↓ 22 callersMethodReply
Reply replies to current client session
message.go:33
↓ 21 callersMethodBroadcast
Broadcast send to all peers
socket.go:24
↓ 18 callersMethodSend
Send overrides Socket interface in Node
kpaxos/replica.go:118
↓ 16 callersFunctionNewQuorum
NewQuorum returns a new Quorum
quorum.go:12
↓ 15 callersMethodGet
(Key)
db.go:56
↓ 15 callersMethodRun
()
node.go:17
↓ 14 callersMethodForward
(id ID, r Request)
node.go:19
↓ 14 callersFunctionNewNode
NewNode creates a new Node object from configuration
node.go:38
↓ 13 callersMethodExecute
(Command)
db.go:54
↓ 13 callersFunctionGetConfig
GetConfig returns paxi package configuration
config.go:45
↓ 13 callersFunctionInfof
(format string, v ...interface{})
log/log.go:146
↓ 12 callersMethodBroadcast
Broadcast overrides Socket interface in Node
kpaxos/replica.go:104
↓ 12 callersMethodClose
()
socket.go:29
↓ 12 callersMethodEncode
(interface{})
codec.go:15
↓ 12 callersFunctionMax
Max of two int
util.go:13
↓ 11 callersMethodAdd
(e interface{})
lib/set.go:9
↓ 11 callersMethodDecode
(interface{})
codec.go:16
↓ 11 callersFunctionFatal
(v ...interface{})
log/log.go:172
↓ 11 callersMethodlinearizable
(history []*operation)
checker.go:69
↓ 10 callersMethodMulticastZone
MulticastZone send msg to all nodes in the same site
socket.go:18
↓ 9 callersMethodMajority
Majority quorum satisfied
quorum.go:60
↓ 9 callersMethodWrite
(key, value int)
benchmark.go:16
↓ 8 callersMethodBallot
Ballot returns current ballot
paxos/paxos.go:71
↓ 8 callersFunctionNewBallot
NewBallot generates ballot number in format <n, zone, node>
ballot.go:15
↓ 8 callersMethodReset
Reset resets the quorum to empty
quorum.go:48
↓ 8 callersMethodSet
(value string)
log/log.go:35
↓ 7 callersMethodAddEdge
(from, to interface{})
lib/graph.go:49
↓ 7 callersFunctionErrorf
(format string, v ...interface{})
log/log.go:168
↓ 7 callersMethodHas
(e interface{})
lib/set.go:13
↓ 7 callersMethodIsRead
()
db.go:32
↓ 7 callersMethodLen
Len returns the number of items in the stack
lib/stack.go:19
↓ 7 callersFunctionNewPolicy
NewPolicy returns the policy by policy name from config
policy.go:16
↓ 7 callersFunctionNewSet
()
lib/set.go:5
↓ 7 callersMethodNext
Next generates the next ballot number given node id
ballot.go:50
↓ 7 callersMethodString
()
chain/msg.go:32
↓ 6 callersFunctionFatalf
(format string, v ...interface{})
log/log.go:177
↓ 6 callersMethodHandleRequest
HandleRequest handles request and start phase 1 or phase 2
paxos/paxos.go:86
↓ 6 callersMethodHas
(v interface{})
lib/graph.go:23
↓ 6 callersMethodIsLeader
IsLeader indecates if this node is current leader
paxos/paxos.go:61
↓ 6 callersFunctionNewID
NewID returns a new ID type given two int number of zone and node
id.go:14
↓ 6 callersMethodNode
Node returns Node ID component
id.go:41
↓ 6 callersMethodRESTGet
RESTGet issues a http call to node and return value and headers
client.go:157
↓ 6 callersMethodWait
Wait blocks for the limit
rate.go:26
↓ 6 callersMethodpaxos
(gid int)
paxos_group/replica.go:35
↓ 5 callersMethodAdd
(v interface{})
lib/graph.go:27
↓ 5 callersMethodHit
(id ID)
policy.go:12
↓ 5 callersFunctionInfo
(v ...interface{})
log/log.go:140
↓ 5 callersFunctionNewGraph
()
lib/graph.go:11
↓ 5 callersFunctionNewHTTPClient
NewHTTPClient creates a new Client from config
client.go:46
↓ 5 callersFunctionNewPaxos
NewPaxos creates new paxos instance
paxos/paxos.go:41
↓ 5 callersMethodPush
Push a value onto the top of the stack
lib/stack.go:44
↓ 5 callersMethodPut
(Key, Value)
db.go:57
↓ 5 callersMethodString
()
stat.go:39
↓ 5 callersMethodcopyDep
copyDep clones dependency list of instance
epaxos/instance.go:43
↓ 5 callersMethodrest
rest accesses server's REST API with url = http://ip:port/key if value == nil, it's a read
client.go:104
↓ 4 callersMethodClose
Close closes send channel and stops listener
transport.go:36
↓ 4 callersMethodContains
(e interface{})
lib/cset.go:33
↓ 4 callersMethodEqual
(a Command)
db.go:40
↓ 4 callersMethodGet
(Key)
client.go:21
↓ 4 callersMethodHandleP1a
HandleP1a handles P1a message
paxos/paxos.go:134
↓ 4 callersMethodHandleP1b
HandleP1b handles P1b message
paxos/paxos.go:183
↓ 4 callersMethodHandleP2a
HandleP2a handles P2a message
paxos/paxos.go:231
↓ 4 callersMethodHandleP2b
HandleP2b handles P2b message
paxos/paxos.go:268
↓ 4 callersMethodHandleP3
HandleP3 handles phase 3 commit message
paxos/paxos.go:311
↓ 4 callersMethodInsert
Insert inserts the value and its byte into ring as a node
lib/hash_ring.go:23
↓ 4 callersMethodLeader
Leader returns leader id of the current ballot
paxos/paxos.go:66
↓ 4 callersMethodListen
Listen waits for connections, non-blocking once listener starts
transport.go:33
↓ 4 callersMethodN
N returns first 32 bit of ballot
ballot.go:38
↓ 4 callersFunctionNewTransport
NewTransport creates new transport object with url
transport.go:40
↓ 4 callersMethodNext
Next returns the next value in the ring; nil if v does not exists
lib/hash_ring.go:69
↓ 4 callersMethodRemove
(v interface{})
lib/graph.go:35
↓ 4 callersMethodZoneMajority
ZoneMajority returns true if majority quorum satisfied in any zone
quorum.go:75
↓ 4 callersMethodexec
()
sdpaxos/replica.go:238
↓ 4 callersMethodinit
(key paxi.Key)
m2paxos/replica.go:30
↓ 4 callersMethodinit
(key paxi.Key)
kpaxos/replica.go:46
↓ 4 callersMethodinit
(key paxi.Key)
wpaxos/replica.go:36
↓ 4 callersMethodretry
(s int, b paxi.Ballot)
hpaxos/paxos.go:129
↓ 4 callersMethodupdate
updates local record for conflicts
epaxos/replica.go:82
↓ 3 callersMethodClone
()
lib/set.go:36
↓ 3 callersFunctionConnectToMaster
ConnectToMaster connects to master node and set global Config
util.go:69
↓ 3 callersFunctionDebug
(v ...interface{})
log/log.go:128
↓ 3 callersMethodDial
Dial connects to remote server non-blocking once connected
transport.go:30
↓ 3 callersMethodID
ID return node id as last 32 bits of ballot
ballot.go:43
↓ 3 callersFunctionInit
Init setup paxi package
init.go:11
↓ 3 callersFunctionNewBallotFromString
(b string)
ballot.go:19
↓ 3 callersFunctionNewCodec
NewCodec creates new codec object based on scheme, i.e. json and gob
codec.go:20
↓ 3 callersFunctionNewSocket
NewSocket return Socket interface instance given self ID, node list, transport and codec name
socket.go:52
↓ 3 callersMethodP1a
P1a starts phase 1 prepare
paxos/paxos.go:100
↓ 3 callersMethodRESTPut
RESTPut puts new value as http.request body and return previous value
client.go:162
↓ 3 callersMethodRead
(key int)
benchmark.go:15
↓ 3 callersMethodRecv
Recv waits for message from t.recv chan
transport.go:27
↓ 3 callersMethodRecv
Recv receives a message
socket.go:27
↓ 3 callersMethodRemove
(e interface{})
lib/set.go:18
next →1–100 of 575, ranked by callers