puppetlabs.puppetdb.utils — org.openvoxproject/puppetdb 8.12.0

add-tar-entry clj

(add-tar-entry tar-writer {:keys [file-suffix contents]})

Inputs: [tar-writer {:keys [file-suffix contents]} :- tar-item]

Writes the given tar-item to tar-writer using export-root-directory as the base directory for contents

assoc-if-exists clj

(assoc-if-exists m & ks)

Assoc only if the key is already present

assoc-when clj macro

(assoc-when map key val & kvs)

Assocs the provided values with the corresponding keys if and only if the key is not already present in map.

await-ref-state clj

(await-ref-state ref pred)

(await-ref-state ref pred timeout-ms timeout-val)

Waits until (pred @ref) is true and returns val, unless that takes longer than timeout-ms, in which case, returns timeout-val.

await-scheduler-shutdown clj

(await-scheduler-shutdown s wait-time)

base-url->str clj

(base-url->str {:keys [protocol host port prefix version] :as _base-url})

Inputs: [{:keys [protocol host port prefix version], :as _base-url} :- base-url-schema] Returns: s/Str

Converts the `base-url' map to an ASCII URL. May throw MalformedURLException or URISyntaxException.

base-url->str-no-path clj

(base-url->str-no-path {:keys [protocol host port] :as _base-url})

Inputs: [{:keys [protocol host port], :as _base-url} :- base-url-schema] Returns: s/Str

Converts the `base-url' map to an ASCII URL minus the path element. This can be used to build a full URL when you have an absolute path.

base-url->str-with-prefix clj

(base-url->str-with-prefix {:keys [protocol host port prefix] :as _base-url})

base-url-schema clj

byte-array-class clj

call-unless-shutting-down clj

(call-unless-shutting-down what shutting-down? shutdown-context f)

cmd-params->json-str clj

(cmd-params->json-str {:strs [command version certname payload]})

cmd-url-params clj

(cmd-url-params {:keys [command version certname producer-timestamp timeout]})

collapse-seq clj

(collapse-seq split-pred collapse-fn rows)

Lazily consumes and collapses the seq rows. Uses split-pred to chunk the seq, passes in each chunk to collapse-fn. Each result of collapse-fn is an item in the return lazy-seq.

compression-file-extension-schema clj

content-encoding->file-extension clj

(content-encoding->file-extension encoding)

content-encodings->file-extensions clj

describe-bad-base-url clj

(describe-bad-base-url base-url)

If a problem is detected with base-url, returns a string describing the issue. For example {:host "x:y" ...}.

digit? clj

(digit? c)

Inputs: [c :- Character] Returns: s/Bool

Return true if the character is a digit

env-config-for-db-ulong clj

(env-config-for-db-ulong name default)

exceptional-shutdown-requestor clj

(exceptional-shutdown-requestor request-shutdown messages status)

Returns a function that when called with one Throwable argument, calls request-shutdown (as defined by Trapperkeeper) to request a shutdown with the given messages and status.

export-root-dir clj

flush-and-exit clj

(flush-and-exit status)

Attempts to flush out and err, reporting any failures to err, if possible, and then invokes (System/exit status).

HasSocketChannel clj protocol

get-socket-channel clj

(get-socket-channel this)

Returns the associated socket channel.

known-error? clj

(known-error? ex)

kwd->str clj

(kwd->str kwd)

Inputs: [kwd :- s/Keyword]

Convert a keyword to a string. This is different from name in that it will preserve the entire keyword, i.e. :foo/bar -> "foo/bar", where name would be just "bar"

leaf-error? clj

(leaf-error? ex)

match-any-of clj

(match-any-of strings)

Given a collection of strings and characters, construct a regex string suitable for passing to re-pattern that consists of a capturing group which matches any member of the collection.

metrics-base-url clj

(metrics-base-url host port & [version])

nil-on-failure clj macro

(nil-on-failure & body)

Executes body and if an exception is thrown, returns nil

noisy-future clj macro

(noisy-future & body)

optional-key? clj

(optional-key? x)

pdb-cmd-base-url clj

(pdb-cmd-base-url host port & [version protocol])

print-err clj

(print-err & args)

println-err clj

(println-err & args)

