clojurewerkz.welle.conversion

*convert-json-keys-to-keywords*

dynamic

bin-index

macro

(bin-index index-name)

byte-array-type

Type object for a Java primitive byte array.

BytesConversion

protocol

members

to-bytes

(to-bytes input)
Converts input to a byte array value that can be stored in a bucket

counting-retrier

(counting-retrier)(counting-retrier n)
Instantiates a default (counting) retrier that will retry the operation given
number of times (by default 3)

deserialize

multimethod

deserialize-value

(deserialize-value m)
Replaces :value key with its deserialized form using :content-type key to
get value content type

from-bucket-properties

(from-bucket-properties props)

from-riak-object

(from-riak-object ro)
Converts IRiakObjects to a Clojure map

indexes-from

(indexes-from ro)
Returns indexes on the given IRiakObject as a Clojure map where values are keywords
and values are sets

IndexQueryConversion

protocol

members

to-range-query

(to-range-query start end bucket-name index-name)
Builds a range 2i query

to-value-query

(to-value-query value bucket-name index-name)
Builds a value 2i query

int-index

macro

(int-index index-name)

LinkWalkingAccumulationFlagConversion

protocol

members

mutation-from

(mutation-from f)
Instantiates a new mutation that will delegate to the provided function.

The function is supposed to take a value and implement any mutation logic
necessary.

QuorumConversion

protocol

members

to-quorum

(to-quorum input)
Coerces input to a value suitable for representing a read, write or other quorum/quora.
Riak Java client supports passing those values as numerical primitives, Quorum and Quora.

resolver-from

(resolver-from f)
Instantiates a new sibling resolver that will delegate to the provided function.

The function is supposed to take a collection of siblings and implement any resolution logic
necessary.

retrier-from

(retrier-from f)
Instantiates a new retrier that will delegate to the provided function.

The function is supposed to take a callable and implement any retrier logic
necessary.

serialize

multimethod

to-bucket-properties

(to-bucket-properties {:keys [allow-siblings last-write-wins n-val backend big-vclock small-vclock old-vclock young-vclock not-found-ok basic-quorum enable-search r w pr dw rw pw pre-commit-hooks post-commit-hooks], :or {allow-siblings false, n-val 3, enable-search false, old-vclock 86400, young-vclock 20, small-vclock 50, big-vclock 50}})

to-delete-meta

(to-delete-meta r pr w dw pw rw vclock timeout)
Builds a DeleteMeta instance from provided arguments

to-fetch-meta

(to-fetch-meta r pr not-found-ok basic-quorum head-only return-deleted-vclock if-modified-since if-modified-vclock timeout)
Builds a FetchMeta instance from provided arguments

to-index-query

multimethod

to-riak-object

(to-riak-object {:keys [bucket key value content-type metadata indexes vclock vtag last-modified links], :or {content-type Constants/CTYPE_OCTET_STREAM, metadata {}}, :as options})
Builds a Riak object from a Clojure map of well-known attributes:
:value, :content-type, :metadata, :indexes, :vclock, :vtag, :last-modified

to-store-meta

(to-store-meta w dw pw return-body if-none-match if-not-modified timeout)
Builds a StoreMeta instance from provided arguments

to-tunable-cap-props

(to-tunable-cap-props {:keys [r w dw rw pr pw basic-quorum not-found-ok], :or {not-found-ok false}})
Build a TunableCAPProps instance from Clojure map

VClockConversion

protocol

members

to-vclock

(to-vclock input)
Converts input to a VClock instance