net.resp.connection — xyz.zcaudate/net.resp 4.0.1

*close* clj

connection clj

(connection {:keys [host port]})

creates a connection

(def |c| (connection {:host "localhost" :port 4456})) (connection? |c|) => true

(connection:close |c|)

connection-string clj

(connection-string connection)

returns the string

connection:close clj

(connection:close connection)

closes the connection

connection:health clj

(connection:health connection)

checks on the health of the connection

(connection:health |conn|) => {:status :ok}

connection:info clj

(connection:info connection)

outputs connection info

connection:process-bulk clj

(connection:process-bulk connection inputs outputs _)

processes the returned responses

connection:process-single clj

(connection:process-single _ data {:keys [format deserialize string]})

processes output data

connection:read clj

(connection:read connection)

reads from the connection

connection:request-bulk clj

(connection:request-bulk connection commands)

(connection:request-bulk connection commands _)

sends a multi command to the connection

connection:request-single clj

(connection:request-single connection command)

(connection:request-single connection command _)

requests the connection command

connection:started? clj

(connection:started? connection)

checks that connection has started

connection:stopped? clj

(connection:stopped? connection)

checks that connection has stopped

connection:throw clj

(connection:throw connection t)

writes an exception to the connection

connection:transact-combine clj

(connection:transact-combine _ data)

not valid for rdp protocol

connection:transact-end clj

(connection:transact-end connection)

command to end transaction

(connection:transact-end nil) => ["EXEC"]

connection:transact-start clj

(connection:transact-start connection)

command to start transaction

(connection:transact-start nil) => ["MULTI"]

connection:value clj

(connection:value connection val)

writes a string value to the connection

connection:write clj

(connection:write connection input)

writes to the connection

connection? clj

(connection? obj)

checks if instance is type connection

(connection? |conn|) => true

input-array clj

(input-array command)

protects against wrong inputs

(seq (input-array [1 2 3])) => '("1" "2" "3")

pipeline clj

(pipeline connection)

retrieves the connection pipeline

pipeline:read clj

(pipeline:read pipeline)

reads from the pipeline

pipeline:write clj

(pipeline:write pipeline input)

sends a request tot the pipeline

pipeline? clj

(pipeline? obj)

checks if object is instance of pipeline

test:activate clj

test:config clj

(test:config)

creates a container and gets config

(test:config) => map?

test:connection clj

(test:connection)

(test:connection m)

creates a test connection

(test:connection) => connection?

test:deactivate clj

with-connection clj macro

(with-connection [conn opts] & body)

creates a temporary connection and runs code

(with-connection [conn {:port 17000}] (cc/bulk conn (fn [] (cc/req conn ["FLUSHDB"]) (cc/req conn ["SET" "TEST:A" 1]) (cc/req conn ["KEYS" "*"])) {})) => ["OK" "OK" ["TEST:A"]]

with-test:connection clj macro

(with-test:connection conn & body)

creates an runs statements using a test connection

(with-connection [conn {:port 17000}] (cc/bulk conn (fn [] (cc/req conn ["FLUSHDB"]) (cc/req conn ["SET" "TEST:A" 1]) (cc/req conn ["KEYS" "*"])) {})) => ["OK" "OK" ["TEST:A"]]