MCPcopy Create free account

hub / github.com/bdeggleston/kickboxer / functions

Functions1,093 in github.com/bdeggleston/kickboxer

MethodDeserialize
(*bufio.Reader)
src/cluster/message_stream.go:45
MethodDeserialize
(*bufio.Reader)
src/cluster/message_stream.go:54
MethodDeserialize
(buf *bufio.Reader)
src/cluster/message_stream.go:72
MethodDeserialize
(buf *bufio.Reader)
src/cluster/message_stream.go:112
MethodDeserialize
(*bufio.Reader)
src/cluster/message_stream.go:140
MethodDeserialize
(buf *bufio.Reader)
src/cluster/store_mock.go:145
MethodDeserializeValue
(b []byte)
src/kvstore/store.go:54
MethodDeserializeValue
(b []byte)
src/redis/store.go:53
MethodDeserializeValue
(b []byte)
src/consensus/testing_mocks.go:336
MethodDeserializeValue
(b []byte)
src/cluster/store_mock.go:90
MethodEqual
(value store.Value)
src/consensus/testing_mocks.go:37
MethodEqual
(o store.Value)
src/cluster/store_mock.go:125
MethodError
()
src/message/errors.go:7
MethodError
()
src/consensus/errors.go:12
MethodError
()
src/consensus/errors.go:39
MethodError
()
src/cluster/message.go:7
MethodError
()
src/cluster/testing.go:198
MethodError
()
src/cluster/cluster.go:511
MethodError
()
src/cluster/cluster.go:515
MethodError
()
src/cluster/cluster.go:517
MethodError
()
src/node/node.go:29
MethodExecuteInstruction
(instruction store.Instruction)
src/kvstore/store.go:69
MethodExecuteInstruction
(instruction store.Instruction)
src/consensus/testing_mocks.go:298
MethodExecuteInstruction
executes a write instruction against the node's store
src/cluster/store_mock.go:62
MethodExecuteQuery
(cmd string, key string, args []string, timestamp time.Time)
src/topology/mocks.go:54
MethodExecuteQuery
(cmd string, key string, args []string, timestamp time.Time)
src/consensus/testing_mocks.go:102
MethodExecuteQuery
executes a write instruction against the node's store
src/cluster/node.go:93
MethodExecuteQuery
executes a write instruction against the node's store
src/cluster/node.go:228
MethodExecuteQuery
executes a write instruction against the node's store
src/cluster/node_mock.go:66
MethodExecuteQuery
(cmd string, key string, args []string, timestamp time.Time)
src/node/node.go:37
MethodExecuteRead
executes a read against the cluster
src/cluster/cluster.go:574
MethodExecuteWrite
executes a write against the cluster
src/cluster/cluster.go:697
MethodGaugeDelta
(stat string, value int64, rate float32)
src/consensus/testing_mocks.go:259
MethodGetAddr
()
src/topology/mocks.go:38
MethodGetAddr
()
src/consensus/testing_mocks.go:194
MethodGetAddr
()
src/cluster/server.go:128
MethodGetAddr
()
src/cluster/node.go:41
MethodGetAndSetDeps
(instance *Instance)
src/consensus/manager_depedencies.go:297
MethodGetBallot
()
src/consensus/message.go:83
MethodGetBallot
()
src/consensus/message.go:218
MethodGetDatacenterId
()
src/topology/mocks.go:40
MethodGetDatacenterId
()
src/consensus/testing_mocks.go:197
MethodGetDatacenterId
()
src/cluster/node.go:47
MethodGetID
returns the id of the cluster
src/clusterproto/clusterproto.go:30
MethodGetId
()
src/topology/mocks.go:36
MethodGetId
()
src/consensus/testing_mocks.go:100
MethodGetId
()
src/cluster/node.go:45
MethodGetKeys
returns all of the keys held by the store, including keys containing tombstones
src/kvstore/store.go:178
MethodGetKeys
returns all of the keys held by the store, including keys containing tombstones
src/redis/store.go:179
MethodGetKeys
()
src/consensus/testing_mocks.go:339
MethodGetKeys
()
src/cluster/store_mock.go:93
MethodGetNode
(nid node.NodeId)
src/topology/topology.go:100
MethodGetNodesForKey
returns the replicas for the given key at the given constistency level
src/clusterproto/clusterproto.go:37
MethodGetNodesForToken
returns a map of datacenter ids -> replica nodes
src/topology/datacenter.go:83
MethodGetRawKey
----------- data import / export ----------- blindly gets the contents of the given key
src/kvstore/store.go:162
MethodGetRawKey
----------- data import / export ----------- blindly gets the contents of the given key
src/redis/store.go:163
MethodGetRawKey
(key string)
src/consensus/testing_mocks.go:337
MethodGetRawKey
(key string)
src/cluster/store_mock.go:91
MethodGetRing
(dcId DatacenterID)
src/topology/datacenter.go:71
MethodGetStatus
()
src/topology/mocks.go:41
MethodGetStatus
()
src/consensus/testing_mocks.go:198
MethodGetStatus
()
src/cluster/node.go:49
MethodGetStore
returns the cluster's store
src/clusterproto/clusterproto.go:33
MethodGetTimestamp
()
src/kvstore/val_tombstone.go:24
MethodGetTimestamp
()
src/kvstore/val_bool.go:28
MethodGetTimestamp
()
src/redis/val_tombstone.go:24
MethodGetTimestamp
()
src/redis/val_bool.go:28
MethodGetTimestamp
()
src/consensus/testing_mocks.go:34
MethodGetTimestamp
()
src/cluster/store_mock.go:118
MethodGetToken
()
src/topology/mocks.go:39
MethodGetToken
(key string)
src/topology/topology.go:119
MethodGetToken
(key string)
src/partitioner/partitioner.go:6
MethodGetToken
()
src/consensus/testing_mocks.go:196
MethodGetToken
()
src/cluster/node.go:43
MethodGetType
()
src/consensus/message.go:44
MethodGetType
()
src/consensus/message.go:84
MethodGetType
()
src/consensus/message.go:153
MethodGetType
()
src/consensus/message.go:219
MethodGetType
()
src/consensus/message.go:245
MethodGetType
()
src/consensus/message.go:275
MethodGetType
()
src/consensus/message.go:305
MethodGetType
()
src/consensus/message.go:329
MethodGetType
()
src/consensus/message.go:385
MethodGetType
()
src/consensus/message.go:412
MethodGetType
()
src/consensus/message.go:454
MethodGetType
()
src/consensus/message.go:510
MethodGetType
()
src/cluster/message_query.go:61
MethodGetType
()
src/cluster/message_query.go:97
MethodGetType
()
src/cluster/message_query.go:136
MethodGetType
()
src/cluster/message_connect.go:119
MethodGetType
()
src/cluster/message_connect.go:170
MethodGetType
()
src/cluster/message_connect.go:208
MethodGetType
()
src/cluster/message_connect.go:233
MethodGetType
()
src/cluster/message_connect.go:268
MethodGetType
()
src/cluster/message_stream.go:28
MethodGetType
()
src/cluster/message_stream.go:37
MethodGetType
()
src/cluster/message_stream.go:46
MethodGetType
()
src/cluster/message_stream.go:55
MethodGetType
()
src/cluster/message_stream.go:124
MethodGetType
()
src/cluster/message_stream.go:141
← previousnext →401–500 of 1,093, ranked by callers