Skip to content

Commit 83bc98f

Browse files
committed
resource: turn empty fn from pub to crate
1 parent 1e88ff7 commit 83bc98f

File tree

7 files changed

+14
-14
lines changed

7 files changed

+14
-14
lines changed

opentelemetry-sdk/src/logs/log_emitter.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ fn noop_logger_provider() -> &'static LoggerProvider {
2424
NOOP_LOGGER_PROVIDER.get_or_init(|| LoggerProvider {
2525
inner: Arc::new(LoggerProviderInner {
2626
processors: Vec::new(),
27-
resource: Resource::builder_empty().build(),
27+
resource: Resource::empty(),
2828
is_shutdown: AtomicBool::new(true),
2929
}),
3030
})
@@ -482,7 +482,7 @@ mod tests {
482482

483483
// If user provided a resource, it takes priority during collision.
484484
let no_service_name = super::LoggerProvider::builder()
485-
.with_resource(Resource::builder_empty().build())
485+
.with_resource(Resource::empty())
486486
.build();
487487
assert_eq!(no_service_name.resource().len(), 0);
488488
}
@@ -641,7 +641,7 @@ mod tests {
641641
shutdown_called.clone(),
642642
flush_called.clone(),
643643
))],
644-
resource: Resource::builder_empty().build(),
644+
resource: Resource::empty(),
645645
is_shutdown: AtomicBool::new(false),
646646
});
647647

@@ -682,7 +682,7 @@ mod tests {
682682
shutdown_called.clone(),
683683
flush_called.clone(),
684684
))],
685-
resource: Resource::builder_empty().build(),
685+
resource: Resource::empty(),
686686
is_shutdown: AtomicBool::new(false),
687687
});
688688

opentelemetry-sdk/src/metrics/meter_provider.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -435,7 +435,7 @@ mod tests {
435435
let reader5 = TestMetricReader::new();
436436
let no_service_name = super::SdkMeterProvider::builder()
437437
.with_reader(reader5)
438-
.with_resource(Resource::builder_empty().build())
438+
.with_resource(Resource::empty())
439439
.build();
440440

441441
assert_eq!(no_service_name.inner.pipes.0[0].resource.len(), 0)

opentelemetry-sdk/src/metrics/periodic_reader.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -325,7 +325,7 @@ impl PeriodicReaderInner {
325325
// TODO: Reuse the internal vectors. Or refactor to avoid needing any
326326
// owned data structures to be passed to exporters.
327327
let mut rm = ResourceMetrics {
328-
resource: Resource::builder_empty().build(),
328+
resource: Resource::empty(),
329329
scope_metrics: Vec::new(),
330330
};
331331

@@ -647,7 +647,7 @@ mod tests {
647647
.build();
648648

649649
let rm = &mut ResourceMetrics {
650-
resource: Resource::builder_empty().build(),
650+
resource: Resource::empty(),
651651
scope_metrics: Vec::new(),
652652
};
653653
// Pipeline is not registered, so collect should return an error

opentelemetry-sdk/src/metrics/periodic_reader_with_async_runtime.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ where
119119
timeout: self.timeout,
120120
runtime,
121121
rm: ResourceMetrics {
122-
resource: Resource::builder_empty().build(),
122+
resource: Resource::empty(),
123123
scope_metrics: Vec::new(),
124124
},
125125
}
@@ -466,7 +466,7 @@ mod tests {
466466
let exporter = InMemoryMetricExporter::default();
467467
let reader = PeriodicReader::builder(exporter.clone(), runtime::Tokio).build();
468468
let mut rm = ResourceMetrics {
469-
resource: Resource::builder_empty().build(),
469+
resource: Resource::empty(),
470470
scope_metrics: Vec::new(),
471471
};
472472

opentelemetry-sdk/src/resource/env.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ impl ResourceDetector for EnvResourceDetector {
2222
fn detect(&self) -> Resource {
2323
match env::var(OTEL_RESOURCE_ATTRIBUTES) {
2424
Ok(s) if !s.is_empty() => construct_otel_resources(s),
25-
Ok(_) | Err(_) => Resource::builder_empty().with_attributes(vec![]).build(), // return empty resource
25+
Ok(_) | Err(_) => Resource::empty(), // return empty resource
2626
}
2727
}
2828
}

opentelemetry-sdk/src/resource/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ impl Resource {
7979

8080
/// Creates an empty resource.
8181
/// This is the basic constructor that initializes a resource with no attributes and no schema URL.
82-
fn empty() -> Self {
82+
pub(crate) fn empty() -> Self {
8383
Resource {
8484
inner: Arc::new(ResourceInner {
8585
attrs: HashMap::new(),
@@ -92,7 +92,7 @@ impl Resource {
9292
///
9393
/// Values are de-duplicated by key, and the first key-value pair with a non-empty string value
9494
/// will be retained
95-
fn new<T: IntoIterator<Item = KeyValue>>(kvs: T) -> Self {
95+
pub(crate) fn new<T: IntoIterator<Item = KeyValue>>(kvs: T) -> Self {
9696
let mut attrs = HashMap::new();
9797
for kv in kvs {
9898
attrs.insert(kv.key, kv.value);

opentelemetry-sdk/src/trace/provider.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ fn noop_tracer_provider() -> &'static TracerProvider {
9393
sampler: Box::new(Sampler::ParentBased(Box::new(Sampler::AlwaysOn))),
9494
id_generator: Box::<RandomIdGenerator>::default(),
9595
span_limits: SpanLimits::default(),
96-
resource: Cow::Owned(Resource::builder_empty().build()),
96+
resource: Cow::Owned(Resource::empty()),
9797
},
9898
is_shutdown: AtomicBool::new(true),
9999
}),
@@ -644,7 +644,7 @@ mod tests {
644644

645645
// If user provided a resource, it takes priority during collision.
646646
let no_service_name = super::TracerProvider::builder()
647-
.with_resource(Resource::builder_empty().build())
647+
.with_resource(Resource::empty())
648648
.build();
649649

650650
assert_eq!(no_service_name.config().resource.len(), 0)

0 commit comments

Comments
 (0)