Type Alias SequencesResource 

pub type SequencesResource = Resource<Sequence>;

A sequence stores a table with up to 400 columns indexed by row number. There can be at most 400 numeric columns and 200 string columns. Each of the columns has a pre-defined type: a string, integer, or floating point number.

Aliased Type

pub struct SequencesResource {
    pub api_client: Arc<ApiClient>,
    /* private fields */
}

Fields

api_client: Arc<ApiClient>

A reference to the shared API Client.

Implementations

impl SequencesResource

pub async fn insert_rows(&self, rows: &[InsertSequenceRows]) -> Result<()>

Insert a list of rows into a set of sequences.

Arguments

• rows - Sequence row batches to insert.

pub async fn retrieve_rows( &self, query: RetrieveSequenceRows, ) -> Result<RetrieveSequenceRowsResponse>

Retrieve a rows from a set of sequences.

Arguments

• query - Sequence rows retrieval query.

pub async fn retrieve_last_row( &self, query: RetrieveLastSequenceRow, ) -> Result<RetrieveSequenceRowsResponse>

Retrieve the last row from a sequence. The last row is the one with the highest row number, not necessarily the one that was ingested the most recently.

Arguments

• query - Sequence row retrieval query.

pub async fn delete_rows(&self, query: &[DeleteSequenceRows]) -> Result<()>

Delete rows from a set of sequences.

Arguments

• query - Row ranges to delete.

Trait Implementations

impl Create<AddSequence, Sequence> for SequencesResource

fn create( &self, creates: &[TCreate], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

Create a list of resources.

fn create_from( &self, creates: &[impl Into<TCreate> + Sync + Clone], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

Create a list of resources, converting from a different type.

fn create_ignore_duplicates( &self, creates: &[TCreate], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where TCreate: EqIdentity,

Create a list of resources, ignoring any that fail with general “conflict” errors.

fn create_from_ignore_duplicates<'a, T: 'a>( &self, creates: &'a [impl Into<TCreate> + Sync + Clone], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where TCreate: EqIdentity,

Create a list of resources, converting from a different type, and ignoring any that fail with general “conflict” errors.

impl<R> DeleteWithIgnoreUnknownIds<IdentityList<R>> for SequencesResource

where IdentityList<R>: Serialize, R: Send + Sync,

fn delete( &self, deletes: impl Into<TIdt> + Send, ignore_unknown_ids: bool, ) -> impl Future<Output = Result<()>> + Send

where Self: Sync,

Delete a list of resources, optionally ignore unknown ids.

impl FilterWithRequest<SequenceFilterRequest, Sequence> for SequencesResource

fn filter( &self, filter: TFilter, ) -> impl Future<Output = Result<ItemsVec<TResponse, Cursor>>> + Send

Filter resources.

fn filter_all( &self, filter: TFilter, ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where TFilter: SetCursor, TResponse: Send,

Filter resources, following cursors until they are exhausted.

fn filter_all_stream( &self, filter: TFilter, ) -> impl TryStream<Ok = TResponse, Error = Error, Item = Result<TResponse>> + Send

where TFilter: SetCursor, TResponse: Send + 'static,

Filter resources, following cursors. This returns a stream, you can abort the stream whenever you want and only resources retrieved up to that point will be returned.

fn filter_all_partitioned( &self, filter: TFilter, num_partitions: u32, ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where TFilter: SetCursor + WithPartition, TResponse: Send,

Filter resources using partitioned reads, following cursors until all partitions are exhausted.

fn filter_all_partitioned_stream( &self, filter: TFilter, num_partitions: u32, ) -> impl TryStream<Ok = TResponse, Error = Error, Item = Result<TResponse>> + Send

where TFilter: SetCursor + WithPartition, TResponse: Send + 'static,

Filter resources using partitioned reads, following cursors until all partitions are exhausted. This returns a stream.

impl List<LimitCursorPartitionQuery, Sequence> for SequencesResource

fn list( &self, params: Option<TParams>, ) -> impl Future<Output = Result<ItemsVec<TResponse, Cursor>>> + Send

Query a resource with optional query parameters.

impl<R> RetrieveWithIgnoreUnknownIds<IdentityList<R>, Sequence> for SequencesResource

where IdentityList<R>: Serialize, R: Send + Sync,

fn retrieve( &self, ids: impl Into<TIdt> + Send, ignore_unknown_ids: bool, ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

Retrieve a list of items from CDF. If ignore_unknown_ids is false, this will fail if any items are missing from CDF.

impl SearchItems<'_, SequenceFilter, SequenceSearch, Sequence> for SequencesResource

fn search( &'a self, filter: TFilter, search: TSearch, limit: Option<u32>, ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

Fuzzy search resources.

impl Update<Patch<PatchSequence>, Sequence> for SequencesResource

fn update( &self, updates: &[TUpdate], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

Update a list of resources.

fn update_from<'a, T>( &self, updates: &'a [T], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where T: Sync + Clone + 'a, TUpdate: From<T>,

Update a list of resources by converting to the update from a different type.

fn update_ignore_unknown_ids( &self, updates: &[TUpdate], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where TUpdate: EqIdentity, TResponse: Send,

Update a list of resources, ignoring any that fail due to items missing in CDF.

fn update_from_ignore_unknown_ids<'a, T>( &self, updates: &'a [T], ) -> impl Future<Output = Result<Vec<TResponse>>> + Send

where T: Sync + Clone + 'a, TUpdate: From<T> + EqIdentity, TResponse: Send,

Update a list of resources by converting from a different type, ignoring any that fail due items missing in CDF.

impl WithBasePath for SequencesResource

const BASE_PATH: &'static str = "sequences"

Base path for this resource type.