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)
    Adds a prepared commit at its reserved slot and returns a future for that commit's result.
    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)
    Fails the batch and its pending commit completions with the supplied cause.
    void
    flush()
    Flushes pending commits according to the implementation's batch-release policy.
    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)
      Adds a prepared commit at its reserved slot and returns a future for that commit's result.

    • 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()
      Flushes pending commits according to the implementation's batch-release policy.

    • fail

      void fail(Throwable failure)
      Fails the batch and its pending commit completions with the supplied cause.