Packages

object GrpcProtocol

INTERNAL API

Core definitions for gRPC protocols.

Annotations
@InternalApi()
Source
GrpcProtocol.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GrpcProtocol
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. case class DataFrame(data: ByteString) extends Frame with Product with Serializable

    A data (or message) frame in a gRPC protocol stream.

  2. sealed trait Frame extends AnyRef

    A frame in a logical gRPC protocol stream

  3. case class GrpcProtocolReader(messageEncoding: Codec, decodeSingleFrame: (ByteString) ⇒ ByteString, frameDecoder: Flow[ByteString, Frame, NotUsed]) extends Product with Serializable

    Implements the decoding of the gRPC framing from a physical/transport layer.

  4. case class GrpcProtocolWriter(contentType: ContentType, messageEncoding: Codec, encodeFrame: (Frame) ⇒ ChunkStreamPart, encodeDataToResponse: (ByteString, Seq[HttpHeader], Trailer) ⇒ HttpResponse, frameEncoder: Flow[Frame, ChunkStreamPart, NotUsed]) extends Product with Serializable

    Implements the encoding of a stream of gRPC Frames into a physical/transport layer.

    Implements the encoding of a stream of gRPC Frames into a physical/transport layer.

    This maps the logical gRPC frames into a stream of chunks that can be handled by the HTTP/2 or HTTP/1.1 transport layer.

  5. case class TrailerFrame(trailers: List[HttpHeader]) extends Frame with Product with Serializable

    A trailer (status headers) frame in a gRPC protocol stream

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  6. def detect(mediaType: MediaType): Option[GrpcProtocol]

    Detects which gRPC protocol variant is indicated by a mediatype.

    Detects which gRPC protocol variant is indicated by a mediatype.

    returns

    a GrpcProtocol matching the request mediatype if known.

  7. def detect(request: HttpRequest): Option[GrpcProtocol]

    Detects which gRPC protocol variant is indicated in a request.

    Detects which gRPC protocol variant is indicated in a request.

    returns

    a GrpcProtocol matching the request mediatype if specified and known.

  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  11. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. def negotiate(request: HttpRequest): Option[(Try[GrpcProtocolReader], GrpcProtocolWriter)]

    Calculates the gRPC protocol encoding to use for an interaction with a gRPC client.

    Calculates the gRPC protocol encoding to use for an interaction with a gRPC client.

    request

    the client request to respond to.

    returns

    the protocol reader for the request, and a protocol writer for the response.

  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  19. def toString(): String
    Definition Classes
    AnyRef → Any
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped