Skip to main content

ReadRequest

Struct ReadRequest 

Source
#[non_exhaustive]
pub struct ReadRequest {
Show 15 fields pub session: String, pub transaction: Option<TransactionSelector>, pub table: String, pub index: String, pub columns: Vec<String>, pub key_set: Option<KeySet>, pub limit: i64, pub resume_token: Bytes, pub partition_token: Bytes, pub request_options: Option<RequestOptions>, pub directed_read_options: Option<DirectedReadOptions>, pub data_boost_enabled: bool, pub order_by: OrderBy, pub lock_hint: LockHint, pub routing_hint: Option<RoutingHint>, /* private fields */
}
Expand description

The request for Read and [StreamingRead][google.spanner.v1.Spanner.StreamingRead].

Fields (Non-exhaustive)§

This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.
§session: String

Required. The session in which the read should be performed.

§transaction: Option<TransactionSelector>

The transaction to use. If none is provided, the default is a temporary read-only transaction with strong concurrency.

§table: String

Required. The name of the table in the database to be read.

§index: String

If non-empty, the name of an index on table. This index is used instead of the table primary key when interpreting key_set and sorting result rows. See key_set for further information.

§columns: Vec<String>

Required. The columns of table to be returned for each row matching this request.

§key_set: Option<KeySet>

Required. key_set identifies the rows to be yielded. key_set names the primary keys of the rows in table to be yielded, unless index is present. If index is present, then key_set instead names index keys in index.

If the partition_token field is empty, rows are yielded in table primary key order (if index is empty) or index key order (if index is non-empty). If the partition_token field isn’t empty, rows are yielded in an unspecified order.

It isn’t an error for the key_set to name rows that don’t exist in the database. Read yields nothing for nonexistent rows.

§limit: i64

If greater than zero, only the first limit rows are yielded. If limit is zero, the default is no limit. A limit can’t be specified if partition_token is set.

§resume_token: Bytes

If this request is resuming a previously interrupted read, resume_token should be copied from the last PartialResultSet yielded before the interruption. Doing this enables the new read to resume where the last read left off. The rest of the request parameters must exactly match the request that yielded this token.

§partition_token: Bytes

If present, results are restricted to the specified partition previously created using PartitionRead. There must be an exact match for the values of fields common to this message and the PartitionReadRequest message used to create this partition_token.

§request_options: Option<RequestOptions>

Common options for this request.

§directed_read_options: Option<DirectedReadOptions>

Directed read options for this request.

§data_boost_enabled: bool

If this is for a partitioned read and this field is set to true, the request is executed with Spanner Data Boost independent compute resources.

If the field is set to true but the request doesn’t set partition_token, the API returns an INVALID_ARGUMENT error.

§order_by: OrderBy

Optional. Order for the returned rows.

By default, Spanner returns result rows in primary key order except for PartitionRead requests. For applications that don’t require rows to be returned in primary key (ORDER_BY_PRIMARY_KEY) order, setting ORDER_BY_NO_ORDER option allows Spanner to optimize row retrieval, resulting in lower latencies in certain cases (for example, bulk point lookups).

§lock_hint: LockHint

Optional. Lock Hint for the request, it can only be used with read-write transactions.

§routing_hint: Option<RoutingHint>

Optional. Makes the Spanner requests location-aware if present.

It gives the server hints that can be used to route the request to an appropriate server, potentially significantly decreasing latency and improving throughput. To achieve improved performance, most fields must be filled in with accurate values.

Implementations§

Source§

impl ReadRequest

Source

pub fn new() -> Self

Creates a new default instance.

Source

pub fn set_session<T: Into<String>>(self, v: T) -> Self

Sets the value of session.

Source

pub fn set_transaction<T>(self, v: T) -> Self

Sets the value of transaction.

Source

pub fn set_or_clear_transaction<T>(self, v: Option<T>) -> Self

Sets or clears the value of transaction.

Source

pub fn set_table<T: Into<String>>(self, v: T) -> Self

Sets the value of table.

Source

pub fn set_index<T: Into<String>>(self, v: T) -> Self

Sets the value of index.

Source

pub fn set_columns<T, V>(self, v: T) -> Self
where T: IntoIterator<Item = V>, V: Into<String>,

Sets the value of columns.

Source

pub fn set_key_set<T>(self, v: T) -> Self
where T: Into<KeySet>,

Sets the value of key_set.

Source

pub fn set_or_clear_key_set<T>(self, v: Option<T>) -> Self
where T: Into<KeySet>,

Sets or clears the value of key_set.

Source

pub fn set_limit<T: Into<i64>>(self, v: T) -> Self

Sets the value of limit.

Source

pub fn set_resume_token<T: Into<Bytes>>(self, v: T) -> Self

Sets the value of resume_token.

Source

pub fn set_partition_token<T: Into<Bytes>>(self, v: T) -> Self

Sets the value of partition_token.

Source

pub fn set_request_options<T>(self, v: T) -> Self
where T: Into<RequestOptions>,

Sets the value of request_options.

Source

pub fn set_or_clear_request_options<T>(self, v: Option<T>) -> Self
where T: Into<RequestOptions>,

Sets or clears the value of request_options.

Source

pub fn set_directed_read_options<T>(self, v: T) -> Self

Sets the value of directed_read_options.

Source

pub fn set_or_clear_directed_read_options<T>(self, v: Option<T>) -> Self

Sets or clears the value of directed_read_options.

Source

pub fn set_data_boost_enabled<T: Into<bool>>(self, v: T) -> Self

Sets the value of data_boost_enabled.

Source

pub fn set_order_by<T: Into<OrderBy>>(self, v: T) -> Self

Sets the value of order_by.

Source

pub fn set_lock_hint<T: Into<LockHint>>(self, v: T) -> Self

Sets the value of lock_hint.

Source

pub fn set_routing_hint<T>(self, v: T) -> Self
where T: Into<RoutingHint>,

Sets the value of routing_hint.

Source

pub fn set_or_clear_routing_hint<T>(self, v: Option<T>) -> Self
where T: Into<RoutingHint>,

Sets or clears the value of routing_hint.

Trait Implementations§

Source§

impl Clone for ReadRequest

Source§

fn clone(&self) -> ReadRequest

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for ReadRequest

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl Default for ReadRequest

Source§

fn default() -> ReadRequest

Returns the “default value” for a type. Read more
Source§

impl Message for ReadRequest

Source§

fn typename() -> &'static str

The typename of this message.
Source§

impl PartialEq for ReadRequest

Source§

fn eq(&self, other: &ReadRequest) -> bool

Tests for self and other values to be equal, and is used by ==.
1.0.0 (const: unstable) · Source§

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
Source§

impl StructuralPartialEq for ReadRequest

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FutureExt for T

Source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
Source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<L> LayerExt<L> for L

Source§

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in Layered.
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more