Struct GCRuntimeSubscriber 

pub struct GCRuntimeSubscriber {
    runtime_addr: String,
    tcp_writer: GCConnectionDataWriter,
    last_msg_log: AtomicU64,
    num_messages_lost: AtomicU64,
}

Fields

runtime_addr: String

tcp_writer: GCConnectionDataWriter

last_msg_log: AtomicU64

num_messages_lost: AtomicU64

Implementations

impl GCRuntimeSubscriber

pub fn new(runtime_addr: SocketAddrV4, writer: GCConnectionDataWriter) -> Self

fn log_message_lost(&self, e: GCNetError)

Log messages every TIME_PER_LOG_MS if messages are being lost

Trait Implementations

impl Drop for GCRuntimeSubscriber

fn drop(&mut self)

Executes the destructor for this type.

impl GCDatapointSubscriber for GCRuntimeSubscriber

fn update_datapoint_value( &self, data_value: GCArc<GCDatapointValue>, ) -> Result<(), GCMessageBrokerError>

Sends a datapoint value to the Plugin, this calls issues a call to gc_plugin_receive_datapoint exported by the plugin

fn unique_identifier(&self) -> &GCSubscriberIdentifier

Returns the unique identifier of the subscriber