Functions — github.com/bdeggleston/kickboxer

hub / github.com/bdeggleston/kickboxer / functions

Functions1,093 in github.com/bdeggleston/kickboxer

⨍ Functions 1,093◇ Types & classes 186

FunctionTestGetKeys

(t *testing.T)

src/redis/store_test.go:90

MethodTestGetLocalNodesForToken

(c *gocheck.C)

src/topology/topology_test.go:109

FunctionTestGetManager

(t *testing.T)

src/consensus/manager_test.go:21

FunctionTestGetManagerNodes

(t *testing.T)

src/consensus/manager_test.go:29

FunctionTestGetManagerReplicas

(t *testing.T)

src/consensus/manager_test.go:33

MethodTestGetNodesForToken

(c *gocheck.C)

src/topology/topology_test.go:95

MethodTestGetNodesForToken

(c *gocheck.C)

src/topology/datacenter_test.go:69

FunctionTestGetNonStringFails

tests that calling get on a key holding a value other than a string value returns an error

src/kvstore/cmd_get_test.go:30

FunctionTestGetNonStringFails

tests that calling get on a key holding a value other than a string value returns an error

src/redis/cmd_get_test.go:29

MethodTestGetOpensConnection

test that connections are opened if the pool is empty

src/cluster/connectionpool_test.go:87

MethodTestGetOrSet

(c *gocheck.C)

src/consensus/instance_test.go:119

MethodTestGetOrSetExistingInstance

(c *gocheck.C)

src/consensus/manager_test.go:134

MethodTestGetOrSetNewInstance

(c *gocheck.C)

src/consensus/manager_test.go:128

MethodTestGetOrSetNewInstanceAddsToDepsManager

tests that new instances passed into get or set adds the instance to the dependency manager if their status is above preaccepted

src/consensus/manager_test.go:149

MethodTestGetOrSetPreacceptedNewInstanceSkipsDepsManager

tests that new instances passed into get or set don't add the instance to the dependency manager if the status is preaccepted or below

src/consensus/manager_test.go:163

MethodTestGetOrSetResetsToCommitted

tests that get or set sets new instances to committed if the new instance has an status of executed

src/consensus/manager_test.go:177

FunctionTestGetRawKeySuccess

----------- data import / export -----------

src/kvstore/store_test.go:50

FunctionTestGetRawKeySuccess

----------- data import / export -----------

src/redis/store_test.go:55

MethodTestGetRing

(c *gocheck.C)

src/topology/topology_test.go:85

MethodTestGetRing

(c *gocheck.C)

src/topology/datacenter_test.go:59

MethodTestGetUnknownNode

************** GetNode tests **************/

src/topology/ring_test.go:38

MethodTestGetUnknownNode

(c *gocheck.C)

src/cluster/server_test.go:26

FunctionTestGetValidation

tests validation of GET insructions

src/kvstore/cmd_get_test.go:35

FunctionTestGetValidation

tests validation of GET insructions

src/redis/cmd_get_test.go:34

MethodTestHandleBallotFailure

tests that new attributes are returned

src/consensus/manager_preaccept_test.go:478

MethodTestHandleCommitAsyncExecute

when a commit message is received, the instance should be asynchronously executed against the store

src/consensus/manager_commit_test.go:288

MethodTestHandleDifferentAttrs

tests that the replica updates the sequence and dependencies if it disagrees with the leader

src/consensus/manager_preaccept_test.go:385

MethodTestHandleIdenticalAttrs

tests that the dependency match flag is set if the seq and deps matched

src/consensus/manager_preaccept_test.go:347

MethodTestHandleNewAttrs

tests that new attributes are returned

src/consensus/manager_preaccept_test.go:438

MethodTestHandleNewSuccess

tests that commits are handled properly if the commit if for an instance the node has not previously seen

src/consensus/manager_commit_test.go:264

MethodTestHandleNoop

(c *gocheck.C)

src/consensus/manager_accept_test.go:326

MethodTestHandleSuccess

tests that an instance is marked as committed when a commit request is recived

src/consensus/manager_commit_test.go:243

MethodTestHandleSuccessCase

test that instances are marked as accepted when an accept request is received, and there are no problems with the request

src/consensus/manager_accept_test.go:300

MethodTestHashes

(c *gocheck.C)

src/partitioner/md5_test.go:11

MethodTestHigherStatusFailure

