mirabelle.transport.tcp — fr.mcorbin/mirabelle 0.13.0

build-initializer clj

(build-initializer stream-handler
                   tcp-timer
                   shared-event-executor
                   channel-group
                   ssl-context)

A channel pipeline initializer for a TCP server.

epoll-netty-implementation clj

(epoll-netty-implementation)

gen-tcp-handler clj

(gen-tcp-handler stream-handler registry channel-group handler)

Wraps Netty boilerplate for common TCP server handlers. Given a reference to a core, a stats package, a channel group, and a handler fn, returns a ChannelInboundHandlerAdapter which calls (handler core stats channel-handler-context message) for each received message.

Automatically handles channel closure, and handles exceptions thrown by the handler by logging an error and closing the channel.

get-netty-implementation clj

(get-netty-implementation native?)

int32-frame-decoder clj

(int32-frame-decoder)

int32-frame-encoder clj

(int32-frame-encoder)

kqueue-netty-implementation clj

(kqueue-netty-implementation)

nio-netty-implementation clj

(nio-netty-implementation)

ssl-handler clj

(ssl-handler context)

Given an SSLContext, creates a new SSLEngine and a corresponding Netty SslHandler wrapping it.

tcp-handler clj

(tcp-handler stream-handler tcp-timer ctx message)

Given a core, a channel, and a message, applies the message to core and writes a response back on this channel.