Redirects output to standard error before invoking println

read-json-content clj

(read-json-content reader)

(read-json-content reader keywordize-keys?)

Utility function for our cli tools. For reading json content from a tar-reader.

regex-quote clj

(regex-quote s)

request-scheduler-shutdown clj

(request-scheduler-shutdown s interrupt-in-flight-tasks?)

response->channel clj

(response->channel response)

Returns the socket channel (i.e. something that can be registered with a Selector) associated with a jetty response object.

schedule clj

(schedule s f delay)

schedule-at-fixed-rate clj

(schedule-at-fixed-rate s f initial-delay period)

schedule-with-fixed-delay clj

(schedule-with-fixed-delay s f initial-delay delay)

scheduler clj

(scheduler core-threads)

str-schema clj

(str-schema kwd-schema)

Function for converting a schema with keyword keys to to one with string keys. Doesn't walk the map so nested schema won't work.

stringify-keys clj

(stringify-keys m)

Recursively transforms all map keys from keywords to strings. This improves on clojure.walk/stringify-keys by supporting the conversion of hyphenated keywords to strings instead of trying to resolve them in a namespace first.

strip-nil-values clj

(strip-nil-values m)

remove all nil-valued keys from a map

supported-content-encodings clj

tar-item clj

throw-if-shutdown-pending clj

(throw-if-shutdown-pending shutdown-reason)

throw-sink-cli-error clj

(throw-sink-cli-error msg)

time-limited-seq clj

(time-limited-seq coll deadline-ns on-timeout)

Returns a new sequence of the items in coll that will call on-timeout (which must return something seq-ish if it doesn't throw) if the timeout is reached while consuming the collection. Does nothing given an ##Inf timeout. The timeout is with respect to the ephemeral-now-ns timeline.

try-process-cli clj

(try-process-cli f)

(try-process-cli f
                 &
                 {:keys [preamble postamble] :or {preamble "" postamble ""}})

update-matching-keys clj

(update-matching-keys m pred f & _)

Returns the map resulting from an (update m k f & args) for every key k in m satisfying (pred k).

update-when clj

(update-when m ks f & args)

Acts as update-in if ks refers to a value, otherwise returns m.

utf8 clj

utf8-bytes clj

(utf8-bytes s)

utf8-length clj

(utf8-length s)

Return the length in bytes of the given string when encoded in UTF-8

utf8-truncate clj

(utf8-truncate s max-bytes)

Truncate the given string such that its UTF-8 representation is at most max-bytes long. Note that the returned string may be empty.

validate-cli-base-url! clj

(validate-cli-base-url! {:keys [base-url] :as options})

Validates the base-url and throws an exception appropriate for kitchensink/cli! on error.

vector-maybe clj

(vector-maybe v)

Vectorize an argument if it's not already vector

with-captured-throw clj macro

(with-captured-throw & body)

with-fatal-error-handler clj macro

(with-fatal-error-handler handle & body)

Calls (handler ex) instead of throwing if the body throws a fatal error, which is any Throwable other than Exception, AssertionError, or ThreadDeath.

with-log-mdc clj macro

(with-log-mdc alternating-kvs & body)

Establishes the MDC contexts given by the alternating-kvs key value pairs during the execution of the body, and ensures that the original values (if any) are always restored before returning. The keys associated with any nil values will be removed via MDC/remove.

with-monitored-execution clj macro

(with-monitored-execution initiate-shutdown & body)

Executes body while logging any exceptions and printing them to err. Calls (initiate-shutdown ex) as a side effect for any fatal errors (see with-shutdown-request-on-fatal-error).

with-noisy-failure clj macro

(with-noisy-failure & body)

with-nonfatal-exceptions-suppressed clj macro

(with-nonfatal-exceptions-suppressed & body)

Suppresses all Throwables that are not Errors, and suppresses one type of Error: AssertionError.

with-shutdown-request-on-fatal-error clj macro

(with-shutdown-request-on-fatal-error initiate-shutdown & body)

Calls (initiate-shutdown ex) as a side effect if the body throws a fatal error (see with-fatal-error-handler). Any exceptions thrown by initiate-shutdown will be suppressed by (.addSuppressed ex ...).