forked from Deuxfleurs/garage
Alex
382e74c798
**Spec:** - [x] Start writing - [x] Specify all layout endpoints - [x] Specify all endpoints for operations on keys - [x] Specify all endpoints for operations on key/bucket permissions - [x] Specify all endpoints for operations on buckets - [x] Specify all endpoints for operations on bucket aliases View rendered spec at <https://git.deuxfleurs.fr/Deuxfleurs/garage/src/branch/admin-api/doc/drafts/admin-api.md> **Code:** - [x] Refactor code for admin api to use common api code that was created for K2V **General endpoints:** - [x] Metrics - [x] GetClusterStatus - [x] ConnectClusterNodes - [x] GetClusterLayout - [x] UpdateClusterLayout - [x] ApplyClusterLayout - [x] RevertClusterLayout **Key-related endpoints:** - [x] ListKeys - [x] CreateKey - [x] ImportKey - [x] GetKeyInfo - [x] UpdateKey - [x] DeleteKey **Bucket-related endpoints:** - [x] ListBuckets - [x] CreateBucket - [x] GetBucketInfo - [x] DeleteBucket - [x] PutBucketWebsite - [x] DeleteBucketWebsite **Operations on key/bucket permissions:** - [x] BucketAllowKey - [x] BucketDenyKey **Operations on bucket aliases:** - [x] GlobalAliasBucket - [x] GlobalUnaliasBucket - [x] LocalAliasBucket - [x] LocalUnaliasBucket **And also:** - [x] Separate error type for the admin API (this PR includes a quite big refactoring of error handling) - [x] Add management of website access - [ ] Check that nothing is missing wrt what can be done using the CLI - [ ] Improve formatting of the spec - [x] Make sure everyone is cool with the API design Fix #231 Fix #295 Co-authored-by: Alex Auvolat <alex@adnab.me> Reviewed-on: Deuxfleurs/garage#298 Co-authored-by: Alex <alex@adnab.me> Co-committed-by: Alex <alex@adnab.me>
37 lines
940 B
Rust
37 lines
940 B
Rust
use std::time::Duration;
|
|
|
|
use opentelemetry::sdk::{
|
|
trace::{self, IdGenerator, Sampler},
|
|
Resource,
|
|
};
|
|
use opentelemetry::KeyValue;
|
|
use opentelemetry_otlp::WithExportConfig;
|
|
|
|
use garage_util::data::*;
|
|
use garage_util::error::*;
|
|
|
|
pub fn init_tracing(export_to: &str, node_id: Uuid) -> Result<(), Error> {
|
|
let node_id = hex::encode(&node_id.as_slice()[..8]);
|
|
|
|
opentelemetry_otlp::new_pipeline()
|
|
.tracing()
|
|
.with_exporter(
|
|
opentelemetry_otlp::new_exporter()
|
|
.tonic()
|
|
.with_endpoint(export_to)
|
|
.with_timeout(Duration::from_secs(3)),
|
|
)
|
|
.with_trace_config(
|
|
trace::config()
|
|
.with_id_generator(IdGenerator::default())
|
|
.with_sampler(Sampler::AlwaysOn)
|
|
.with_resource(Resource::new(vec![
|
|
KeyValue::new("service.name", "garage"),
|
|
KeyValue::new("service.instance.id", node_id),
|
|
])),
|
|
)
|
|
.install_batch(opentelemetry::runtime::Tokio)
|
|
.ok_or_message("Unable to initialize tracing")?;
|
|
|
|
Ok(())
|
|
}
|