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
↓ 6 callers
Method
validatePath
set path to be under Config.RootDir if path is empty or not specified as absolute path
cmd/proxy/config/config.go:158
↓ 6 callers
Function
waitForStateWithSSs
(fn func(ss ...SSNode) bool, nodes ...SSNode)
test/testutil/server/cluster.go:525
↓ 5 callers
Method
AddOpRequest
difference from AddOpRequestInfo(): namespace and key not logged
pkg/logging/logging.go:364
↓ 5 callers
Method
AddOpRequestResponseInfo
(req, resp *proto.OperationalMessage)
pkg/logging/logging.go:222
↓ 5 callers
Method
AddRequestID
(id proto.RequestId)
pkg/logging/logging.go:168
↓ 5 callers
Method
AddTTL
(v uint32)
pkg/logging/logging.go:183
↓ 5 callers
Function
ApproxEqual
(v1 uint32, v2 uint32, epsilon uint32)
test/testutil/testhelper.go:223
↓ 5 callers
Function
CalStatus
(st proto.OpStatus)
pkg/logging/calstatus.go:69
↓ 5 callers
Method
CalStatus
()
pkg/logging/calstatus.go:76
↓ 5 callers
Method
Cap
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 callers
Method
ClearPayload
()
pkg/proto/opMsg.go:222
↓ 5 callers
Function
ConfigBlockCache
()
cmd/storageserv/storage/db/config.go:358
↓ 5 callers
Function
Debugln
(args ...interface{})
third_party/forked/golang/glog/pplog.go:247
↓ 5 callers
Method
Delete
(cli *JunoClient)
cmd/tools/goldendata/goldenset.go:32
↓ 5 callers
Method
Encode
()
test/testutil/mock/common.go:75
↓ 5 callers
Function
Flush
Flush flushes all pending log I/O.
third_party/forked/golang/glog/glog.go:439
↓ 5 callers
Function
GetBufferPool
(size int)
pkg/util/mem.go:48
↓ 5 callers
Method
GetCtx
()
pkg/io/requestcontext.go:53
↓ 5 callers
Method
GetData
()
pkg/proto/payload.go:83
↓ 5 callers
Function
GetExpirationTime
(ttl uint32)
pkg/util/util.go:142
↓ 5 callers
Function
GetManager
()
cmd/storageserv/redist/redist.go:86
↓ 5 callers
Method
GetName
()
pkg/cmd/cmd.go:46
↓ 5 callers
Method
GetNamespace
()
pkg/proto/opMsg.go:214
↓ 5 callers
Method
GetNetConn
()
pkg/sec/sslctx.go:36
↓ 5 callers
Method
GetNodes
(id uint32, start_zoneid uint32)
pkg/cluster/shardmap.go:74
↓ 5 callers
Method
GetNumWorkers
()
cmd/proxy/stats/monhandler.go:75
↓ 5 callers
Function
GetReplicateErrors
()
cmd/dbscanserv/prime/opdata.go:179
↓ 5 callers
Method
GetShards
()
pkg/cluster/node.go:74
↓ 5 callers
Method
HexDump
()
pkg/proto/rawmessage.go:69
↓ 5 callers
Function
HtmlDurationEscapeString
(d time.Duration)
pkg/stats/htmltmpl.go:169
↓ 5 callers
Function
Initialize
* Two arguments required arg 0: *Config arg 1: uint8 bitmask flag arg 2: isServerManager (optional) */
pkg/sec/secinit.go:68
↓ 5 callers
Function
IsLocalAddress
(addr string)
pkg/net/netutil/netutil.go:54
↓ 5 callers
Method
IsRecordPresent
(id RecordID, rec *Record)
cmd/storageserv/storage/db/db.go:40
↓ 5 callers
Function
JunoInternalKeyForLimits
JunoInternalKeyForLimits returns the key for limits configuration
cmd/proxy/config/limitscfg.go:74
↓ 5 callers
Function
LogWorkerExit
(workerId int)
pkg/logging/logging.go:446
↓ 5 callers
Function
LogWorkerStart
(workerId int)
pkg/logging/logging.go:429
↓ 5 callers
Function
Murmur3Hash
(data []byte)
pkg/util/util.go:50
↓ 5 callers
Function
NewDecoder
(r io.Reader)
pkg/proto/decode.go:39
↓ 5 callers
Function
NewErrorOutboundResponse
(status uint32)
pkg/io/requestcontext.go:167
↓ 5 callers
Function
NewInboundRespose
(opCode proto.OpCode, m *proto.RawMessage)
pkg/io/requestcontext.go:131
↓ 5 callers
Function
NewProxyInRespose
(clientRequest *proto.OperationalMessage, m *proto.RawMessage, receiveTime time.Time, logData *logging.KeyValu
cmd/proxy/proc/base.go:186
↓ 5 callers
Function
NewRecordIDWithBuffer
(buf *bytes.Buffer, shardId shard.ID, microShardId uint8, namespace []byte, key []byte)
cmd/storageserv/storage/db/recordid.go:54
↓ 5 callers
Method
NewRequest
NewRequest creates a new OperationalMessage with the provided parameters.
pkg/client/clientimpl.go:314
↓ 5 callers
Function
NewRingBufferWithExtra
(size uint32, extra_pct uint32)
pkg/util/ringbuffer.go:123
↓ 5 callers
Function
NewRocksDBptions
Note: rocksdb C binding does not support getters for option types
cmd/storageserv/storage/db/config.go:246
↓ 5 callers
Function
NewShardMap
(c *Cluster)
pkg/cluster/shardmap.go:43
↓ 5 callers
Function
NewUint16State
(addr *uint16, header string, fullHeader string)
pkg/stats/statelog.go:137
↓ 5 callers
Function
OnelineVersionString
()
pkg/version/version.go:40
↓ 5 callers
Function
P
(t)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 5 callers
Function
PingServers
(cmd int, startid int, stopid int, addr ...string)
cmd/dbscanserv/app/rpcclient.go:169
↓ 5 callers
Method
PutValue
(key string, val string, params ...int)
pkg/etcd/etcdclient.go:212
↓ 5 callers
Method
Read
(r IReader)
pkg/cluster/cluster.go:128
↓ 5 callers
Method
ReadFromCache
(cacheName string)
pkg/cluster/cluster.go:408
↓ 5 callers
Method
Resize
(n int)
pkg/util/ppbuffer.go:29
↓ 5 callers
Method
Run
()
pkg/service/service.go:156
↓ 5 callers
Method
Run
()
cmd/storageserv/app/storagemgr.go:120
↓ 5 callers
Method
Send
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 callers
Method
SetAsResponse
()
pkg/proto/opMsg.go:132
↓ 5 callers
Method
SetCompactionFilter
(opts *gorocksdb.Options, enable bool)
cmd/storageserv/storage/db/shardingByPrefix.go:44
↓ 5 callers
Method
SetSource
(ip net.IP, port uint16, appName []byte)
pkg/proto/opMsg.go:289
↓ 5 callers
Method
SetStatus
(s string)
pkg/stats/redist/stats.go:153
↓ 5 callers
Method
Timeout
(t int, i int)
cmd/dbscanserv/app/rpcclient.go:89
↓ 5 callers
Function
ValidateZones
Validate shardids are unique and consecutive.
pkg/cluster/util.go:40
↓ 5 callers
Function
WaitForUp
(waittime time.Duration, servers ...IServer)
test/testutil/server/server.go:384
↓ 5 callers
Function
WatchForProxy
Watch for version change
pkg/etcd/watch.go:30
↓ 5 callers
Method
WriteTo
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 callers
Function
_
(t)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 5 callers
Function
a
(b,c)
client/Ruby/docs/js/jquery.js:2
↓ 5 callers
Method
complete
(calstatus string, opStatus string, rht time.Duration, opCode string, target string)
cmd/proxy/replication/replicaterequest.go:141
↓ 5 callers
Method
encode
(raw []byte)
pkg/proto/mayfly/msg.go:67
↓ 5 callers
Method
getBooleanProperty
(final String key, boolean defaultValue)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/BasePropertiesProvider.java:112
↓ 5 callers
Method
getConnectTimeout
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/IOProcessor.java:130
↓ 5 callers
Method
getConnectionPoolSize
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:137
↓ 5 callers
Method
getFromWorkerWithWorkerId
(urlPath string, query url.Values, workerId int)
cmd/proxy/stats/monhandler.go:212
↓ 5 callers
Method
getMessageType
()
pkg/proto/defs.go:334
↓ 5 callers
Method
getNumNoStageErrors
()
cmd/proxy/proc/state.go:170
↓ 5 callers
Method
getOpaqueResMap
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/RequestQueue.java:97
↓ 5 callers
Method
getReqId
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:188
↓ 5 callers
Method
getResponseTimeout
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:181
↓ 5 callers
Method
getStringProperty
(String key, String defaultValue)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/BasePropertiesProvider.java:138
↓ 5 callers
Method
getType
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 callers
Method
header
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 callers
Method
isKeyRange
()
test/drv/junoload/tsteng.go:248
↓ 5 callers
Method
isOpened
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/IOProcessor.java:286
↓ 5 callers
Method
isRetryEnabled
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/JunoClientConfigHolder.java:408
↓ 5 callers
Method
logError
(op string, err error)
pkg/client/clientimpl.go:132
↓ 5 callers
Method
logStrOpCode
(opcode proto.OpCode)
cmd/proxy/proc/base.go:960
↓ 5 callers
Function
newDefaultPrepDeleteRequest
()
cmd/storageserv/storage/delete_test.go:144
↓ 5 callers
Method
newRandomKey
(s int)
test/drv/bulkload/bulkload.go:60
↓ 5 callers
Method
onException
(TestEvent event)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/Scheduler.java:273
↓ 5 callers
Method
onPrepareFailure
(rc *SSRequestContext)
cmd/proxy/proc/set.go:73
↓ 5 callers
Method
onPrepareFailure
(rc *SSRequestContext)
cmd/proxy/proc/update.go:120
↓ 5 callers
Method
onPrepareFailure
(rc *SSRequestContext)
cmd/proxy/proc/create.go:135
↓ 5 callers
Function
parseKeys
(key string)
test/drv/bulkload/bulkload.go:220
↓ 5 callers
Function
printUsage
()
cmd/clustermgr/clustermgr.go:166
↓ 5 callers
Method
process
(request *proto.OperationalMessage)
test/testutil/ssclient/ssclient.go:113
↓ 5 callers
Method
readBuf
(ByteBuf in)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/OperationMessage.java:91
↓ 5 callers
Method
recordConnectCount
(String endpoint, String status, String cause)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/JunoMetrics.java:148
↓ 5 callers
Method
replaceFront
(mb *prime.MessageBlock)
cmd/dbscanserv/app/scan.go:386
↓ 5 callers
Method
sendAbort
(ssIndex uint32)
cmd/proxy/proc/processor.go:55
← previous
next →
501–600 of 5,003, ranked by callers