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
↓ 4 callers
Method
getAddress
()
client/Java/examples/employee-dashboard-app/src/main/java/com/paypal/juno/employeedashboardapp/model/Employee.java:75
↓ 4 callers
Method
getApplicationName
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:148
↓ 4 callers
Method
getBufferLength
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/PayloadOperationMessage.java:145
↓ 4 callers
Method
getConnectionTimeout
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:131
↓ 4 callers
Method
getCreationTime
()
client/Java/Juno/juno-client-api/src/main/java/com/paypal/juno/client/io/JunoResponse.java:76
↓ 4 callers
Method
getDbInstanceAndKey
(id RecordID)
cmd/storageserv/storage/db/sharding.go:33
↓ 4 callers
Method
getFieldSize
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MetaMessageTagAndType.java:74
↓ 4 callers
Function
getHistogram
(histName CMetric)
pkg/logging/otel/logger.go:230
↓ 4 callers
Method
getMaxKeySize
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:165
↓ 4 callers
Method
getMsgType
()
pkg/proto/header.go:119
↓ 4 callers
Method
getPartition
(key string)
pkg/util/cmap.go:49
↓ 4 callers
Method
getPort
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/transport/socket/SocketConfigHolder.java:58
↓ 4 callers
Method
getRecord
Return our mock record based on the namespace and key. @param namespace outer key @param key inner key @return the mock record if we have it, otherwi
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/mock/MockJunoUnresponsiveServer.java:222
↓ 4 callers
Method
getRecord
Return our mock record based on the namespace and key. @param namespace outer key @param key inner key @return the mock record if we have it, otherwi
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/mock/MockJunoServer.java:216
↓ 4 callers
Method
getRecord
(int id)
client/Java/examples/employee-dashboard-app/src/main/java/com/paypal/juno/employeedashboardapp/service/JunoCache.java:93
↓ 4 callers
Method
getReqStartTime
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:164
↓ 4 callers
Method
getRequestUuid
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MetaOperationMessage.java:142
↓ 4 callers
Method
getServerIp
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/OperationMessage.java:75
↓ 4 callers
Method
getTTL
()
test/drv/junoload/randomgen.go:72
↓ 4 callers
Method
grow
grow grows the buffer to guarantee space for n more bytes. It returns the index where bytes should be written. If the buffer can't grow it will panic
pkg/util/buffer.go:88
↓ 4 callers
Function
h
(a)
client/Ruby/docs/js/jquery.js:2
↓ 4 callers
Function
highlight
()
client/Ruby/docs/js/full_list.js:176
↓ 4 callers
Method
incrementFailedAttempts
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/RequestQueue.java:242
↓ 4 callers
Method
incrementSuccessfulAttempts
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/RequestQueue.java:244
↓ 4 callers
Method
initialize
()
pkg/stats/sharedstats.go:53
↓ 4 callers
Function
isConflict
TODO: revisit... Used to detect replication conflict. Not for conditional update
cmd/storageserv/storage/storage.go:1129
↓ 4 callers
Method
nDigits
nDigits formats an n-digit integer at buf.tmp[i], padding with pad on the left. It assumes d >= 0.
third_party/forked/golang/glog/glog.go:669
↓ 4 callers
Function
newDefaultGetRequest
()
cmd/storageserv/storage/get_test.go:87
↓ 4 callers
Method
onEvent
(TestEvent event)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/IOProcessor.java:195
↓ 4 callers
Method
onFailure
(rc *SSRequestContext)
cmd/proxy/proc/destroy.go:75
↓ 4 callers
Method
onIOError
()
cmd/proxy/proc/state.go:145
↓ 4 callers
Method
onPrepareFailure
(rc *SSRequestContext)
cmd/proxy/proc/destroy2.go:144
↓ 4 callers
Method
onTimeout
()
cmd/proxy/proc/state.go:140
↓ 4 callers
Method
output
output writes the data to the log files and releases the buffer.
third_party/forked/golang/glog/glog.go:737
↓ 4 callers
Function
printUsage
()
cmd/clustermgr/clusterctl/clusterctl.go:167
↓ 4 callers
Method
processIntProperty
(String property, Integer currentValue, int min,int max, Integer defaultValue)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/JunoClientConfigHolder.java:264
↓ 4 callers
Method
replyToClientAndRepair
()
cmd/proxy/proc/get.go:77
↓ 4 callers
Method
sendMessage
(msg *proto.RawMessage, ssIndex uint32)
cmd/proxy/proc/base.go:489
↓ 4 callers
Method
sendPrepareRequest
()
cmd/proxy/proc/processor.go:57
↓ 4 callers
Method
serializeObject
(Employee emp)
client/Java/examples/employee-dashboard-app/src/main/java/com/paypal/juno/employeedashboardapp/model/Employee.java:138
↓ 4 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-impl/src/main/java/com/paypal/juno/client/impl/JunoClientImpl.java:123
↓ 4 callers
Method
setCompressionType
(CompressionType compressionType)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/PayloadOperationMessage.java:129
↓ 4 callers
Method
setInitSSRequest
()
cmd/proxy/proc/base.go:75
↓ 4 callers
Method
setMessageSize
(long messageSize)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:184
↓ 4 callers
Method
setOpCode
(opcode proto.OpCode)
cmd/proxy/proc/state.go:92
↓ 4 callers
Method
setStatus
(ServerOperationStatus status)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:137
↓ 4 callers
Method
setValue
(byte[] value)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:113
↓ 4 callers
Method
setupShards
(dbnamePrefix string, shardMap shard.Map)
cmd/storageserv/storage/db/sharding.go:35
↓ 4 callers
Method
shuttingDown
()
pkg/service/service.go:194
↓ 4 callers
Function
sim_timeout
(zoneid uint32, nodeid uint32, to_freq uint32, chQuit chan bool, cs *ClusterStats)
pkg/cluster/clusterstats_test.go:29
↓ 4 callers
Method
size
()
cmd/proxy/stats/shmstats/shmstats.go:233
↓ 4 callers
Method
succeeded
()
cmd/proxy/proc/get.go:73
↓ 4 callers
Method
testCreateGetKey
(int loops)
client/Java/Juno/FunctionalTests/src/test/java/com/paypal/qa/juno/ConnectionPoolingTest.java:279
↓ 4 callers
Method
useSSL
@return true to use SSL
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/transport/TransportConfigHolder.java:50
↓ 4 callers
Method
validateInput
Validate the user supplied inputs for limits based on the operation type @param req - Request parameters to be validated @param opr - Type of Operatio
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/JunoClientUtil.java:157
↓ 4 callers
Method
validatePath
set path to be under Config.RootDir if path is empty or not specified as absolute path
cmd/storageserv/config/config.go:219
↓ 4 callers
Function
writeBasicSSRequestInfo
(b *logging.KeyValueBuffer, ssOp proto.OpCode, ssIndex int, ssAddr string, proc *ProcessorBase)
cmd/proxy/proc/proc_logging.go:85
↓ 4 callers
Method
writeBuf
(ByteBuf out)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MessageHeader.java:307
↓ 4 callers
Function
x
(a,b)
client/Ruby/docs/js/jquery.js:2
↓ 3 callers
Method
AddDropReason
(reason string)
pkg/logging/logging.go:146
↓ 3 callers
Method
AddExample
(cmdExample string, desc string)
pkg/cmd/cmd.go:52
↓ 3 callers
Function
AddHeader
AddHeader returns data ready for sending to the CAL daemon by returning msg prepended by a CAL message header.
pkg/logging/cal/net/protocol/wire.go:34
↓ 3 callers
Method
AddNamespace
(ns []byte)
pkg/logging/logging.go:108
↓ 3 callers
Method
AddOpRequestResponse
difference from AddOpRequestResponseInfo(): not log correlation id, key, or namespace
pkg/logging/logging.go:283
↓ 3 callers
Method
AddRequestHandleTime
(rhtus int)
pkg/logging/logging.go:179
↓ 3 callers
Function
CleanStatus
CleanStatus makes s an appropriate CAL status.
pkg/logging/cal/net/protocol/message.go:284
↓ 3 callers
Method
Close
()
pkg/io/outboundconnector.go:129
↓ 3 callers
Function
CloseDb
()
cmd/dbscanserv/prime/db.go:155
↓ 3 callers
Function
CloseProxyConnect
()
cmd/dbscanserv/prime/result.go:74
↓ 3 callers
Method
CompactRangeOptions
CompactRangeOptions runs a manual compaction on a Range of keys with options.
third_party/patches/forked/tecbot/gorocksdb/compact_range_options.go:23
↓ 3 callers
Method
Copy
Copy deep copy the given LimitsConfig
cmd/proxy/config/limitscfg.go:171
↓ 3 callers
Method
CreateResponse
()
pkg/proto/opMsg.go:75
↓ 3 callers
Method
Decode
(raw []byte)
pkg/proto/mayfly/msg.go:247
↓ 3 callers
Method
Decode
(value *bytes.Buffer)
test/testutil/mock/common.go:87
↓ 3 callers
Function
DecodeRecordKey
(sskey []byte)
cmd/storageserv/storage/db/recordid.go:78
↓ 3 callers
Function
DecodeRecordKeyNoShardID
(storageKey []byte)
cmd/storageserv/storage/db/recordid.go:86
↓ 3 callers
Function
DecodeVal
(val []byte)
cmd/dbscanserv/prime/meta.go:199
↓ 3 callers
Method
Decrypt
()
pkg/proto/payload.go:174
↓ 3 callers
Method
DeepCopy
(from *RawMessage)
pkg/proto/rawmessage.go:53
↓ 3 callers
Method
Default
()
pkg/sec/seccfg.go:62
↓ 3 callers
Method
DeleteKey
(key string)
pkg/etcd/etcdclient.go:319
↓ 3 callers
Method
DidResume
()
pkg/sec/sslctx.go:33
↓ 3 callers
Method
EncodeToBuffer
(buffer *bytes.Buffer)
cmd/storageserv/storage/db/record.go:199
↓ 3 callers
Method
EncodingSize
()
cmd/storageserv/storage/db/record.go:195
↓ 3 callers
Method
Equal
(id RequestId)
pkg/proto/requestid.go:90
↓ 3 callers
Function
Exitln
Exitln logs to the FATAL, ERROR, WARNING, and INFO logs, then calls os.Exit(1).
third_party/forked/golang/glog/glog.go:1154
↓ 3 callers
Function
Finalize
()
cmd/proxy/stats/shmstats/shmstats.go:898
↓ 3 callers
Method
Flush
()
third_party/forked/golang/glog/glog.go:417
↓ 3 callers
Function
GenRemoteAddr
(ip string, zoneid int)
cmd/dbscanserv/app/remote.go:147
↓ 3 callers
Method
Get
()
pkg/util/bytepool.go:28
↓ 3 callers
Method
GetCipherName
()
pkg/sec/sslctx.go:32
↓ 3 callers
Method
GetConfig
GetConfig returns the config properties of a given key
pkg/cfg/cfg.go:130
↓ 3 callers
Method
GetCorrelationID
()
pkg/proto/opMsg.go:333
↓ 3 callers
Function
GetDbMapRange
()
cmd/dbscanserv/prime/db.go:62
↓ 3 callers
Method
GetDecryptionKey
(version uint32)
pkg/proto/cryptoks.go:33
↓ 3 callers
Method
GetError
()
internal/cli/ctx.go:31
↓ 3 callers
Method
GetHttpMonAddr
()
test/testutil/server/server.go:54
↓ 3 callers
Function
GetListenerStats
()
cmd/proxy/stats/shmstats/shmstats.go:937
↓ 3 callers
Method
GetNumActiveConnections
()
pkg/io/listener.go:51
↓ 3 callers
Function
GetNumOpenDbs
()
cmd/dbscanserv/prime/db.go:107
← previous
next →
701–800 of 5,003, ranked by callers