puppetlabs.pcp.broker.shared — puppetlabs/pcp-broker 1.8.0

Broker clj

BrokerDatabase clj

BrokerState clj

build-and-register-metrics clj

(build-and-register-metrics broker)

Inputs: [broker :- Broker] Returns: #:s{Keyword Object}

deliver-message clj

(deliver-message broker message sender)

Inputs: [broker :- Broker message :- Message sender :- (s/maybe Connection)]

Message consumer. Delivers a message to the websocket indicated by the :target field

deliver-server-message clj

(deliver-server-message broker message client)

Inputs: [broker :- Broker message :- Message client :- Connection]

Message consumer. Delivers a message to the websocket indicated by the :target field but only if it still routed to the connection specified by the client argument

get-connection clj

(get-connection broker uri)

Inputs: [broker :- Broker uri :- p/Uri] Returns: (s/maybe Connection)

get-controller clj

(get-controller broker uri)

(get-controller broker uri timeout)

Inputs: ([broker :- Broker uri :- p/Uri] [broker :- Broker uri :- p/Uri timeout :- s/Int]) Returns: (s/maybe Connection)

handle-delivery-failure clj

(handle-delivery-failure message sender reason)

Inputs: [message :- Message sender :- (s/maybe Connection) reason :- s/Str]

Send an error message with the specified description.

Inventory clj

log-delivery-failure clj

(log-delivery-failure message reason)

Inputs: [message :- Message reason :- s/Str]

Log message delivery failure given the message and failure reason.

MessageLog clj

Schema for a loggable summary of a message

PatternSets clj

send-error-message clj

(send-error-message in-reply-to-message description connection)

Inputs: [in-reply-to-message :- (s/maybe Message) description :- s/Str connection :- Connection]

send-message clj

(send-message connection message)

Inputs: [connection :- Connection message :- Message]

Subscription clj

summarize clj

(summarize message)

Inputs: [message :- Message] Returns: MessageLog