Struct MonoHub 

pub struct MonoHub { /* private fields */ }

Monochrome music API activation — stateless API proxy.

Implementations

impl MonoHub

pub async fn new() -> Self

Create a hub targeting the default Monochrome API instance.

pub async fn with_url(base_url: impl Into<String>) -> Self

Create a hub targeting a specific API base URL (no trailing slash).

pub fn client(&self) -> Arc<MonoClient>

Get a shared reference to the underlying MonoClient.

impl MonoHub

pub async fn track( &self, id: u64, ) -> impl Stream<Item = MonoEvent> + Send + 'static

Get track metadata by Tidal track ID

pub async fn album( &self, id: u64, ) -> impl Stream<Item = MonoEvent> + Send + 'static

Get album metadata and its full track listing by Tidal album ID

pub async fn artist( &self, id: u64, ) -> impl Stream<Item = MonoEvent> + Send + 'static

Get artist metadata by Tidal artist ID

pub async fn search( &self, query: String, kind: Option<SearchKind>, limit: Option<u32>, offset: Option<u32>, ) -> impl Stream<Item = MonoEvent> + Send + 'static

Search for tracks, albums, or artists

pub async fn lyrics( &self, id: u64, ) -> impl Stream<Item = MonoEvent> + Send + 'static

Get synchronized lyrics for a track by Tidal track ID

pub async fn recommendations( &self, id: u64, ) -> impl Stream<Item = MonoEvent> + Send + 'static

Get recommended tracks similar to a given track

pub async fn stream_url( &self, id: u64, quality: Option<String>, ) -> impl Stream<Item = MonoEvent> + Send + 'static

Resolve the direct CDN stream URL for a track

pub async fn download( &self, id: u64, path: String, quality: Option<String>, ) -> impl Stream<Item = MonoEvent> + Send + 'static

Download a track to a local file

pub async fn cover( &self, id: u64, size: Option<u32>, ) -> impl Stream<Item = MonoEvent> + Send + 'static

Get cover art URL(s) for a track or album

impl MonoHub

pub const NAMESPACE: &'static str = "monochrome"

pub const PLUGIN_ID: Uuid

Stable plugin instance ID for handle routing

pub fn plugin_id(&self) -> Uuid

Get the plugin’s stable instance ID

Trait Implementations

impl Activation for MonoHub

type Methods = MonoHubMethod

fn namespace(&self) -> &str

fn version(&self) -> &str

fn description(&self) -> &str

Short description (max 15 words)

fn long_description(&self) -> Option<&str>

Long description (optional, for detailed documentation)

fn methods(&self) -> Vec<&str>

fn method_help(&self, method: &str) -> Option<String>

fn call<'life0, 'life1, 'async_trait>( &'life0 self, method: &'life1 str, params: Value, ) -> Pin<Box<dyn Future<Output = Result<PlexusStream, PlexusError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn into_rpc_methods(self) -> Methods

fn plugin_schema(&self) -> PluginSchema

Return this activation’s schema (methods + optional children)

fn plugin_id(&self) -> Uuid

Stable activation instance ID for handle routing By default generates a deterministic UUID from namespace+major_version Using major version only ensures handles survive minor/patch upgrades (semver)

fn resolve_handle<'life0, 'life1, 'async_trait>( &'life0 self, _handle: &'life1 Handle, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = PlexusStreamItem> + Send>>, PlexusError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

impl Clone for MonoHub

fn clone(&self) -> MonoHub

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl MonoHubRpcServer for MonoHub

fn track<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, id: u64, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get track metadata by Tidal track ID

fn album<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, id: u64, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get album metadata and its full track listing by Tidal album ID

fn artist<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, id: u64, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get artist metadata by Tidal artist ID

fn search<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, query: String, kind: Option<SearchKind>, limit: Option<u32>, offset: Option<u32>, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Search for tracks, albums, or artists

fn lyrics<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, id: u64, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get synchronized lyrics for a track by Tidal track ID

fn recommendations<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, id: u64, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get recommended tracks similar to a given track

fn stream_url<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, id: u64, quality: Option<String>, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Resolve the direct CDN stream URL for a track

fn download<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, id: u64, path: String, quality: Option<String>, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Download a track to a local file

fn cover<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, id: u64, size: Option<u32>, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get cover art URL(s) for a track or album

fn into_rpc(self) -> RpcModule<Self>

Collects all the methods and subscriptions defined in the trait and adds them into a single RpcModule.