trait GraphStoreRequestFlowBuilder extends SparqlClientHelpers with HttpClientFlowBuilder with ErrorHandlerSupport

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GraphStoreRequestFlowBuilder
  2. ErrorHandlerSupport
  3. HttpClientFlowBuilder
  4. SparqlClientHelpers
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def errorHandler: ErrorHandler
    Definition Classes
    ErrorHandlerSupport
  2. implicit abstract val materializer: ActorMaterializer
    Definition Classes
    GraphStoreRequestFlowBuilder → SparqlClientHelpers
  3. implicit abstract val system: ActorSystem
    Definition Classes
    GraphStoreRequestFlowBuilder → SparqlClientHelpers

Concrete 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. def acceptQueryMediaType(queryType: QueryType): MediaType
    Definition Classes
    SparqlClientHelpers
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def calculateSuccess(statusCode: StatusCode): Boolean

    Returns true or false if a supported success or failure code is given.

    Returns true or false if a supported success or failure code is given. For unsupported codes, a SparqlClientRequestFailed is thrown.

  7. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  8. def defaultHttpClientFlow[T](endpoint: HttpEndpoint)(implicit system: ActorSystem, materializer: ActorMaterializer): Flow[(HttpRequest, T), (Try[HttpResponse], T), NotUsed]
    Definition Classes
    HttpClientFlowBuilder
  9. def defaultSSLConfig()(implicit system: ActorSystem, materializer: ActorMaterializer): AkkaSSLConfig

    The default HTTPS connection context config is very slack, use only for tests - not very useful for real world use.

    The default HTTPS connection context config is very slack, use only for tests - not very useful for real world use.

    Attributes
    protected
    Definition Classes
    HttpClientFlowBuilder
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  12. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  13. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. def graphStoreOpToRequest(endpoint: HttpEndpoint)(graphStoreRequest: GraphStoreRequest): (HttpRequest, GraphStoreRequest)
  15. def graphStoreRequestFlow(endpointFlow: HttpEndpointFlow[GraphStoreRequest]): Flow[GraphStoreRequest, GraphStoreResponse, NotUsed]
  16. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. def httpsConnectionContext(config: Option[AkkaSSLConfig])(implicit system: ActorSystem, materializer: ActorMaterializer): HttpsConnectionContext

    Override if the default connection context is not satisfactory.

    Override if the default connection context is not satisfactory.

    Attributes
    protected
    Definition Classes
    HttpClientFlowBuilder
  18. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  19. def isSparqlResultsJson(contentType: ContentType): Boolean
    Definition Classes
    SparqlClientHelpers
  20. def makeHttpRequest(endpoint: HttpEndpoint, request: GraphStoreRequest): HttpRequest
  21. def makeHttpRequest(endpoint: HttpEndpoint, statement: SparqlStatement): HttpRequest
    Definition Classes
    SparqlClientHelpers
  22. def makeModelSource(entity: HttpEntity): Source[Option[Model], Any]
  23. def makeRequestHeaders(endpoint: HttpEndpoint): List[HttpHeader]
    Definition Classes
    SparqlClientHelpers
  24. def mapContentTypeToRdfFormat(contentType: ContentType): RDFFormat
    Definition Classes
    SparqlClientHelpers
  25. def mapRdfFormatToContentType(format: RDFFormat): ContentType
    Definition Classes
    SparqlClientHelpers
  26. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  27. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  28. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  29. def pooledHttpClientFlow[T](endpoint: HttpEndpoint, akkaSSLConfig: Option[AkkaSSLConfig] = None)(implicit system: ActorSystem, materializer: ActorMaterializer): Flow[(HttpRequest, T), (Try[HttpResponse], T), NotUsed]

    Returns the default

    Returns the default

    Definition Classes
    HttpClientFlowBuilder
  30. def queuedAndPooledHttpClientFlow[T](endpoint: HttpEndpoint, queueSize: Int = 10, overflowStrategy: OverflowStrategy = OverflowStrategy.backpressure, akkaSSLConfig: Option[AkkaSSLConfig] = None)(implicit system: ActorSystem, materializer: ActorMaterializer): Flow[(HttpRequest, T), (Try[HttpResponse], T), NotUsed]

    Creates a flow that allows for access to the connection pool via a bounded request queue.

    Creates a flow that allows for access to the connection pool via a bounded request queue.

    {@see https://doc.akka.io/docs/akka-http/current/client-side/host-level.html#using-the-host-level-api-with-a-queue}

    endpoint

    the HTTP(S) endpoint

    queueSize

    the size of the queue

    overflowStrategy

    the overflow strategy to apply if the queue overruns

    akkaSSLConfig

    SSL config

    Definition Classes
    HttpClientFlowBuilder
  31. implicit val rawBooleanFromEntityUnmarshaller: FromEntityUnmarshaller[Boolean]
    Definition Classes
    SparqlClientHelpers
  32. def responseToSparqlResponse(response: (Try[HttpResponse], SparqlRequest)): SparqlResponse

    Takes the HttpResponse and makes a SparqlResponse.

    Takes the HttpResponse and makes a SparqlResponse.

    NB: This function will NOT consume the response entity!!

    Definition Classes
    SparqlClientHelpers
  33. def sparqlToRequest(endpoint: HttpEndpoint)(request: SparqlRequest): (HttpRequest, SparqlRequest)
    Definition Classes
    SparqlClientHelpers
  34. val strictEntityMaximumLengthInBytes: Int

    Limit the response entity size to 100MB by default

  35. val strictEntityReadTimeout: FiniteDuration

    Specifies for how long to wait for a "strict" http entity.

  36. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  37. def toString(): String
    Definition Classes
    AnyRef → Any
  38. val useStrictByteStringStrategy: Boolean

    If this is set to true then the response entity is "strictified", i.e.

    If this is set to true then the response entity is "strictified", i.e. all chunks are loaded into memory in one go. However by being false, the result is processed as a proper stream but there is the risk is that the user might get more than a single response per request.

  39. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  40. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  41. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from ErrorHandlerSupport

Inherited from HttpClientFlowBuilder

Inherited from SparqlClientHelpers

Inherited from AnyRef

Inherited from Any

Ungrouped