Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ailidani/paxi
/ functions
Functions
575 in github.com/ailidani/paxi
⨍
Functions
575
◇
Types & classes
177
↓ 3 callers
Method
Send
Send sends message into t.send chan
transport.go:24
↓ 3 callers
Method
Send
(to ID, m interface{})
socket.go:69
↓ 3 callers
Method
String
()
sdpaxos/msg.go:36
↓ 3 callers
Method
String
()
paxos/msg.go:77
↓ 3 callers
Method
contains
(key paxi.Key)
wankeeper/tokens.go:20
↓ 3 callers
Method
happenBefore
(b operation)
operation.go:13
↓ 3 callers
Method
init
(key paxi.Key)
wankeeper/replica.go:101
↓ 3 callers
Function
newChecker
()
checker.go:15
↓ 3 callers
Function
run
(transport string, t *testing.T)
socket_test.go:21
↓ 3 callers
Method
set
(key paxi.Key, id paxi.ID)
wankeeper/tokens.go:37
↓ 3 callers
Function
uniformTest
(p Policy, t *testing.T)
policy_test.go:8
↓ 3 callers
Method
updateCommit
(id paxi.ID)
epaxos/replica.go:102
↓ 2 callers
Method
AddOperation
AddOperation adds the operation
history.go:44
↓ 2 callers
Method
BFS
BFS returns breadth first search vertices from a given source
lib/graph.go:86
↓ 2 callers
Method
Crash
drop message by chance p for t seconds
socket.go:35
↓ 2 callers
Method
Init
()
benchmark.go:14
↓ 2 callers
Method
Linearizable
Linearizable concurrently checks if each partition of the history is linearizable and returns the total number of anomaly reads
history.go:55
↓ 2 callers
Function
MakeDefaultConfig
MakeDefaultConfig returns Config object with few default values only used by init() and master
config.go:56
↓ 2 callers
Function
NewBenchmark
NewBenchmark returns new Benchmark object given implementation of DB interface
benchmark.go:89
↓ 2 callers
Function
NewClient
(id paxi.ID)
paxos/client.go:16
↓ 2 callers
Function
NewClient
()
chain/client.go:15
↓ 2 callers
Function
NewHistory
NewHistory creates a History map
history.go:24
↓ 2 callers
Function
NewLimiter
NewLimiter creates a new rate limiter, where rate is operations per second
rate.go:18
↓ 2 callers
Method
P1a
(r paxi.Request)
hpaxos/paxos.go:66
↓ 2 callers
Method
P2a
P2a starts phase 2 accept
paxos/paxos.go:111
↓ 2 callers
Method
P2a
(s int)
hpaxos/paxos.go:83
↓ 2 callers
Method
Peek
Peek views the top item on the stack
lib/stack.go:24
↓ 2 callers
Method
Pop
Pop the top item of the stack and return it
lib/stack.go:32
↓ 2 callers
Method
Run
Run starts the main logic of benchmarking
benchmark.go:135
↓ 2 callers
Function
Simulation
Simulation enable go channel transportation to simulate distributed environment
config.go:50
↓ 2 callers
Function
Statistic
Statistic function creates Stat object from raw latency data
stat.go:44
↓ 2 callers
Method
Stop
()
benchmark.go:17
↓ 2 callers
Method
String
()
m2paxos/msg.go:50
↓ 2 callers
Method
Vertices
()
lib/graph.go:71
↓ 2 callers
Function
Warningf
(format string, v ...interface{})
log/log.go:158
↓ 2 callers
Method
WriteFile
WriteFile writes stat to new file in path
stat.go:25
↓ 2 callers
Method
add
(o *operation)
checker.go:21
↓ 2 callers
Method
attributes
attibutes generates the sequence and dependency attributes for command
epaxos/replica.go:60
↓ 2 callers
Method
collect
(latencies <-chan time.Duration)
benchmark.go:277
↓ 2 callers
Method
exec
()
paxos/paxos.go:343
↓ 2 callers
Method
exec
()
vpaxos/paxos.go:149
↓ 2 callers
Method
exec
()
hpaxos/paxos.go:273
↓ 2 callers
Method
exec
(key paxi.Key)
wankeeper/replica.go:177
↓ 2 callers
Method
forward
()
paxos/paxos.go:369
↓ 2 callers
Method
getBuffer
()
log/log.go:70
↓ 2 callers
Method
json
(id ID, key Key, value Value)
client.go:166
↓ 2 callers
Method
lead
(requests ...*paxi.Request)
wankeeper/leader.go:42
↓ 2 callers
Method
mine
()
blockchain/block.go:43
↓ 2 callers
Method
next
generates key based on distribution
benchmark.go:202
↓ 2 callers
Method
put
(k Key, v Value)
db.go:123
↓ 2 callers
Method
query
(k paxi.Key, id paxi.ID)
vpaxos/master.go:27
↓ 2 callers
Function
replica
(id paxi.ID)
server/server.go:31
↓ 2 callers
Method
replicas
replicas returns the next 2 neighbors of current node as its replicas
dynamo/replica.go:43
↓ 2 callers
Function
run
(cmd string, args []string)
cmd/cmd.go:35
↓ 2 callers
Method
visit
(v interface{}, colors map[interface{}]color)
lib/graph.go:180
↓ 2 callers
Method
worker
(keys <-chan int, result chan<- time.Duration)
benchmark.go:246
↓ 1 callers
Method
All
()
quorum.go:55
↓ 1 callers
Method
AllZones
AllZones returns true if there is at one ack from each zone
quorum.go:70
↓ 1 callers
Function
Conflict
Conflict checks if two commands are conflicting as reorder them will end in different states
db.go:165
↓ 1 callers
Method
Consensus
(Key)
client.go:27
↓ 1 callers
Method
Cycle
Cycle returns the first cycle with vertices
lib/graph.go:212
↓ 1 callers
Method
Cyclic
Cyclic returns true if the graph contains a cycle
lib/graph.go:195
↓ 1 callers
Function
DefaultBConfig
DefaultBConfig returns a default benchmark config
benchmark.go:51
↓ 1 callers
Method
Drop
Fault injection
socket.go:32
↓ 1 callers
Method
Drop
Drop drops every message send for t seconds
client.go:344
↓ 1 callers
Method
Empty
()
db.go:25
↓ 1 callers
Method
Empty
()
lib/stack.go:50
↓ 1 callers
Method
FGridQ1
FGridQ1 is flexible grid quorum for phase 1
quorum.go:100
↓ 1 callers
Method
FGridQ2
FGridQ2 is flexible grid quorum for phase 2
quorum.go:111
↓ 1 callers
Method
FastQuorum
FastQuorum from fast paxos
quorum.go:65
↓ 1 callers
Method
From
From returns all vertices in graph that can be reached directly from v
lib/graph.go:76
↓ 1 callers
Function
Genesis
Genesis gets the genesis block which has byte[1024] data byte[256] prev hash
blockchain/block.go:78
↓ 1 callers
Method
GetURL
(id ID, key Key)
client.go:83
↓ 1 callers
Method
GridColumn
GridColumn == all nodes in one zone
quorum.go:90
↓ 1 callers
Method
GridRow
GridRow == AllZones
quorum.go:85
↓ 1 callers
Method
HandleRequest
(r paxi.Request)
hpaxos/paxos.go:62
↓ 1 callers
Method
History
(Key)
db.go:55
↓ 1 callers
Method
ID
()
node.go:49
↓ 1 callers
Method
IsWrite
()
db.go:36
↓ 1 callers
Method
Load
Load will create all K keys to DB
benchmark.go:104
↓ 1 callers
Method
Load
Load loads configuration from config file in JSON format
config.go:97
↓ 1 callers
Method
MultiGet
MultiGet concurrently read values from n nodes
client.go:207
↓ 1 callers
Method
MulticastQuorum
MulticastQuorum sends msg to random number of nodes
socket.go:21
↓ 1 callers
Method
N
N returns total number of nodes
config.go:77
↓ 1 callers
Function
NewDatabase
NewDatabase returns database that impelements Database interface
db.go:70
↓ 1 callers
Function
NewMiner
NewMiner creates new Miner as paxi node
blockchain/miner.go:23
↓ 1 callers
Function
NewPaxos
NewPaxos creates new paxos instance
hpaxos/paxos.go:37
↓ 1 callers
Function
NewReplica
(id paxi.ID)
paxos_group/replica.go:20
↓ 1 callers
Function
NewReplica
NewReplica initialize replica and register all message types
epaxos/replica.go:30
↓ 1 callers
Function
NewReplica
(id paxi.ID)
sdpaxos/replica.go:33
↓ 1 callers
Function
NewReplica
NewReplica generates new Paxos replica
paxos/replica.go:29
↓ 1 callers
Function
NewReplica
NewReplica create new Replica instance
m2paxos/replica.go:15
↓ 1 callers
Function
NewReplica
(id paxi.ID)
chain/replica.go:30
↓ 1 callers
Function
NewReplica
(id paxi.ID)
vpaxos/replica.go:24
↓ 1 callers
Function
NewReplica
NewReplica generates new Paxos replica
hpaxos/replica.go:15
↓ 1 callers
Function
NewReplica
(id paxi.ID)
dynamo/replica.go:18
↓ 1 callers
Function
NewReplica
NewReplica creates new replica object for wankeeper
wankeeper/replica.go:34
↓ 1 callers
Function
NewReplica
(id paxi.ID)
kpaxos/replica.go:17
↓ 1 callers
Function
NewReplica
NewReplica create new Replica instance
wpaxos/replica.go:20
↓ 1 callers
Function
NewReplica
NewReplica generates ABD replica
abd/replica.go:37
← previous
next →
101–200 of 575, ranked by callers