Functions — github.com/bdeggleston/kickboxer

hub / github.com/bdeggleston/kickboxer / functions

Functions1,093 in github.com/bdeggleston/kickboxer

⨍ Functions 1,093◇ Types & classes 186

MethodGetValue

()

src/cluster/store_mock.go:114

MethodGetValueType

()

src/kvstore/val_string.go:35

MethodGetValueType

()

src/kvstore/val_tombstone.go:28

MethodGetValueType

()

src/kvstore/val_bool.go:32

MethodGetValueType

()

src/redis/val_string.go:35

MethodGetValueType

()

src/redis/val_tombstone.go:28

MethodGetValueType

()

src/redis/val_bool.go:32

MethodGetValueType

()

src/consensus/testing_mocks.go:35

MethodGetValueType

()

src/cluster/store_mock.go:122

MethodInterferingKeys

returns an array of keys used by consensus to determine which instructions the given instruction set will interfere with. Basically, think of the give

src/store/store.go:46

MethodInterferingKeys

(instruction store.Instruction)

src/kvstore/store.go:154

MethodInterferingKeys

(instruction store.Instruction)

src/consensus/testing_mocks.go:313

MethodInterferingKeys

(instruction store.Instruction)

src/cluster/store_mock.go:85

MethodIsReadOnly

(instruction Instruction)

src/store/store.go:48

MethodIsReadOnly

(instruction store.Instruction)

src/consensus/testing_mocks.go:321

MethodIsReadOnly

(instruction store.Instruction)

src/cluster/store_mock.go:83

MethodIsStarted

()

src/topology/mocks.go:42

MethodIsStarted

()

src/consensus/testing_mocks.go:195

MethodIsStarted

()

src/cluster/node.go:83

MethodIsStarted

()

src/cluster/node.go:153

MethodIsStarted

()

src/cluster/node_mock.go:61

MethodIsWriteOnly

(instruction Instruction)

src/store/store.go:50

MethodIsWriteOnly

(instruction store.Instruction)

src/consensus/testing_mocks.go:329

MethodIsWriteOnly

(instruction store.Instruction)

src/cluster/store_mock.go:84

MethodIsZero

()

src/store/instruction.go:56

MethodKeyExists

(key string)

src/kvstore/store.go:186

MethodKeyExists

(key string)

src/redis/store.go:189

MethodKeyExists

(key string)

src/consensus/testing_mocks.go:340

MethodKeyExists

(key string)

src/cluster/store_mock.go:94

MethodLen

()

src/topology/ring.go:20

MethodLen

()

src/consensus/consensus_test.go:47

MethodLen

()

src/consensus/manager_execute.go:22

MethodLess

returns true if the item at index i is less than the item and index j

src/topology/ring.go:26

MethodLess

(x, y int)

src/consensus/consensus_test.go:51

MethodLess

returns true if the item at index x is less than the item and index y

src/consensus/manager_execute.go:28

MethodLocalAddr

()

src/cluster/testing.go:191

src/consensus/instance_containers.go:149

MethodMoveNode

Changes the given node's token and initiates streaming from new replica nodes When changing the token ring from this: N0 N1 N2 N3

src/cluster/cluster.go:427

MethodName

()

src/topology/mocks.go:37

MethodName

()

src/consensus/testing_mocks.go:193

MethodName

()

src/cluster/node.go:39

FunctionNewMessageEncodingError

(reason string)

src/message/errors.go:15

FunctionNewNodeError

(reason string)

src/cluster/node.go:20

TODO: implement and fix

src/cluster/message_query.go:64

MethodNumBytes

TODO: implement and fix

src/cluster/message_query.go:100

MethodNumBytes

TODO: implement and fix

src/cluster/message_query.go:139

MethodNumBytes

()

src/cluster/message_connect.go:91

MethodNumBytes

()

src/cluster/message_connect.go:121

MethodNumBytes

()

src/cluster/message_connect.go:172

MethodNumBytes

()

src/cluster/message_connect.go:210

MethodNumBytes

