Class DefaultChunkedFileQueryBuilder

java.lang.Object
eu.cloudnetservice.driver.impl.network.chunk.builder.DefaultChunkedFileQueryBuilder
All Implemented Interfaces:
eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder
@AutoService(services=eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder.class, name="default", singleton=false) public class DefaultChunkedFileQueryBuilder extends Object implements eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder
Default implementation of a builder for a file query from a remote network component.
Since:
4.0

  • Field Details

    • EMPTY_BUFFER

      private static final eu.cloudnetservice.driver.network.buffer.DataBuf EMPTY_BUFFER

    • dataIdentifier

      private String dataIdentifier

    • dataSource

      private eu.cloudnetservice.driver.channel.ChannelMessageTarget dataSource

    • messageBufferConfigurator

      private Consumer<eu.cloudnetservice.driver.network.buffer.DataBuf.Mutable> messageBufferConfigurator

    • chunkSize

      private int chunkSize

  • Constructor Details

    • DefaultChunkedFileQueryBuilder

      public DefaultChunkedFileQueryBuilder()

  • Method Details

    • chunkSize

      @NonNull public @NonNull eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder chunkSize(int chunkSize)
      Specified by:
      chunkSize in interface eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder

    • dataIdentifier

      @NonNull public @NonNull eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder dataIdentifier(@NonNull @NonNull String dataIdentifier)
      Specified by:
      dataIdentifier in interface eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder

    • requestFromNode

      @NonNull public @NonNull eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder requestFromNode(@NonNull @NonNull String nodeId)
      Specified by:
      requestFromNode in interface eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder

    • requestFromService

      @NonNull public @NonNull eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder requestFromService(@NonNull @NonNull String serviceName)
      Specified by:
      requestFromService in interface eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder

    • configureMessageBuffer

      @NonNull public @NonNull eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder configureMessageBuffer(@NonNull @NonNull Consumer<eu.cloudnetservice.driver.network.buffer.DataBuf.Mutable> bufferConfigurer)
      Specified by:
      configureMessageBuffer in interface eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder

    • query

      @NonNull public @NonNull CompletableFuture<InputStream> query()
      Specified by:
      query in interface eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder

    • queryToTempFile

      @NonNull public @NonNull CompletableFuture<Path> queryToTempFile()
      Specified by:
      queryToTempFile in interface eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder

    • queryToPath

      @NonNull public @NonNull CompletableFuture<Path> queryToPath(@NonNull @NonNull Path target)
      Specified by:
      queryToPath in interface eu.cloudnetservice.driver.network.chunk.ChunkedFileQueryBuilder