vespa-feed-client/src/main/java/ai/vespa/feed/client/RequestStrategy.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

// Copyright Verizon Media. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package ai.vespa.feed.client;

import org.apache.hc.client5.http.async.methods.SimpleHttpRequest;
import org.apache.hc.client5.http.async.methods.SimpleHttpResponse;

import java.util.concurrent.CompletableFuture;
import java.util.function.BiConsumer;

/**
 * Controls execution of feed operations.
 *
 * @author jonmv
 */
public interface RequestStrategy {

    /** Whether this has failed, and we should stop. */
    boolean hasFailed();

    /** Enqueue the given operation, which is dispatched to a vessel future when ready. */
    CompletableFuture<SimpleHttpResponse> enqueue(DocumentId documentId, SimpleHttpRequest request,
                                                  BiConsumer<SimpleHttpRequest, CompletableFuture<SimpleHttpResponse>> dispatch);

}