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
// @generated
// This file is @generated by prost-build.
/// Request object for ByteStream.Read.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReadRequest {
/// The name of the resource to read.
#[prost(string, tag = "1")]
pub resource_name: ::prost::alloc::string::String,
/// The offset for the first byte to return in the read, relative to the start
/// of the resource.
///
/// A `read_offset` that is negative or greater than the size of the resource
/// will cause an `OUT_OF_RANGE` error.
#[prost(int64, tag = "2")]
pub read_offset: i64,
/// The maximum number of `data` bytes the server is allowed to return in the
/// sum of all `ReadResponse` messages. A `read_limit` of zero indicates that
/// there is no limit, and a negative `read_limit` will cause an error.
///
/// If the stream returns fewer bytes than allowed by the `read_limit` and no
/// error occurred, the stream includes all data from the `read_offset` to the
/// end of the resource.
#[prost(int64, tag = "3")]
pub read_limit: i64,
}
/// Response object for ByteStream.Read.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReadResponse {
/// A portion of the data for the resource. The service **may** leave `data`
/// empty for any given `ReadResponse`. This enables the service to inform the
/// client that the request is still live while it is running an operation to
/// generate more data.
#[prost(bytes = "vec", tag = "10")]
pub data: ::prost::alloc::vec::Vec<u8>,
}
/// Request object for ByteStream.Write.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct WriteRequest {
/// The name of the resource to write. This **must** be set on the first
/// `WriteRequest` of each `Write()` action. If it is set on subsequent calls,
/// it **must** match the value of the first request.
#[prost(string, tag = "1")]
pub resource_name: ::prost::alloc::string::String,
/// The offset from the beginning of the resource at which the data should be
/// written. It is required on all `WriteRequest`s.
///
/// In the first `WriteRequest` of a `Write()` action, it indicates
/// the initial offset for the `Write()` call. The value **must** be equal to
/// the `committed_size` that a call to `QueryWriteStatus()` would return.
///
/// On subsequent calls, this value **must** be set and **must** be equal to
/// the sum of the first `write_offset` and the sizes of all `data` bundles
/// sent previously on this stream.
///
/// An incorrect value will cause an error.
#[prost(int64, tag = "2")]
pub write_offset: i64,
/// If `true`, this indicates that the write is complete. Sending any
/// `WriteRequest`s subsequent to one in which `finish_write` is `true` will
/// cause an error.
#[prost(bool, tag = "3")]
pub finish_write: bool,
/// A portion of the data for the resource. The client **may** leave `data`
/// empty for any given `WriteRequest`. This enables the client to inform the
/// service that the request is still live while it is running an operation to
/// generate more data.
#[prost(bytes = "vec", tag = "10")]
pub data: ::prost::alloc::vec::Vec<u8>,
}
/// Response object for ByteStream.Write.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct WriteResponse {
/// The number of bytes that have been processed for the given resource.
#[prost(int64, tag = "1")]
pub committed_size: i64,
}
/// Request object for ByteStream.QueryWriteStatus.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct QueryWriteStatusRequest {
/// The name of the resource whose write status is being requested.
#[prost(string, tag = "1")]
pub resource_name: ::prost::alloc::string::String,
}
/// Response object for ByteStream.QueryWriteStatus.
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct QueryWriteStatusResponse {
/// The number of bytes that have been processed for the given resource.
#[prost(int64, tag = "1")]
pub committed_size: i64,
/// `complete` is `true` only if the client has sent a `WriteRequest` with
/// `finish_write` set to true, and the server has processed that request.
#[prost(bool, tag = "2")]
pub complete: bool,
}
// @@protoc_insertion_point(module)