Copyright	(c) Soostone Inc 2020
License	AllRightsReserved
Stability	experimental
Portability	POSIX
Safe Haskell	None
Language	Haskell2010

Napkin.Run.Redshift

Contents

Redshift Re-exports
Orphan instances

Description

Synopsis

data RedshiftT (m :: Type -> Type) a
data family BackendSchemaField bk
connectRedshift :: forall (m :: Type -> Type). MonadIO m => RedshiftDB -> Int -> NominalDiffTime -> Int -> RedshiftT m (Pool Connection)
runRedshift :: MonadIO m => RedshiftState -> RedshiftT m a -> m a
defRS :: Configuration -> RedshiftState
redNick :: String -> IO RedshiftDB
withRedshift :: String -> Int -> NominalDiffTime -> Int -> (BackendConn Redshift -> IO b) -> IO b
withPostgresString :: Natural -> String -> (BackendConn Redshift -> IO b) -> IO b

Redshift Re-exports

data RedshiftT (m :: Type -> Type) a #

The Redshift monad transformer that all the redshift API operations run in. This monad ensures that all tunnels get a unique port on localhost.

Instances

Instances details

MonadTrans RedshiftT
Instance details Defined in Aws.Redshift.Monad Methods lift :: Monad m => m a -> RedshiftT m a #
Monad m => Monad (RedshiftT m)
Instance details Defined in Aws.Redshift.Monad Methods (>>=) :: RedshiftT m a -> (a -> RedshiftT m b) -> RedshiftT m b # (>>) :: RedshiftT m a -> RedshiftT m b -> RedshiftT m b # return :: a -> RedshiftT m a #
Functor m => Functor (RedshiftT m)
Instance details Defined in Aws.Redshift.Monad Methods fmap :: (a -> b) -> RedshiftT m a -> RedshiftT m b # (<$) :: a -> RedshiftT m b -> RedshiftT m a #
MonadFix m => MonadFix (RedshiftT m)
Instance details Defined in Aws.Redshift.Monad Methods mfix :: (a -> RedshiftT m a) -> RedshiftT m a #
MonadFail m => MonadFail (RedshiftT m)
Instance details Defined in Aws.Redshift.Monad Methods fail :: String -> RedshiftT m a #
Monad m => Applicative (RedshiftT m)
Instance details Defined in Aws.Redshift.Monad Methods pure :: a -> RedshiftT m a # (<>) :: RedshiftT m (a -> b) -> RedshiftT m a -> RedshiftT m b # liftA2 :: (a -> b -> c) -> RedshiftT m a -> RedshiftT m b -> RedshiftT m c # (>) :: RedshiftT m a -> RedshiftT m b -> RedshiftT m b # (<*) :: RedshiftT m a -> RedshiftT m b -> RedshiftT m a #
MonadIO m => MonadIO (RedshiftT m)
Instance details Defined in Aws.Redshift.Monad Methods liftIO :: IO a -> RedshiftT m a #
MonadThrow m => MonadThrow (RedshiftT m)
Instance details Defined in Aws.Redshift.Monad Methods throwM :: Exception e => e -> RedshiftT m a #
MonadCatch m => MonadCatch (RedshiftT m)
Instance details Defined in Aws.Redshift.Monad Methods catch :: Exception e => RedshiftT m a -> (e -> RedshiftT m a) -> RedshiftT m a #
MonadMask m => MonadMask (RedshiftT m)
Instance details Defined in Aws.Redshift.Monad Methods mask :: ((forall a. RedshiftT m a -> RedshiftT m a) -> RedshiftT m b) -> RedshiftT m b # uninterruptibleMask :: ((forall a. RedshiftT m a -> RedshiftT m a) -> RedshiftT m b) -> RedshiftT m b # generalBracket :: RedshiftT m a -> (a -> ExitCase b -> RedshiftT m c) -> (a -> RedshiftT m b) -> RedshiftT m (b, c) #
MFunctor RedshiftT
Instance details Defined in Aws.Redshift.Monad Methods hoist :: forall m n (b :: k). Monad m => (forall a. m a -> n a) -> RedshiftT m b -> RedshiftT n b #

data family BackendSchemaField bk #

Instances

Instances details

