MCPcopy Create free account

hub / github.com/paypal/junodb / functions

Functions5,003 in github.com/paypal/junodb

⨍ Functions 5,003◇ Types & classes 696
↓ 2 callersMethodCheckConnection
()
test/testutil/ssclient/advssclient.go:92
↓ 2 callersMethodCleanAll
drain everything in the ringbuffer
pkg/util/ringbuffer.go:287
↓ 2 callersMethodClearMarkedDelete
()
cmd/storageserv/storage/db/record.go:333
↓ 2 callersMethodClearOnError
(err error)
internal/cli/tracker.go:131
↓ 2 callersFunctionClose
()
pkg/etcd/etcd.go:51
↓ 2 callersMethodClose
()
pkg/stats/statelog.go:113
↓ 2 callersMethodClose
()
internal/cli/connector.go:57
↓ 2 callersFunctionCollect
(file string, startShardid int, stopShardid int, skip int, driver bool)
cmd/dbscanserv/app/collect.go:75
↓ 2 callersMethodConnect
()
pkg/logging/cal/net/io/clientapi.go:54
↓ 2 callersFunctionConnectTo
(endpoint *ServiceEndpoint, connectTimeout time.Duration)
pkg/io/conn.go:144
↓ 2 callersFunctionCopyStandardLogTo
CopyStandardLogTo arranges for messages written to the Go "log" package's default logs to also appear in the Google logs for the named and lower sever
third_party/forked/golang/glog/glog.go:961
↓ 2 callersMethodCreateShardMap
()
pkg/cluster/cluster.go:522
↓ 2 callersFunctionD
(t,e,i)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 2 callersMethodDbRange
()
cmd/dbscanserv/app/remote.go:129
↓ 2 callersMethodDeQueue
()
pkg/util/ringbuffer.go:158
↓ 2 callersMethodDelKey
(shardid int, key []byte)
cmd/tools/goldendata/client.go:120
↓ 2 callersMethodDeleteKeyWithPrefix
(key string, isPrefix bool)
pkg/etcd/etcdwriter.go:35
↓ 2 callersFunctionDial
(target string, timeout time.Duration)
pkg/sec/sslctx.go:54
↓ 2 callersMethodDisplayStats
()
cmd/storageserv/storage/db/dbcopy/dbclient.go:87
↓ 2 callersFunctionDisplayZones
(zones []*Zone, header string)
pkg/cluster/util.go:28
↓ 2 callersFunctionDoPatch
Patch records in target pool
cmd/dbscanserv/app/patch.go:223
↓ 2 callersFunctionEnabled
()
cmd/proxy/replication/replicator.go:118
↓ 2 callersMethodEncode
()
pkg/proto/mayfly/msg.go:213
↓ 2 callersMethodEncodeRedistMsg
(shardId shard.ID, ns []byte, key []byte, row *proto.RawMessage)
cmd/storageserv/storage/db/record.go:315
↓ 2 callersFunctionEncodeVal
(val []byte, rec *db.Record)
cmd/dbscanserv/prime/meta.go:188
↓ 2 callersFunctionFinalize
()
pkg/initmgr/init.go:135
↓ 2 callersMethodForward
(shardId shard.ID, msg *proto.RawMessage, realtime bool, cntOnFailure bool)
cmd/storageserv/redist/redist.go:255
↓ 2 callersFunctionG
(t,e)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 2 callersMethodGetAggregatedInboundConnStats
()
cmd/proxy/stats/shmstats/shmstats.go:862
↓ 2 callersMethodGetAggregatedReqProcStats
()
cmd/proxy/stats/shmstats/shmstats.go:846
↓ 2 callersMethodGetBody
()
pkg/proto/rawmessage.go:65
↓ 2 callersFunctionGetCommand
(name string)
pkg/cmd/cmd.go:196
↓ 2 callersMethodGetConnectivity
()
pkg/cluster/shardmgr.go:446
↓ 2 callersMethodGetCreationTime
()
pkg/proto/opMsg.go:250
↓ 2 callersFunctionGetCurrentWorkerStatsManager
()
cmd/storageserv/stats/shmstats/shmstats.go:464
↓ 2 callersFunctionGetDbHandle
One db handle per zoneid, nodeid.
cmd/dbscanserv/prime/db.go:80
↓ 2 callersMethodGetDesc
()
pkg/cmd/cmd.go:47
↓ 2 callersMethodGetDoneCh
()
pkg/etcd/etcdclient.go:133
↓ 2 callersMethodGetIoConfig
(lsnr *io.ListenerConfig)
pkg/service/svccfg.go:93
↓ 2 callersMethodGetIoConfig
(target *ReplicationTarget)
cmd/proxy/replication/config/repcfg.go:68
↓ 2 callersFunctionGetLimits
GetLimits returns the limits setting for the given namespace
cmd/proxy/config/limitscfg.go:156
↓ 2 callersMethodGetListeners
()
pkg/service/service.go:236
↓ 2 callersFunctionGetLocalIPv4Address
()
pkg/net/netutil/netutil.go:76
↓ 2 callersMethodGetMShardId
()
pkg/stats/redist/stats.go:124
↓ 2 callersMethodGetMappedData
()
pkg/stats/sharedstats.go:78
↓ 2 callersMethodGetMaxNumHostsPerZone
()
pkg/cluster/config.go:93
↓ 2 callersMethodGetMessage
()
cmd/proxy/replication/replicaterequest.go:125
↓ 2 callersFunctionGetModTimeBegin
()
cmd/dbscanserv/prime/meta.go:264
↓ 2 callersMethodGetNodeId
(shardid uint32, zoneid uint32)
pkg/cluster/shardmap.go:103
↓ 2 callersFunctionGetNumOpenFDs
()
pkg/util/file.go:32
↓ 2 callersMethodGetNumWorkers
()
cmd/storageserv/stats/monhandler.go:71
↓ 2 callersFunctionGetOpCodeAndOpStatus
(wmsg *RawMessage)
pkg/proto/decode.go:280
↓ 2 callersMethodGetPingIP
()
pkg/io/outboundconnector.go:67
↓ 2 callersFunctionGetProxyAddr
()
cmd/dbscanserv/prime/result.go:66
↓ 2 callersMethodGetQueTimeout
()
pkg/util/ringbuffer.go:77
↓ 2 callersFunctionGetRangeidBits
()
cmd/dbscanserv/prime/meta.go:227
↓ 2 callersFunctionGetReplicationTargetStats
()
cmd/proxy/stats/shmstats/shmstats.go:959
↓ 2 callersMethodGetReqTimeoutCh
()
internal/cli/connector.go:92
↓ 2 callersMethodGetRequestIDString
()
pkg/proto/opMsg.go:317
↓ 2 callersMethodGetResponse
()
internal/cli/ctx.go:30
↓ 2 callersMethodGetSSProcessor
(zoneId int, nodeId int)
pkg/cluster/shardmgr.go:333
↓ 2 callersFunctionGetScanStatus
()
cmd/dbscanserv/prime/db.go:236
↓ 2 callersFunctionGetScanner
One scanner per zoneid, shardid.
cmd/dbscanserv/app/scan.go:81
↓ 2 callersFunctionGetServerStats
()
cmd/storageserv/stats/shmstats/shmstats.go:453
↓ 2 callersFunctionGetServerStats
()
cmd/proxy/stats/shmstats/shmstats.go:918
↓ 2 callersMethodGetShardId
()
pkg/proto/opMsg.go:184
↓ 2 callersFunctionGetShardInfo
(zoneid, shardid int)
cmd/dbscanserv/app/scan.go:112
↓ 2 callersMethodGetSnapshotStats
()
cmd/storageserv/redist/replicator.go:118
↓ 2 callersMethodGetStats
()
test/drv/junoload/stats.go:78
↓ 2 callersMethodGetStatsStr
(start time.Time)
pkg/stats/redist/stats.go:157
↓ 2 callersMethodGetToken
(size int64)
cmd/storageserv/redist/ratelimiter.go:55
↓ 2 callersFunctionGetTotal
()
pkg/util/ringbuffer_test.go:41
↓ 2 callersFunctionGetVersionFromDb
(key []byte, zoneid int)
cmd/dbscanserv/app/cmd.go:269
↓ 2 callersMethodGetWorkerStats
()
cmd/storageserv/stats/shmstats/shmstats.go:177
↓ 2 callersMethodGetWorkerStats
()
cmd/proxy/stats/shmstats/shmstats.go:289
↓ 2 callersFunctionGetWorkerStatsManager
(workerId int)
cmd/storageserv/stats/shmstats/shmstats.go:468
↓ 2 callersFunctionGetWorkerStatsManager
(workerId int)
cmd/proxy/stats/shmstats/shmstats.go:952
↓ 2 callersMethodGetWorkerUrl
(i int)
cmd/proxy/stats/monhandler.go:71
↓ 2 callersMethodGiveUpBufferOwnership
()
pkg/proto/rawmessage.go:202
↓ 2 callersMethodHandleCommand
()
cmd/dbscanserv/app/cmd.go:75
↓ 2 callersFunctionHtmlElem
(tagName string, code string)
pkg/stats/htmltmpl.go:157
↓ 2 callersFunctionI
(a)
client/Ruby/docs/js/jquery.js:2
↓ 2 callersMethodId
()
test/testutil/server/server.go:55
↓ 2 callersFunctionIncludeExpireKeys
()
cmd/dbscanserv/prime/meta.go:338
↓ 2 callersMethodIncreaseFailCnt
()
pkg/stats/redist/stats.go:107
↓ 2 callersMethodIncreaseTotalCnt
()
pkg/stats/redist/stats.go:99
↓ 2 callersFunctionInfoQuery
(w http.ResponseWriter, values url.Values)
cmd/proxy/stats/qry/infoquery.go:41
↓ 2 callersMethodInit
(numZones int)
cmd/dbscanserv/prime/result.go:126
↓ 2 callersFunctionInitForManager
(numChildren int)
cmd/storageserv/stats/shmstats/shmstats.go:433
↓ 2 callersFunctionInitForMonitor
()
cmd/proxy/stats/shmstats/shmstats.go:902
↓ 2 callersFunctionInitForWorker
(isChild bool, workerId int)
cmd/proxy/stats/shmstats/shmstats.go:894
↓ 2 callersFunctionInitSecConfig
(conf *Config)
pkg/sec/seccfg.go:49
↓ 2 callersMethodInitZone
(zone int)
pkg/cluster/filter.go:36
↓ 2 callersFunctionInitialize
only called once during start up
cmd/storageserv/storage/db/rocksdb.go:132
↓ 2 callersFunctionInitializeCMap
(numShards int)
cmd/storageserv/storage/lock.go:38
↓ 2 callersMethodIsDone
()
cmd/storageserv/redist/redist.go:250
↓ 2 callersMethodIsForDeleteReplication
For namespace migration
pkg/proto/opMsg.go:116
↓ 2 callersMethodIsForReplication
func (m *OperationalMessage) SetFlags(f uint8) { m.flags = f }
pkg/proto/opMsg.go:106
↓ 2 callersMethodIsInProcess
()
test/testutil/server/config.go:49
↓ 2 callersFunctionIsLocalIPAddress
(ipAddr string)
pkg/net/netutil/netutil.go:69
← previousnext →1,001–1,100 of 5,003, ranked by callers