MCPcopy Create free account

hub / github.com/bdeggleston/kickboxer / types & classes

Types & classes186 in github.com/bdeggleston/kickboxer

↓ 7 callersTypeAliasConsistencyLevel
src/clusterproto/clusterproto.go:15
↓ 7 callersTypeAliasConsistencyLevel
src/cluster/cluster.go:36
↓ 6 callersTypeAliasDatacenterID
** What happens when a new datacenter joins? * both clusters collect information about each other * streaming needs to be reworked to reconcile inc
src/topology/datacenter.go:27
↓ 4 callersTypeAliasToken
src/partitioner/partitioner.go:3
↓ 3 callersTypeAliasClusterStatus
src/cluster/cluster.go:28
↓ 3 callersTypeAliasNodeStatus
src/topology/node.go:8
↓ 2 callersInterfaceBallotMessage
src/consensus/message.go:13
↓ 2 callersStructUUID
wraps up the google uuid library and stores values as 2 uint64 values
src/types/uuid.go:22
↓ 1 callersTypeAliasInstanceStatus
src/consensus/instance.go:18
↓ 1 callersInterfaceNode
src/topology/node.go:16
↓ 1 callersTypeAliasnodeTimeoutError
src/cluster/cluster.go:516
StructAcceptInstanceTest
src/consensus/manager_accept_test.go:17
StructAcceptIntegrationTest
src/consensus/integration_test.go:118
StructAcceptLeaderTest
src/consensus/manager_accept_test.go:142
StructAcceptReplicaTest
** replica **/
src/consensus/manager_accept_test.go:285
StructAcceptRequest
src/consensus/message.go:140
StructAcceptResponse
src/consensus/message.go:194
StructAddNodeTest
************** addNode tests **************/
src/cluster/cluster_test.go:90
StructB16
16 byte value
src/types/b16.go:8
StructB16Test
src/types/b16_test.go:12
StructBallotError
returned if a request fails due to the request ballot being old
src/consensus/errors.go:20
StructBoolean
src/kvstore/val_bool.go:11
StructBoolean
src/redis/val_bool.go:11
InterfaceCluster
defines relevant cluster methods
src/clusterproto/clusterproto.go:28
StructCluster
src/cluster/cluster.go:48
StructClusterMessageTest
src/cluster/message_test.go:20
StructClusterStartupTest
************** startup tests **************/
src/cluster/cluster_test.go:209
StructClusterTest
src/cluster/cluster_test.go:39
StructCommitInstanceTest
src/consensus/manager_commit_test.go:17
StructCommitIntegrationTest
src/consensus/integration_test.go:174
StructCommitLeaderTest
** leader **/
src/consensus/manager_commit_test.go:152
StructCommitReplicaTest
src/consensus/manager_commit_test.go:235
StructCommitRequest
src/consensus/message.go:237
StructCommitResponse
src/consensus/message.go:267
StructConnection
encapsulates a remote connection
src/cluster/connection.go:11
StructConnectionAcceptedResponse
src/cluster/message_connect.go:123
StructConnectionPool
pools connections to a single host
src/cluster/connection.go:67
StructConnectionPoolTest
src/cluster/connectionpool_test.go:11
StructConnectionRefusedResponse
src/cluster/message_connect.go:191
StructConnectionRequest
sent when connecting to another node
src/cluster/message_connect.go:113
StructConsensusMessageTest
src/consensus/message_test.go:16
StructConsensusQueryBenchmarks
src/consensus/consensus_test.go:59
StructDatacenterContainer
src/topology/datacenter.go:29
StructDatacenterTest
src/topology/datacenter_test.go:35
StructDependenciesTest
src/consensus/manager_dependencies_test.go:124
StructDependencyMapTest
src/consensus/manager_dependencies_test.go:23
StructDepsLog
src/consensus/instance.go:68
StructDiscoverPeerResponse
src/cluster/message_connect.go:237
StructDiscoverPeersRequest
asks other nodes for peer info
src/cluster/message_connect.go:215
StructExecuteApplyInstanceTest
src/consensus/manager_execute_test.go:677
StructExecuteDependencyChainTest
src/consensus/manager_execute_test.go:252
StructExecuteInstanceTest
src/consensus/manager_execute_test.go:80
StructHandlePrepareSuccessorRequestTest
src/consensus/manager_prepare_test.go:1014
ClassInstance
pydebug/debug.py:38
StructInstance
a serializable set of instructions
src/consensus/instance.go:74
StructInstanceID
src/consensus/instance.go:44
TypeAliasInstanceIDSet
src/consensus/instance_containers.go:9
StructInstanceMap
src/consensus/instance_containers.go:153
StructInstanceMapTest
src/consensus/instance_test.go:50
StructInstanceRequest
src/consensus/message.go:448
StructInstanceResponse
src/consensus/message.go:490
StructInstanceResult
src/consensus/instance.go:52
TypeAliasInstanceResultChan
src/consensus/instance.go:57
StructInstanceSerializationTest
src/consensus/instance_test.go:134
StructInstanceSetTest
src/consensus/instance_test.go:18
StructInstanceTest
src/consensus/instance_test.go:170
StructInstruction
an instruction to be executed against the store. These objects should be considered immutable once instantiated
src/store/instruction.go:16
StructInstructionTest
src/store/instruction_test.go:13
StructInvalidStatusUpdateError
returned if a request is aborted because it's no longer valid (ie: running a prepare phase on a committed instance)
src/consensus/errors.go:33
StructJoinStreamTest
src/cluster/cluster_join_test.go:10
StructKVStore
src/kvstore/store.go:27
StructLeaderTest
src/consensus/manager_leader_test.go:10
StructLocalNode
LocalNode provides access to the local store
src/cluster/node.go:52
StructLocalNodeTest
************** local tests **************/
src/cluster/node_test.go:17
StructMD5Partitioner
partitions on a keys md5 hash
src/partitioner/md5.go:8
StructMD5PartitionerTest
src/partitioner/md5_test.go:7
StructManager
replica level manager for consensus operations
src/consensus/manager.go:156
StructManagerExecuteQueryTest
src/consensus/manager_test.go:188
StructManagerTest
src/consensus/manager_test.go:56
InterfaceMessage
message wire protocol is as follow: [type (4b)][num fields (4b)]...[field size (4b)][field data] each message type can define the data format as neede
src/message/message.go:11
StructMessageEncodingError
src/message/errors.go:11
StructMessageEncodingError
src/cluster/message.go:11
StructMessageError
src/message/errors.go:3
StructMessageError
src/cluster/message.go:3
InterfaceNode
the basic node interface
src/node/node.go:34
StructNodeError
src/cluster/node.go:16
StructNodeError
src/node/node.go:21
StructNodeId
src/node/node.go:13
InterfacePartitioner
src/partitioner/partitioner.go:5
StructPeerData
----------- startup and connection -----------
src/cluster/message_connect.go:29
StructPeerDataTest
************** getPeerData tests **************/
src/cluster/cluster_test.go:146
StructPeerDiscoveryTest
* TODO: how to maintain token rings and maps without locks? LOCKS * we need to be able to run multiple requests of any type concurrently * we
src/cluster/cluster_test.go:277
StructPeerServer
src/cluster/server.go:13
StructPreAcceptInstanceTest
src/consensus/manager_preaccept_test.go:17
StructPreAcceptIntegrationTest
src/consensus/integration_test.go:40
StructPreAcceptLeaderTest
src/consensus/manager_preaccept_test.go:114
StructPreAcceptReplicaTest
src/consensus/manager_preaccept_test.go:334
StructPreAcceptRequest
src/consensus/message.go:38
StructPreAcceptResponse
src/consensus/message.go:61
StructPrepareAnalyzeResponsesTest
tests the analyzePrepareResponses method
src/consensus/manager_prepare_test.go:193
next →1–100 of 186, ranked by callers