Interface ModelCommitBatchingClient.ModelCommitBatch

Enclosing interface:
ModelCommitBatchingClient
public static interface ModelCommitBatchingClient.ModelCommitBatch

  • Method Summary

    Modifier and Type
    Method
    Description
    CompletableFuture<io.fluxzero.common.api.modeling.CommitModelsResult>
    add(int slot, io.fluxzero.common.api.modeling.CommitModels commit)
     
    default CompletableFuture<io.fluxzero.common.api.modeling.CommitModelsResult>
    add(int slot, io.fluxzero.common.api.modeling.CommitModels commit, ModelCommitBatchingClient.ModelCommitCompletion completion)
    Adds a commit whose post-commit work may be combined with other results in the same transport response.
    void
    fail(Throwable failure)
     
    void
    flush()
     
    void
    skip(int slot)
    Marks a reserved slot as intentionally empty.

  • Method Details

    • add

      CompletableFuture<io.fluxzero.common.api.modeling.CommitModelsResult> add(int slot, io.fluxzero.common.api.modeling.CommitModels commit)

    • add

      default CompletableFuture<io.fluxzero.common.api.modeling.CommitModelsResult> add(int slot, io.fluxzero.common.api.modeling.CommitModels commit, ModelCommitBatchingClient.ModelCommitCompletion completion)
      Adds a commit whose post-commit work may be combined with other results in the same transport response. Implementations without grouped result support retain correct per-result completion.

    • skip

      void skip(int slot)
      Marks a reserved slot as intentionally empty.

    • flush

      void flush()

    • fail

      void fail(Throwable failure)