Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Netflix/rend
/ functions
Functions
544 in github.com/Netflix/rend
⨍
Functions
544
◇
Types & classes
88
Method
Get
(req common.GetRequest)
orcas/l1l2batch.go:475
Method
Get
(req common.GetRequest)
orcas/locked_test.go:39
Method
Get
(req common.GetRequest)
orcas/locked.go:207
Method
Get
(req common.GetRequest)
orcas/l1l2.go:524
Method
GetE
(rw *bufio.ReadWriter, key []byte)
client/binprot/prot.go:265
Method
GetE
(response common.GetEResponse)
protocol/types.go:46
Method
GetE
(response common.GetEResponse)
protocol/binprot/respond.go:196
Method
GetE
(response common.GetEResponse)
protocol/textprot/respond.go:91
Method
GetE
(cmd common.GetRequest)
handlers/types.go:33
Method
GetE
(cmd common.GetRequest)
handlers/inmem/inmem.go:199
Method
GetE
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
Method
GetE
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
Method
GetE
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
Method
GetE
(req common.GetRequest)
server/default_test.go:106
Method
GetE
(req common.GetRequest)
server/default_test.go:142
Method
GetE
(req common.GetRequest)
orcas/l1only.go:285
Method
GetE
(cmd common.GetRequest)
orcas/util_test.go:91
Method
GetE
(req common.GetRequest)
orcas/l1l2batch.go:618
Method
GetE
(req common.GetRequest)
orcas/locked_test.go:40
Method
GetE
(req common.GetRequest)
orcas/locked.go:261
Method
GetE
(req common.GetRequest)
orcas/l1l2.go:711
Method
GetEnd
(opaque uint32, noopEnd bool)
protocol/binprot/respond.go:175
Method
GetEnd
(opaque uint32, noopEnd bool)
protocol/textprot/respond.go:87
Method
GetOpaque
()
common/datatypes.go:152
Method
GetOpaque
()
common/datatypes.go:171
Method
GetOpaque
()
common/datatypes.go:190
Method
GetOpaque
()
common/datatypes.go:207
Method
GetOpaque
()
common/datatypes.go:224
Method
GetOpaque
()
common/datatypes.go:239
Method
GetOpaque
()
common/datatypes.go:253
Method
GetOpaque
()
common/datatypes.go:267
Method
GetWithOpaque
(rw *bufio.ReadWriter, key []byte, opaque int)
client/binprot/prot.go:277
Method
GetWithOpaque
(rw *bufio.ReadWriter, key []byte, opaque int)
client/textprot/prot.go:124
Function
IncCounter
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
Function
IncCounterBy
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
Function
IsAppError
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
Method
IsQuiet
()
common/datatypes.go:156
Method
IsQuiet
()
common/datatypes.go:178
Method
IsQuiet
()
common/datatypes.go:194
Method
IsQuiet
()
common/datatypes.go:211
Method
IsQuiet
()
common/datatypes.go:228
Method
IsQuiet
()
common/datatypes.go:243
Method
IsQuiet
()
common/datatypes.go:257
Method
IsQuiet
()
common/datatypes.go:271
Function
L1L2
(l1, l2 handlers.Handler, res protocol.Responder)
orcas/l1l2.go:33
Function
L1L2Batch
(l1, l2 handlers.Handler, res protocol.Responder)
orcas/l1l2batch.go:33
Function
L1Only
(l1, l2 handlers.Handler, res protocol.Responder)
orcas/l1only.go:30
Method
Len
()
metrics/endpoint.go:251
Method
Less
(i, j int)
metrics/endpoint.go:253
Function
ListenAndServe
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
Function
Locked
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
Function
LockedWithExisting
(oc OrcaConst, locksetID uint32)
orcas/locked.go:103
Method
Loop
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
Function
New
()
handlers/inmem/inmem.go:45
Method
NewDisambiguator
(p protocol.Peeker)
protocol/binprot/components.go:36
Method
NewDisambiguator
(p protocol.Peeker)
protocol/textprot/components.go:36
Function
NewHandler
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
Function
NewHandler
NewHandler returns an implementation of handlers.Handler that implements a straightforward request-response like normal memcached usage.
handlers/memcached/std/handler.go:49
Function
NewHandler
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
Method
NewRequestParser
(r *bufio.Reader)
protocol/binprot/components.go:28
Method
NewRequestParser
(r *bufio.Reader)
protocol/textprot/components.go:28
Method
NewResponder
(w *bufio.Writer)
protocol/binprot/components.go:32
Method
NewResponder
(w *bufio.Writer)
protocol/textprot/components.go:32
Function
NilHandler
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
Method
Noop
(opaque uint32)
protocol/types.go:50
Method
Noop
(opaque uint32)
protocol/binprot/respond.go:226
Method
Noop
(opaque uint32)
protocol/textprot/respond.go:114
Method
Noop
(req common.NoopRequest)
server/default_test.go:114
Method
Noop
(req common.NoopRequest)
server/default_test.go:144
Method
Noop
(req common.NoopRequest)
orcas/l1only.go:382
Method
Noop
(req common.NoopRequest)
orcas/l1l2batch.go:693
Method
Noop
(req common.NoopRequest)
orcas/locked_test.go:42
Method
Noop
(req common.NoopRequest)
orcas/locked.go:325
Method
Noop
(req common.NoopRequest)
orcas/l1l2.go:880
Function
Now
()
timer/timer_fallback.go:23
Function
ObserveHist
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
Method
Parse
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
Method
Parse
()
protocol/textprot/parser.go:39
Method
Parse
On first call, returns the values in the testRequestParser On second call, always returns io.EOF
server/default_test.go:46
Method
Prepend
(rw *bufio.ReadWriter, key, value []byte)
client/binprot/prot.go:236
Method
Prepend
(rw *bufio.ReadWriter, key []byte, value []byte)
client/textprot/prot.go:113
Method
Prepend
(opaque uint32, quiet bool)
protocol/types.go:43
Method
Prepend
(opaque uint32, quiet bool)
protocol/binprot/respond.go:157
Method
Prepend
(opaque uint32, quiet bool)
protocol/textprot/respond.go:51
Method
Prepend
(cmd common.SetRequest)
handlers/types.go:31
Method
Prepend
(cmd common.SetRequest)
handlers/inmem/inmem.go:141
Method
Prepend
Prepend performs a prepend request on the remote backend
handlers/memcached/chunked/handler.go:343
Method
Prepend
Prepend performs a prepend request on the remote backend
handlers/memcached/std/handler.go:96
Method
Prepend
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
Method
Prepend
(req common.SetRequest)
server/default_test.go:90
Method
Prepend
(req common.SetRequest)
server/default_test.go:138
Method
Prepend
(req common.SetRequest)
orcas/l1only.go:142
Method
Prepend
(cmd common.SetRequest)
orcas/util_test.go:61
Method
Prepend
(req common.SetRequest)
orcas/l1l2batch.go:288
Method
Prepend
(req common.SetRequest)
orcas/locked_test.go:36
Method
Prepend
(req common.SetRequest)
orcas/locked.go:183
Method
Prepend
(req common.SetRequest)
orcas/l1l2.go:332
Function
PrintHist
Accepts a sorted slice of durations in nanoseconds Prints a histogram to stdout
client/stats/stats.go:89
Function
PutResponseHeader
PutResponseHeader returns the response header to the pool
protocol/binprot/headers.go:90
Method
Quit
(opaque uint32, quiet bool)
protocol/types.go:51
← previous
next →
301–400 of 544, ranked by callers