Safe Haskell	None
Language	Haskell2010

Network.Kafka.Protocol

Contents

Generated lenses
Composed lenses

Synopsis

Documentation

data ReqResp a where #

Constructors

MetadataRR :: MonadIO m => MetadataRequest -> ReqResp (m MetadataResponse)
ProduceRR :: MonadIO m => ProduceRequest -> ReqResp (m ProduceResponse)
FetchRR :: MonadIO m => FetchRequest -> ReqResp (m FetchResponse)
OffsetRR :: MonadIO m => OffsetRequest -> ReqResp (m OffsetResponse)

doRequest' :: (Deserializable a, MonadIO m) => CorrelationId -> Handle -> Request -> m (Either String a) #

doRequest :: MonadIO m => ClientId -> CorrelationId -> Handle -> ReqResp (m a) -> m (Either String a) #

class Serializable a where #

Minimal complete definition

serialize

Methods

serialize :: a -> Put #

Instances

Serializable Int8 #
Methods serialize :: Int8 -> Put #
Serializable Int16 #
Methods serialize :: Int16 -> Put #
Serializable Int32 #
Methods serialize :: Int32 -> Put #
Serializable Int64 #
Methods serialize :: Int64 -> Put #
Serializable Request #
Methods serialize :: Request -> Put #
Serializable KafkaError #
Methods serialize :: KafkaError -> Put #
Serializable Metadata #
Methods serialize :: Metadata -> Put #
Serializable ConsumerGroup #
Methods serialize :: ConsumerGroup -> Put #
Serializable OffsetFetchRequest #
Methods serialize :: OffsetFetchRequest -> Put #
Serializable OffsetCommitRequest #
Methods serialize :: OffsetCommitRequest -> Put #
Serializable GroupCoordinatorRequest #
Methods serialize :: GroupCoordinatorRequest -> Put #
Serializable Value #
Methods serialize :: Value -> Put #
Serializable Key #
Methods serialize :: Key -> Put #
Serializable Attributes #
Methods serialize :: Attributes -> Put #
Serializable MagicByte #
Methods serialize :: MagicByte -> Put #
Serializable Crc #
Methods serialize :: Crc -> Put #
Serializable Message #
Methods serialize :: Message -> Put #
Serializable Offset #
Methods serialize :: Offset -> Put #
Serializable MessageSetMember #
Methods serialize :: MessageSetMember -> Put #
Serializable MessageSet #
Methods serialize :: MessageSet -> Put #
Serializable Partition #
Methods serialize :: Partition -> Put #
Serializable Timeout #
Methods serialize :: Timeout -> Put #
Serializable RequiredAcks #
Methods serialize :: RequiredAcks -> Put #
Serializable ProduceRequest #
Methods serialize :: ProduceRequest -> Put #
Serializable MaxBytes #
Methods serialize :: MaxBytes -> Put #
Serializable MinBytes #
Methods serialize :: MinBytes -> Put #
Serializable MaxWaitTime #
Methods serialize :: MaxWaitTime -> Put #
Serializable ReplicaId #
Methods serialize :: ReplicaId -> Put #
Serializable FetchRequest #
Methods serialize :: FetchRequest -> Put #
Serializable MaxNumberOfOffsets #
Methods serialize :: MaxNumberOfOffsets -> Put #
Serializable Time #
Methods serialize :: Time -> Put #
Serializable OffsetRequest #
Methods serialize :: OffsetRequest -> Put #
Serializable Replicas #
Methods serialize :: Replicas -> Put #
Serializable FetchResponse #
Methods serialize :: FetchResponse -> Put #
Serializable ProduceResponse #
Methods serialize :: ProduceResponse -> Put #
Serializable KafkaString #
Methods serialize :: KafkaString -> Put #
Serializable KafkaBytes #
Methods serialize :: KafkaBytes -> Put #
Serializable TopicName #
Methods serialize :: TopicName -> Put #
Serializable MetadataRequest #
Methods serialize :: MetadataRequest -> Put #
Serializable RequestMessage #
Methods serialize :: RequestMessage -> Put #
Serializable ClientId #
Methods serialize :: ClientId -> Put #
Serializable CorrelationId #
Methods serialize :: CorrelationId -> Put #
Serializable ApiVersion #
Methods serialize :: ApiVersion -> Put #
Serializable ApiKey #
Methods serialize :: ApiKey -> Put #
Serializable a => Serializable [a] #
Methods serialize :: [a] -> Put #
(Serializable a, Serializable b) => Serializable (a, b) #
Methods serialize :: (a, b) -> Put #
(Serializable a, Serializable b, Serializable c) => Serializable (a, b, c) #
Methods serialize :: (a, b, c) -> Put #
(Serializable a, Serializable b, Serializable c, Serializable d) => Serializable (a, b, c, d) #
Methods serialize :: (a, b, c, d) -> Put #
(Serializable a, Serializable b, Serializable c, Serializable d, Serializable e) => Serializable (a, b, c, d, e) #
Methods serialize :: (a, b, c, d, e) -> Put #

class Deserializable a where #

Minimal complete definition

deserialize

Methods

deserialize :: Get a #

Instances

Deserializable Int8 #
Methods deserialize :: Get Int8 #
Deserializable Int16 #
Methods deserialize :: Get Int16 #
Deserializable Int32 #
Methods deserialize :: Get Int32 #
Deserializable Int64 #
Methods deserialize :: Get Int64 #
Deserializable KafkaError #
Methods deserialize :: Get KafkaError #
Deserializable Metadata #
Methods deserialize :: Get Metadata #
Deserializable ConsumerGroup #
Methods deserialize :: Get ConsumerGroup #
Deserializable Value #
Methods deserialize :: Get Value #
Deserializable Key #
Methods deserialize :: Get Key #
Deserializable Attributes #
Methods deserialize :: Get Attributes #
Deserializable MagicByte #
Methods deserialize :: Get MagicByte #
Deserializable Crc #
Methods deserialize :: Get Crc #
Deserializable Message #
Methods deserialize :: Get Message #
Deserializable Offset #
Methods deserialize :: Get Offset #
Deserializable MessageSetMember #
Methods deserialize :: Get MessageSetMember #
Deserializable MessageSet #
Methods deserialize :: Get MessageSet #
Deserializable Partition #
Methods deserialize :: Get Partition #
Deserializable Timeout #
Methods deserialize :: Get Timeout #
Deserializable RequiredAcks #
Methods deserialize :: Get RequiredAcks #
Deserializable MaxBytes #
Methods deserialize :: Get MaxBytes #
Deserializable MinBytes #
Methods deserialize :: Get MinBytes #
Deserializable MaxWaitTime #
Methods deserialize :: Get MaxWaitTime #
Deserializable ReplicaId #
Methods deserialize :: Get ReplicaId #
Deserializable FetchRequest #
Methods deserialize :: Get FetchRequest #
Deserializable OffsetFetchResponse #
Methods deserialize :: Get OffsetFetchResponse #
Deserializable OffsetCommitResponse #
Methods deserialize :: Get OffsetCommitResponse #
Deserializable Isr #
Methods deserialize :: Get Isr #
Deserializable Replicas #
Methods deserialize :: Get Replicas #
Deserializable Leader #
Methods deserialize :: Get Leader #
Deserializable PartitionMetadata #
Methods deserialize :: Get PartitionMetadata #
Deserializable TopicMetadata #
Methods deserialize :: Get TopicMetadata #
Deserializable Port #
Methods deserialize :: Get Port #
Deserializable Host #
Methods deserialize :: Get Host #
Deserializable NodeId #
Methods deserialize :: Get NodeId #
Deserializable Broker #
Methods deserialize :: Get Broker #
Deserializable MetadataResponse #
Methods deserialize :: Get MetadataResponse #
Deserializable FetchResponse #
Methods deserialize :: Get FetchResponse #
Deserializable PartitionOffsets #
Methods deserialize :: Get PartitionOffsets #
Deserializable OffsetResponse #
Methods deserialize :: Get OffsetResponse #
Deserializable ProduceResponse #
Methods deserialize :: Get ProduceResponse #
Deserializable KafkaString #
Methods deserialize :: Get KafkaString #
Deserializable KafkaBytes #
Methods deserialize :: Get KafkaBytes #
Deserializable TopicName #
Methods deserialize :: Get TopicName #
Deserializable MetadataRequest #
Methods deserialize :: Get MetadataRequest #
Deserializable ClientId #
Methods deserialize :: Get ClientId #
Deserializable CorrelationId #
Methods deserialize :: Get CorrelationId #
Deserializable ApiVersion #
Methods deserialize :: Get ApiVersion #
Deserializable ApiKey #
Methods deserialize :: Get ApiKey #
Deserializable GroupCoordinatorResponse #
Methods deserialize :: Get GroupCoordinatorResponse #
Deserializable a => Deserializable [a] #
Methods deserialize :: Get [a] #
(Deserializable a, Deserializable b) => Deserializable (a, b) #
Methods deserialize :: Get (a, b) #
(Deserializable a, Deserializable b, Deserializable c) => Deserializable (a, b, c) #
Methods deserialize :: Get (a, b, c) #
(Deserializable a, Deserializable b, Deserializable c, Deserializable d) => Deserializable (a, b, c, d) #
Methods deserialize :: Get (a, b, c, d) #
(Deserializable a, Deserializable b, Deserializable c, Deserializable d, Deserializable e) => Deserializable (a, b, c, d, e) #
Methods deserialize :: Get (a, b, c, d, e) #

newtype GroupCoordinatorResponse #

Constructors

GroupCoordinatorResp (KafkaError, Broker)

Instances

Eq GroupCoordinatorResponse #
Methods (==) :: GroupCoordinatorResponse -> GroupCoordinatorResponse -> Bool # (/=) :: GroupCoordinatorResponse -> GroupCoordinatorResponse -> Bool #
Show GroupCoordinatorResponse #
Methods showsPrec :: Int -> GroupCoordinatorResponse -> ShowS # show :: GroupCoordinatorResponse -> String # showList :: [GroupCoordinatorResponse] -> ShowS #
Generic GroupCoordinatorResponse #
Associated Types type Rep GroupCoordinatorResponse :: * -> * # Methods from :: GroupCoordinatorResponse -> Rep GroupCoordinatorResponse x # to :: Rep GroupCoordinatorResponse x -> GroupCoordinatorResponse #
Deserializable GroupCoordinatorResponse #
Methods deserialize :: Get GroupCoordinatorResponse #
type Rep GroupCoordinatorResponse #
type Rep GroupCoordinatorResponse = D1 * (MetaData "GroupCoordinatorResponse" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "GroupCoordinatorResp" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (KafkaError, Broker))))

newtype ApiKey #

Constructors

ApiKey Int16

Instances

Enum ApiKey #
Methods succ :: ApiKey -> ApiKey # pred :: ApiKey -> ApiKey # toEnum :: Int -> ApiKey # fromEnum :: ApiKey -> Int # enumFrom :: ApiKey -> [ApiKey] # enumFromThen :: ApiKey -> ApiKey -> [ApiKey] # enumFromTo :: ApiKey -> ApiKey -> [ApiKey] # enumFromThenTo :: ApiKey -> ApiKey -> ApiKey -> [ApiKey] #
Eq ApiKey #
Methods (==) :: ApiKey -> ApiKey -> Bool # (/=) :: ApiKey -> ApiKey -> Bool #
Integral ApiKey #
Methods quot :: ApiKey -> ApiKey -> ApiKey # rem :: ApiKey -> ApiKey -> ApiKey # div :: ApiKey -> ApiKey -> ApiKey # mod :: ApiKey -> ApiKey -> ApiKey # quotRem :: ApiKey -> ApiKey -> (ApiKey, ApiKey) # divMod :: ApiKey -> ApiKey -> (ApiKey, ApiKey) # toInteger :: ApiKey -> Integer #
Num ApiKey #
Methods (+) :: ApiKey -> ApiKey -> ApiKey # (-) :: ApiKey -> ApiKey -> ApiKey # (*) :: ApiKey -> ApiKey -> ApiKey # negate :: ApiKey -> ApiKey # abs :: ApiKey -> ApiKey # signum :: ApiKey -> ApiKey # fromInteger :: Integer -> ApiKey #
Ord ApiKey #
Methods compare :: ApiKey -> ApiKey -> Ordering # (<) :: ApiKey -> ApiKey -> Bool # (<=) :: ApiKey -> ApiKey -> Bool # (>) :: ApiKey -> ApiKey -> Bool # (>=) :: ApiKey -> ApiKey -> Bool # max :: ApiKey -> ApiKey -> ApiKey # min :: ApiKey -> ApiKey -> ApiKey #
Real ApiKey #
Methods toRational :: ApiKey -> Rational #
Show ApiKey #
Methods showsPrec :: Int -> ApiKey -> ShowS # show :: ApiKey -> String # showList :: [ApiKey] -> ShowS #
Generic ApiKey #
Associated Types type Rep ApiKey :: * -> * # Methods from :: ApiKey -> Rep ApiKey x # to :: Rep ApiKey x -> ApiKey #
Deserializable ApiKey #
Methods deserialize :: Get ApiKey #
Serializable ApiKey #
Methods serialize :: ApiKey -> Put #
type Rep ApiKey #
type Rep ApiKey = D1 * (MetaData "ApiKey" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "ApiKey" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int16)))

