Functions — github.com/bdeggleston/kickboxer

hub / github.com/bdeggleston/kickboxer / functions

Functions1,093 in github.com/bdeggleston/kickboxer

⨍ Functions 1,093◇ Types & classes 186

↓ 1 callersMethodSize

()

src/topology/datacenter.go:52

↓ 1 callersMethodSize

()

src/topology/topology.go:61

↓ 1 callersMethodStart

()

src/cluster/node.go:137

↓ 1 callersMethodString

()

src/types/uuid.go:62

↓ 1 callersMethodString

()

src/consensus/errors.go:41

↓ 1 callersMethodTearDownSuite

(c *gocheck.C)

src/consensus/manager_execute_test.go:34

↓ 1 callersMethodWrite

this implements the io.Writer interface

src/cluster/connection.go:39

↓ 1 callersFunctionWriteValue

(buf io.Writer, v store.Value)

src/kvstore/values.go:19

↓ 1 callersFunctionWriteValue

(buf io.Writer, v store.Value)

src/redis/values.go:19

↓ 1 callersMethod_add

(cls, data)

pydebug/debug.py:61

↓ 1 callersMethod_add_in_dep

(self, iid)

pydebug/debug.py:57

↓ 1 callersMethodaccept

(inst *Instance, incrementBallot bool)

src/consensus/instance.go:329

↓ 1 callersMethodacceptConnections

()

src/cluster/server.go:133

↓ 1 callersFunctionaddClusterDC

----------------- datacenter setup / mocks -----------------

src/cluster/testing.go:131

↓ 1 callersFunctionbaseValueEqual

(v0, v1 store.Value)

src/cluster/store_mock.go:160

↓ 1 callersMethodbroadcast

()

src/consensus/manager.go:142

↓ 1 callersMethodcheckConsistency

checks that all of the queries were executed in the same order, per key

src/consensus/consensus_test.go:172

↓ 1 callersFunctioncheck_consistency

(history=5)

pydebug/debug.py:133

↓ 1 callersFunctioncheck_strong_connections

()

pydebug/debug.py:151

↓ 1 callersMethoddel

Removes the specified keys. A key is ignored if it does not exist. Return value: Integer reply: The number of keys that were removed. internally, eac

src/kvstore/cmd_del.go:25

↓ 1 callersMethoddel

Removes the specified keys. A key is ignored if it does not exist. Return value: Integer reply: The number of keys that were removed. internally, eac

src/redis/cmd_del.go:25

↓ 1 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/kvstore/cmd_get.go:18

↓ 1 callersMethodgetChildDeps

(instance *Instance)

src/consensus/manager_depedencies.go:128

↓ 1 callersMethodgetCommitTimeout

()

src/consensus/instance.go:169

↓ 1 callersMethodgetCommitTimeoutEvent

()

src/consensus/instance.go:175

↓ 1 callersMethodgetDependencies

()

src/consensus/instance.go:201

↓ 1 callersFunctiongetHighValue

----------- reconcile helpers ----------- returns the value with the highest timestamp

src/kvstore/values.go:62

↓ 1 callersFunctiongetHighValue

----------- reconcile helpers ----------- returns the value with the highest timestamp

src/redis/values.go:62

↓ 1 callersMethodincrementBallot

()

src/consensus/instance.go:208

↓ 1 callersFunctionmakeAcceptCommitTimeout

()

src/consensus/manager_accept.go:11

↓ 1 callersFunctionmakePreAcceptCommitTimeout

()

src/consensus/manager_preaccept.go:11

↓ 1 callersMethodmessageHandler

(mn *mockNode, msg message.Message)

src/consensus/consensus_test.go:160

↓ 1 callersFunctionmockStoreDefaultInterferingKeys

(c *mockStore, instruction store.Instruction)

src/consensus/testing_mocks.go:309

↓ 1 callersFunctionmockStoreDefaultIsReadOnly

(s *mockStore, instruction store.Instruction)

src/consensus/testing_mocks.go:317

↓ 1 callersFunctionmockStoreDefaultIsWriteOnly

(s *mockStore, instruction store.Instruction)

src/consensus/testing_mocks.go:325

↓ 1 callersFunctionnewDependencyManager

(manager *Manager)

src/consensus/manager_depedencies.go:346

↓ 1 callersFunctionnewEvent

()

src/consensus/manager.go:123

↓ 1 callersFunctionnewIntVal

(val int, ts time.Time)

src/consensus/testing_mocks.go:30

↓ 1 callersFunctionnewMockNode

creates a simple node don't use for tests that depend on complex topology

src/consensus/testing_mocks.go:76

↓ 1 callersFunctionnumMappedNodes

returns the total number of nodes in a node map

src/cluster/cluster.go:484

↓ 1 callersMethodpreaccept

-------------- state changes --------------

src/consensus/instance.go:300

↓ 1 callersMethodquorumSize

()

src/consensus/testing_setup.go:161

