MCPcopy Create free account

hub / github.com/Netflix/rend / functions

Functions544 in github.com/Netflix/rend

MethodGet
(req common.GetRequest)
orcas/l1l2batch.go:475
MethodGet
(req common.GetRequest)
orcas/locked_test.go:39
MethodGet
(req common.GetRequest)
orcas/locked.go:207
MethodGet
(req common.GetRequest)
orcas/l1l2.go:524
MethodGetE
(rw *bufio.ReadWriter, key []byte)
client/binprot/prot.go:265
MethodGetE
(response common.GetEResponse)
protocol/types.go:46
MethodGetE
(response common.GetEResponse)
protocol/binprot/respond.go:196
MethodGetE
(response common.GetEResponse)
protocol/textprot/respond.go:91
MethodGetE
(cmd common.GetRequest)
handlers/types.go:33
MethodGetE
(cmd common.GetRequest)
handlers/inmem/inmem.go:199
MethodGetE
GetE performs a batched gete request on the remote backend. The channels returned are expected to be read from until either a single error is received
handlers/memcached/chunked/handler.go:606
MethodGetE
GetE performs a batched gete request on the remote backend. The channels returned are expected to be read from until either a single error is received
handlers/memcached/std/handler.go:187
MethodGetE
GetE performs a get-with-expiration on the backend. It is a custom command only implemented in Rend. It retrieves the whole batch of keys given as a g
handlers/memcached/batched/handler.go:383
MethodGetE
(req common.GetRequest)
server/default_test.go:106
MethodGetE
(req common.GetRequest)
server/default_test.go:142
MethodGetE
(req common.GetRequest)
orcas/l1only.go:285
MethodGetE
(cmd common.GetRequest)
orcas/util_test.go:91
MethodGetE
(req common.GetRequest)
orcas/l1l2batch.go:618
MethodGetE
(req common.GetRequest)
orcas/locked_test.go:40
MethodGetE
(req common.GetRequest)
orcas/locked.go:261
MethodGetE
(req common.GetRequest)
orcas/l1l2.go:711
MethodGetEnd
(opaque uint32, noopEnd bool)
protocol/binprot/respond.go:175
MethodGetEnd
(opaque uint32, noopEnd bool)
protocol/textprot/respond.go:87
MethodGetOpaque
()
common/datatypes.go:152
MethodGetOpaque
()
common/datatypes.go:171
MethodGetOpaque
()
common/datatypes.go:190
MethodGetOpaque
()
common/datatypes.go:207
MethodGetOpaque
()
common/datatypes.go:224
MethodGetOpaque
()
common/datatypes.go:239
MethodGetOpaque
()
common/datatypes.go:253
MethodGetOpaque
()
common/datatypes.go:267
MethodGetWithOpaque
(rw *bufio.ReadWriter, key []byte, opaque int)
client/binprot/prot.go:277
MethodGetWithOpaque
(rw *bufio.ReadWriter, key []byte, opaque int)
client/textprot/prot.go:124
FunctionIncCounter
IncCounter increases the specified counter by 1. Only values returned by AddCounter can be used. Arbitrary values may panic or have undefined behavior
metrics/counters.go:60
FunctionIncCounterBy
IncCounterBy increments the specified counter by the given amount. This is for situations where the count is not a one by one thing, like counting byt
metrics/counters.go:66
FunctionIsAppError
IsAppError differentiates between protocol-defined errors that are relatively benign and other fatal errors like an IO error because of some socket pr
common/datatypes.go:68
MethodIsQuiet
()
common/datatypes.go:156
MethodIsQuiet
()
common/datatypes.go:178
MethodIsQuiet
()
common/datatypes.go:194
MethodIsQuiet
()
common/datatypes.go:211
MethodIsQuiet
()
common/datatypes.go:228
MethodIsQuiet
()
common/datatypes.go:243
MethodIsQuiet
()
common/datatypes.go:257
MethodIsQuiet
()
common/datatypes.go:271
FunctionL1L2
(l1, l2 handlers.Handler, res protocol.Responder)
orcas/l1l2.go:33
FunctionL1L2Batch
(l1, l2 handlers.Handler, res protocol.Responder)
orcas/l1l2batch.go:33
FunctionL1Only
(l1, l2 handlers.Handler, res protocol.Responder)
orcas/l1only.go:30
MethodLen
()
metrics/endpoint.go:251
MethodLess
(i, j int)
metrics/endpoint.go:253
FunctionListenAndServe
ListenAndServe is the main accept() loop of a server. It will use all of the components passed in to construct a full set of components to serve a con
server/listen.go:114
FunctionLocked
Locking wraps an orcas.Orca to provide locking around operations on the same key. When multipleReaders is true, operations will allow many readers and
orcas/locked.go:77
FunctionLockedWithExisting
(oc OrcaConst, locksetID uint32)
orcas/locked.go:103
MethodLoop
Loop acts as a master loop for the connection that it is given. Requests are read using the given protocol.RequestParser and performed by the given or
server/default.go:50
FunctionNew
()
handlers/inmem/inmem.go:45
MethodNewDisambiguator
(p protocol.Peeker)
protocol/binprot/components.go:36
MethodNewDisambiguator
(p protocol.Peeker)
protocol/textprot/components.go:36
FunctionNewHandler
NewHandler returns an implementation of handlers.Handler that implements a special interaction with the memcached server to pack data into fixed-size
handlers/memcached/chunked/handler.go:123
FunctionNewHandler
NewHandler returns an implementation of handlers.Handler that implements a straightforward request-response like normal memcached usage.
handlers/memcached/std/handler.go:49
FunctionNewHandler
NewHandler creates a new handler with the given unix socket as the connected backend. The first time this method is called it creates a background mon
handlers/memcached/batched/handler.go:84
MethodNewRequestParser
(r *bufio.Reader)
protocol/binprot/components.go:28
MethodNewRequestParser
(r *bufio.Reader)
protocol/textprot/components.go:28
MethodNewResponder
(w *bufio.Writer)
protocol/binprot/components.go:32
MethodNewResponder
(w *bufio.Writer)
protocol/textprot/components.go:32
FunctionNilHandler
NilHandler is used as a placeholder for when there is no handler needed. Since the Server API is a composition of a few things, including Handlers, th
handlers/types.go:24
MethodNoop
(opaque uint32)
protocol/types.go:50
MethodNoop
(opaque uint32)
protocol/binprot/respond.go:226
MethodNoop
(opaque uint32)
protocol/textprot/respond.go:114
MethodNoop
(req common.NoopRequest)
server/default_test.go:114
MethodNoop
(req common.NoopRequest)
server/default_test.go:144
MethodNoop
(req common.NoopRequest)
orcas/l1only.go:382
MethodNoop
(req common.NoopRequest)
orcas/l1l2batch.go:693
MethodNoop
(req common.NoopRequest)
orcas/locked_test.go:42
MethodNoop
(req common.NoopRequest)
orcas/locked.go:325
MethodNoop
(req common.NoopRequest)
orcas/l1l2.go:880
FunctionNow
()
timer/timer_fallback.go:23
FunctionObserveHist
ObserveHist adds an observation to the given histogram. The id parameter is a handle returned by the AddHistogram method. Using numbers not returned b
metrics/histograms.go:252
MethodParse
Gets can be pipelined by sending many headers at once to the server. In this case, it is to our advantage to read as many as we can before replying to
protocol/binprot/parser.go:128
MethodParse
()
protocol/textprot/parser.go:39
MethodParse
On first call, returns the values in the testRequestParser On second call, always returns io.EOF
server/default_test.go:46
MethodPrepend
(rw *bufio.ReadWriter, key, value []byte)
client/binprot/prot.go:236
MethodPrepend
(rw *bufio.ReadWriter, key []byte, value []byte)
client/textprot/prot.go:113
MethodPrepend
(opaque uint32, quiet bool)
protocol/types.go:43
MethodPrepend
(opaque uint32, quiet bool)
protocol/binprot/respond.go:157
MethodPrepend
(opaque uint32, quiet bool)
protocol/textprot/respond.go:51
MethodPrepend
(cmd common.SetRequest)
handlers/types.go:31
MethodPrepend
(cmd common.SetRequest)
handlers/inmem/inmem.go:141
MethodPrepend
Prepend performs a prepend request on the remote backend
handlers/memcached/chunked/handler.go:343
MethodPrepend
Prepend performs a prepend request on the remote backend
handlers/memcached/std/handler.go:96
MethodPrepend
Prepend performs a prepend operation on the backend. It will prepend the data to the value only if it already exists.
handlers/memcached/batched/handler.go:201
MethodPrepend
(req common.SetRequest)
server/default_test.go:90
MethodPrepend
(req common.SetRequest)
server/default_test.go:138
MethodPrepend
(req common.SetRequest)
orcas/l1only.go:142
MethodPrepend
(cmd common.SetRequest)
orcas/util_test.go:61
MethodPrepend
(req common.SetRequest)
orcas/l1l2batch.go:288
MethodPrepend
(req common.SetRequest)
orcas/locked_test.go:36
MethodPrepend
(req common.SetRequest)
orcas/locked.go:183
MethodPrepend
(req common.SetRequest)
orcas/l1l2.go:332
FunctionPrintHist
Accepts a sorted slice of durations in nanoseconds Prints a histogram to stdout
client/stats/stats.go:89
FunctionPutResponseHeader
PutResponseHeader returns the response header to the pool
protocol/binprot/headers.go:90
MethodQuit
(opaque uint32, quiet bool)
protocol/types.go:51
← previousnext →301–400 of 544, ranked by callers