Struct SpineConnectionImpl 

pub struct SpineConnectionImpl {
    config: Arc<RwLock<ProtocolConfig>>,
    state: Arc<RwLock<ConnectionState>>,
    heartbeat_config: HeartbeatConfig,
    last_heartbeat: Arc<RwLock<DateTime<Utc>>>,
    metrics: Arc<RwLock<ConnectionMetrics>>,
}

Spine connection implementation

Fields

config: Arc<RwLock<ProtocolConfig>>

Protocol configuration

state: Arc<RwLock<ConnectionState>>

Current connection state

heartbeat_config: HeartbeatConfig

Heartbeat configuration

last_heartbeat: Arc<RwLock<DateTime<Utc>>>

Timestamp of the last heartbeat

metrics: Arc<RwLock<ConnectionMetrics>>

Connection metrics

Implementations

impl SpineConnectionImpl

pub fn new(config: ProtocolConfig) -> Self

Create a new Spine connection

Arguments

• config - Protocol configuration

Returns

A new SpineConnectionImpl instance

pub async fn Connect(&mut self) -> Result<()>

Connect to the Spine service

pub async fn Disconnect(&mut self) -> Result<()>

Disconnect from the Spine service

pub async fn GetState(&self) -> ConnectionState

Get the current connection state

pub async fn SendRequest( &self, method: &str, payload: Vec<u8>, ) -> Result<Vec<u8>>

Send a request to the Spine service

Arguments

• method - The method name to call
• payload - The request payload

pub async fn GetMetrics(&self) -> ConnectionMetrics

Get the connection metrics

pub fn SetHeartbeatConfig(&mut self, config: HeartbeatConfig)

Set the heartbeat configuration