aboutsummaryrefslogtreecommitdiffstats
path: root/config-model/src/main/java/com/yahoo/vespa/model/utils
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-12-15 14:22:21 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2018-01-25 13:33:55 +0000
commitd2834dc7a53fe629425b53ad95f6d503ca901f31 (patch)
tree58ff101ceb86b87bc9e7dec68d7339d5a39facb2 /config-model/src/main/java/com/yahoo/vespa/model/utils
parentf03d9cab494447f079a342124fbd0c0b3541f439 (diff)
Add option to also send an uri.
Diffstat (limited to 'config-model/src/main/java/com/yahoo/vespa/model/utils')
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/utils/FileSender.java17
1 files changed, 17 insertions, 0 deletions
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/utils/FileSender.java b/config-model/src/main/java/com/yahoo/vespa/model/utils/FileSender.java
index 413363d7b0d..8995fcbca99 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/utils/FileSender.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/utils/FileSender.java
@@ -20,6 +20,8 @@ import java.util.*;
*/
public class FileSender implements Serializable {
+ public enum FileType {FILE, URI};
+
/**
* Send the given file to all given services.
*
@@ -34,6 +36,7 @@ public class FileSender implements Serializable {
throw new IllegalStateException("No service instances. Probably a standalone cluster setting up <nodes> " +
"using 'count' instead of <node> tags.");
}
+
FileReference fileref = null;
for (AbstractService service : services) {
// The same reference will be returned from each call.
@@ -42,6 +45,20 @@ public class FileSender implements Serializable {
return fileref;
}
+ public static FileReference sendUriToServices(String uri, Collection<? extends AbstractService> services) {
+ if (services.isEmpty()) {
+ throw new IllegalStateException("No service instances. Probably a standalone cluster setting up <nodes> " +
+ "using 'count' instead of <node> tags.");
+ }
+
+ FileReference fileref = null;
+ for (AbstractService service : services) {
+ // The same reference will be returned from each call.
+ fileref = service.sendUri(uri);
+ }
+ return fileref;
+ }
+
/**
* Sends all user configured files for a producer to all given services.
*/