Struct nomad_client_rs::NomadClient

pub struct NomadClient { /* private fields */ }

Implementations

impl NomadClient

pub async fn allocation_restart(
&self,
alloc_id: &str,
req: &AllocationRestartRequest
) -> Result<(), ClientError>

impl NomadClient

pub async fn client_list_files(
&self,
alloc_id: &str,
path: Option<String>
) -> Result<Vec<AllocFileInfo>, ClientError>

pub async fn client_get_file(
&self,
alloc_id: &str,
file_path: &str
) -> Result<String, ClientError>

pub async fn client_get_file_info(
&self,
alloc_id: &str,
file_path: &str
) -> Result<AllocFileInfo, ClientError>

impl NomadClient

pub async fn deployment_list(
&self,
params: Option<DeploymentListParams>
) -> Result<Vec<Deployment>, ClientError>

pub async fn deployment_get(&self, id: &str) -> Result<Deployment, ClientError>

pub async fn deployment_allocation_list(
&self,
id: &str
) -> Result<Vec<Allocation>, ClientError>

pub async fn deployment_fail(
&self,
id: &str
) -> Result<DeploymentFailResponse, ClientError>

impl NomadClient

pub fn events_subscribe(
&self
) -> (JoinHandle<Result<(), ClientError>>, UnboundedReceiver<Event>)

impl NomadClient

pub async fn job_dispatch(
&self,
job_name: &str,
req: &JobDispatchRequest
) -> Result<JobDispatchResponse, ClientError>

pub async fn job_parse(&self, req: &JobParseRequest) -> Result<Job, ClientError>

pub async fn job_create(
&self,
req: &JobCreateRequest
) -> Result<JobCreateResponse, ClientError>

pub async fn job_list_allocations(
&self,
job_name: &str,
params: &JobListAllocationsParams
) -> Result<Vec<Allocation>, ClientError>

impl NomadClient

pub async fn namespace_list(
&self,
params: Option<NamespaceListParams>
) -> Result<Vec<Namespace>, ClientError>

pub async fn namespace_get(
&self,
namespace: &str
) -> Result<Namespace, ClientError>

pub async fn namespace_create(
&self,
namespace: &NamespaceRequest
) -> Result<(), ClientError>

pub async fn namespace_delete(&self, namespace: &str) -> Result<(), ClientError>

impl NomadClient

pub async fn status_get_leader(&self) -> Result<String, ClientError>

pub async fn status_get_peers(&self) -> Result<Vec<String>, ClientError>

impl NomadClient

pub async fn variables_list(
&self,
params: &VariableListParams
) -> Result<Vec<Variable>, ClientError>

pub async fn variable_get(
&self,
var_path: &str,
params: &VariableGetParams
) -> Result<Variable, ClientError>

pub async fn variable_create(
&self,
var_path: &str,
req: &VariableCreateRequest
) -> Result<Variable, ClientError>

pub async fn variable_delete(
&self,
var_path: &str,
params: &VariableDeleteParams
) -> Result<VariableDeleteResponse, ClientError>

impl NomadClient

pub fn new(config: Config) -> Self

pub fn config(&self) -> &Config

pub fn get_base_url(&self) -> String

pub fn get_endpoint(&self, endpoint: &str) -> String

pub fn request(&self, method: Method, endpoint: &str) -> RequestBuilder

Trait Implementations

impl Clone for NomadClient

fn clone(&self) -> NomadClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for NomadClient

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

Formats the value using the given formatter.

impl Default for NomadClient

fn default() -> Self

Returns the “default value” for a type.