diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-12-15 14:22:21 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2018-01-25 13:33:55 +0000 |
commit | d2834dc7a53fe629425b53ad95f6d503ca901f31 (patch) | |
tree | 58ff101ceb86b87bc9e7dec68d7339d5a39facb2 /config-model/src/main/java/com/yahoo/vespa/model/utils | |
parent | f03d9cab494447f079a342124fbd0c0b3541f439 (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.java | 17 |
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. */ |