Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/paypal/junodb
/ functions
Functions
5,003 in github.com/paypal/junodb
⨍
Functions
5,003
◇
Types & classes
696
↓ 3 callers
Method
deleteKey
(ix int)
test/cli/util.go:170
↓ 3 callers
Method
duplicate
()
cmd/storageserv/storage/db/sharding.go:44
↓ 3 callers
Method
encode
(buf []byte)
pkg/proto/metaField.go:140
↓ 3 callers
Method
encodingSize
()
pkg/proto/mayfly/opmsg.go:317
↓ 3 callers
Method
enqueue
Push to channel
cmd/dbscanserv/app/scan.go:313
↓ 3 callers
Method
errorPrepareResponseOpStatus
Returns the OpStatus to Client
cmd/proxy/proc/processor.go:60
↓ 3 callers
Method
errorResponseOpStatus
()
cmd/proxy/proc/get.go:217
↓ 3 callers
Method
failed
()
cmd/proxy/proc/get.go:152
↓ 3 callers
Function
fileExist
(name string)
cmd/storageserv/compact/dbclient.go:46
↓ 3 callers
Function
finalizeOnce
()
third_party/forked/golang/glog/pplog.go:57
↓ 3 callers
Function
forwardRequest
(p2 *reqProcCtxT, prepare *reqProcCtxT)
cmd/storageserv/storage/storage.go:1168
↓ 3 callers
Method
genString
Generate a String of random alpha data (no numerics). @param length the length of the string to gen; must be >= 0 @throws IllegalArgumentException if
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/client/impl/DataGenUtils.java:68
↓ 3 callers
Method
getAppName
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MetaMessageSourceField.java:60
↓ 3 callers
Method
getCompressedType
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/PayloadOperationMessage.java:125
↓ 3 callers
Method
getCreationTime
()
client/Java/Juno/juno-client-api/src/main/java/com/paypal/juno/client/io/JunoRequest.java:107
↓ 3 callers
Method
getDefaultLifetimeSecs
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/JunoClientConfigHolder.java:396
↓ 3 callers
Function
getFromPrepareMap
(shardId shard.ID, recId db.RecordID, reqId proto.RequestId)
cmd/storageserv/storage/lock.go:104
↓ 3 callers
Method
getIP
(zoneid int, nodeid int)
cmd/dbscanserv/app/init.go:200
↓ 3 callers
Method
getKey
(seed int)
cmd/tools/goldendata/redistset.go:86
↓ 3 callers
Method
getMaxLifetimeSecs
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/JunoClientConfigHolder.java:381
↓ 3 callers
Method
getOpcode
@return the opcode
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MessageHeader.java:192
↓ 3 callers
Method
getOperationRetry
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:223
↓ 3 callers
Method
getPrefixKey
(shardId shard.ID)
cmd/storageserv/storage/db/shardingByPrefix.go:442
↓ 3 callers
Method
getPrefixKey
(shardId uint16)
cmd/storageserv/storage/db/dbcopy/dbclient.go:341
↓ 3 callers
Function
getTestRecordID
()
cmd/storageserv/storage/storage_test.go:48
↓ 3 callers
Method
getTimeToLiveSec
()
client/Java/Juno/juno-client-api/src/main/java/com/paypal/juno/client/io/JunoRequest.java:95
↓ 3 callers
Method
get_members
(self)
cmd/etcdsvr/etcdsvr.py:106
↓ 3 callers
Method
get_members
(self)
docker/service/junoclusterserv/etcdsvr.py:91
↓ 3 callers
Method
hashCode
()
client/Java/Juno/juno-client-api/src/main/java/com/paypal/juno/client/io/JunoRequest.java:118
↓ 3 callers
Method
hashCode
()
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/mock/MockKey.java:30
↓ 3 callers
Function
i
()
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 3 callers
Method
isCompleted
()
client/Java/Juno/FunctionalTests/src/test/java/com/paypal/qa/juno/BatchTestSubscriber.java:71
↓ 3 callers
Method
isCompleted
()
client/Java/Juno/FunctionalTests/src/test/java/com/paypal/qa/juno/BatchReactSubscriber.java:72
↓ 3 callers
Method
isRecordMarkDeleted
()
cmd/proxy/proc/update.go:57
↓ 3 callers
Method
isSSL
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/IOProcessor.java:290
↓ 3 callers
Method
isTestMode
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/Scheduler.java:249
↓ 3 callers
Method
keyExists
Check to see if the key already exists. @param namespace outer key @param key inner key @return true if we have both keys in our map, false otherwise
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/mock/MockJunoUnresponsiveServer.java:205
↓ 3 callers
Method
keyExists
Check to see if the key already exists. @param namespace outer key @param key inner key @return true if we have both keys in our map, false otherwise
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/mock/MockJunoServer.java:199
↓ 3 callers
Function
l
(a,c,d)
client/Ruby/docs/js/jquery.js:2
↓ 3 callers
Function
logForwardRequestError
(p *reqProcCtxT, err error)
cmd/storageserv/storage/storage.go:828
↓ 3 callers
Method
logStats
(shardId shard.ID, rb *redist.Replicator)
cmd/storageserv/storage/db/shardingByPrefix.go:291
↓ 3 callers
Method
mapShmData
()
cmd/storageserv/stats/shmstats/shmstats.go:255
↓ 3 callers
Method
mapShmData
(byCreator bool)
cmd/proxy/stats/shmstats/shmstats.go:575
↓ 3 callers
Method
needApplyUDF
()
cmd/proxy/proc/base.go:78
↓ 3 callers
Function
newDefaultSetRequest
()
cmd/storageserv/storage/set_test.go:97
↓ 3 callers
Function
newDefaultUpdateRequest
()
cmd/storageserv/storage/update_test.go:98
↓ 3 callers
Function
numBytesToPadTo8
(size int)
cmd/storageserv/stats/shmstats/shmstats.go:113
↓ 3 callers
Method
onCommitFailure
(st *SSRequestContext)
cmd/proxy/proc/set.go:101
↓ 3 callers
Method
onCommitFailure
(st *SSRequestContext)
cmd/proxy/proc/destroy2.go:183
↓ 3 callers
Method
onCommitFailure
(st *SSRequestContext)
cmd/proxy/proc/update.go:159
↓ 3 callers
Method
onCommitFailure
(st *SSRequestContext)
cmd/proxy/proc/create.go:178
↓ 3 callers
Method
onError
(Throwable e)
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/net/RequestQueueTest.java:116
↓ 3 callers
Method
onNext
(JunoResponse message)
client/Java/Juno/FunctionalTests/src/test/java/com/paypal/qa/juno/BatchTestSubscriber.java:96
↓ 3 callers
Method
onRepairSuccess
(rc *SSRequestContext)
cmd/proxy/proc/create.go:163
↓ 3 callers
Method
parseDate
(String date)
client/Java/examples/employee-dashboard-app/src/main/java/com/paypal/juno/employeedashboardapp/controller/EmployeeController.java:30
↓ 3 callers
Method
parse_cfg
(self, status_only)
cmd/etcdsvr/etcdsvr.py:242
↓ 3 callers
Method
populateBeanLists
Populate the bean list based on the value How they are declared. If they are declared with @named annotations then the named value will be put in the
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/JunoClientBeanFactoryPostProcessor.java:199
↓ 3 callers
Method
putBuffer
putBuffer returns a buffer to the free list.
third_party/forked/golang/glog/glog.go:530
↓ 3 callers
Function
r
(t)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 3 callers
Method
randLen
()
test/drv/bulkload/bulkload.go:117
↓ 3 callers
Method
readBuf
(ByteBuf in)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MessageHeader.java:355
↓ 3 callers
Method
readNodesShards
tag: either TagNodeShards or TagRedistNodeShards
pkg/etcd/etcdreader.go:422
↓ 3 callers
Function
recordMostUpdatedThan
(m1, m2 *proto.OperationalMessage)
cmd/proxy/proc/processor.go:372
↓ 3 callers
Function
removeLocalSecretFile
(secretfilename string)
pkg/sec/certs_test.go:56
↓ 3 callers
Method
resetFromOpMsg
(opmsg *proto.OperationalMessage)
cmd/proxy/proc/state.go:108
↓ 3 callers
Method
send
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/IOProcessor.java:593
↓ 3 callers
Method
sendRepair
(ssIndex uint32)
cmd/proxy/proc/processor.go:56
↓ 3 callers
Method
set
Update the record if present in Juno DB else create that record with the default TTL in the configuration @param key - Key of the record to be Upserte
client/Java/Juno/juno-client-api/src/main/java/com/paypal/juno/client/JunoReactClient.java:90
↓ 3 callers
Method
set
(zoneid int, shardid uint32, nodeid int)
pkg/cluster/filter.go:56
↓ 3 callers
Method
setAbortMsg
()
cmd/proxy/proc/processor.go:249
↓ 3 callers
Method
setKey
(byte[] key)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/PayloadOperationMessage.java:111
↓ 3 callers
Method
setKeyLength
(int keyLength)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/PayloadOperationMessage.java:93
↓ 3 callers
Function
setMap
(to map[string]interface{}, from map[string]keyValue)
pkg/cfg/cfg.go:261
↓ 3 callers
Method
setNamespace
(byte[] namespace)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/PayloadOperationMessage.java:101
↓ 3 callers
Method
setOpcode
@param opcode the opcode to set
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MessageHeader.java:199
↓ 3 callers
Method
setPayloadComponent
(PayloadOperationMessage payloadComponent)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/OperationMessage.java:63
↓ 3 callers
Method
setShardId
(shid uint16)
cmd/proxy/proc/state.go:88
↓ 3 callers
Method
setVState
setVState sets a consistent state for V logging. l.mu is held.
third_party/forked/golang/glog/glog.go:494
↓ 3 callers
Method
setValue
(byte[] value)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/PayloadOperationMessage.java:120
↓ 3 callers
Method
setValueLength
(long valueLength)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/PayloadOperationMessage.java:77
↓ 3 callers
Method
setVersion
@param version the version to set
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MessageHeader.java:154
↓ 3 callers
Method
size
()
cmd/storageserv/stats/shmstats/shmstats.go:138
↓ 3 callers
Method
testLoadCreates
(int records, int loops )
client/Java/Juno/FunctionalTests/src/test/java/com/paypal/qa/juno/ConnectionPoolingTest.java:94
↓ 3 callers
Method
update
Update a record in Juno DB @param key - Key of the record to be Updated @param value - Record Value @return JunoResponse - Juno Response object which
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/impl/JunoClientImpl.java:100
↓ 3 callers
Method
updateHead
only called by reader (head)
pkg/util/ringbuffer.go:224
↓ 3 callers
Method
useLTM
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/IOProcessor.java:134
↓ 3 callers
Method
waitForFinish
(rb *redist.Replicator)
cmd/storageserv/storage/db/sharding.go:52
↓ 3 callers
Function
y
()
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 2 callers
Method
AddCorrelationId
(id []byte)
pkg/logging/logging.go:211
↓ 2 callers
Method
AddDeleteWithRange
(beginKey string, endKey string)
pkg/etcd/etcdclient.go:431
↓ 2 callers
Method
AddExpirationTime
(v uint32)
pkg/logging/logging.go:190
↓ 2 callers
Method
AddKey
(shardid int, key []byte, payload []byte)
cmd/tools/goldendata/client.go:71
↓ 2 callers
Method
AddOpCode
(opcode proto.OpCode)
pkg/logging/logging.go:124
↓ 2 callers
Function
AddRpcClient
(zoneid int, ip string)
cmd/dbscanserv/app/rpcclient.go:55
↓ 2 callers
Method
AddShardId
(shardId uint16)
pkg/logging/logging.go:150
↓ 2 callers
Function
AddShardInfo
(zoneid, shardid, nodeid int, ip string)
cmd/dbscanserv/app/scan.go:118
↓ 2 callers
Method
AddStateWriter
(w IStatesWriter)
pkg/stats/statelog.go:327
↓ 2 callers
Method
BackOff
BackOff increases the expiration time.
pkg/logging/cal/net/io/backoff.go:26
↓ 2 callers
Method
Call
(key []byte, value []byte, params []byte)
pkg/udf/udfmgr.go:27
↓ 2 callers
Method
Call
()
cmd/proxy/stats/shmstatswr.go:43
← previous
next →
901–1,000 of 5,003, ranked by callers