MCPcopy Create free account

hub / github.com/Netflix/rend / functions

Functions544 in github.com/Netflix/rend

MethodAppend
(rw *bufio.ReadWriter, key []byte, value []byte)
client/textprot/prot.go:102
MethodAppend
(opaque uint32, quiet bool)
protocol/types.go:42
MethodAppend
(opaque uint32, quiet bool)
protocol/binprot/respond.go:150
MethodAppend
(opaque uint32, quiet bool)
protocol/textprot/respond.go:47
MethodAppend
(cmd common.SetRequest)
handlers/types.go:30
MethodAppend
(cmd common.SetRequest)
handlers/inmem/inmem.go:120
MethodAppend
Append performs an append request on the remote backend
handlers/memcached/chunked/handler.go:338
MethodAppend
Append performs an append request on the remote backend
handlers/memcached/std/handler.go:88
MethodAppend
Append performs an append operation on the backend. It will append the data to the value only if it already exists.
handlers/memcached/batched/handler.go:195
MethodAppend
(req common.SetRequest)
server/default_test.go:86
MethodAppend
(req common.SetRequest)
server/default_test.go:137
MethodAppend
(req common.SetRequest)
orcas/l1only.go:115
MethodAppend
(cmd common.SetRequest)
orcas/util_test.go:56
MethodAppend
(req common.SetRequest)
orcas/l1l2batch.go:221
MethodAppend
(req common.SetRequest)
orcas/locked_test.go:35
MethodAppend
(req common.SetRequest)
orcas/locked.go:175
MethodAppend
(req common.SetRequest)
orcas/l1l2.go:264
MethodBatchGet
(rw *bufio.ReadWriter, keys [][]byte)
client/binprot/prot.go:289
MethodBatchGet
(rw *bufio.ReadWriter, keys [][]byte)
client/textprot/prot.go:177
FunctionBatched
Batched returns an implementation of the Handler interface that multiplexes requests on to a connection pool in order to reduce the overhead per reque
handlers/memcached/constructors.go:63
FunctionBenchmarkHeaders
(b *testing.B)
protocol/binprot/parser_test.go:67
FunctionBenchmarkTagsBuildStringAppend
(b *testing.B)
metrics/tagsbench_test.go:59
FunctionBenchmarkTagsBuildStringByteSlice
(b *testing.B)
metrics/tagsbench_test.go:103
FunctionBenchmarkTagsBuildStringByteSliceDynamicData
(b *testing.B)
metrics/tagsbench_test.go:122
FunctionBenchmarkTagsBuildStringByteSlicePrealloc
(b *testing.B)
metrics/tagsbench_test.go:84
FunctionBenchmarkTimerNow
(b *testing.B)
timer/timer_test.go:87
FunctionBenchmarkTimerSince
(b *testing.B)
timer/timer_test.go:93
FunctionBenchmarkWallTimeNow
(b *testing.B)
timer/timer_test.go:100
FunctionBenchmarkWallTimeSince
(b *testing.B)
timer/timer_test.go:106
MethodCanParse
()
protocol/binprot/components.go:44
MethodCanParse
()
protocol/textprot/components.go:44
FunctionChunked
Chunked returns an implementation of the Handler interface that implements an interaction model which splits data to set size chunks before inserting.
handlers/memcached/constructors.go:47
MethodClose
()
handlers/inmem/inmem.go:302
MethodClose
Close closes the Handler's underlying io.ReadWriteCloser. Any calls to the handler after Close is called are invalid.
handlers/memcached/chunked/handler.go:138
MethodClose
Close closes the Handler's underlying io.ReadWriteCloser. Any calls to the handler after Close is called are invalid.
handlers/memcached/std/handler.go:59
MethodClose
Close does nothing for this Handler as the connections are pooled behind it and are not explicitly controlled.
handlers/memcached/batched/handler.go:102
MethodClose
()
server/default_test.go:30
MethodClose
()
orcas/util_test.go:131
MethodConfigure
(conn net.Conn)
server/listen.go:40
MethodConfigure
(conn net.Conn)
server/listen.go:73
FunctionConnect
(host string, port int)
client/common/utils.go:64
FunctionDecodeError
(header *ResponseHeader)
protocol/binprot/types.go:86
FunctionDefault
Default creates a new *DefaultServer instance with the given connections, request parser, and request orchestrator.
server/default.go:39
MethodDelete
(rw *bufio.ReadWriter, key []byte)
client/binprot/prot.go:319
MethodDelete
(rw *bufio.ReadWriter, key []byte)
client/textprot/prot.go:237
MethodDelete
(opaque uint32)
protocol/types.go:48
MethodDelete
(opaque uint32)
protocol/binprot/respond.go:218
MethodDelete
(opaque uint32)
protocol/textprot/respond.go:106
MethodDelete
(cmd common.DeleteRequest)
handlers/types.go:35
MethodDelete
(cmd common.DeleteRequest)
handlers/inmem/inmem.go:271
MethodDelete
Delete performs a delete request on the remote backend
handlers/memcached/chunked/handler.go:725
MethodDelete
Delete performs a delete request on the remote backend
handlers/memcached/std/handler.go:269
MethodDelete
Delete performs a delete operation on the backend. It will unconditionally remove the value.
handlers/memcached/batched/handler.go:207
MethodDelete
(req common.DeleteRequest)
server/default_test.go:94
MethodDelete
(req common.DeleteRequest)
server/default_test.go:139
MethodDelete
(req common.DeleteRequest)
orcas/l1only.go:169
MethodDelete
(cmd common.DeleteRequest)
orcas/util_test.go:121
MethodDelete
(req common.DeleteRequest)
orcas/l1l2batch.go:345
MethodDelete
(req common.DeleteRequest)
orcas/locked_test.go:37
MethodDelete
(req common.DeleteRequest)
orcas/locked.go:191
MethodDelete
(req common.DeleteRequest)
orcas/l1l2.go:389
MethodError
()
client/binprot/prot.go:33
MethodError
(opaque uint32, reqType common.RequestType, err error, quiet bool)
protocol/textprot/respond.go:129
MethodError
(req common.Request, reqType common.RequestType, err error)
server/default_test.go:130
MethodError
(req common.Request, reqType common.RequestType, err error)
server/default_test.go:149
MethodError
(req common.Request, reqType common.RequestType, err error)
orcas/l1only.go:398
MethodError
(req common.Request, reqType common.RequestType, err error)
orcas/l1l2batch.go:709
MethodError
(req common.Request, reqType common.RequestType, err error)
orcas/locked_test.go:47
MethodError
(req common.Request, reqType common.RequestType, err error)
orcas/locked.go:341
MethodError
(req common.Request, reqType common.RequestType, err error)
orcas/l1l2.go:896
FunctionExp
get a random expiration
client/common/utils.go:82
MethodGAT
(rw *bufio.ReadWriter, key []byte)
client/binprot/prot.go:305
MethodGAT
(rw *bufio.ReadWriter, key []byte)
client/textprot/prot.go:231
MethodGAT
(response common.GetResponse)
protocol/types.go:47
MethodGAT
(response common.GetResponse)
protocol/binprot/respond.go:185
MethodGAT
(response common.GetResponse)
protocol/textprot/respond.go:95
MethodGAT
(cmd common.GATRequest)
handlers/inmem/inmem.go:237
MethodGAT
GAT performs a get-and-touch request on the remote backend
handlers/memcached/chunked/handler.go:621
MethodGAT
GAT performs a get-and-touch request on the remote backend
handlers/memcached/std/handler.go:237
MethodGAT
GAT performs a get-and-touch on the backend for the given key. It will retrieve the value while updating the TTL to the one supplied.
handlers/memcached/batched/handler.go:231
MethodGAT
(cmd common.GATRequest)
orcas/util_test.go:116
MethodGat
(req common.GATRequest)
server/default_test.go:110
MethodGat
(req common.GATRequest)
server/default_test.go:143
MethodGat
(req common.GATRequest)
orcas/l1only.go:350
MethodGat
(req common.GATRequest)
orcas/l1l2batch.go:624
MethodGat
(req common.GATRequest)
orcas/locked_test.go:41
MethodGat
(req common.GATRequest)
orcas/locked.go:317
MethodGat
(req common.GATRequest)
orcas/l1l2.go:717
FunctionGet
Accepts a sorted slice of durations in nanoseconds Returns a Stats struct of millisecond statistics
client/stats/stats.go:35
MethodGet
(rw *bufio.ReadWriter, key []byte)
client/binprot/prot.go:253
MethodGet
(response common.GetResponse)
protocol/binprot/respond.go:164
MethodGet
(response common.GetResponse)
protocol/textprot/respond.go:55
MethodGet
(cmd common.GetRequest)
handlers/inmem/inmem.go:162
MethodGet
Get performs a batched get request on the remote backend. The channels returned are expected to be read from until either a single error is received o
handlers/memcached/chunked/handler.go:468
MethodGet
Get performs a batched get request on the remote backend. The channels returned are expected to be read from until either a single error is received o
handlers/memcached/std/handler.go:137
MethodGet
Get performs a get operation on the backend. It retrieves the whole of the batch of keys given as a group and returns them one at a time over the requ
handlers/memcached/batched/handler.go:298
MethodGet
(req common.GetRequest)
server/default_test.go:102
MethodGet
(req common.GetRequest)
server/default_test.go:141
MethodGet
(req common.GetRequest)
orcas/l1only.go:223
MethodGet
(cmd common.GetRequest)
orcas/util_test.go:66
← previousnext →201–300 of 544, ranked by callers