()

src/cluster/message_connect.go:235

MethodNumBytes

TODO: implement and fix

src/cluster/message_connect.go:271

MethodNumBytes

()

src/cluster/message_stream.go:29

MethodNumBytes

()

src/cluster/message_stream.go:38

MethodNumBytes

()

src/cluster/message_stream.go:47

MethodNumBytes

()

src/cluster/message_stream.go:56

MethodNumBytes

TODO: implement and fix

src/cluster/message_stream.go:83

MethodNumBytes

()

src/cluster/message_stream.go:126

MethodNumBytes

()

src/cluster/message_stream.go:142

FunctionNumSliceBytes

(b []byte)

src/serializer/serializer.go:104

FunctionNumStringBytes

(s string)

src/serializer/serializer.go:100

FunctionNumTimeBytes

()

src/serializer/serializer.go:108

MethodRead

(_ []byte)

src/cluster/testing.go:206

MethodRead

(b []byte)

src/cluster/testing.go:227

MethodRead

reads outgoing messages to the receiver

src/cluster/testing.go:290

FunctionReadFieldString

(buf *bufio.Reader)

src/serializer/serializer.go:71

FunctionReadMessage

reads a message from the given reader

src/message/io.go:36

FunctionReadTime

reads a time value

src/serializer/serializer.go:88

MethodReconcile

reconciles multiple values and returns instructions for correcting the values on inaccurate nodes Reconcile should handle value maps with one value w

src/kvstore/store.go:107

MethodReconcile

reconciles multiple values and returns instructions for correcting the values on inaccurate nodes Reconcile should handle value maps with one value w

src/redis/store.go:112

MethodReconcile

not implemented

src/consensus/testing_mocks.go:334

MethodReconcile

(key string, values []store.Value)

src/cluster/store_mock.go:75

FunctionRegisterMessage

(mtype uint32, constructor messageConstructor)

src/message/io.go:19

MethodRemoteAddr

()

src/cluster/testing.go:192

MethodRemove

(ids ...InstanceID)

src/consensus/instance_containers.go:71

MethodRemoveID

(id InstanceID)

src/consensus/instance_containers.go:211

MethodRemoveNode

removes the given node from the token ring there are 2 scenarios to deal with in regards to streaming data in: * if the removed node is still reacha

src/cluster/cluster.go:468

MethodReportAcknowledged

When an instance is committed, it has been acknowledged by a quorum of replicas, and it's dependencies can be removed from the dependency manager

src/consensus/manager_depedencies.go:310

MethodReportExecuted

(instance *Instance)

src/consensus/manager_depedencies.go:322

MethodReturnsValue

(cmd string)

src/kvstore/store.go:146

MethodReturnsValue

(cmd string)

src/redis/store.go:151

MethodReturnsValue

(cmd string)

src/cluster/store_mock.go:86

MethodSendMessage

(message.Message)

src/topology/mocks.go:57

MethodSendMessage

(srcRequest message.Message)

src/consensus/testing_mocks.go:107

MethodSendMessage

(m message.Message)

src/cluster/node.go:87

MethodSendMessage

(m message.Message)

src/cluster/node_mock.go:76

MethodSerialize

(buf *bufio.Writer)

src/kvstore/val_string.go:46

MethodSerialize

(buf *bufio.Writer)

src/kvstore/val_tombstone.go:36

MethodSerialize

(buf *bufio.Writer)

src/kvstore/val_bool.go:43

MethodSerialize

(buf *bufio.Writer)

src/redis/val_string.go:46

MethodSerialize

(buf *bufio.Writer)

src/redis/val_tombstone.go:36

MethodSerialize

(buf *bufio.Writer)

src/redis/val_bool.go:43

MethodSerialize

(buf *bufio.Writer)

src/consensus/message.go:50

MethodSerialize

(buf *bufio.Writer)

src/consensus/message.go:107

MethodSerialize

(buf *bufio.Writer)

src/consensus/message.go:170

← previous next →501–600 of 1,093, ranked by callers