loki_api/
logproto.rs

1#[derive(Clone, PartialEq, ::prost::Message)]
2pub struct PushRequest {
3    #[prost(message, repeated, tag="1")]
4    pub streams: ::prost::alloc::vec::Vec<StreamAdapter>,
5}
6#[derive(Clone, PartialEq, ::prost::Message)]
7pub struct PushResponse {
8}
9#[derive(Clone, PartialEq, ::prost::Message)]
10pub struct QueryRequest {
11    #[prost(string, tag="1")]
12    pub selector: ::prost::alloc::string::String,
13    #[prost(uint32, tag="2")]
14    pub limit: u32,
15    #[prost(message, optional, tag="3")]
16    pub start: ::core::option::Option<::prost_types::Timestamp>,
17    #[prost(message, optional, tag="4")]
18    pub end: ::core::option::Option<::prost_types::Timestamp>,
19    #[prost(enumeration="Direction", tag="5")]
20    pub direction: i32,
21    #[prost(string, repeated, tag="7")]
22    pub shards: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
23    #[prost(message, repeated, tag="8")]
24    pub deletes: ::prost::alloc::vec::Vec<Delete>,
25}
26#[derive(Clone, PartialEq, ::prost::Message)]
27pub struct SampleQueryRequest {
28    #[prost(string, tag="1")]
29    pub selector: ::prost::alloc::string::String,
30    #[prost(message, optional, tag="2")]
31    pub start: ::core::option::Option<::prost_types::Timestamp>,
32    #[prost(message, optional, tag="3")]
33    pub end: ::core::option::Option<::prost_types::Timestamp>,
34    #[prost(string, repeated, tag="4")]
35    pub shards: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
36    #[prost(message, repeated, tag="5")]
37    pub deletes: ::prost::alloc::vec::Vec<Delete>,
38}
39#[derive(Clone, PartialEq, ::prost::Message)]
40pub struct Delete {
41    #[prost(string, tag="1")]
42    pub selector: ::prost::alloc::string::String,
43    #[prost(int64, tag="2")]
44    pub start: i64,
45    #[prost(int64, tag="3")]
46    pub end: i64,
47}
48#[derive(Clone, PartialEq, ::prost::Message)]
49pub struct QueryResponse {
50    #[prost(message, repeated, tag="1")]
51    pub streams: ::prost::alloc::vec::Vec<StreamAdapter>,
52    #[prost(message, optional, tag="2")]
53    pub stats: ::core::option::Option<super::stats::Ingester>,
54}
55#[derive(Clone, PartialEq, ::prost::Message)]
56pub struct SampleQueryResponse {
57    #[prost(message, repeated, tag="1")]
58    pub series: ::prost::alloc::vec::Vec<Series>,
59    #[prost(message, optional, tag="2")]
60    pub stats: ::core::option::Option<super::stats::Ingester>,
61}
62#[derive(Clone, PartialEq, ::prost::Message)]
63pub struct LabelRequest {
64    #[prost(string, tag="1")]
65    pub name: ::prost::alloc::string::String,
66    /// True to fetch label values, false for fetch labels names.
67    #[prost(bool, tag="2")]
68    pub values: bool,
69    #[prost(message, optional, tag="3")]
70    pub start: ::core::option::Option<::prost_types::Timestamp>,
71    #[prost(message, optional, tag="4")]
72    pub end: ::core::option::Option<::prost_types::Timestamp>,
73}
74#[derive(Clone, PartialEq, ::prost::Message)]
75pub struct LabelResponse {
76    #[prost(string, repeated, tag="1")]
77    pub values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
78}
79#[derive(Clone, PartialEq, ::prost::Message)]
80pub struct StreamAdapter {
81    #[prost(string, tag="1")]
82    pub labels: ::prost::alloc::string::String,
83    #[prost(message, repeated, tag="2")]
84    pub entries: ::prost::alloc::vec::Vec<EntryAdapter>,
85    /// hash contains the original hash of the stream.
86    #[prost(uint64, tag="3")]
87    pub hash: u64,
88}
89#[derive(Clone, PartialEq, ::prost::Message)]
90pub struct EntryAdapter {
91    #[prost(message, optional, tag="1")]
92    pub timestamp: ::core::option::Option<::prost_types::Timestamp>,
93    #[prost(string, tag="2")]
94    pub line: ::prost::alloc::string::String,
95}
96#[derive(Clone, PartialEq, ::prost::Message)]
97pub struct Sample {
98    #[prost(int64, tag="1")]
99    pub timestamp: i64,
100    #[prost(double, tag="2")]
101    pub value: f64,
102    #[prost(uint64, tag="3")]
103    pub hash: u64,
104}
105/// LegacySample exists for backwards compatibility reasons and is deprecated. Do not use.
106#[derive(Clone, PartialEq, ::prost::Message)]
107pub struct LegacySample {
108    #[prost(double, tag="1")]
109    pub value: f64,
110    #[prost(int64, tag="2")]
111    pub timestamp_ms: i64,
112}
113#[derive(Clone, PartialEq, ::prost::Message)]
114pub struct Series {
115    #[prost(string, tag="1")]
116    pub labels: ::prost::alloc::string::String,
117    #[prost(message, repeated, tag="2")]
118    pub samples: ::prost::alloc::vec::Vec<Sample>,
119    #[prost(uint64, tag="3")]
120    pub stream_hash: u64,
121}
122#[derive(Clone, PartialEq, ::prost::Message)]
123pub struct TailRequest {
124    #[prost(string, tag="1")]
125    pub query: ::prost::alloc::string::String,
126    #[prost(uint32, tag="3")]
127    pub delay_for: u32,
128    #[prost(uint32, tag="4")]
129    pub limit: u32,
130    #[prost(message, optional, tag="5")]
131    pub start: ::core::option::Option<::prost_types::Timestamp>,
132}
133#[derive(Clone, PartialEq, ::prost::Message)]
134pub struct TailResponse {
135    #[prost(message, optional, tag="1")]
136    pub stream: ::core::option::Option<StreamAdapter>,
137    #[prost(message, repeated, tag="2")]
138    pub dropped_streams: ::prost::alloc::vec::Vec<DroppedStream>,
139}
140#[derive(Clone, PartialEq, ::prost::Message)]
141pub struct SeriesRequest {
142    #[prost(message, optional, tag="1")]
143    pub start: ::core::option::Option<::prost_types::Timestamp>,
144    #[prost(message, optional, tag="2")]
145    pub end: ::core::option::Option<::prost_types::Timestamp>,
146    #[prost(string, repeated, tag="3")]
147    pub groups: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
148    #[prost(string, repeated, tag="4")]
149    pub shards: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
150}
151#[derive(Clone, PartialEq, ::prost::Message)]
152pub struct SeriesResponse {
153    #[prost(message, repeated, tag="1")]
154    pub series: ::prost::alloc::vec::Vec<SeriesIdentifier>,
155}
156#[derive(Clone, PartialEq, ::prost::Message)]
157pub struct SeriesIdentifier {
158    #[prost(map="string, string", tag="1")]
159    pub labels: ::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
160}
161#[derive(Clone, PartialEq, ::prost::Message)]
162pub struct DroppedStream {
163    #[prost(message, optional, tag="1")]
164    pub from: ::core::option::Option<::prost_types::Timestamp>,
165    #[prost(message, optional, tag="2")]
166    pub to: ::core::option::Option<::prost_types::Timestamp>,
167    #[prost(string, tag="3")]
168    pub labels: ::prost::alloc::string::String,
169}
170#[derive(Clone, PartialEq, ::prost::Message)]
171pub struct TimeSeriesChunk {
172    #[prost(string, tag="1")]
173    pub from_ingester_id: ::prost::alloc::string::String,
174    #[prost(string, tag="2")]
175    pub user_id: ::prost::alloc::string::String,
176    #[prost(message, repeated, tag="3")]
177    pub labels: ::prost::alloc::vec::Vec<LabelPair>,
178    #[prost(message, repeated, tag="4")]
179    pub chunks: ::prost::alloc::vec::Vec<Chunk>,
180}
181#[derive(Clone, PartialEq, ::prost::Message)]
182pub struct LabelPair {
183    #[prost(string, tag="1")]
184    pub name: ::prost::alloc::string::String,
185    #[prost(string, tag="2")]
186    pub value: ::prost::alloc::string::String,
187}
188/// LegacyLabelPair exists for backwards compatibility reasons and is deprecated. Do not use.
189#[derive(Clone, PartialEq, ::prost::Message)]
190pub struct LegacyLabelPair {
191    #[prost(bytes="vec", tag="1")]
192    pub name: ::prost::alloc::vec::Vec<u8>,
193    #[prost(bytes="vec", tag="2")]
194    pub value: ::prost::alloc::vec::Vec<u8>,
195}
196#[derive(Clone, PartialEq, ::prost::Message)]
197pub struct Chunk {
198    #[prost(bytes="vec", tag="1")]
199    pub data: ::prost::alloc::vec::Vec<u8>,
200}
201#[derive(Clone, PartialEq, ::prost::Message)]
202pub struct TransferChunksResponse {
203}
204#[derive(Clone, PartialEq, ::prost::Message)]
205pub struct TailersCountRequest {
206}
207#[derive(Clone, PartialEq, ::prost::Message)]
208pub struct TailersCountResponse {
209    #[prost(uint32, tag="1")]
210    pub count: u32,
211}
212#[derive(Clone, PartialEq, ::prost::Message)]
213pub struct GetChunkIDsRequest {
214    #[prost(string, tag="1")]
215    pub matchers: ::prost::alloc::string::String,
216    #[prost(message, optional, tag="2")]
217    pub start: ::core::option::Option<::prost_types::Timestamp>,
218    #[prost(message, optional, tag="3")]
219    pub end: ::core::option::Option<::prost_types::Timestamp>,
220}
221#[derive(Clone, PartialEq, ::prost::Message)]
222pub struct GetChunkIDsResponse {
223    #[prost(string, repeated, tag="1")]
224    pub chunk_i_ds: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
225}
226#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
227#[repr(i32)]
228pub enum Direction {
229    Forward = 0,
230    Backward = 1,
231}
loki_api/logproto.rs

loki_api/
logproto.rs
