MCPcopy Index your code

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

Functions380 in github.com/baidu-golang/pbrpc

⨍ Functions 380◇ Types & classes 63
↓ 38 callersMethodClose
()
connection.go:40
↓ 27 callersMethodWrite
()
header.go:38
↓ 19 callersFunctionstopRpcServer
(rpcServer *baidurpc.TcpServer)
server_test.go:185
↓ 14 callersMethodStart
()
server.go:278
↓ 14 callersFunctioninitRequest
(r *RpcDataPackage)
rpcpackage.go:148
↓ 12 callersMethodGetMeta
()
rpcpackage.go:328
↓ 12 callersFunctiontestSendRpc
(testName string, client *baidurpc.RpcClient, timeout, auth bool, chunksize uint32, async bool)
client_test.go:201
↓ 11 callersFunctionstartRpcServer
(chunksize uint32)
client_test.go:230
↓ 10 callersMethodSend
(rpcDataPackage *RpcDataPackage)
connection.go:38
↓ 10 callersMethodStop
()
server.go:279
↓ 9 callersFunctioninitRpcMeta
(r *RpcDataPackage)
rpcpackage.go:135
↓ 8 callersMethodErrorCode
(errorCode int32)
rpcpackage.go:282
↓ 8 callersMethodErrorText
(errorText string)
rpcpackage.go:290
↓ 8 callersMethodSendRpcRequest
SendRpcRequest send rpc request to remote server
client.go:302
↓ 8 callersMethodSetParameterIn
SetParameterIn
client.go:144
↓ 8 callersFunctionerrResponse
(errno int, message string)
httpserver.go:193
↓ 8 callersFunctiontoJson
(o interface{})
httpserver.go:197
↓ 7 callersMethodGetMethodName
()
server.go:227
↓ 7 callersMethodGetServiceName
()
server.go:226
↓ 7 callersMethodServe
Serve do listening from net trasport
nettool/customizelistener.go:118
↓ 7 callersFunctioncreateClient
createClient
client_test.go:258
↓ 7 callersFunctioninitRpcDataPackage
()
rpcpackage_test.go:34
↓ 6 callersFunctionError
Error logs to the ERROR, WARNING, and INFO logs. Arguments are handled in the manner of fmt.Print; a newline is appended if missing.
log.go:48
↓ 6 callersMethodGetMagicCode
()
header.go:101
↓ 6 callersFunctionGetServiceId
(serviceName, methodName string)
server.go:614
↓ 6 callersMethodRegisterNameWithMethodMapping
RegisterNameWithMethodMapping call RegisterName with method name mapping map
server.go:660
↓ 6 callersMethodSetAuthService
SetAuthService set authenticate service
server.go:444
↓ 6 callersMethodSetHost
SetHost set host name
client.go:72
↓ 6 callersMethodSetPort
SetPort set port
client.go:78
↓ 6 callersFunctiondoSimpleRPCInvokeWithSignatureWithConvey
doSimpleRPCInvokeWithSignatureWithConvey send rpc request
client_test.go:302
↓ 5 callersMethodGetResponse
()
pb_data.go:76
↓ 5 callersFunctionInfof
Infof logs to the INFO log. Arguments are handled in the manner of fmt.Printf; a newline is appended if missing.
log.go:30
↓ 5 callersMethodRead
(bytes []byte)
header.go:44
↓ 5 callersMethodReceive
()
connection.go:39
↓ 5 callersMethodSetData
(Data []byte)
rpcpackage.go:184
↓ 5 callersFunctioncreateRpcServer
createRpcServer create rpc server by port and localhost
server_test.go:38
↓ 5 callersFunctionfile_brpc_meta_proto_rawDescGZIP
()
pb_data.go:450
↓ 5 callersFunctionwrapResponse
(r *RpcDataPackage, errorCode int, errorText string)
server.go:607
↓ 4 callersMethodChunk
Chunk chunk to small packages by chunk size
rpcpackage.go:517
↓ 4 callersMethodCompressType
(compressType int32)
rpcpackage.go:208
↓ 4 callersMethodGetRequest
()
pb_data.go:69
↓ 4 callersMethodRegisterName
RegisterName register publishes in the server with specified name for its set of methods of the receiver value that satisfy the following conditions:
server.go:698
↓ 4 callersMethodSendReceive
(rpcDataPackage *RpcDataPackage)
connection.go:37
↓ 4 callersMethodString
()
pb_data.go:46
↓ 4 callersFunctionWarningf
Warningf logs to the WARNING and INFO logs. Arguments are handled in the manner of fmt.Printf; a newline is appended if missing.
log.go:42
↓ 4 callersFunctiongetHeaderAsInt64
(req *http.Request, key string)
httpserver.go:179
↓ 4 callersFunctionsendHttpRequest
(urlpath, method, body string, paramters, headers map[string]string)
httpserver_test.go:114
↓ 4 callersFunctionstartRpcServerWithHttpMode
startRpcServer start rpc server and register echo service as default rpc service
client_test.go:235
↓ 4 callersFunctionstopRpcServer
(rpcServer *baidurpc.TcpServer)
example/server_example_test.go:201
↓ 3 callersMethodAccept
()
nettool/customizelistener.go:50
↓ 3 callersMethodClose
Close close connection
connection.go:181
↓ 3 callersMethodGet
()
client.go:391
↓ 3 callersMethodGetData
()
rpcpackage.go:335
↓ 3 callersMethodGetMessageSize
()
header.go:109
↓ 3 callersMethodGetMetaSize
()
header.go:117
↓ 3 callersMethodGetRequestRpcDataPackage
GetRequestRpcDataPackage
client.go:149
↓ 3 callersFunctionInt
Int convert to pointer type of int
server_test.go:191
↓ 3 callersFunctionNewCustomListenerSelectorByListener
NewCustomListenerSelectorByListener
nettool/customizelistener.go:89
↓ 3 callersMethodNewParameter
()
server.go:228
↓ 3 callersMethodReadIO
* Read byte array and initialize RpcPackage */
rpcpackage.go:428
↓ 3 callersMethodSendRpcRequestWithTimeout
SendRpcRequest send rpc request to remote server
client.go:308
↓ 3 callersMethodSetAttachment
(Attachment []byte)
rpcpackage.go:189
↓ 3 callersFunctionTimetookInSeconds
get time took in seconds
utility.go:25
↓ 3 callersFunctionWriteReaderWithRealData
WriteReaderWithRealData
rpcpackage_test.go:97
↓ 3 callersMethodborrowObject
()
connectionpool.go:91
↓ 3 callersFunctiondoInit
(r *RpcDataPackage)
rpcpackage.go:315
↓ 3 callersFunctionfile_go_proto_rawDescGZIP
()
pb_status.go:249
↓ 3 callersFunctioninitHeader
(r *RpcDataPackage)
rpcpackage.go:129
↓ 3 callersFunctioninitResponse
(r *RpcDataPackage)
rpcpackage.go:158
↓ 3 callersFunctionint64ToString
(i int64)
httpserver.go:189
↓ 3 callersFunctionisMessageType
Is this type implements from proto.Message
server.go:874
↓ 3 callersFunctionparseMetaString
(meta string)
server.go:164
↓ 2 callersMethodAuthenticate
Authenticate do auth action if return true auth success
server.go:234
↓ 2 callersMethodChuckInfo
(streamId int64, chunkId int64)
rpcpackage.go:306
↓ 2 callersMethodCorrelationId
(correlationId int64)
rpcpackage.go:201
↓ 2 callersMethodDoService
* RPC service call back method. message : parameter in from RPC client or 'nil' if has no parameter attachment : attachment content from R
server.go:225
↓ 2 callersMethodEnableHttp
EnableHttp
server.go:439
↓ 2 callersFunctionErrorf
Errorf logs to the ERROR, WARNING, and INFO logs. Arguments are handled in the manner of fmt.Printf; a newline is appended if missing.
log.go:54
↓ 2 callersMethodGetChunkStreamId
GetChunkStreamId
rpcpackage.go:566
↓ 2 callersMethodGetCompressType
()
pb_data.go:83
↓ 2 callersMethodGetLogId
()
pb_data.go:179
↓ 2 callersMethodGetParentSpanId
()
rpcpackage.go:256
↓ 2 callersMethodGetServiceName
()
pb_data.go:165
↓ 2 callersMethodLogId
(logId int64)
rpcpackage.go:215
↓ 2 callersMethodMagicCode
(magicCode string)
rpcpackage.go:113
↓ 2 callersMethodMethodName
(methodName string)
rpcpackage.go:176
↓ 2 callersMethodNewCodec
(rw io.ReadWriter)
codec.go:233
↓ 2 callersFunctionNewCustomListenerSelector
NewCustomListenerSelector new a CustomListenerSelector
nettool/customizelistener.go:74
↓ 2 callersFunctionNewCustomListenerSelectorByAddr
NewCustomListenerSelectorByAddr new a CustomListenerSelector by address string
nettool/customizelistener.go:79
↓ 2 callersFunctionNewRpcDataPackageProtocol
NewRpcDataPackageProtocol create a RpcDataPackageProtocol and start timewheel
codec.go:222
↓ 2 callersMethodParentSpanId
(parentSpanId int64)
rpcpackage.go:250
↓ 2 callersMethodRead
(b []byte)
rpcpackage.go:504
↓ 2 callersMethodRegisterDefaultListener
RegisterDefaultListener
nettool/customizelistener.go:113
↓ 2 callersMethodRegisterListener
RegisterListener
nettool/customizelistener.go:103
↓ 2 callersMethodRegisterRpc
RegisterRpc register Rpc direct
server.go:901
↓ 2 callersMethodRpcRequestMetaExt
(ext map[string]string)
rpcpackage.go:261
↓ 2 callersMethodServiceName
(serviceName string)
rpcpackage.go:168
↓ 2 callersMethodSetMagicCode
(MagicCode []byte)
header.go:94
↓ 2 callersMethodSetTraceService
SetTraceService set trace service
server.go:449
↓ 2 callersMethodSpanId
(spanId int64)
rpcpackage.go:239
next →1–100 of 380, ranked by callers