56 lines
1.4 KiB
Nix
56 lines
1.4 KiB
Nix
{ config, lib, pkgs, options, ... }:
|
|
|
|
let
|
|
cfg = config.services.prometheus.exporters.flow;
|
|
inherit (lib)
|
|
mkOption
|
|
types
|
|
literalExpression
|
|
concatStringsSep
|
|
optionalString
|
|
;
|
|
in {
|
|
port = 9590;
|
|
extraOpts = {
|
|
brokers = mkOption {
|
|
type = types.listOf types.str;
|
|
example = literalExpression ''[ "kafka.example.org:19092" ]'';
|
|
description = "List of Kafka brokers to connect to.";
|
|
};
|
|
|
|
asn = mkOption {
|
|
type = types.ints.positive;
|
|
example = 65542;
|
|
description = "The ASN being monitored.";
|
|
};
|
|
|
|
partitions = mkOption {
|
|
type = types.listOf types.int;
|
|
default = [];
|
|
description = ''
|
|
The number of the partitions to consume, none means all.
|
|
'';
|
|
};
|
|
|
|
topic = mkOption {
|
|
type = types.str;
|
|
example = "pmacct.acct";
|
|
description = "The Kafka topic to consume from.";
|
|
};
|
|
};
|
|
|
|
serviceOpts = {
|
|
serviceConfig = {
|
|
DynamicUser = true;
|
|
ExecStart = ''
|
|
${pkgs.prometheus-flow-exporter}/bin/flow-exporter \
|
|
-asn ${toString cfg.asn} \
|
|
-topic ${cfg.topic} \
|
|
-brokers ${concatStringsSep "," cfg.brokers} \
|
|
${optionalString (cfg.partitions != []) "-partitions ${concatStringsSep "," cfg.partitions}"} \
|
|
-addr ${cfg.listenAddress}:${toString cfg.port} ${concatStringsSep " " cfg.extraFlags}
|
|
'';
|
|
};
|
|
};
|
|
}
|