puppetlabs.pcp.broker.inventory — puppetlabs/pcp-broker 2.0.2

batch-update-interval-ms clj

build-inventory-data clj

(build-inventory-data inventory pattern-sets)

Inputs: [inventory :- shared/Inventory pattern-sets :- shared/PatternSets] Returns: p/InventoryResponse

Build the payload of the inventory response message given the inventory snapshot and a set of patterns to filter the snapshot.

build-pattern-sets clj

(build-pattern-sets patterns)

Inputs: [patterns :- [p/Uri]] Returns: shared/PatternSets

Parse the passed patterns and split them into explicit and wildcard sets for faster matching.

build-update-data clj

(build-update-data updates pattern-sets)

Inputs: [updates :- [p/InventoryChange] pattern-sets :- shared/PatternSets] Returns: (s/maybe p/InventoryUpdate)

Build the payload of the inventory update message given the inventory updates snapshot and a set of patterns to filter the snapshot. Return nil if there are no updates matching the patterns.

init-database clj

(init-database)

Inputs: [] Returns: shared/BrokerDatabase

send-updates clj

(send-updates broker)

Inputs: [broker :- Broker]

start-inventory-updates! clj

(start-inventory-updates! broker)

Inputs: [broker :- Broker]

Start periodic sending of the inventory updates.

stop-inventory-updates! clj

(stop-inventory-updates! broker)

Inputs: [broker :- Broker]

Stop the periodic sending of the inventory updates.

subscribe-client! clj

(subscribe-client! broker client connection pattern-sets)

Inputs: [broker :- Broker client :- p/Uri connection :- Object pattern-sets :- shared/PatternSets] Returns: shared/BrokerDatabase

Subscribe the specified client for inventory updates. Expects a promise of a connection, to be fulfilled when the initial inventory response has been sent; that prevents messages appearing out of order. Return the broker database snapshot at the time of subscribing.

unchecked+ clj

(unchecked+ a b)

Inputs: [a :- s/Int b :- s/Int] Returns: s/Int

An addition which can overflow

unchecked- clj

(unchecked- a b)

Inputs: [a :- s/Int b :- s/Int] Returns: s/Int

A substraction which can overflow

unsubscribe-client! clj

(unsubscribe-client! broker client)

Inputs: [broker :- Broker client :- p/Uri] Returns: shared/BrokerDatabase

Unsubscribe the specified client from inventory updates. Return the broker database snapshot at the time of unsubscribing.

uri-pattern-sets-match? clj

(uri-pattern-sets-match? {:keys [explicit wildcard]} subject)

Inputs: [{:keys [explicit wildcard]} :- shared/PatternSets subject :- p/Uri] Returns: s/Bool

Does a subject uri match the pattern sets?