Crate liner_broker 

liner_broker

liner_broker is a simple and fast redis based message serverless broker.
Data transfer via TCP.

Examples

use liner_broker::Liner;
 
fn  main() {
 
    let mut client1 = Liner::new("client1", "topic_client1", "localhost:2255", "redis://localhost/");
    let mut client2 = Liner::new("client2", "topic_client2", "localhost:2256", "redis://localhost/");
    
    client1.run(Box::new(|_to: &str, _from: &str, _data: &[u8]|{
        println!("receive_from {}", _from);
    }));
    client2.run(Box::new(|_to: &str, _from: &str, _data: &[u8]|{
        println!("receive_from {}", _from);
    }));
  
    let array = [0; 100];
    for _ in 0..10{
        client1.send_to("topic_client2", array.as_slice(), true);
        println!("send_to client2");       
    }
}
 

Modules

redis

Macros

print_debug

print_error

Structs

Client

Public client handle. Internally boxed so run may pass a stable self pointer to background listener threads; moving this handle does not move that state.

Liner

ReceiverSeedEntry

One catalog row for Store::seed_receivers (JSON shape matches the C receivers_json array).

StatusEmitter

Shared between Client and background sender threads.

UData

Enums

ErrorCode

Stable i32 values shared with include/liner.h.

StatusMsg

Keys into the status detail message map ([status_msg_templates]).

StoreBackend

Constants

LNR_LISTENER_STORE_ERROR

Listener: background store / DB error on ack / lookup paths.

LNR_PEER_CONNECTED

Peer registered / run (internal client_connected), related topic only.

LNR_PEER_DISCONNECTED

Peer teardown (internal client_disconnected), related topic only.

LNR_PEER_SUBSCRIBED

Peer subscribe (internal subscribed), related topic only.

LNR_PEER_UNSUBSCRIBED

Peer unsubscribe (internal unsubscribed), related topic only.

LNR_SENDER_BUSY

Sender: sync enqueue rejected because peer send queue is full (max_send_queue).

LNR_SENDER_ROUTE_LOST

Sender: TCP connect fail or stream close for a local route.

LNR_SENDER_SEND_ERROR

Sender: background write/flush failure after an accepted send.

LNR_SENDER_STORE_ERROR

Sender: background store / DB error on send-reconnect / persist paths.

Traits

Store

Operations the broker needs from a key–value / queue style store.

Functions

lnr_advertise_addr^⚠

Safety

lnr_bound_listen_addr^⚠

Safety

lnr_clear_addresses_of_topic^⚠

Cleaning client addresses. Call only when the client is not running yet.

lnr_clear_stored_messages^⚠

Clearing messages that were not previously sent for some reason. Call only when the client is not running yet.

lnr_delete_client^⚠

Deleting a client.

lnr_get_compress_threshold^⚠

Safety

lnr_get_max_message_size^⚠

Safety

lnr_get_max_send_queue^⚠

Safety

lnr_is_running^⚠

Safety

lnr_last_error_code^⚠

Last sync-API error code (LNR_OK / LNR_ERR_*). Returns LNR_OK for a null handle.

lnr_last_error_message^⚠

Safety

lnr_list_addresses^⚠

Safety

lnr_new_client^⚠

Deprecated: use lnr_new_client_redis. Same behavior as lnr_new_client_redis.

lnr_new_client_redis^⚠

Create new client (Redis URL).

lnr_new_client_sqlite^⚠

Create new client (SQLite database file path).

lnr_pending_by_peer^⚠

Safety

lnr_pending_count^⚠

Safety

lnr_published_addr^⚠

Safety

lnr_refresh_address_topic^⚠

Refresh address of topic (actual for new clients)

lnr_run^⚠

Launching a client to send messages and listen for incoming messages.

lnr_send_all^⚠

Send message to other clients. Call only when the client is already running.

lnr_send_to^⚠

Send message to other client. Call only when the client is already running.

lnr_set_advertise_addr^⚠

Set advertise address before lnr_run. addr == NULL or empty clears.

lnr_set_compress_threshold^⚠

Safety

lnr_set_log_cb^⚠

Safety

lnr_set_max_message_size^⚠

Safety

lnr_set_max_send_queue^⚠

Safety

lnr_set_status_cb^⚠

Set or clear the status / background-error callback.

lnr_stop^⚠

Stop the client (unregister + join threads). Idempotent.

lnr_subscribe^⚠

Subscribe to the topic and receive messages from other clients.

lnr_unsubscribe^⚠

Unsubscribe from the topic and do not receive messages from other clients.

lnr_version^⚠

Safety

open_store

open_store_mutex

Same backends as open_store, shared across Client / Listener / Sender threads.

set_log_cb

Install or clear the global log callback. None restores stderr-only behavior.

version

Crate version string (same as lnr_version / CARGO_PKG_VERSION).

Type Aliases

AddrCbackC

LogCbackC

PendingCbackC

StatusCbackIntern