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

make-message clj

Message clj

multicast-message? clj

(multicast-message? message)

Inputs: [message :- Message] Returns: s/Bool

Returns a boolean specifying whether the message uses multicast in the target field.

v1->v2 clj

(v1->v2 v1-msg)

Inputs: [v1-msg :- m1/Message] Returns: Message

Transform a v1 Message to a v2 Message.

v1-codec clj

v1-decode clj

(v1-decode bytes)

Inputs: [bytes :- bytes] Returns: Message

Transform a v1 wire format message to a clojure map conforming to the latest message schema.

v1-encode clj

(v1-encode message)

Inputs: [message :- Message] Returns: bytes

Encode a clojure map conforming to the latest message scheme to the v1 binary wire format.

v2->v1 clj

(v2->v1 {:keys [message_type data in_reply_to] :as v2-msg})

Inputs: [{:keys [message_type data in_reply_to], :as v2-msg} :- Message] Returns: m1/Message

Transform a v2 Message to a v1 Message.

v2-codec clj

v2-decode clj

v2-encode clj

validate-not-multicast clj

(validate-not-multicast message)

Inputs: [message]