MCPcopy Create free account

hub / github.com/Netflix/rend / functions

Functions544 in github.com/Netflix/rend

↓ 1 callersMethodConfigure
(net.Conn)
server/types.go:44
↓ 1 callersMethodDelete
(rw *bufio.ReadWriter, key []byte)
client/common/types.go:34
↓ 1 callersMethodGAT
(rw *bufio.ReadWriter, key []byte)
client/common/types.go:32
↓ 1 callersMethodGet
(rw *bufio.ReadWriter, key []byte)
client/textprot/prot.go:127
↓ 1 callersMethodGet
(cmd common.GetRequest)
handlers/types.go:32
↓ 1 callersMethodGetWithOpaque
(rw *bufio.ReadWriter, key []byte, opaque int)
client/common/types.go:31
↓ 1 callersMethodMore
()
handlers/memcached/chunked/chunkedLimitedReader.go:98
↓ 1 callersFunctionNewBinaryResponder
(writer *bufio.Writer)
protocol/binprot/respond.go:123
↓ 1 callersMethodNewDisambiguator
(p Peeker)
protocol/types.go:75
↓ 1 callersFunctionNewTextParser
(reader *bufio.Reader)
protocol/textprot/parser.go:33
↓ 1 callersFunctionNewTextResponder
(writer *bufio.Writer)
protocol/textprot/respond.go:29
↓ 1 callersMethodNextChunk
()
handlers/memcached/chunked/chunkedLimitedReader.go:91
↓ 1 callersFunctionNow
Now returns the current monotonic time, with an arbitrary starting time. It is not useful for telling the current wall clock time, only for timing.
timer/timer_asm.go:21
↓ 1 callersFunctionRandData
(r *rand.Rand, n int, useCached bool)
client/common/utils.go:48
↓ 1 callersFunctionRandSeed
()
client/common/utils.go:37
↓ 1 callersFunctionReadResponseHeader
(r io.Reader)
protocol/binprot/headers.go:166
↓ 1 callersMethodSetE
(rw *bufio.ReadWriter, key, value []byte, expiration uint32)
client/binprot/prot.go:153
↓ 1 callersFunctionTagsBuildStringAppend
(tgs tags)
metrics/tagsbench_test.go:48
↓ 1 callersMethodTouch
(rw *bufio.ReadWriter, key []byte)
client/common/types.go:35
↓ 1 callersFunctionavg
(data []int)
client/stats/stats.go:67
↓ 1 callersMethodbatchIntoBuffer
The opaque value in the requests is related to the base value returned by its index in the array meaning the first request sent out will have the opaq
handlers/memcached/batched/conn.go:340
↓ 1 callersMethodbatcher
()
handlers/memcached/batched/conn.go:227
↓ 1 callersFunctionbatchkeys
(r *rand.Rand, key []byte)
client/cmd/blast/main.go:328
↓ 1 callersFunctionchunkSize
(keylen int)
handlers/memcached/chunked/handler.go:181
↓ 1 callersFunctionchunkSliceIndices
(chunkSize, chunkNum, totalLength int)
handlers/memcached/chunked/keys.go:42
↓ 1 callersFunctioncommunicator
(prot common.Prot, conn net.Conn, tasks <-chan *common.Task, metrics chan<- metric, comms *sync.WaitGroup)
client/cmd/blast/main.go:264
↓ 1 callersFunctioncommunicator
(prot common.Prot, conn net.Conn, tasks <-chan *common.Task, metrics chan<- metric, comms *sync.WaitGroup)
client/cmd/setops/main.go:247
↓ 1 callersFunctionconsumeBatchResponse
(r *bufio.Reader)
client/binprot/prot.go:118
↓ 1 callersFunctionconsumeResponseCheckOpaque
(r *bufio.Reader, opq int)
client/binprot/prot.go:87
↓ 1 callersFunctionconsumeResponseE
(r *bufio.Reader)
client/binprot/prot.go:37
↓ 1 callersFunctionerrorToCode
(err error)
protocol/binprot/types.go:118
↓ 1 callersFunctionextractBHist
(b bhist)
metrics/histograms.go:433
↓ 1 callersFunctionextractHist
(h *hist)
metrics/histograms.go:395
↓ 1 callersFunctionfillKeys
fills a bunch of channels round robin with keys
client/cmd/setget/main.go:80
↓ 1 callersFunctiongenTokens
()
handlers/memcached/chunked/tokens.go:32
↓ 1 callersFunctiongetAllBucketHistograms
()
metrics/histograms.go:417
↓ 1 callersFunctiongetAllBulkCallbackGauges
()
metrics/bulkcallback.go:48
↓ 1 callersFunctiongetAllCallbackGauges
()
metrics/callbackgauges.go:77
↓ 1 callersFunctiongetAllCounters
()
metrics/counters.go:70
↓ 1 callersFunctiongetAllGauges
()
metrics/gauges.go:90
↓ 1 callersFunctiongetAllHistograms
()
metrics/histograms.go:326
↓ 1 callersFunctiongetAndTouchMetadata
(rw *bufio.ReadWriter, key []byte, exptime uint32)
handlers/memcached/chunked/localComm.go:29
↓ 1 callersFunctiongetBucket
(n uint64)
metrics/histograms.go:302
↓ 1 callersFunctiongetNewLocks
(multipleReaders bool, concurrency uint8)
orcas/locked.go:36
↓ 1 callersFunctiongetRelay
Creates a new relay with one connection or returns an existing relay for the given socket.
handlers/memcached/batched/relay.go:53
↓ 1 callersFunctionhdatPercentiles
Percentiles go by 5% percentile steps from min to max. We report all of them even though it's likely only min, 25th, 50th, 75th, 95th, 99th, and max w
metrics/histograms.go:454
↓ 1 callersFunctionidentifyPanic
()
server/utils.go:36
↓ 1 callersFunctionlzcntSlowForTestingOnly
(x uint64)
metrics/lzcnt_test.go:34
↓ 1 callersFunctionminmax
(data []int)
client/stats/stats.go:53
↓ 1 callersMethodmonitor
(firstConnSetup chan struct{})
handlers/memcached/batched/relay.go:129
↓ 1 callersFunctionnewChunkLimitedReader
(reader io.Reader, chunkSize, totalSize int64)
handlers/memcached/chunked/chunkedLimitedReader.go:20
↓ 1 callersFunctionnewConn
(sock string, id uint32, batchDelay time.Duration, batchSize, readerSize, writerSize uint32, expand chan struc
handlers/memcached/batched/conn.go:66
↓ 1 callersFunctionnewHist
()
metrics/histograms.go:146
↓ 1 callersFunctionnextKey
(key []byte)
client/cmd/setget/main.go:103
↓ 1 callersFunctionpausePercentiles
the first 21 positions are the percentiles by 5's from 0 to 100 the 22nd position is the bonus 99th percentile this makes looping over the values easi
metrics/endpoint.go:223
↓ 1 callersFunctionprintFloatMetrics
(w io.Writer, metrics []FloatMetric)
metrics/endpoint.go:214
↓ 1 callersFunctionprintIntMetrics
(w io.Writer, metrics []IntMetric)
metrics/endpoint.go:208
↓ 1 callersFunctionreadBatchGet
(r io.Reader, header *RequestHeader)
protocol/binprot/parser.go:295
↓ 1 callersFunctionreadBatchGetE
(r io.Reader, header *RequestHeader)
protocol/binprot/parser.go:364
↓ 1 callersFunctionreadMetadata
(r io.Reader)
handlers/memcached/chunked/types.go:37
↓ 1 callersFunctionreadResponseHeader
(r *bufio.Reader)
handlers/memcached/std/handler.go:26
↓ 1 callersMethodreader
()
handlers/memcached/batched/conn.go:505
↓ 1 callersFunctionrealHandleGet
(cmd common.GetRequest, dataOut chan common.GetResponse, errorOut chan error, rw *bufio.ReadWriter)
handlers/memcached/chunked/handler.go:476
↓ 1 callersFunctionrealHandleGet
(cmd common.GetRequest, dataOut chan common.GetResponse, errorOut chan error, rw *bufio.ReadWriter)
handlers/memcached/std/handler.go:144
↓ 1 callersFunctionrealHandleGet
(h Handler, cmd common.GetRequest, dataOut chan common.GetResponse, errorOut chan error)
handlers/memcached/batched/handler.go:305
↓ 1 callersFunctionrealHandleGetE
(cmd common.GetRequest, dataOut chan common.GetEResponse, errorOut chan error, rw *bufio.ReadWriter)
handlers/memcached/std/handler.go:194
↓ 1 callersFunctionrealHandleGetE
(h Handler, cmd common.GetRequest, dataOut chan common.GetEResponse, errorOut chan error)
handlers/memcached/batched/handler.go:390
↓ 1 callersMethodrecoveryMonitor
()
handlers/memcached/batched/conn.go:201
↓ 1 callersFunctionreqTypeToOpcode
Mae sure this includes all possibilities in the github.com/netflix/rend/common.RequestType enum
protocol/binprot/respond.go:252
↓ 1 callersMethodreset
()
handlers/memcached/chunked/handler.go:131
↓ 1 callersFunctiontaskValue
(r *rand.Rand, cmd common.Op)
client/cmd/blast/main.go:254
↓ 1 callersFunctiontaskValue
(r *rand.Rand, cmd common.Op)
client/cmd/setops/main.go:237
↓ 1 callersFunctionworker
(prot common.Prot, rw *bufio.ReadWriter, keys chan []byte, wg *sync.WaitGroup)
client/cmd/setget/main.go:131
↓ 1 callersFunctionworker
(numops int, prot common.Prot, wg *sync.WaitGroup)
client/cmd/fill/main.go:72
↓ 1 callersFunctionwriteErrorResponseHeader
(w *bufio.Writer, opcode uint8, status uint16, opaque uint32)
protocol/binprot/respond.go:341
MethodAccept
()
server/listen.go:36
MethodAccept
()
server/listen.go:69
MethodAdd
(rw *bufio.ReadWriter, key, value []byte)
client/binprot/prot.go:175
MethodAdd
(rw *bufio.ReadWriter, key []byte, value []byte)
client/textprot/prot.go:52
MethodAdd
(opaque uint32, quiet bool)
protocol/types.go:40
MethodAdd
(opaque uint32, quiet bool)
protocol/binprot/respond.go:136
MethodAdd
(opaque uint32, quiet bool)
protocol/textprot/respond.go:39
MethodAdd
(cmd common.SetRequest)
handlers/types.go:28
MethodAdd
(cmd common.SetRequest)
handlers/inmem/inmem.go:68
MethodAdd
Add performs an add request on the remote backend
handlers/memcached/chunked/handler.go:148
MethodAdd
Add performs an add request on the remote backend
handlers/memcached/std/handler.go:72
MethodAdd
Add performs an add operation on the backend. It only sets the value if it does not already exist.
handlers/memcached/batched/handler.go:183
MethodAdd
(req common.SetRequest)
server/default_test.go:78
MethodAdd
(req common.SetRequest)
server/default_test.go:135
MethodAdd
(req common.SetRequest)
orcas/l1only.go:61
MethodAdd
(cmd common.SetRequest)
orcas/util_test.go:46
MethodAdd
(req common.SetRequest)
orcas/l1l2batch.go:109
MethodAdd
(req common.SetRequest)
orcas/locked_test.go:33
MethodAdd
(req common.SetRequest)
orcas/locked.go:159
MethodAdd
(req common.SetRequest)
orcas/l1l2.go:115
FunctionAddCounter
AddCounter registers a counter and returns an ID that can be used to increment it. There is a maximum of 1024 metrics, after which adding a new one wi
metrics/counters.go:41
FunctionAddFloatGauge
AddFloatGauge registers a float-based gauge and returns an ID that can be used to access it. There is a maximum of 1024 gauges, after which adding a n
metrics/gauges.go:59
FunctionAddHistogram
AddHistogram creates a new histogram structure to record observations. The handle returned is used to record observations. There is a maximum of 1024
metrics/histograms.go:186
FunctionAddIntGauge
AddIntGauge registers an integer-based gauge and returns an ID that can be used to update it. There is a maximum of 1024 gauges, after which adding a
metrics/gauges.go:39
MethodAppend
(rw *bufio.ReadWriter, key, value []byte)
client/binprot/prot.go:219
← previousnext →101–200 of 544, ranked by callers