tests that an instance is not marked as accepted, or added to the inProgress set if it already has a higher status

src/consensus/manager_accept_test.go:78

MethodTestHigherStatusFailure

(c *gocheck.C)

src/consensus/manager_preaccept_test.go:48

MethodTestInitialization

(c *gocheck.C)

src/cluster/connectionpool_test.go:15

MethodTestInstanceCommittedAbort

tests that the preparePhase doesn't actually do anything if the instance has been committed

src/consensus/manager_prepare_test.go:253

MethodTestInstanceCreation

test that instances are created properly

src/consensus/manager_test.go:63

MethodTestInstanceCreationPersistenceError

tests that the comand leader aborts if there's an error creating a new instance

src/consensus/manager_leader_test.go:25

MethodTestInstanceDependentConnectedDependencyOrdering

tests that the dependency ordering of connected instances is the same, regardless of the 'target' instance

src/consensus/manager_execute_test.go:276

MethodTestInstanceDependentDependencyOrdering

tests that the dependency ordering is the same, regardless of the 'target' instance

src/consensus/manager_execute_test.go:305

MethodTestInstanceRequest

(c *gocheck.C)

src/consensus/message_test.go:248

MethodTestInstanceResponse

(c *gocheck.C)

src/consensus/message_test.go:266

MethodTestInstanceStrongComponentsAreIncludedInExOrder

tests that getting the execution order saves the strongly connected component ids on the instances

src/consensus/manager_execute_test.go:395

MethodTestIntegration

(c *gocheck.C)

src/consensus/manager_dependencies_test.go:368

FunctionTestInterfaceIsImplemented

(t *testing.T)

src/redis/store_test.go:48

MethodTestInvalidPartitioner

(c *gocheck.C)

src/cluster/cluster_test.go:72

MethodTestInvalidReplicationFactor

tests that instantiating a cluster with an invalid replication factor returns an error

src/cluster/cluster_test.go:56

FunctionTestIsReadCmd

(t *testing.T)

src/kvstore/store_test.go:35

FunctionTestIsReadCmd

(t *testing.T)

src/redis/store_test.go:35

FunctionTestIsWriteCmd

(t *testing.T)

src/kvstore/store_test.go:22

FunctionTestIsWriteCmd

(t *testing.T)

src/redis/store_test.go:22

MethodTestIsZero

(c *gocheck.C)

src/types/b16_test.go:29

FunctionTestKeyExists

(t *testing.T)

src/kvstore/store_test.go:109

FunctionTestKeyExists

(t *testing.T)

src/redis/store_test.go:114

MethodTestKeyRouting

tests that the proper nodes are returned for the given keys

src/topology/ring_test.go:153

MethodTestLastKeyReadIsUpdated

tests the last reads array is updated if the instance is a read

src/consensus/manager_dependencies_test.go:164

MethodTestLastKeyWriteIsUpdated

tests the last write is updated if the instance is a write

src/consensus/manager_dependencies_test.go:195

MethodTestLocalReadDeps

tests the deps reported by a single deps node for a read

src/consensus/manager_dependencies_test.go:210

MethodTestLocalWriteDeps

tests the deps reported by a single deps node for a write

src/consensus/manager_dependencies_test.go:223

MethodTestMergeAttributes

(c *gocheck.C)

src/consensus/manager_preaccept_test.go:229

MethodTestMergeAttributesBadStatus

tests that calling merge attributes fails if the instance status id not preaccepted

src/consensus/instance_test.go:176

MethodTestMergeAttributesNoChanges

(c *gocheck.C)

src/consensus/manager_preaccept_test.go:275

MethodTestMessageSendingFailureCase

tests that a node is marked as down if sending a message fails

src/cluster/node_test.go:105

MethodTestMessageSendingSuccessCase

tests that sending and receiving messages works as expected

src/cluster/node_test.go:81

FunctionTestMismatchedStreamReceive

test that reconciliation is performed if the received value doesn't match the value on this node

src/cluster/cluster_streaming_test.go:155

MethodTestMissingDependencyOrder

getExecutionOrder should return an error if an instance depends on an instance that the manager hasn't seen

src/consensus/manager_execute_test.go:332

MethodTestMissingInstanceSuccess

tests that handle accept adds any missing instances in the missing instances message

src/consensus/manager_accept_test.go:408

MethodTestMissingInstanceSuccessCase

(c *gocheck.C)

src/consensus/integration_test.go:73

