1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352
// This file is @generated by prost-build.
/// Request message for the Parse method.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ParseRequest {
/// Required. Source text in CEL syntax.
#[prost(string, tag = "1")]
pub cel_source: ::prost::alloc::string::String,
/// Tag for version of CEL syntax, for future use.
#[prost(string, tag = "2")]
pub syntax_version: ::prost::alloc::string::String,
/// File or resource for source text, used in [SourceInfo][google.api.SourceInfo].
#[prost(string, tag = "3")]
pub source_location: ::prost::alloc::string::String,
/// Prevent macro expansion. See "Macros" in Language Defiinition.
#[prost(bool, tag = "4")]
pub disable_macros: bool,
}
/// Response message for the Parse method.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ParseResponse {
/// The parsed representation, or unset if parsing failed.
#[prost(message, optional, tag = "1")]
pub parsed_expr: ::core::option::Option<super::super::v1alpha1::ParsedExpr>,
/// Any number of issues with [StatusDetails][] as the details.
#[prost(message, repeated, tag = "2")]
pub issues: ::prost::alloc::vec::Vec<super::super::super::super::rpc::Status>,
}
/// Request message for the Check method.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckRequest {
/// Required. The parsed representation of the CEL program.
#[prost(message, optional, tag = "1")]
pub parsed_expr: ::core::option::Option<super::super::v1alpha1::ParsedExpr>,
/// Declarations of types for external variables and functions.
/// Required if program uses external variables or functions
/// not in the default environment.
#[prost(message, repeated, tag = "2")]
pub type_env: ::prost::alloc::vec::Vec<super::super::v1alpha1::Decl>,
/// The protocol buffer context. See "Name Resolution" in the
/// Language Definition.
#[prost(string, tag = "3")]
pub container: ::prost::alloc::string::String,
/// If true, use only the declarations in [type_env][google.api.expr.conformance.v1alpha1.CheckRequest.type_env]. If false (default),
/// add declarations for the standard definitions to the type environment. See
/// "Standard Definitions" in the Language Definition.
#[prost(bool, tag = "4")]
pub no_std_env: bool,
}
/// Response message for the Check method.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CheckResponse {
/// The annotated representation, or unset if checking failed.
#[prost(message, optional, tag = "1")]
pub checked_expr: ::core::option::Option<super::super::v1alpha1::CheckedExpr>,
/// Any number of issues with [StatusDetails][] as the details.
#[prost(message, repeated, tag = "2")]
pub issues: ::prost::alloc::vec::Vec<super::super::super::super::rpc::Status>,
}
/// Request message for the Eval method.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EvalRequest {
/// Bindings for the external variables. The types SHOULD be compatible
/// with the type environment in [CheckRequest][google.api.expr.conformance.v1alpha1.CheckRequest], if checked.
#[prost(btree_map = "string, message", tag = "3")]
pub bindings: ::prost::alloc::collections::BTreeMap<
::prost::alloc::string::String,
super::super::v1alpha1::ExprValue,
>,
/// SHOULD be the same container as used in [CheckRequest][google.api.expr.conformance.v1alpha1.CheckRequest], if checked.
#[prost(string, tag = "4")]
pub container: ::prost::alloc::string::String,
/// Required. Either the parsed or annotated representation of the CEL program.
#[prost(oneof = "eval_request::ExprKind", tags = "1, 2")]
pub expr_kind: ::core::option::Option<eval_request::ExprKind>,
}
/// Nested message and enum types in `EvalRequest`.
pub mod eval_request {
/// Required. Either the parsed or annotated representation of the CEL program.
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum ExprKind {
/// Evaluate based on the parsed representation.
#[prost(message, tag = "1")]
ParsedExpr(super::super::super::v1alpha1::ParsedExpr),
/// Evaluate based on the checked representation.
#[prost(message, tag = "2")]
CheckedExpr(super::super::super::v1alpha1::CheckedExpr),
}
}
/// Response message for the Eval method.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EvalResponse {
/// The execution result, or unset if execution couldn't start.
#[prost(message, optional, tag = "1")]
pub result: ::core::option::Option<super::super::v1alpha1::ExprValue>,
/// Any number of issues with [StatusDetails][] as the details.
/// Note that CEL execution errors are reified into [ExprValue][].
/// Nevertheless, we'll allow out-of-band issues to be raised,
/// which also makes the replies more regular.
#[prost(message, repeated, tag = "2")]
pub issues: ::prost::alloc::vec::Vec<super::super::super::super::rpc::Status>,
}
/// A specific position in source.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SourcePosition {
/// The source location name (e.g. file name).
#[prost(string, tag = "1")]
pub location: ::prost::alloc::string::String,
/// The UTF-8 code unit offset.
#[prost(int32, tag = "2")]
pub offset: i32,
/// The 1-based index of the starting line in the source text
/// where the issue occurs, or 0 if unknown.
#[prost(int32, tag = "3")]
pub line: i32,
/// The 0-based index of the starting position within the line of source text
/// where the issue occurs. Only meaningful if line is nonzero.
#[prost(int32, tag = "4")]
pub column: i32,
}
/// Warnings or errors in service execution are represented by
/// [google.rpc.Status][google.rpc.Status] messages, with the following message
/// in the details field.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IssueDetails {
/// The severity of the issue.
#[prost(enumeration = "issue_details::Severity", tag = "1")]
pub severity: i32,
/// Position in the source, if known.
#[prost(message, optional, tag = "2")]
pub position: ::core::option::Option<SourcePosition>,
/// Expression ID from [Expr][], 0 if unknown.
#[prost(int64, tag = "3")]
pub id: i64,
}
/// Nested message and enum types in `IssueDetails`.
pub mod issue_details {
/// Severities of issues.
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum Severity {
/// An unspecified severity.
Unspecified = 0,
/// Deprecation issue for statements and method that may no longer be
/// supported or maintained.
Deprecation = 1,
/// Warnings such as: unused variables.
Warning = 2,
/// Errors such as: unmatched curly braces or variable redefinition.
Error = 3,
}
impl Severity {
/// String value of the enum field names used in the ProtoBuf definition.
///
/// The values are not transformed in any way and thus are considered stable
/// (if the ProtoBuf definition does not change) and safe for programmatic use.
pub fn as_str_name(&self) -> &'static str {
match self {
Severity::Unspecified => "SEVERITY_UNSPECIFIED",
Severity::Deprecation => "DEPRECATION",
Severity::Warning => "WARNING",
Severity::Error => "ERROR",
}
}
/// Creates an enum from field names used in the ProtoBuf definition.
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"SEVERITY_UNSPECIFIED" => Some(Self::Unspecified),
"DEPRECATION" => Some(Self::Deprecation),
"WARNING" => Some(Self::Warning),
"ERROR" => Some(Self::Error),
_ => None,
}
}
}
}
/// Generated client implementations.
pub mod conformance_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
/// Access a CEL implementation from another process or machine.
/// A CEL implementation is decomposed as a parser, a static checker,
/// and an evaluator. Every CEL implementation is expected to provide
/// a server for this API. The API will be used for conformance testing
/// and other utilities.
#[derive(Debug, Clone)]
pub struct ConformanceServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> ConformanceServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> ConformanceServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
>>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
{
ConformanceServiceClient::new(InterceptedService::new(inner, interceptor))
}
/// Compress requests with the given encoding.
///
/// This requires the server to support it otherwise it might respond with an
/// error.
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
/// Enable decompressing responses.
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
/// Limits the maximum size of a decoded message.
///
/// Default: `4MB`
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
/// Limits the maximum size of an encoded message.
///
/// Default: `usize::MAX`
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
/// Transforms CEL source text into a parsed representation.
pub async fn parse(
&mut self,
request: impl tonic::IntoRequest<super::ParseRequest>,
) -> std::result::Result<tonic::Response<super::ParseResponse>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.api.expr.conformance.v1alpha1.ConformanceService/Parse",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.api.expr.conformance.v1alpha1.ConformanceService",
"Parse",
),
);
self.inner.unary(req, path, codec).await
}
/// Runs static checks on a parsed CEL representation and return
/// an annotated representation, or a set of issues.
pub async fn check(
&mut self,
request: impl tonic::IntoRequest<super::CheckRequest>,
) -> std::result::Result<tonic::Response<super::CheckResponse>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.api.expr.conformance.v1alpha1.ConformanceService/Check",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.api.expr.conformance.v1alpha1.ConformanceService",
"Check",
),
);
self.inner.unary(req, path, codec).await
}
/// Evaluates a parsed or annotation CEL representation given
/// values of external bindings.
pub async fn eval(
&mut self,
request: impl tonic::IntoRequest<super::EvalRequest>,
) -> std::result::Result<tonic::Response<super::EvalResponse>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.api.expr.conformance.v1alpha1.ConformanceService/Eval",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.api.expr.conformance.v1alpha1.ConformanceService",
"Eval",
),
);
self.inner.unary(req, path, codec).await
}
}
}