Apache Pekko gRPC
1.0.2
API
Generated with
Apache Pekko gRPC/org.apache.pekko.grpc/org.apache.pekko.grpc.internal

org.apache.pekko.grpc.internal

package org.apache.pekko.grpc.internal

Members list

Type members

Classlikes

abstract class AbstractGrpcProtocol(subType: String) extends GrpcProtocol

Attributes

Companion
object
Source
AbstractGrpcProtocol.scala
Supertypes
trait GrpcProtocol
class Object
trait Matchable
class Any
Known subtypes
object GrpcProtocolNative.type
object GrpcProtocolWeb.type
object GrpcProtocolWebText.type
object AbstractGrpcProtocol

Attributes

Companion
class
Source
AbstractGrpcProtocol.scala
Supertypes
class Object
trait Matchable
class Any
Self type
@InternalStableApi
abstract class BaseMarshaller[T](val protobufSerializer: ProtobufSerializer[T]) extends Marshaller[T], WithProtobufSerializer[T]

INTERNAL API

INTERNAL API

Attributes

Source
Marshallers.scala
Supertypes
trait Marshaller[T]
class Object
trait Matchable
class Any
Known subtypes
class Marshaller[T]
class ProtoMarshaller[T]
class CancellationBarrierGraphStage[T] extends GraphStage[FlowShape[T, T]]

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

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

Attributes

Source
CancellationBarrierGraphStage.scala
Supertypes
class GraphStage[FlowShape[T, T]]
class GraphStageWithMaterializedValue[FlowShape[T, T], NotUsed]
trait Graph[FlowShape[T, T], NotUsed]
class Object
trait Matchable
class Any
Show all
@InternalApi
object ChannelUtils

INTERNAL API

INTERNAL API

Attributes

Source
ChannelUtils.scala
Supertypes
class Object
trait Matchable
class Any
Self type
@InternalApi
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

Attributes

Source
ClientState.scala
Supertypes
class RuntimeException
class Exception
class Throwable
trait Serializable
class Object
trait Matchable
class Any
Show all
class ClientConnectionException(msg: String) 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.

Attributes

Source
ChannelUtils.scala
Supertypes
class RuntimeException
class Exception
class Throwable
trait Serializable
class Object
trait Matchable
class Any
Show all
abstract class Codec

Attributes

Source
Codec.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
object Gzip.type
object Identity.type
object Codecs

Attributes

Source
Codecs.scala
Supertypes
class Object
trait Matchable
class Any
Self type
Codecs.type
@InternalApi
class EntryMetadataImpl(entries: List[(String, MetadataEntry)]) extends Metadata

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

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

Value parameters

entries

The list of (key, entry) tuples.

Attributes

Source
MetadataImpl.scala
Supertypes
trait Metadata
class Object
trait Matchable
class Any
@InternalApi
object GrpcEntityHelpers

INTERNAL API

INTERNAL API

Attributes

Source
GrpcEntityHelpers.scala
Supertypes
class Object
trait Matchable
class Any
Self type
@InternalApi
class GrpcMetadataImpl(delegate: Metadata) 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.

Value parameters

delegate

The underlying mutable metadata.

Attributes

Source
MetadataImpl.scala
Supertypes
trait Metadata
class Object
trait Matchable
class Any
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

Attributes

Source
GrpcProtocolNative.scala
Supertypes
trait GrpcProtocol
class Object
trait Matchable
class Any
Self type
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.

Attributes

Source
GrpcProtocolWeb.scala
Supertypes
trait GrpcProtocol
class Object
trait Matchable
class Any
Show all
Self type
abstract class GrpcProtocolWebBase(subType: String) extends AbstractGrpcProtocol

Attributes

Source
GrpcProtocolWeb.scala
Supertypes
trait GrpcProtocol
class Object
trait Matchable
class Any
Known subtypes
object GrpcProtocolWeb.type
object GrpcProtocolWebText.type
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.

Attributes

Source
GrpcProtocolWeb.scala
Supertypes
trait GrpcProtocol
class Object
trait Matchable
class Any
Show all
Self type
@InternalApi
object GrpcRequestHelpers

Attributes

Source
GrpcRequestHelpers.scala
Supertypes
class Object
trait Matchable
class Any
Self type
@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

Attributes

Source
GrpcResponseHelpers.scala
Supertypes
class Object
trait Matchable
class Any
Self type
object Gzip extends Codec

Attributes

