Functions — github.com/bdeggleston/kickboxer

hub / github.com/bdeggleston/kickboxer / functions

Functions1,093 in github.com/bdeggleston/kickboxer

⨍ Functions 1,093◇ Types & classes 186

↓ 7 callersFunctiontransformMockNodeArray

(src []*mockNode)

src/consensus/testing_mocks.go:210

↓ 7 callersMethodwaitForStatus

waits for all managers to have the given status for the given instance

src/consensus/integration_test.go:30

↓ 6 callersMethodAdd

(ids ...InstanceID)

src/consensus/instance_containers.go:65

↓ 6 callersMethodClose

()

src/consensus/testing_mocks.go:276

↓ 6 callersMethodCombine

(idSets ...InstanceIDSet)

src/consensus/instance_containers.go:77

↓ 6 callersMethodDeserializeValue

serializes a value

src/store/store.go:58

↓ 6 callersMethodGet

gets a connection from the pool, creating one if the pool is empty

src/cluster/connection.go:119

↓ 6 callersMethodHandleAccept

handles an accept message from the command leader for an instance this executes the replica accept phase for the given instance

src/consensus/manager_accept.go:168

↓ 6 callersFunctionNewBallotError

(format string, a ...interface{})

src/consensus/errors.go:26

↓ 6 callersFunctionNewSizedInstanceIDSet

(size int)

src/consensus/instance_containers.go:19

↓ 6 callersMethodNumBytes

returns the number of bytes the serialized message will contain

src/message/message.go:26

↓ 6 callersMethodSerialize

(buf *bufio.Writer)

src/store/store.go:16

↓ 6 callersMethodUnmarshalBinary

(bs []byte)

src/types/b16.go:31

↓ 6 callersMethodcommitInstances

commits all instances

src/consensus/manager_execute_test.go:259

↓ 6 callersMethodgetChan

()

src/consensus/manager.go:127

↓ 6 callersMethodgetCommitEvent

()

src/consensus/instance.go:152

↓ 6 callersMethodgetInstanceReplicas

returns the replicas for the given instance's key, excluding the local node

src/consensus/manager.go:214

↓ 6 callersFunctionnewPgmConn

()

src/cluster/testing.go:282

↓ 6 callersMethodpatchAccept

(e error)

src/consensus/manager_prepare_test.go:52

↓ 5 callersMethodAddDependency

(keys []string, instance *Instance)

src/consensus/manager_depedencies.go:263

↓ 5 callersMethodDeserialize

(buf *bufio.Reader)

src/store/store.go:17

↓ 5 callersMethodGetAddr

()

src/topology/node.go:20

↓ 5 callersMethodGetValue

()

src/kvstore/val_bool.go:24

↓ 5 callersMethodGetValue

()

src/redis/val_bool.go:24

↓ 5 callersMethodHandlePreAccept

handles a preaccept message from the command leader for an instance this executes the replica preaccept phase for the given instance

src/consensus/manager_preaccept.go:208

↓ 5 callersMethodMarshalBinary

()

src/types/b16.go:13

↓ 5 callersMethodName

()

src/topology/node.go:19

↓ 5 callersFunctionNewRemoteNode

creates a new remote node from only an address

src/cluster/node.go:123

↓ 5 callersMethodSetHandshakeCompleted

()

src/cluster/connection.go:58

↓ 5 callersMethodStop

()

src/node/node.go:41

↓ 5 callersMethodacceptPhase

(instance *Instance)

src/consensus/manager_accept.go:162

↓ 5 callersMethodaddOutgoingMessage

(m message.Message)

src/cluster/testing.go:324

↓ 5 callersMethodgetInstance

(iid InstanceID)

src/consensus/manager.go:267

↓ 5 callersMethodpatchPreAccept

(r bool, e error)

src/consensus/manager_prepare_test.go:45

↓ 5 callersMethodsetDeps

(reason string, deps []InstanceID)