MethodTestMissingVertex1

tests that missing vertices are skipped

src/consensus/algorithms_test.go:98

MethodTestMissingVertex2

(c *gocheck.C)

src/consensus/algorithms_test.go:116

MethodTestMixedNilResponses

tests that a mix of responses with nil instances, and not nil instances is safe from nil pointer errors

src/consensus/manager_prepare_test.go:228

MethodTestNewDependencyMap

tests that a new dependencies object is created for new leaf nodes

src/consensus/manager_dependencies_test.go:131

MethodTestNewInstanceSuccess

tests that an instance is marked as accepted, added to the instances and inProgress set, and persisted if the instance hasn't been seen before

src/consensus/manager_accept_test.go:58

MethodTestNewInstanceSuccess

tests that accepts are handled properly if the commit if for an instance the node has not been previously seen by this replica

src/consensus/manager_accept_test.go:353

MethodTestNewNoopAccept

tests that the noop flag is recognized when preaccepting new instances

src/consensus/manager_accept_test.go:112

MethodTestNewNoopPreaccept

tests that the noop flag is recognized when preaccepting new instances

src/consensus/manager_preaccept_test.go:86

MethodTestNewRootDependencyMap

tests that a new dependencies object is created for new root nodes

src/consensus/manager_dependencies_test.go:30

MethodTestNewSuccessCase

tests that an instance is marked as committed, added to the instances and committed set, and persisted if the instance hasn't been seen before

src/consensus/manager_commit_test.go:58

MethodTestNilSuccessorResponse

tests that the non successor will go to the next successor if the successor returns a nil instance

src/consensus/manager_prepare_test.go:894

MethodTestNoSelfDependence

tests that an instance cannot gain a dependency on itself

src/consensus/manager_dependencies_test.go:181

MethodTestNodeStreamsFromCorrectNode

TODO: this tests that a node joining the cluster identifies the correct node to stream data from, and sends it a message

src/cluster/cluster_join_test.go:18

MethodTestNodesAreStarted

tests all nodes are started on cluster startup

src/cluster/cluster_test.go:214

MethodTestNonReplicaLeaderFailure

tests that execution will fail if the command leader (the node running ExecuteQuery can't find itself in the list of given replicas

src/consensus/manager_leader_test.go:19

MethodTestNonStronglyConnectedGraph

tests that the graph 0 -> 1 -> 2 -> 3 -> 4 returns 4 components

src/consensus/algorithms_test.go:80

MethodTestNumBytesCalculation

(c *gocheck.C)

src/store/instruction_test.go:35

MethodTestOldBallotFailure

tests that accept messages fail if an higher ballot number has been seen for this message

src/consensus/manager_accept_test.go:385

MethodTestOldNoopAccept

tests that the noop flag is recognized when preaccepting previously seen instances

src/consensus/manager_accept_test.go:118

MethodTestOldNoopPreaccept

tests that the noop flag is recognized when preaccepting previously seen instances

src/consensus/manager_preaccept_test.go:99

MethodTestOpenConnectionReturn

tests that open connections are returned to the connection pool

src/cluster/connectionpool_test.go:29

MethodTestOtherDCDiscoveryFromExistingPeers

(c *gocheck.C)

src/cluster/cluster_test.go:531

MethodTestOtherDCPeerDiscoveryFromSeedAddresses

tests that discovering peers from a list of seed addresses that belong to different DCs works properly

src/cluster/cluster_test.go:390

MethodTestPeerDiscoveryNodeDataFailure

tests that a node is still added to the ring, even if there's a problem connecting to it when discovered from another node

src/cluster/cluster_test.go:597

MethodTestPeerDiscoveryOnStartup

tests that all peers are discovered on startup

src/cluster/cluster_test.go:293

MethodTestPeerDiscoveryResponse

tests that the discoverPeers function returns the proper data

src/cluster/cluster_test.go:299

MethodTestPeerDiscoverySeedFailure

(c *gocheck.C)

src/cluster/cluster_test.go:571

MethodTestPeerServerIsStarted

(c *gocheck.C)

src/cluster/cluster_test.go:237

MethodTestPoolSize

tests that pool counter is incremented and decremented properly

src/cluster/connectionpool_test.go:107

MethodTestPreAcceptBallotFailure

(c *gocheck.C)

src/consensus/manager_test.go:198

← previous next →801–900 of 1,093, ranked by callers