Functions — github.com/bdeggleston/kickboxer

hub / github.com/bdeggleston/kickboxer / functions

Functions1,093 in github.com/bdeggleston/kickboxer

⨍ Functions 1,093◇ Types & classes 186

↓ 2 callersMethodExecuteRead

(cmd string, key string, args []string)

src/redis/store.go:68

↓ 2 callersMethodGetPeerAddr

()

src/cluster/cluster.go:138

↓ 2 callersMethodGetStatus

()

src/topology/node.go:23

↓ 2 callersMethodGetToken

(key string)

src/cluster/testing.go:155

↓ 2 callersMethodHandleMessage

(msg message.Message)

src/consensus/manager.go:229

↓ 2 callersMethodInstances

()

src/consensus/instance_containers.go:240

↓ 2 callersMethodIsStarted

()

src/node/node.go:42

↓ 2 callersFunctionNewMessageEncodingError

(reason string)

src/cluster/message.go:15

↓ 2 callersMethodNumBytes

()

src/consensus/message.go:331

↓ 2 callersMethodNumBytes

()

src/consensus/message.go:414

↓ 2 callersMethodNumBytesLimitedUnsafe

-------------- serialization --------------

src/consensus/instance.go:400

↓ 2 callersFunctionReadFieldBytes

read field bytes

src/serializer/serializer.go:50

↓ 2 callersMethodSendMessage

(m message.Message)

src/cluster/node.go:197

↓ 2 callersMethodSerialize

(buf *bufio.Writer)

src/store/instruction.go:74

↓ 2 callersMethodSerializeLimitedUnsafe

(buf *bufio.Writer)

src/consensus/instance.go:444

↓ 2 callersMethodSetUpSuite

(c *gocheck.C)

src/consensus/manager_prepare_test.go:240

↓ 2 callersMethodTokenLocallyReplicated

returns true if the given token is replicated by the local node

src/topology/topology.go:150

↓ 2 callersMethodUnion

(o InstanceIDSet)

src/consensus/instance_containers.go:36

↓ 2 callersFunctionWriteFieldBytes

writes the field length, then the field to the writer

src/serializer/serializer.go:16

↓ 2 callersMethodall

()

src/consensus/manager_depedencies.go:82

↓ 2 callersMethodanalyzePrepareResponses

analyzes the responses to a prepare request, and returns an instance the prepare phase should use to determine how to proceed

src/consensus/manager_prepare.go:14

↓ 2 callersMethodcheckLocalKeyEligibility

(key string)

src/consensus/manager.go:204

↓ 2 callersMethodgetConnection

returns a connection with a completed handshake

src/cluster/node.go:158

↓ 2 callersMethodgetNode

(nid node.NodeId)

src/topology/ring.go:63

↓ 2 callersMethodgetSuccessors

()

src/consensus/instance.go:193

↓ 2 callersFunctionnewDependencyMap

()

src/consensus/manager_depedencies.go:60

↓ 2 callersMethodpreAcceptInstanceUnsafe

(inst *Instance, incrementBallot bool)

src/consensus/manager_preaccept.go:16

↓ 2 callersMethodprepareShouldProceed

TODO: test alone determines a prepare phase should proceed for the given instance will block if waiting on a timeout / notification

src/consensus/manager_prepare.go:440

↓ 2 callersMethodreconcileRead

reconciles values and issues repair statements to other nodes

src/cluster/cluster.go:520

↓ 2 callersMethodrunBenchmark

(numQueries int, c *gocheck.C)

src/consensus/consensus_test.go:389

↓ 2 callersMethodsendCommit

Mark the instance as committed locally, persist state to disk, then send commit messages to the other replicas We're not concerned with whether the re

src/consensus/manager_commit.go:73

↓ 2 callersFunctionsetupDeps

(manager *Manager)

src/consensus/testing_setup.go:24

↓ 2 callersMethodsetupDiscoverFromExistingPeers

(c *gocheck.C, responses map[string]*ConnectionAcceptedResponse)

src/cluster/cluster_test.go:427

↓ 2 callersMethodsetupSeedPeerDiscovery

sets up seeded peer discovery with a map of addresses -> connection accepted responses returns a cluster

src/cluster/cluster_test.go:306

↓ 2 callersMethodstreamFromNode

************** streaming **************/ initiates streaming tokens from the given node

src/cluster/cluster.go:302

↓ 2 callersMethodstreamToNode

streams keys that are owned/replicated by the given node to it

src/cluster/cluster.go:316

↓ 2 callersMethodupdateInstanceBallotFromResponses

(instance *Instance, responses []BallotMessage)

src/consensus/manager.go:361

↓ 1 callersMethodAddNode

(node Node)

src/topology/datacenter.go:41

↓ 1 callersMethodAllNodes

()

src/topology/topology.go:72

↓ 1 callersMethodClose

closes the connection

src/cluster/connection.go:48

↓ 1 callersMethodCopy

()

src/store/instruction.go:45

↓ 1 callersMethodDeserialize

(buf *bufio.Reader)

src/store/instruction.go:86

↓ 1 callersMethodDeserialize

deserializes everything after the size data pass in a wrapped exception to receive

src/message/message.go:19

↓ 1 callersMethodDeserialize

(buf *bufio.Reader)

src/consensus/instance.go:545

↓ 1 callersMethodDeserialize

(buf *bufio.Reader)

src/cluster/message_connect.go:57

↓ 1 callersMethodError

()

src/cluster/node.go:24

↓ 1 callersMethodExecutePaxos

executes a serialized query against the cluster this method designates the node it's called on as the command leader for the given query. Should only

