Functions — github.com/bdeggleston/kickboxer

hub / github.com/bdeggleston/kickboxer / functions

Functions1,093 in github.com/bdeggleston/kickboxer

⨍ Functions 1,093◇ Types & classes 186

↓ 382 callersMethodCheck

(params []interface {}, names []string)

src/consensus/algorithms_test.go:16

↓ 106 callersMethodGetId

()

src/node/node.go:35

↓ 84 callersMethodGet

(iid InstanceID)

src/consensus/instance_containers.go:168

↓ 82 callersMethodmakeInstance

creates a bare epaxos instance from the given instructions

src/consensus/manager.go:299

↓ 80 callersMethodContains

(instance *Instance)

src/consensus/instance_containers.go:224

↓ 77 callersMethodstatsInc

(stat string, delta int64)

src/consensus/manager.go:253

↓ 63 callersMethodAdd

(instance *Instance)

src/consensus/instance_containers.go:162

↓ 63 callersMethodCopy

returns a copy of the instance

src/consensus/instance.go:251

↓ 63 callersFunctionNewInstanceID

()

src/consensus/instance.go:48

↓ 56 callersFunctionNewInstanceIDSet

(ids []InstanceID)

src/consensus/instance_containers.go:11

↓ 38 callersFunctiongetBasicInstruction

()

src/consensus/testing_setup.go:98

↓ 38 callersMethodpreAcceptInstance

sets the given instance to preaccepted and updates, deps, seq, and commit timeout in the case of handling messages from leaders to replicas the messag

src/consensus/manager_preaccept.go:28

↓ 35 callersMethodWrite

(b []byte)

src/cluster/testing.go:268

↓ 34 callersFunctionmakeInstance

(nid node.NodeId, deps []InstanceID)

src/consensus/testing_setup.go:116

↓ 30 callersMethodcommitInstance

sets the given instance as committed in the case of handling messages from leaders to replicas the message instance should be passed in. It will eithe

src/consensus/manager_commit.go:33

↓ 30 callersMethodstatsTiming

(stat string, start time.Time)

src/consensus/manager.go:261

↓ 28 callersMethodRead

(b []byte)

src/cluster/testing.go:262

↓ 27 callersMethodBytes

()

src/types/uuid.go:54

↓ 26 callersMethodGetTimestamp

returns the highest level timestamp for this value

src/store/store.go:13

↓ 24 callersMethodGetToken

()

src/topology/node.go:21

↓ 24 callersMethodnewInstruction

(key string)

src/consensus/manager_dependencies_test.go:19

↓ 23 callersMethodPut

returns a connection to the pool

src/cluster/connection.go:96

↓ 23 callersFunctionsetupKVStore

returns a redis instance with defaults set

src/kvstore/testing.go:9

↓ 23 callersFunctionsetupRedis

returns a redis instance with defaults set

src/redis/testing.go:9

↓ 21 callersFunctionmakeDependencies

(size int)

src/consensus/testing_setup.go:108

↓ 20 callersMethodacceptInstance

sets the given instance as accepted in the case of handling messages from leaders to replicas the message instance should be passed in. It will either

src/consensus/manager_accept.go:34

↓ 19 callersMethodGetAndSetDeps

(keys []string, instance *Instance)

src/consensus/manager_depedencies.go:150

↓ 18 callersMethodReconcile

reconciles multiple values and returns instructions for correcting the values on inaccurate nodes

src/store/store.go:35

↓ 18 callersMethodget

(key string)

src/consensus/manager_depedencies.go:64

↓ 17 callersMethodgetStatus

()

src/consensus/instance.go:181

↓ 16 callersMethodgetBallot

()

src/consensus/instance.go:187

↓ 15 callersMethodGetLocalID

()

src/consensus/manager.go:225

↓ 15 callersFunctionNewString

single value constructor

src/kvstore/val_string.go:19

↓ 15 callersFunctionNewString

single value constructor

src/redis/val_string.go:19

↓ 15 callersMethodgetExecutionOrder

topologically sorts instance dependencies, grouped by strongly connected components

