(ns pubsub.sequencer)

(def routing-table (atom {}))

(defrecord Sequencing [sequence-number
                       group-local-sequencer-number
                       forwarding-table
                       reverse-path-table
                       output-buffer ; channel?
                       input-buffer])



(defrecord SequencerNode [ingress
                          distribute])

(def ingress (chan))
(def distribute {:va (chan)
                 :ca (chan)
                 :ir (chan)})

(defn sequence []
      (let []
           ()))