MCPcopy Create free account

hub / github.com/Netflix/rend / functions

Functions544 in github.com/Netflix/rend

⨍ Functions 544◇ Types & classes 88
↓ 49 callersMethodWrite
(p []byte)
protocol/binprot/parser_test.go:57
↓ 24 callersMethodError
(req common.Request, reqType common.RequestType, err error)
orcas/types.go:41
↓ 19 callersMethodSet
(req common.SetRequest)
orcas/types.go:27
↓ 18 callersMethodresp
(s string)
protocol/textprot/respond.go:154
↓ 18 callersMethodverifyEmpty
(t *testing.T)
orcas/util_test.go:29
↓ 17 callersMethodDelete
(req common.DeleteRequest)
orcas/types.go:32
↓ 17 callersMethodGet
(req common.GetRequest)
orcas/types.go:34
↓ 16 callersFunctioncopyTags
(orig Tags)
metrics/histograms.go:161
↓ 15 callersMethodClose
()
handlers/types.go:37
↓ 15 callersMethodGet
(rw *bufio.ReadWriter, key []byte)
client/common/types.go:30
↓ 15 callersMethodReplace
(req common.SetRequest)
orcas/types.go:29
↓ 15 callersMethodTouch
(req common.TouchRequest)
orcas/types.go:33
↓ 14 callersMethodAppend
(req common.SetRequest)
orcas/types.go:30
↓ 14 callersMethodPrepend
(req common.SetRequest)
orcas/types.go:31
↓ 13 callersMethodAdd
(rw *bufio.ReadWriter, key []byte, value []byte)
client/common/types.go:26
↓ 13 callersMethodAdd
(req common.SetRequest)
orcas/types.go:28
↓ 13 callersFunctionwriteReq
(w io.Writer, opcode, keylen, extralen, bodylen, opaque int)
client/binprot/headers.go:84
↓ 13 callersFunctionwriteSuccessResponseHeader
(w *bufio.Writer, opcode uint8, keyLength, extraLength, totalBodyLength int, opaque uint32, flush bool)
protocol/binprot/respond.go:308
↓ 11 callersFunctionreadString
(r io.Reader, l uint16)
protocol/binprot/parser.go:503
↓ 10 callersFunctioncmdGenerator
(tasks chan<- *common.Task, taskGens *sync.WaitGroup, numTasks int, cmd common.Op)
client/cmd/blast/main.go:240
↓ 10 callersMethodgetlock
var numops uint64 = 0
orcas/locked.go:126
↓ 9 callersMethodGet
(response common.GetResponse)
protocol/types.go:44
↓ 9 callersFunctionconsumeResponse
(r *bufio.Reader)
client/binprot/prot.go:64
↓ 8 callersMethodGAT
(cmd common.GATRequest)
handlers/types.go:34
↓ 8 callersMethoddoRequest
(cmd common.Request, reqType common.RequestType)
handlers/memcached/batched/handler.go:129
↓ 8 callersMethodisExpired
()
handlers/inmem/inmem.go:31
↓ 7 callersMethodGetE
(req common.GetRequest)
orcas/types.go:35
↓ 7 callersMethodNoop
(req common.NoopRequest)
orcas/types.go:37
↓ 7 callersMethodQuit
(req common.QuitRequest)
orcas/types.go:38
↓ 7 callersMethodVersion
(req common.VersionRequest)
orcas/types.go:39
↓ 6 callersMethodError
(opaque uint32, reqType common.RequestType, err error, quiet bool)
protocol/types.go:53
↓ 6 callersMethodGetEnd
(opaque uint32, noopEnd bool)
protocol/types.go:45
↓ 6 callersMethodString
()
client/common/types.go:73
↓ 6 callersFunctionchunkKey
(key []byte, chunk int)
handlers/memcached/chunked/keys.go:29
↓ 6 callersFunctionsetRequest
(r io.Reader, reqHeader *RequestHeader, reqType common.RequestType, quiet bool, start uint64)
protocol/binprot/parser.go:433
↓ 6 callersFunctionwriteRequestHeader
(w io.Writer, rh *RequestHeader)
protocol/binprot/headers.go:141
↓ 5 callersMethodSet
Yes, the abstraction is a little bit leaky, but the code in other places benefits from the consistency.
client/common/types.go:25
↓ 5 callersFunctionabort
(toClose []io.Closer, err error)
server/utils.go:25
↓ 5 callersFunctioncmdGenerator
(tasks chan<- *common.Task, taskGens *sync.WaitGroup, numTasks int, cmd common.Op)
client/cmd/setops/main.go:223
↓ 5 callersMethodhandleSetCommon
(cmd common.SetRequest)
handlers/memcached/std/handler.go:103
↓ 5 callersFunctionmakeRequestHeader
(opcode uint8, keyLength, extraLength, totalBodyLength int, opaque uint32)
protocol/binprot/headers.go:62
↓ 5 callersFunctionp
(data []int, p float64)
client/stats/stats.go:75
↓ 5 callersFunctionsetRequest
(r *bufio.Reader, clParts []string, reqType common.RequestType, start uint64)
protocol/textprot/parser.go:150
↓ 5 callersFunctionuint32ValueOrDefault
(val uint32, def uint32)
handlers/memcached/batched/handler.go:56
↓ 5 callersFunctionwriteKeyCmd
Key commands send the header and key only
protocol/binprot/commands.go:100
↓ 4 callersMethodGat
(req common.GATRequest)
orcas/types.go:36
↓ 4 callersMethodParse
()
protocol/types.go:31
↓ 4 callersMethodRead
(p []byte)
protocol/binprot/parser_test.go:53
↓ 4 callersMethodRead
io.Reader's interface implements this as a value method, not a pointer method.
handlers/memcached/chunked/chunkedLimitedReader.go:53
↓ 4 callersMethodUnknown
(req common.Request)
orcas/types.go:40
↓ 4 callersFunctionappendPrependRequest
(r io.Reader, reqHeader *RequestHeader, reqType common.RequestType, quiet bool, start uint64)
protocol/binprot/parser.go:475
↓ 4 callersFunctiongetMetadata
(rw *bufio.ReadWriter, key []byte)
handlers/memcached/chunked/localComm.go:38
↓ 4 callersMethodhandleSetCommon
(cmd common.SetRequest, reqType common.RequestType)
handlers/memcached/chunked/handler.go:209
↓ 4 callersFunctionreadRequestHeader
(r io.Reader)
protocol/binprot/headers.go:100
↓ 4 callersFunctionreadRes
(r io.Reader)
client/binprot/headers.go:128
↓ 4 callersFunctionreadUInt32
(r io.Reader)
protocol/binprot/parser.go:514
↓ 4 callersFunctionstatusToError
(status uint16)
client/binprot/headers.go:159
↓ 3 callersMethodAccept
()
server/types.go:43
↓ 3 callersMethodError
(opaque uint32, reqType common.RequestType, err error, quiet bool)
protocol/binprot/respond.go:246
↓ 3 callersMethodGetOpaque
()
common/datatypes.go:137
↓ 3 callersMethodIsQuiet
()
common/datatypes.go:138
↓ 3 callersMethodLoop
Loop is intended to be an infinite loop serving a single connection which will only return when the connection is done being serviced. The server impl
server/types.go:35
↓ 3 callersFunctionTagsBuildStringByteSlice
(tgs tags)
metrics/tagsbench_test.go:90
↓ 3 callersFunctiongetLocal
(rw *bufio.ReadWriter, readExp bool)
handlers/memcached/std/localComm.go:55
↓ 3 callersFunctiongetLocalIntoBuf
(rw *bufio.Reader, metaData metadata, tokenBuf, dataBuf []byte, chunkNum, totalDataLength int)
handlers/memcached/chunked/localComm.go:113
↓ 3 callersFunctionmetaKey
(key []byte)
handlers/memcached/chunked/keys.go:22
↓ 3 callersFunctionreadResponseHeader
(r *bufio.Reader)
handlers/memcached/chunked/handler.go:99
↓ 3 callersFunctionsimpleCmdLocal
(rw *bufio.ReadWriter, flush bool)
handlers/memcached/chunked/localComm.go:90
↓ 3 callersMethodsubmit
Submits a request to a random connection in the pool. The random number generator is passed in so there is no sharing between external connections.
handlers/memcached/batched/relay.go:119
↓ 3 callersFunctionwriteDataCmdCommon
Data commands are those that send a header, key, exptime, and data
protocol/binprot/commands.go:26
↓ 3 callersFunctionwriteKeyExptimeCmd
Key Exptime commands send the header, key, and an exptime
protocol/binprot/commands.go:144
↓ 3 callersFunctionwriteResponseHeader
(w io.Writer, rh *ResponseHeader)
protocol/binprot/headers.go:203
↓ 2 callersMethodAppend
(rw *bufio.ReadWriter, key []byte, value []byte)
client/common/types.go:28
↓ 2 callersFunctionNewBinaryParser
(reader *bufio.Reader)
protocol/binprot/parser.go:110
↓ 2 callersMethodNewRequestParser
(r *bufio.Reader)
protocol/types.go:76
↓ 2 callersMethodNewResponder
(w *bufio.Writer)
protocol/types.go:77
↓ 2 callersMethodPeek
(n int)
protocol/types.go:60
↓ 2 callersMethodPrepend
(rw *bufio.ReadWriter, key []byte, value []byte)
client/common/types.go:29
↓ 2 callersMethodReplace
(rw *bufio.ReadWriter, key []byte, value []byte)
client/common/types.go:27
↓ 2 callersMethodaddConn
Adds a connection to the pool. This is one way only, making this effectively a high-water-mark pool with no connections being torn down.
handlers/memcached/batched/relay.go:99
↓ 2 callersFunctionexptime
Takes a TTL in seconds and returns the unix time in seconds when the item will expire.
handlers/memcached/chunked/handler.go:191
↓ 2 callersFunctionfloat64ValueOrDefault
(val float64, def float64)
handlers/memcached/batched/handler.go:63
↓ 2 callersFunctiongetCommon
(w *bufio.Writer, response common.GetResponse, opcode uint8)
protocol/binprot/respond.go:293
↓ 2 callersFunctiongetEResponseToGetResponse
(res common.GetEResponse)
handlers/memcached/batched/handler.go:218
↓ 2 callersFunctiongetMetadataCommon
(rw *bufio.ReadWriter)
handlers/memcached/chunked/localComm.go:47
↓ 2 callersFunctiongetRequestToTrackerMap
There may be more than one request with the same key and a different opaque We may also get "malicious" input where multiple requests have the same ke
handlers/memcached/batched/handler.go:247
↓ 2 callersMethodhandleAppendPrependCommon
(cmd common.SetRequest, reqType common.RequestType)
handlers/memcached/chunked/handler.go:347
↓ 2 callersFunctionisMiss
(err error)
client/cmd/blast/main.go:324
↓ 2 callersFunctionisMiss
(err error)
client/cmd/setops/main.go:291
↓ 2 callersFunctionlzcnt
Function copied from Damian Gryski's go-bits package Copyright 2015 Damian Gryski, under MIT license See the NOTICE file for more details. https://git
metrics/lzcnt.go:23
↓ 2 callersFunctionpIdx
(datalen int, p float64)
client/stats/stats.go:80
↓ 2 callersFunctionprintTags
(tags Tags)
metrics/endpoint.go:195
↓ 2 callersFunctionrandSeed
()
handlers/memcached/batched/types.go:41
↓ 2 callersMethodreconnect
(initialDelay bool)
handlers/memcached/batched/conn.go:130
↓ 2 callersFunctionsimpleCmdLocal
(rw *bufio.ReadWriter)
handlers/memcached/std/localComm.go:27
↓ 2 callersFunctiontrackerMapToGetRequest
(tm trackermap)
handlers/memcached/batched/handler.go:266
↓ 2 callersFunctionwriteAppendPrependCmdCommon
(w io.Writer, opcode uint8, key []byte, flags, exptime, dataSize, opaque uint32)
protocol/binprot/commands.go:69
↓ 2 callersFunctionwriteMetadata
(w io.Writer, md metadata)
handlers/memcached/chunked/types.go:58
↓ 1 callersMethodBatchGet
(rw *bufio.ReadWriter, keys [][]byte)
client/common/types.go:33
↓ 1 callersMethodCanParse
()
protocol/types.go:68
next →1–100 of 544, ranked by callers