-
Notifications
You must be signed in to change notification settings - Fork 53
/
PromSinkConfig.java
50 lines (37 loc) · 1.55 KB
/
PromSinkConfig.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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
package io.odpf.firehose.config;
import io.odpf.firehose.config.converter.ProtoIndexToFieldMapConverter;
import io.odpf.firehose.config.converter.RangeToHashMapConverter;
import java.util.Map;
import java.util.Properties;
public interface PromSinkConfig extends AppConfig {
@Key("SINK_PROM_RETRY_STATUS_CODE_RANGES")
@DefaultValue("400-600")
@ConverterClass(RangeToHashMapConverter.class)
Map<Integer, Boolean> getSinkPromRetryStatusCodeRanges();
@Key("SINK_PROM_REQUEST_LOG_STATUS_CODE_RANGES")
@DefaultValue("400-499")
@ConverterClass(RangeToHashMapConverter.class)
Map<Integer, Boolean> getSinkPromRequestLogStatusCodeRanges();
@Key("SINK_PROM_REQUEST_TIMEOUT_MS")
@DefaultValue("10000")
Integer getSinkPromRequestTimeoutMs();
@Key("SINK_PROM_MAX_CONNECTIONS")
Integer getSinkPromMaxConnections();
@Key("SINK_PROM_SERVICE_URL")
String getSinkPromServiceUrl();
@Key("SINK_PROM_HEADERS")
@DefaultValue("")
String getSinkPromHeaders();
@Key("SINK_PROM_METRIC_NAME_PROTO_INDEX_MAPPING")
@ConverterClass(ProtoIndexToFieldMapConverter.class)
Properties getSinkPromMetricNameProtoIndexMapping();
@Key("SINK_PROM_LABEL_NAME_PROTO_INDEX_MAPPING")
@ConverterClass(ProtoIndexToFieldMapConverter.class)
Properties getSinkPromLabelNameProtoIndexMapping();
@Key("SINK_PROM_PROTO_EVENT_TIMESTAMP_INDEX")
@DefaultValue("1")
Integer getSinkPromProtoEventTimestampIndex();
@Key("SINK_PROM_WITH_EVENT_TIMESTAMP")
@DefaultValue("false")
boolean isEventTimestampEnabled();
}