aleph.netty
activity-logger
(activity-logger level)(activity-logger name level)
AlephServer
protocol
members
port
(port _)
Returns the port the server is listening on.
wait-for-close
(wait-for-close _)
Blocks until the server has been closed.
append-to-buf!
(append-to-buf! buf x)
bandwidth-tracker
(bandwidth-tracker ch)
buf->array
(buf->array buf)
buffered-source
(buffered-source ch metric capacity)
bufs->array
(bufs->array bufs)
channel-handler
macro
(channel-handler & {:as handlers})
channel-inbound-handler
macro
(channel-inbound-handler & {:as handlers})
channel-inbound-throughput
channel-outbound-handler
macro
(channel-outbound-handler & {:as handlers})
channel-outbound-throughput
channel-remote-address
(channel-remote-address ch)
channel-server-name
(channel-server-name ch)
channel-server-port
(channel-server-port ch)
channel-ssl-session
(channel-ssl-session ch)
client-event-thread-pool-name
coerce-log-level
(coerce-log-level level)
convert-address-types
(convert-address-types address-types)
create-client
(create-client pipeline-builder ssl-context bootstrap-transform remote-address local-address epoll?)(create-client pipeline-builder ssl-context bootstrap-transform remote-address local-address epoll? name-resolver)
dns-name-servers-provider
(dns-name-servers-provider servers)
dns-resolver-group
(dns-resolver-group {:keys [max-payload-size max-queries-per-resolve address-types query-timeout min-ttl max-ttl negative-ttl trace-enabled? opt-resources-enabled? search-domains ndots decode-idn? recursion-desired? name-servers epoll?], :or {recursion-desired? true, max-payload-size 4096, opt-resources-enabled? true, max-ttl Integer/MAX_VALUE, max-queries-per-resolve 16, ndots -1, epoll? false, min-ttl 0, decode-idn? true, query-timeout 5000, trace-enabled? false}})
Creates an instance of DnsAddressResolverGroup that might be set as a resolver to Bootstrap.
DNS options are a map of:
|:--- |:---
| `max-payload-size` | sets capacity of the datagram packet buffer (in bytes), defaults to `4096`
| `max-queries-per-resolve` | sets the maximum allowed number of DNS queries to send when resolving a host name, defaults to `16`
| `address-types` | sets the list of the protocol families of the address resolved, should be one of `:ipv4-only`, `:ipv4-preferred`, `:ipv6-only`, `:ipv4-preferred` (calculated automatically based on ipv4/ipv6 support when not set explicitly)
| `query-timeout` | sets the timeout of each DNS query performed by this resolver (in milliseconds), defaults to `5000`
| `min-ttl` | sets minimum TTL of the cached DNS resource records (in seconds), defaults to `0`
| `max-ttl` | sets maximum TTL of the cached DNS resource records (in seconds), defaults to `Integer/MAX_VALUE` (the resolver will respect the TTL from the DNS)
| `negative-ttl` | sets the TTL of the cache for the failed DNS queries (in seconds)
| `trace-enabled?` | if set to `true`, the resolver generates the detailed trace information in an exception message, defaults to `false`
| `opt-resources-enabled?` | if set to `true`, enables the automatic inclusion of a optional records that tries to give the remote DNS server a hint about how much data the resolver can read per response, defaults to `true`
| `search-domains` | sets the list of search domains of the resolver, when not given the default list is used (platform dependent)
| `ndots` | sets the number of dots which must appear in a name before an initial absolute query is made, defaults to `-1`
| `decode-idn?` | set if domain / host names should be decoded to unicode when received, defaults to `true`
| `recursion-desired?` | if set to `true`, the resolver sends a DNS query with the RD (recursion desired) flag set, defaults to `true`
| `name-servers` | optional list of DNS server addresses, automatically discovered when not set (platform dependent)
| `epoll?` | if `true`, uses `epoll` when available, defaults to `false`
enumerating-thread-factory
(enumerating-thread-factory prefix daemon?)
epoll-available?
(epoll-available?)
get-attribute
(get-attribute ch attr)
get-default-event-loop-threads
(get-default-event-loop-threads)
Determines the default number of threads to use for a Netty EventLoopGroup.
This mimics the default used by Netty as of version 4.1.
insecure-ssl-client-context
(insecure-ssl-client-context)
instrument!
(instrument! stream)
leak-detector-level!
(leak-detector-level! level)
pipeline-initializer
(pipeline-initializer pipeline-builder)
release-buf->array
(release-buf->array buf)
remove-if-present
(remove-if-present pipeline handler)
safe-execute
macro
(safe-execute ch & body)
self-signed-ssl-context
(self-signed-ssl-context)
A self-signed SSL context for servers.
set-attribute
(set-attribute ch attr val)
set-logger!
(set-logger! logger)
sink
(sink ch)(sink ch downstream? coerce-fn)(sink ch downstream? coerce-fn additional-description)
ssl-client-context
(ssl-client-context)(ssl-client-context {:keys [private-key private-key-password certificate-chain trust-store]})
Creates a new client SSL context.
Keyword arguments are:
|:---|:----
| `private-key` | A `java.io.File`, `java.io.InputStream`, or `java.security.PrivateKey` containing the client-side private key.
| `certificate-chain` | A `java.io.File`, `java.io.InputStream`, or array of `java.security.cert.X509Certificate` containing the client's certificate chain.
| `private-key-password` | A string, the private key's password (optional).
| `trust-store` | A `java.io.File`, `java.io.InputStream`, array of `java.security.cert.X509Certificate`, or a `javax.net.ssl.TrustManagerFactory` to initialize the context's trust manager.
Note that if specified, the types of `private-key` and `certificate-chain` must be
"compatible": either both input streams, both files, or a private key and an array
of certificates.
start-server
(start-server pipeline-builder ssl-context bootstrap-transform on-close socket-address epoll?)
to-byte-buf
(to-byte-buf x)(to-byte-buf ch x)
to-byte-buf-stream
(to-byte-buf-stream x chunk-size)
wrap-future
(wrap-future f)
write-and-flush
(write-and-flush x msg)