MCPcopy Create free account

hub / github.com/baidu-golang/pbrpc / functions

Functions380 in github.com/baidu-golang/pbrpc

⨍ Functions 380◇ Types & classes 63
↓ 2 callersMethodStartServer
StartServer start server with net.Listener
server.go:347
↓ 2 callersMethodString
()
example/pb_example_test.go:55
↓ 2 callersMethodTrace
(service, name string, traceInfo *TraceInfo)
server.go:246
↓ 2 callersMethodTraceId
(traceId int64)
rpcpackage.go:228
↓ 2 callersMethodWriteIO
* Convert RpcPackage to byte array */
rpcpackage.go:346
↓ 2 callersMethodasyncRequest
asyncRequest
client.go:241
↓ 2 callersMethodconnect
(url URL, timeout *time.Duration, sendChanSize int)
connection.go:70
↓ 2 callersFunctiondoConnect
(address string, protocol *RpcDataPackageProtocol[*RpcDataPackage, *RpcDataPackage], timeout *time.Duration, s
connection.go:98
↓ 2 callersFunctiondoHaSimpleRPCInvokeWithSignatureWithConvey
doSimpleRPCInvokeWithSignatureWithConvey send rpc request
haclient_test.go:63
↓ 2 callersFunctiondoReceive
(session *link.Session[*RpcDataPackage, *RpcDataPackage])
connection.go:166
↓ 2 callersMethoddoSendReceive
(rpcDataPackage *RpcDataPackage, ch <-chan *RpcDataPackage)
client.go:287
↓ 2 callersMethoddoServiceInvoke
(c *ErrorContext, msg proto.Message, sname, method string, attachment []byte, logid int64, service Service)
server.go:592
↓ 2 callersFunctiongetHeaderAsByte
(req *http.Request, key string)
httpserver.go:171
↓ 2 callersFunctionintToBytes
(i int32)
header.go:75
↓ 2 callersFunctionisContextType
Is this type implements from context.Context
server.go:890
↓ 2 callersFunctionparsePbMetaFromType
(t reflect.Type)
server.go:127
↓ 2 callersMethodregisterServiceType
Register register RPC service
server.go:646
↓ 2 callersFunctionsendRpc
(host string, port int, serviceName, methodName string, parameterIn, parameterOut proto.Message)
status_test.go:81
↓ 2 callersFunctionsuitableMethods
suitableMethods returns suitable Rpc methods of typ, it will report error using log if reportErr is true.
server.go:801
↓ 2 callersFunctionvalidateRpcDataPackage
(t *testing.T, r2 baidurpc.RpcDataPackage)
rpcpackage_test.go:64
↓ 1 callersMethodAddr
()
nettool/customizelistener.go:59
↓ 1 callersFunctionAttachement
Attachment utility function to get attachemnt from context
server.go:920
↓ 1 callersMethodAuthenticationData
(authenticationData []byte)
rpcpackage.go:194
↓ 1 callersFunctionBindAttachement
BindAttachement add attachement value to the context
server.go:930
↓ 1 callersFunctionBindLogId
BindError add error value to the context
server.go:940
↓ 1 callersMethodClearChunkStatus
()
rpcpackage.go:587
↓ 1 callersMethodClose
()
connectionpool.go:142
↓ 1 callersMethodClose
Close do close all listeners
nettool/customizelistener.go:171
↓ 1 callersFunctionErrors
BindError add error value to the context
server.go:945
↓ 1 callersFunctionGUNZIP
GUNZIP do unzip action by gzip package
compress.go:26
↓ 1 callersFunctionGZIP
GZIP do gzip action by gzip package
compress.go:10
↓ 1 callersMethodGetAttachment
()
rpcpackage.go:339
↓ 1 callersMethodGetAttachmentSize
()
pb_data.go:97
↓ 1 callersMethodGetChunkId
()
pb_data.go:324
↓ 1 callersMethodGetCorrelationId
()
pb_data.go:90
↓ 1 callersMethodGetErr
()
client.go:399
↓ 1 callersMethodGetErrorCode
()
pb_data.go:262
↓ 1 callersMethodGetErrorText
()
pb_data.go:269
↓ 1 callersMethodGetMethodName
()
pb_data.go:172
↓ 1 callersMethodGetParentSpanId
()
pb_data.go:200
↓ 1 callersMethodGetRpcDataPackage
()
client.go:395
↓ 1 callersMethodGetRpcRequestMetaExt
()
rpcpackage.go:272
↓ 1 callersMethodGetRpcRequestMetaExt
()
pb_data.go:207
↓ 1 callersMethodGetSpanId
()
pb_data.go:193
↓ 1 callersMethodGetStreamId
()
pb_data.go:317
↓ 1 callersMethodGetTraceId
()
rpcpackage.go:234
↓ 1 callersMethodGetTraceId
()
pb_data.go:186
↓ 1 callersFunctionInfo
Info logs to the INFO log. Arguments are handled in the manner of fmt.Print; a newline is appended if missing.
log.go:24
↓ 1 callersMethodIsChunkPackage
IsChunkPackage
rpcpackage.go:578
↓ 1 callersMethodIsFinalPackage
IsFinalPackage
rpcpackage.go:583
↓ 1 callersFunctionNewHaRpcCientWithTimewheelSetting
NewHaRpcCient
haclient.go:77
↓ 1 callersFunctionNewRPCRequestStatus
NewRPCRequestStatus
status.go:114
↓ 1 callersFunctionNewRpcCient
NewRpcCient new rpc client
client.go:100
↓ 1 callersFunctionNewRpcCientWithTimeWheelSetting
NewRpcCientWithTimeWheelSetting new rpc client with set timewheel settings
client.go:105
↓ 1 callersFunctionNewRpcDataPackage
()
rpcpackage.go:104
↓ 1 callersFunctionNewSimpleService
NewSimpleService create RPC service
server_test.go:123
↓ 1 callersFunctionNewTCPConnection
* Create a new TCPConnection and try to connect to target server by URL. */
connection.go:59
↓ 1 callersFunctionNewTCPConnectionPool
(url URL, timeout *time.Duration, config *pool.ObjectPoolConfig)
connectionpool.go:54
↓ 1 callersMethodParsePbMeta
ParsePbMeta parse pb tag string
server.go:115
↓ 1 callersMethodRead
Read read byte array
header.go:82
↓ 1 callersMethodReconnect
()
connection.go:41
↓ 1 callersMethodRegister
(service *Service)
server.go:280
↓ 1 callersMethodRequestIn
RequestIn
status.go:178
↓ 1 callersMethodReset
()
pb_data.go:37
↓ 1 callersMethodSendRpcRequest
SendRpcRequest send rpc request by elect one client
haclient.go:111
↓ 1 callersMethodSendRpcRequestAsyc
SendRpcRequestAsyc send rpc request to remote server in asynchronous way
client.go:404
↓ 1 callersMethodSetMessageSize
(MessageSize int32)
header.go:105
↓ 1 callersMethodSetMetaSize
(MetaSize int32)
header.go:113
↓ 1 callersMethodSetReadDeadline
SetReadDeadline sets the deadline for future Read calls and any currently-blocked Read call. A zero value for t means Read will not time out.
nettool/customizelistener.go:278
↓ 1 callersMethodSetWriteDeadline
SetWriteDeadline sets the deadline for future Write calls and any currently-blocked Write call. Even if write times out, it may return n > 0, indicati
nettool/customizelistener.go:287
↓ 1 callersMethodStart
()
server.go:394
↓ 1 callersMethodStop
Stop do stop rpc server
server.go:619
↓ 1 callersMethodTestConnection
()
connection.go:45
↓ 1 callersFunctionUnescapeUnicode
UnescapeUnicode
httpserver.go:214
↓ 1 callersMethodWrite
* Convert Header struct to byte array */
header.go:66
↓ 1 callersMethodWrite
* Convert RpcPackage to byte array */
rpcpackage.go:364
↓ 1 callersMethodasyncRequest
asyncRequest
haclient.go:153
↓ 1 callersMethodconnect
(url URL, timeout *time.Duration, sendChanSize int)
connectionpool.go:72
↓ 1 callersFunctionconvertRpcDataPackage
(msg interface{}, isPtr bool)
codec.go:106
↓ 1 callersFunctioncreatePooledConnectionClient
createClient
client_test.go:280
↓ 1 callersFunctioncreateRpcServerWithChunkSize
createRpcServer create rpc server by port and localhost
client_test.go:222
↓ 1 callersMethoddoHandleProcess
(session *link.Session[*RpcDataPackage, *RpcDataPackage], r *RpcDataPackage)
server.go:476
↓ 1 callersMethoddoReceive
(conn io.ReadWriter)
codec.go:132
↓ 1 callersFunctiondoSimpleRPCInvokeWithSignature
doSimpleRPCInvokeWithSignature send rpc request
benchmark_test.go:65
↓ 1 callersMethodelectClient
electClient
haclient.go:97
↓ 1 callersFunctionequalRpcDataPackage
(r baidurpc.RpcDataPackage, t *testing.T)
rpcpackage_test.go:51
↓ 1 callersMethodexpire
expire remove qps data after time expire
status.go:189
↓ 1 callersFunctionfile_DataMessage_proto_init
()
datamessage_test.go:106
↓ 1 callersFunctionfile_DataMessage_proto_init
()
example/pb_example_test.go:121
↓ 1 callersFunctionfile_DataMessage_proto_rawDescGZIP
()
datamessage_test.go:86
↓ 1 callersFunctionfile_DataMessage_proto_rawDescGZIP
()
example/pb_example_test.go:101
↓ 1 callersFunctionfile_brpc_meta_proto_init
()
pb_data.go:478
↓ 1 callersFunctionfile_go_proto_init
()
pb_status.go:274
↓ 1 callersMethodgetChunkId
getChunkId
rpcpackage.go:572
↓ 1 callersFunctiongetServiceMethod
(path string)
httpserver.go:202
↓ 1 callersFunctionhandleConn
(conn net.Conn, quitString string)
nettool/customizelistener_test.go:97
↓ 1 callersMethodinit
(serviceName, methodName *string)
client.go:133
↓ 1 callersFunctioninitChuckInfo
(r *RpcDataPackage)
rpcpackage.go:141
↓ 1 callersMethodregisterWithMethodMapping
registerWithMethodMapping call RegisterName with method name mapping map
server.go:703
↓ 1 callersMethodsafeReceive
()
client.go:231
← previousnext →101–200 of 380, ranked by callers