p

akka.grpc

internal

package internal

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. abstract class AbstractGrpcProtocol extends GrpcProtocol
  2. abstract class BaseMarshaller[T] extends io.grpc.MethodDescriptor.Marshaller[T] with WithProtobufSerializer[T]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalStableApi()
  3. class CancellationBarrierGraphStage[T] extends GraphStage[FlowShape[T, T]]

    'barrier' that makes sure that, even when downstream is cancelled, the complete upstream is consumed.

  4. final class ClientClosedException extends RuntimeException

    INTERNAL API Used from generated code so can't be private.

    INTERNAL API Used from generated code so can't be private.

    Thrown if a withChannel call is called after closing the internal channel

    Annotations
    @InternalApi()
  5. class ClientConnectionException extends RuntimeException

    Used to indicate that a gRPC client gave up establishing a connection after the configured number of connection-attempts, which is only the case if a limit is set (the default is to retry forever).

    Used to indicate that a gRPC client gave up establishing a connection after the configured number of connection-attempts, which is only the case if a limit is set (the default is to retry forever). The client is shut down when giving up, so a new client must be created to connect again.

  6. abstract class Codec extends AnyRef
  7. class EntryMetadataImpl extends Metadata

    This class represents metadata as a list of (key, entry) tuples.

    This class represents metadata as a list of (key, entry) tuples.

    Annotations
    @InternalApi()
  8. class GrpcMetadataImpl extends Metadata

    This class wraps a mutable Metadata from io.grpc with the Scala Metadata interface.

    This class wraps a mutable Metadata from io.grpc with the Scala Metadata interface.

    Annotations
    @InternalApi()
  9. abstract class GrpcProtocolWebBase extends AbstractGrpcProtocol
  10. class HardcodedServiceDiscovery extends ServiceDiscovery
  11. class HeaderMetadataImpl extends Metadata

    This class wraps a list of headers from an HttpResponse with the Metadata interface.

    This class wraps a list of headers from an HttpResponse with the Metadata interface.

    Annotations
    @InternalApi()
  12. class HttpMessageMetadataImpl extends HeaderMetadataImpl

    This class wraps an HttpMessage with the Metadata interface.

  13. abstract class InternalChannel extends AnyRef

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  14. trait InvocationInterceptor extends AnyRef

    INTERNAL API

    INTERNAL API

    Wraps the invocation of each user service method in the generated SDK ScalaHandlerFactory, run synchronously inside intercept on the same thread. Picked up from the request attribute InvocationInterceptor.Key, when not present InvocationInterceptor.NoOp is used. The service instance is created before the request is unmarshalled, outside of the interceptor.

    Only that synchronous part is covered. User code that runs later, on other threads, runs outside of the interceptor: continuations of a returned CompletionStage, the stages of a returned Source and the processing of the incoming Source for client and bidirectional streaming methods.

    Only called when a user method is invoked. It is not called for an unknown method, an unsupported content type, a unary or server streaming request body that cannot be decoded, or when the instance factory denies the request. For client and bidirectional streaming it is called also when the body is malformed, since the method receives the incoming Source before any element is decoded.

    Code generated by 2.5.13 and earlier never calls the interceptor.

    Annotations
    @InternalStableApi()
  15. final class JavaBidirectionalStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[JavaBidirectionalStreamingRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  16. final class JavaClientStreamingRequestBuilder[I, O] extends SingleResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[JavaClientStreamingRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  17. class JavaMetadataImpl extends Metadata with MetadataStatus

    This class wraps a scaladsl.Metadata instance with the javadsl.Metadata interface.

    This class wraps a scaladsl.Metadata instance with the javadsl.Metadata interface.

    Annotations
    @InternalApi()
  18. final class JavaServerStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[I, O] with MetadataOperations[JavaServerStreamingRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  19. final class JavaUnaryRequestBuilder[I, O] extends SingleResponseRequestBuilder[I, O] with MetadataOperations[JavaUnaryRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  20. final class Marshaller[T <: GeneratedMessage] extends BaseMarshaller[T]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalStableApi()
  21. final class MetadataImpl extends AnyRef

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  22. trait MetadataOperations[T <: MetadataOperations[T]] extends AnyRef

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  23. class MissingParameterException extends Throwable
  24. class ProtoMarshaller[T <: Message] extends BaseMarshaller[T]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalStableApi()
  25. class RichGrpcMetadataImpl extends GrpcMetadataImpl with MetadataStatus
  26. final class ScalaBidirectionalStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[ScalaBidirectionalStreamingRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  27. final class ScalaClientStreamingRequestBuilder[I, O] extends SingleResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[ScalaClientStreamingRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  28. final class ScalaServerStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[I, O] with MetadataOperations[ScalaServerStreamingRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  29. final class ScalaUnaryRequestBuilder[I, O] extends SingleResponseRequestBuilder[I, O] with MetadataOperations[ScalaUnaryRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  30. final class ServerReflectionImpl extends ServerReflection

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  31. class ServiceDescriptionImpl extends ServiceDescription

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  32. trait TelemetrySpi extends AnyRef
    Annotations
    @InternalStableApi()
  33. trait WithProtobufSerializer[T] extends AnyRef

Deprecated Type Members

  1. final class ClientState extends AnyRef

    INTERNAL API

    INTERNAL API

    Deprecated: This class wraps a GrpcChannel for compatibility with clients generated by previous versions.

    Annotations
    @deprecated @InternalApi()
    Deprecated

    (Since version akka-grpc 2.1.5) Kept for binary compatibility between generated code and runtime

Value Members

  1. object AbstractGrpcProtocol
  2. object AkkaHttpClientUtils

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  3. object ChannelUtils

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  4. object Codecs
  5. object GrpcEntityHelpers

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  6. object GrpcProtocolNative extends AbstractGrpcProtocol

    Implementation of the gRPC (application/grpc+proto) protocol:

    Implementation of the gRPC (application/grpc+proto) protocol:

    Protocol:

    • Data frames are encoded to a stream of Chunk as per the gRPC specification
    • Trailer frames are encoded to LastChunk, to be rendered into the underlying HTTP/2 transport
  7. object GrpcProtocolWeb extends GrpcProtocolWebBase

    Implementation of the gRPC Web protocol.

    Implementation of the gRPC Web protocol.

    Protocol:

    • Data frames are encoded to a stream of Chunk as per the gRPC-web specification.
    • Trailer frames are encoded to a Chunk (containing a marked trailer frame) as per the gRPC-web specification.
  8. object GrpcProtocolWebText extends GrpcProtocolWebBase

    The application/grpc-web-text+proto variant of gRPC.

    The application/grpc-web-text+proto variant of gRPC.

    This is the same as application/grpc-web+proto, but with each chunk of the frame encoded gRPC data also base64 encoded.

  9. object GrpcRequestHelpers
    Annotations
    @InternalApi()
  10. object GrpcResponseHelpers

    Some helpers for creating HTTP entities for use with gRPC.

    Some helpers for creating HTTP entities for use with gRPC.

    INTERNAL API

    Annotations
    @InternalApi()
  11. object Gzip extends Codec
  12. object Identity extends Codec
  13. object InvocationInterceptor

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalStableApi()
  14. object MetadataImpl

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  15. object NettyClientUtils

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  16. object RequestBuilderImpl
  17. object ServerReflectionImpl

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  18. object SingleParameterSink
  19. object TelemetryExtension extends ExtensionId[TelemetryExtensionImpl] with ExtensionIdProvider

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalStableApi()

Ungrouped