src/consensus/instance.go:225

↓ 4 callersMethodEqual

(o store.Value)

src/kvstore/val_string.go:39

↓ 4 callersMethodEqual

(o store.Value)

src/kvstore/val_bool.go:36

↓ 4 callersMethodEqual

(o store.Value)

src/redis/val_string.go:39

↓ 4 callersMethodEqual

(o store.Value)

src/redis/val_bool.go:36

↓ 4 callersMethodGetKeys

returns all of the keys held by the store

src/store/store.go:67

↓ 4 callersMethodGetLocalNodeID

()

src/topology/topology.go:111

↓ 4 callersMethodGetMap

adds the instances of the given instance ids to the given instance map, and returns it if the given map is nil, a new map is allocated and returned

src/consensus/instance_containers.go:252

↓ 4 callersMethodGetName

()

src/cluster/cluster.go:137

↓ 4 callersMethodGetType

returns the message type enum

src/message/message.go:22

↓ 4 callersMethodHandleCommit

handles an commit message from the command leader for an instance this executes the replica commit phase for the given instance

src/consensus/manager_commit.go:125

↓ 4 callersMethodHandlePrepare

handles a prepare message from an instance attempting to take control of an instance.

src/consensus/manager_prepare.go:533

↓ 4 callersMethodHandlePrepareSuccessor

handles a message from a replica requesting that a prepare phase is executed on the given instance

src/consensus/manager_prepare.go:571

↓ 4 callersMethodInstanceIDs

()

src/consensus/instance_containers.go:230

↓ 4 callersMethodInterferingKeys

TODO: remove and rework epaxos to interact with the store directly

src/clusterproto/clusterproto.go:46

↓ 4 callersMethodKeyExists

checks if a key exists in the store

src/store/store.go:70

↓ 4 callersMethodList

()

src/consensus/instance_containers.go:127

↓ 4 callersFunctionNewRing

creates and starts a ring

src/topology/ring.go:50

↓ 4 callersMethodReportExecuted

reports and instance as executed. Once an instance has been acknowledged as a dependency and executed, it can be removed from the dependency tree

src/consensus/manager_depedencies.go:240

↓ 4 callersMethodSetUpTest

(c *gocheck.C)

src/consensus/manager_prepare_test.go:32

↓ 4 callersMethodSubtract

remove all the keys in o, from i, returns removed keys

src/consensus/instance_containers.go:97

↓ 4 callersMethodTime

()

src/types/uuid.go:44

↓ 4 callersMethodaddMissingInstances

(instances ...*Instance)

src/consensus/manager.go:351

↓ 4 callersMethodbroadcastCommitEvent

()

src/consensus/instance.go:161

↓ 4 callersMethodcommitPhase

(instance *Instance)

src/consensus/manager_commit.go:119

↓ 4 callersMethodgetLocalDeps

(instance *Instance)

src/consensus/manager_depedencies.go:119

↓ 4 callersMethodgetPeerData

returns data on peer nodes

src/cluster/cluster.go:154

↓ 4 callersMethodhandleConnection

(conn net.Conn)

src/cluster/server.go:60

↓ 4 callersMethodpatchPreparePhase

(err error, commit bool)

src/consensus/manager_execute_test.go:132

↓ 4 callersMethodsendAccept

(instance *Instance, replicas []node.Node)

src/consensus/manager_accept.go:65

↓ 4 callersMethodsendPreAccept

sends pre accept responses to the given replicas, and returns their responses. An error will be returned if there are problems, or a quorum of respons

src/consensus/manager_preaccept.go:58

↓ 4 callersFunctionsetupCluster

----------------- cluster setup -----------------

src/cluster/testing.go:26

↓ 3 callersMethodClosed

()

src/cluster/connection.go:53

↓ 3 callersMethodEqual

(o store.Value)

src/kvstore/val_tombstone.go:32

↓ 3 callersMethodEqual

