p

akka.grpc

internal

package internal

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. abstract class AbstractGrpcProtocol extends GrpcProtocol
  2. class AkkaDiscoveryNameResolver extends NameResolver
  3. class AkkaDiscoveryNameResolverProvider extends NameResolverProvider
  4. abstract class BaseMarshaller[T] extends io.grpc.MethodDescriptor.Marshaller[T] with WithProtobufSerializer[T]

    INTERNAL API

    INTERNAL API

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

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

  6. 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()
  7. 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.

  8. final class ClientState extends AnyRef

    INTERNAL API

    INTERNAL API

    Client utilities taking care of Channel reconnection and Channel lifecycle in general.

    Annotations
    @InternalApi()
  9. abstract class Codec extends AnyRef
  10. 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()
  11. 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()
  12. abstract class GrpcProtocolWebBase extends AbstractGrpcProtocol
  13. class HardcodedServiceDiscovery extends ServiceDiscovery
  14. 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()
  15. abstract class InternalChannel extends AnyRef

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  18. class JavaMetadataImpl extends Metadata

    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()
  19. final class JavaServerStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[I, O] with MetadataOperations[JavaServerStreamingRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalStableApi()
  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. final class ScalaBidirectionalStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[ScalaBidirectionalStreamingRequestBuilder[I, O]]

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  30. class ServiceDescriptionImpl extends ServiceDescription

    INTERNAL API

    INTERNAL API

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

Value Members

  1. object AbstractGrpcProtocol
  2. object AkkaDiscoveryNameResolver
  3. object AkkaHttpClientUtils

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  4. object ChannelUtils

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  5. object ClientState
  6. object Codecs
  7. object GrpcEntityHelpers

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  8. 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
  9. 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.
  10. 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.

  11. object GrpcRequestHelpers
    Annotations
    @InternalApi()
  12. 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()
  13. object Gzip extends Codec
  14. object Identity extends Codec
  15. object NettyClientUtils

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  16. object ServerReflectionImpl

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalStableApi()

Ungrouped