Ido Barkan barkanido

## match_example.clj
(match/match [a b]
            [_ true] :first
            [true false] :second
            [_ false] :third)

(try
 (cond
  (= b true) :first
  (= b false) (try
               (cond

## DateTimeFormatter.java
import java.time.LocalDateTime;
import java.time.ZonedDateTime;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.time.format.DateTimeFormatterBuilder;
import java.time.temporal.ChronoField;

public class Main {


## core.clj
(ns toy-url-decoder.core
  (:require [cemerick.url :as c-url]
            [criterium.core :as crit])
  (:import [java.net URI URL]
           [io.netty.handler.codec.http QueryStringDecoder]
           [java.nio.charset Charset]
           [org.apache.http.client.utils URLEncodedUtils]
           [org.apache.http NameValuePair]
           [java.util List Map Map$Entry]))

## transcoder-get.clj
user=> (aero/put c "index" "set-name" 42 1000)
<< … >>
user=> (defn inc-transcoder [rec] (when rec
  #_=>                                  (update rec :payload inc)))
#'user/inc-transcoder
user=> (d/chain (aero/get-single c "index" "set-name" {:transcoder inc-transcoder})
  #_=>          :payload
  #_=>          println)
<< … >>
43

## transcoder-put.clj
user=> (aero/put c "17" "set-name" 1 1000 {:transcoder str})
<< … >>

## client-events.clj
(ns af-common-rta-aerospike.core
  (:require [aerospike-clj.client :as aero]
            [statsd.metrics :as metrics]
            [statsd.core :as statsd]
            [manifold.deferred :as d]))

(defrecord DBMeter []
  client/ClientEvents
  (on-success [_ op-name op-result _index op-start-time client]
    (statsd/send-timing (metrics/format-statsd-metric (:cluster-name client) op-name "latency")

## aero-record.clj
user=> @(aero/get-single c "index" "set-name")
#aerospike_clj.client.AerospikeRecord{:payload 42, :gen 1, :ttl 285167713}

## aero-putget.clj
user=> (aero/put c "index" "set-name" 42 1000)
<< … >>
user=> (def f (aero/get-single c "index" "set-name"))
#'user/f
user=> (d/chain (aero/get-single c "index" "set-name")
  #_=>          :ttl
  #_=>          aero/expiry-unix
  #_=>          #(java.time.Instant/ofEpochSecond %)
  #_=>          str
  #_=>          println)

## aero-client.clj
user=> (require '[aerospike-clj.client :as aero])
nil
user=> (def c (aero/init-simple-aerospike-client ["localhost"] "test"))
;; Starting aerospike clients for clusters localhost with username null
#'user/c
user=>