↓ 1 callersFunctionreadLocalOnly

returns true if the consistency level only requires talking to local nodes

src/cluster/cluster.go:494

↓ 1 callersFunctionreconcileString

(key string, highValue *String, values []store.Value)

src/kvstore/val_string.go:74

↓ 1 callersFunctionreconcileString

(key string, highValue *String, values map[string]store.Value)

src/redis/val_string.go:74

↓ 1 callersFunctionreconcileTombstone

(key string, highValue *Tombstone, values []store.Value)

src/kvstore/val_tombstone.go:55

↓ 1 callersFunctionreconcileTombstone

(key string, highValue *Tombstone, values map[string]store.Value)

src/redis/val_tombstone.go:55

↓ 1 callersMethodrefreshRing

refreshes the token ring after changes this method does no locking, the caller needs to do that

src/topology/ring.go:87

↓ 1 callersMethodsetNoop

()

src/consensus/instance.go:392

↓ 1 callersFunctionsetupDC

(numDCs int, numNodes int)

src/topology/datacenter_test.go:16

↓ 1 callersFunctionsetupReplicaSet

returns a set of mock nodes of the given size

src/consensus/testing_setup.go:72

↓ 1 callersFunctionunresponsiveListener

----------------- connection mocks -----------------

src/cluster/testing.go:178

↓ 1 callersMethodvalidateDel

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

src/kvstore/cmd_del.go:8

↓ 1 callersMethodvalidateDel

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

src/redis/cmd_del.go:8

↓ 1 callersMethodvalidateGet

(key string, args []string)

src/kvstore/cmd_get.go:8

↓ 1 callersMethodvalidateGet

(key string, args []string)

src/redis/cmd_get.go:8

↓ 1 callersMethodvalidateSet

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

src/kvstore/cmd_set.go:9

↓ 1 callersMethodvalidateSet

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

src/redis/cmd_set.go:9

MethodAddDependency

(instance *Instance)

src/consensus/manager_depedencies.go:334

MethodAddNode

(n Node)

src/topology/topology.go:46

MethodAllNodes

()

src/topology/datacenter.go:60

MethodApplyQuery

executes a query against the local store

src/clusterproto/clusterproto.go:43

FunctionAssertEqual

(t *testing.T, name string, v1 interface {}, v2 interface{})

src/testing_helpers/helpers.go:8

FunctionAssertSliceEqual

(t *testing.T, name string, v1 []byte, v2 []byte)

src/testing_helpers/helpers.go:18

FunctionAssertStringArrayEqual

(t *testing.T, name string, v1 []string, v2 []string)

src/testing_helpers/helpers.go:28

FunctionBenchmarkQueries

(b *testing.B)

src/consensus/consensus_test.go:549

MethodBenchmarkTarjan

(c *gocheck.C)

src/consensus/algorithms_test.go:289

MethodCheck

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

src/consensus/testing_checks.go:11

MethodCheck

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

src/consensus/testing_checks.go:41

MethodClear

remove all keys from i

src/consensus/instance_containers.go:104

MethodCopy

()

src/consensus/instance_containers.go:110

MethodDec

(stat string, value int64, rate float32)

src/consensus/testing_mocks.go:245

MethodDeserialize

(buf *bufio.Reader)

src/kvstore/val_string.go:59

MethodDeserialize

(buf *bufio.Reader)

src/kvstore/val_tombstone.go:46

MethodDeserialize

(buf *bufio.Reader)

src/kvstore/val_bool.go:58

MethodDeserialize

(buf *bufio.Reader)

src/redis/val_string.go:59

MethodDeserialize

(buf *bufio.Reader)

src/redis/val_tombstone.go:46

MethodDeserialize

(buf *bufio.Reader)

src/redis/val_bool.go:58

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:55

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:123

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:181

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:229

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:261

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:281

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:313

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:363

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:401

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:438

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:480

MethodDeserialize

(buf *bufio.Reader)

src/consensus/message.go:521

MethodDeserialize

(_ *bufio.Reader)

src/consensus/testing_mocks.go:45

MethodDeserialize

(buf *bufio.Reader)

src/cluster/message_query.go:41

MethodDeserialize

(buf *bufio.Reader)

src/cluster/message_query.go:90

MethodDeserialize

(buf *bufio.Reader)

src/cluster/message_query.go:122

MethodDeserialize

(buf *bufio.Reader)

src/cluster/message_connect.go:146

MethodDeserialize

(buf *bufio.Reader)

src/cluster/message_connect.go:201

MethodDeserialize

(buf *bufio.Reader)

src/cluster/message_connect.go:228

MethodDeserialize

(buf *bufio.Reader)

src/cluster/message_connect.go:255

MethodDeserialize

(*bufio.Reader)

src/cluster/message_stream.go:27

MethodDeserialize

(*bufio.Reader)

src/cluster/message_stream.go:36

← previous next →301–400 of 1,093, ranked by callers