src/consensus/manager_execute.go:51

↓ 15 callersFunctionnewDependencies

()

src/consensus/manager_depedencies.go:109

↓ 14 callersMethodcheckMessage

(c *gocheck.C, src message.Message)

src/cluster/message_test.go:24

↓ 13 callersMethodAddNode

adds a node to the ring, returns true if the node was added, false if not

src/topology/ring.go:107

↓ 13 callersMethodContains

(id InstanceID)

src/consensus/instance_containers.go:118

↓ 13 callersMethodExecuteInstruction

----------- queries ----------- executes a query instruction against the node's store

src/store/store.go:31

↓ 13 callersFunctionNewTombstone

single value constructor

src/kvstore/val_tombstone.go:17

↓ 13 callersFunctionNewTombstone

single value constructor

src/redis/val_tombstone.go:17

↓ 13 callersMethodSize

()

src/consensus/instance_containers.go:123

↓ 13 callersMethodStart

()

src/node/node.go:40

↓ 12 callersFunctionNewCluster

( // the local store store store.Store, // the address the peer server will be listening on addr string,

src/cluster/cluster.go:75

↓ 12 callersMethodPersist

persists the manager's state to disk

src/consensus/manager.go:248

↓ 12 callersMethodmakeInstruction

(val int)

src/consensus/integration_test.go:25

↓ 11 callersMethodContainsID

(id InstanceID)

src/consensus/instance_containers.go:217

↓ 11 callersMethodEqual

(o InstanceIDSet)

src/consensus/instance_containers.go:24

↓ 11 callersMethodGetNode

gets a node by it's node id

src/topology/ring.go:73

↓ 11 callersMethodInc

(stat string, value int64, rate float32)

src/consensus/testing_mocks.go:238

↓ 10 callersMethodDeserializeLimited

(buf *bufio.Reader)

src/consensus/instance.go:480

↓ 10 callersMethodGetValueType

()

src/store/store.go:14

↓ 10 callersFunctionNewBoolean

(val bool, timestamp time.Time)

src/kvstore/val_bool.go:16

↓ 10 callersFunctionNewBoolean

(val bool, timestamp time.Time)

src/redis/val_bool.go:16

↓ 10 callersMethodReadBuffer

(buf *bufio.Reader)

src/types/uuid.go:85

↓ 10 callersMethodSetRawKey

sets the contents of the given key

src/store/store.go:64

↓ 10 callersMethodWriteBuffer

(buf *bufio.Writer)

src/types/uuid.go:76

↓ 10 callersMethodaddListener

()

src/consensus/instance.go:242

↓ 10 callersMethodgetOrSetInstance

returns the local instance with the same id as the given instance, or sets the given instance locally. Does not handle any of the committed, inprogres

src/consensus/manager.go:274

↓ 9 callersMethodClose

()

src/cluster/testing.go:187

↓ 9 callersMethodExecuteWrite

(cmd string, key string, args []string, timestamp time.Time)

src/redis/store.go:85

↓ 9 callersMethodGetDatacenterId

()

src/topology/node.go:22

↓ 9 callersMethodGetNodeId

info getters

src/cluster/cluster.go:134

↓ 9 callersFunctionNewConnectionPool

creates a connection pool for the given address and max size if the max size is 0, 10 is used, if the given timeout is 0 or less, 10 seconds is used

src/cluster/connection.go:83

↓ 9 callersMethodNumBytesLimited

()

src/consensus/instance.go:438

↓ 9 callersMethodSendMessage

(message.Message)

src/node/node.go:38

↓ 9 callersMethodSerializeLimited

(buf *bufio.Writer)

src/consensus/instance.go:519

↓ 9 callersMethodaddNode

adds a node to the cluster, if it's not already part of the cluster, and starting it if the cluster has been started

src/cluster/cluster.go:143

↓ 9 callersMethodcompareNodeToConnectionResponse

(c *gocheck.C, cluster *Cluster, n topology.Node, addr string, response *ConnectionAcceptedResponse)

src/cluster/cluster_test.go:342

↓ 9 callersMethodexecuteInstance

applies an instance to the store first it will resolve all dependencies, then wait for them to commit/reject, or force them to do one or the other. Th

src/consensus/manager_execute.go:410

↓ 9 callersMethodgetInstruction

(val int)

src/consensus/testing_setup.go:132

↓ 9 callersMethodpatchCommit

(e error)

src/consensus/manager_prepare_test.go:59

↓ 9 callersFunctiontarjanConnect

implementation of tarjan's strongly connected components algorithm give it a directed graph, and it will return a list of instance id sets, grouped in

src/consensus/algorithms.go:7

↓ 8 callersMethodEqual

instruction equality test

src/store/instruction.go:34

↓ 8 callersMethodGetLocalNodesForToken

returns local dc replicas for the given token

src/topology/topology.go:138

↓ 8 callersMethodGetNodesForToken

returns the nodes that replicate the given token includes the node that owns the token, and it's replicas to simplify the binary search logic, a toke

src/topology/ring.go:140

↓ 8 callersMethodIsZero

()

src/types/b16.go:50

↓ 8 callersFunctionNewRemoteNodeInfo

creates a new remote node from info provided from the node

src/cluster/node.go:128

↓ 8 callersMethodReportAcknowledged

when an instance is accepted or committed, it's dependencies can be considered acknowledged by the cluster. The instance itself is not, because we wan

src/consensus/manager_depedencies.go:208

↓ 8 callersMethodget

Get the value of key. If the key does not exist the special value nil is returned. An error is returned if the value stored at key is not a string, be

src/redis/cmd_get.go:18

↓ 8 callersFunctiongetTimeoutEvent

returns a channel that will wake up after the given duration

src/consensus/manager.go:151

↓ 8 callersMethodmakeIds

(num int)

src/consensus/algorithms_test.go:71

↓ 8 callersFunctionmakeRing

makes a ring of the given size, with the tokens evenly spaced

src/cluster/testing.go:64

↓ 8 callersFunctionnewMockNode

(id node.NodeId, dcid DatacenterID, token partitioner.Token, name string)

src/topology/mocks.go:26

↓ 8 callersMethodpreAcceptPhase

runs the full preaccept phase for the given instance, returning a bool indicating if an accept phase is required or not

src/consensus/manager_preaccept.go:195

↓ 8 callersMethodpreparePhase

TODO: rename to prepareInstance runs explicit prepare phase on instances where a command leader failure is suspected during execution,

src/consensus/manager_prepare.go:527

↓ 8 callersFunctionsetupEmptyManager

()

src/consensus/testing_setup.go:54

↓ 7 callersMethodAllLocalNodes

()

src/topology/topology.go:83

↓ 7 callersMethodAllNodes

returns a copy of the token ring

src/topology/ring.go:123

↓ 7 callersMethodEqual

compares 2 Values

src/store/store.go:20

↓ 7 callersMethodGetRing

(dcId DatacenterID)

src/topology/topology.go:89

↓ 7 callersMethodSerializeValue

----------- data import / export ----------- serializes a value

src/store/store.go:55

↓ 7 callersMethodTiming

(stat string, delta int64, rate float32)

src/consensus/testing_mocks.go:266

↓ 7 callersMethodapplyInstance

executes an instance against the store

src/consensus/manager_execute.go:204

↓ 7 callersFunctionassertEqualValue

(t *testing.T, name string, v1 store.Value, v2 store.Value)

src/kvstore/testing.go:13

↓ 7 callersFunctionassertEqualValue

(t *testing.T, name string, v1 store.Value, v2 store.Value)

src/redis/testing.go:13

↓ 7 callersMethoddiscoverPeers

talks to the seed addresses and any additional remote nodes we're already aware of to discover new node

src/cluster/cluster.go:172

↓ 7 callersMethodgetInstanceDeps

(instance *Instance)

src/consensus/manager.go:294

↓ 7 callersFunctionnewBiConn

(numIn, numOut int)

src/cluster/testing.go:246

next →1–100 of 1,093, ranked by callers