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 can not establish a connection after the configured number of attempts.

    Used to indicate that a gRPC client can not establish a connection after the configured number of attempts.

    Can be caught to re-create the client if it is likely that your service discovery mechanism will resolve to different instances.

  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. final class JavaBidirectionalStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[JavaBidirectionalStreamingRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  16. 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()
  17. final class JavaServerStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[I, O] with MetadataOperations[JavaServerStreamingRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalStableApi()
  20. trait MetadataOperations[T <: MetadataOperations[T]] extends AnyRef

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  29. class ServiceDescriptionImpl extends ServiceDescription

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  30. trait TelemetrySpi extends AnyRef
    Annotations
    @InternalStableApi()
  31. 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 NettyClientUtils

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  14. object RequestBuilderImpl
  15. object ServerReflectionImpl

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalStableApi()

Ungrouped