Struct ConsumerRegistry 

pub struct ConsumerRegistry { /* private fields */ }

Registry for tracking consumers

Implementations

impl ConsumerRegistry

pub fn new() -> Self

Create a new consumer registry

pub async fn register(&self, consumer: Consumer)

Register a consumer

pub async fn get_by_id(&self, id: &str) -> Option<Consumer>

Get consumer by ID

pub async fn get_by_identifier( &self, identifier: &ConsumerIdentifier, ) -> Option<Consumer>

Get consumer by identifier

pub async fn list_all(&self) -> Vec<Consumer>

List all consumers

pub async fn remove(&self, id: &str) -> Option<Consumer>

Remove a consumer

pub async fn get_or_create( &self, identifier: ConsumerIdentifier, name: String, workspace_id: Option<String>, ) -> Consumer

Create or get consumer by identifier

Trait Implementations

impl Clone for ConsumerRegistry

fn clone(&self) -> ConsumerRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerRegistry

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

Formats the value using the given formatter.

impl Default for ConsumerRegistry

fn default() -> Self

Returns the “default value” for a type.