MCPcopy Index your code

hub / github.com/paypal/junodb / functions

Functions5,003 in github.com/paypal/junodb

↓ 7 callersMethodListenAndServe
(addr string)
cmd/proxy/stats/monhandler.go:103
↓ 7 callersFunctionRecordReplication
(opType string, status string, destination string, latency int64)
pkg/logging/otel/logger.go:292
↓ 7 callersFunctionRecordSSConnection
(endpoint string, status string, latency int64)
pkg/logging/otel/logger.go:308
↓ 7 callersMethodShallowCopy
(from *RawMessage)
pkg/proto/rawmessage.go:46
↓ 7 callersMethodState
()
pkg/stats/statelog.go:44
↓ 7 callersMethodTruncate
Truncate discards all but the first n unread bytes from the buffer but continues to use the same allocated storage. It panics if n is negative or grea
pkg/util/buffer.go:68
↓ 7 callersMethodWatchEvt
(key string, ctx context.Context)
pkg/etcd/etcdclient.go:347
↓ 7 callersMethodallocate
(primaryCount int, secondaryCount int)
pkg/cluster/node.go:140
↓ 7 callersMethodbuildMockOperationMessage
Given a mock mayfly record build an operation message for the response @param mmr @param status @return
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/mock/MockJunoUnresponsiveServer.java:279
↓ 7 callersMethodbuildMockOperationMessage
Given a mock mayfly record build an operation message for the response @param mmr @param status @return
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/mock/MockJunoServer.java:275
↓ 7 callersFunctionc
(t)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 7 callersFunctioncheckResponse
checkResponse validates the response from the server against the original request.
pkg/client/clientimpl.go:344
↓ 7 callersMethodcreate
Insert a record into Juno DB with default TTL @param key - Key of the record to be Inserted @param value - Record Value @return Mono<JunoResponse> - E
client/Java/Juno/juno-client-api/src/main/java/com/paypal/juno/client/JunoReactClient.java:37
↓ 7 callersFunctiondbPutWrapper
TODO: need a version for delete Wrapper of db.Put & Forward
cmd/storageserv/storage/storage.go:1190
↓ 7 callersMethoddequeue
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/RequestQueue.java:194
↓ 7 callersMethodgetConfigPrefix
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:237
↓ 7 callersMethodgetHost
@return Host name of the Server
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/transport/TransportConfigHolder.java:40
↓ 7 callersMethodgetPort
@return Server port
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/transport/TransportConfigHolder.java:45
↓ 7 callersMethodgetRecordNamespace
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:173
↓ 7 callersMethodisEmpty
()
pkg/proto/mayfly/opmsg.go:136
↓ 7 callersMethodisOk
(err error)
cmd/tools/cmd/cli/cli.go:356
↓ 7 callersMethodisPayloadCompressed
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:196
↓ 7 callersMethodisPingResp
(OperationMessage op, BaseProcessor processor)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/PingMessage.java:85
↓ 7 callersMethodisQuit
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/WorkerPool.java:165
↓ 7 callersMethodlogStrSsIdx
(ssIndex uint32)
cmd/proxy/proc/base.go:956
↓ 7 callersMethodmerge
(rangeid int, jm *prime.JoinMap, rs *prime.Result)
cmd/dbscanserv/app/scan.go:188
↓ 7 callersFunctionn
()
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 7 callersFunctionnewAbortRequest
(req *proto.OperationalMessage)
cmd/storageserv/storage/storage_test.go:339
↓ 7 callersFunctionnewOptionData
newOptionData function applies the options passed in and returns an initialized optionData.
pkg/client/option.go:83
↓ 7 callersFunctionnumBytesToPadTo8
(size int)
cmd/proxy/stats/shmstats/shmstats.go:143
↓ 7 callersMethodprint
(s severity, args ...interface{})
third_party/forked/golang/glog/glog.go:702
↓ 7 callersMethodprocessRedistTarget
Prepare target node to accept new shards -- added new shards allowed -- set redist_tgtstate_zoneid_nodeid to ready
cmd/storageserv/watcher/watcher.go:323
↓ 7 callersFunctionrun_cmd
(cmd, get_result=False)
cmd/etcdsvr/etcdsvr.py:73
↓ 7 callersFunctions
()
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 7 callersMethodsendRepairs
()
cmd/proxy/proc/processor.go:301
↓ 7 callersMethodsetSSOpRequestFromClientRequest
(request *proto.OperationalMessage, op proto.OpCode, version uint32, keepValue bool)
cmd/proxy/proc/base.go:469
↓ 7 callersMethodvalidateAndReturnDefaultInt
(String key, Integer prop, int min, int max, Integer defaultVal)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/JunoClientConfigHolder.java:230
↓ 6 callersMethodAddCreationTime
(v uint32)
pkg/logging/logging.go:197
↓ 6 callersMethodCleanUp
only called by reader (head) two cases: if full, clean up size/10, dequeue if not nil if head is free (nil), move head till not nil
pkg/util/ringbuffer.go:265
↓ 6 callersFunctionConnect
(cfg *Config, clsName string)
pkg/etcd/etcd.go:35
↓ 6 callersMethodDelete
(id RecordID)
cmd/storageserv/storage/db/db.go:37
↓ 6 callersMethodExec
()
pkg/cmd/cmd.go:55
↓ 6 callersFunctionGetCurrentWorkerStatsManager
TODO make sure shmStats has been initialized....
cmd/proxy/stats/shmstats/shmstats.go:948
↓ 6 callersMethodGetInt
(key string, defv int)
pkg/stats/redist/stats.go:198
↓ 6 callersFunctionGetNamespaceAndKey
(key []byte)
cmd/dbscanserv/prime/result.go:204
↓ 6 callersFunctionGetReplicateCount
()
cmd/dbscanserv/prime/opdata.go:175
↓ 6 callersMethodGetStatus
()
pkg/io/requestcontext.go:42
↓ 6 callersMethodInit
()
test/drv/junoload/stats.go:129
↓ 6 callersFunctionIsCancel
()
cmd/dbscanserv/app/collect.go:57
↓ 6 callersFunctionIsCopyNamespace
()
cmd/dbscanserv/prime/opdata.go:211
↓ 6 callersMethodIsExpired
()
cmd/storageserv/storage/db/record.go:310
↓ 6 callersFunctionLoadConfig
(file string)
cmd/clustermgr/cmd/config.go:116
↓ 6 callersFunctionLoadNewConfig
(file string)
cmd/clustermgr/cmd/config.go:127
↓ 6 callersMethodMarkDelete
()
cmd/storageserv/storage/db/record.go:337
↓ 6 callersMethodMustStop
(t *testing.T)
pkg/logging/otel/test/mock_collector.go:70
↓ 6 callersFunctionNewConfig
(addrs ...string)
pkg/etcd/config.go:58
↓ 6 callersFunctionNewDBError
(e error)
cmd/storageserv/storage/db/rocksdb.go:59
↓ 6 callersMethodNewIterator
NewIterator returns an Iterator over the the database that uses the ReadOptions given.
third_party/patches/forked/tecbot/gorocksdb/db.go:368
↓ 6 callersFunctionNewSSClientWithNumShards
(server string, ns string, numShards uint32)
test/testutil/ssclient/ssclient.go:104
↓ 6 callersMethodNewSnapshot
NewSnapshot creates a new snapshot of the database.
third_party/patches/forked/tecbot/gorocksdb/db.go:381
↓ 6 callersMethodNext
Next returns a slice containing the next n bytes from the buffer, advancing the buffer as if the bytes had been returned by Read. If there are fewer t
pkg/util/buffer.go:281
↓ 6 callersMethodPutValuesWithTxn
(op OpList)
pkg/etcd/etcdwriter.go:36
↓ 6 callersMethodReleaseSnapshot
ReleaseSnapshot releases the snapshot and its resources.
third_party/patches/forked/tecbot/gorocksdb/db.go:387
↓ 6 callersMethodResetRecord
()
cmd/storageserv/storage/db/record.go:186
↓ 6 callersMethodRun
()
pkg/cluster/clusterstats.go:81
↓ 6 callersMethodSetAsResponse
()
pkg/proto/header.go:94
↓ 6 callersMethodSetBlockBasedTableFactory
SetBlockBasedTableFactory sets the block based table factory.
third_party/patches/forked/tecbot/gorocksdb/options.go:970
↓ 6 callersMethodSetListeners
(values []string)
pkg/service/svccfg.go:76
↓ 6 callersMethodShutdown
()
cmd/storageserv/storage/db/db.go:32
↓ 6 callersFunctionVerboseln
(args ...interface{})
third_party/forked/golang/glog/pplog.go:219
↓ 6 callersFunctionWithCond
WithCond function returns an IOption that sets a context.
pkg/client/option.go:63
↓ 6 callersFunctionacquireLock
(p *reqProcCtxT)
cmd/storageserv/storage/lock.go:45
↓ 6 callersMethodcommitFailed
()
cmd/proxy/proc/processor.go:186
↓ 6 callersMethodcopy
(other Node)
pkg/cluster/node.go:224
↓ 6 callersFunctioncu
(a,b)
client/Ruby/docs/js/jquery.js:2
↓ 6 callersMethoddoBatch
Perform batch operations @param request - List of request to be processed @return List of JunoResponses - Juno Response object which contains the stat
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/impl/JunoClientImpl.java:146
↓ 6 callersMethodenqueue
(OperationMessage req)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/RequestQueue.java:119
↓ 6 callersMethodgenAlphaNumString
Generate a String of random alpha-numeric data. @param length the length of the string to gen; must be >= 0 @throws IllegalArgumentException if lengt
client/Java/Juno/FunctionalTests/src/test/java/com/paypal/qa/juno/DataGenUtils.java:87
↓ 6 callersMethodgetAppName
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:155
↓ 6 callersMethodgetCompressionAchieved
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:204
↓ 6 callersMethodgetConnectionTimeoutMsecs
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/JunoClientConfigHolder.java:366
↓ 6 callersMethodgetHost
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/IOProcessor.java:122
↓ 6 callersMethodgetMessageSize
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MessageHeader.java:142
↓ 6 callersMethodgetPort
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/IOProcessor.java:126
↓ 6 callersMethodgetResponseTimeout
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/JunoClientConfigHolder.java:444
↓ 6 callersMethodgetTtl
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MetaOperationMessage.java:122
↓ 6 callersMethodgetWithPrefix
key is sorted in descending order
pkg/etcd/etcdclient.go:475
↓ 6 callersMethodhasNoPending
()
cmd/proxy/proc/state.go:150
↓ 6 callersFunctionht
(e)
cmd/clustermgr/redistserv/web/js-css/jquery-ui-1.13.2/jquery-ui.min.js:6
↓ 6 callersMethodinitResponseWithStatus
(opStatus proto.OpStatus)
cmd/storageserv/storage/proc.go:382
↓ 6 callersMethodisDone
()
cmd/proxy/proc/base.go:246
↓ 6 callersMethodnewRandomKey
(s int)
test/cli/util.go:95
↓ 6 callersMethodonSuccessResponse
()
cmd/proxy/proc/state.go:130
↓ 6 callersMethodprintProperties
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/JunoClientConfigHolder.java:59
↓ 6 callersMethodprocessRedistSource
source start to forward requests to target
cmd/storageserv/watcher/watcher.go:369
↓ 6 callersFunctionrunMockCollector
(t *testing.T, cfg mockCollectorConfig)
pkg/logging/otel/test/mock_collector.go:212
↓ 6 callersMethodsetMockParams
(mp *MockParams, key []byte)
test/testutil/mock/client.go:117
↓ 6 callersFunctionsim_response_time
(zoneid uint32, nodeid uint32, send_freq uint32, proctime uint32, chQuit chan bool, cs *ClusterStats)
pkg/cluster/clusterstats_test.go:56
↓ 6 callersMethodstopMockServer
()
client/Java/Juno/juno-client-impl/src/test/java/com/paypal/juno/mock/MockJunoServer.java:76
↓ 6 callersFunctionvalidate
(r *proto.OperationalMessage)
cmd/storageserv/storage/storage.go:113
← previousnext →401–500 of 5,003, ranked by callers