(o store.Value)

src/redis/val_tombstone.go:32

↓ 3 callersMethodGetOrSet

gets an existing instance matching the given instance's iid, or adds the given instance to the map. The initialize function, if not nil, is run on the

src/consensus/instance_containers.go:178

↓ 3 callersMethodGetRawKey

returns raw data associated with the given key

src/store/store.go:61

↓ 3 callersMethodGetToken

(key string)

src/partitioner/md5.go:12

↓ 3 callersFunctionNewInstanceMap

()

src/consensus/instance_containers.go:158

↓ 3 callersFunctionNewInstruction

creates a new instruction

src/store/instruction.go:24

↓ 3 callersFunctionNewInvalidStatusUpdateError

(instance *Instance, update InstanceStatus)

src/consensus/errors.go:50

↓ 3 callersFunctionNewManager

( t *topology.Topology, s store.Store, )

src/consensus/manager.go:172

↓ 3 callersFunctionNewTimeoutError

(format string, a ...interface{})

src/consensus/errors.go:14

↓ 3 callersMethodRemove

(instance *Instance)

src/consensus/instance_containers.go:205

↓ 3 callersMethodString

()

src/consensus/errors.go:25

↓ 3 callersMethodTimeout

()

src/cluster/testing.go:200

↓ 3 callersMethodaddMissingInstancesUnsafe

(instances ...*Instance)

src/consensus/manager.go:317

↓ 3 callersFunctionbaseValueEqual

----------- equality helpers -----------

src/kvstore/values.go:53

↓ 3 callersFunctionbaseValueEqual

----------- equality helpers -----------

src/redis/values.go:53

↓ 3 callersMethodcommit

commits the instance the broadcast event is not sent here because the instance needs to be persisted before the event is sent

src/consensus/instance.go:359

↓ 3 callersMethodexecuteDependencyChain

executes the dependencies up to the given instance

src/consensus/manager_execute.go:264

↓ 3 callersMethodexecuteRequest

executes a request and returns a response message

src/cluster/server.go:31

↓ 3 callersMethodlog

log to the test pointer, if it exists

src/cluster/node_mock.go:81

↓ 3 callersFunctionmakeLiteralRing

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

src/cluster/testing.go:94

↓ 3 callersMethodmergeAttributes

merges sequence and dependencies onto this instance, and returns true/false to indicate if there were any changes

src/consensus/instance.go:276

↓ 3 callersMethodmergePreAcceptAttributes

merges the attributes from the pre accept responses onto the local instance and returns a bool indicating if any changes were made

src/consensus/manager_preaccept.go:133

↓ 3 callersFunctionnewMockNode

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

src/cluster/node_mock.go:39

↓ 3 callersFunctionnewMockStatter

()

src/consensus/testing_mocks.go:230

↓ 3 callersFunctionnewMockStore

()

src/consensus/testing_mocks.go:286

↓ 3 callersMethodset

Set key to hold the string value. If key already holds a value, it is overwritten, regardless of its type. Any previous time to live associated with t

src/kvstore/cmd_set.go:23

↓ 3 callersMethodset

Set key to hold the string value. If key already holds a value, it is overwritten, regardless of its type. Any previous time to live associated with t

src/redis/cmd_set.go:23

↓ 3 callersMethodupdateBallot

(ballot uint32)

src/consensus/instance.go:215

↓ 2 callersFunctionConnect

connects and returns a new connection timeout is the number of milliseconds until the connection attempt is aborted

src/cluster/connection.go:21

↓ 2 callersMethodDifference

returns a new set with all of the keys in i, that aren't in o

src/consensus/instance_containers.go:86

↓ 2 callersMethodError

()

src/consensus/errors.go:24

↓ 2 callersMethodExecuteQuery

executes a distributed query against cluster

src/clusterproto/clusterproto.go:40

← previous next →101–200 of 1,093, ranked by callers