newtype ApiVersion #

Constructors

ApiVersion Int16

Instances

Enum ApiVersion #
Methods succ :: ApiVersion -> ApiVersion # pred :: ApiVersion -> ApiVersion # toEnum :: Int -> ApiVersion # fromEnum :: ApiVersion -> Int # enumFrom :: ApiVersion -> [ApiVersion] # enumFromThen :: ApiVersion -> ApiVersion -> [ApiVersion] # enumFromTo :: ApiVersion -> ApiVersion -> [ApiVersion] # enumFromThenTo :: ApiVersion -> ApiVersion -> ApiVersion -> [ApiVersion] #
Eq ApiVersion #
Methods (==) :: ApiVersion -> ApiVersion -> Bool # (/=) :: ApiVersion -> ApiVersion -> Bool #
Integral ApiVersion #
Methods quot :: ApiVersion -> ApiVersion -> ApiVersion # rem :: ApiVersion -> ApiVersion -> ApiVersion # div :: ApiVersion -> ApiVersion -> ApiVersion # mod :: ApiVersion -> ApiVersion -> ApiVersion # quotRem :: ApiVersion -> ApiVersion -> (ApiVersion, ApiVersion) # divMod :: ApiVersion -> ApiVersion -> (ApiVersion, ApiVersion) # toInteger :: ApiVersion -> Integer #
Num ApiVersion #
Methods (+) :: ApiVersion -> ApiVersion -> ApiVersion # (-) :: ApiVersion -> ApiVersion -> ApiVersion # (*) :: ApiVersion -> ApiVersion -> ApiVersion # negate :: ApiVersion -> ApiVersion # abs :: ApiVersion -> ApiVersion # signum :: ApiVersion -> ApiVersion # fromInteger :: Integer -> ApiVersion #
Ord ApiVersion #
Methods compare :: ApiVersion -> ApiVersion -> Ordering # (<) :: ApiVersion -> ApiVersion -> Bool # (<=) :: ApiVersion -> ApiVersion -> Bool # (>) :: ApiVersion -> ApiVersion -> Bool # (>=) :: ApiVersion -> ApiVersion -> Bool # max :: ApiVersion -> ApiVersion -> ApiVersion # min :: ApiVersion -> ApiVersion -> ApiVersion #
Real ApiVersion #
Methods toRational :: ApiVersion -> Rational #
Show ApiVersion #
Methods showsPrec :: Int -> ApiVersion -> ShowS # show :: ApiVersion -> String # showList :: [ApiVersion] -> ShowS #
Generic ApiVersion #
Associated Types type Rep ApiVersion :: * -> * # Methods from :: ApiVersion -> Rep ApiVersion x # to :: Rep ApiVersion x -> ApiVersion #
Deserializable ApiVersion #
Methods deserialize :: Get ApiVersion #
Serializable ApiVersion #
Methods serialize :: ApiVersion -> Put #
type Rep ApiVersion #
type Rep ApiVersion = D1 * (MetaData "ApiVersion" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "ApiVersion" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int16)))

newtype CorrelationId #

Constructors

CorrelationId Int32

Instances

Enum CorrelationId #
Methods succ :: CorrelationId -> CorrelationId # pred :: CorrelationId -> CorrelationId # toEnum :: Int -> CorrelationId # fromEnum :: CorrelationId -> Int # enumFrom :: CorrelationId -> [CorrelationId] # enumFromThen :: CorrelationId -> CorrelationId -> [CorrelationId] # enumFromTo :: CorrelationId -> CorrelationId -> [CorrelationId] # enumFromThenTo :: CorrelationId -> CorrelationId -> CorrelationId -> [CorrelationId] #
Eq CorrelationId #
Methods (==) :: CorrelationId -> CorrelationId -> Bool # (/=) :: CorrelationId -> CorrelationId -> Bool #
Integral CorrelationId #
Methods quot :: CorrelationId -> CorrelationId -> CorrelationId # rem :: CorrelationId -> CorrelationId -> CorrelationId # div :: CorrelationId -> CorrelationId -> CorrelationId # mod :: CorrelationId -> CorrelationId -> CorrelationId # quotRem :: CorrelationId -> CorrelationId -> (CorrelationId, CorrelationId) # divMod :: CorrelationId -> CorrelationId -> (CorrelationId, CorrelationId) # toInteger :: CorrelationId -> Integer #
Num CorrelationId #
Methods (+) :: CorrelationId -> CorrelationId -> CorrelationId # (-) :: CorrelationId -> CorrelationId -> CorrelationId # (*) :: CorrelationId -> CorrelationId -> CorrelationId # negate :: CorrelationId -> CorrelationId # abs :: CorrelationId -> CorrelationId # signum :: CorrelationId -> CorrelationId # fromInteger :: Integer -> CorrelationId #
Ord CorrelationId #
Methods compare :: CorrelationId -> CorrelationId -> Ordering # (<) :: CorrelationId -> CorrelationId -> Bool # (<=) :: CorrelationId -> CorrelationId -> Bool # (>) :: CorrelationId -> CorrelationId -> Bool # (>=) :: CorrelationId -> CorrelationId -> Bool # max :: CorrelationId -> CorrelationId -> CorrelationId # min :: CorrelationId -> CorrelationId -> CorrelationId #
Real CorrelationId #
Methods toRational :: CorrelationId -> Rational #
Show CorrelationId #
Methods showsPrec :: Int -> CorrelationId -> ShowS # show :: CorrelationId -> String # showList :: [CorrelationId] -> ShowS #
Generic CorrelationId #
Associated Types type Rep CorrelationId :: * -> * # Methods from :: CorrelationId -> Rep CorrelationId x # to :: Rep CorrelationId x -> CorrelationId #
Deserializable CorrelationId #
Methods deserialize :: Get CorrelationId #
Serializable CorrelationId #
Methods serialize :: CorrelationId -> Put #
type Rep CorrelationId #
type Rep CorrelationId = D1 * (MetaData "CorrelationId" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "CorrelationId" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

newtype ClientId #

Constructors

ClientId KafkaString

Instances

Eq ClientId #
Methods (==) :: ClientId -> ClientId -> Bool # (/=) :: ClientId -> ClientId -> Bool #
Show ClientId #
Methods showsPrec :: Int -> ClientId -> ShowS # show :: ClientId -> String # showList :: [ClientId] -> ShowS #
IsString ClientId #
Methods fromString :: String -> ClientId #
Generic ClientId #
Associated Types type Rep ClientId :: * -> * # Methods from :: ClientId -> Rep ClientId x # to :: Rep ClientId x -> ClientId #
Deserializable ClientId #
Methods deserialize :: Get ClientId #
Serializable ClientId #
Methods serialize :: ClientId -> Put #
type Rep ClientId #
type Rep ClientId = D1 * (MetaData "ClientId" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "ClientId" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * KafkaString)))

data RequestMessage #

Constructors

MetadataRequest MetadataRequest
ProduceRequest ProduceRequest
FetchRequest FetchRequest
OffsetRequest OffsetRequest
OffsetCommitRequest OffsetCommitRequest
OffsetFetchRequest OffsetFetchRequest
GroupCoordinatorRequest GroupCoordinatorRequest

Instances

Eq RequestMessage #
Methods (==) :: RequestMessage -> RequestMessage -> Bool # (/=) :: RequestMessage -> RequestMessage -> Bool #
Show RequestMessage #
Methods showsPrec :: Int -> RequestMessage -> ShowS # show :: RequestMessage -> String # showList :: [RequestMessage] -> ShowS #
Generic RequestMessage #
Associated Types type Rep RequestMessage :: * -> * # Methods from :: RequestMessage -> Rep RequestMessage x # to :: Rep RequestMessage x -> RequestMessage #
Serializable RequestMessage #
Methods serialize :: RequestMessage -> Put #
type Rep RequestMessage #
type Rep RequestMessage = D1 * (MetaData "RequestMessage" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" False) ((:+:) * ((:+:) * (C1 * (MetaCons "MetadataRequest" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * MetadataRequest))) ((:+:) * (C1 * (MetaCons "ProduceRequest" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * ProduceRequest))) (C1 * (MetaCons "FetchRequest" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * FetchRequest))))) ((:+:) * ((:+:) * (C1 * (MetaCons "OffsetRequest" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * OffsetRequest))) (C1 * (MetaCons "OffsetCommitRequest" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * OffsetCommitRequest)))) ((:+:) * (C1 * (MetaCons "OffsetFetchRequest" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * OffsetFetchRequest))) (C1 * (MetaCons "GroupCoordinatorRequest" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * GroupCoordinatorRequest))))))

newtype MetadataRequest #

Constructors

MetadataReq [TopicName]

Instances

Eq MetadataRequest #
Methods (==) :: MetadataRequest -> MetadataRequest -> Bool # (/=) :: MetadataRequest -> MetadataRequest -> Bool #
Show MetadataRequest #
Methods showsPrec :: Int -> MetadataRequest -> ShowS # show :: MetadataRequest -> String # showList :: [MetadataRequest] -> ShowS #
Generic MetadataRequest #
Associated Types type Rep MetadataRequest :: * -> * # Methods from :: MetadataRequest -> Rep MetadataRequest x # to :: Rep MetadataRequest x -> MetadataRequest #
Deserializable MetadataRequest #
Methods deserialize :: Get MetadataRequest #
Serializable MetadataRequest #
Methods serialize :: MetadataRequest -> Put #
type Rep MetadataRequest #
type Rep MetadataRequest = D1 * (MetaData "MetadataRequest" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "MetadataReq" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [TopicName])))

newtype TopicName #

Constructors

TName
Fields _tName :: KafkaString

Instances

