MCPcopy Create free account

hub / github.com/paypal/junodb / functions

Functions5,003 in github.com/paypal/junodb

↓ 6 callersMethodvalidatePath
set path to be under Config.RootDir if path is empty or not specified as absolute path
cmd/proxy/config/config.go:158
↓ 6 callersFunctionwaitForStateWithSSs
(fn func(ss ...SSNode) bool, nodes ...SSNode)
test/testutil/server/cluster.go:525
↓ 5 callersMethodAddOpRequest
difference from AddOpRequestInfo(): namespace and key not logged
pkg/logging/logging.go:364
↓ 5 callersMethodAddOpRequestResponseInfo
(req, resp *proto.OperationalMessage)
pkg/logging/logging.go:222
↓ 5 callersMethodAddRequestID
(id proto.RequestId)
pkg/logging/logging.go:168
↓ 5 callersMethodAddTTL
(v uint32)
pkg/logging/logging.go:183
↓ 5 callersFunctionApproxEqual
(v1 uint32, v2 uint32, epsilon uint32)
test/testutil/testhelper.go:223
↓ 5 callersFunctionCalStatus
(st proto.OpStatus)
pkg/logging/calstatus.go:69
↓ 5 callersMethodCalStatus
()
pkg/logging/calstatus.go:76
↓ 5 callersMethodCap
Cap returns the capacity of the buffer's underlying byte slice, that is, the total space allocated for the buffer's data.
pkg/util/buffer.go:63
↓ 5 callersMethodClearPayload
()
pkg/proto/opMsg.go:222
↓ 5 callersFunctionConfigBlockCache
()
cmd/storageserv/storage/db/config.go:358
↓ 5 callersFunctionDebugln
(args ...interface{})
third_party/forked/golang/glog/pplog.go:247
↓ 5 callersMethodDelete
(cli *JunoClient)
cmd/tools/goldendata/goldenset.go:32
↓ 5 callersMethodEncode
()
test/testutil/mock/common.go:75
↓ 5 callersFunctionFlush
Flush flushes all pending log I/O.
third_party/forked/golang/glog/glog.go:439
↓ 5 callersFunctionGetBufferPool
(size int)
pkg/util/mem.go:48
↓ 5 callersMethodGetCtx
()
pkg/io/requestcontext.go:53
↓ 5 callersMethodGetData
()
pkg/proto/payload.go:83
↓ 5 callersFunctionGetExpirationTime
(ttl uint32)
pkg/util/util.go:142
↓ 5 callersFunctionGetManager
()
cmd/storageserv/redist/redist.go:86
↓ 5 callersMethodGetName
()
pkg/cmd/cmd.go:46
↓ 5 callersMethodGetNamespace
()
pkg/proto/opMsg.go:214
↓ 5 callersMethodGetNetConn
()
pkg/sec/sslctx.go:36
↓ 5 callersMethodGetNodes
(id uint32, start_zoneid uint32)
pkg/cluster/shardmap.go:74
↓ 5 callersMethodGetNumWorkers
()
cmd/proxy/stats/monhandler.go:75
↓ 5 callersFunctionGetReplicateErrors
()
cmd/dbscanserv/prime/opdata.go:179
↓ 5 callersMethodGetShards
()
pkg/cluster/node.go:74
↓ 5 callersMethodHexDump
()
pkg/proto/rawmessage.go:69
↓ 5 callersFunctionHtmlDurationEscapeString
(d time.Duration)
pkg/stats/htmltmpl.go:169
↓ 5 callersFunctionInitialize
* Two arguments required arg 0: *Config arg 1: uint8 bitmask flag arg 2: isServerManager (optional) */
pkg/sec/secinit.go:68
↓ 5 callersFunctionIsLocalAddress
(addr string)
pkg/net/netutil/netutil.go:54
↓ 5 callersMethodIsRecordPresent
(id RecordID, rec *Record)
cmd/storageserv/storage/db/db.go:40
↓ 5 callersFunctionJunoInternalKeyForLimits
JunoInternalKeyForLimits returns the key for limits configuration
cmd/proxy/config/limitscfg.go:74
↓ 5 callersFunctionLogWorkerExit
(workerId int)
pkg/logging/logging.go:446
↓ 5 callersFunctionLogWorkerStart
(workerId int)
pkg/logging/logging.go:429
↓ 5 callersFunctionMurmur3Hash
(data []byte)
pkg/util/util.go:50
↓ 5 callersFunctionNewDecoder
(r io.Reader)
pkg/proto/decode.go:39
↓ 5 callersFunctionNewErrorOutboundResponse
(status uint32)
pkg/io/requestcontext.go:167
↓ 5 callersFunctionNewInboundRespose
(opCode proto.OpCode, m *proto.RawMessage)
pkg/io/requestcontext.go:131
↓ 5 callersFunctionNewProxyInRespose
(clientRequest *proto.OperationalMessage, m *proto.RawMessage, receiveTime time.Time, logData *logging.KeyValu
cmd/proxy/proc/base.go:186
↓ 5 callersFunctionNewRecordIDWithBuffer
(buf *bytes.Buffer, shardId shard.ID, microShardId uint8, namespace []byte, key []byte)
cmd/storageserv/storage/db/recordid.go:54
↓ 5 callersMethodNewRequest
NewRequest creates a new OperationalMessage with the provided parameters.
pkg/client/clientimpl.go:314
↓ 5 callersFunctionNewRingBufferWithExtra
(size uint32, extra_pct uint32)
pkg/util/ringbuffer.go:123
↓ 5 callersFunctionNewRocksDBptions
Note: rocksdb C binding does not support getters for option types
cmd/storageserv/storage/db/config.go:246
↓ 5 callersFunctionNewShardMap
(c *Cluster)
pkg/cluster/shardmap.go:43
↓ 5 callersFunctionNewUint16State
(addr *uint16, header string, fullHeader string)
pkg/stats/statelog.go:137
↓ 5 callersFunctionOnelineVersionString
()
pkg/version/version.go:40
↓ 5 callersFunctionP
(t)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 5 callersFunctionPingServers
(cmd int, startid int, stopid int, addr ...string)
cmd/dbscanserv/app/rpcclient.go:169
↓ 5 callersMethodPutValue
(key string, val string, params ...int)
pkg/etcd/etcdclient.go:212
↓ 5 callersMethodRead
(r IReader)
pkg/cluster/cluster.go:128
↓ 5 callersMethodReadFromCache
(cacheName string)
pkg/cluster/cluster.go:408
↓ 5 callersMethodResize
(n int)
pkg/util/ppbuffer.go:29
↓ 5 callersMethodRun
()
pkg/service/service.go:156
↓ 5 callersMethodRun
()
cmd/storageserv/app/storagemgr.go:120
↓ 5 callersMethodSend
Send encodes and asynchronously (best effort) transmits m to the CAL server. Typically this method is not called directly. Use a Logger instead.
pkg/logging/cal/net/io/clientapi.go:52
↓ 5 callersMethodSetAsResponse
()
pkg/proto/opMsg.go:132
↓ 5 callersMethodSetCompactionFilter
(opts *gorocksdb.Options, enable bool)
cmd/storageserv/storage/db/shardingByPrefix.go:44
↓ 5 callersMethodSetSource
(ip net.IP, port uint16, appName []byte)
pkg/proto/opMsg.go:289
↓ 5 callersMethodSetStatus
(s string)
pkg/stats/redist/stats.go:153
↓ 5 callersMethodTimeout
(t int, i int)
cmd/dbscanserv/app/rpcclient.go:89
↓ 5 callersFunctionValidateZones
Validate shardids are unique and consecutive.
pkg/cluster/util.go:40
↓ 5 callersFunctionWaitForUp
(waittime time.Duration, servers ...IServer)
test/testutil/server/server.go:384
↓ 5 callersFunctionWatchForProxy
Watch for version change
pkg/etcd/watch.go:30
↓ 5 callersMethodWriteTo
WriteTo writes data to w until the buffer is drained or an error occurs. The return value n is the number of bytes written; it always fits into an int
pkg/util/buffer.go:206
↓ 5 callersFunction_
(t)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 5 callersFunctiona
(b,c)
client/Ruby/docs/js/jquery.js:2
↓ 5 callersMethodcomplete
(calstatus string, opStatus string, rht time.Duration, opCode string, target string)
cmd/proxy/replication/replicaterequest.go:141
↓ 5 callersMethodencode
(raw []byte)
pkg/proto/mayfly/msg.go:67
↓ 5 callersMethodgetBooleanProperty
(final String key, boolean defaultValue)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/BasePropertiesProvider.java:112
↓ 5 callersMethodgetConnectTimeout
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/IOProcessor.java:130
↓ 5 callersMethodgetConnectionPoolSize
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:137
↓ 5 callersMethodgetFromWorkerWithWorkerId
(urlPath string, query url.Values, workerId int)
cmd/proxy/stats/monhandler.go:212
↓ 5 callersMethodgetMessageType
()
pkg/proto/defs.go:334
↓ 5 callersMethodgetNumNoStageErrors
()
cmd/proxy/proc/state.go:170
↓ 5 callersMethodgetOpaqueResMap
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/RequestQueue.java:97
↓ 5 callersMethodgetReqId
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:188
↓ 5 callersMethodgetResponseTimeout
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:181
↓ 5 callersMethodgetStringProperty
(String key, String defaultValue)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/BasePropertiesProvider.java:138
↓ 5 callersMethodgetType
Mapping between the Optype in Request and Optype in JunoMessage @param opType - JunoRequest.OperationType @return JunoMesage.OperationType
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/JunoClientUtil.java:242
↓ 5 callersMethodheader
Stubbed out for testing. * header formats a log header as defined by the C++ implementation. It returns a buffer containing the formatted header and t
third_party/forked/golang/glog/glog.go:560
↓ 5 callersMethodisKeyRange
()
test/drv/junoload/tsteng.go:248
↓ 5 callersMethodisOpened
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/IOProcessor.java:286
↓ 5 callersMethodisRetryEnabled
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/JunoClientConfigHolder.java:408
↓ 5 callersMethodlogError
(op string, err error)
pkg/client/clientimpl.go:132
↓ 5 callersMethodlogStrOpCode
(opcode proto.OpCode)
cmd/proxy/proc/base.go:960
↓ 5 callersFunctionnewDefaultPrepDeleteRequest
()
cmd/storageserv/storage/delete_test.go:144
↓ 5 callersMethodnewRandomKey
(s int)
test/drv/bulkload/bulkload.go:60
↓ 5 callersMethodonException
(TestEvent event)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/Scheduler.java:273
↓ 5 callersMethodonPrepareFailure
(rc *SSRequestContext)
cmd/proxy/proc/set.go:73
↓ 5 callersMethodonPrepareFailure
(rc *SSRequestContext)
cmd/proxy/proc/update.go:120
↓ 5 callersMethodonPrepareFailure
(rc *SSRequestContext)
cmd/proxy/proc/create.go:135
↓ 5 callersFunctionparseKeys
(key string)
test/drv/bulkload/bulkload.go:220
↓ 5 callersFunctionprintUsage
()
cmd/clustermgr/clustermgr.go:166
↓ 5 callersMethodprocess
(request *proto.OperationalMessage)
test/testutil/ssclient/ssclient.go:113
↓ 5 callersMethodreadBuf
(ByteBuf in)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/OperationMessage.java:91
↓ 5 callersMethodrecordConnectCount
(String endpoint, String status, String cause)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/JunoMetrics.java:148
↓ 5 callersMethodreplaceFront
(mb *prime.MessageBlock)
cmd/dbscanserv/app/scan.go:386
↓ 5 callersMethodsendAbort
(ssIndex uint32)
cmd/proxy/proc/processor.go:55
← previousnext →501–600 of 5,003, ranked by callers