Struct StreamsResource 

pub struct StreamsResource<'c> { /* private fields */ }

client.streams() — compile + deploy StreamBuilder pipelines.

Sugar over client.pipelines().create() — the compile happens client-side, the deploy is the same POST.

Implementations

impl<'c> StreamsResource<'c>

pub fn compile(&self, builder: &StreamBuilder) -> Result<Value, PulseError>

Compile the builder to a pipeline dict WITHOUT deploying.

pub fn compile_with_name( &self, builder: &StreamBuilder, name: &str, ) -> Result<Value, PulseError>

Compile with a name override WITHOUT deploying.

pub async fn deploy(&self, builder: &StreamBuilder) -> Result<Value, PulseError>

Compile + POST to /api/pulse/pipelines. Returns the server response.

pub async fn deploy_with_name( &self, builder: &StreamBuilder, name: &str, ) -> Result<Value, PulseError>

Compile with a name override + POST to /api/pulse/pipelines.

Trait Implementations

impl Debug for StreamsResource<'_>

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

Formats the value using the given formatter.