stakhanov-0.1.0.0: src/Database/PostgreSQL/Stakhanov/Types.hs

module Database.PostgreSQL.Stakhanov.Types where

import           Data.Aeson.Types
import           Data.Int
import qualified Data.Text        as T
import           Data.Time
import           Data.Vector
import qualified Hasql.Connection as C

type VT           = Int32
type Qty          = Int32
type Seconds      = Int32
type Milliseconds = Int32
type MsgId        = Int64
type MsgIds       = Vector MsgId
type Messages     = Vector Message
type Queues       = Vector Queue

newtype HasqlConn = HasqlConn { unHasqlConn :: C.Connection }

instance Show HasqlConn where
  show (HasqlConn _) = show ("a Hasql connection" :: String)

data Queue =
  Queue
    { qName    :: T.Text
    , qPGConn  :: !HasqlConn
    , qDetails :: Maybe Details
    , qMetrics :: Maybe Metrics
    } deriving (Show)

instance Eq Queue where
 Queue n _ _ _ == Queue n' _ _ _ = n == n'

data Details =
  Details
    {
      createdAt     :: UTCTime
    , isPartitioned :: Bool
    , isUnlogged    :: Bool
    } deriving (Show)

data Message =
  Message
    { msgId             :: MsgId
    , readCount         :: Int32
    , enqueuedAt        :: UTCTime
    , lastReadAt        :: Maybe UTCTime
    , visibilityTimeout :: UTCTime
    , message           :: Value
    , headers           :: Maybe Value
    } deriving (Show)

instance Eq Message where
  Message i _ _ _ _ _ _ == Message i' _ _ _ _ _ _ = i == i'

data Metrics =
  Metrics
    { queueLength        :: Int64
    , newestMsgAge       :: Maybe Seconds
    , oldestMsgAge       :: Maybe Seconds
    , totalMessages      :: Int64
    , scrapeTime         :: UTCTime
    , queueVisibleLength :: Int64
    } deriving (Show)

data Delay = InSeconds Int32 | WithTimestamp UTCTime