Eq TopicName #
Methods (==) :: TopicName -> TopicName -> Bool # (/=) :: TopicName -> TopicName -> Bool #
Ord TopicName #
Methods compare :: TopicName -> TopicName -> Ordering # (<) :: TopicName -> TopicName -> Bool # (<=) :: TopicName -> TopicName -> Bool # (>) :: TopicName -> TopicName -> Bool # (>=) :: TopicName -> TopicName -> Bool # max :: TopicName -> TopicName -> TopicName # min :: TopicName -> TopicName -> TopicName #
Show TopicName #
Methods showsPrec :: Int -> TopicName -> ShowS # show :: TopicName -> String # showList :: [TopicName] -> ShowS #
IsString TopicName #
Methods fromString :: String -> TopicName #
Generic TopicName #
Associated Types type Rep TopicName :: * -> * # Methods from :: TopicName -> Rep TopicName x # to :: Rep TopicName x -> TopicName #
Deserializable TopicName #
Methods deserialize :: Get TopicName #
Serializable TopicName #
Methods serialize :: TopicName -> Put #
type Rep TopicName #
type Rep TopicName = D1 * (MetaData "TopicName" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "TName" PrefixI True) (S1 * (MetaSel (Just Symbol "_tName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * KafkaString)))

newtype KafkaBytes #

Constructors

KBytes
Fields _kafkaByteString :: ByteString

Instances

Eq KafkaBytes #
Methods (==) :: KafkaBytes -> KafkaBytes -> Bool # (/=) :: KafkaBytes -> KafkaBytes -> Bool #
Show KafkaBytes #
Methods showsPrec :: Int -> KafkaBytes -> ShowS # show :: KafkaBytes -> String # showList :: [KafkaBytes] -> ShowS #
IsString KafkaBytes #
Methods fromString :: String -> KafkaBytes #
Generic KafkaBytes #
Associated Types type Rep KafkaBytes :: * -> * # Methods from :: KafkaBytes -> Rep KafkaBytes x # to :: Rep KafkaBytes x -> KafkaBytes #
Deserializable KafkaBytes #
Methods deserialize :: Get KafkaBytes #
Serializable KafkaBytes #
Methods serialize :: KafkaBytes -> Put #
type Rep KafkaBytes #
type Rep KafkaBytes = D1 * (MetaData "KafkaBytes" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "KBytes" PrefixI True) (S1 * (MetaSel (Just Symbol "_kafkaByteString") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * ByteString)))

newtype KafkaString #

Constructors

KString
Fields _kString :: ByteString

Instances

Eq KafkaString #
Methods (==) :: KafkaString -> KafkaString -> Bool # (/=) :: KafkaString -> KafkaString -> Bool #
Ord KafkaString #
Methods compare :: KafkaString -> KafkaString -> Ordering # (<) :: KafkaString -> KafkaString -> Bool # (<=) :: KafkaString -> KafkaString -> Bool # (>) :: KafkaString -> KafkaString -> Bool # (>=) :: KafkaString -> KafkaString -> Bool # max :: KafkaString -> KafkaString -> KafkaString # min :: KafkaString -> KafkaString -> KafkaString #
Show KafkaString #
Methods showsPrec :: Int -> KafkaString -> ShowS # show :: KafkaString -> String # showList :: [KafkaString] -> ShowS #
IsString KafkaString #
Methods fromString :: String -> KafkaString #
Generic KafkaString #
Associated Types type Rep KafkaString :: * -> * # Methods from :: KafkaString -> Rep KafkaString x # to :: Rep KafkaString x -> KafkaString #
Deserializable KafkaString #
Methods deserialize :: Get KafkaString #
Serializable KafkaString #
Methods serialize :: KafkaString -> Put #
type Rep KafkaString #
type Rep KafkaString = D1 * (MetaData "KafkaString" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "KString" PrefixI True) (S1 * (MetaSel (Just Symbol "_kString") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * ByteString)))

newtype ProduceResponse #

Constructors

ProduceResp
Fields _produceResponseFields :: [(TopicName, [(Partition, KafkaError, Offset)])]

Instances

Eq ProduceResponse #
Methods (==) :: ProduceResponse -> ProduceResponse -> Bool # (/=) :: ProduceResponse -> ProduceResponse -> Bool #
Show ProduceResponse #
Methods showsPrec :: Int -> ProduceResponse -> ShowS # show :: ProduceResponse -> String # showList :: [ProduceResponse] -> ShowS #
Generic ProduceResponse #
Associated Types type Rep ProduceResponse :: * -> * # Methods from :: ProduceResponse -> Rep ProduceResponse x # to :: Rep ProduceResponse x -> ProduceResponse #
Deserializable ProduceResponse #
Methods deserialize :: Get ProduceResponse #
Serializable ProduceResponse #
Methods serialize :: ProduceResponse -> Put #
type Rep ProduceResponse #
type Rep ProduceResponse = D1 * (MetaData "ProduceResponse" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "ProduceResp" PrefixI True) (S1 * (MetaSel (Just Symbol "_produceResponseFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [(TopicName, [(Partition, KafkaError, Offset)])])))

newtype OffsetResponse #

Constructors

OffsetResp
Fields _offsetResponseFields :: [(TopicName, [PartitionOffsets])]

Instances

Eq OffsetResponse #
Methods (==) :: OffsetResponse -> OffsetResponse -> Bool # (/=) :: OffsetResponse -> OffsetResponse -> Bool #
Show OffsetResponse #
Methods showsPrec :: Int -> OffsetResponse -> ShowS # show :: OffsetResponse -> String # showList :: [OffsetResponse] -> ShowS #
Generic OffsetResponse #
Associated Types type Rep OffsetResponse :: * -> * # Methods from :: OffsetResponse -> Rep OffsetResponse x # to :: Rep OffsetResponse x -> OffsetResponse #
Deserializable OffsetResponse #
Methods deserialize :: Get OffsetResponse #
type Rep OffsetResponse #
type Rep OffsetResponse = D1 * (MetaData "OffsetResponse" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "OffsetResp" PrefixI True) (S1 * (MetaSel (Just Symbol "_offsetResponseFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [(TopicName, [PartitionOffsets])])))

newtype PartitionOffsets #

Constructors

PartitionOffsets
Fields _partitionOffsetsFields :: (Partition, KafkaError, [Offset])

Instances

Eq PartitionOffsets #
Methods (==) :: PartitionOffsets -> PartitionOffsets -> Bool # (/=) :: PartitionOffsets -> PartitionOffsets -> Bool #
Show PartitionOffsets #
Methods showsPrec :: Int -> PartitionOffsets -> ShowS # show :: PartitionOffsets -> String # showList :: [PartitionOffsets] -> ShowS #
Generic PartitionOffsets #
Associated Types type Rep PartitionOffsets :: * -> * # Methods from :: PartitionOffsets -> Rep PartitionOffsets x # to :: Rep PartitionOffsets x -> PartitionOffsets #
Deserializable PartitionOffsets #
Methods deserialize :: Get PartitionOffsets #
type Rep PartitionOffsets #
type Rep PartitionOffsets = D1 * (MetaData "PartitionOffsets" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "PartitionOffsets" PrefixI True) (S1 * (MetaSel (Just Symbol "_partitionOffsetsFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (Partition, KafkaError, [Offset]))))

newtype FetchResponse #

Constructors

FetchResp
Fields _fetchResponseFields :: [(TopicName, [(Partition, KafkaError, Offset, MessageSet)])]

Instances

Eq FetchResponse #
Methods (==) :: FetchResponse -> FetchResponse -> Bool # (/=) :: FetchResponse -> FetchResponse -> Bool #
Show FetchResponse #
Methods showsPrec :: Int -> FetchResponse -> ShowS # show :: FetchResponse -> String # showList :: [FetchResponse] -> ShowS #
Generic FetchResponse #
Associated Types type Rep FetchResponse :: * -> * # Methods from :: FetchResponse -> Rep FetchResponse x # to :: Rep FetchResponse x -> FetchResponse #
Deserializable FetchResponse #
Methods deserialize :: Get FetchResponse #
Serializable FetchResponse #
Methods serialize :: FetchResponse -> Put #
type Rep FetchResponse #
type Rep FetchResponse = D1 * (MetaData "FetchResponse" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "FetchResp" PrefixI True) (S1 * (MetaSel (Just Symbol "_fetchResponseFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [(TopicName, [(Partition, KafkaError, Offset, MessageSet)])])))

newtype MetadataResponse #

Constructors

MetadataResp
Fields _metadataResponseFields :: ([Broker], [TopicMetadata])

Instances

Eq MetadataResponse #
Methods (==) :: MetadataResponse -> MetadataResponse -> Bool # (/=) :: MetadataResponse -> MetadataResponse -> Bool #
Show MetadataResponse #
Methods showsPrec :: Int -> MetadataResponse -> ShowS # show :: MetadataResponse -> String # showList :: [MetadataResponse] -> ShowS #
Generic MetadataResponse #
Associated Types type Rep MetadataResponse :: * -> * # Methods from :: MetadataResponse -> Rep MetadataResponse x # to :: Rep MetadataResponse x -> MetadataResponse #
Deserializable MetadataResponse #
Methods deserialize :: Get MetadataResponse #
type Rep MetadataResponse #
type Rep MetadataResponse = D1 * (MetaData "MetadataResponse" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "MetadataResp" PrefixI True) (S1 * (MetaSel (Just Symbol "_metadataResponseFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * ([Broker], [TopicMetadata]))))

newtype Broker #

Constructors

Broker
Fields _brokerFields :: (NodeId, Host, Port)

Instances

Eq Broker #
Methods (==) :: Broker -> Broker -> Bool # (/=) :: Broker -> Broker -> Bool #
Ord Broker #
Methods compare :: Broker -> Broker -> Ordering # (<) :: Broker -> Broker -> Bool # (<=) :: Broker -> Broker -> Bool # (>) :: Broker -> Broker -> Bool # (>=) :: Broker -> Broker -> Bool # max :: Broker -> Broker -> Broker # min :: Broker -> Broker -> Broker #
Show Broker #
Methods showsPrec :: Int -> Broker -> ShowS # show :: Broker -> String # showList :: [Broker] -> ShowS #
Generic Broker #
Associated Types type Rep Broker :: * -> * # Methods from :: Broker -> Rep Broker x # to :: Rep Broker x -> Broker #
Deserializable Broker #
Methods deserialize :: Get Broker #
type Rep Broker #
type Rep Broker = D1 * (MetaData "Broker" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Broker" PrefixI True) (S1 * (MetaSel (Just Symbol "_brokerFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (NodeId, Host, Port))))

newtype NodeId #

Constructors

NodeId
Fields _nodeId :: Int32

Instances

Enum NodeId #
Methods succ :: NodeId -> NodeId # pred :: NodeId -> NodeId # toEnum :: Int -> NodeId # fromEnum :: NodeId -> Int # enumFrom :: NodeId -> [NodeId] # enumFromThen :: NodeId -> NodeId -> [NodeId] # enumFromTo :: NodeId -> NodeId -> [NodeId] # enumFromThenTo :: NodeId -> NodeId -> NodeId -> [NodeId] #
Eq NodeId #
Methods (==) :: NodeId -> NodeId -> Bool # (/=) :: NodeId -> NodeId -> Bool #
Integral NodeId #
Methods quot :: NodeId -> NodeId -> NodeId # rem :: NodeId -> NodeId -> NodeId # div :: NodeId -> NodeId -> NodeId # mod :: NodeId -> NodeId -> NodeId # quotRem :: NodeId -> NodeId -> (NodeId, NodeId) # divMod :: NodeId -> NodeId -> (NodeId, NodeId) # toInteger :: NodeId -> Integer #
Num NodeId #
Methods (+) :: NodeId -> NodeId -> NodeId # (-) :: NodeId -> NodeId -> NodeId # (*) :: NodeId -> NodeId -> NodeId # negate :: NodeId -> NodeId # abs :: NodeId -> NodeId # signum :: NodeId -> NodeId # fromInteger :: Integer -> NodeId #
Ord NodeId #
Methods compare :: NodeId -> NodeId -> Ordering # (<) :: NodeId -> NodeId -> Bool # (<=) :: NodeId -> NodeId -> Bool # (>) :: NodeId -> NodeId -> Bool # (>=) :: NodeId -> NodeId -> Bool # max :: NodeId -> NodeId -> NodeId # min :: NodeId -> NodeId -> NodeId #
Real NodeId #
Methods toRational :: NodeId -> Rational #
Show NodeId #
Methods showsPrec :: Int -> NodeId -> ShowS # show :: NodeId -> String # showList :: [NodeId] -> ShowS #
Generic NodeId #
Associated Types type Rep NodeId :: * -> * # Methods from :: NodeId -> Rep NodeId x # to :: Rep NodeId x -> NodeId #
Deserializable NodeId #
Methods deserialize :: Get NodeId #
type Rep NodeId #
type Rep NodeId = D1 * (MetaData "NodeId" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "NodeId" PrefixI True) (S1 * (MetaSel (Just Symbol "_nodeId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

newtype Host #

Constructors

Host
Fields _hostKString :: KafkaString

Instances

Eq Host #
Methods (==) :: Host -> Host -> Bool # (/=) :: Host -> Host -> Bool #
Ord Host #
Methods compare :: Host -> Host -> Ordering # (<) :: Host -> Host -> Bool # (<=) :: Host -> Host -> Bool # (>) :: Host -> Host -> Bool # (>=) :: Host -> Host -> Bool # max :: Host -> Host -> Host # min :: Host -> Host -> Host #
Show Host #
Methods showsPrec :: Int -> Host -> ShowS # show :: Host -> String # showList :: [Host] -> ShowS #
IsString Host #
Methods fromString :: String -> Host #
Generic Host #
Associated Types type Rep Host :: * -> * # Methods from :: Host -> Rep Host x # to :: Rep Host x -> Host #
Deserializable Host #
Methods deserialize :: Get Host #
type Rep Host #
type Rep Host = D1 * (MetaData "Host" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Host" PrefixI True) (S1 * (MetaSel (Just Symbol "_hostKString") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * KafkaString)))

newtype Port #

Constructors

Port
Fields _portInt :: Int32

Instances

Enum Port #
Methods succ :: Port -> Port # pred :: Port -> Port # toEnum :: Int -> Port # fromEnum :: Port -> Int # enumFrom :: Port -> [Port] # enumFromThen :: Port -> Port -> [Port] # enumFromTo :: Port -> Port -> [Port] # enumFromThenTo :: Port -> Port -> Port -> [Port] #
Eq Port #
Methods (==) :: Port -> Port -> Bool # (/=) :: Port -> Port -> Bool #
Integral Port #
Methods quot :: Port -> Port -> Port # rem :: Port -> Port -> Port # div :: Port -> Port -> Port # mod :: Port -> Port -> Port # quotRem :: Port -> Port -> (Port, Port) # divMod :: Port -> Port -> (Port, Port) # toInteger :: Port -> Integer #
Num Port #
Methods (+) :: Port -> Port -> Port # (-) :: Port -> Port -> Port # (*) :: Port -> Port -> Port # negate :: Port -> Port # abs :: Port -> Port # signum :: Port -> Port # fromInteger :: Integer -> Port #
Ord Port #
Methods compare :: Port -> Port -> Ordering # (<) :: Port -> Port -> Bool # (<=) :: Port -> Port -> Bool # (>) :: Port -> Port -> Bool # (>=) :: Port -> Port -> Bool # max :: Port -> Port -> Port # min :: Port -> Port -> Port #
Real Port #
Methods toRational :: Port -> Rational #
Show Port #
Methods showsPrec :: Int -> Port -> ShowS # show :: Port -> String # showList :: [Port] -> ShowS #
Generic Port #
Associated Types type Rep Port :: * -> * # Methods from :: Port -> Rep Port x # to :: Rep Port x -> Port #
Deserializable Port #
Methods deserialize :: Get Port #
type Rep Port #
type Rep Port = D1 * (MetaData "Port" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Port" PrefixI True) (S1 * (MetaSel (Just Symbol "_portInt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

newtype TopicMetadata #

Constructors

TopicMetadata
Fields _topicMetadataFields :: (KafkaError, TopicName, [PartitionMetadata])

Instances

Eq TopicMetadata #
Methods (==) :: TopicMetadata -> TopicMetadata -> Bool # (/=) :: TopicMetadata -> TopicMetadata -> Bool #
Show TopicMetadata #
Methods showsPrec :: Int -> TopicMetadata -> ShowS # show :: TopicMetadata -> String # showList :: [TopicMetadata] -> ShowS #
Generic TopicMetadata #
Associated Types type Rep TopicMetadata :: * -> * # Methods from :: TopicMetadata -> Rep TopicMetadata x # to :: Rep TopicMetadata x -> TopicMetadata #
Deserializable TopicMetadata #
Methods deserialize :: Get TopicMetadata #
type Rep TopicMetadata #
type Rep TopicMetadata = D1 * (MetaData "TopicMetadata" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "TopicMetadata" PrefixI True) (S1 * (MetaSel (Just Symbol "_topicMetadataFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (KafkaError, TopicName, [PartitionMetadata]))))

newtype PartitionMetadata #

Constructors

PartitionMetadata
Fields _partitionMetadataFields :: (KafkaError, Partition, Leader, Replicas, Isr)

Instances

Eq PartitionMetadata #
Methods (==) :: PartitionMetadata -> PartitionMetadata -> Bool # (/=) :: PartitionMetadata -> PartitionMetadata -> Bool #
Show PartitionMetadata #
Methods showsPrec :: Int -> PartitionMetadata -> ShowS # show :: PartitionMetadata -> String # showList :: [PartitionMetadata] -> ShowS #
Generic PartitionMetadata #
Associated Types type Rep PartitionMetadata :: * -> * # Methods from :: PartitionMetadata -> Rep PartitionMetadata x # to :: Rep PartitionMetadata x -> PartitionMetadata #
Deserializable PartitionMetadata #
Methods deserialize :: Get PartitionMetadata #
type Rep PartitionMetadata #
type Rep PartitionMetadata = D1 * (MetaData "PartitionMetadata" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "PartitionMetadata" PrefixI True) (S1 * (MetaSel (Just Symbol "_partitionMetadataFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (KafkaError, Partition, Leader, Replicas, Isr))))

newtype Leader #

Constructors

Leader
Fields _leaderId :: Maybe Int32

Instances

Eq Leader #
Methods (==) :: Leader -> Leader -> Bool # (/=) :: Leader -> Leader -> Bool #
Ord Leader #
Methods compare :: Leader -> Leader -> Ordering # (<) :: Leader -> Leader -> Bool # (<=) :: Leader -> Leader -> Bool # (>) :: Leader -> Leader -> Bool # (>=) :: Leader -> Leader -> Bool # max :: Leader -> Leader -> Leader # min :: Leader -> Leader -> Leader #
Show Leader #
Methods showsPrec :: Int -> Leader -> ShowS # show :: Leader -> String # showList :: [Leader] -> ShowS #
Generic Leader #
Associated Types type Rep Leader :: * -> * # Methods from :: Leader -> Rep Leader x # to :: Rep Leader x -> Leader #
Deserializable Leader #
Methods deserialize :: Get Leader #
type Rep Leader #
type Rep Leader = D1 * (MetaData "Leader" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Leader" PrefixI True) (S1 * (MetaSel (Just Symbol "_leaderId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (Maybe Int32))))

newtype Replicas #

Constructors

Replicas [Int32]

Instances

Eq Replicas #
Methods (==) :: Replicas -> Replicas -> Bool # (/=) :: Replicas -> Replicas -> Bool #
Show Replicas #
Methods showsPrec :: Int -> Replicas -> ShowS # show :: Replicas -> String # showList :: [Replicas] -> ShowS #
Generic Replicas #
Associated Types type Rep Replicas :: * -> * # Methods from :: Replicas -> Rep Replicas x # to :: Rep Replicas x -> Replicas #
Deserializable Replicas #
Methods deserialize :: Get Replicas #
Serializable Replicas #
Methods serialize :: Replicas -> Put #
type Rep Replicas #
type Rep Replicas = D1 * (MetaData "Replicas" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Replicas" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [Int32])))

newtype Isr #

Constructors

Isr [Int32]

Instances

Eq Isr #
Methods (==) :: Isr -> Isr -> Bool # (/=) :: Isr -> Isr -> Bool #
Show Isr #
Methods showsPrec :: Int -> Isr -> ShowS # show :: Isr -> String # showList :: [Isr] -> ShowS #
Generic Isr #
Associated Types type Rep Isr :: * -> * # Methods from :: Isr -> Rep Isr x # to :: Rep Isr x -> Isr #
Deserializable Isr #
Methods deserialize :: Get Isr #
type Rep Isr #
type Rep Isr = D1 * (MetaData "Isr" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Isr" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [Int32])))

newtype OffsetCommitResponse #

Constructors

OffsetCommitResp [(TopicName, [(Partition, KafkaError)])]

Instances

Eq OffsetCommitResponse #
Methods (==) :: OffsetCommitResponse -> OffsetCommitResponse -> Bool # (/=) :: OffsetCommitResponse -> OffsetCommitResponse -> Bool #
Show OffsetCommitResponse #
Methods showsPrec :: Int -> OffsetCommitResponse -> ShowS # show :: OffsetCommitResponse -> String # showList :: [OffsetCommitResponse] -> ShowS #
Generic OffsetCommitResponse #
Associated Types type Rep OffsetCommitResponse :: * -> * # Methods from :: OffsetCommitResponse -> Rep OffsetCommitResponse x # to :: Rep OffsetCommitResponse x -> OffsetCommitResponse #
Deserializable OffsetCommitResponse #
Methods deserialize :: Get OffsetCommitResponse #
type Rep OffsetCommitResponse #
type Rep OffsetCommitResponse = D1 * (MetaData "OffsetCommitResponse" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "OffsetCommitResp" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [(TopicName, [(Partition, KafkaError)])])))

newtype OffsetFetchResponse #

Constructors

OffsetFetchResp [(TopicName, [(Partition, Offset, Metadata, KafkaError)])]

Instances

Eq OffsetFetchResponse #
Methods (==) :: OffsetFetchResponse -> OffsetFetchResponse -> Bool # (/=) :: OffsetFetchResponse -> OffsetFetchResponse -> Bool #
Show OffsetFetchResponse #
Methods showsPrec :: Int -> OffsetFetchResponse -> ShowS # show :: OffsetFetchResponse -> String # showList :: [OffsetFetchResponse] -> ShowS #
Generic OffsetFetchResponse #
Associated Types type Rep OffsetFetchResponse :: * -> * # Methods from :: OffsetFetchResponse -> Rep OffsetFetchResponse x # to :: Rep OffsetFetchResponse x -> OffsetFetchResponse #
Deserializable OffsetFetchResponse #
Methods deserialize :: Get OffsetFetchResponse #
type Rep OffsetFetchResponse #
type Rep OffsetFetchResponse = D1 * (MetaData "OffsetFetchResponse" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "OffsetFetchResp" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [(TopicName, [(Partition, Offset, Metadata, KafkaError)])])))

newtype OffsetRequest #

Constructors

OffsetReq (ReplicaId, [(TopicName, [(Partition, Time, MaxNumberOfOffsets)])])

Instances

Eq OffsetRequest #
Methods (==) :: OffsetRequest -> OffsetRequest -> Bool # (/=) :: OffsetRequest -> OffsetRequest -> Bool #
Show OffsetRequest #
Methods showsPrec :: Int -> OffsetRequest -> ShowS # show :: OffsetRequest -> String # showList :: [OffsetRequest] -> ShowS #
Generic OffsetRequest #
Associated Types type Rep OffsetRequest :: * -> * # Methods from :: OffsetRequest -> Rep OffsetRequest x # to :: Rep OffsetRequest x -> OffsetRequest #
Serializable OffsetRequest #
Methods serialize :: OffsetRequest -> Put #
type Rep OffsetRequest #
type Rep OffsetRequest = D1 * (MetaData "OffsetRequest" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "OffsetReq" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (ReplicaId, [(TopicName, [(Partition, Time, MaxNumberOfOffsets)])]))))

newtype Time #

Constructors

Time
Fields _timeInt :: Int64

Instances

Bounded Time #
Methods minBound :: Time # maxBound :: Time #
Enum Time #
Methods succ :: Time -> Time # pred :: Time -> Time # toEnum :: Int -> Time # fromEnum :: Time -> Int # enumFrom :: Time -> [Time] # enumFromThen :: Time -> Time -> [Time] # enumFromTo :: Time -> Time -> [Time] # enumFromThenTo :: Time -> Time -> Time -> [Time] #
Eq Time #
Methods (==) :: Time -> Time -> Bool # (/=) :: Time -> Time -> Bool #
Integral Time #
Methods quot :: Time -> Time -> Time # rem :: Time -> Time -> Time # div :: Time -> Time -> Time # mod :: Time -> Time -> Time # quotRem :: Time -> Time -> (Time, Time) # divMod :: Time -> Time -> (Time, Time) # toInteger :: Time -> Integer #
Num Time #
Methods (+) :: Time -> Time -> Time # (-) :: Time -> Time -> Time # (*) :: Time -> Time -> Time # negate :: Time -> Time # abs :: Time -> Time # signum :: Time -> Time # fromInteger :: Integer -> Time #
Ord Time #
Methods compare :: Time -> Time -> Ordering # (<) :: Time -> Time -> Bool # (<=) :: Time -> Time -> Bool # (>) :: Time -> Time -> Bool # (>=) :: Time -> Time -> Bool # max :: Time -> Time -> Time # min :: Time -> Time -> Time #
Real Time #
Methods toRational :: Time -> Rational #
Show Time #
Methods showsPrec :: Int -> Time -> ShowS # show :: Time -> String # showList :: [Time] -> ShowS #
Generic Time #
Associated Types type Rep Time :: * -> * # Methods from :: Time -> Rep Time x # to :: Rep Time x -> Time #
Serializable Time #
Methods serialize :: Time -> Put #
type Rep Time #
type Rep Time = D1 * (MetaData "Time" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Time" PrefixI True) (S1 * (MetaSel (Just Symbol "_timeInt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int64)))

newtype MaxNumberOfOffsets #

Constructors

MaxNumberOfOffsets Int32

Instances

Enum MaxNumberOfOffsets #
Methods succ :: MaxNumberOfOffsets -> MaxNumberOfOffsets # pred :: MaxNumberOfOffsets -> MaxNumberOfOffsets # toEnum :: Int -> MaxNumberOfOffsets # fromEnum :: MaxNumberOfOffsets -> Int # enumFrom :: MaxNumberOfOffsets -> [MaxNumberOfOffsets] # enumFromThen :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> [MaxNumberOfOffsets] # enumFromTo :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> [MaxNumberOfOffsets] # enumFromThenTo :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets -> [MaxNumberOfOffsets] #
Eq MaxNumberOfOffsets #
Methods (==) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> Bool # (/=) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> Bool #
Integral MaxNumberOfOffsets #
Methods quot :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # rem :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # div :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # mod :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # quotRem :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> (MaxNumberOfOffsets, MaxNumberOfOffsets) # divMod :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> (MaxNumberOfOffsets, MaxNumberOfOffsets) # toInteger :: MaxNumberOfOffsets -> Integer #
Num MaxNumberOfOffsets #
Methods (+) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # (-) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # (*) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # negate :: MaxNumberOfOffsets -> MaxNumberOfOffsets # abs :: MaxNumberOfOffsets -> MaxNumberOfOffsets # signum :: MaxNumberOfOffsets -> MaxNumberOfOffsets # fromInteger :: Integer -> MaxNumberOfOffsets #
Ord MaxNumberOfOffsets #
Methods compare :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> Ordering # (<) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> Bool # (<=) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> Bool # (>) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> Bool # (>=) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> Bool # max :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # min :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets #
Real MaxNumberOfOffsets #
Methods toRational :: MaxNumberOfOffsets -> Rational #
Show MaxNumberOfOffsets #
Methods showsPrec :: Int -> MaxNumberOfOffsets -> ShowS # show :: MaxNumberOfOffsets -> String # showList :: [MaxNumberOfOffsets] -> ShowS #
Generic MaxNumberOfOffsets #
Associated Types type Rep MaxNumberOfOffsets :: * -> * # Methods from :: MaxNumberOfOffsets -> Rep MaxNumberOfOffsets x # to :: Rep MaxNumberOfOffsets x -> MaxNumberOfOffsets #
Serializable MaxNumberOfOffsets #
Methods serialize :: MaxNumberOfOffsets -> Put #
type Rep MaxNumberOfOffsets #
type Rep MaxNumberOfOffsets = D1 * (MetaData "MaxNumberOfOffsets" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "MaxNumberOfOffsets" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

newtype FetchRequest #

Constructors

FetchReq (ReplicaId, MaxWaitTime, MinBytes, [(TopicName, [(Partition, Offset, MaxBytes)])])

Instances

Eq FetchRequest #
Methods (==) :: FetchRequest -> FetchRequest -> Bool # (/=) :: FetchRequest -> FetchRequest -> Bool #
Show FetchRequest #
Methods showsPrec :: Int -> FetchRequest -> ShowS # show :: FetchRequest -> String # showList :: [FetchRequest] -> ShowS #
Generic FetchRequest #
Associated Types type Rep FetchRequest :: * -> * # Methods from :: FetchRequest -> Rep FetchRequest x # to :: Rep FetchRequest x -> FetchRequest #
Deserializable FetchRequest #
Methods deserialize :: Get FetchRequest #
Serializable FetchRequest #
Methods serialize :: FetchRequest -> Put #
type Rep FetchRequest #
type Rep FetchRequest = D1 * (MetaData "FetchRequest" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "FetchReq" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (ReplicaId, MaxWaitTime, MinBytes, [(TopicName, [(Partition, Offset, MaxBytes)])]))))

newtype ReplicaId #

Constructors

ReplicaId Int32

Instances

Enum ReplicaId #
Methods succ :: ReplicaId -> ReplicaId # pred :: ReplicaId -> ReplicaId # toEnum :: Int -> ReplicaId # fromEnum :: ReplicaId -> Int # enumFrom :: ReplicaId -> [ReplicaId] # enumFromThen :: ReplicaId -> ReplicaId -> [ReplicaId] # enumFromTo :: ReplicaId -> ReplicaId -> [ReplicaId] # enumFromThenTo :: ReplicaId -> ReplicaId -> ReplicaId -> [ReplicaId] #
Eq ReplicaId #
Methods (==) :: ReplicaId -> ReplicaId -> Bool # (/=) :: ReplicaId -> ReplicaId -> Bool #
Integral ReplicaId #
Methods quot :: ReplicaId -> ReplicaId -> ReplicaId # rem :: ReplicaId -> ReplicaId -> ReplicaId # div :: ReplicaId -> ReplicaId -> ReplicaId # mod :: ReplicaId -> ReplicaId -> ReplicaId # quotRem :: ReplicaId -> ReplicaId -> (ReplicaId, ReplicaId) # divMod :: ReplicaId -> ReplicaId -> (ReplicaId, ReplicaId) # toInteger :: ReplicaId -> Integer #
Num ReplicaId #
Methods (+) :: ReplicaId -> ReplicaId -> ReplicaId # (-) :: ReplicaId -> ReplicaId -> ReplicaId # (*) :: ReplicaId -> ReplicaId -> ReplicaId # negate :: ReplicaId -> ReplicaId # abs :: ReplicaId -> ReplicaId # signum :: ReplicaId -> ReplicaId # fromInteger :: Integer -> ReplicaId #
Ord ReplicaId #
Methods compare :: ReplicaId -> ReplicaId -> Ordering # (<) :: ReplicaId -> ReplicaId -> Bool # (<=) :: ReplicaId -> ReplicaId -> Bool # (>) :: ReplicaId -> ReplicaId -> Bool # (>=) :: ReplicaId -> ReplicaId -> Bool # max :: ReplicaId -> ReplicaId -> ReplicaId # min :: ReplicaId -> ReplicaId -> ReplicaId #
Real ReplicaId #
Methods toRational :: ReplicaId -> Rational #
Show ReplicaId #
Methods showsPrec :: Int -> ReplicaId -> ShowS # show :: ReplicaId -> String # showList :: [ReplicaId] -> ShowS #
Generic ReplicaId #
Associated Types type Rep ReplicaId :: * -> * # Methods from :: ReplicaId -> Rep ReplicaId x # to :: Rep ReplicaId x -> ReplicaId #
Deserializable ReplicaId #
Methods deserialize :: Get ReplicaId #
Serializable ReplicaId #
Methods serialize :: ReplicaId -> Put #
type Rep ReplicaId #
type Rep ReplicaId = D1 * (MetaData "ReplicaId" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "ReplicaId" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

newtype MaxWaitTime #

Constructors

MaxWaitTime Int32

Instances

Enum MaxWaitTime #
Methods succ :: MaxWaitTime -> MaxWaitTime # pred :: MaxWaitTime -> MaxWaitTime # toEnum :: Int -> MaxWaitTime # fromEnum :: MaxWaitTime -> Int # enumFrom :: MaxWaitTime -> [MaxWaitTime] # enumFromThen :: MaxWaitTime -> MaxWaitTime -> [MaxWaitTime] # enumFromTo :: MaxWaitTime -> MaxWaitTime -> [MaxWaitTime] # enumFromThenTo :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime -> [MaxWaitTime] #
Eq MaxWaitTime #
Methods (==) :: MaxWaitTime -> MaxWaitTime -> Bool # (/=) :: MaxWaitTime -> MaxWaitTime -> Bool #
Integral MaxWaitTime #
Methods quot :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # rem :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # div :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # mod :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # quotRem :: MaxWaitTime -> MaxWaitTime -> (MaxWaitTime, MaxWaitTime) # divMod :: MaxWaitTime -> MaxWaitTime -> (MaxWaitTime, MaxWaitTime) # toInteger :: MaxWaitTime -> Integer #
Num MaxWaitTime #
Methods (+) :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # (-) :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # (*) :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # negate :: MaxWaitTime -> MaxWaitTime # abs :: MaxWaitTime -> MaxWaitTime # signum :: MaxWaitTime -> MaxWaitTime # fromInteger :: Integer -> MaxWaitTime #
Ord MaxWaitTime #
Methods compare :: MaxWaitTime -> MaxWaitTime -> Ordering # (<) :: MaxWaitTime -> MaxWaitTime -> Bool # (<=) :: MaxWaitTime -> MaxWaitTime -> Bool # (>) :: MaxWaitTime -> MaxWaitTime -> Bool # (>=) :: MaxWaitTime -> MaxWaitTime -> Bool # max :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # min :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime #
Real MaxWaitTime #
Methods toRational :: MaxWaitTime -> Rational #
Show MaxWaitTime #
Methods showsPrec :: Int -> MaxWaitTime -> ShowS # show :: MaxWaitTime -> String # showList :: [MaxWaitTime] -> ShowS #
Generic MaxWaitTime #
Associated Types type Rep MaxWaitTime :: * -> * # Methods from :: MaxWaitTime -> Rep MaxWaitTime x # to :: Rep MaxWaitTime x -> MaxWaitTime #
Deserializable MaxWaitTime #
Methods deserialize :: Get MaxWaitTime #
Serializable MaxWaitTime #
Methods serialize :: MaxWaitTime -> Put #
type Rep MaxWaitTime #
type Rep MaxWaitTime = D1 * (MetaData "MaxWaitTime" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "MaxWaitTime" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

newtype MinBytes #

Constructors

MinBytes Int32

Instances

Enum MinBytes #
Methods succ :: MinBytes -> MinBytes # pred :: MinBytes -> MinBytes # toEnum :: Int -> MinBytes # fromEnum :: MinBytes -> Int # enumFrom :: MinBytes -> [MinBytes] # enumFromThen :: MinBytes -> MinBytes -> [MinBytes] # enumFromTo :: MinBytes -> MinBytes -> [MinBytes] # enumFromThenTo :: MinBytes -> MinBytes -> MinBytes -> [MinBytes] #
Eq MinBytes #
Methods (==) :: MinBytes -> MinBytes -> Bool # (/=) :: MinBytes -> MinBytes -> Bool #
Integral MinBytes #
Methods quot :: MinBytes -> MinBytes -> MinBytes # rem :: MinBytes -> MinBytes -> MinBytes # div :: MinBytes -> MinBytes -> MinBytes # mod :: MinBytes -> MinBytes -> MinBytes # quotRem :: MinBytes -> MinBytes -> (MinBytes, MinBytes) # divMod :: MinBytes -> MinBytes -> (MinBytes, MinBytes) # toInteger :: MinBytes -> Integer #
Num MinBytes #
Methods (+) :: MinBytes -> MinBytes -> MinBytes # (-) :: MinBytes -> MinBytes -> MinBytes # (*) :: MinBytes -> MinBytes -> MinBytes # negate :: MinBytes -> MinBytes # abs :: MinBytes -> MinBytes # signum :: MinBytes -> MinBytes # fromInteger :: Integer -> MinBytes #
Ord MinBytes #
Methods compare :: MinBytes -> MinBytes -> Ordering # (<) :: MinBytes -> MinBytes -> Bool # (<=) :: MinBytes -> MinBytes -> Bool # (>) :: MinBytes -> MinBytes -> Bool # (>=) :: MinBytes -> MinBytes -> Bool # max :: MinBytes -> MinBytes -> MinBytes # min :: MinBytes -> MinBytes -> MinBytes #
Real MinBytes #
Methods toRational :: MinBytes -> Rational #
Show MinBytes #
Methods showsPrec :: Int -> MinBytes -> ShowS # show :: MinBytes -> String # showList :: [MinBytes] -> ShowS #
Generic MinBytes #
Associated Types type Rep MinBytes :: * -> * # Methods from :: MinBytes -> Rep MinBytes x # to :: Rep MinBytes x -> MinBytes #
Deserializable MinBytes #
Methods deserialize :: Get MinBytes #
Serializable MinBytes #
Methods serialize :: MinBytes -> Put #
type Rep MinBytes #
type Rep MinBytes = D1 * (MetaData "MinBytes" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "MinBytes" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

newtype MaxBytes #

Constructors

MaxBytes Int32

Instances

Enum MaxBytes #
Methods succ :: MaxBytes -> MaxBytes # pred :: MaxBytes -> MaxBytes # toEnum :: Int -> MaxBytes # fromEnum :: MaxBytes -> Int # enumFrom :: MaxBytes -> [MaxBytes] # enumFromThen :: MaxBytes -> MaxBytes -> [MaxBytes] # enumFromTo :: MaxBytes -> MaxBytes -> [MaxBytes] # enumFromThenTo :: MaxBytes -> MaxBytes -> MaxBytes -> [MaxBytes] #
Eq MaxBytes #
Methods (==) :: MaxBytes -> MaxBytes -> Bool # (/=) :: MaxBytes -> MaxBytes -> Bool #
Integral MaxBytes #
Methods quot :: MaxBytes -> MaxBytes -> MaxBytes # rem :: MaxBytes -> MaxBytes -> MaxBytes # div :: MaxBytes -> MaxBytes -> MaxBytes # mod :: MaxBytes -> MaxBytes -> MaxBytes # quotRem :: MaxBytes -> MaxBytes -> (MaxBytes, MaxBytes) # divMod :: MaxBytes -> MaxBytes -> (MaxBytes, MaxBytes) # toInteger :: MaxBytes -> Integer #
Num MaxBytes #
Methods (+) :: MaxBytes -> MaxBytes -> MaxBytes # (-) :: MaxBytes -> MaxBytes -> MaxBytes # (*) :: MaxBytes -> MaxBytes -> MaxBytes # negate :: MaxBytes -> MaxBytes # abs :: MaxBytes -> MaxBytes # signum :: MaxBytes -> MaxBytes # fromInteger :: Integer -> MaxBytes #
Ord MaxBytes #
Methods compare :: MaxBytes -> MaxBytes -> Ordering # (<) :: MaxBytes -> MaxBytes -> Bool # (<=) :: MaxBytes -> MaxBytes -> Bool # (>) :: MaxBytes -> MaxBytes -> Bool # (>=) :: MaxBytes -> MaxBytes -> Bool # max :: MaxBytes -> MaxBytes -> MaxBytes # min :: MaxBytes -> MaxBytes -> MaxBytes #
Real MaxBytes #
Methods toRational :: MaxBytes -> Rational #
Show MaxBytes #
Methods showsPrec :: Int -> MaxBytes -> ShowS # show :: MaxBytes -> String # showList :: [MaxBytes] -> ShowS #
Generic MaxBytes #
Associated Types type Rep MaxBytes :: * -> * # Methods from :: MaxBytes -> Rep MaxBytes x # to :: Rep MaxBytes x -> MaxBytes #
Deserializable MaxBytes #
Methods deserialize :: Get MaxBytes #
Serializable MaxBytes #
Methods serialize :: MaxBytes -> Put #
type Rep MaxBytes #
type Rep MaxBytes = D1 * (MetaData "MaxBytes" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "MaxBytes" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

newtype ProduceRequest #

Constructors

ProduceReq (RequiredAcks, Timeout, [(TopicName, [(Partition, MessageSet)])])

Instances

Eq ProduceRequest #
Methods (==) :: ProduceRequest -> ProduceRequest -> Bool # (/=) :: ProduceRequest -> ProduceRequest -> Bool #
Show ProduceRequest #
Methods showsPrec :: Int -> ProduceRequest -> ShowS # show :: ProduceRequest -> String # showList :: [ProduceRequest] -> ShowS #
Generic ProduceRequest #
Associated Types type Rep ProduceRequest :: * -> * # Methods from :: ProduceRequest -> Rep ProduceRequest x # to :: Rep ProduceRequest x -> ProduceRequest #
Serializable ProduceRequest #
Methods serialize :: ProduceRequest -> Put #
type Rep ProduceRequest #
type Rep ProduceRequest = D1 * (MetaData "ProduceRequest" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "ProduceReq" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (RequiredAcks, Timeout, [(TopicName, [(Partition, MessageSet)])]))))

newtype RequiredAcks #

Constructors

RequiredAcks Int16

Instances

Enum RequiredAcks #
Methods succ :: RequiredAcks -> RequiredAcks # pred :: RequiredAcks -> RequiredAcks # toEnum :: Int -> RequiredAcks # fromEnum :: RequiredAcks -> Int # enumFrom :: RequiredAcks -> [RequiredAcks] # enumFromThen :: RequiredAcks -> RequiredAcks -> [RequiredAcks] # enumFromTo :: RequiredAcks -> RequiredAcks -> [RequiredAcks] # enumFromThenTo :: RequiredAcks -> RequiredAcks -> RequiredAcks -> [RequiredAcks] #
Eq RequiredAcks #
Methods (==) :: RequiredAcks -> RequiredAcks -> Bool # (/=) :: RequiredAcks -> RequiredAcks -> Bool #
Integral RequiredAcks #
Methods quot :: RequiredAcks -> RequiredAcks -> RequiredAcks # rem :: RequiredAcks -> RequiredAcks -> RequiredAcks # div :: RequiredAcks -> RequiredAcks -> RequiredAcks # mod :: RequiredAcks -> RequiredAcks -> RequiredAcks # quotRem :: RequiredAcks -> RequiredAcks -> (RequiredAcks, RequiredAcks) # divMod :: RequiredAcks -> RequiredAcks -> (RequiredAcks, RequiredAcks) # toInteger :: RequiredAcks -> Integer #
Num RequiredAcks #
Methods (+) :: RequiredAcks -> RequiredAcks -> RequiredAcks # (-) :: RequiredAcks -> RequiredAcks -> RequiredAcks # (*) :: RequiredAcks -> RequiredAcks -> RequiredAcks # negate :: RequiredAcks -> RequiredAcks # abs :: RequiredAcks -> RequiredAcks # signum :: RequiredAcks -> RequiredAcks # fromInteger :: Integer -> RequiredAcks #
Ord RequiredAcks #
Methods compare :: RequiredAcks -> RequiredAcks -> Ordering # (<) :: RequiredAcks -> RequiredAcks -> Bool # (<=) :: RequiredAcks -> RequiredAcks -> Bool # (>) :: RequiredAcks -> RequiredAcks -> Bool # (>=) :: RequiredAcks -> RequiredAcks -> Bool # max :: RequiredAcks -> RequiredAcks -> RequiredAcks # min :: RequiredAcks -> RequiredAcks -> RequiredAcks #
Real RequiredAcks #
Methods toRational :: RequiredAcks -> Rational #
Show RequiredAcks #
Methods showsPrec :: Int -> RequiredAcks -> ShowS # show :: RequiredAcks -> String # showList :: [RequiredAcks] -> ShowS #
Generic RequiredAcks #
Associated Types type Rep RequiredAcks :: * -> * # Methods from :: RequiredAcks -> Rep RequiredAcks x # to :: Rep RequiredAcks x -> RequiredAcks #
Deserializable RequiredAcks #
Methods deserialize :: Get RequiredAcks #
Serializable RequiredAcks #
Methods serialize :: RequiredAcks -> Put #
type Rep RequiredAcks #
type Rep RequiredAcks = D1 * (MetaData "RequiredAcks" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "RequiredAcks" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int16)))

newtype Timeout #

Constructors

Timeout Int32

Instances

Enum Timeout #
Methods succ :: Timeout -> Timeout # pred :: Timeout -> Timeout # toEnum :: Int -> Timeout # fromEnum :: Timeout -> Int # enumFrom :: Timeout -> [Timeout] # enumFromThen :: Timeout -> Timeout -> [Timeout] # enumFromTo :: Timeout -> Timeout -> [Timeout] # enumFromThenTo :: Timeout -> Timeout -> Timeout -> [Timeout] #
Eq Timeout #
Methods (==) :: Timeout -> Timeout -> Bool # (/=) :: Timeout -> Timeout -> Bool #
Integral Timeout #
Methods quot :: Timeout -> Timeout -> Timeout # rem :: Timeout -> Timeout -> Timeout # div :: Timeout -> Timeout -> Timeout # mod :: Timeout -> Timeout -> Timeout # quotRem :: Timeout -> Timeout -> (Timeout, Timeout) # divMod :: Timeout -> Timeout -> (Timeout, Timeout) # toInteger :: Timeout -> Integer #
Num Timeout #
Methods (+) :: Timeout -> Timeout -> Timeout # (-) :: Timeout -> Timeout -> Timeout # (*) :: Timeout -> Timeout -> Timeout # negate :: Timeout -> Timeout # abs :: Timeout -> Timeout # signum :: Timeout -> Timeout # fromInteger :: Integer -> Timeout #
Ord Timeout #
Methods compare :: Timeout -> Timeout -> Ordering # (<) :: Timeout -> Timeout -> Bool # (<=) :: Timeout -> Timeout -> Bool # (>) :: Timeout -> Timeout -> Bool # (>=) :: Timeout -> Timeout -> Bool # max :: Timeout -> Timeout -> Timeout # min :: Timeout -> Timeout -> Timeout #
Real Timeout #
Methods toRational :: Timeout -> Rational #
Show Timeout #
Methods showsPrec :: Int -> Timeout -> ShowS # show :: Timeout -> String # showList :: [Timeout] -> ShowS #
Generic Timeout #
Associated Types type Rep Timeout :: * -> * # Methods from :: Timeout -> Rep Timeout x # to :: Rep Timeout x -> Timeout #
Deserializable Timeout #
Methods deserialize :: Get Timeout #
Serializable Timeout #
Methods serialize :: Timeout -> Put #
type Rep Timeout #
type Rep Timeout = D1 * (MetaData "Timeout" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Timeout" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

newtype Partition #

Constructors

Partition Int32

Instances

Enum Partition #
Methods succ :: Partition -> Partition # pred :: Partition -> Partition # toEnum :: Int -> Partition # fromEnum :: Partition -> Int # enumFrom :: Partition -> [Partition] # enumFromThen :: Partition -> Partition -> [Partition] # enumFromTo :: Partition -> Partition -> [Partition] # enumFromThenTo :: Partition -> Partition -> Partition -> [Partition] #
Eq Partition #
Methods (==) :: Partition -> Partition -> Bool # (/=) :: Partition -> Partition -> Bool #
Integral Partition #
Methods quot :: Partition -> Partition -> Partition # rem :: Partition -> Partition -> Partition # div :: Partition -> Partition -> Partition # mod :: Partition -> Partition -> Partition # quotRem :: Partition -> Partition -> (Partition, Partition) # divMod :: Partition -> Partition -> (Partition, Partition) # toInteger :: Partition -> Integer #
Num Partition #
Methods (+) :: Partition -> Partition -> Partition # (-) :: Partition -> Partition -> Partition # (*) :: Partition -> Partition -> Partition # negate :: Partition -> Partition # abs :: Partition -> Partition # signum :: Partition -> Partition # fromInteger :: Integer -> Partition #
Ord Partition #
Methods compare :: Partition -> Partition -> Ordering # (<) :: Partition -> Partition -> Bool # (<=) :: Partition -> Partition -> Bool # (>) :: Partition -> Partition -> Bool # (>=) :: Partition -> Partition -> Bool # max :: Partition -> Partition -> Partition # min :: Partition -> Partition -> Partition #
Real Partition #
Methods toRational :: Partition -> Rational #
Show Partition #
Methods showsPrec :: Int -> Partition -> ShowS # show :: Partition -> String # showList :: [Partition] -> ShowS #
Generic Partition #
Associated Types type Rep Partition :: * -> * # Methods from :: Partition -> Rep Partition x # to :: Rep Partition x -> Partition #
Deserializable Partition #
Methods deserialize :: Get Partition #
Serializable Partition #
Methods serialize :: Partition -> Put #
type Rep Partition #
type Rep Partition = D1 * (MetaData "Partition" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Partition" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

data MessageSet #

Constructors

MessageSet
Fields _codec :: CompressionCodec _messageSetMembers :: [MessageSetMember]

Instances

Eq MessageSet #
Methods (==) :: MessageSet -> MessageSet -> Bool # (/=) :: MessageSet -> MessageSet -> Bool #
Show MessageSet #
Methods showsPrec :: Int -> MessageSet -> ShowS # show :: MessageSet -> String # showList :: [MessageSet] -> ShowS #
Generic MessageSet #
Associated Types type Rep MessageSet :: * -> * # Methods from :: MessageSet -> Rep MessageSet x # to :: Rep MessageSet x -> MessageSet #
Deserializable MessageSet #
Methods deserialize :: Get MessageSet #
Serializable MessageSet #
Methods serialize :: MessageSet -> Put #
type Rep MessageSet #
type Rep MessageSet = D1 * (MetaData "MessageSet" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" False) (C1 * (MetaCons "MessageSet" PrefixI True) ((::) (S1 * (MetaSel (Just Symbol "_codec") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * CompressionCodec)) (S1 * (MetaSel (Just Symbol "_messageSetMembers") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * [MessageSetMember]))))

data MessageSetMember #

Constructors

MessageSetMember
Fields _setOffset :: Offset _setMessage :: Message

Instances

Eq MessageSetMember #
Methods (==) :: MessageSetMember -> MessageSetMember -> Bool # (/=) :: MessageSetMember -> MessageSetMember -> Bool #
Show MessageSetMember #
Methods showsPrec :: Int -> MessageSetMember -> ShowS # show :: MessageSetMember -> String # showList :: [MessageSetMember] -> ShowS #
Generic MessageSetMember #
Associated Types type Rep MessageSetMember :: * -> * # Methods from :: MessageSetMember -> Rep MessageSetMember x # to :: Rep MessageSetMember x -> MessageSetMember #
Deserializable MessageSetMember #
Methods deserialize :: Get MessageSetMember #
Serializable MessageSetMember #
Methods serialize :: MessageSetMember -> Put #
type Rep MessageSetMember #
type Rep MessageSetMember = D1 * (MetaData "MessageSetMember" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" False) (C1 * (MetaCons "MessageSetMember" PrefixI True) ((::) (S1 * (MetaSel (Just Symbol "_setOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Offset)) (S1 * (MetaSel (Just Symbol "_setMessage") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Message))))

newtype Offset #

Constructors

Offset Int64

Instances

Enum Offset #
Methods succ :: Offset -> Offset # pred :: Offset -> Offset # toEnum :: Int -> Offset # fromEnum :: Offset -> Int # enumFrom :: Offset -> [Offset] # enumFromThen :: Offset -> Offset -> [Offset] # enumFromTo :: Offset -> Offset -> [Offset] # enumFromThenTo :: Offset -> Offset -> Offset -> [Offset] #
Eq Offset #
Methods (==) :: Offset -> Offset -> Bool # (/=) :: Offset -> Offset -> Bool #
Integral Offset #
Methods quot :: Offset -> Offset -> Offset # rem :: Offset -> Offset -> Offset # div :: Offset -> Offset -> Offset # mod :: Offset -> Offset -> Offset # quotRem :: Offset -> Offset -> (Offset, Offset) # divMod :: Offset -> Offset -> (Offset, Offset) # toInteger :: Offset -> Integer #
Num Offset #
Methods (+) :: Offset -> Offset -> Offset # (-) :: Offset -> Offset -> Offset # (*) :: Offset -> Offset -> Offset # negate :: Offset -> Offset # abs :: Offset -> Offset # signum :: Offset -> Offset # fromInteger :: Integer -> Offset #
Ord Offset #
Methods compare :: Offset -> Offset -> Ordering # (<) :: Offset -> Offset -> Bool # (<=) :: Offset -> Offset -> Bool # (>) :: Offset -> Offset -> Bool # (>=) :: Offset -> Offset -> Bool # max :: Offset -> Offset -> Offset # min :: Offset -> Offset -> Offset #
Real Offset #
Methods toRational :: Offset -> Rational #
Show Offset #
Methods showsPrec :: Int -> Offset -> ShowS # show :: Offset -> String # showList :: [Offset] -> ShowS #
Generic Offset #
Associated Types type Rep Offset :: * -> * # Methods from :: Offset -> Rep Offset x # to :: Rep Offset x -> Offset #
Deserializable Offset #
Methods deserialize :: Get Offset #
Serializable Offset #
Methods serialize :: Offset -> Put #
type Rep Offset #
type Rep Offset = D1 * (MetaData "Offset" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Offset" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int64)))

newtype Message #

Constructors

Message
Fields _messageFields :: (Crc, MagicByte, Attributes, Key, Value)

Instances

Eq Message #
Methods (==) :: Message -> Message -> Bool # (/=) :: Message -> Message -> Bool #
Show Message #
Methods showsPrec :: Int -> Message -> ShowS # show :: Message -> String # showList :: [Message] -> ShowS #
Generic Message #
Associated Types type Rep Message :: * -> * # Methods from :: Message -> Rep Message x # to :: Rep Message x -> Message #
Deserializable Message #
Methods deserialize :: Get Message #
Serializable Message #
Methods serialize :: Message -> Put #
type Rep Message #
type Rep Message = D1 * (MetaData "Message" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Message" PrefixI True) (S1 * (MetaSel (Just Symbol "_messageFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (Crc, MagicByte, Attributes, Key, Value))))

data CompressionCodec #

Constructors

NoCompression
Gzip

Instances

Eq CompressionCodec #
Methods (==) :: CompressionCodec -> CompressionCodec -> Bool # (/=) :: CompressionCodec -> CompressionCodec -> Bool #
Show CompressionCodec #
Methods showsPrec :: Int -> CompressionCodec -> ShowS # show :: CompressionCodec -> String # showList :: [CompressionCodec] -> ShowS #
Generic CompressionCodec #
Associated Types type Rep CompressionCodec :: * -> * # Methods from :: CompressionCodec -> Rep CompressionCodec x # to :: Rep CompressionCodec x -> CompressionCodec #
type Rep CompressionCodec #
type Rep CompressionCodec = D1 * (MetaData "CompressionCodec" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" False) ((:+:) * (C1 * (MetaCons "NoCompression" PrefixI False) (U1 )) (C1 (MetaCons "Gzip" PrefixI False) (U1 *)))

newtype Crc #

Constructors

Crc Int32

Instances

Enum Crc #
Methods succ :: Crc -> Crc # pred :: Crc -> Crc # toEnum :: Int -> Crc # fromEnum :: Crc -> Int # enumFrom :: Crc -> [Crc] # enumFromThen :: Crc -> Crc -> [Crc] # enumFromTo :: Crc -> Crc -> [Crc] # enumFromThenTo :: Crc -> Crc -> Crc -> [Crc] #
Eq Crc #
Methods (==) :: Crc -> Crc -> Bool # (/=) :: Crc -> Crc -> Bool #
Integral Crc #
Methods quot :: Crc -> Crc -> Crc # rem :: Crc -> Crc -> Crc # div :: Crc -> Crc -> Crc # mod :: Crc -> Crc -> Crc # quotRem :: Crc -> Crc -> (Crc, Crc) # divMod :: Crc -> Crc -> (Crc, Crc) # toInteger :: Crc -> Integer #
Num Crc #
Methods (+) :: Crc -> Crc -> Crc # (-) :: Crc -> Crc -> Crc # (*) :: Crc -> Crc -> Crc # negate :: Crc -> Crc # abs :: Crc -> Crc # signum :: Crc -> Crc # fromInteger :: Integer -> Crc #
Ord Crc #
Methods compare :: Crc -> Crc -> Ordering # (<) :: Crc -> Crc -> Bool # (<=) :: Crc -> Crc -> Bool # (>) :: Crc -> Crc -> Bool # (>=) :: Crc -> Crc -> Bool # max :: Crc -> Crc -> Crc # min :: Crc -> Crc -> Crc #
Real Crc #
Methods toRational :: Crc -> Rational #
Show Crc #
Methods showsPrec :: Int -> Crc -> ShowS # show :: Crc -> String # showList :: [Crc] -> ShowS #
Generic Crc #
Associated Types type Rep Crc :: * -> * # Methods from :: Crc -> Rep Crc x # to :: Rep Crc x -> Crc #
Deserializable Crc #
Methods deserialize :: Get Crc #
Serializable Crc #
Methods serialize :: Crc -> Put #
type Rep Crc #
type Rep Crc = D1 * (MetaData "Crc" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Crc" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int32)))

newtype MagicByte #

Constructors

MagicByte Int8

Instances

Enum MagicByte #
Methods succ :: MagicByte -> MagicByte # pred :: MagicByte -> MagicByte # toEnum :: Int -> MagicByte # fromEnum :: MagicByte -> Int # enumFrom :: MagicByte -> [MagicByte] # enumFromThen :: MagicByte -> MagicByte -> [MagicByte] # enumFromTo :: MagicByte -> MagicByte -> [MagicByte] # enumFromThenTo :: MagicByte -> MagicByte -> MagicByte -> [MagicByte] #
Eq MagicByte #
Methods (==) :: MagicByte -> MagicByte -> Bool # (/=) :: MagicByte -> MagicByte -> Bool #
Integral MagicByte #
Methods quot :: MagicByte -> MagicByte -> MagicByte # rem :: MagicByte -> MagicByte -> MagicByte # div :: MagicByte -> MagicByte -> MagicByte # mod :: MagicByte -> MagicByte -> MagicByte # quotRem :: MagicByte -> MagicByte -> (MagicByte, MagicByte) # divMod :: MagicByte -> MagicByte -> (MagicByte, MagicByte) # toInteger :: MagicByte -> Integer #
Num MagicByte #
Methods (+) :: MagicByte -> MagicByte -> MagicByte # (-) :: MagicByte -> MagicByte -> MagicByte # (*) :: MagicByte -> MagicByte -> MagicByte # negate :: MagicByte -> MagicByte # abs :: MagicByte -> MagicByte # signum :: MagicByte -> MagicByte # fromInteger :: Integer -> MagicByte #
Ord MagicByte #
Methods compare :: MagicByte -> MagicByte -> Ordering # (<) :: MagicByte -> MagicByte -> Bool # (<=) :: MagicByte -> MagicByte -> Bool # (>) :: MagicByte -> MagicByte -> Bool # (>=) :: MagicByte -> MagicByte -> Bool # max :: MagicByte -> MagicByte -> MagicByte # min :: MagicByte -> MagicByte -> MagicByte #
Real MagicByte #
Methods toRational :: MagicByte -> Rational #
Show MagicByte #
Methods showsPrec :: Int -> MagicByte -> ShowS # show :: MagicByte -> String # showList :: [MagicByte] -> ShowS #
Generic MagicByte #
Associated Types type Rep MagicByte :: * -> * # Methods from :: MagicByte -> Rep MagicByte x # to :: Rep MagicByte x -> MagicByte #
Deserializable MagicByte #
Methods deserialize :: Get MagicByte #
Serializable MagicByte #
Methods serialize :: MagicByte -> Put #
type Rep MagicByte #
type Rep MagicByte = D1 * (MetaData "MagicByte" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "MagicByte" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int8)))

data Attributes #

Constructors

Attributes
Fields _compressionCodec :: CompressionCodec

Instances

Eq Attributes #
Methods (==) :: Attributes -> Attributes -> Bool # (/=) :: Attributes -> Attributes -> Bool #
Show Attributes #
Methods showsPrec :: Int -> Attributes -> ShowS # show :: Attributes -> String # showList :: [Attributes] -> ShowS #
Generic Attributes #
Associated Types type Rep Attributes :: * -> * # Methods from :: Attributes -> Rep Attributes x # to :: Rep Attributes x -> Attributes #
Deserializable Attributes #
Methods deserialize :: Get Attributes #
Serializable Attributes #
Methods serialize :: Attributes -> Put #
type Rep Attributes #
type Rep Attributes = D1 * (MetaData "Attributes" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" False) (C1 * (MetaCons "Attributes" PrefixI True) (S1 * (MetaSel (Just Symbol "_compressionCodec") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * CompressionCodec)))

newtype Key #

Constructors

Key
Fields _keyBytes :: Maybe KafkaBytes

Instances

Eq Key #
Methods (==) :: Key -> Key -> Bool # (/=) :: Key -> Key -> Bool #
Show Key #
Methods showsPrec :: Int -> Key -> ShowS # show :: Key -> String # showList :: [Key] -> ShowS #
Generic Key #
Associated Types type Rep Key :: * -> * # Methods from :: Key -> Rep Key x # to :: Rep Key x -> Key #
Deserializable Key #
Methods deserialize :: Get Key #
Serializable Key #
Methods serialize :: Key -> Put #
type Rep Key #
type Rep Key = D1 * (MetaData "Key" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Key" PrefixI True) (S1 * (MetaSel (Just Symbol "_keyBytes") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (Maybe KafkaBytes))))

newtype Value #

Constructors

Value
Fields _valueBytes :: Maybe KafkaBytes

Instances

Eq Value #
Methods (==) :: Value -> Value -> Bool # (/=) :: Value -> Value -> Bool #
Show Value #
Methods showsPrec :: Int -> Value -> ShowS # show :: Value -> String # showList :: [Value] -> ShowS #
Generic Value #
Associated Types type Rep Value :: * -> * # Methods from :: Value -> Rep Value x # to :: Rep Value x -> Value #
Deserializable Value #
Methods deserialize :: Get Value #
Serializable Value #
Methods serialize :: Value -> Put #
type Rep Value #
type Rep Value = D1 * (MetaData "Value" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Value" PrefixI True) (S1 * (MetaSel (Just Symbol "_valueBytes") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (Maybe KafkaBytes))))

data ResponseMessage #

Constructors

MetadataResponse MetadataResponse
ProduceResponse ProduceResponse
FetchResponse FetchResponse
OffsetResponse OffsetResponse
OffsetCommitResponse OffsetCommitResponse
OffsetFetchResponse OffsetFetchResponse
GroupCoordinatorResponse GroupCoordinatorResponse

Instances

Eq ResponseMessage #
Methods (==) :: ResponseMessage -> ResponseMessage -> Bool # (/=) :: ResponseMessage -> ResponseMessage -> Bool #
Show ResponseMessage #
Methods showsPrec :: Int -> ResponseMessage -> ShowS # show :: ResponseMessage -> String # showList :: [ResponseMessage] -> ShowS #
Generic ResponseMessage #
Associated Types type Rep ResponseMessage :: * -> * # Methods from :: ResponseMessage -> Rep ResponseMessage x # to :: Rep ResponseMessage x -> ResponseMessage #
type Rep ResponseMessage #
type Rep ResponseMessage = D1 * (MetaData "ResponseMessage" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" False) ((:+:) * ((:+:) * (C1 * (MetaCons "MetadataResponse" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * MetadataResponse))) ((:+:) * (C1 * (MetaCons "ProduceResponse" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * ProduceResponse))) (C1 * (MetaCons "FetchResponse" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * FetchResponse))))) ((:+:) * ((:+:) * (C1 * (MetaCons "OffsetResponse" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * OffsetResponse))) (C1 * (MetaCons "OffsetCommitResponse" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * OffsetCommitResponse)))) ((:+:) * (C1 * (MetaCons "OffsetFetchResponse" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * OffsetFetchResponse))) (C1 * (MetaCons "GroupCoordinatorResponse" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * GroupCoordinatorResponse))))))

newtype GroupCoordinatorRequest #

Constructors

GroupCoordinatorReq ConsumerGroup

Instances

Eq GroupCoordinatorRequest #
Methods (==) :: GroupCoordinatorRequest -> GroupCoordinatorRequest -> Bool # (/=) :: GroupCoordinatorRequest -> GroupCoordinatorRequest -> Bool #
Show GroupCoordinatorRequest #
Methods showsPrec :: Int -> GroupCoordinatorRequest -> ShowS # show :: GroupCoordinatorRequest -> String # showList :: [GroupCoordinatorRequest] -> ShowS #
Generic GroupCoordinatorRequest #
Associated Types type Rep GroupCoordinatorRequest :: * -> * # Methods from :: GroupCoordinatorRequest -> Rep GroupCoordinatorRequest x # to :: Rep GroupCoordinatorRequest x -> GroupCoordinatorRequest #
Serializable GroupCoordinatorRequest #
Methods serialize :: GroupCoordinatorRequest -> Put #
type Rep GroupCoordinatorRequest #
type Rep GroupCoordinatorRequest = D1 * (MetaData "GroupCoordinatorRequest" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "GroupCoordinatorReq" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * ConsumerGroup)))

newtype OffsetCommitRequest #

Constructors

OffsetCommitReq (ConsumerGroup, [(TopicName, [(Partition, Offset, Time, Metadata)])])

Instances

Eq OffsetCommitRequest #
Methods (==) :: OffsetCommitRequest -> OffsetCommitRequest -> Bool # (/=) :: OffsetCommitRequest -> OffsetCommitRequest -> Bool #
Show OffsetCommitRequest #
Methods showsPrec :: Int -> OffsetCommitRequest -> ShowS # show :: OffsetCommitRequest -> String # showList :: [OffsetCommitRequest] -> ShowS #
Generic OffsetCommitRequest #
Associated Types type Rep OffsetCommitRequest :: * -> * # Methods from :: OffsetCommitRequest -> Rep OffsetCommitRequest x # to :: Rep OffsetCommitRequest x -> OffsetCommitRequest #
Serializable OffsetCommitRequest #
Methods serialize :: OffsetCommitRequest -> Put #
type Rep OffsetCommitRequest #
type Rep OffsetCommitRequest = D1 * (MetaData "OffsetCommitRequest" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "OffsetCommitReq" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (ConsumerGroup, [(TopicName, [(Partition, Offset, Time, Metadata)])]))))

newtype OffsetFetchRequest #

Constructors

OffsetFetchReq (ConsumerGroup, [(TopicName, [Partition])])

Instances

Eq OffsetFetchRequest #
Methods (==) :: OffsetFetchRequest -> OffsetFetchRequest -> Bool # (/=) :: OffsetFetchRequest -> OffsetFetchRequest -> Bool #
Show OffsetFetchRequest #
Methods showsPrec :: Int -> OffsetFetchRequest -> ShowS # show :: OffsetFetchRequest -> String # showList :: [OffsetFetchRequest] -> ShowS #
Generic OffsetFetchRequest #
Associated Types type Rep OffsetFetchRequest :: * -> * # Methods from :: OffsetFetchRequest -> Rep OffsetFetchRequest x # to :: Rep OffsetFetchRequest x -> OffsetFetchRequest #
Serializable OffsetFetchRequest #
Methods serialize :: OffsetFetchRequest -> Put #
type Rep OffsetFetchRequest #
type Rep OffsetFetchRequest = D1 * (MetaData "OffsetFetchRequest" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "OffsetFetchReq" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (ConsumerGroup, [(TopicName, [Partition])]))))

newtype ConsumerGroup #

Constructors

ConsumerGroup KafkaString

Instances

Eq ConsumerGroup #
Methods (==) :: ConsumerGroup -> ConsumerGroup -> Bool # (/=) :: ConsumerGroup -> ConsumerGroup -> Bool #
Show ConsumerGroup #
Methods showsPrec :: Int -> ConsumerGroup -> ShowS # show :: ConsumerGroup -> String # showList :: [ConsumerGroup] -> ShowS #
IsString ConsumerGroup #
Methods fromString :: String -> ConsumerGroup #
Generic ConsumerGroup #
Associated Types type Rep ConsumerGroup :: * -> * # Methods from :: ConsumerGroup -> Rep ConsumerGroup x # to :: Rep ConsumerGroup x -> ConsumerGroup #
Deserializable ConsumerGroup #
Methods deserialize :: Get ConsumerGroup #
Serializable ConsumerGroup #
Methods serialize :: ConsumerGroup -> Put #
type Rep ConsumerGroup #
type Rep ConsumerGroup = D1 * (MetaData "ConsumerGroup" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "ConsumerGroup" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * KafkaString)))

newtype Metadata #

Constructors

Metadata KafkaString

Instances

Eq Metadata #
Methods (==) :: Metadata -> Metadata -> Bool # (/=) :: Metadata -> Metadata -> Bool #
Show Metadata #
Methods showsPrec :: Int -> Metadata -> ShowS # show :: Metadata -> String # showList :: [Metadata] -> ShowS #
IsString Metadata #
Methods fromString :: String -> Metadata #
Generic Metadata #
Associated Types type Rep Metadata :: * -> * # Methods from :: Metadata -> Rep Metadata x # to :: Rep Metadata x -> Metadata #
Deserializable Metadata #
Methods deserialize :: Get Metadata #
Serializable Metadata #
Methods serialize :: Metadata -> Put #
type Rep Metadata #
type Rep Metadata = D1 * (MetaData "Metadata" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Metadata" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * KafkaString)))

errorKafka :: KafkaError -> Int16 #

data KafkaError #

Constructors

NoError	`0` No error--it worked!
Unknown	`-1` An unexpected server error
OffsetOutOfRange	`1` The requested offset is outside the range of offsets maintained by the server for the given topic/partition.
InvalidMessage	`2` This indicates that a message contents does not match its CRC
UnknownTopicOrPartition	`3` This request is for a topic or partition that does not exist on this broker.
InvalidMessageSize	`4` The message has a negative size
LeaderNotAvailable	`5` This error is thrown if we are in the middle of a leadership election and there is currently no leader for this partition and hence it is unavailable for writes.
NotLeaderForPartition	`6` This error is thrown if the client attempts to send messages to a replica that is not the leader for some partition. It indicates that the clients metadata is out of date.
RequestTimedOut	`7` This error is thrown if the request exceeds the user-specified time limit in the request.
BrokerNotAvailable	`8` This is not a client facing error and is used mostly by tools when a broker is not alive.
ReplicaNotAvailable	`9` If replica is expected on a broker, but is not.
MessageSizeTooLarge	`10` The server has a configurable maximum message size to avoid unbounded memory allocation. This error is thrown if the client attempt to produce a message larger than this maximum.
StaleControllerEpochCode	`11` Internal error code for broker-to-broker communication.
OffsetMetadataTooLargeCode	`12` If you specify a string larger than configured maximum for offset metadata
OffsetsLoadInProgressCode	`14` The broker returns this error code for an offset fetch request if it is still loading offsets (after a leader change for that offsets topic partition).
ConsumerCoordinatorNotAvailableCode	`15` The broker returns this error code for consumer metadata requests or offset commit requests if the offsets topic has not yet been created.
NotCoordinatorForConsumerCode	`16` The broker returns this error code if it receives an offset fetch or commit request for a consumer group that it is not a coordinator for.

Instances

Bounded KafkaError #
Methods minBound :: KafkaError # maxBound :: KafkaError #
Enum KafkaError #
Methods succ :: KafkaError -> KafkaError # pred :: KafkaError -> KafkaError # toEnum :: Int -> KafkaError # fromEnum :: KafkaError -> Int # enumFrom :: KafkaError -> [KafkaError] # enumFromThen :: KafkaError -> KafkaError -> [KafkaError] # enumFromTo :: KafkaError -> KafkaError -> [KafkaError] # enumFromThenTo :: KafkaError -> KafkaError -> KafkaError -> [KafkaError] #
Eq KafkaError #
Methods (==) :: KafkaError -> KafkaError -> Bool # (/=) :: KafkaError -> KafkaError -> Bool #
Show KafkaError #
Methods showsPrec :: Int -> KafkaError -> ShowS # show :: KafkaError -> String # showList :: [KafkaError] -> ShowS #
Generic KafkaError #
Associated Types type Rep KafkaError :: * -> * # Methods from :: KafkaError -> Rep KafkaError x # to :: Rep KafkaError x -> KafkaError #
Exception KafkaError #
Methods toException :: KafkaError -> SomeException # fromException :: SomeException -> Maybe KafkaError # displayException :: KafkaError -> String #
Deserializable KafkaError #
Methods deserialize :: Get KafkaError #
Serializable KafkaError #
Methods serialize :: KafkaError -> Put #
type Rep KafkaError #
type Rep KafkaError = D1 * (MetaData "KafkaError" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" False) ((:+:) * ((:+:) * ((:+:) * ((:+:) * (C1 * (MetaCons "NoError" PrefixI False) (U1 )) (C1 (MetaCons "Unknown" PrefixI False) (U1 ))) ((:+:) (C1 * (MetaCons "OffsetOutOfRange" PrefixI False) (U1 )) (C1 (MetaCons "InvalidMessage" PrefixI False) (U1 )))) ((:+:) ((:+:) * (C1 * (MetaCons "UnknownTopicOrPartition" PrefixI False) (U1 )) (C1 (MetaCons "InvalidMessageSize" PrefixI False) (U1 ))) ((:+:) (C1 * (MetaCons "LeaderNotAvailable" PrefixI False) (U1 )) (C1 (MetaCons "NotLeaderForPartition" PrefixI False) (U1 ))))) ((:+:) ((:+:) * ((:+:) * (C1 * (MetaCons "RequestTimedOut" PrefixI False) (U1 )) (C1 (MetaCons "BrokerNotAvailable" PrefixI False) (U1 ))) ((:+:) (C1 * (MetaCons "ReplicaNotAvailable" PrefixI False) (U1 )) (C1 (MetaCons "MessageSizeTooLarge" PrefixI False) (U1 )))) ((:+:) ((:+:) * (C1 * (MetaCons "StaleControllerEpochCode" PrefixI False) (U1 )) (C1 (MetaCons "OffsetMetadataTooLargeCode" PrefixI False) (U1 ))) ((:+:) (C1 * (MetaCons "OffsetsLoadInProgressCode" PrefixI False) (U1 )) ((:+:) (C1 * (MetaCons "ConsumerCoordinatorNotAvailableCode" PrefixI False) (U1 )) (C1 (MetaCons "NotCoordinatorForConsumerCode" PrefixI False) (U1 *)))))))

newtype Request #

Constructors

Request (CorrelationId, ClientId, RequestMessage)

Instances

Eq Request #
Methods (==) :: Request -> Request -> Bool # (/=) :: Request -> Request -> Bool #
Show Request #
Methods showsPrec :: Int -> Request -> ShowS # show :: Request -> String # showList :: [Request] -> ShowS #
Generic Request #
Associated Types type Rep Request :: * -> * # Methods from :: Request -> Rep Request x # to :: Rep Request x -> Request #
Serializable Request #
Methods serialize :: Request -> Put #
type Rep Request #
type Rep Request = D1 * (MetaData "Request" "Network.Kafka.Protocol" "milena-0.5.2.2-Llzag1PPzlJ4hURASp2yJM" True) (C1 * (MetaCons "Request" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (CorrelationId, ClientId, RequestMessage))))