src/consensus/manager.go:380

↓ 1 callersMethodExecuteQuery

(instruction store.Instruction)

src/consensus/manager.go:417

↓ 1 callersMethodGauge

(stat string, value int64, rate float32)

src/consensus/testing_mocks.go:252

↓ 1 callersMethodGetBallot

()

src/consensus/message.go:15

↓ 1 callersMethodGetDatacenterId

()

src/cluster/cluster.go:135

↓ 1 callersMethodGetLocalDatacenterID

()

src/topology/topology.go:115

↓ 1 callersMethodGetLocalNodesForKey

************** key routing **************/ gets the token of the given key and returns the nodes that it maps to

src/cluster/cluster.go:288

↓ 1 callersMethodGetNodesForKey

returns a map of DC id -> nodes for the give key

src/cluster/cluster.go:294

↓ 1 callersMethodGetNodesForToken

returns a map of datacenter ids -> replica nodes

src/topology/topology.go:124

↓ 1 callersMethodGetTimestamp

()

src/kvstore/val_string.go:31

↓ 1 callersMethodGetTimestamp

()

src/redis/val_string.go:31

↓ 1 callersMethodGetToken

()

src/cluster/cluster.go:136

↓ 1 callersMethodGetValue

()

src/kvstore/val_string.go:27

↓ 1 callersMethodGetValue

()

src/redis/val_string.go:27

↓ 1 callersMethodHandshakeCompleted

()

src/cluster/connection.go:57

↓ 1 callersMethodIntersect

(o InstanceIDSet)

src/consensus/instance_containers.go:47

↓ 1 callersMethodIsReadCommand

(cmd string)

src/redis/store.go:135

↓ 1 callersMethodIsReadOnly

(instruction store.Instruction)

src/kvstore/store.go:130

↓ 1 callersMethodIsWriteCommand

(cmd string)

src/redis/store.go:143

↓ 1 callersMethodIsWriteOnly

(instruction store.Instruction)

src/kvstore/store.go:138

↓ 1 callersMethodJoinCluster

************** node changes **************/ called when a node is first added to the cluster When changing the token ring from this: N0 N1

src/cluster/cluster.go:384

↓ 1 callersMethodLen

()

src/consensus/instance_containers.go:199

↓ 1 callersFunctionNewDatacenterContainer

()

src/topology/datacenter.go:34

↓ 1 callersFunctionNewInstanceResultChan

returns a new InstanceResultChan

src/consensus/instance.go:60

↓ 1 callersFunctionNewKVStore

()

src/kvstore/store.go:41

↓ 1 callersFunctionNewLocalNode

(id node.NodeId, dcId topology.DatacenterID, token partitioner.Token, name string, store store.Store)

src/cluster/node.go:60

↓ 1 callersFunctionNewMD5Partitioner

()

src/partitioner/md5.go:18

↓ 1 callersFunctionNewPeerServer

(cluster *Cluster, listenAddr string)

src/cluster/server.go:23

↓ 1 callersFunctionNewRedis

()

src/redis/store.go:40

↓ 1 callersFunctionNewTopology

( localNID node.NodeId, localDCID DatacenterID, prtnr partitioner.Partitioner, replicationFactor uint, )

src/topology/topology.go:30

↓ 1 callersMethodNumBytes

returns the expected number of bytes from serialization

src/store/instruction.go:61

↓ 1 callersMethodNumBytes

()

src/consensus/message.go:46

↓ 1 callersMethodNumBytes

()

src/consensus/message.go:86

↓ 1 callersMethodNumBytes

()

src/consensus/message.go:155

↓ 1 callersMethodNumBytes

()

src/consensus/message.go:204

↓ 1 callersMethodNumBytes

()

src/consensus/message.go:247

↓ 1 callersMethodNumBytes

()

src/consensus/message.go:269

↓ 1 callersMethodNumBytes

()

src/consensus/message.go:291

↓ 1 callersMethodNumBytes

()

src/consensus/message.go:387

↓ 1 callersMethodNumBytes

()

src/consensus/message.go:457

↓ 1 callersMethodNumBytes

()

src/consensus/message.go:494

↓ 1 callersMethodNumBytes

()

src/consensus/instance.go:525

↓ 1 callersMethodRead

this implements the io.Reader interface

src/cluster/connection.go:30

↓ 1 callersFunctionReadBytes

reads the specified number of bytes out of the reader, performing multiple reads if neccesary

src/serializer/serializer.go:36

↓ 1 callersFunctionReadValue

(buf io.Reader)

src/kvstore/values.go:29

↓ 1 callersFunctionReadValue

(buf io.Reader)

src/redis/values.go:29

↓ 1 callersMethodSerialize

serializes the entire message, including headers. Pass a wrapped connection in to send

src/message/message.go:15

↓ 1 callersMethodSerialize

(buf *bufio.Writer)

src/consensus/instance.go:536

↓ 1 callersMethodSetUpSuite

(c *gocheck.C)

src/consensus/consensus_test.go:71

↓ 1 callersMethodSetUpSuite

(c *gocheck.C)

src/consensus/manager_execute_test.go:29

↓ 1 callersMethodSetUpTest

(c *gocheck.C)

src/consensus/manager_accept_test.go:160

↓ 1 callersMethodSetUpTest

(c *gocheck.C)

src/consensus/consensus_test.go:121

↓ 1 callersMethodSetUpTest

(c *gocheck.C)

src/consensus/manager_preaccept_test.go:119

↓ 1 callersMethodSetUpTest

makes a set of interdependent instances, and sets their expected ordering

src/consensus/manager_execute_test.go:40

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