aleph.netty

->HeaderMap

(->HeaderMap headers added removed mta)
Positional factory function for class aleph.netty.HeaderMap.

acquire

(acquire x)

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.

allocate

(allocate x)

append-to-buf!

(append-to-buf! buf x)

array-class

attribute

(attribute s)

bandwidth-tracker

(bandwidth-tracker ch)

buf->array

(buf->array buf)

buffered-source

(buffered-source ch metric capacity)

bufs->array

(bufs->array bufs)

channel

(channel x)

channel-handler

macro

(channel-handler & {:as handlers})

channel-inbound-counter

channel-inbound-throughput

channel-outbound-counter

channel-outbound-throughput

channel-remote-address

(channel-remote-address ch)

channel-server-name

(channel-server-name ch)

channel-server-port

(channel-server-port ch)

client-event-thread-pool-name

close

(close x)

create-client

(create-client pipeline-builder ssl-context bootstrap-transform remote-address local-address epoll?)

epoll-available?

(epoll-available?)

epoll-client-group

flush

(flush x)

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.

headers

(headers h)

insecure-ssl-client-context

(insecure-ssl-client-context)

instrument!

(instrument! stream)

leak-detector-level!

(leak-detector-level! level)

nio-client-group

pipeline-initializer

(pipeline-initializer pipeline-builder)

put!

(put! ch s msg)

release

(release x)

release-buf->array

(release-buf->array buf)

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)

source

(source ch)

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

(write x msg)

write-and-flush

(write-and-flush x msg)