vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/FeederSettings.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
25
26
27
28
29

// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.http.server;

import com.yahoo.container.jdisc.HttpRequest;
import com.yahoo.messagebus.routing.Route;

import java.util.Optional;

/**
 * Wrapper for the feed feederSettings read from HTTP request.
 *
 * @author Steinar Knutsen
 */
public class FeederSettings {

    private static final Route DEFAULT_ROUTE = Route.parse("default");
    public final boolean drain; // TODO: Implement drain=true
    public final Route route;
    public final FeedParams.DataFormat dataFormat;
    public final Integer traceLevel;

    public FeederSettings(HttpRequest request) {
        this.drain = Optional.ofNullable(request.getHeader(Headers.DRAIN)).map(Boolean::parseBoolean).orElse(false);
        this.route = Optional.ofNullable(request.getHeader(Headers.ROUTE)).map(Route::parse).orElse(DEFAULT_ROUTE);
        this.dataFormat = Optional.ofNullable(request.getHeader(Headers.DATA_FORMAT)).map(FeedParams.DataFormat::valueOf).orElse(FeedParams.DataFormat.JSON_UTF8);
        this.traceLevel = Optional.ofNullable(request.getHeader(Headers.TRACE_LEVEL)).map(Integer::valueOf).orElse(null);
    }

}