MCPcopy Create free account

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

Functions380 in github.com/baidu-golang/pbrpc

⨍ Functions 380◇ Types & classes 63
MethodProtoReflect
()
example/pb_example_test.go:61
MethodQpsDataStatus
(c context.Context, method *RPCMethod)
status.go:75
MethodRead
Read reads data from the connection. Read can be made to time out and return an error after a fixed time limit; see SetDeadline and SetReadDeadline.
nettool/customizelistener.go:194
MethodReceive
Receive
connectionpool.go:132
MethodReceive
receive serialized data to target server by connection IO return param: 1. RpcDataPackage unserialized from connection io. or nil if exception found 2
codec.go:119
MethodReceive
Receive data from connection
connection.go:158
MethodReconnect
Reconnect do connect by saved info
connectionpool.go:160
MethodReconnect
Reconnect do connect by saved info
connection.go:194
MethodRegister
Register register RPC service
server.go:641
MethodRemoteAddr
RemoteAddr returns the remote network address.
nettool/customizelistener.go:246
MethodReset
()
pb_status.go:34
MethodReset
()
pb_status.go:105
MethodReset
()
pb_status.go:173
MethodReset
()
datamessage_test.go:31
MethodReset
()
pb_data.go:133
MethodReset
()
pb_data.go:230
MethodReset
()
pb_data.go:285
MethodReset
()
pb_data.go:340
MethodReset
()
example/pb_example_test.go:46
MethodSend
Send
connectionpool.go:120
MethodSend
Here begin to implements link module Codec interface for RpcDataPackageCodec * type Codec[S, R any] interface { Receive() (R, error) Send(S) error
codec.go:62
MethodSend
Send data to connection
connection.go:148
MethodSendReceive
(rpcDataPackage *RpcDataPackage)
connectionpool.go:108
MethodSendReceive
SendReceive send data to connect and block wait data recevie
connection.go:132
MethodSendRpcRequestWithTimeout
SendRpcRequest send rpc request by elect one client with timeout feature
haclient.go:136
MethodServeHTTP
ServeHTTP to serve http reqeust and response to process http rpc handle
httpserver.go:61
MethodSetDeadline
SetDeadline sets the read and write deadlines associated with the connection. It is equivalent to calling both SetReadDeadline and SetWriteDeadline.
nettool/customizelistener.go:271
MethodSetTimeout
set connection io read and write dead line
codec.go:200
MethodStart
Start
status.go:129
MethodStartAndBlock
()
server.go:421
MethodStatus
(c context.Context)
status.go:37
MethodStop
Stop
status.go:197
MethodStop
Stop
codec.go:248
MethodString
()
pb_status.go:43
MethodString
()
pb_status.go:114
MethodString
()
pb_status.go:182
MethodString
()
datamessage_test.go:40
MethodString
()
pb_data.go:142
MethodString
()
pb_data.go:239
MethodString
()
pb_data.go:294
MethodString
()
pb_data.go:349
FunctionTestChunk
TestChunk
rpcpackage_test.go:164
FunctionTestCodecReceive
TestCodecReceive
codec_test.go:55
FunctionTestCodecSend
TestCodecSend
codec_test.go:32
MethodTestConnection
()
connection.go:112
FunctionTestEqualModeWay
(t *testing.T)
nettool/customizelistener_test.go:55
FunctionTestHaClient
TestHaClient test ha client
haclient_test.go:33
FunctionTestHttpRpcServer
TestHttpRpcServer
httpserver_test.go:61
FunctionTestHttpRpcServerWithAuthenticate
TestHttpRpcServerWithAuthenticate
httpserver_test.go:84
FunctionTestHttpRpcServerWithPath
TestHttpRpcServerWithPath
httpserver_test.go:23
FunctionTestNewCustomListenerSelector
(t *testing.T)
nettool/customizelistener_test.go:26
FunctionTestPooledTcpConnectionClient
TestPooledTcpConnectionClient
client_test.go:165
FunctionTestPropertySetAndGet
TestPropertySetAndGet
request.pb_test.go:33
FunctionTestRpcDataWriteReader
TestRpcDataWriteReader test head read and write
header_test.go:32
FunctionTestRpcRequestStatus
TestRpcRequestStatus
status_test.go:65
FunctionTestRpcStatus
TestRpcStatus
status_test.go:44
FunctionTestServerWithAuthenticate
TestServerWithAuthenticate
server_test.go:54
FunctionTestServerWithOldRegisterWay
TestServerWithOldRegisterWay
server_test.go:168
FunctionTestServerWithPublishMethods
TestServerWithPublishMethods
server_test.go:80
FunctionTestServerWithoutPublishMethods
TestServerWithoutPublishMethods
server_test.go:68
FunctionTestSingleTcpConnectionClient
TestSingleTcpConnectionClient
client_test.go:55
FunctionTestSingleTcpConnectionClientAndServerWithChunk
TestSingleTcpConnectionClientAndServerWithChunk
client_test.go:111
FunctionTestSingleTcpConnectionClientByAsync
TestSingleTcpConnectionClientByAsync
client_test.go:183
FunctionTestSingleTcpConnectionClientWithAuthenticate
TestSingleTcpConnectionClientWithAuthenticate
client_test.go:73
FunctionTestSingleTcpConnectionClientWithBadChunkCase
TestSingleTcpConnectionClientWithBadChunkCase
client_test.go:130
FunctionTestSingleTcpConnectionClientWithChunk
TestSingleTcpConnectionClientWithChunk
client_test.go:92
FunctionTestTimetookInSeconds
(t *testing.T)
utility_test.go:25
FunctionTestWriteReaderWithGZIP
TestWriteReaderWithGZIP
rpcpackage_test.go:140
FunctionTestWriteReaderWithMockData
TestWriteReaderWithMockData
rpcpackage_test.go:74
FunctionTestWriteReaderWithRealData
TestWriteReaderWithRealData
rpcpackage_test.go:130
FunctionTestWriteReaderWithSNAPPY
TestWriteReaderWithSNAPPY
rpcpackage_test.go:151
MethodTrace
Trace
client_test.go:47
MethodValidateObject
(ctx context.Context, object *pool.PooledObject)
connectionpool.go:194
FunctionWarning
Warning logs to the WARNING and INFO logs. Arguments are handled in the manner of fmt.Print; a newline is appended if missing.
log.go:36
MethodWrite
Write writes data to the connection. Write can be made to time out and return an error after a fixed time limit; see SetDeadline and SetWriteDeadline.
nettool/customizelistener.go:230
MethodhandleResponse
(session *link.Session[*RpcDataPackage, *RpcDataPackage])
server.go:453
Functioninit
()
pb_status.go:273
Functioninit
()
datamessage_test.go:105
Functioninit
()
pb_data.go:477
Functioninit
()
example/pb_example_test.go:120
← previous301–380 of 380, ranked by callers