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
// This file is @generated by prost-build.
/// Describes a running service that sends errors.
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ServiceContext {
/// An identifier of the service—for example, `discoveryengine.googleapis.com`.
#[prost(string, tag = "1")]
pub service: ::prost::alloc::string::String,
}
/// HTTP request data that is related to a reported error.
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct HttpRequestContext {
/// The HTTP response status code for the request.
#[prost(int32, tag = "1")]
pub response_status_code: i32,
}
/// Indicates a location in the source code of the service for which
/// errors are reported.
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct SourceLocation {
/// Human-readable name of a function or method—for example,
/// `google.cloud.discoveryengine.v1alpha.RecommendationService.Recommend`.
#[prost(string, tag = "1")]
pub function_name: ::prost::alloc::string::String,
}
/// A description of the context in which an error occurred.
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ErrorContext {
/// The HTTP request which was processed when the error was triggered.
#[prost(message, optional, tag = "1")]
pub http_request: ::core::option::Option<HttpRequestContext>,
/// The location in the source code where the decision was made to
/// report the error, usually the place where it was logged.
#[prost(message, optional, tag = "2")]
pub report_location: ::core::option::Option<SourceLocation>,
}
/// The error payload that is populated on LRO import APIs, including the
/// following:
///
/// * `google.cloud.discoveryengine.v1alpha.DocumentService.ImportDocuments`
/// * `google.cloud.discoveryengine.v1alpha.UserEventService.ImportUserEvents`
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ImportErrorContext {
/// The operation resource name of the LRO.
#[prost(string, tag = "1")]
pub operation: ::prost::alloc::string::String,
/// Google Cloud Storage file path of the import source.
/// Can be set for batch operation error.
#[prost(string, tag = "2")]
pub gcs_path: ::prost::alloc::string::String,
/// Line number of the content in file.
/// Should be empty for permission or batch operation error.
#[prost(string, tag = "3")]
pub line_number: ::prost::alloc::string::String,
/// Detailed content which caused the error.
/// Should be empty for permission or batch operation error.
#[prost(oneof = "import_error_context::LineContent", tags = "4, 5")]
pub line_content: ::core::option::Option<import_error_context::LineContent>,
}
/// Nested message and enum types in `ImportErrorContext`.
pub mod import_error_context {
/// Detailed content which caused the error.
/// Should be empty for permission or batch operation error.
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
pub enum LineContent {
/// The detailed content which caused the error on importing a document.
#[prost(string, tag = "4")]
Document(::prost::alloc::string::String),
/// The detailed content which caused the error on importing a user event.
#[prost(string, tag = "5")]
UserEvent(::prost::alloc::string::String),
}
}
/// The error payload that is populated on LRO sync APIs, including the
/// following:
///
/// * `google.cloud.discoveryengine.v1main.DataConnectorService.SetUpDataConnector`
/// * `google.cloud.discoveryengine.v1main.DataConnectorService.StartConnectorRun`
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ConnectorRunErrorContext {
/// The operation resource name of the LRO to sync the connector.
#[prost(string, tag = "1")]
pub operation: ::prost::alloc::string::String,
/// The full resource name of the DataConnector.
/// Format:
/// `projects/*/locations/*/collections/*/dataConnector`.
#[prost(string, tag = "2")]
pub data_connector: ::prost::alloc::string::String,
/// The full resource name of the Connector Run.
/// Format:
/// `projects/*/locations/*/collections/*/dataConnector/connectorRuns/*`.
/// The `connector_run_id` is system-generated.
#[prost(string, tag = "3")]
pub connector_run: ::prost::alloc::string::String,
/// The entity to sync for the connector run.
#[prost(string, tag = "4")]
pub entity: ::prost::alloc::string::String,
/// The type of sync run.
/// Can be one of the following:
///
/// * `FULL`
/// * `INCREMENTAL`
#[prost(string, tag = "5")]
pub sync_type: ::prost::alloc::string::String,
/// The time when the connector run started.
#[prost(message, optional, tag = "6")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
/// The time when the connector run ended.
#[prost(message, optional, tag = "7")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
}
/// An error log which is reported to the Error Reporting system.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ErrorLog {
/// The service context in which this error has occurred.
#[prost(message, optional, tag = "1")]
pub service_context: ::core::option::Option<ServiceContext>,
/// A description of the context in which the error occurred.
#[prost(message, optional, tag = "2")]
pub context: ::core::option::Option<ErrorContext>,
/// A message describing the error.
#[prost(string, tag = "3")]
pub message: ::prost::alloc::string::String,
/// The RPC status associated with the error log.
#[prost(message, optional, tag = "4")]
pub status: ::core::option::Option<super::super::super::rpc::Status>,
/// The API request payload, represented as a protocol buffer.
///
/// Most API request types are supported—for example:
///
/// * `type.googleapis.com/google.cloud.discoveryengine.v1alpha.DocumentService.CreateDocumentRequest`
/// * `type.googleapis.com/google.cloud.discoveryengine.v1alpha.UserEventService.WriteUserEventRequest`
#[prost(message, optional, tag = "5")]
pub request_payload: ::core::option::Option<::prost_types::Struct>,
/// The API response payload, represented as a protocol buffer.
///
/// This is used to log some "soft errors", where the response is valid but we
/// consider there are some quality issues like unjoined events.
///
/// The following API responses are supported, and no PII is included:
///
/// * `google.cloud.discoveryengine.v1alpha.RecommendationService.Recommend`
/// * `google.cloud.discoveryengine.v1alpha.UserEventService.WriteUserEvent`
/// * `google.cloud.discoveryengine.v1alpha.UserEventService.CollectUserEvent`
#[prost(message, optional, tag = "6")]
pub response_payload: ::core::option::Option<::prost_types::Struct>,
/// The error payload that is populated on LRO import APIs.
#[prost(message, optional, tag = "7")]
pub import_payload: ::core::option::Option<ImportErrorContext>,
/// The error payload that is populated on LRO connector sync APIs.
#[prost(message, optional, tag = "8")]
pub connector_run_payload: ::core::option::Option<ConnectorRunErrorContext>,
}