Source
Gzip.scala
Supertypes
class Codec
class Object
trait Matchable
class Any
Self type
Gzip.type
class HardcodedServiceDiscovery(resolved: Resolved) extends ServiceDiscovery

Attributes

Source
HardcodedServiceDiscovery.scala
Supertypes
class ServiceDiscovery
class Object
trait Matchable
class Any
@InternalApi
class HeaderMetadataImpl(headers: Seq[HttpHeader]) 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.

Value parameters

headers

The list of HTTP response headers.

Attributes

Source
MetadataImpl.scala
Supertypes
trait Metadata
class Object
trait Matchable
class Any
object Identity extends Codec

Attributes

Source
Identity.scala
Supertypes
class Codec
class Object
trait Matchable
class Any
Self type
Identity.type
@InternalApi
abstract class InternalChannel

INTERNAL API

INTERNAL API

Attributes

Source
InternalChannel.scala
Supertypes
class Object
trait Matchable
class Any
@InternalApi
final class JavaBidirectionalStreamingRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit ec: ExecutionContext) extends StreamResponseRequestBuilder[Source[I, NotUsed], O], MetadataOperations[JavaBidirectionalStreamingRequestBuilder[I, O]]

INTERNAL API

INTERNAL API

Attributes

Source
RequestBuilderImpl.scala
Supertypes
trait StreamResponseRequestBuilder[Source[I, NotUsed], O]
class Object
trait Matchable
class Any
@InternalApi
final class JavaClientStreamingRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit mat: Materializer, ec: ExecutionContext) extends SingleResponseRequestBuilder[Source[I, NotUsed], O], MetadataOperations[JavaClientStreamingRequestBuilder[I, O]]

INTERNAL API

INTERNAL API

Attributes

Source
RequestBuilderImpl.scala
Supertypes
trait SingleResponseRequestBuilder[Source[I, NotUsed], O]
class Object
trait Matchable
class Any
@InternalApi
class JavaMetadataImpl(delegate: Metadata) 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.

Value parameters

delegate

The underlying Scala metadata instance.

Attributes

Source
MetadataImpl.scala
Supertypes
trait Metadata
class Object
trait Matchable
class Any
@InternalApi
final class JavaServerStreamingRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit ec: ExecutionContext) extends StreamResponseRequestBuilder[I, O], MetadataOperations[JavaServerStreamingRequestBuilder[I, O]]

INTERNAL API

INTERNAL API

Attributes

Source
RequestBuilderImpl.scala
Supertypes
class Object
trait Matchable
class Any
@InternalApi
final class JavaUnaryRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit ex: ExecutionContext) extends SingleResponseRequestBuilder[I, O], MetadataOperations[JavaUnaryRequestBuilder[I, O]]

INTERNAL API

INTERNAL API

Attributes

Source
RequestBuilderImpl.scala
Supertypes
class Object
trait Matchable
class Any
@InternalStableApi
final class Marshaller[T <: GeneratedMessage](protobufSerializer: ProtobufSerializer[T]) extends BaseMarshaller[T]

INTERNAL API

INTERNAL API

Attributes

Source
Marshallers.scala
Supertypes
class BaseMarshaller[T]
trait Marshaller[T]
class Object
trait Matchable
class Any
Show all
@InternalApi
trait MetadataOperations[T <: MetadataOperations[T]]

INTERNAL API

INTERNAL API

Attributes

Source
RequestBuilderImpl.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
Show all
class MissingParameterException extends Throwable

Attributes

Source
MissingParameterException.scala
Supertypes
class Throwable
trait Serializable
class Object
trait Matchable
class Any
@InternalApi
object NettyClientUtils

INTERNAL API

INTERNAL API

Attributes

Source
NettyClientUtils.scala
Supertypes
class Object
trait Matchable
class Any
Self type
class PekkoDiscoveryNameResolver(discovery: ServiceDiscovery, defaultPort: Int, serviceName: String, portName: Option[String], protocol: Option[String], resolveTimeout: FiniteDuration)(implicit val ec: ExecutionContext) extends NameResolver

Attributes

Companion
object
Source
PekkoDiscoveryNameResolver.scala
Supertypes
class NameResolver
class Object
trait Matchable
class Any
object PekkoDiscoveryNameResolver

Attributes

Companion
class
Source
PekkoDiscoveryNameResolver.scala
Supertypes
class Object
trait Matchable
class Any
Self type
class PekkoDiscoveryNameResolverProvider(discovery: ServiceDiscovery, defaultPort: Int, portName: Option[String], protocol: Option[String], resolveTimeout: FiniteDuration)(implicit ec: ExecutionContext) extends NameResolverProvider

