Skip to content

Commit

Permalink
Regenerate protobuf types
Browse files Browse the repository at this point in the history
  • Loading branch information
@aumetra
aumetra committed Jul 10, 2024
1 parent 70a9bc7 commit 95608c5
Show file tree
Hide file tree
Showing 4 changed files with 21 additions and 54 deletions.
23 changes: 6 additions & 17 deletions opentelemetry-proto/src/proto/tonic/opentelemetry.proto.collector.logs.v1.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -207,19 +207,17 @@ pub mod logs_service_server {
/// case logs are sent/received to/from multiple Applications).
#[derive(Debug)]
pub struct LogsServiceServer<T: LogsService> {
inner: _Inner<T>,
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
struct _Inner<T>(Arc<T>);
impl<T: LogsService> LogsServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
let inner = _Inner(inner);
Self {
inner,
accept_compression_encodings: Default::default(),
Expand Down Expand Up @@ -282,7 +280,6 @@ pub mod logs_service_server {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
let inner = self.inner.clone();
match req.uri().path() {
"/opentelemetry.proto.collector.logs.v1.LogsService/Export" => {
#[allow(non_camel_case_types)]
Expand Down Expand Up @@ -313,7 +310,6 @@ pub mod logs_service_server {
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let inner = inner.0;
let method = ExportSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
Expand All @@ -335,8 +331,11 @@ pub mod logs_service_server {
Ok(
http::Response::builder()
.status(200)
.header("grpc-status", "12")
.header("content-type", "application/grpc")
.header("grpc-status", tonic::Code::Unimplemented as i32)
.header(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
)
.body(empty_body())
.unwrap(),
)
Expand All @@ -357,16 +356,6 @@ pub mod logs_service_server {
}
}
}
impl<T: LogsService> Clone for _Inner<T> {
fn clone(&self) -> Self {
Self(Arc::clone(&self.0))
}
}
impl<T: std::fmt::Debug> std::fmt::Debug for _Inner<T> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(f, "{:?}", self.0)
}
}
impl<T: LogsService> tonic::server::NamedService for LogsServiceServer<T> {
const NAME: &'static str = "opentelemetry.proto.collector.logs.v1.LogsService";
}
Expand Down
23 changes: 6 additions & 17 deletions opentelemetry-proto/src/proto/tonic/opentelemetry.proto.collector.metrics.v1.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -207,19 +207,17 @@ pub mod metrics_service_server {
/// central collector.
#[derive(Debug)]
pub struct MetricsServiceServer<T: MetricsService> {
inner: _Inner<T>,
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
struct _Inner<T>(Arc<T>);
impl<T: MetricsService> MetricsServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
let inner = _Inner(inner);
Self {
inner,
accept_compression_encodings: Default::default(),
Expand Down Expand Up @@ -282,7 +280,6 @@ pub mod metrics_service_server {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
let inner = self.inner.clone();
match req.uri().path() {
"/opentelemetry.proto.collector.metrics.v1.MetricsService/Export" => {
#[allow(non_camel_case_types)]
Expand Down Expand Up @@ -313,7 +310,6 @@ pub mod metrics_service_server {
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let inner = inner.0;
let method = ExportSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
Expand All @@ -335,8 +331,11 @@ pub mod metrics_service_server {
Ok(
http::Response::builder()
.status(200)
.header("grpc-status", "12")
.header("content-type", "application/grpc")
.header("grpc-status", tonic::Code::Unimplemented as i32)
.header(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
)
.body(empty_body())
.unwrap(),
)
Expand All @@ -357,16 +356,6 @@ pub mod metrics_service_server {
}
}
}
impl<T: MetricsService> Clone for _Inner<T> {
fn clone(&self) -> Self {
Self(Arc::clone(&self.0))
}
}
impl<T: std::fmt::Debug> std::fmt::Debug for _Inner<T> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(f, "{:?}", self.0)
}
}
impl<T: MetricsService> tonic::server::NamedService for MetricsServiceServer<T> {
const NAME: &'static str = "opentelemetry.proto.collector.metrics.v1.MetricsService";
}
Expand Down
23 changes: 6 additions & 17 deletions opentelemetry-proto/src/proto/tonic/opentelemetry.proto.collector.trace.v1.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -207,19 +207,17 @@ pub mod trace_service_server {
/// case spans are sent/received to/from multiple Applications).
#[derive(Debug)]
pub struct TraceServiceServer<T: TraceService> {
inner: _Inner<T>,
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
struct _Inner<T>(Arc<T>);
impl<T: TraceService> TraceServiceServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
let inner = _Inner(inner);
Self {
inner,
accept_compression_encodings: Default::default(),
Expand Down Expand Up @@ -282,7 +280,6 @@ pub mod trace_service_server {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
let inner = self.inner.clone();
match req.uri().path() {
"/opentelemetry.proto.collector.trace.v1.TraceService/Export" => {
#[allow(non_camel_case_types)]
Expand Down Expand Up @@ -313,7 +310,6 @@ pub mod trace_service_server {
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let inner = inner.0;
let method = ExportSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
Expand All @@ -335,8 +331,11 @@ pub mod trace_service_server {
Ok(
http::Response::builder()
.status(200)
.header("grpc-status", "12")
.header("content-type", "application/grpc")
.header("grpc-status", tonic::Code::Unimplemented as i32)
.header(
http::header::CONTENT_TYPE,
tonic::metadata::GRPC_CONTENT_TYPE,
)
.body(empty_body())
.unwrap(),
)
Expand All @@ -357,16 +356,6 @@ pub mod trace_service_server {
}
}
}
impl<T: TraceService> Clone for _Inner<T> {
fn clone(&self) -> Self {
Self(Arc::clone(&self.0))
}
}
impl<T: std::fmt::Debug> std::fmt::Debug for _Inner<T> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(f, "{:?}", self.0)
}
}
impl<T: TraceService> tonic::server::NamedService for TraceServiceServer<T> {
const NAME: &'static str = "opentelemetry.proto.collector.trace.v1.TraceService";
}
Expand Down
6 changes: 3 additions & 3 deletions opentelemetry-proto/src/proto/tonic/opentelemetry.proto.metrics.v1.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -335,7 +335,7 @@ pub mod number_data_point {
#[cfg_attr(feature = "with-serde", derive(serde::Serialize, serde::Deserialize))]
#[cfg_attr(feature = "with-serde", serde(rename_all = "camelCase"))]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum Value {
#[prost(double, tag = "4")]
AsDouble(f64),
Expand Down Expand Up @@ -624,7 +624,7 @@ pub mod summary_data_point {
#[cfg_attr(feature = "with-serde", derive(serde::Serialize, serde::Deserialize))]
#[cfg_attr(feature = "with-serde", serde(rename_all = "camelCase"))]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ValueAtQuantile {
/// The quantile of a distribution. Must be in the interval
/// \[0.0, 1.0\].
Expand Down Expand Up @@ -685,7 +685,7 @@ pub mod exemplar {
#[cfg_attr(feature = "with-serde", derive(serde::Serialize, serde::Deserialize))]
#[cfg_attr(feature = "with-serde", serde(rename_all = "camelCase"))]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum Value {
#[prost(double, tag = "3")]
AsDouble(f64),
Expand Down

0 comments on commit 95608c5

Please sign in to comment.