Struct PulseClient 

pub struct PulseClient { /* private fields */ }

Async HTTP client for the Pulse REST API.

Example

use pulse_client::PulseClient;

let client = PulseClient::builder()
    .base_url("http://localhost:9090")
    .build()?;

client.auth().login("alice", "secret").await?;

for pipeline in client.pipelines().list().await? {
    println!("{}", pipeline["name"]);
}

Thread safety

PulseClient is Clone and cheap to clone — the underlying reqwest client pools connections, and the token sits behind an Arc<RwLock>. Share a single instance across tasks.

Implementations

impl PulseClient

pub fn builder() -> PulseClientBuilder

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

Returns the current bearer token, or None if none is set.

pub fn set_token<S: Into<String>>(&self, token: S)

Updates the bearer token used by subsequent authenticated requests. Safe to call from multiple tasks concurrently.

pub fn clear_token(&self)

Clears the bearer token, effectively logging out the client.

pub fn auth(&self) -> AuthResource<'_>

pub fn pipelines(&self) -> PipelinesResource<'_>

pub fn agents(&self) -> AgentsResource<'_>

pub fn templates(&self) -> TemplatesResource<'_>

pub fn users(&self) -> UsersResource<'_>

pub fn events(&self) -> EventsResource<'_>

pub fn iq(&self) -> IQResource<'_>

pub fn streams(&self) -> StreamsResource<'_>

client.streams() — B-107 Kafka-Streams-like declarative DSL.

pub async fn version(&self) -> Result<Value, PulseError>

GET /api/pulse/version — public, no JWT required. Returns the Pulse server’s build + version metadata.

Trait Implementations

impl Clone for PulseClient

fn clone(&self) -> PulseClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PulseClient

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

Formats the value using the given formatter.