Struct SubscriptionClient

pub struct SubscriptionClient { /* private fields */ }

A single SubscriptionClient enables subscription multiplexing.

Implementations

impl SubscriptionClient

pub fn start<T>( &self, request_body: &QueryBody<T::Variables>, ) -> BoxedSubscription<T>

where T: GraphQLQuery + Send + Sync, <T as GraphQLQuery>::ResponseData: Unpin + Send + Sync + 'static,

Start a new subscription request.

Trait Implementations

impl ComponentsSubscriptionExt for SubscriptionClient

fn component_added(&self) -> BoxedSubscription<ComponentAddedSubscription>

Subscription for when a component has been added

fn component_removed(&self) -> BoxedSubscription<ComponentRemovedSubscription>

Subscription for when a component has been removed

impl Debug for SubscriptionClient

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

Formats the value using the given formatter.

impl HealthSubscriptionExt for SubscriptionClient

fn heartbeat_subscription( &self, interval: i64, ) -> BoxedSubscription<HeartbeatSubscription>

Executes a heartbeat subscription, on a millisecond interval.

impl MetricsSubscriptionExt for SubscriptionClient

fn uptime_subscription(&self) -> BoxedSubscription<UptimeSubscription>

Executes an uptime metrics subscription.

fn component_allocated_bytes_subscription( &self, interval: i64, ) -> BoxedSubscription<ComponentAllocatedBytesSubscription>

Executes an all component allocated bytes subscription.

fn component_received_bytes_totals_subscription( &self, interval: i64, ) -> BoxedSubscription<ComponentReceivedBytesTotalsSubscription>

Executes an all component bytes received totals subscription.

fn component_received_bytes_throughputs_subscription( &self, interval: i64, ) -> BoxedSubscription<ComponentReceivedBytesThroughputsSubscription>

Executes a component bytes received throughput subscription.

fn component_received_events_totals_subscription( &self, interval: i64, ) -> BoxedSubscription<ComponentReceivedEventsTotalsSubscription>

Executes an all component received events totals subscription.

fn component_received_events_throughputs_subscription( &self, interval: i64, ) -> BoxedSubscription<ComponentReceivedEventsThroughputsSubscription>

Executes an all component received events throughputs subscription.

fn component_sent_bytes_totals_subscription( &self, interval: i64, ) -> BoxedSubscription<ComponentSentBytesTotalsSubscription>

Executes an all component bytes sent totals subscription.

fn component_sent_bytes_throughputs_subscription( &self, interval: i64, ) -> BoxedSubscription<ComponentSentBytesThroughputsSubscription>

Executes a component bytes sent throughput subscription.

fn component_sent_events_totals_subscription( &self, interval: i64, ) -> BoxedSubscription<ComponentSentEventsTotalsSubscription>

Executes a component sent events totals subscription.

fn component_sent_events_throughputs_subscription( &self, interval: i64, ) -> BoxedSubscription<ComponentSentEventsThroughputsSubscription>

Executes a component sent events throughputs subscription.

fn component_errors_totals_subscription( &self, interval: i64, ) -> BoxedSubscription<ComponentErrorsTotalsSubscription>

impl TapSubscriptionExt for SubscriptionClient

fn output_events_by_component_id_patterns_subscription( &self, outputs_patterns: Vec<String>, inputs_patterns: Vec<String>, encoding: TapEncodingFormat, limit: i64, interval: i64, ) -> BoxedSubscription<OutputEventsByComponentIdPatternsSubscription>

Executes an output events subscription.

impl TestSubscriptionExt for SubscriptionClient

fn errors_total_subscription( &self, interval: i64, ) -> BoxedSubscription<ErrorsTotalSubscription>