pub struct RemoteScan { /* private fields */ }Expand description
Remote scan builder
Implementations§
Source§impl RemoteScan
impl RemoteScan
Sourcepub fn start_after(self, pk: &[u8], sk: Option<&[u8]>) -> Self
pub fn start_after(self, pk: &[u8], sk: Option<&[u8]>) -> Self
Set the exclusive start key for pagination
Sourcepub fn index(self, index_name: impl Into<String>) -> Self
pub fn index(self, index_name: impl Into<String>) -> Self
Scan a secondary index instead of the base table
Sourcepub fn segment(self, segment: usize, total_segments: usize) -> Self
pub fn segment(self, segment: usize, total_segments: usize) -> Self
Configure parallel scan (segment must be < total_segments)
Sourcepub async fn execute(
self,
client: &mut KeystoneDbClient<Channel>,
) -> Result<RemoteScanResponse>
pub async fn execute( self, client: &mut KeystoneDbClient<Channel>, ) -> Result<RemoteScanResponse>
Execute the scan and get a stream of responses
Note: The server currently returns a single response, but this interface is prepared for future streaming support.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for RemoteScan
impl RefUnwindSafe for RemoteScan
impl Send for RemoteScan
impl Sync for RemoteScan
impl Unpin for RemoteScan
impl UnsafeUnpin for RemoteScan
impl UnwindSafe for RemoteScan
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
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§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>
Wrap the input message
T in a tonic::Request