mirabelle.transport
channel-groupclj
(channel-group n)Make a channel group with a given name.
Make a channel group with a given name.
channel-initializercljmacro
(channel-initializer & names-and-exprs)Constructs an instance of a Netty ChannelInitializer from a list of names and expressions which return handlers. Handlers with :shared metadata on their names are bound once and re-used in every invocation of getPipeline(), other handlers will be evaluated each time.
(channel-pipeline-factory
frame-decoder (make-an-int32-frame-decoder)
^:shared protobuf-decoder (ProtobufDecoder. (Proto$Msg/getDefaultInstance))
^:shared msg-decoder msg-decoder)
Constructs an instance of a Netty ChannelInitializer from a list of
names and expressions which return handlers. Handlers with :shared metadata
on their names are bound once and re-used in every invocation of
getPipeline(), other handlers will be evaluated each time.
```clojure
(channel-pipeline-factory
frame-decoder (make-an-int32-frame-decoder)
^:shared protobuf-decoder (ProtobufDecoder. (Proto$Msg/getDefaultInstance))
^:shared msg-decoder msg-decoder)
```datagram->byte-buf-decoderclj
(datagram->byte-buf-decoder)A decoder that turns DatagramPackets into ByteBufs.
A decoder that turns DatagramPackets into ByteBufs.
decode-msgclj
(decode-msg msg)Decode a protobuf to a message. Decodes the protocol buffer representation of Msg and applies post-load-event to all events.
Decode a protobuf to a message. Decodes the protocol buffer representation of Msg and applies post-load-event to all events.
derefableclj
(derefable f)A simple wrapper for a netty future which on deref just calls (syncUninterruptibly f), and returns the future's result.
A simple wrapper for a netty future which on deref just calls (syncUninterruptibly f), and returns the future's result.
event-executorclj
(event-executor nb-core)Creates a new netty execution handler for processing events. Defaults to 1 thread per core.
Creates a new netty execution handler for processing events. Defaults to 1 thread per core.
handleclj
(handle handler-fn msg)Handles a msg with the given handler.
Handles a msg with the given handler.
ioutil-lockclj
There's a bug in JDK 6, 7, and 8 which can cause a deadlock initializing sse-server and netty concurrently; we serialize them with this lock. https://github.com/riemann/riemann/issues/617
There's a bug in JDK 6, 7, and 8 which can cause a deadlock initializing sse-server and netty concurrently; we serialize them with this lock. https://github.com/riemann/riemann/issues/617
msg-decoderclj
(msg-decoder)Netty decoder for Msg protobuf objects -> maps
Netty decoder for Msg protobuf objects -> maps
msg-encoderclj
(msg-encoder)Netty encoder for maps -> Msg protobuf objects
Netty encoder for maps -> Msg protobuf objects
post-load-eventclj
(post-load-event e)After events are loaded, we assign default times if none exist.
After events are loaded, we assign default times if none exist.
protobuf-decoderclj
(protobuf-decoder)Decodes protobufs to Msg objects
Decodes protobufs to Msg objects
protobuf-encoderclj
(protobuf-encoder)Encodes protobufs to Msg objects
Encodes protobufs to Msg objects
retainclj
(retain x)Retain a ReferenceCounted object, if x is such an object. Otherwise, noop. Returns x.
Retain a ReferenceCounted object, if x is such an object. Otherwise, noop. Returns x.
shutdown-event-executor-groupclj
(shutdown-event-executor-group g)Gracefully shut down an event executor group. Returns a derefable future.
Gracefully shut down an event executor group. Returns a derefable future.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close