Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/bdeggleston/kickboxer
/ types & classes
Types & classes
186 in github.com/bdeggleston/kickboxer
⨍
Functions
1,093
◇
Types & classes
186
↓ 7 callers
TypeAlias
ConsistencyLevel
src/clusterproto/clusterproto.go:15
↓ 7 callers
TypeAlias
ConsistencyLevel
src/cluster/cluster.go:36
↓ 6 callers
TypeAlias
DatacenterID
** 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 callers
TypeAlias
Token
src/partitioner/partitioner.go:3
↓ 3 callers
TypeAlias
ClusterStatus
src/cluster/cluster.go:28
↓ 3 callers
TypeAlias
NodeStatus
src/topology/node.go:8
↓ 2 callers
Interface
BallotMessage
src/consensus/message.go:13
↓ 2 callers
Struct
UUID
wraps up the google uuid library and stores values as 2 uint64 values
src/types/uuid.go:22
↓ 1 callers
TypeAlias
InstanceStatus
src/consensus/instance.go:18
↓ 1 callers
Interface
Node
src/topology/node.go:16
↓ 1 callers
TypeAlias
nodeTimeoutError
src/cluster/cluster.go:516
Struct
AcceptInstanceTest
src/consensus/manager_accept_test.go:17
Struct
AcceptIntegrationTest
src/consensus/integration_test.go:118
Struct
AcceptLeaderTest
src/consensus/manager_accept_test.go:142
Struct
AcceptReplicaTest
** replica **/
src/consensus/manager_accept_test.go:285
Struct
AcceptRequest
src/consensus/message.go:140
Struct
AcceptResponse
src/consensus/message.go:194
Struct
AddNodeTest
************** addNode tests **************/
src/cluster/cluster_test.go:90
Struct
B16
16 byte value
src/types/b16.go:8
Struct
B16Test
src/types/b16_test.go:12
Struct
BallotError
returned if a request fails due to the request ballot being old
src/consensus/errors.go:20
Struct
Boolean
src/kvstore/val_bool.go:11
Struct
Boolean
src/redis/val_bool.go:11
Interface
Cluster
defines relevant cluster methods
src/clusterproto/clusterproto.go:28
Struct
Cluster
src/cluster/cluster.go:48
Struct
ClusterMessageTest
src/cluster/message_test.go:20
Struct
ClusterStartupTest
************** startup tests **************/
src/cluster/cluster_test.go:209
Struct
ClusterTest
src/cluster/cluster_test.go:39
Struct
CommitInstanceTest
src/consensus/manager_commit_test.go:17
Struct
CommitIntegrationTest
src/consensus/integration_test.go:174
Struct
CommitLeaderTest
** leader **/
src/consensus/manager_commit_test.go:152
Struct
CommitReplicaTest
src/consensus/manager_commit_test.go:235
Struct
CommitRequest
src/consensus/message.go:237
Struct
CommitResponse
src/consensus/message.go:267
Struct
Connection
encapsulates a remote connection
src/cluster/connection.go:11
Struct
ConnectionAcceptedResponse
src/cluster/message_connect.go:123
Struct
ConnectionPool
pools connections to a single host
src/cluster/connection.go:67
Struct
ConnectionPoolTest
src/cluster/connectionpool_test.go:11
Struct
ConnectionRefusedResponse
src/cluster/message_connect.go:191
Struct
ConnectionRequest
sent when connecting to another node
src/cluster/message_connect.go:113
Struct
ConsensusMessageTest
src/consensus/message_test.go:16
Struct
ConsensusQueryBenchmarks
src/consensus/consensus_test.go:59
Struct
DatacenterContainer
src/topology/datacenter.go:29
Struct
DatacenterTest
src/topology/datacenter_test.go:35
Struct
DependenciesTest
src/consensus/manager_dependencies_test.go:124
Struct
DependencyMapTest
src/consensus/manager_dependencies_test.go:23
Struct
DepsLog
src/consensus/instance.go:68
Struct
DiscoverPeerResponse
src/cluster/message_connect.go:237
Struct
DiscoverPeersRequest
asks other nodes for peer info
src/cluster/message_connect.go:215
Struct
ExecuteApplyInstanceTest
src/consensus/manager_execute_test.go:677
Struct
ExecuteDependencyChainTest
src/consensus/manager_execute_test.go:252
Struct
ExecuteInstanceTest
src/consensus/manager_execute_test.go:80
Struct
HandlePrepareSuccessorRequestTest
src/consensus/manager_prepare_test.go:1014
Class
Instance
pydebug/debug.py:38
Struct
Instance
a serializable set of instructions
src/consensus/instance.go:74
Struct
InstanceID
src/consensus/instance.go:44
TypeAlias
InstanceIDSet
src/consensus/instance_containers.go:9
Struct
InstanceMap
src/consensus/instance_containers.go:153
Struct
InstanceMapTest
src/consensus/instance_test.go:50
Struct
InstanceRequest
src/consensus/message.go:448
Struct
InstanceResponse
src/consensus/message.go:490
Struct
InstanceResult
src/consensus/instance.go:52
TypeAlias
InstanceResultChan
src/consensus/instance.go:57
Struct
InstanceSerializationTest
src/consensus/instance_test.go:134
Struct
InstanceSetTest
src/consensus/instance_test.go:18
Struct
InstanceTest
src/consensus/instance_test.go:170
Struct
Instruction
an instruction to be executed against the store. These objects should be considered immutable once instantiated
src/store/instruction.go:16
Struct
InstructionTest
src/store/instruction_test.go:13
Struct
InvalidStatusUpdateError
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
Struct
JoinStreamTest
src/cluster/cluster_join_test.go:10
Struct
KVStore
src/kvstore/store.go:27
Struct
LeaderTest
src/consensus/manager_leader_test.go:10
Struct
LocalNode
LocalNode provides access to the local store
src/cluster/node.go:52
Struct
LocalNodeTest
************** local tests **************/
src/cluster/node_test.go:17
Struct
MD5Partitioner
partitions on a keys md5 hash
src/partitioner/md5.go:8
Struct
MD5PartitionerTest
src/partitioner/md5_test.go:7
Struct
Manager
replica level manager for consensus operations
src/consensus/manager.go:156
Struct
ManagerExecuteQueryTest
src/consensus/manager_test.go:188
Struct
ManagerTest
src/consensus/manager_test.go:56
Interface
Message
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
Struct
MessageEncodingError
src/message/errors.go:11
Struct
MessageEncodingError
src/cluster/message.go:11
Struct
MessageError
src/message/errors.go:3
Struct
MessageError
src/cluster/message.go:3
Interface
Node
the basic node interface
src/node/node.go:34
Struct
NodeError
src/cluster/node.go:16
Struct
NodeError
src/node/node.go:21
Struct
NodeId
src/node/node.go:13
Interface
Partitioner
src/partitioner/partitioner.go:5
Struct
PeerData
----------- startup and connection -----------
src/cluster/message_connect.go:29
Struct
PeerDataTest
************** getPeerData tests **************/
src/cluster/cluster_test.go:146
Struct
PeerDiscoveryTest
* 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
Struct
PeerServer
src/cluster/server.go:13
Struct
PreAcceptInstanceTest
src/consensus/manager_preaccept_test.go:17
Struct
PreAcceptIntegrationTest
src/consensus/integration_test.go:40
Struct
PreAcceptLeaderTest
src/consensus/manager_preaccept_test.go:114
Struct
PreAcceptReplicaTest
src/consensus/manager_preaccept_test.go:334
Struct
PreAcceptRequest
src/consensus/message.go:38
Struct
PreAcceptResponse
src/consensus/message.go:61
Struct
PrepareAnalyzeResponsesTest
tests the analyzePrepareResponses method
src/consensus/manager_prepare_test.go:193
next →
1–100 of 186, ranked by callers