franz-0.5: Append-only database
Safe HaskellNone
LanguageHaskell2010

Database.Franz.Internal.Protocol

Synopsis

Documentation

data FranzException Source #

Instances

Instances details
Show FranzException Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Generic FranzException Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Associated Types

type Rep FranzException :: Type -> Type #

Exception FranzException Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Serialize FranzException Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

type Rep FranzException Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

data RequestType Source #

Constructors

AllItems 
LastItem 

Instances

Instances details
Show RequestType Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Generic RequestType Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Associated Types

type Rep RequestType :: Type -> Type #

Serialize RequestType Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

type Rep RequestType Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

type Rep RequestType = D1 ('MetaData "RequestType" "Database.Franz.Internal.Protocol" "franz-0.5-KxXJcuIWnOq5voPsLQF7IG" 'False) (C1 ('MetaCons "AllItems" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "LastItem" 'PrefixI 'False) (U1 :: Type -> Type))

data ItemRef Source #

Constructors

BySeqNum !Int

sequential number

ByIndex !IndexName !Int

index name and value

Instances

Instances details
Show ItemRef Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Generic ItemRef Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Associated Types

type Rep ItemRef :: Type -> Type #

Methods

from :: ItemRef -> Rep ItemRef x #

to :: Rep ItemRef x -> ItemRef #

Serialize ItemRef Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

type Rep ItemRef Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

type Rep ItemRef = D1 ('MetaData "ItemRef" "Database.Franz.Internal.Protocol" "franz-0.5-KxXJcuIWnOq5voPsLQF7IG" 'False) (C1 ('MetaCons "BySeqNum" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Int)) :+: C1 ('MetaCons "ByIndex" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 IndexName) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Int)))

data Query Source #

Constructors

Query 

Fields

Instances

Instances details
Show Query Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Methods

showsPrec :: Int -> Query -> ShowS #

show :: Query -> String #

showList :: [Query] -> ShowS #

Generic Query Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Associated Types

type Rep Query :: Type -> Type #

Methods

from :: Query -> Rep Query x #

to :: Rep Query x -> Query #

Serialize Query Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Methods

put :: Putter Query #

get :: Get Query #

type Rep Query Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

type Rep Query = D1 ('MetaData "Query" "Database.Franz.Internal.Protocol" "franz-0.5-KxXJcuIWnOq5voPsLQF7IG" 'False) (C1 ('MetaCons "Query" 'PrefixI 'True) ((S1 ('MetaSel ('Just "reqStream") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 StreamName) :*: S1 ('MetaSel ('Just "reqFrom") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 ItemRef)) :*: (S1 ('MetaSel ('Just "reqTo") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 ItemRef) :*: S1 ('MetaSel ('Just "reqType") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 RequestType))))

data RawRequest Source #

Instances

Instances details
Generic RawRequest Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

Associated Types

type Rep RawRequest :: Type -> Type #

Serialize RawRequest Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

type Rep RawRequest Source # 
Instance details

Defined in Database.Franz.Internal.Protocol

data ResponseHeader Source #

Constructors

Response !ResponseId

response ID, number of streams; there are items satisfying the query

ResponseWait !ResponseId

response ID; requested elements are not available right now

ResponseError !ResponseId !FranzException

something went wrong

data PayloadHeader Source #

Initial seqno, final seqno, base offset, index names

Constructors

PayloadHeader !Int !Int !Int !(Vector IndexName) 

Instances

Instances details
Serialize PayloadHeader Source # 
Instance details

Defined in Database.Franz.Internal.Protocol