MCPcopy Create free account

hub / github.com/cockroachdb/rpc-bench / functions

Functions158 in github.com/cockroachdb/rpc-bench

⨍ Functions 158◇ Types & classes 20
↓ 12 callersFunctionsovWire
(x uint64)
wire.pb.go:392
↓ 10 callersFunctionencodeVarintWire
(dAtA []byte, offset int, v uint64)
wire.pb.go:330
↓ 7 callersMethodClose
Close closes the underlying connection.
conn.go:54
↓ 5 callersMethodMarshal
()
echo.pb.go:288
↓ 5 callersFunctionbenchmarkEcho
(b *testing.B, size int, accept func(net.Listener, *tls.Config) error, setup func(net.Addr), teardown func(),
rpc_test.go:57
↓ 4 callersMethodString
()
echo.pb.go:34
↓ 4 callersMethodUnmarshal
(dAtA []byte)
echo.pb.go:391
↓ 4 callersFunctionbenchmarkEchoGRPC
(b *testing.B, listenAndServeFn func(net.Listener, *tls.Config) error, size int)
rpc_test.go:142
↓ 4 callersFunctionbenchmarkEchoStreamGRPC
(b *testing.B, listenAndServeFn func(net.Listener, *tls.Config) error, size int)
rpc_test.go:171
↓ 4 callersFunctionmarshal
(buf *bytes.Buffer, m proto.Message)
server.go:192
↓ 4 callersMethodrecvProto
(m proto.Message, uncompressedSize uint32, decompressor decompressFunc)
conn.go:88
↓ 4 callersMethodsendFrame
(data []byte)
conn.go:58
↓ 4 callersFunctionsovEcho
(x uint64)
echo.pb.go:385
↓ 3 callersMethodEcho
(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption)
echo.pb.go:151
↓ 3 callersMethodMarshalToSizedBuffer
(dAtA []byte)
echo.pb.go:303
↓ 3 callersMethodMarshalToSizedBuffer
(dAtA []byte)
echo.pb.go:333
↓ 3 callersMethodMarshalToSizedBuffer
(dAtA []byte)
wire.pb.go:243
↓ 3 callersMethodMarshalToSizedBuffer
(dAtA []byte)
wire.pb.go:293
↓ 3 callersMethodReset
()
echo.pb.go:33
↓ 3 callersMethodSize
()
echo.pb.go:359
↓ 3 callersMethodSize
()
echo.pb.go:372
↓ 3 callersMethodSize
()
wire.pb.go:341
↓ 3 callersMethodSize
()
wire.pb.go:366
↓ 3 callersMethodwrite
(w io.Writer, data []byte)
conn.go:75
↓ 2 callersMethodMarshal
()
wire.pb.go:228
↓ 2 callersFunctionNewEchoClient
(cc *grpc.ClientConn)
echo.pb.go:159
↓ 2 callersMethodRecv
()
echo.pb.go:183
↓ 2 callersFunctionRegisterEchoServer
(s *grpc.Server, srv EchoServer)
echo.pb.go:220
↓ 2 callersMethodSend
(*EchoRequest)
echo.pb.go:182
↓ 2 callersMethodStreamEcho
(ctx context.Context, opts ...grpc.CallOption)
echo.pb.go:152
↓ 2 callersFunctionbenchmarkEchoGobRPC
(b *testing.B, size int)
rpc_test.go:283
↓ 2 callersFunctionbenchmarkEchoProtoHTTP
(b *testing.B, size int, accept func(net.Listener, *tls.Config) error, roundTripper http.RoundTripper)
rpc_test.go:415
↓ 2 callersFunctionbenchmarkEchoProtoHTTP1
(b *testing.B, size int)
rpc_test.go:455
↓ 2 callersFunctionbenchmarkEchoProtoHTTP2
(b *testing.B, size int)
rpc_test.go:471
↓ 2 callersFunctionbenchmarkEchoProtoRPC
(b *testing.B, size int)
rpc_test.go:340
↓ 2 callersFunctionencodeVarintEcho
(dAtA []byte, offset int, v uint64)
echo.pb.go:348
↓ 2 callersFunctionskipEcho
(dAtA []byte)
echo.pb.go:561
↓ 2 callersFunctionskipWire
(dAtA []byte)
wire.pb.go:733
↓ 1 callersMethodMarshalTo
([]byte)
server.go:189
↓ 1 callersFunctionNewClient
NewClient returns a new rpc.Client to handle requests to the set of services at the other end of the connection.
client.go:156
↓ 1 callersFunctionNewClientCodec
NewClientCodec returns a new rpc.ClientCodec using Protobuf-RPC on conn.
client.go:47
↓ 1 callersFunctionNewServerCodec
NewServerCodec returns a serverCodec that communicates with the ClientCodec on the other end of the given conn.
server.go:48
↓ 1 callersFunctionServeConn
ServeConn runs the Protobuf-RPC server on a single connection. ServeConn blocks, serving the connection until the client hangs up. The caller typicall
server.go:183
↓ 1 callersMethodSize
()
server.go:188
↓ 1 callersMethodUnmarshal
(dAtA []byte)
echo.pb.go:476
↓ 1 callersMethodUnmarshal
(dAtA []byte)
wire.pb.go:398
↓ 1 callersMethodUnmarshal
(dAtA []byte)
wire.pb.go:559
↓ 1 callersFunctionrandString
(n int)
rpc_test.go:49
↓ 1 callersMethodreadRequestBody
(r *bufio.Reader, header *RequestHeader, request proto.Message)
server.go:175
↓ 1 callersMethodreadRequestHeader
(r *bufio.Reader, header *RequestHeader)
server.go:171
↓ 1 callersMethodreadResponseBody
(header *ResponseHeader, response proto.Message)
client.go:149
↓ 1 callersMethodreadResponseHeader
(header *ResponseHeader)
client.go:145
↓ 1 callersMethodwriteRequest
(r *rpc.Request, request proto.Message)
client.go:109
↓ 1 callersMethodwriteResponse
(r *rpc.Response, response proto.Message)
server.go:122
FunctionBenchmarkGRPCServeHTTP_1K
(b *testing.B)
rpc_test.go:244
FunctionBenchmarkGRPCServeHTTP_64K
(b *testing.B)
rpc_test.go:248
FunctionBenchmarkGRPCServeHTTP_Stream_1K
(b *testing.B)
rpc_test.go:252
FunctionBenchmarkGRPCServeHTTP_Stream_64k
(b *testing.B)
rpc_test.go:256
FunctionBenchmarkGRPCServe_1K
(b *testing.B)
rpc_test.go:215
FunctionBenchmarkGRPCServe_64K
(b *testing.B)
rpc_test.go:219
FunctionBenchmarkGRPCServe_Stream_1K
(b *testing.B)
rpc_test.go:223
FunctionBenchmarkGRPCServe_Stream_64k
(b *testing.B)
rpc_test.go:227
FunctionBenchmarkGobRPC_1K
(b *testing.B)
rpc_test.go:315
FunctionBenchmarkGobRPC_64K
(b *testing.B)
rpc_test.go:319
FunctionBenchmarkProtoHTTP1_1K
(b *testing.B)
rpc_test.go:463
FunctionBenchmarkProtoHTTP1_64K
(b *testing.B)
rpc_test.go:467
FunctionBenchmarkProtoHTTP2_1K
(b *testing.B)
rpc_test.go:478
FunctionBenchmarkProtoHTTP2_64K
(b *testing.B)
rpc_test.go:482
FunctionBenchmarkProtoRPC_1K
(b *testing.B)
rpc_test.go:368
FunctionBenchmarkProtoRPC_64K
(b *testing.B)
rpc_test.go:372
MethodDescriptor
()
echo.pb.go:36
MethodDescriptor
()
echo.pb.go:80
MethodDescriptor
()
wire.pb.go:58
MethodDescriptor
()
wire.pb.go:134
MethodEcho
(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption)
echo.pb.go:163
MethodEcho
(context.Context, *EchoRequest)
echo.pb.go:205
MethodEcho
(ctx context.Context, req *EchoRequest)
echo.pb.go:213
MethodEcho
(ctx context.Context, req *EchoRequest)
rpc_test.go:123
MethodEcho
(args *EchoRequest, reply *EchoResponse)
rpc_test.go:264
MethodEnumDescriptor
()
wire.pb.go:43
MethodGetCompression
()
wire.pb.go:109
MethodGetCompression
()
wire.pb.go:185
MethodGetError
()
wire.pb.go:178
MethodGetId
()
wire.pb.go:88
MethodGetId
()
wire.pb.go:164
MethodGetMethod
()
wire.pb.go:95
MethodGetMethod
()
wire.pb.go:171
MethodGetMethodId
()
wire.pb.go:102
MethodGetMsg
()
echo.pb.go:66
MethodGetMsg
()
echo.pb.go:110
MethodGetUncompressedSize
()
wire.pb.go:116
MethodGetUncompressedSize
()
wire.pb.go:192
MethodMarshal
()
echo.pb.go:318
MethodMarshal
()
wire.pb.go:278
MethodMarshalTo
(dAtA []byte)
echo.pb.go:298
MethodMarshalTo
(dAtA []byte)
echo.pb.go:328
MethodMarshalTo
(dAtA []byte)
wire.pb.go:238
MethodMarshalTo
(dAtA []byte)
wire.pb.go:288
MethodProtoMessage
()
echo.pb.go:35
MethodProtoMessage
()
echo.pb.go:79
next →1–100 of 158, ranked by callers