1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.config.server.http;
import com.yahoo.component.annotation.Inject;
import com.yahoo.collections.Tuple2;
import com.yahoo.container.jdisc.HttpRequest;
import com.yahoo.container.jdisc.HttpResponse;
import com.yahoo.jdisc.application.BindingMatch;
import com.yahoo.vespa.config.ConfigKey;
import com.yahoo.vespa.config.server.RequestHandler;
import com.yahoo.vespa.config.server.tenant.TenantRepository;
import com.yahoo.config.provision.ApplicationId;
import java.util.Optional;
import java.util.Set;
/**
* Handler for a list configs of given name operation. Lists all configs in model for a given config name.
*
* @author vegardh
* @since 5.1.11
*/
public class HttpListNamedConfigsHandler extends HttpHandler {
private final RequestHandler requestHandler;
public HttpListNamedConfigsHandler(HttpHandler.Context ctx,
RequestHandler requestHandler) {
super(ctx);
this.requestHandler = requestHandler;
}
@Inject
public HttpListNamedConfigsHandler(HttpHandler.Context ctx,
TenantRepository tenantRepository) {
this(ctx, tenantRepository.defaultTenant().getRequestHandler());
}
@Override
public HttpResponse handleGET(HttpRequest req) {
boolean recursive = req.getBooleanProperty(HttpListConfigsHandler.RECURSIVE_QUERY_PROPERTY);
ConfigKey<?> listKey = parseReqToKey(req);
HttpConfigRequest.validateRequestKey(listKey, requestHandler, ApplicationId.defaultId());
Set<ConfigKey<?>> configs = requestHandler.listNamedConfigs(ApplicationId.defaultId(), Optional.empty(), listKey, recursive);
String urlBase = Utils.getUrlBase(req, "/config/v1/");
return new HttpListConfigsHandler.ListConfigsResponse(configs, requestHandler.allConfigsProduced(ApplicationId.defaultId(), Optional.empty()), urlBase, recursive);
}
private ConfigKey<?> parseReqToKey(HttpRequest req) {
BindingMatch<?> bm = Utils.getBindingMatch(req, "http://*/config/v1/*/*");
String config = bm.group(2); // See jdisc-bindings.cfg. The port number is implicitly 1, it seems.
Tuple2<String, String> nns = HttpConfigRequest.nameAndNamespace(config);
String name = nns.first;
String namespace = nns.second;
String idSegment = "";
if (bm.groupCount() == 4) {
idSegment = bm.group(3);
}
return new ConfigKey<>(name, idSegment, namespace);
}
}
|
