Lamina 0.5.0-SNAPSHOT API documentation
event-driven data structures for clojure
lamina.core
Public variables and functions:
- async-promise?
- atom-sink
- cancel-callback
- channel
- channel*
- channel->lazy-seq
- channel->seq
- channel-pair
- channel?
- close
- close-on-idle
- closed-channel
- closed-result
- closed?
- combine-latest
- complete
- concat*
- defer-onto-queue
- distribute-aggregate
- distributor
- drained-result
- drained?
- drop*
- drop-while*
- emit-in-order
- enqueue
- enqueue-and-close
- error
- error-result
- error-value
- expiring-result
- filter*
- force-close
- force-error
- fork
- ground
- grounded-channel
- idle-result
- join
- join->>
- last*
- lazy-seq->channel
- map*
- mapcat*
- merge-channels
- merge-results
- named-channel
- on-closed
- on-drained
- on-error
- on-realized
- partition*
- partition-all*
- partition-every
- periodically
- permanent-channel
- pipeline
- read-channel
- read-channel*
- receive
- receive-all
- receive-in-order
- redirect
- reduce*
- reductions*
- remove*
- restart
- result-channel
- run-pipeline
- sample-every
- sink
- sink->>
- siphon
- siphon->>
- splice
- split
- success-result
- take*
- take-while*
- tap
- timed-result
- transactional?
- transitions
- wait-for-message
- wait-for-result
- wait-stage
- watch-channel
- with-timeout
- zip
- zip-all
lamina.trace
Public variables and functions:
- aggregating-trace-router
- analyze-timings
- canonical-probe-name
- defn-instrumented
- distill-timing
- error-probe-channel
- instrument
- instrumented-fn
- local-trace-router
- merge-distilled-timings
- probe-channel
- probe-enabled?
- probe-names
- register-context-builder
- select-probes
- subscribe
- time*
- trace
- trace*
- trace-router
- tracing?
- with-instrumentation