Nats

Undocumented in source.

final

class Nats {

import std.format : sformat;;

import std.socket : Address, parseAddress;;

import std.traits : Unqual;;

import eventcore.core : IOMode;;

import vibe.core.net : TCPConnection, connectTCP, WaitForDataStatus;;

import vibe.core.sync : TaskCondition, RecursiveTaskMutex, TaskMutex;;

import vibe.data.json : Json;;

import nbuff : Nbuff;;

auto natsClientVersion;

struct ConnectInfo;

struct Statistics;

this(string natsUri, string name);

this(NatsClientConfig config);

void connect();

bool connected();

const(Subscription[]) subscriptions();

const(Statistics) statistics();

Subscription subscribe(string subject, NatsHandler handler, string queueGroup);

void unsubscribe(Subscription s, uint msgsToDrain);

void publish(const(char)[] subject, const(T)[] payload);

void publishRequest(const(char)[] subject, const(T)[] payload, NatsHandler handler);

Duration flush(Duration timeout);

void disconnect();

void close();

}

Constructors

this this(string natsUri, string name): Undocumented in source.
this this(NatsClientConfig config): Undocumented in source.

Destructor

~this ~this(): Undocumented in source.

Members

Functions

close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
connect void connect(): Undocumented in source. Be warned that the author may not have intended to support it.
connected bool connected(): Undocumented in source. Be warned that the author may not have intended to support it.
disconnect void disconnect(): Undocumented in source. Be warned that the author may not have intended to support it.
flush Duration flush(Duration timeout): Undocumented in source. Be warned that the author may not have intended to support it.
publish void publish(const(char)[] subject, const(T)[] payload): Undocumented in source. Be warned that the author may not have intended to support it.
publishRequest void publishRequest(const(char)[] subject, const(T)[] payload, NatsHandler handler): Undocumented in source. Be warned that the author may not have intended to support it.
statistics const(Statistics) statistics(): Undocumented in source. Be warned that the author may not have intended to support it.
subscribe Subscription subscribe(string subject, NatsHandler handler, string queueGroup): Undocumented in source. Be warned that the author may not have intended to support it.
subscriptions const(Subscription[]) subscriptions(): Undocumented in source. Be warned that the author may not have intended to support it.
unsubscribe void unsubscribe(Subscription s, uint msgsToDrain): Undocumented in source. Be warned that the author may not have intended to support it.

Static variables

natsClientVersion auto natsClientVersion;: Undocumented in source.

Structs

ConnectInfo struct ConnectInfo: Undocumented in source.
Statistics struct Statistics: Undocumented in source.

Meta

Source

See Implementation

nats client classes

Nats

manifest constants

VERSION