Functions — github.com/ailidani/paxi

CodeHub MCPcopy Create free account

hub / github.com/ailidani/paxi / functions

Functions575 in github.com/ailidani/paxi

⨍ Functions 575◇ Types & classes 177

↓ 1 callersFunctionNewStack

NewStack creates a new Stack

lib/stack.go:14

↓ 1 callersMethodNext

Next generates the next block given some data

blockchain/block.go:32

↓ 1 callersMethodPartition

↓ 1 callersMethodQuorumGet

QuorumGet concurrently read values from majority nodes

↓ 1 callersMethodReadFile

ReadFile reads csv log file and create operations in history

↓ 1 callersMethodRemoveEdge

(from, to interface{})

lib/graph.go:63

↓ 1 callersFunctionRetry

Retry function f sleep time between attempts

↓ 1 callersMethodRetry

↓ 1 callersFunctionRunClient

(t *testing.T, port string)

http_test.go:40

↓ 1 callersFunctionRunServer

(t *testing.T, port string)

http_test.go:13

↓ 1 callersFunctionSchedule

Schedule repeatedly call function with intervals

↓ 1 callersMethodScheme

transport.go:95

↓ 1 callersFunctionSetup

Setup setup log format and output file

↓ 1 callersMethodSize

Size returns current ack size

↓ 1 callersMethodSlice

↓ 1 callersMethodString

String is implemented to print the config

↓ 1 callersMethodString

vpaxos/msg.go:74

↓ 1 callersMethodString

wankeeper/msg.go:68

↓ 1 callersMethodTo

To returns all vertices that can reach to v

lib/graph.go:81

↓ 1 callersFunctionWarning

(v ...interface{})

↓ 1 callersMethodbytes

blockchain/block.go:65

↓ 1 callersMethodclear

↓ 1 callersMethodconcurrent

operation.go:17

↓ 1 callersMethodexecute

epaxos/replica.go:356

↓ 1 callersMethodforward

(r *paxi.Request)

wankeeper/leader.go:38

↓ 1 callersMethodget

wankeeper/tokens.go:33

↓ 1 callersMethodhandle

handle receives messages from message channel and calls handle function using refection

↓ 1 callersMethodhandleCommit

wankeeper/leader.go:147

↓ 1 callersMethodhandleMove

vpaxos/master.go:53

↓ 1 callersMethodhandleRequest

(m paxi.Request)

vpaxos/replica.go:63

↓ 1 callersMethodhandleRequest

(m paxi.Request)

vpaxos/paxos.go:48

↓ 1 callersMethodhash

dynamo/replica.go:36

↓ 1 callersMethodhttp

serve serves the http REST API request from clients

↓ 1 callersFunctionindex

static paxos groups

paxos_group/replica.go:31

↓ 1 callersFunctionindex

TODO replace this with a consistent hash ring

kpaxos/replica.go:32

↓ 1 callersMethodlead

(r *paxi.Request)

wankeeper/master.go:24

↓ 1 callersMethodmatch

match finds the first matching write operation to the given read operation

↓ 1 callersMethodmerge

matched write inherits edges read

↓ 1 callersMethodmerge

merge the seq and dep for instance

epaxos/instance.go:29

↓ 1 callersMethodmonitor

(k paxi.Key, id paxi.ID)

vpaxos/replica.go:43

↓ 1 callersFunctionnewKPaxos

(key paxi.Key, node paxi.Node)

m2paxos/kpaxos.go:23

↓ 1 callersFunctionnewKPaxos

(key paxi.Key, node paxi.Node)

wpaxos/kpaxos.go:29

↓ 1 callersFunctionnewLeader

wankeeper/leader.go:18

↓ 1 callersFunctionnewMaster

vpaxos/master.go:16

↓ 1 callersFunctionnewMaster

wankeeper/master.go:13

↓ 1 callersFunctionnewPaxos

(node paxi.Node)

vpaxos/paxos.go:30

↓ 1 callersFunctionnewTokens

wankeeper/tokens.go:13

↓ 1 callersMethodreadAny

paxos/client.go:132

↓ 1 callersMethodreadInProgress

(m paxi.Request)

paxos/replica.go:68

↓ 1 callersMethodreadLeader

paxos/client.go:54

↓ 1 callersMethodreadQuorum

paxos/client.go:69

↓ 1 callersMethodrecv

recv receives messages from socket and pass to message channel

↓ 1 callersMethodreset

↓ 1 callersMethodsearch

lib/hash_ring.go:53

↓ 1 callersMethodstrongConnect

strongConnect runs Tarjan's algorithm recursivley and outputs a grouping of strongly connected vertices.

lib/graph_scc.go:35

↓ 1 callersMethodupdate

(scb map[int]CommandBallot)

paxos/paxos.go:164

↓ 1 callersFunctionusage

↓ 1 callersFunctionworker

(tasks <-chan int)

rate_test.go:12

ADD increase ack size by one

Add puts an operation in History

MethodBFSReverse

(v interface{})

lib/graph.go:135

FunctionBenchmarkCodecGob

codec_test.go:45

FunctionBenchmarkCodecJSON

codec_test.go:62

MethodBroadcast

(m interface{})

MethodBroadcast

Broadcast overrides Socket interface in Node

paxos_group/replica.go:81

MethodBroadcast

Broadcast overrides Socket interface in Node

m2paxos/kpaxos.go:45

MethodBroadcast

Broadcast overrides Socket interface in Node

wpaxos/kpaxos.go:51

transport.go:90

FunctionConflictBatch

ConflictBatch checks if two batchs of commands are conflict

MethodConsensus

Consensus collects /history/key from every node and compare their values

(key interface{})

Crash stops the node for t seconds then recover node crash forever if t < 0

DFS returns depth first search vertices from a given source

lib/graph.go:111

(m interface{})

(m interface{})

transport.go:99

transport.go:176

transport.go:249

(m interface{})

(m interface{})

Execute is the state-transition function returns current state value if state unchanged or previous state value

state_machine.go:7

* // Execute implements StateMachine interface func (d *database) Execute(c interface{}) interface{} { cmd, ok := c.(Command) if !ok { log.Error("

delays every message send to ID for d ms and last for t seconds

(id ID, p float64, t int)

* func (n *node) Forward(id ID, m Request) { key := m.Command.Key url := config.HTTPAddrs[id] + "/" + strconv.Itoa(int(key)) log.Debugf("Node %v f

Get gets the current value and version of given key

Get gets value of given key (use REST) Default implementation of Client interface

Get implements paxi.Client interface there are three reading modes: (1) read as normal command (2) read from leader with current ballot number (3) rea

paxos/client.go:27

(key interface{}, version interface{})

Get returns random element from set

(key interface{})

Get returns the node value that given k belongs to

lib/hash_ring.go:63

← previous next →201–300 of 575, ranked by callers