Attributes

Source
PekkoDiscoveryNameResolverProvider.scala
Supertypes
class NameResolverProvider
class Factory
class Object
trait Matchable
class Any
@InternalApi
object PekkoHttpClientUtils

INTERNAL API

INTERNAL API

Attributes

Source
PekkoHttpClientUtils.scala
Supertypes
class Object
trait Matchable
class Any
Self type
@InternalStableApi
class ProtoMarshaller[T <: Message](protobufSerializer: ProtobufSerializer[T]) extends BaseMarshaller[T]

INTERNAL API

INTERNAL API

Attributes

Source
Marshallers.scala
Supertypes
class BaseMarshaller[T]
trait Marshaller[T]
class Object
trait Matchable
class Any
Show all
@InternalApi
final class ScalaBidirectionalStreamingRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit ec: ExecutionContext) extends StreamResponseRequestBuilder[Source[I, NotUsed], O], MetadataOperations[ScalaBidirectionalStreamingRequestBuilder[I, O]]

INTERNAL API

INTERNAL API

Attributes

Source
RequestBuilderImpl.scala
Supertypes
trait StreamResponseRequestBuilder[Source[I, NotUsed], O]
class Object
trait Matchable
class Any
@InternalApi
final class ScalaClientStreamingRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit mat: Materializer, ec: ExecutionContext) extends SingleResponseRequestBuilder[Source[I, NotUsed], O], MetadataOperations[ScalaClientStreamingRequestBuilder[I, O]]

INTERNAL API

INTERNAL API

Attributes

Source
RequestBuilderImpl.scala
Supertypes
trait SingleResponseRequestBuilder[Source[I, NotUsed], O]
class Object
trait Matchable
class Any
@InternalApi
final class ScalaServerStreamingRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit ec: ExecutionContext) extends StreamResponseRequestBuilder[I, O], MetadataOperations[ScalaServerStreamingRequestBuilder[I, O]]

INTERNAL API

INTERNAL API

Attributes

Source
RequestBuilderImpl.scala
Supertypes
class Object
trait Matchable
class Any
@InternalApi
final class ScalaUnaryRequestBuilder[I, O](descriptor: MethodDescriptor[I, O], channel: InternalChannel, defaultOptions: CallOptions, settings: GrpcClientSettings, val headers: MetadataImpl)(implicit ec: ExecutionContext) extends SingleResponseRequestBuilder[I, O], MetadataOperations[ScalaUnaryRequestBuilder[I, O]]

INTERNAL API

INTERNAL API

Attributes

Source
RequestBuilderImpl.scala
Supertypes
class Object
trait Matchable
class Any
@InternalApi
final class ServerReflectionImpl extends ServerReflection

INTERNAL API

INTERNAL API

Attributes

Companion
object
Source
ServerReflectionImpl.scala
Supertypes
class Object
trait Matchable
class Any
@InternalApi
object ServerReflectionImpl

INTERNAL API

INTERNAL API

Attributes

Companion
class
Source
ServerReflectionImpl.scala
Supertypes
class Object
trait Matchable
class Any
Self type
@InternalApi
class ServiceDescriptionImpl(val name: String, val descriptor: FileDescriptor) extends ServiceDescription

INTERNAL API

INTERNAL API

Attributes

Source
ServiceDescriptionImpl.scala
Supertypes
class Object
trait Matchable
class Any
object SingleParameterSink

Attributes

Source
SingleParameterSink.scala
Supertypes
class Object
trait Matchable
class Any
Self type
@InternalStableApi
object TelemetryExtension extends ExtensionId[TelemetryExtensionImpl], ExtensionIdProvider

INTERNAL API

INTERNAL API

Attributes

Source
TelemetrySpi.scala
Supertypes
trait ExtensionIdProvider
trait ExtensionId[TelemetryExtensionImpl]
class Object
trait Matchable
class Any
Self type
@InternalStableApi
trait TelemetrySpi

Attributes

Source
TelemetrySpi.scala
Supertypes
class Object
trait Matchable
class Any
trait WithProtobufSerializer[T]

Attributes

Source
WithProtobufSerializer.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class BaseMarshaller[T]
class Marshaller[T]
class ProtoMarshaller[T]

Deprecated classlikes

@InternalApi
final class ClientState

INTERNAL API

INTERNAL API

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

Attributes

Deprecated
true
Source
ClientState.scala
Supertypes
class Object
trait Matchable
class Any
Generated with