MCPcopy Create free account

hub / github.com/paypal/junodb / functions

Functions5,003 in github.com/paypal/junodb

⨍ Functions 5,003◇ Types & classes 696
↓ 5 callersMethodsendCommits
()
cmd/proxy/proc/processor.go:242
↓ 5 callersMethodserializeResponse
Serialize a response to send back to the client @param opMsg @return The input stream containing the serialized response. @throws java.io.IOException
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/mock/MockJunoUnresponsiveServer.java:266
↓ 5 callersMethodserializeResponse
Serialize a response to send back to the client @param mmheader the header for the message @param appName the appname of the client @param mom the op
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/mock/MockJunoServer.java:262
↓ 5 callersMethodsetPingIp
(String ip)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/BaseProcessor.java:38
↓ 5 callersMethodsetRequestId
(req *proto.OperationalMessage)
cmd/tools/cmd/cli/sscli.go:131
↓ 5 callersFunctionshmName
(pid int)
cmd/storageserv/stats/shmstats/shmstats.go:109
↓ 5 callersFunctionshmName
(pid int)
cmd/proxy/stats/shmstats/shmstats.go:139
↓ 5 callersMethodshutdown
(self, status=0)
cmd/etcdsvr/etcdsvr.py:396
↓ 5 callersMethodshutdown
(self, status=0)
docker/service/junoclusterserv/etcdsvr.py:378
↓ 5 callersFunctiontestRequestResponse
(t *testing.T, rawRequest []byte, rawResponse []byte)
pkg/proto/opMsg_test.go:31
↓ 5 callersFunctiontestRequestResponse
(t *testing.T, rawRequest []byte, rawResponse []byte)
pkg/proto/mayfly/msg_test.go:29
↓ 5 callersMethodtotalLength
()
pkg/cluster/node.go:153
↓ 5 callersMethodwriteBufPadding
(int start, ByteBuf out, int padding)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/OperationMessage.java:168
↓ 4 callersMethodAddHexKey
(key []byte)
pkg/logging/logging.go:104
↓ 4 callersMethodAddLink
(href string, text string)
pkg/stats/htmlstats.go:78
↓ 4 callersMethodAddress
()
test/testutil/server/server.go:123
↓ 4 callersMethodEncrypt
(pType PayloadType)
pkg/proto/payload.go:137
↓ 4 callersMethodError
()
internal/cli/error.go:57
↓ 4 callersFunctionFinalize
()
cmd/storageserv/stats/shmstats/shmstats.go:449
↓ 4 callersMethodFinalize
()
pkg/initmgr/init.go:56
↓ 4 callersMethodGetAppName
()
pkg/proto/opMsg.go:349
↓ 4 callersFunctionGetEtcdCli
()
pkg/etcd/etcd.go:59
↓ 4 callersFunctionGetOpCode
(wmsg *RawMessage)
pkg/proto/decode.go:294
↓ 4 callersFunctionGetOpStatus
(wmsg *RawMessage)
pkg/proto/decode.go:313
↓ 4 callersMethodGetPayloadType
()
pkg/proto/payload.go:79
↓ 4 callersFunctionGetRangeCount
()
cmd/dbscanserv/prime/meta.go:231
↓ 4 callersMethodGetRateLimit
()
cmd/storageserv/redist/replicator.go:148
↓ 4 callersFunctionGetRpcClient
(addr string)
cmd/dbscanserv/app/rpcclient.go:51
↓ 4 callersMethodGetSecFlag
TODO find a better name
cmd/proxy/config/config.go:215
↓ 4 callersFunctionGetServerTypeText
(t ServerType)
test/testutil/server/cluster.go:82
↓ 4 callersFunctionGetShardIds
lower two bytes are used for Shard Id, and higher two bytes are used for Micro Shard Id
pkg/util/util.go:77
↓ 4 callersFunctionGetShardInfoByKey
(key []byte, numShards uint32, numZones uint32, AlgVersion uint32)
pkg/util/util.go:59
↓ 4 callersMethodGetSrcIP
()
pkg/proto/opMsg.go:353
↓ 4 callersFunctionGetTimeToLive
(expirationTime uint32)
pkg/util/util.go:118
↓ 4 callersMethodGetUDF
thread safe
pkg/udf/udfmgr.go:81
↓ 4 callersMethodHandshake
()
pkg/sec/sslctx.go:35
↓ 4 callersFunctionI
(t,e)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 4 callersMethodIncreaseDropCnt
()
pkg/stats/redist/stats.go:111
↓ 4 callersMethodInitNode
(zoneid uint32, nodeid uint32)
pkg/cluster/node.go:48
↓ 4 callersFunctionInitialize
(args ...interface{})
pkg/cluster/shardmgr.go:73
↓ 4 callersMethodIsConnected
(zone int, zoneIndex int)
pkg/cluster/shardmgr.go:502
↓ 4 callersFunctionIsMarkDelete
(val []byte)
cmd/dbscanserv/prime/meta.go:342
↓ 4 callersMethodIsMarkeddown
(zoneid uint32, nodeid uint32)
pkg/cluster/clusterstats.go:127
↓ 4 callersMethodIsOriginatorSet
()
pkg/proto/opMsg.go:321
↓ 4 callersFunctionIsPrimary
(shardid uint32, zoneid uint32, numZones uint32)
pkg/cluster/zone.go:64
↓ 4 callersFunctionKeyRedistNodeState
(zone int, node int, shardid int)
pkg/etcd/keys.go:156
↓ 4 callersMethodLogStats
(start time.Time, etcd bool, forceabort bool)
cmd/storageserv/redist/replicator.go:122
↓ 4 callersFunctionM
(t,e,i)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 4 callersFunctionNewClusterStats
(numZones uint32, maxNodesPerZone uint32, conf *StatsConfig)
pkg/cluster/clusterstats.go:62
↓ 4 callersFunctionNewCmdWithConfig
(addr string, poolSize int)
test/cli/util.go:65
↓ 4 callersFunctionNewFloat32State
(addr *float32, header string, fullHeader string, precision uint8)
pkg/stats/statelog.go:260
↓ 4 callersFunctionNewInitializer
(initializeFunc func(args ...interface{}) error, finalizeFunc func())
pkg/initmgr/init.go:176
↓ 4 callersFunctionNewMessageBlock
Get one from pool.
cmd/dbscanserv/prime/meta.go:91
↓ 4 callersFunctionNewMsg
NewMsg creates a new Msg with required fields populated. NewMsg automatically sets CreatedAt and records the active goroutine. If class is not one of
pkg/logging/cal/net/protocol/message.go:65
↓ 4 callersFunctionNewProcessor
( server io.ServiceEndpoint, sourceName string, connPoolSize int, connectTimeout time.Duration, responseT
internal/cli/processor.go:136
↓ 4 callersMethodNewRequest
(op proto.OpCode, key []byte, value []byte, ttl uint32)
test/testutil/ssclient/advssclient.go:82
↓ 4 callersFunctionNewUDFManager
(udfDir string)
pkg/udf/udfmgr.go:57
↓ 4 callersFunctionNewValBuffer
()
cmd/dbscanserv/prime/meta.go:86
↓ 4 callersMethodOnComplete
()
cmd/proxy/proc/base.go:733
↓ 4 callersFunctionParseCommandLine
()
pkg/cmd/cmd.go:203
↓ 4 callersMethodPrettyPrint
(w io.Writer)
pkg/proto/opMsg.go:377
↓ 4 callersMethodQuit
()
pkg/cluster/clusterstats.go:85
↓ 4 callersMethodRead
(r io.Reader)
pkg/io/requestcontext.go:55
↓ 4 callersFunctionRedistAuto
(newConfig string, zoneSelected int, skipZone int, dryrun bool, maxFailures int, maxWait int, forTest bool, r
cmd/clustermgr/cmd/cmd.go:228
↓ 4 callersFunctionRedistCommit
(newConfig string, zoneSelected int, dryrun bool, waitForFinish bool, maxFailures int, markdown bool)
cmd/clustermgr/cmd/cmd.go:434
↓ 4 callersFunctionRedistPrepare
(newConfig string, zoneSelected int, dryrun bool, swaphost bool)
cmd/clustermgr/cmd/cmd.go:330
↓ 4 callersFunctionRedistStart
(configFile string, flag bool, zoneid int, src bool, dryrun bool, ratelimit int, markdown bool)
cmd/clustermgr/cmd/cmd.go:299
↓ 4 callersMethodReplyError
(err error)
internal/cli/ctx.go:118
↓ 4 callersMethodSendProcState
(st ProcStat)
pkg/stats/statelog.go:343
↓ 4 callersMethodSendRequest
(opMsg *proto.OperationalMessage)
cmd/proxy/replication/replicator.go:182
↓ 4 callersMethodSetNewRequestId
()
pkg/proto/requestid.go:66
↓ 4 callersMethodSetOption
Set option for opened db.
third_party/patches/forked/tecbot/gorocksdb/set_option.go:12
↓ 4 callersMethodSetPayload
(payload *Payload)
pkg/proto/opMsg.go:218
↓ 4 callersMethodSetPrefixExtractor
SetPrefixExtractor sets the prefic extractor. If set, use the specified function to determine the prefixes for keys. These prefixes will be placed in
third_party/patches/forked/tecbot/gorocksdb/options.go:405
↓ 4 callersFunctionSetProxyAddr
(addr string)
cmd/dbscanserv/prime/result.go:62
↓ 4 callersMethodShortNameString
()
pkg/proto/defs.go:234
↓ 4 callersMethodShutdown
()
internal/cli/connector.go:77
↓ 4 callersMethodStop
()
test/testutil/server/cluster.go:52
↓ 4 callersMethodSync
()
third_party/forked/golang/glog/glog.go:418
↓ 4 callersFunctionToHexString
(data []byte)
pkg/util/print.go:43
↓ 4 callersFunctionUpdateDbAccessTime
()
cmd/dbscanserv/prime/db.go:122
↓ 4 callersMethodValidate
()
cmd/clustermgr/cmd/config.go:54
↓ 4 callersFunctionVerboseInfof
(format string, args ...interface{})
third_party/forked/golang/glog/pplog.go:231
↓ 4 callersFunctionWaitForDown
(waittime time.Duration, servers ...IServer)
test/testutil/server/server.go:388
↓ 4 callersMethodWidth
()
pkg/stats/statelog.go:46
↓ 4 callersMethodWrite
(w io.Writer)
pkg/io/requestcontext.go:47
↓ 4 callersMethodWriteToToml
WriteToToml writes the configuration properties in TOML format
pkg/cfg/cfg.go:90
↓ 4 callersFunctionaddPage
(path string, handler func(w http.ResponseWriter, r *http.Request))
cmd/storageserv/stats/httphandler.go:63
↓ 4 callersMethodaddSourceField
(byte[] ip4, int port, byte[] appName)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MetaOperationMessage.java:190
↓ 4 callersFunctionat
(t,e)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 4 callersFunctionb
(t,e,i)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 4 callersFunctionbl
(a)
client/Ruby/docs/js/jquery.js:2
↓ 4 callersMethodcacheRecord
(Employee emp)
client/Java/examples/employee-dashboard-app/src/main/java/com/paypal/juno/employeedashboardapp/service/JunoCache.java:33
↓ 4 callersFunctioncalLogReqProcError
(name string, data []byte)
cmd/proxy/proc/proc_logging.go:96
↓ 4 callersMethodcheckForRetry
(OperationStatus status)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/JunoClientUtil.java:69
↓ 4 callersMethodcommitSucceeded
()
cmd/proxy/proc/processor.go:53
↓ 4 callersMethoddecodeOperationMessage
This method decodes the Operation message got from Juno Server over the I/O channel and creates the JunoMessage object. @param opMsg - Operaion messag
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/JunoClientUtil.java:383
↓ 4 callersMethodencodingSize
()
pkg/proto/mayfly/msg.go:160
↓ 4 callersFunctionfileExist
(name string)
cmd/dbscanserv/app/remote.go:383
↓ 4 callersMethodget
Get a record from Juno DB @param key - Key of the record to be retrieved @return JunoResponse - Juno Response object which contains the status of the
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/impl/JunoClientImpl.java:77
← previousnext →601–700 of 5,003, ranked by callers