phaser.disruptor — userevents/phaser 1.1.5

add-gating-sequences clj

(add-gating-sequences rb sequences)

Add the specified gating sequences to this instance of the Disruptor. They will safely and atomically added to the list of gating sequences.

add-sequence clj

(add-sequence sequence-group sequence)

create-batch-event-processor clj

(create-batch-event-processor rb barrier handler)

create-event-factory clj

(create-event-factory handler)

Create an EventFactory which is called by the RingBuffer to pre-populate all the events to fill the RingBuffer.

create-event-handler clj

(create-event-handler handler)

Create an EventHandler which is a callback interface for processing events as they become available in the RingBuffer.

create-event-publisher clj multimethod

Returns a function that publishes events to the RingBuffer of different arity depending on which EventTranslator is being used.

create-event-translator clj

(create-event-translator handler)

Create an EventTranslator which translate (write) data representations into events claimed from the RingBuffer

create-event-translator-one-arg clj

(create-event-translator-one-arg handler)

Create an EventTranslatorOneArg which translate (write) data representations into events claimed from the RingBuffer

create-event-translator-three-arg clj

(create-event-translator-three-arg handler)

Create an EventTranslatorThreeArg which translate (write) data representations into events claimed from the RingBuffer

create-event-translator-two-arg clj

(create-event-translator-two-arg handler)

Create an EventTranslatorTwoArg which translate (write) data representations into events claimed from the RingBuffer

create-event-translator-var-arg clj

(create-event-translator-var-arg handler)

Create an EventTranslatorVararg which translate (write) data representations into events claimed from the RingBuffer. The Handler should accept a variadic number of params

create-exception-handler clj

(create-exception-handler on-event on-start on-shutdown)

create-multi-producer clj

(create-multi-producer factory size)

(create-multi-producer factory size strategy)

create-sequence-barrier clj

(create-sequence-barrier rb sequences)

create-single-producer clj

(create-single-producer factory size)

(create-single-producer factory size strategy)

create-work-handler clj

(create-work-handler handler)

Create a WorkHandler which is for processing units of work as they become available in the RingBuffer.

create-worker-pool clj

(create-worker-pool factory exception-handler handlers)

(create-worker-pool rb sb exception-handler handlers)

deffactory clj macro

(deffactory name & args)

Define a Disruptor EventFactory which is called by the RingBuffer.

defhandler clj macro

(defhandler name & args)

Define a Disruptor event handler which is a callback interface for processing events as they become available in the RingBuffer.

deftranslator clj macro

(deftranslator name & args)

Define a Disrupter EventTranslator which translate (write) data representations into events claimed from the RingBuffer

deftranslator1 clj macro

(deftranslator1 name & args)

Define a Disrupter EventTranslatorOneArg which translate (write) data representations into events claimed from the RingBuffer

deftranslator2 clj macro

(deftranslator2 name & args)

Define a Disrupter EventTranslatorTwoArg which translate (write) data representations into events claimed from the RingBuffer

deftranslator3 clj macro

(deftranslator3 name & args)

Define a Disrupter EventTranslatorThreeArg which translate (write) data representations into events claimed from the RingBuffer

deftranslatorvarg clj macro

(deftranslatorvarg name & args)

Define a Disrupter EventTranslatorVararg which translate (write) data representations into events claimed from the RingBuffer

event-for-sequence clj

(event-for-sequence rb sequence)

Returns the event for a given sequence in the Ring Buffer

get-buffer-size clj

(get-buffer-size rb)

get-cursor clj

(get-cursor rb)

get-sequence clj

(get-sequence event-processor)

handle-exceptions-with clj

(handle-exceptions-with batch-processor exception-handler)