Struct google_api_proto::google::genomics::v1::StreamReadsRequest
source · pub struct StreamReadsRequest {
pub project_id: String,
pub read_group_set_id: String,
pub reference_name: String,
pub start: i64,
pub end: i64,
pub shard: i32,
pub total_shards: i32,
}
Expand description
The stream reads request.
Fields§
§project_id: String
The Google Cloud project ID which will be billed for this access. The caller must have WRITE access to this project. Required.
read_group_set_id: String
The ID of the read group set from which to stream reads.
reference_name: String
The reference sequence name, for example chr1
,
1
, or chrX
. If set to *, only unmapped reads are
returned.
start: i64
The start position of the range on the reference, 0-based inclusive. If
specified, referenceName
must also be specified.
end: i64
The end position of the range on the reference, 0-based exclusive. If
specified, referenceName
must also be specified.
shard: i32
Restricts results to a shard containing approximately 1/totalShards
of the normal response payload for this query. Results from a sharded
request are disjoint from those returned by all queries which differ only
in their shard parameter. A shard may yield 0 results; this is especially
likely for large values of totalShards
.
Valid values are [0, totalShards)
.
total_shards: i32
Specifying totalShards
causes a disjoint subset of the normal response
payload to be returned for each query with a unique shard
parameter
specified. A best effort is made to yield equally sized shards. Sharding
can be used to distribute processing amongst workers, where each worker is
assigned a unique shard
number and all workers specify the same
totalShards
number. The union of reads returned for all sharded queries
[0, totalShards)
is equal to those returned by a single unsharded query.
Queries for different values of totalShards
with common divisors will
share shard boundaries. For example, streaming shard
2 of 5
totalShards
yields the same results as streaming shard
s 4 and 5 of 10
totalShards
. This property can be leveraged for adaptive retries.
Trait Implementations§
source§impl Clone for StreamReadsRequest
impl Clone for StreamReadsRequest
source§fn clone(&self) -> StreamReadsRequest
fn clone(&self) -> StreamReadsRequest
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for StreamReadsRequest
impl Debug for StreamReadsRequest
source§impl Default for StreamReadsRequest
impl Default for StreamReadsRequest
source§impl Message for StreamReadsRequest
impl Message for StreamReadsRequest
source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
source§fn encode_to_vec(&self) -> Vec<u8>where
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8>where
Self: Sized,
source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
source§fn encode_length_delimited_to_vec(&self) -> Vec<u8>where
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8>where
Self: Sized,
source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self
. Read moresource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self
.source§impl PartialEq for StreamReadsRequest
impl PartialEq for StreamReadsRequest
source§fn eq(&self, other: &StreamReadsRequest) -> bool
fn eq(&self, other: &StreamReadsRequest) -> bool
self
and other
values to be equal, and is used
by ==
.impl StructuralPartialEq for StreamReadsRequest
Auto Trait Implementations§
impl Freeze for StreamReadsRequest
impl RefUnwindSafe for StreamReadsRequest
impl Send for StreamReadsRequest
impl Sync for StreamReadsRequest
impl Unpin for StreamReadsRequest
impl UnwindSafe for StreamReadsRequest
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request