Module

Yoga.ScyllaDB.ScyllaDB

Package: purescript-yoga-scylladb
Repository: rowtype-yoga/purescript-yoga-scylladb

#Client Source

data Client

#ResultSet Source

data ResultSet

#ContactPoint Source

newtype ContactPoint

Constructors

ContactPoint String

Instances

#Keyspace Source

newtype Keyspace

Constructors

Keyspace String

Instances

#Datacenter Source

newtype Datacenter

Constructors

Datacenter String

Instances

#Username Source

newtype Username

Constructors

Username String

Instances

#Password Source

newtype Password

Constructors

Password String

Instances

#PoolSize Source

newtype PoolSize

Constructors

PoolSize Int

Instances

#ReplicationFactor Source

newtype ReplicationFactor

Constructors

ReplicationFactor Int

Instances

#CQL Source

newtype CQL

Constructors

CQL String

Instances

#ConsistencyLevel Source

data ConsistencyLevel

Constructors

Instances

#Row Source

type Row = Foreign

#QueryResultImpl Source

type QueryResultImpl = { pageState :: Nullable String, rowLength :: Int, rows :: Array Row }

#QueryResult Source

type QueryResult = { pageState :: Maybe String, rowLength :: Int, rows :: Array Row }

#toQueryResult Source

toQueryResult :: QueryResultImpl -> QueryResult

#ClientOptionsImpl Source

type ClientOptionsImpl :: Row Typetype ClientOptionsImpl = (contactPoints :: Array ContactPoint, credentials :: { password :: Password, username :: Username }, keyspace :: Keyspace, localDataCenter :: Datacenter, policies :: { loadBalancing :: Foreign, reconnection :: Foreign, retry :: Foreign }, pooling :: { coreConnectionsPerHost :: PoolSize, maxConnectionsPerHost :: PoolSize }, protocolOptions :: { maxSchemaAgreementWaitSeconds :: Int, port :: Int }, queryOptions :: { consistency :: ConsistencyLevel, fetchSize :: Int, prepare :: Boolean }, socketOptions :: { connectTimeout :: Milliseconds, readTimeout :: Milliseconds })

#createClientImpl Source

createClientImpl :: forall opts. EffectFn1 (Record opts) Client

#createClient Source

createClient :: forall opts opts_. Union opts opts_ ClientOptionsImpl => Record opts -> Effect Client

#connectImpl Source

connectImpl :: EffectFn1 Client (Promise Unit)

#connect Source

connect :: Client -> Aff Unit

#executeImpl Source

executeImpl :: EffectFn3 Client CQL (Array Foreign) (Promise QueryResultImpl)

#execute Source

execute :: CQL -> Array Foreign -> Client -> Aff QueryResult

#ExecuteOptionsImpl Source

type ExecuteOptionsImpl :: Row Typetype ExecuteOptionsImpl = (consistency :: ConsistencyLevel, fetchSize :: Int, pageState :: String, prepare :: Boolean, timestamp :: Number, traceQuery :: Boolean)

#executeWithOptionsImpl Source

executeWithOptionsImpl :: forall opts. EffectFn4 Client CQL (Array Foreign) (Record opts) (Promise QueryResultImpl)

#executeWithOptions Source

executeWithOptions :: forall opts opts_. Union opts opts_ ExecuteOptionsImpl => CQL -> Array Foreign -> Record opts -> Client -> Aff QueryResult

#BatchQuery Source

type BatchQuery = { params :: Array Foreign, query :: CQL }

#batchImpl Source

batchImpl :: EffectFn2 Client (Array BatchQuery) (Promise QueryResultImpl)

#batch Source

batch :: Array BatchQuery -> Client -> Aff QueryResult

#BatchOptionsImpl Source

type BatchOptionsImpl :: Row Typetype BatchOptionsImpl = (consistency :: ConsistencyLevel, counter :: Boolean, logged :: Boolean, timestamp :: Number)

#batchWithOptionsImpl Source

batchWithOptionsImpl :: forall opts. EffectFn3 Client (Array BatchQuery) (Record opts) (Promise QueryResultImpl)

#batchWithOptions Source

batchWithOptions :: forall opts opts_. Union opts opts_ BatchOptionsImpl => Array BatchQuery -> Record opts -> Client -> Aff QueryResult

#streamImpl Source

streamImpl :: EffectFn3 Client CQL (Array Foreign) (Promise (Array Row))

#stream Source

stream :: CQL -> Array Foreign -> Client -> Aff (Array Row)

#PreparedStatement Source

data PreparedStatement

#prepareImpl Source

prepareImpl :: EffectFn2 Client CQL (Promise PreparedStatement)

#prepare Source

prepare :: CQL -> Client -> Aff PreparedStatement

#executePreparedImpl Source

executePreparedImpl :: EffectFn3 Client PreparedStatement (Array Foreign) (Promise QueryResultImpl)

#executePrepared Source

executePrepared :: PreparedStatement -> Array Foreign -> Client -> Aff QueryResult

#getKeyspaceImpl Source

getKeyspaceImpl :: EffectFn2 Client Keyspace (Nullable Foreign)

#getKeyspace Source

getKeyspace :: Keyspace -> Client -> Effect (Maybe Foreign)

#getTableImpl Source

getTableImpl :: EffectFn3 Client Keyspace String (Nullable Foreign)

#getTable Source

getTable :: Keyspace -> String -> Client -> Effect (Maybe Foreign)

#getHostsImpl Source

getHostsImpl :: EffectFn1 Client (Array Foreign)

#getHosts Source

getHosts :: Client -> Effect (Array Foreign)

#shutdownImpl Source

shutdownImpl :: EffectFn1 Client (Promise Unit)

#shutdown Source

shutdown :: Client -> Aff Unit

#pingImpl Source

pingImpl :: EffectFn1 Client (Promise Boolean)

#ping Source

ping :: Client -> Aff Boolean

#ToCQLValue Source

class ToCQLValue a  where

Members

toCQLValue :: a -> Foreign

Instances

ToCQLValue String
ToCQLValue Int
ToCQLValue Number
ToCQLValue Boolean
ToCQLValue Foreign
ToCQLValue UUID
(ToCQLValue a) => ToCQLValue (Array a)

#param Source

param :: forall a. ToCQLValue a => a -> Array Foreign

#params Source

params :: forall a. ToCQLValue a => Array a -> Array Foreign

#UUID Source

data UUID

Instances

ToCQLValue UUID

#uuidImpl Source

uuidImpl :: Effect UUID

#uuid Source

uuid :: Effect UUID

#timeUuidImpl Source

timeUuidImpl :: Effect UUID

#timeUuid Source

timeUuid :: Effect UUID

#uuidFromStringImpl Source

uuidFromStringImpl :: EffectFn1 String (Nullable UUID)

#uuidFromString Source

uuidFromString :: String -> Effect (Maybe UUID)

#createKeyspace Source

createKeyspace :: Keyspace -> ReplicationFactor -> Client -> Aff QueryResult

#dropKeyspace Source

dropKeyspace :: Keyspace -> Client -> Aff QueryResult

#useKeyspace Source

useKeyspace :: Keyspace -> Client -> Aff QueryResult

Modules: Yoga.ScyllaDB.ScyllaDB; Yoga.ScyllaDB.TypedQuery