Command GetRelationSchema [BackendSchemaField Sqlite] Sqlite #
Instance details Defined in Napkin.Run.Sqlite Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Sqlite -> GetRelationSchema -> m [BackendSchemaField Sqlite] #
Command GetRelationSchema [BackendSchemaField Redshift] Redshift #
Instance details Defined in Napkin.Run.Redshift Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> GetRelationSchema -> m [BackendSchemaField Redshift] #
Command GetRelationSchema [BackendSchemaField Postgres] Postgres #
Instance details Defined in Napkin.Run.Postgres Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Postgres -> GetRelationSchema -> m [BackendSchemaField Postgres] #
Command GetRelationSchema [BackendSchemaField BigQuery] BigQuery #
Instance details Defined in Napkin.Run.BigQuery Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn BigQuery -> GetRelationSchema -> m [BackendSchemaField BigQuery] #
Eq (BackendSchemaField Sqlite) #
Instance details Defined in Napkin.Run.Sqlite Methods (==) :: BackendSchemaField Sqlite -> BackendSchemaField Sqlite -> Bool # (/=) :: BackendSchemaField Sqlite -> BackendSchemaField Sqlite -> Bool #
Eq (BackendSchemaField Redshift) #
Instance details Defined in Napkin.Run.Redshift Methods (==) :: BackendSchemaField Redshift -> BackendSchemaField Redshift -> Bool # (/=) :: BackendSchemaField Redshift -> BackendSchemaField Redshift -> Bool #
Eq (BackendSchemaField Postgres) #
Instance details Defined in Napkin.Run.Postgres Methods (==) :: BackendSchemaField Postgres -> BackendSchemaField Postgres -> Bool # (/=) :: BackendSchemaField Postgres -> BackendSchemaField Postgres -> Bool #
Eq (BackendSchemaField BigQuery) #
Instance details Defined in Napkin.Run.BigQuery Methods (==) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool # (/=) :: BackendSchemaField BigQuery -> BackendSchemaField BigQuery -> Bool #
Show (BackendSchemaField Sqlite) #
Instance details Defined in Napkin.Run.Sqlite Methods showsPrec :: Int -> BackendSchemaField Sqlite -> ShowS # show :: BackendSchemaField Sqlite -> String # showList :: [BackendSchemaField Sqlite] -> ShowS #
Show (BackendSchemaField Redshift) #
Instance details Defined in Napkin.Run.Redshift Methods showsPrec :: Int -> BackendSchemaField Redshift -> ShowS # show :: BackendSchemaField Redshift -> String # showList :: [BackendSchemaField Redshift] -> ShowS #
Show (BackendSchemaField Postgres) #
Instance details Defined in Napkin.Run.Postgres Methods showsPrec :: Int -> BackendSchemaField Postgres -> ShowS # show :: BackendSchemaField Postgres -> String # showList :: [BackendSchemaField Postgres] -> ShowS #
Show (BackendSchemaField BigQuery) #
Instance details Defined in Napkin.Run.BigQuery Methods showsPrec :: Int -> BackendSchemaField BigQuery -> ShowS # show :: BackendSchemaField BigQuery -> String # showList :: [BackendSchemaField BigQuery] -> ShowS #
FromRow (BackendSchemaField Sqlite) #
Instance details Defined in Napkin.Run.Sqlite Methods fromRow :: RowParser (BackendSchemaField Sqlite) #
data BackendSchemaField Sqlite #
Instance details Defined in Napkin.Run.Sqlite data BackendSchemaField Sqlite = SqliteSchemaField { scdCid :: Int scdName :: Text scdType :: Text scdNullable :: Int scdDefaultValue :: Maybe Int scdPrimaryKey :: Int }
data BackendSchemaField Redshift #
Instance details Defined in Napkin.Run.Redshift data BackendSchemaField Redshift = RedshiftSchemaField PGSchemaField
data BackendSchemaField Postgres #
Instance details Defined in Napkin.Run.Postgres data BackendSchemaField Postgres = PostgresSchemaField PGSchemaField
data BackendSchemaField BigQuery #
Instance details Defined in Napkin.Run.BigQuery data BackendSchemaField BigQuery = BigQuerySchemaField TableFieldSchema

connectRedshift :: forall (m :: Type -> Type). MonadIO m => RedshiftDB -> Int -> NominalDiffTime -> Int -> RedshiftT m (Pool Connection) #

Establish a postgresql-simple connection to a RedshiftDB.

runRedshift :: MonadIO m => RedshiftState -> RedshiftT m a -> m a #

Runs any DB action in IO.

The only way to unwrap RedshiftT, as we need to carefully manage SSH tunnels and database connections.

defRS :: Configuration -> RedshiftState #

A default RedshiftState that cleans up and is not verbose. If you store your keys in ~/.aws-keys you can use baseConfiguration for the configuration parameter

