MCPcopy Create free account

hub / github.com/bdeggleston/kickboxer / functions

Functions1,093 in github.com/bdeggleston/kickboxer

FunctionTest
Hook up gocheck into the "go test" runner.
src/types/types_test.go:12
FunctionTest
Hook up gocheck into the "go test" runner.
src/topology/topology_test.go:18
FunctionTest
Hook up gocheck into the "go test" runner.
src/partitioner/partitioner_test.go:12
FunctionTest
Hook up gocheck into the "go test" runner.
src/consensus/manager_test.go:42
FunctionTest
Hook up gocheck into the "go test" runner.
src/cluster/cluster_test.go:25
MethodTestAcceptBallotFailure
(c *gocheck.C)
src/consensus/manager_test.go:206
MethodTestAcceptFailure
tests that receiving prepare responses, where the highest balloted instance's status was accepted, an accept phase is initiated, and the method return
src/consensus/manager_prepare_test.go:556
MethodTestAcceptMessageBallotIsUpToDate
tests that the accept messages sent out have the same ballot as the local instance
src/consensus/manager_accept_test.go:258
MethodTestAcceptRequest
(c *gocheck.C)
src/consensus/message_test.go:62
MethodTestAcceptResponse
(c *gocheck.C)
src/consensus/message_test.go:84
MethodTestAcceptStatusUpdate
if any of the respones have been rejected, and the remote instance from the rejecting node is accepted, committed, or executed, the local instance sho
src/consensus/manager_prepare_test.go:392
MethodTestAcceptSuccess
tests that receiving prepare responses, where the highest balloted instance's status was accepted, an accept phase is initiated
src/consensus/manager_prepare_test.go:532
MethodTestAcceptSuccess
(c *gocheck.C)
src/consensus/manager_test.go:202
MethodTestAcceptSuccessCase
test successful accept cycle
src/consensus/integration_test.go:125
MethodTestAcceptedSuccessorResponse
tests that the non successor will accept the local instance if the successor returns an accepted instance
src/consensus/manager_prepare_test.go:915
MethodTestAddMissingInstance
tests that the addMissingInstance method works properly
src/consensus/manager_test.go:85
MethodTestAddNode
tests add node behavior
src/topology/topology_test.go:73
MethodTestAddNode
tests add node behavior
src/topology/datacenter_test.go:47
MethodTestAddOtherDCNode
(c *gocheck.C)
src/cluster/cluster_test.go:121
MethodTestAddReadDependency
(c *gocheck.C)
src/consensus/manager_dependencies_test.go:345
MethodTestAddWriteDependency
(c *gocheck.C)
src/consensus/manager_dependencies_test.go:356
MethodTestAddingExistingNodeToRing
tests that nothing is changed if a node is already known by the cluster, and an error is returned
src/topology/ring_test.go:75
MethodTestAddingNewNodeToRing
************** AddNode tests **************/ tests that a node is added to the cluster if the cluster has not seen it yet
src/topology/ring_test.go:58
MethodTestAddingNewNodeToStartedCluster
TODO: this tests that a node is added to the cluster if the cluster has not seen it yet, and starts it if the cluster has been started
src/cluster/cluster_test.go:98
MethodTestAddingNode
(c *gocheck.C)
src/cluster/cluster_test.go:102
MethodTestAllNodes
************** AllNodes tests **************/
src/topology/ring_test.go:89
MethodTestBallotFailure
tests that the local instance's ballot is updated from rejected prepare responses
src/consensus/manager_prepare_test.go:161
MethodTestBallotFailure
tests that a prepare request with an unincremented ballot number is not accepted
src/consensus/manager_prepare_test.go:751
MethodTestBallotIncrement
(c *gocheck.C)
src/consensus/manager_accept_test.go:45
MethodTestBallotIncrement
(c *gocheck.C)
src/consensus/manager_preaccept_test.go:38
MethodTestBallotIncrement
(c *gocheck.C)
src/consensus/manager_commit_test.go:47
MethodTestBallotUpdate
tests that the instance's ballot is updated if prepare responses return higher ballot numbers
src/consensus/manager_prepare_test.go:664
MethodTestBallotUpdateFromResponses
tests that the ballot is always updated from prepare responses
src/consensus/manager_prepare_test.go:188
FunctionTestBasicStreamReceive
************** query behavior tests **************/
src/cluster/cluster_streaming_test.go:148
MethodTestBenchmarkQueries
(c *gocheck.C)
src/consensus/consensus_test.go:537
MethodTestBookKeeping
tests that apply instance marks the instance as executed, and moves it into the executed container
src/consensus/manager_execute_test.go:734
FunctionTestBooleanEquality
tests the boolean value's equality method
src/kvstore/val_bool_test.go:38
FunctionTestBooleanEquality
tests the boolean value's equality method
src/redis/val_bool_test.go:38
FunctionTestBooleanValue
(t *testing.T)
src/kvstore/val_bool_test.go:10
FunctionTestBooleanValue
(t *testing.T)
src/redis/val_bool_test.go:10
FunctionTestCheckManagerEligibility
(t *testing.T)
src/consensus/manager_test.go:25
MethodTestClosedConnectionReturn
test that closed connections are not returned to the connection pool
src/cluster/connectionpool_test.go:42
MethodTestClusterStatusChanges
(c *gocheck.C)
src/cluster/cluster_test.go:226
MethodTestCommitExecutedFailure
tests that an instance is not marked as committed, or added to the committed set if it already has been executed
src/consensus/manager_commit_test.go:80
MethodTestCommitExpiredTimeout
tests that the prepare phase immediately starts if the given instance is past it's commit grace period
src/consensus/manager_prepare_test.go:273
MethodTestCommitFailure
tests that receiving prepare responses, where the highest balloted instance's status was committed, a commit phase is initiated, and the method return
src/consensus/manager_prepare_test.go:600
MethodTestCommitInstanceBroadcast
tests that instances with a commitNotify Cond object calls broadcast when the instance is committed
src/consensus/manager_commit_test.go:122
MethodTestCommitMessageBallotIsUpToDate
tests that the accept messages sent out have the same ballot as the local instance
src/consensus/manager_commit_test.go:202
MethodTestCommitNoop
(c *gocheck.C)
src/consensus/manager_commit_test.go:126
MethodTestCommitNotify
tests that the prepare phase will wait on the commit notify cond if it's within the commit grace period, and will abort the prepare if another gorouti
src/consensus/manager_prepare_test.go:318
MethodTestCommitRequest
(c *gocheck.C)
src/consensus/message_test.go:103
MethodTestCommitResponse
(c *gocheck.C)
src/consensus/message_test.go:121
MethodTestCommitStatusUpdate
if any of the respones have been rejected, and the remote instance from the rejecting node is accepted, committed, or executed, the local instance sho
src/consensus/manager_prepare_test.go:423
MethodTestCommitSuccess
tests that receiving prepare responses, where the highest balloted instance's status was committed, a commit phase is initiated
src/consensus/manager_prepare_test.go:577
MethodTestCommitTimeout
tests that the prepare phase starts after the commit grace period if another goroutine does not commit it first
src/consensus/manager_prepare_test.go:295
MethodTestCommittedInstance
tests that the prepare phase method is not called if the instance has been committed
src/consensus/manager_prepare_test.go:1061
MethodTestCommittedSuccessorResponse
tests that the non successor will commit the local instance if the successor returns an committed instance
src/consensus/manager_prepare_test.go:934
MethodTestConcurrentNodeAdditions
TODO: this 2 nodes added to the cluster at the same time should find out about each other
src/cluster/cluster_test.go:203
MethodTestConnectionAcceptedResponse
(c *gocheck.C)
src/cluster/message_test.go:50
FunctionTestConnectionFailure
test connecting to an address that's not listening
src/cluster/connection_test.go:9
MethodTestConnectionRefusedResponse
(c *gocheck.C)
src/cluster/message_test.go:60
MethodTestConnectionRequest
(c *gocheck.C)
src/cluster/message_test.go:39
MethodTestCopy
(c *gocheck.C)
src/store/instruction_test.go:50
MethodTestDeferInfiniteLoop
tests that,if defer to successor first returns false, and then true, the prepare phase will continue
src/consensus/manager_prepare_test.go:988
FunctionTestDelExistingVal
test that a tombstone value is written
src/kvstore/cmd_del_test.go:12
FunctionTestDelExistingVal
test that a tombstone value is written
src/redis/cmd_del_test.go:12
FunctionTestDelNonExistingVal
(t *testing.T)
src/kvstore/cmd_del_test.go:56
FunctionTestDelNonExistingVal
(t *testing.T)
src/redis/cmd_del_test.go:56
FunctionTestDelValidation
tests validation of DEL insructions
src/kvstore/cmd_del_test.go:87
FunctionTestDelValidation
tests validation of DEL insructions
src/redis/cmd_del_test.go:87
MethodTestDependencyOrdering
(c *gocheck.C)
src/consensus/manager_execute_test.go:265
MethodTestDiscoverPeersRequest
(c *gocheck.C)
src/cluster/message_test.go:65
MethodTestDiscoverPeersResponse
(c *gocheck.C)
src/cluster/message_test.go:72
MethodTestDiscoveryFromExistingPeers
tests that discovering peers from existing peers works properly
src/cluster/cluster_test.go:493
MethodTestDiscoveryFromSeedAddresses
tests that discovering peers from a list of seed addresses works properly
src/cluster/cluster_test.go:353
MethodTestEncoding
(c *gocheck.C)
src/types/b16_test.go:16
MethodTestEncoding
(c *gocheck.C)
src/types/uuid_test.go:16
MethodTestExecuteQueryMessage
tests calling execute query sends correct message
src/cluster/node_test.go:121
MethodTestExecutedFailure
tests that receiving prepare responses, where the highest balloted instance's status was executed, a commit phase is initiated, and the method returns
src/consensus/manager_prepare_test.go:644
MethodTestExecutedSuccess
tests that receiving prepare responses, where the highest balloted instance's status was executed, a commit phase is initiated
src/consensus/manager_prepare_test.go:621
MethodTestExecutedSuccessorResponse
tests that the non successor will commit the local instance if the successor returns an committed instance
src/consensus/manager_prepare_test.go:952
MethodTestExecutingLongStronglyConnectedComponentOrdering
tests that, as large strongly connected components are executed, their execution ordering is not affected by the dependency graph excluding some execu
src/consensus/manager_execute_test.go:444
MethodTestExistingDependencyMap
tests that existing dependencies object is used if it exists
src/consensus/manager_dependencies_test.go:146
MethodTestExistingRootDependencyMap
tests that an existing dependencies object is used for a key if it exists
src/consensus/manager_dependencies_test.go:44
MethodTestExistingSuccessCase
tests that an instance is marked as committed, added to the committed set, removed from the inProgress set, and persisted if it hasn't already been ex
src/consensus/manager_commit_test.go:27
MethodTestExpectedDataIsReturned
(c *gocheck.C)
src/cluster/cluster_test.go:150
MethodTestExpectedDataIsReturnedFromOtherDCs
(c *gocheck.C)
src/cluster/cluster_test.go:168
MethodTestExplicitPrepare
tests that an explicit prepare is initiated on any uncommitted instance in the instance's dependency graph
src/consensus/manager_execute_test.go:144
MethodTestExplicitPrepareBallotFailure
tests that execute will return an error if it receives more ballot failures than the BALLOT_FAILURE_RETRIES value
src/consensus/manager_execute_test.go:239
MethodTestExplicitPrepareFailure
tests that execute will return an error if a prepare call returns a non ballot related error
src/consensus/manager_execute_test.go:224
MethodTestExplicitPrepareRetry
tests that an explicit prepare is retried if it fails due to a ballot failure
src/consensus/manager_execute_test.go:163
MethodTestExplicitPrepareRetryCondAbort
tests that an explicit prepare which is retried, will wait before retrying, but will abort if a commit notify event is broadcasted
src/consensus/manager_execute_test.go:191
MethodTestExternalDependencySuccess
tests that instances up to and including the given instance are executed when the dependencies all have a remote instance id
src/consensus/manager_execute_test.go:346
MethodTestFullConnectionReturn
test that connections are closed if the pool is full
src/cluster/connectionpool_test.go:55
FunctionTestGet
(t *testing.T)
src/kvstore/cmd_get_test.go:10
FunctionTestGet
(t *testing.T)
src/redis/cmd_get_test.go:9
MethodTestGetAndSet
(c *gocheck.C)
src/consensus/instance_test.go:54
MethodTestGetConn
test that open connections are returned
src/cluster/connectionpool_test.go:70
MethodTestGetExistingNode
tests that fetching a node with a valid node id returns the requested node
src/topology/ring_test.go:46
FunctionTestGetKeys
(t *testing.T)
src/kvstore/store_test.go:85
← previousnext →701–800 of 1,093, ranked by callers