Package index • nanonext

Core

Socket and nano object creation

nanonext nanonext-package: nanonext: NNG (Nanomsg Next Gen) Lightweight Messaging Library
socket(): Open Socket
nano(): Create Nano Object
context(): Open Context
dial(): Dial an Address from a Socket
listen(): Listen to an Address from a Socket
start(<nanoListener>) start(<nanoDialer>): Start Listener/Dialer
close(<nanoContext>) close(<nanoDialer>) close(<nanoListener>) close(<ncurlSession>) close(<nanoServer>) close(<nanoSocket>) close(<nanoStream>): Close Connection
protocols: Protocols (Documentation)
transports: Transports (Documentation)

Communication

Send and receive operations

send(): Send
recv(): Receive
send_aio(): Send Async
recv_aio(): Receive Async
request(): Request over Context (RPC Client for Req/Rep Protocol)
reply(): Reply over Context (RPC Server for Req/Rep Protocol)
subscribe() unsubscribe(): Subscribe / Unsubscribe Topic
survey_time(): Set Survey Time

Async I/O

Asynchronous operations and promises

call_aio() call_aio_(): Call the Value of an Asynchronous Aio Operation
collect_aio() collect_aio_(): Collect Data of an Aio or List of Aios
stop_aio(): Stop Asynchronous Aio Operation
stop_request(): Stop Request Operation
race_aio(): Race Aio
unresolved(): Query if an Aio is Unresolved
is_aio() is_nano() is_ncurl_session(): Validators
as.promise(<recvAio>): Make recvAio Promise
as.promise(<ncurlAio>): Make ncurlAio Promise

Synchronization

Condition variables and pipe events

cv() wait() wait_() until() until_() cv_value() cv_reset() cv_signal(): Condition Variables
`%~>%`: Signal Forwarder
pipe_notify(): Pipe Notify
pipe_id(): Get the Pipe ID of a recvAio
monitor() read_monitor(): Monitor a Socket for Pipe Changes

HTTP Client

HTTP requests and sessions

ncurl(): ncurl
ncurl_aio(): ncurl Async
ncurl_session() transact(): ncurl Session
status_code(): Translate HTTP Status Codes

WebSocket Client

WebSocket and byte stream connections

stream(): Open Stream

HTTP/WebSocket Server

Server creation and request handlers

http_server(): Create HTTP/WebSocket Server
handler(): Create HTTP Handler
handler_ws(): Create WebSocket Handler
handler_stream(): Create HTTP Streaming Handler
handler_file(): Create Static File Handler
handler_directory(): Create Static Directory Handler
handler_inline(): Create Inline Static Content Handler
handler_redirect(): Create HTTP Redirect Handler
format_sse(): Format Server-Sent Event

TLS

Secure connections

tls_config(): Create TLS Configuration
write_cert(): Generate Self-Signed Certificate and Key

Options and Statistics

Configuration and monitoring

opt() `opt<-`(): Get and Set Options for a Socket, Context, Stream, Listener or Dialer
stat(): Get Statistic for a Socket, Listener or Dialer

Serialization

Custom serialization configuration

serial_config(): Create Serialization Configuration

Utilities

Helper functions

parse_url(): Parse URL
nng_error(): Translate Error Codes
nng_version(): NNG Library Version
is_error_value() is_nul_byte(): Error Validators
ip_addr(): IP Address
random(): Random Data Generation
mclock(): Clock Utility
msleep(): Sleep Utility
messenger(): Messenger
reap(): Reap
read_stdin(): Read stdin
write_stdout(): Write to Stdout