API
#github.com/xulang-org/packages/natsNATS high-performance cloud-native messaging driver for Xu. Features Standard NATS text protocol implementation in 100% pure Xu. High-throughput publish/subscribe (PUB/SUB). Queue Groups (distributed load-balanced worker queues). Request-Reply RPC pattern with dynamic inbox routing. Automatic PING/PONG heartbeat management.
github.com/xulang-org/packages · 0.1.1 · Install and use
openpub fn open(addr string) ClientNATS high-performance cloud-native messaging driver for Xu. Features Standard NATS text protocol implementation in 100% pure Xu. High-throughput publish/subscribe (PUB/SUB). Queue Groups (distributed load-balanced worker queues). Request-Reply RPC pattern with dynamic inbox routing. Automatic PING/PONG heartbeat management. Throws on failure.
addr stringClient — a value of this type
open_poolpub fn open_pool(addr string, max_idle int) PoolOpen pool.
addr stringmax_idle intPool — a value of this type
struct Clientpub struct Client {
pub fd int
pub buf string
pub addr string
pub next_sid int
pub server_info string
}Public struct `Client`.
fd intbuf stringaddr stringnext_sid intserver_info string(&mut Client) read_linepub fn (c &mut Client) read_line() stringMethod on `&mut Client`: read line. Throws on failure.
c &mut Clientstring — result string
(&mut Client) read_bytespub fn (c &mut Client) read_bytes(n int) stringMethod on `&mut Client`: read through delim (inclusive). Throws on failure.
c &mut Clientn intstring — result string
(&mut Client) write_rawpub fn (c &mut Client) write_raw(data string) intMethod on `&mut Client`: write raw. Throws on failure.
c &mut Clientdata stringint — a value of this type
connectpub fn connect(addr string) Clientconnect; returns Client.
addr stringClient — a value of this type
connect_authpub fn connect_auth(addr string, user string, pass string) ClientConnect auth. Throws on failure.
addr stringuser stringpass stringClient — a value of this type
(&mut Client) pingpub fn (c &mut Client) ping() boolCall `ping` on `&mut Client`. Throws on failure.
c &mut Clientbool — true or false
(&mut Client) publishpub fn (c &mut Client) publish(subject string, data string) intCall `publish` on `&mut Client`. Throws on failure.
c &mut Clientsubject stringdata stringint — a value of this type
(&mut Client) publish_requestpub fn (c &mut Client) publish_request(subject string, reply_to string, data string) intMethod on `&mut Client`: publish request. Throws on failure.
c &mut Clientsubject stringreply_to stringdata stringint — a value of this type
(&mut Client) subscribepub fn (c &mut Client) subscribe(subject string) SubscriptionCall `subscribe` on `&mut Client`. Throws on failure.
c &mut Clientsubject stringSubscription — a value of this type
(&mut Client) queue_subscribepub fn (c &mut Client) queue_subscribe(subject string, queue_group string) SubscriptionMethod on `&mut Client`: queue subscribe. Throws on failure.
c &mut Clientsubject stringqueue_group stringSubscription — a value of this type
(&mut Client) unsubscribepub fn (c &mut Client) unsubscribe(sub Subscription) intCall `unsubscribe` on `&mut Client`. Throws on failure.
c &mut Clientsub Subscriptionint — a value of this type
(&mut Client) next_msgpub fn (c &mut Client) next_msg() MessageMethod on `&mut Client`: next msg. Throws on failure.
c &mut ClientMessage — a value of this type
(&mut Client) requestpub fn (c &mut Client) request(subject string, data string) MessageCall `request` on `&mut Client`. Throws on failure.
c &mut Clientsubject stringdata stringMessage — a value of this type
(&mut Client) closepub fn (c &mut Client) close() intMethod on `&mut Client`: close the resource.
c &mut Clientint — a value of this type
struct Messagepub struct Message {
pub subject string
pub sid string
pub reply_to string
pub data string
}Public struct `Message`.
subject stringsid stringreply_to stringdata stringnew_msgpub fn new_msg(subject string, sid string, reply_to string, data string) MessageConstruct msg.
subject stringsid stringreply_to stringdata stringMessage — a value of this type
struct Poolpub struct Pool {
pub url string
pub auth_user string
pub auth_pass string
pub idle chan int
pub max_idle int
}Connection Pool for NATS messaging system. Uses channel of socket file descriptors for lightweight and high-throughput pooling.
url stringauth_user stringauth_pass stringidle chan intmax_idle intnew_poolpub fn new_pool(url string, max_idle int) PoolConstruct pool.
url stringmax_idle intPool — a value of this type
new_pool_authpub fn new_pool_auth(url string, user string, pass string, max_idle int) PoolConstruct pool auth.
url stringuser stringpass stringmax_idle intPool — a value of this type
(&Pool) getpub fn (p &Pool) get() ClientCall `get` on `&Pool`. Throws on failure.
p &PoolClient — a value of this type
(&Pool) put_connpub fn (p &Pool) put_conn(fd int)Method on `&Pool`: put connection.
p &Poolfd int(&Pool) putpub fn (p &Pool) put(c Client)Call `put` on `&Pool`.
p &Poolc Client(&Pool) publishpub fn (p &Pool) publish(subject string, data string) intCall `publish` on `&Pool`. Throws on failure.
p &Poolsubject stringdata stringint — a value of this type
(&Pool) closepub fn (p &Pool) close()Method on `&Pool`: close the resource.
p &Poolstruct Subscriptionpub struct Subscription {
pub sid string
pub subject string
pub queue_group string
}Public struct `Subscription`.
sid stringsubject stringqueue_group stringnew_subpub fn new_sub(sid string, subject string, queue_group string) SubscriptionConstruct sub.
sid stringsubject stringqueue_group stringSubscription — a value of this type