omq_nif (omq v0.2.2)

View Source

Summary

Functions

backend_name()
bind(Socket, Endpoint)
close(Socket, LingerMs)
closed(Socket)
connect(Socket, Endpoint)
connection_info(Socket, ConnectionId)
connections(Socket)
context_closed(Context)
context_from_share_key(ShareKey)
context_new(IoThreads)
context_share_key(Context)
context_term(Context)
curve_keypair()
curve_public(Secret)
disconnect(Socket, Endpoint)
getsockopt(Socket, Option)
has_feature(Name)
join(Socket, Group)
leave(Socket, Group)
monitor(Socket)
monitor_recv(Monitor, TimeoutMs)
monitor_try_recv(Monitor)
plain_server_credentials(Socket, Credentials)
recv(Socket, TimeoutMs)
send(Socket, Parts, RoutingId)
send_group(Socket, Group, Body)
setsockopt(Socket, Option, IntValue, BinValue)
socket_id(Socket)
socket_new(Context, SocketType)
socket_type(Socket)
subscribe(Socket, Prefix)
try_recv(Socket)
try_send(Socket, Parts, RoutingId)
unbind(Socket, Endpoint)
unsubscribe(Socket, Prefix)
version()
wait_any(Sockets, TimeoutMs)
wait_connected(Socket, MinPeers, TimeoutMs)
wait_subscribed(Socket, MinSubscriptions, TimeoutMs)

Functions

backend_name()

bind(Socket, Endpoint)

close(Socket, LingerMs)

closed(Socket)

connect(Socket, Endpoint)

connection_info(Socket, ConnectionId)

connections(Socket)

context_closed(Context)

context_from_share_key(ShareKey)

context_new(IoThreads)

context_share_key(Context)

context_term(Context)

curve_keypair()

curve_public(Secret)

disconnect(Socket, Endpoint)

getsockopt(Socket, Option)

has_feature(Name)

join(Socket, Group)

leave(Socket, Group)

monitor(Socket)

monitor_recv(Monitor, TimeoutMs)

monitor_try_recv(Monitor)

plain_server_credentials(Socket, Credentials)

recv(Socket, TimeoutMs)

send(Socket, Parts, RoutingId)

send_group(Socket, Group, Body)

setsockopt(Socket, Option, IntValue, BinValue)

socket_id(Socket)

socket_new(Context, SocketType)

socket_type(Socket)

subscribe(Socket, Prefix)

try_recv(Socket)

try_send(Socket, Parts, RoutingId)

unbind(Socket, Endpoint)

unsubscribe(Socket, Prefix)

version()

wait_any(Sockets, TimeoutMs)

wait_connected(Socket, MinPeers, TimeoutMs)

wait_subscribed(Socket, MinSubscriptions, TimeoutMs)