Struct LocalAsyncConnectionServiceClient 

pub struct LocalAsyncConnectionServiceClient<C> { /* private fields */ }

Trait Implementations

impl<C> AsyncService<C> for LocalAsyncConnectionServiceClient<C>

fn new(client: C, runtime: &Arc<ConjureRuntime>) -> Self

Creates a new service wrapping an async HTTP client.

impl<C: Clone> Clone for LocalAsyncConnectionServiceClient<C>

fn clone(&self) -> LocalAsyncConnectionServiceClient<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for LocalAsyncConnectionServiceClient<C>

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

Formats the value using the given formatter.

impl<I: Stream<Item = Result<Bytes, Error>>, __C> LocalAsyncConnectionService<I> for LocalAsyncConnectionServiceClient<__C>

where __C: LocalAsyncClient<ResponseBody = I>,

async fn create_connection( &self, auth_: &BearerToken, create_connection: &CreateConnection, ) -> Result<Connection, Error>

Creates a new connection.

async fn update_connection( &self, auth_: &BearerToken, rid: &ConnectionRid, request: &UpdateConnectionRequest, ) -> Result<Connection, Error>

Updates an existing connection.

async fn update_connection_status( &self, auth_: &BearerToken, rid: &ConnectionRid, request: &ConnectionStatus, ) -> Result<(), Error>

Updates an existing connection status.

async fn add_available_tags( &self, auth_: &BearerToken, rid: &ConnectionRid, tags: &BTreeMap<TagName, BTreeSet<TagValue>>, ) -> Result<Connection, Error>

Adds available tag key/value pairs to the connection. If a tag name already exists, the values will be merged. This is primarily an internal endpoint to update tags for external connections as they are periodically scraped. This endpoint should only be called by clients for Visual crossing connections. Throws if called for Nominal connections which have their tags automatically indexed in the underlying Database.

async fn get_connection( &self, auth_: &BearerToken, rid: &ConnectionRid, ) -> Result<Connection, Error>

Gets a connection by its RID.

async fn get_connections( &self, auth_: &BearerToken, rids: &BTreeSet<ConnectionRid>, ) -> Result<BTreeSet<Connection>, Error>

Gets a set of connections by their RIDs.

async fn list_connections( &self, auth_: &BearerToken, include_archived: Option<bool>, workspaces: &BTreeSet<WorkspaceRid>, ) -> Result<BTreeSet<Connection>, Error>

Lists all connections.

async fn list_connections_v2( &self, auth_: &BearerToken, include_archived: Option<bool>, workspaces: &BTreeSet<WorkspaceRid>, page_size: Option<i32>, next_page_token: Option<&Token>, ) -> Result<ListConnectionsResponse, Error>

Lists connections with pagination. Returns connections ordered by creation time descending.

async fn list_connections_by_nominal_data_source( &self, auth_: &BearerToken, nominal_data_source_rids: &BTreeSet<NominalDataSourceRid>, workspaces: &BTreeSet<WorkspaceRid>, page_size: Option<i32>, next_page_token: Option<&Token>, ) -> Result<ListConnectionsResponse, Error>

Lists connections that reference the specified Nominal data sources, with pagination. Only returns connections within the caller’s organization.

async fn archive_connection( &self, auth_: &BearerToken, rid: &ConnectionRid, ) -> Result<(), Error>

Archives a connection, which simply tags the connection for a client to filter.

async fn unarchive_connection( &self, auth_: &BearerToken, rid: &ConnectionRid, ) -> Result<(), Error>

Undoes the archiving of a connection.