java.lang.Object
- com.google.api.gax.grpc.GrpcRawCallableFactory

@InternalApi("For internal use by google-cloud-java clients only")
public class GrpcRawCallableFactory
extends java.lang.Object

Class with utility methods to create low level grpc-based direct callables.

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static <RequestT,ResponseT> BidiStreamingCallable<RequestT,ResponseT>`	`createBidiStreamingCallable(GrpcCallSettings<RequestT,ResponseT> grpcCallSettings, java.util.Set<StatusCode.Code> retryableCodes)`	Create a bidirectional streaming callable object with grpc-specific functionality.
`static <RequestT,ResponseT> ClientStreamingCallable<RequestT,ResponseT>`	`createClientStreamingCallable(GrpcCallSettings<RequestT,ResponseT> grpcCallSettings, java.util.Set<StatusCode.Code> retryableCodes)`	Create a client-streaming callable object with grpc-specific functionality.
`static <RequestT,ResponseT> ServerStreamingCallable<RequestT,ResponseT>`	`createServerStreamingCallable(GrpcCallSettings<RequestT,ResponseT> grpcCallSettings, java.util.Set<StatusCode.Code> retryableCodes)`	Create a server-streaming callable with grpc-specific functionality.
`static <RequestT,ResponseT> UnaryCallable<RequestT,ResponseT>`	`createUnaryCallable(GrpcCallSettings<RequestT,ResponseT> grpcCallSettings, java.util.Set<StatusCode.Code> retryableCodes)`	Create a Unary callable object with minimal grpc-specific functionality.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createUnaryCallable

public static <RequestT,ResponseT> UnaryCallable<RequestT,ResponseT> createUnaryCallable(GrpcCallSettings<RequestT,ResponseT> grpcCallSettings,
                                                                                                     java.util.Set<StatusCode.Code> retryableCodes)

Create a Unary callable object with minimal grpc-specific functionality.

Parameters:: grpcCallSettings - the gRPC call settings; retryableCodes - the StatusCode.Code that should be marked as retryable

createBidiStreamingCallable

public static <RequestT,ResponseT> BidiStreamingCallable<RequestT,ResponseT> createBidiStreamingCallable(GrpcCallSettings<RequestT,ResponseT> grpcCallSettings,
                                                                                                                     java.util.Set<StatusCode.Code> retryableCodes)

Create a bidirectional streaming callable object with grpc-specific functionality. Designed for use by generated code.

Parameters:: grpcCallSettings - the gRPC call settings; retryableCodes - the StatusCode.Code that should be marked as retryable
Returns:: BidiStreamingCallable callable object.

createServerStreamingCallable

public static <RequestT,ResponseT> ServerStreamingCallable<RequestT,ResponseT> createServerStreamingCallable(GrpcCallSettings<RequestT,ResponseT> grpcCallSettings,
                                                                                                                         java.util.Set<StatusCode.Code> retryableCodes)

Create a server-streaming callable with grpc-specific functionality. Designed for use by generated code.

Parameters:: grpcCallSettings - the gRPC call settings; retryableCodes - the StatusCode.Code that should be marked as retryable

createClientStreamingCallable

public static <RequestT,ResponseT> ClientStreamingCallable<RequestT,ResponseT> createClientStreamingCallable(GrpcCallSettings<RequestT,ResponseT> grpcCallSettings,
                                                                                                                         java.util.Set<StatusCode.Code> retryableCodes)

Create a client-streaming callable object with grpc-specific functionality. Designed for use by generated code.

Parameters:: grpcCallSettings - the gRPC call settings; retryableCodes - the StatusCode.Code that should be marked as retryable