package internal
- Alphabetic
- Public
- All
Type Members
- abstract class AbstractGrpcProtocol extends GrpcProtocol
-
abstract
class
BaseMarshaller[T] extends io.grpc.MethodDescriptor.Marshaller[T] with WithProtobufSerializer[T]
INTERNAL API
INTERNAL API
- Annotations
- @InternalStableApi()
-
class
CancellationBarrierGraphStage[T] extends GraphStage[FlowShape[T, T]]
'barrier' that makes sure that, even when downstream is cancelled, the complete upstream is consumed.
-
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()
-
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.
- abstract class Codec extends AnyRef
-
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()
-
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()
- abstract class GrpcProtocolWebBase extends AbstractGrpcProtocol
- class HardcodedServiceDiscovery extends ServiceDiscovery
-
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()
-
abstract
class
InternalChannel extends AnyRef
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
final
class
JavaBidirectionalStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[JavaBidirectionalStreamingRequestBuilder[I, O]]
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
final
class
JavaClientStreamingRequestBuilder[I, O] extends SingleResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[JavaClientStreamingRequestBuilder[I, O]]
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
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()
-
final
class
JavaServerStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[I, O] with MetadataOperations[JavaServerStreamingRequestBuilder[I, O]]
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
final
class
JavaUnaryRequestBuilder[I, O] extends SingleResponseRequestBuilder[I, O] with MetadataOperations[JavaUnaryRequestBuilder[I, O]]
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
final
class
Marshaller[T <: GeneratedMessage] extends BaseMarshaller[T]
INTERNAL API
INTERNAL API
- Annotations
- @InternalStableApi()
-
trait
MetadataOperations[T <: MetadataOperations[T]] extends AnyRef
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
- class MissingParameterException extends Throwable
- class PekkoDiscoveryNameResolver extends NameResolver
- class PekkoDiscoveryNameResolverProvider extends NameResolverProvider
-
class
ProtoMarshaller[T <: Message] extends BaseMarshaller[T]
INTERNAL API
INTERNAL API
- Annotations
- @InternalStableApi()
-
final
class
ScalaBidirectionalStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[ScalaBidirectionalStreamingRequestBuilder[I, O]]
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
final
class
ScalaClientStreamingRequestBuilder[I, O] extends SingleResponseRequestBuilder[Source[I, NotUsed], O] with MetadataOperations[ScalaClientStreamingRequestBuilder[I, O]]
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
final
class
ScalaServerStreamingRequestBuilder[I, O] extends StreamResponseRequestBuilder[I, O] with MetadataOperations[ScalaServerStreamingRequestBuilder[I, O]]
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
final
class
ScalaUnaryRequestBuilder[I, O] extends SingleResponseRequestBuilder[I, O] with MetadataOperations[ScalaUnaryRequestBuilder[I, O]]
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
final
class
ServerReflectionImpl extends ServerReflection
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
class
ServiceDescriptionImpl extends ServiceDescription
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
trait
TelemetrySpi extends AnyRef
- Annotations
- @InternalStableApi()
- trait WithProtobufSerializer[T] extends AnyRef
-
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
- object AbstractGrpcProtocol
-
object
ChannelUtils
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
- object Codecs
-
object
GrpcEntityHelpers
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
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
-
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.
-
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. -
object
GrpcRequestHelpers
- Annotations
- @InternalApi()
-
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()
- object Gzip extends Codec
- object Identity extends Codec
-
object
NettyClientUtils
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
- object PekkoDiscoveryNameResolver
-
object
PekkoHttpClientUtils
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
-
object
ServerReflectionImpl
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
- object SingleParameterSink
-
object
TelemetryExtension extends ExtensionId[TelemetryExtensionImpl] with ExtensionIdProvider
INTERNAL API
INTERNAL API
- Annotations
- @InternalStableApi()