Uses of Interface
com.hazelcast.jet.grpc.GrpcService
Package | Description |
---|---|
com.hazelcast.jet.grpc |
Contributes
gRPC service factories that can be to apply transformations to
a pipeline which for each input item calls to a gRPC service. |
-
Uses of GrpcService in com.hazelcast.jet.grpc
Methods in com.hazelcast.jet.grpc that return types with arguments of type GrpcService Modifier and Type Method Description static <T, R> ServiceFactory<?,? extends GrpcService<T,R>>
GrpcServices. bidirectionalStreamingService(SupplierEx<? extends io.grpc.ManagedChannelBuilder<?>> channelFn, FunctionEx<? super io.grpc.ManagedChannel,? extends FunctionEx<io.grpc.stub.StreamObserver<R>,io.grpc.stub.StreamObserver<T>>> callStubFn)
Creates aServiceFactory
that calls out to a bidrectional streaming gRPC service.static <T, R> ServiceFactory<?,? extends GrpcService<T,R>>
GrpcServices. unaryService(SupplierEx<? extends io.grpc.ManagedChannelBuilder<?>> channelFn, FunctionEx<? super io.grpc.ManagedChannel,? extends BiConsumerEx<T,io.grpc.stub.StreamObserver<R>>> callStubFn)
Creates aServiceFactory
that calls out to a unary gRPC service.