Struct OpenStack 

pub struct OpenStack { /* private fields */ }

Synchronous client for the OpenStack API for a single user.

Separate Identity (not the scope) should use separate instances of this.

use openstack_sdk::api::{paged, Pagination, Query};
use openstack_sdk::{OpenStack, config::ConfigFile, OpenStackError};
use openstack_sdk::types::ServiceType;
use openstack_sdk::api::compute::v2::flavor::list;

fn list_flavors() -> Result<(), OpenStackError> {
    // Get the builder for the listing Flavors Endpoint
    let mut ep_builder = list::Request::builder();
    // Set the `min_disk` query param
    ep_builder.min_disk("15");
    let ep = ep_builder.build().unwrap();

    let cfg = ConfigFile::new().unwrap();
    // Get connection config from clouds.yaml/secure.yaml
    let profile = cfg.get_cloud_config("devstack").unwrap().unwrap();
    // Establish connection
    let mut session = OpenStack::new(&profile)?;

    // Invoke service discovery when desired.
    session.discover_service_endpoint(&ServiceType::Compute)?;

    // Execute the call with pagination limiting maximum amount of entries to 1000
    let data: Vec<serde_json::Value> = paged(ep, Pagination::Limit(1000))
        .query(&session)
        .unwrap();

    println!("Data = {:?}", data);
    Ok(())
}

Implementations

impl OpenStack

pub fn new(config: &CloudConfig) -> Result<Self, OpenStackError>

Create a new OpenStack API session from CloudConfig

pub fn authorize( &mut self, scope: Option<AuthTokenScope>, interactive: bool, renew_auth: bool, ) -> Result<(), OpenStackError>

Authorize against the cloud using provided credentials and get the session token

pub fn authorize_with_auth_helper<A>( &mut self, scope: Option<AuthTokenScope>, auth_helper: &mut A, renew_auth: bool, ) -> Result<(), OpenStackError>

where A: AuthHelper,

Authorize against the cloud using provided credentials and get the session token

pub fn discover_service_endpoint( &mut self, service_type: &ServiceType, ) -> Result<(), OpenStackError>

pub fn get_auth_token(&self) -> Option<String>

Return current authentication token

pub fn get_auth_state(&self, offset: Option<TimeDelta>) -> Option<AuthState>

Return current authentication status

Offset can be used to calculate imminent expiration.

Trait Implementations

impl Client for OpenStack

fn rest( &self, request: Builder, body: Vec<u8>, ) -> Result<HttpResponse<Bytes>, ApiError<Self::Error>>

Perform the query with the client specifics

impl Clone for OpenStack

fn clone(&self) -> OpenStack

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OpenStack

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

Formats the value using the given formatter.

impl RestClient for OpenStack

fn get_service_endpoint( &self, service_type: &ServiceType, version: Option<&ApiVersion>, ) -> Result<&ServiceEndpoint, ApiError<Self::Error>>

Get service endpoint from the catalog

type Error = RestError

The errors which may occur for this client.

fn get_current_project(&self) -> Option<Project>

Get current token project information