Struct DataSourceServiceAsyncClient

pub struct DataSourceServiceAsyncClient<T>(/* private fields */);

Data sources are data input to runs, including databases, CSV, video, and streaming data. They contain channels that represent the series data. The DataSource Service is responsible for indexing and searching channels across data sources.

Implementations

impl<T> DataSourceServiceAsyncClient<T>

where T: AsyncClient,

pub async fn search_channels( &self, auth_: &BearerToken, query: &SearchChannelsRequest, ) -> Result<SearchChannelsResponse, Error>

Returns channels that match the search criteria. Results are sorted by similarity score.

pub async fn search_filtered_channels( &self, auth_: &BearerToken, query: &SearchFilteredChannelsRequest, ) -> Result<SearchFilteredChannelsResponse, Error>

Returns channels that match the search criteria. Results are sorted by similarity score.

pub async fn search_hierarchical_channels( &self, auth_: &BearerToken, query: &SearchHierarchicalChannelsRequest, ) -> Result<SearchHierarchicalChannelsResponse, Error>

Returns only channels that are direct children of the parent. Returns results sorted alphabetically.

pub async fn index_channel_prefix_tree( &self, auth_: &BearerToken, request: &IndexChannelPrefixTreeRequest, ) -> Result<ChannelPrefixTree, Error>

Indexes the channel prefix tree for a specified data source. This operation constructs a prefix tree from the channels available in the data source.

pub async fn batch_get_channel_prefix_trees( &self, auth_: &BearerToken, request: &BatchGetChannelPrefixTreeRequest, ) -> Result<BatchGetChannelPrefixTreeResponse, Error>

Returns the channel prefix tree for each of the specified data sources. If the tree for a data source has not been indexed, it will be omitted from the map.

pub async fn get_available_tags_for_channel( &self, auth_: &BearerToken, request: &GetAvailableTagsForChannelRequest, ) -> Result<GetAvailableTagsForChannelResponse, Error>

Returns the the set of all tag keys and their values that are available for the specified channel given an initial set of filters.

pub async fn get_data_scope_bounds( &self, auth_: &BearerToken, request: &BatchGetDataScopeBoundsRequest, ) -> Result<BatchGetDataScopeBoundsResponse, Error>

Returns the maximum data timestamps for the specified data scopes. Responses are returned in the same order as requests.

Trait Implementations

impl<T> AsyncService<T> for DataSourceServiceAsyncClient<T>

where T: AsyncClient,

fn new(client: T) -> Self

Creates a new service wrapping an async HTTP client.

impl<T: Clone> Clone for DataSourceServiceAsyncClient<T>

fn clone(&self) -> DataSourceServiceAsyncClient<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for DataSourceServiceAsyncClient<T>

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

Formats the value using the given formatter.