Home
last modified time | relevance | path

Searched refs:serviceImpl (Results 1 – 25 of 40) sorted by relevance

12

/external/grpc-grpc/src/csharp/Grpc.HealthCheck.Tests/
DHealthClientServerTest.cs38 Grpc.HealthCheck.HealthServiceImpl serviceImpl; field in Grpc.HealthCheck.Tests.HealthClientServerTest
43 serviceImpl = new HealthServiceImpl(); in Init()
48 Services = { Grpc.Health.V1.Health.BindService(serviceImpl) }, in Init()
68 serviceImpl.SetStatus("", HealthCheckResponse.Types.ServingStatus.Serving); in ServiceIsRunning()
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/helloworld/
DHelloWorldClientTest.java54 private final GreeterGrpc.GreeterImplBase serviceImpl = field in HelloWorldClientTest
65 .forName(serverName).directExecutor().addService(serviceImpl).build().start()); in setUp()
85 verify(serviceImpl) in greet_messageDeliveredToServer()
/external/grpc-grpc-java/examples/example-kotlin/src/test/kotlin/io/grpc/examples/helloworld/
DHelloWorldClientTest.kt55 …private val serviceImpl = mock(GreeterGrpc.GreeterImplBase::class.java, delegatesTo<Any>(object : … constant in io.grpc.examples.helloworld.HelloWorldClientTest
68 .forName(serverName).directExecutor().addService(serviceImpl).build().start()) in setUp()
88 verify<GreeterGrpc.GreeterImplBase>(serviceImpl) in greet_messageDeliveredToServer()
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DTestGrpc.cs529 public static grpc::ServerServiceDefinition BindService(TestServiceBase serviceImpl) in BindService() argument
532 .AddMethod(__Method_EmptyCall, serviceImpl.EmptyCall) in BindService()
533 .AddMethod(__Method_UnaryCall, serviceImpl.UnaryCall) in BindService()
534 .AddMethod(__Method_CacheableUnaryCall, serviceImpl.CacheableUnaryCall) in BindService()
535 .AddMethod(__Method_StreamingOutputCall, serviceImpl.StreamingOutputCall) in BindService()
536 .AddMethod(__Method_StreamingInputCall, serviceImpl.StreamingInputCall) in BindService()
537 .AddMethod(__Method_FullDuplexCall, serviceImpl.FullDuplexCall) in BindService()
538 .AddMethod(__Method_HalfDuplexCall, serviceImpl.HalfDuplexCall) in BindService()
539 .AddMethod(__Method_UnimplementedCall, serviceImpl.UnimplementedCall).Build(); in BindService()
658 public static grpc::ServerServiceDefinition BindService(UnimplementedServiceBase serviceImpl) in BindService() argument
[all …]
DBenchmarkServiceGrpc.cs317 public static grpc::ServerServiceDefinition BindService(BenchmarkServiceBase serviceImpl) in BindService() argument
320 .AddMethod(__Method_UnaryCall, serviceImpl.UnaryCall) in BindService()
321 .AddMethod(__Method_StreamingCall, serviceImpl.StreamingCall) in BindService()
322 .AddMethod(__Method_StreamingFromClient, serviceImpl.StreamingFromClient) in BindService()
323 .AddMethod(__Method_StreamingFromServer, serviceImpl.StreamingFromServer) in BindService()
324 .AddMethod(__Method_StreamingBothWays, serviceImpl.StreamingBothWays).Build(); in BindService()
DWorkerServiceGrpc.cs315 public static grpc::ServerServiceDefinition BindService(WorkerServiceBase serviceImpl) in BindService() argument
318 .AddMethod(__Method_RunServer, serviceImpl.RunServer) in BindService()
319 .AddMethod(__Method_RunClient, serviceImpl.RunClient) in BindService()
320 .AddMethod(__Method_CoreCount, serviceImpl.CoreCount) in BindService()
321 .AddMethod(__Method_QuitWorker, serviceImpl.QuitWorker).Build(); in BindService()
DMetricsGrpc.cs189 public static grpc::ServerServiceDefinition BindService(MetricsServiceBase serviceImpl) in BindService() argument
192 .AddMethod(__Method_GetAllGauges, serviceImpl.GetAllGauges) in BindService()
193 .AddMethod(__Method_GetGauge, serviceImpl.GetGauge).Build(); in BindService()
/external/grpc-grpc/src/csharp/Grpc.Examples/
DMathGrpc.cs281 public static grpc::ServerServiceDefinition BindService(MathBase serviceImpl) in BindService() argument
284 .AddMethod(__Method_Div, serviceImpl.Div) in BindService()
285 .AddMethod(__Method_DivMany, serviceImpl.DivMany) in BindService()
286 .AddMethod(__Method_Fib, serviceImpl.Fib) in BindService()
287 .AddMethod(__Method_Sum, serviceImpl.Sum).Build(); in BindService()
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/
DRouteGuideGrpc.cs320 public static grpc::ServerServiceDefinition BindService(RouteGuideBase serviceImpl) in BindService() argument
323 .AddMethod(__Method_GetFeature, serviceImpl.GetFeature) in BindService()
324 .AddMethod(__Method_ListFeatures, serviceImpl.ListFeatures) in BindService()
325 .AddMethod(__Method_RecordRoute, serviceImpl.RecordRoute) in BindService()
326 .AddMethod(__Method_RouteChat, serviceImpl.RouteChat).Build(); in BindService()
/external/grpc-grpc/src/csharp/Grpc.Reflection.Tests/
DReflectionClientServerTest.cs39 ReflectionServiceImpl serviceImpl; field in Grpc.Reflection.Tests.ReflectionClientServerTest
44 serviceImpl = new ReflectionServiceImpl(ServerReflection.Descriptor); in Init()
49 Services = { ServerReflection.BindService(serviceImpl) }, in Init()
/external/flatbuffers/tests/MyGame/Example/
DMonsterStorageGrpc.java408 private final MonsterStorageImplBase serviceImpl; field in MonsterStorageGrpc.MethodHandlers
411 MethodHandlers(MonsterStorageImplBase serviceImpl, int methodId) { in MethodHandlers() argument
412 this.serviceImpl = serviceImpl; in MethodHandlers()
421 serviceImpl.store((MyGame.Example.Monster) request, in invoke()
425 serviceImpl.retrieve((MyGame.Example.Stat) request, in invoke()
439 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.getMaxHitPoint( in invoke()
442 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.getMinMaxHitPoints( in invoke()
/external/grpc-grpc-java/grpclb/src/generated/main/grpc/io/grpc/lb/v1/
DLoadBalancerGrpc.java187 private final LoadBalancerImplBase serviceImpl; field in LoadBalancerGrpc.MethodHandlers
190 MethodHandlers(LoadBalancerImplBase serviceImpl, int methodId) { in MethodHandlers() argument
191 this.serviceImpl = serviceImpl; in MethodHandlers()
210 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.balanceLoad( in invoke()
/external/grpc-grpc-java/alts/src/generated/main/grpc/io/grpc/alts/internal/
DHandshakerServiceGrpc.java197 private final HandshakerServiceImplBase serviceImpl; field in HandshakerServiceGrpc.MethodHandlers
200 MethodHandlers(HandshakerServiceImplBase serviceImpl, int methodId) { in MethodHandlers() argument
201 this.serviceImpl = serviceImpl; in MethodHandlers()
220 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.doHandshake( in invoke()
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/reflection/v1alpha/
DServerReflectionGrpc.java189 private final ServerReflectionImplBase serviceImpl; field in ServerReflectionGrpc.MethodHandlers
192 MethodHandlers(ServerReflectionImplBase serviceImpl, int methodId) { in MethodHandlers() argument
193 this.serviceImpl = serviceImpl; in MethodHandlers()
212 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.serverReflectionInfo( in invoke()
/external/grpc-grpc-java/services/src/generated/test/grpc/io/grpc/reflection/testing/
DAnotherDynamicServiceGrpc.java223 private final AnotherDynamicServiceImplBase serviceImpl; field in AnotherDynamicServiceGrpc.MethodHandlers
226 MethodHandlers(AnotherDynamicServiceImplBase serviceImpl, int methodId) { in MethodHandlers() argument
227 this.serviceImpl = serviceImpl; in MethodHandlers()
236 serviceImpl.method((io.grpc.reflection.testing.DynamicRequest) request, in invoke()
DDynamicServiceGrpc.java223 private final DynamicServiceImplBase serviceImpl; field in DynamicServiceGrpc.MethodHandlers
226 MethodHandlers(DynamicServiceImplBase serviceImpl, int methodId) { in MethodHandlers() argument
227 this.serviceImpl = serviceImpl; in MethodHandlers()
236 serviceImpl.method((io.grpc.reflection.testing.DynamicRequest) request, in invoke()
DReflectableServiceGrpc.java196 private final ReflectableServiceImplBase serviceImpl; field in ReflectableServiceGrpc.MethodHandlers
199 MethodHandlers(ReflectableServiceImplBase serviceImpl, int methodId) { in MethodHandlers() argument
200 this.serviceImpl = serviceImpl; in MethodHandlers()
209 serviceImpl.method((io.grpc.reflection.testing.Request) request, in invoke()
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/health/v1/
DHealthGrpc.java196 private final HealthImplBase serviceImpl; field in HealthGrpc.MethodHandlers
199 MethodHandlers(HealthImplBase serviceImpl, int methodId) { in MethodHandlers() argument
200 this.serviceImpl = serviceImpl; in MethodHandlers()
209 serviceImpl.check((io.grpc.health.v1.HealthCheckRequest) request, in invoke()
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DUnimplementedServiceGrpc.java228 private final UnimplementedServiceImplBase serviceImpl; field in UnimplementedServiceGrpc.MethodHandlers
231 MethodHandlers(UnimplementedServiceImplBase serviceImpl, int methodId) { in MethodHandlers() argument
232 this.serviceImpl = serviceImpl; in MethodHandlers()
241 serviceImpl.unimplementedCall((io.grpc.testing.integration.EmptyProtos.Empty) request, in invoke()
DMetricsServiceGrpc.java283 private final MetricsServiceImplBase serviceImpl; field in MetricsServiceGrpc.MethodHandlers
286 MethodHandlers(MetricsServiceImplBase serviceImpl, int methodId) { in MethodHandlers() argument
287 this.serviceImpl = serviceImpl; in MethodHandlers()
296 serviceImpl.getAllGauges((io.grpc.testing.integration.Metrics.EmptyMessage) request, in invoke()
300 serviceImpl.getGauge((io.grpc.testing.integration.Metrics.GaugeRequest) request, in invoke()
DReconnectServiceGrpc.java281 private final ReconnectServiceImplBase serviceImpl; field in ReconnectServiceGrpc.MethodHandlers
284 MethodHandlers(ReconnectServiceImplBase serviceImpl, int methodId) { in MethodHandlers() argument
285 this.serviceImpl = serviceImpl; in MethodHandlers()
294 serviceImpl.start((io.grpc.testing.integration.EmptyProtos.Empty) request, in invoke()
298 serviceImpl.stop((io.grpc.testing.integration.EmptyProtos.Empty) request, in invoke()
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DReportQpsScenarioServiceGrpc.java208 private final ReportQpsScenarioServiceImplBase serviceImpl; field in ReportQpsScenarioServiceGrpc.MethodHandlers
211 MethodHandlers(ReportQpsScenarioServiceImplBase serviceImpl, int methodId) { in MethodHandlers() argument
212 this.serviceImpl = serviceImpl; in MethodHandlers()
221 serviceImpl.reportScenario((io.grpc.benchmarks.proto.Control.ScenarioResult) request, in invoke()
DBenchmarkServiceGrpc.java478 private final BenchmarkServiceImplBase serviceImpl; field in BenchmarkServiceGrpc.MethodHandlers
481 MethodHandlers(BenchmarkServiceImplBase serviceImpl, int methodId) { in MethodHandlers() argument
482 this.serviceImpl = serviceImpl; in MethodHandlers()
491 serviceImpl.unaryCall((io.grpc.benchmarks.proto.Messages.SimpleRequest) request, in invoke()
495 serviceImpl.streamingFromServer((io.grpc.benchmarks.proto.Messages.SimpleRequest) request, in invoke()
509 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingCall( in invoke()
512 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingFromClient( in invoke()
515 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.streamingBothWays( in invoke()
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
DSimpleServiceGrpc.java417 private final SimpleServiceImplBase serviceImpl; field in SimpleServiceGrpc.MethodHandlers
420 MethodHandlers(SimpleServiceImplBase serviceImpl, int methodId) { in MethodHandlers() argument
421 this.serviceImpl = serviceImpl; in MethodHandlers()
430 serviceImpl.unaryRpc((io.grpc.testing.protobuf.SimpleRequest) request, in invoke()
434 serviceImpl.serverStreamingRpc((io.grpc.testing.protobuf.SimpleRequest) request, in invoke()
448 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.clientStreamingRpc( in invoke()
451 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.bidiStreamingRpc( in invoke()
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/
DChannelzGrpc.java642 private final ChannelzImplBase serviceImpl; field in ChannelzGrpc.MethodHandlers
645 MethodHandlers(ChannelzImplBase serviceImpl, int methodId) { in MethodHandlers() argument
646 this.serviceImpl = serviceImpl; in MethodHandlers()
655 serviceImpl.getTopChannels((io.grpc.channelz.v1.GetTopChannelsRequest) request, in invoke()
659 serviceImpl.getServers((io.grpc.channelz.v1.GetServersRequest) request, in invoke()
663 serviceImpl.getServerSockets((io.grpc.channelz.v1.GetServerSocketsRequest) request, in invoke()
667 serviceImpl.getChannel((io.grpc.channelz.v1.GetChannelRequest) request, in invoke()
671 serviceImpl.getSubchannel((io.grpc.channelz.v1.GetSubchannelRequest) request, in invoke()
675 serviceImpl.getSocket((io.grpc.channelz.v1.GetSocketRequest) request, in invoke()

12