MCPcopy Index your code

hub / github.com/paypal/junodb / functions

Functions5,003 in github.com/paypal/junodb

↓ 40 callersMethodGetOriginatorRequestID
()
pkg/proto/opMsg.go:313
↓ 40 callersMethodSetOpCode
(op OpCode)
pkg/proto/opMsg.go:140
↓ 39 callersMethodSetOriginatorRequestID
(id RequestId)
pkg/proto/opMsg.go:325
↓ 39 callersMethodSetStatusForAll
(status uint8)
test/testutil/mock/common.go:164
↓ 39 callersMethodsize
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MessageHeader.java:231
↓ 38 callersMethodReset
Reset resets the expiration time.
pkg/logging/cal/net/io/backoff.go:41
↓ 38 callersMethodSetVersion
(version uint32)
pkg/proto/opMsg.go:207
↓ 37 callersMethodEncode
(msg IMessage)
pkg/proto/encode.go:35
↓ 37 callersFunctionNew
(conf Config)
pkg/client/clientimpl.go:85
↓ 37 callersMethodinvoke
(t RequestType)
test/drv/junoload/tsteng.go:406
↓ 37 callersMethodreply
()
cmd/storageserv/storage/proc.go:304
↓ 37 callersMethodreplyWithErrorOpStatus
(st proto.OpStatus)
cmd/storageserv/storage/proc.go:257
↓ 36 callersFunctionRemoveLog
(t *testing.T, hostip string, inProxy bool)
test/testutil/testhelper.go:605
↓ 34 callersFunctionFatal
Fatal logs to the FATAL, ERROR, WARNING, and INFO logs, including a stack trace of all running goroutines, then calls os.Exit(255). Arguments are hand
third_party/forked/golang/glog/glog.go:1111
↓ 34 callersMethodisSet
()
pkg/proto/metaField.go:124
↓ 33 callersMethodSetNewRequestID
()
pkg/proto/opMsg.go:304
↓ 33 callersFunctionreleaseLock
(owner *reqProcCtxT)
cmd/storageserv/storage/lock.go:83
↓ 32 callersMethodBytes
Bytes returns a slice of length b.Len() holding the unread portion of the buffer. The slice is valid for use only until the next buffer modification (
pkg/util/buffer.go:45
↓ 32 callersMethodGetNamespace
()
cmd/proxy/proc/inbreqctx.go:43
↓ 32 callersMethodGetPayload
()
pkg/proto/opMsg.go:226
↓ 32 callersMethodgetNumSuccessResponse
()
cmd/proxy/proc/state.go:158
↓ 32 callersMethodtoString
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:105
↓ 31 callersMethodinitResponse
(opStatus proto.OpStatus, version uint32, expTime uint32, creationTime uint32)
cmd/storageserv/storage/proc.go:346
↓ 30 callersMethodGet
(cli *JunoClient)
cmd/tools/goldendata/goldenset.go:33
↓ 30 callersFunctionUpdateAndValidate
************************************************************ * Function to update and get record to do needed validation ***************************
test/testutil/testhelper.go:370
↓ 30 callersMethodgetHeader
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/OperationMessage.java:48
↓ 30 callersMethodrecordOpCount
(String pool, String op_type, String errorType)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/JunoMetrics.java:114
↓ 29 callersMethodSetAsRequest
()
pkg/proto/opMsg.go:136
↓ 29 callersMethodSetLastModificationTime
(value uint64)
pkg/proto/opMsg.go:277
↓ 29 callersMethodSetShardId
(id uint16)
pkg/proto/opMsg.go:176
↓ 28 callersFunctionvalidateResponse
(t *testing.T, req *proto.OperationalMessage, resp *proto.OperationalMessage, specs specsT)
cmd/storageserv/storage/storage_test.go:310
↓ 27 callersMethodData
()
cmd/storageserv/storage/db/record.go:112
↓ 27 callersFunctionGetDB
()
cmd/storageserv/storage/db/rocksdb.go:75
↓ 27 callersFunctionGetShardMgr
Return shardmgr that is active.
pkg/cluster/shardmgr.go:273
↓ 27 callersFunctionRegisterWithFuncs
(initializeFunc func(args ...interface{}) error, finalizeFunc func(), args ...interface{})
pkg/initmgr/init.go:143
↓ 27 callersFunctionResolveHostIp
()
test/testutil/testhelper.go:1259
↓ 27 callersMethodStop
()
test/testutil/server/server.go:57
↓ 26 callersMethodAddReqIdString
(id string)
pkg/logging/logging.go:175
↓ 26 callersMethodIPAddress
()
test/testutil/server/server.go:51
↓ 26 callersMethodPort
()
test/testutil/server/server.go:52
↓ 26 callersMethodSetKey
(key []byte)
pkg/proto/opMsg.go:192
↓ 26 callersMethodSetNamespace
(namespace []byte)
pkg/proto/opMsg.go:210
↓ 26 callersMethodString
()
test/testutil/server/server.go:49
↓ 26 callersMethodUintOption
(p *uint, name string, value uint, usage string)
pkg/cmd/cmdoption.go:95
↓ 26 callersMethodcreate
Insert a record into Juno DB with default TTL @param key - Key of the record to be Inserted @param value - Record Value @return JunoResponse - Juno Re
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/impl/JunoClientImpl.java:54
↓ 26 callersMethodgetRequestId
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MetaOperationMessage.java:138
↓ 25 callersMethodIsForReplication
()
cmd/proxy/proc/inbreqctx.go:42
↓ 25 callersMethodString
String returns the contents of the unread portion of the buffer as a string. If the Buffer is a nil pointer, it returns "<nil>".
pkg/util/buffer.go:49
↓ 25 callersMethodclear
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/RequestQueue.java:136
↓ 25 callersMethodinit
()
test/testutil/server/cluster.go:49
↓ 24 callersFunctionKey
(Prefix string, list ...int)
pkg/etcd/keys.go:41
↓ 24 callersMethodLen
Len returns the number of bytes of the unread portion of the buffer; b.Len() == len(b.Bytes()).
pkg/util/buffer.go:59
↓ 24 callersMethodSetTimeToLive
(value uint32)
pkg/proto/opMsg.go:246
↓ 24 callersMethodUint16
()
pkg/shard/shard.go:29
↓ 23 callersMethodgetVersion
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:95
↓ 23 callersFunctionvalidateRequest
(t *testing.T, req *proto.OperationalMessage, specs specsT)
cmd/storageserv/storage/storage_test.go:291
↓ 22 callersMethodError
()
pkg/proto/defs.go:285
↓ 22 callersMethodFree
()
cmd/storageserv/storage/db/record.go:114
↓ 22 callersMethodGetExpirationTime
()
pkg/proto/opMsg.go:258
↓ 22 callersMethodGetLastModificationTime
()
pkg/proto/opMsg.go:281
↓ 22 callersFunctioncheckExistence
(t *testing.T, msg *proto.OperationalMessage, msgContentID int, flag int)
cmd/storageserv/storage/storage_test.go:235
↓ 22 callersMethodrecordOpTimer
To record timer based metric for Juno operations. It records the time for JUNO_SSL_CLIENT txns and its status @param metricName - Name of the metric.
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/JunoMetrics.java:65
↓ 21 callersMethodGetKey
()
cmd/storageserv/storage/db/recordid.go:50
↓ 21 callersFunctionLogMsg
(format string, a ...interface{})
cmd/dbscanserv/prime/log.go:92
↓ 21 callersFunctionServerConfig
()
cmd/storageserv/config/config.go:198
↓ 21 callersMethodnewJunoAsyncClient
Instantiates a JunoAsyncClient implementation using the Juno config properties from the given URL. <p> Ensure that uKernel CAL Client is initialized.
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/client/JunoClientFactory.java:103
↓ 20 callersFunctionErrorln
(args ...interface{})
third_party/forked/golang/glog/pplog.go:201
↓ 20 callersMethodFlush
()
pkg/logging/cal/net/io/clientapi.go:58
↓ 20 callersMethodGet
(id RecordID, fetchExpired bool)
cmd/storageserv/storage/db/db.go:35
↓ 20 callersMethodGetConnString
()
pkg/io/listener.go:50
↓ 20 callersMethodGetOpCodeText
()
pkg/proto/opMsg.go:148
↓ 20 callersFunctionNewEtcdClient
(cfg *Config, clusterName string)
pkg/etcd/etcdclient.go:59
↓ 20 callersMethodProcessRequest
(request *proto.OperationalMessage)
internal/cli/processor.go:263
↓ 20 callersMethodRead
for proxy
pkg/cluster/cluster.go:70
↓ 20 callersMethodSetOpStatus
(s OpStatus)
pkg/proto/opMsg.go:152
↓ 20 callersMethodmatch
match reports whether the file matches the pattern. It uses a string comparison if the pattern contains no metacharacters.
third_party/forked/golang/glog/glog.go:277
↓ 19 callersMethodgetOpaque
@return the opaque
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MessageHeader.java:177
↓ 19 callersMethodstatus
()
client/Java/Juno/juno-client-api/src/main/java/com/paypal/juno/client/io/AbstractResponse.java:47
↓ 18 callersMethodSetRequestID
(id RequestId)
pkg/proto/opMsg.go:300
↓ 18 callersFunctioncalLogReqProcEvent
(name string, data []byte)
cmd/proxy/proc/proc_logging.go:92
↓ 18 callersMethodstart
(self)
cmd/etcdsvr/etcdsvr.py:384
↓ 17 callersFunctionNewKVBufferForLog
()
pkg/logging/logging.go:42
↓ 17 callersMethodPrint
(short bool)
pkg/cluster/node.go:243
↓ 17 callersMethodPut
([]byte)
pkg/util/bytepool.go:29
↓ 17 callersMethodRemove
(id uint32)
pkg/util/ringbuffer.go:173
↓ 17 callersMethodReply
(resp IResponseContext)
pkg/io/requestcontext.go:57
↓ 17 callersMethodSetOpaque
(opaque uint32)
internal/cli/ctx.go:33
↓ 17 callersMethodclose
()
cmd/storageserv/compact/dbclient.go:165
↓ 17 callersFunctioncontents
contents returns the specified log value as a string.
third_party/forked/golang/glog/glog_test.go:74
↓ 17 callersMethodgetNamespace
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/PayloadOperationMessage.java:97
↓ 17 callersFunctionw
(a,b,c,e,f,g)
client/Ruby/docs/js/jquery.js:3
↓ 16 callersMethodDecode
(wmsg *RawMessage)
pkg/proto/decode.go:326
↓ 16 callersMethodOnComplete
()
pkg/io/requestcontext.go:58
↓ 16 callersMethodSetRequest
(opcode OpCode, key []byte, namespace []byte, payload *Payload, ttl uint32)
pkg/proto/opMsg.go:70
↓ 16 callersMethodSetWithClearValue
(value []byte)
pkg/proto/payload.go:104
↓ 16 callersFunctionToPrintableAndHexString
(data []byte)
pkg/util/print.go:47
↓ 16 callersMethodValidate
()
cmd/proxy/config/config.go:181
↓ 16 callersMethodcreateCompressablePayload
(int size)
client/Java/Juno/FunctionalTests/src/test/java/com/paypal/qa/juno/DataGenUtils.java:217
↓ 16 callersMethodgetMessageSize
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:180
↓ 16 callersMethodprimaryLength
()
pkg/cluster/node.go:157
← previousnext →101–200 of 5,003, ranked by callers