redNick :: String -> IO RedshiftDB #

Retrieves a RedshiftDB for the specified DB nickname.

withRedshift :: String -> Int -> NominalDiffTime -> Int -> (BackendConn Redshift -> IO b) -> IO b #

withPostgresString :: Natural -> String -> (BackendConn Redshift -> IO b) -> IO b #

Orphan instances

Backend Redshift #
Instance details Associated Types data BackendConn Redshift # Methods backendQuery :: (Katip m, MonadQueryStats m, RenderSql q Redshift) => BackendConn Redshift -> q -> m [Map Text Value] # backendExecute :: (Katip m, MonadQueryStats m, RenderSql q Redshift) => BackendConn Redshift -> q -> m () #
RunBackendConn Redshift #
Instance details Methods runBackendConn :: LogEnv -> DbBackendOptions Redshift -> ConnectionString -> Maybe AppName -> Maybe CredentialsPath -> SpecFile -> Maybe AuthPort -> (Pipeline -> BackendConn Redshift -> IO a) -> IO a #
HasPostgresConn Redshift #
Instance details Methods getPostgresConn :: BackendConn Redshift -> Pool Connection #
Command UpdateQuery () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> UpdateQuery -> m () #
Command Grant () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> Grant -> m () #
Command CheckTableExists Bool Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> CheckTableExists -> m Bool #
Command DeleteFrom () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> DeleteFrom -> m () #
Command InsertIntoQuery () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> InsertIntoQuery -> m () #
Command DropTable () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> DropTable -> m () #
Command DropView () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> DropView -> m () #
Command CopyTable () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> CopyTable -> m () #
Command RenameTable () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> RenameTable -> m () #
Command GetRelationSchema [BackendSchemaField Redshift] Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> GetRelationSchema -> m [BackendSchemaField Redshift] #
Eq (DbBackendOptions Redshift) #
Instance details Methods (==) :: DbBackendOptions Redshift -> DbBackendOptions Redshift -> Bool # (/=) :: DbBackendOptions Redshift -> DbBackendOptions Redshift -> Bool #
Show (DbBackendOptions Redshift) #
Instance details Methods showsPrec :: Int -> DbBackendOptions Redshift -> ShowS # show :: DbBackendOptions Redshift -> String # showList :: [DbBackendOptions Redshift] -> ShowS #
Generic (DbBackendOptions Redshift) #
Instance details Associated Types type Rep (DbBackendOptions Redshift) :: Type -> Type # Methods from :: DbBackendOptions Redshift -> Rep (DbBackendOptions Redshift) x # to :: Rep (DbBackendOptions Redshift) x -> DbBackendOptions Redshift #
ToJSON (DbBackendOptions Redshift) #
Instance details Methods toJSON :: DbBackendOptions Redshift -> Value # toEncoding :: DbBackendOptions Redshift -> Encoding # toJSONList :: [DbBackendOptions Redshift] -> Value # toEncodingList :: [DbBackendOptions Redshift] -> Encoding #
FromJSON (DbBackendOptions Redshift) #
Instance details Methods parseJSON :: Value -> Parser (DbBackendOptions Redshift) # parseJSONList :: Value -> Parser [DbBackendOptions Redshift] #
Default (DbBackendOptions Redshift) #
Instance details Methods def :: DbBackendOptions Redshift #
HasBackendSchemaField Redshift #
Instance details Associated Types data BackendSchemaField Redshift # Methods fieldName :: BackendSchemaField Redshift -> Text # fieldType :: BackendSchemaField Redshift -> Type #
Command (CreateMaterializedViewAs ()) () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> CreateMaterializedViewAs () -> m () #
Command (CreateViewAs ()) () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> CreateViewAs () -> m () #
Command (CreateTableAs ()) () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> CreateTableAs () -> m () #
Command (CreateTableAs TableMeta) () Redshift #
Instance details Methods execCommand :: (Katip m, MonadQueryStats m) => BackendConn Redshift -> CreateTableAs TableMeta -> m () #
Eq (BackendSchemaField Redshift) #
Instance details Methods (==) :: BackendSchemaField Redshift -> BackendSchemaField Redshift -> Bool # (/=) :: BackendSchemaField Redshift -> BackendSchemaField Redshift -> Bool #
Show (BackendSchemaField Redshift) #
Instance details Methods showsPrec :: Int -> BackendSchemaField Redshift -> ShowS # show :: BackendSchemaField Redshift -> String # showList :: [BackendSchemaField Redshift] -> ShowS #