Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/paypal/junodb
/ functions
Functions
5,003 in github.com/paypal/junodb
⨍
Functions
5,003
◇
Types & classes
696
↓ 40 callers
Method
GetOriginatorRequestID
()
pkg/proto/opMsg.go:313
↓ 40 callers
Method
SetOpCode
(op OpCode)
pkg/proto/opMsg.go:140
↓ 39 callers
Method
SetOriginatorRequestID
(id RequestId)
pkg/proto/opMsg.go:325
↓ 39 callers
Method
SetStatusForAll
(status uint8)
test/testutil/mock/common.go:164
↓ 39 callers
Method
size
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MessageHeader.java:231
↓ 38 callers
Method
Reset
Reset resets the expiration time.
pkg/logging/cal/net/io/backoff.go:41
↓ 38 callers
Method
SetVersion
(version uint32)
pkg/proto/opMsg.go:207
↓ 37 callers
Method
Encode
(msg IMessage)
pkg/proto/encode.go:35
↓ 37 callers
Function
New
(conf Config)
pkg/client/clientimpl.go:85
↓ 37 callers
Method
invoke
(t RequestType)
test/drv/junoload/tsteng.go:406
↓ 37 callers
Method
reply
()
cmd/storageserv/storage/proc.go:304
↓ 37 callers
Method
replyWithErrorOpStatus
(st proto.OpStatus)
cmd/storageserv/storage/proc.go:257
↓ 36 callers
Function
RemoveLog
(t *testing.T, hostip string, inProxy bool)
test/testutil/testhelper.go:605
↓ 34 callers
Function
Fatal
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 callers
Method
isSet
()
pkg/proto/metaField.go:124
↓ 33 callers
Method
SetNewRequestID
()
pkg/proto/opMsg.go:304
↓ 33 callers
Function
releaseLock
(owner *reqProcCtxT)
cmd/storageserv/storage/lock.go:83
↓ 32 callers
Method
Bytes
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 callers
Method
GetNamespace
()
cmd/proxy/proc/inbreqctx.go:43
↓ 32 callers
Method
GetPayload
()
pkg/proto/opMsg.go:226
↓ 32 callers
Method
getNumSuccessResponse
()
cmd/proxy/proc/state.go:158
↓ 32 callers
Method
toString
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/conf/JunoPropertiesProvider.java:105
↓ 31 callers
Method
initResponse
(opStatus proto.OpStatus, version uint32, expTime uint32, creationTime uint32)
cmd/storageserv/storage/proc.go:346
↓ 30 callers
Method
Get
(cli *JunoClient)
cmd/tools/goldendata/goldenset.go:33
↓ 30 callers
Function
UpdateAndValidate
************************************************************ * Function to update and get record to do needed validation ***************************
test/testutil/testhelper.go:370
↓ 30 callers
Method
getHeader
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/OperationMessage.java:48
↓ 30 callers
Method
recordOpCount
(String pool, String op_type, String errorType)
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/util/JunoMetrics.java:114
↓ 29 callers
Method
SetAsRequest
()
pkg/proto/opMsg.go:136
↓ 29 callers
Method
SetLastModificationTime
(value uint64)
pkg/proto/opMsg.go:277
↓ 29 callers
Method
SetShardId
(id uint16)
pkg/proto/opMsg.go:176
↓ 28 callers
Function
validateResponse
(t *testing.T, req *proto.OperationalMessage, resp *proto.OperationalMessage, specs specsT)
cmd/storageserv/storage/storage_test.go:310
↓ 27 callers
Method
Data
()
cmd/storageserv/storage/db/record.go:112
↓ 27 callers
Function
GetDB
()
cmd/storageserv/storage/db/rocksdb.go:75
↓ 27 callers
Function
GetShardMgr
Return shardmgr that is active.
pkg/cluster/shardmgr.go:273
↓ 27 callers
Function
RegisterWithFuncs
(initializeFunc func(args ...interface{}) error, finalizeFunc func(), args ...interface{})
pkg/initmgr/init.go:143
↓ 27 callers
Function
ResolveHostIp
()
test/testutil/testhelper.go:1259
↓ 27 callers
Method
Stop
()
test/testutil/server/server.go:57
↓ 26 callers
Method
AddReqIdString
(id string)
pkg/logging/logging.go:175
↓ 26 callers
Method
IPAddress
()
test/testutil/server/server.go:51
↓ 26 callers
Method
Port
()
test/testutil/server/server.go:52
↓ 26 callers
Method
SetKey
(key []byte)
pkg/proto/opMsg.go:192
↓ 26 callers
Method
SetNamespace
(namespace []byte)
pkg/proto/opMsg.go:210
↓ 26 callers
Method
String
()
test/testutil/server/server.go:49
↓ 26 callers
Method
UintOption
(p *uint, name string, value uint, usage string)
pkg/cmd/cmdoption.go:95
↓ 26 callers
Method
create
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 callers
Method
getRequestId
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MetaOperationMessage.java:138
↓ 25 callers
Method
IsForReplication
()
cmd/proxy/proc/inbreqctx.go:42
↓ 25 callers
Method
String
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 callers
Method
clear
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/net/RequestQueue.java:136
↓ 25 callers
Method
init
()
test/testutil/server/cluster.go:49
↓ 24 callers
Function
Key
(Prefix string, list ...int)
pkg/etcd/keys.go:41
↓ 24 callers
Method
Len
Len returns the number of bytes of the unread portion of the buffer; b.Len() == len(b.Bytes()).
pkg/util/buffer.go:59
↓ 24 callers
Method
SetTimeToLive
(value uint32)
pkg/proto/opMsg.go:246
↓ 24 callers
Method
Uint16
()
pkg/shard/shard.go:29
↓ 23 callers
Method
getVersion
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:95
↓ 23 callers
Function
validateRequest
(t *testing.T, req *proto.OperationalMessage, specs specsT)
cmd/storageserv/storage/storage_test.go:291
↓ 22 callers
Method
Error
()
pkg/proto/defs.go:285
↓ 22 callers
Method
Free
()
cmd/storageserv/storage/db/record.go:114
↓ 22 callers
Method
GetExpirationTime
()
pkg/proto/opMsg.go:258
↓ 22 callers
Method
GetLastModificationTime
()
pkg/proto/opMsg.go:281
↓ 22 callers
Function
checkExistence
(t *testing.T, msg *proto.OperationalMessage, msgContentID int, flag int)
cmd/storageserv/storage/storage_test.go:235
↓ 22 callers
Method
recordOpTimer
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 callers
Method
GetKey
()
cmd/storageserv/storage/db/recordid.go:50
↓ 21 callers
Function
LogMsg
(format string, a ...interface{})
cmd/dbscanserv/prime/log.go:92
↓ 21 callers
Function
ServerConfig
()
cmd/storageserv/config/config.go:198
↓ 21 callers
Method
newJunoAsyncClient
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 callers
Function
Errorln
(args ...interface{})
third_party/forked/golang/glog/pplog.go:201
↓ 20 callers
Method
Flush
()
pkg/logging/cal/net/io/clientapi.go:58
↓ 20 callers
Method
Get
(id RecordID, fetchExpired bool)
cmd/storageserv/storage/db/db.go:35
↓ 20 callers
Method
GetConnString
()
pkg/io/listener.go:50
↓ 20 callers
Method
GetOpCodeText
()
pkg/proto/opMsg.go:148
↓ 20 callers
Function
NewEtcdClient
(cfg *Config, clusterName string)
pkg/etcd/etcdclient.go:59
↓ 20 callers
Method
ProcessRequest
(request *proto.OperationalMessage)
internal/cli/processor.go:263
↓ 20 callers
Method
Read
for proxy
pkg/cluster/cluster.go:70
↓ 20 callers
Method
SetOpStatus
(s OpStatus)
pkg/proto/opMsg.go:152
↓ 20 callers
Method
match
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 callers
Method
getOpaque
@return the opaque
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/MessageHeader.java:177
↓ 19 callers
Method
status
()
client/Java/Juno/juno-client-api/src/main/java/com/paypal/juno/client/io/AbstractResponse.java:47
↓ 18 callers
Method
SetRequestID
(id RequestId)
pkg/proto/opMsg.go:300
↓ 18 callers
Function
calLogReqProcEvent
(name string, data []byte)
cmd/proxy/proc/proc_logging.go:92
↓ 18 callers
Method
start
(self)
cmd/etcdsvr/etcdsvr.py:384
↓ 17 callers
Function
NewKVBufferForLog
()
pkg/logging/logging.go:42
↓ 17 callers
Method
Print
(short bool)
pkg/cluster/node.go:243
↓ 17 callers
Method
Put
([]byte)
pkg/util/bytepool.go:29
↓ 17 callers
Method
Remove
(id uint32)
pkg/util/ringbuffer.go:173
↓ 17 callers
Method
Reply
(resp IResponseContext)
pkg/io/requestcontext.go:57
↓ 17 callers
Method
SetOpaque
(opaque uint32)
internal/cli/ctx.go:33
↓ 17 callers
Method
close
()
cmd/storageserv/compact/dbclient.go:165
↓ 17 callers
Function
contents
contents returns the specified log value as a string.
third_party/forked/golang/glog/glog_test.go:74
↓ 17 callers
Method
getNamespace
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/PayloadOperationMessage.java:97
↓ 17 callers
Function
w
(a,b,c,e,f,g)
client/Ruby/docs/js/jquery.js:3
↓ 16 callers
Method
Decode
(wmsg *RawMessage)
pkg/proto/decode.go:326
↓ 16 callers
Method
OnComplete
()
pkg/io/requestcontext.go:58
↓ 16 callers
Method
SetRequest
(opcode OpCode, key []byte, namespace []byte, payload *Payload, ttl uint32)
pkg/proto/opMsg.go:70
↓ 16 callers
Method
SetWithClearValue
(value []byte)
pkg/proto/payload.go:104
↓ 16 callers
Function
ToPrintableAndHexString
(data []byte)
pkg/util/print.go:47
↓ 16 callers
Method
Validate
()
cmd/proxy/config/config.go:181
↓ 16 callers
Method
createCompressablePayload
(int size)
client/Java/Juno/FunctionalTests/src/test/java/com/paypal/qa/juno/DataGenUtils.java:217
↓ 16 callers
Method
getMessageSize
()
client/Java/Juno/juno-client-impl/src/main/java/com/paypal/juno/io/protocol/JunoMessage.java:180
↓ 16 callers
Method
primaryLength
()
pkg/cluster/node.go:157
← previous
next →
101–200 of 5,003, ranked by callers