Index

B C D G S U
All Classes and Interfaces|All Packages

B

bidirectionalStreamingService(SupplierEx<? extends ManagedChannelBuilder<?>>, FunctionEx<? super ManagedChannel, ? extends FunctionEx<StreamObserver<R>, StreamObserver<T>>>) - Static method in class com.hazelcast.jet.grpc.GrpcServices

Creates a ServiceFactory that calls out to a bidirectional streaming gRPC service.

C

call(T) - Method in interface com.hazelcast.jet.grpc.GrpcService

Calls the requested service and returns a future which will be completed with the result once a response is received.

com.hazelcast.jet.grpc - package 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.

D

DESTROY_TIMEOUT - Static variable in class com.hazelcast.jet.grpc.GrpcProperties

Time to wait for StreamObserver.onCompleted() confirmation when destroying a BidirectionalStreamingService You may want to increase this value when your gRPC calls take longer than 1 s to cleanly shutdown the service.

G

GrpcProperties - Class in com.hazelcast.jet.grpc

Properties of the grpc module

GrpcService<T,R> - Interface in com.hazelcast.jet.grpc

Represents a gRPC service that can be used as part of a mapUsingServiceAsync call.

GrpcServices - Class in com.hazelcast.jet.grpc

Provides ServiceFactory implementations for calling gRPC endpoints.

S

SHUTDOWN_TIMEOUT - Static variable in class com.hazelcast.jet.grpc.GrpcProperties

Time to wait for clean shutdown of a ManagedChannel

U

unaryService(SupplierEx<? extends ManagedChannelBuilder<?>>, FunctionEx<? super ManagedChannel, ? extends BiConsumerEx<T, StreamObserver<R>>>) - Static method in class com.hazelcast.jet.grpc.GrpcServices

Creates a ServiceFactory that calls out to a unary gRPC service.

B C D G S U
All Classes and Interfaces|All Packages