1 files changed, 33 insertions, 0 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/RequestStrategy.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/RequestStrategy.java
new file mode 100644
index 00000000000..e3b6b594593
--- /dev/null
+++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/RequestStrategy.java
@@ -0,0 +1,33 @@
+// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+package ai.vespa.feed.client.impl;
+
+import ai.vespa.feed.client.DocumentId;
+import ai.vespa.feed.client.FeedClient.CircuitBreaker.State;
+import ai.vespa.feed.client.HttpResponse;
+import ai.vespa.feed.client.OperationStats;
+
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * Controls execution of feed operations.
+ *
+ * @author jonmv
+ */
+interface RequestStrategy {
+
+    /** Stats for operations sent through this. */
+    OperationStats stats();
+
+    /** State of the circuit breaker. */
+    State circuitBreakerState();
+
+    /** Forcibly terminates this, causing all inflight operations to complete immediately. */
+    void destroy();
+
+    /** Wait for all inflight requests to complete. */
+    void await();
+
+    /** Enqueue the given operation, returning its future result. This may block if the client send queue is full. */
+    CompletableFuture<HttpResponse> enqueue(DocumentId documentId, HttpRequest request);
+
+}