Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/bdeggleston/kickboxer
/ functions
Functions
1,093 in github.com/bdeggleston/kickboxer
⨍
Functions
1,093
◇
Types & classes
186
Function
Test
Hook up gocheck into the "go test" runner.
src/types/types_test.go:12
Function
Test
Hook up gocheck into the "go test" runner.
src/topology/topology_test.go:18
Function
Test
Hook up gocheck into the "go test" runner.
src/partitioner/partitioner_test.go:12
Function
Test
Hook up gocheck into the "go test" runner.
src/consensus/manager_test.go:42
Function
Test
Hook up gocheck into the "go test" runner.
src/cluster/cluster_test.go:25
Method
TestAcceptBallotFailure
(c *gocheck.C)
src/consensus/manager_test.go:206
Method
TestAcceptFailure
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
Method
TestAcceptMessageBallotIsUpToDate
tests that the accept messages sent out have the same ballot as the local instance
src/consensus/manager_accept_test.go:258
Method
TestAcceptRequest
(c *gocheck.C)
src/consensus/message_test.go:62
Method
TestAcceptResponse
(c *gocheck.C)
src/consensus/message_test.go:84
Method
TestAcceptStatusUpdate
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
Method
TestAcceptSuccess
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
Method
TestAcceptSuccess
(c *gocheck.C)
src/consensus/manager_test.go:202
Method
TestAcceptSuccessCase
test successful accept cycle
src/consensus/integration_test.go:125
Method
TestAcceptedSuccessorResponse
tests that the non successor will accept the local instance if the successor returns an accepted instance
src/consensus/manager_prepare_test.go:915
Method
TestAddMissingInstance
tests that the addMissingInstance method works properly
src/consensus/manager_test.go:85
Method
TestAddNode
tests add node behavior
src/topology/topology_test.go:73
Method
TestAddNode
tests add node behavior
src/topology/datacenter_test.go:47
Method
TestAddOtherDCNode
(c *gocheck.C)
src/cluster/cluster_test.go:121
Method
TestAddReadDependency
(c *gocheck.C)
src/consensus/manager_dependencies_test.go:345
Method
TestAddWriteDependency
(c *gocheck.C)
src/consensus/manager_dependencies_test.go:356
Method
TestAddingExistingNodeToRing
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
Method
TestAddingNewNodeToRing
************** 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
Method
TestAddingNewNodeToStartedCluster
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
Method
TestAddingNode
(c *gocheck.C)
src/cluster/cluster_test.go:102
Method
TestAllNodes
************** AllNodes tests **************/
src/topology/ring_test.go:89
Method
TestBallotFailure
tests that the local instance's ballot is updated from rejected prepare responses
src/consensus/manager_prepare_test.go:161
Method
TestBallotFailure
tests that a prepare request with an unincremented ballot number is not accepted
src/consensus/manager_prepare_test.go:751
Method
TestBallotIncrement
(c *gocheck.C)
src/consensus/manager_accept_test.go:45
Method
TestBallotIncrement
(c *gocheck.C)
src/consensus/manager_preaccept_test.go:38
Method
TestBallotIncrement
(c *gocheck.C)
src/consensus/manager_commit_test.go:47
Method
TestBallotUpdate
tests that the instance's ballot is updated if prepare responses return higher ballot numbers
src/consensus/manager_prepare_test.go:664
Method
TestBallotUpdateFromResponses
tests that the ballot is always updated from prepare responses
src/consensus/manager_prepare_test.go:188
Function
TestBasicStreamReceive
************** query behavior tests **************/
src/cluster/cluster_streaming_test.go:148
Method
TestBenchmarkQueries
(c *gocheck.C)
src/consensus/consensus_test.go:537
Method
TestBookKeeping
tests that apply instance marks the instance as executed, and moves it into the executed container
src/consensus/manager_execute_test.go:734
Function
TestBooleanEquality
tests the boolean value's equality method
src/kvstore/val_bool_test.go:38
Function
TestBooleanEquality
tests the boolean value's equality method
src/redis/val_bool_test.go:38
Function
TestBooleanValue
(t *testing.T)
src/kvstore/val_bool_test.go:10
Function
TestBooleanValue
(t *testing.T)
src/redis/val_bool_test.go:10
Function
TestCheckManagerEligibility
(t *testing.T)
src/consensus/manager_test.go:25
Method
TestClosedConnectionReturn
test that closed connections are not returned to the connection pool
src/cluster/connectionpool_test.go:42
Method
TestClusterStatusChanges
(c *gocheck.C)
src/cluster/cluster_test.go:226
Method
TestCommitExecutedFailure
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
Method
TestCommitExpiredTimeout
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
Method
TestCommitFailure
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
Method
TestCommitInstanceBroadcast
tests that instances with a commitNotify Cond object calls broadcast when the instance is committed
src/consensus/manager_commit_test.go:122
Method
TestCommitMessageBallotIsUpToDate
tests that the accept messages sent out have the same ballot as the local instance
src/consensus/manager_commit_test.go:202
Method
TestCommitNoop
(c *gocheck.C)
src/consensus/manager_commit_test.go:126
Method
TestCommitNotify
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
Method
TestCommitRequest
(c *gocheck.C)
src/consensus/message_test.go:103
Method
TestCommitResponse
(c *gocheck.C)
src/consensus/message_test.go:121
Method
TestCommitStatusUpdate
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
Method
TestCommitSuccess
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
Method
TestCommitTimeout
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
Method
TestCommittedInstance
tests that the prepare phase method is not called if the instance has been committed
src/consensus/manager_prepare_test.go:1061
Method
TestCommittedSuccessorResponse
tests that the non successor will commit the local instance if the successor returns an committed instance
src/consensus/manager_prepare_test.go:934
Method
TestConcurrentNodeAdditions
TODO: this 2 nodes added to the cluster at the same time should find out about each other
src/cluster/cluster_test.go:203
Method
TestConnectionAcceptedResponse
(c *gocheck.C)
src/cluster/message_test.go:50
Function
TestConnectionFailure
test connecting to an address that's not listening
src/cluster/connection_test.go:9
Method
TestConnectionRefusedResponse
(c *gocheck.C)
src/cluster/message_test.go:60
Method
TestConnectionRequest
(c *gocheck.C)
src/cluster/message_test.go:39
Method
TestCopy
(c *gocheck.C)
src/store/instruction_test.go:50
Method
TestDeferInfiniteLoop
tests that,if defer to successor first returns false, and then true, the prepare phase will continue
src/consensus/manager_prepare_test.go:988
Function
TestDelExistingVal
test that a tombstone value is written
src/kvstore/cmd_del_test.go:12
Function
TestDelExistingVal
test that a tombstone value is written
src/redis/cmd_del_test.go:12
Function
TestDelNonExistingVal
(t *testing.T)
src/kvstore/cmd_del_test.go:56
Function
TestDelNonExistingVal
(t *testing.T)
src/redis/cmd_del_test.go:56
Function
TestDelValidation
tests validation of DEL insructions
src/kvstore/cmd_del_test.go:87
Function
TestDelValidation
tests validation of DEL insructions
src/redis/cmd_del_test.go:87
Method
TestDependencyOrdering
(c *gocheck.C)
src/consensus/manager_execute_test.go:265
Method
TestDiscoverPeersRequest
(c *gocheck.C)
src/cluster/message_test.go:65
Method
TestDiscoverPeersResponse
(c *gocheck.C)
src/cluster/message_test.go:72
Method
TestDiscoveryFromExistingPeers
tests that discovering peers from existing peers works properly
src/cluster/cluster_test.go:493
Method
TestDiscoveryFromSeedAddresses
tests that discovering peers from a list of seed addresses works properly
src/cluster/cluster_test.go:353
Method
TestEncoding
(c *gocheck.C)
src/types/b16_test.go:16
Method
TestEncoding
(c *gocheck.C)
src/types/uuid_test.go:16
Method
TestExecuteQueryMessage
tests calling execute query sends correct message
src/cluster/node_test.go:121
Method
TestExecutedFailure
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
Method
TestExecutedSuccess
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
Method
TestExecutedSuccessorResponse
tests that the non successor will commit the local instance if the successor returns an committed instance
src/consensus/manager_prepare_test.go:952
Method
TestExecutingLongStronglyConnectedComponentOrdering
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
Method
TestExistingDependencyMap
tests that existing dependencies object is used if it exists
src/consensus/manager_dependencies_test.go:146
Method
TestExistingRootDependencyMap
tests that an existing dependencies object is used for a key if it exists
src/consensus/manager_dependencies_test.go:44
Method
TestExistingSuccessCase
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
Method
TestExpectedDataIsReturned
(c *gocheck.C)
src/cluster/cluster_test.go:150
Method
TestExpectedDataIsReturnedFromOtherDCs
(c *gocheck.C)
src/cluster/cluster_test.go:168
Method
TestExplicitPrepare
tests that an explicit prepare is initiated on any uncommitted instance in the instance's dependency graph
src/consensus/manager_execute_test.go:144
Method
TestExplicitPrepareBallotFailure
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
Method
TestExplicitPrepareFailure
tests that execute will return an error if a prepare call returns a non ballot related error
src/consensus/manager_execute_test.go:224
Method
TestExplicitPrepareRetry
tests that an explicit prepare is retried if it fails due to a ballot failure
src/consensus/manager_execute_test.go:163
Method
TestExplicitPrepareRetryCondAbort
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
Method
TestExternalDependencySuccess
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
Method
TestFullConnectionReturn
test that connections are closed if the pool is full
src/cluster/connectionpool_test.go:55
Function
TestGet
(t *testing.T)
src/kvstore/cmd_get_test.go:10
Function
TestGet
(t *testing.T)
src/redis/cmd_get_test.go:9
Method
TestGetAndSet
(c *gocheck.C)
src/consensus/instance_test.go:54
Method
TestGetConn
test that open connections are returned
src/cluster/connectionpool_test.go:70
Method
TestGetExistingNode
tests that fetching a node with a valid node id returns the requested node
src/topology/ring_test.go:46
Function
TestGetKeys
(t *testing.T)
src/kvstore/store_test.go:85
← previous
next →
701–800 of 1,093, ranked by callers