in worker/src/main.rs [93:118]
fn from(args: ReporterArgs) -> Self {
match args {
ReporterArgs::Grpc {
server_addr,
authentication,
enable_tls,
ssl_cert_chain_path,
ssl_key_path,
ssl_trusted_ca_path,
} => ReporterConfiguration::Grpc(GrpcReporterConfiguration {
server_addr,
authentication: authentication.unwrap_or_default(),
enable_tls,
ssl_cert_chain_path: ssl_cert_chain_path.unwrap_or_default(),
ssl_key_path: ssl_key_path.unwrap_or_default(),
ssl_trusted_ca_path: ssl_trusted_ca_path.unwrap_or_default(),
}),
ReporterArgs::Kafka {
kafka_bootstrap_servers,
kafka_producer_config,
} => ReporterConfiguration::Kafka(KafkaReporterConfiguration {
kafka_bootstrap_servers,
kafka_producer_config: kafka_producer_config.unwrap_or_default(),
}),
}
}