via.endpoint — com.7theta/via 11.15.6

add-event-listener clj/s

(add-event-listener endpoint key listener)

broadcast clj/s

(broadcast endpoint message)

Asynchronously sends message to all connected clients

connect clj/s

(connect endpoint peer-address)

(connect endpoint peer-address peer-id)

(connect endpoint peer-address peer-id ssl-context)

connected-peers clj/s

(connected-peers endpoint)

connected? clj/s

(connected? endpoint peer-id)

disconnect clj/s

(disconnect endpoint peer-id)

(disconnect endpoint peer-id reconnect)

endpoint clj/s

(endpoint {:keys [peers exports transit-handlers event-listeners request-timeout
                  context params client-connect handle-connection]
           :or {request-timeout defaults/request-timeout}})

endpoints clj/s

event? clj/s

(event? endpoint event-id)

export-event clj/s

(export-event endpoint event-id)

export-sub clj/s

(export-sub endpoint sub-id)

first-endpoint clj/s

(first-endpoint)

first-peer clj/s

(first-peer endpoint)

handle-event clj/s

(handle-event endpoint key event)

merge-context clj/s

(merge-context endpoint context)

namespace-type clj/s

namespace? clj/s

(namespace? ns)

outgoing-connect-lock clj/s

peer-connected-states cljs

(peer-connected-states endpoint)

remove-event-listener clj/s

(remove-event-listener endpoint key listener-id)

send clj/s

(send endpoint
      peer-id
      message
      &
      {:keys [type _timeout headers params on-success on-failure on-timeout
              timeout]
       :or {type :event timeout 30000}})

Asynchronously sends message to the client for peer-id

send-reply clj/s

(send-reply endpoint peer-id request-id {:keys [status body]})

send-to-tag clj/s

(send-to-tag endpoint
             tag
             message
             &
             {:keys [type _timeout headers on-success on-failure on-timeout
                     timeout]
              :or {type :event timeout 30000}})

session-context clj/s

(session-context)

(session-context endpoint)

(session-context endpoint peer-id)

shutdown clj/s

(shutdown endpoint)

sub? clj/s

(sub? endpoint sub-id)

unexport-event clj/s

(unexport-event endpoint event-id)

unexport-sub clj/s

(unexport-sub endpoint sub-id)

update-session-context clj/s

(update-session-context endpoint peer-id f)

(update-session-context endpoint peer-id sync f)