Liking cljdoc? Tell your friends :D

gateway.domains.bus.core


bus-domainclj/s

(bus-domain)
source

handle-requestclj/smultimethod

source

joinclj/s

(join state source request)
source

matches-routing?clj/s

(matches-routing? sub-key key)
source

matches-subscription?clj/s

(matches-subscription? topic routing-key [_ subscription])

checks if given topic and routing key match an existing subscription

checks if given topic and routing key match an existing subscription
sourceraw docstring

matches-target?clj/s

(matches-target? target peer)
source

matches-topic?clj/s

(matches-topic? {sub-topic :topic sub-pattern :topic-repattern} topic)

checks if sub-topic matches topic

checks if sub-topic matches topic
sourceraw docstring

publishclj/s

(publish state source request)
source

publish*clj/s

(publish* state request publisher)

distributes a message onto all matching subscribers

distributes a message onto all matching subscribers
sourceraw docstring

source-removedclj/s

(source-removed state source _)

Source has disconnected from the system

Source has disconnected from the system
sourceraw docstring

subscribeclj/s

(subscribe state source request)
source

subscribe*clj/s

(subscribe* state request subscription-id peer)
source

subscriptions->messagesclj/s

(subscriptions->messages peer)

generates messages that applied on a remote node will join the peer to the bus domain and register its subscriptions

generates messages that applied on a remote node will join the peer to the bus domain and register its subscriptions
sourceraw docstring

topic->patternclj/s

(topic->pattern topic)
source

unsubscribeclj/s

(unsubscribe state source request)
source

unsubscribe*clj/s

(unsubscribe* state request peer)
source

wildcard?clj/s

(wildcard? topic)
source

zip-peer-subscriptionsclj/s

(zip-peer-subscriptions peers)

given a collection of peers, returns a [[peer subscription-a] [peer subscription-b]] where subscription-a and subscription-b are the topic subscriptions of the peer

given a collection of peers, returns a [[peer subscription-a] [peer subscription-b]] where
subscription-a and subscription-b are the topic subscriptions of the peer
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close