milena-0.5.3.0: A Kafka client for Haskell.

Safe HaskellNone
LanguageHaskell2010

Network.Kafka.Protocol

Documentation

newtype Request Source #

Instances
Eq Request Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Request -> Request -> Bool #

(/=) :: Request -> Request -> Bool #

Show Request Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic Request Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Request :: Type -> Type #

Methods

from :: Request -> Rep Request x #

to :: Rep Request x -> Request #

Serializable Request Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Request Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Request = D1 (MetaData "Request" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Request" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (CorrelationId, ClientId, RequestMessage))))

data KafkaError Source #

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.

TopicAlreadyExists

36 Topic with this name already exists.

UnsupportedCompressionType

76 The requesting client does not support the compression type of given partition.

Instances
Bounded KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

Enum KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

Show KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep KafkaError :: Type -> Type #

Exception KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep KafkaError = D1 (MetaData "KafkaError" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" False) ((((C1 (MetaCons "NoError" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "Unknown" PrefixI False) (U1 :: Type -> Type)) :+: (C1 (MetaCons "OffsetOutOfRange" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "InvalidMessage" PrefixI False) (U1 :: Type -> Type))) :+: ((C1 (MetaCons "UnknownTopicOrPartition" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "InvalidMessageSize" PrefixI False) (U1 :: Type -> Type)) :+: (C1 (MetaCons "LeaderNotAvailable" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "NotLeaderForPartition" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "RequestTimedOut" PrefixI False) (U1 :: Type -> Type))))) :+: (((C1 (MetaCons "BrokerNotAvailable" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "ReplicaNotAvailable" PrefixI False) (U1 :: Type -> Type)) :+: (C1 (MetaCons "MessageSizeTooLarge" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "StaleControllerEpochCode" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "OffsetMetadataTooLargeCode" PrefixI False) (U1 :: Type -> Type)))) :+: ((C1 (MetaCons "OffsetsLoadInProgressCode" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "ConsumerCoordinatorNotAvailableCode" PrefixI False) (U1 :: Type -> Type)) :+: (C1 (MetaCons "NotCoordinatorForConsumerCode" PrefixI False) (U1 :: Type -> Type) :+: (C1 (MetaCons "TopicAlreadyExists" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "UnsupportedCompressionType" PrefixI False) (U1 :: Type -> Type))))))

newtype Metadata Source #

Constructors

Metadata KafkaString 
Instances
Eq Metadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Show Metadata Source # 
Instance details

Defined in Network.Kafka.Protocol

IsString Metadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic Metadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Metadata :: Type -> Type #

Methods

from :: Metadata -> Rep Metadata x #

to :: Rep Metadata x -> Metadata #

Deserializable Metadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Metadata Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Metadata Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Metadata = D1 (MetaData "Metadata" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Metadata" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString)))

newtype ConsumerGroup Source #

Instances
Eq ConsumerGroup Source # 
Instance details

Defined in Network.Kafka.Protocol

Show ConsumerGroup Source # 
Instance details

Defined in Network.Kafka.Protocol

IsString ConsumerGroup Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic ConsumerGroup Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep ConsumerGroup :: Type -> Type #

Deserializable ConsumerGroup Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ConsumerGroup Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ConsumerGroup Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ConsumerGroup = D1 (MetaData "ConsumerGroup" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "ConsumerGroup" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString)))

newtype CreateTopicsRequest Source #

newtype ReplicationFactor Source #

Constructors

ReplicationFactor Int16 
Instances
Enum ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Num ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Real ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Show ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep ReplicationFactor :: Type -> Type #

Deserializable ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ReplicationFactor = D1 (MetaData "ReplicationFactor" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "ReplicationFactor" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int16)))

data ResponseMessage Source #

Instances
Eq ResponseMessage Source # 
Instance details

Defined in Network.Kafka.Protocol

Show ResponseMessage Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic ResponseMessage Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep ResponseMessage :: Type -> Type #

type Rep ResponseMessage Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ResponseMessage = D1 (MetaData "ResponseMessage" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" False) (((C1 (MetaCons "MetadataResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 MetadataResponse)) :+: C1 (MetaCons "ProduceResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ProduceResponse))) :+: (C1 (MetaCons "FetchResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 FetchResponse)) :+: C1 (MetaCons "OffsetResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 OffsetResponse)))) :+: ((C1 (MetaCons "OffsetCommitResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 OffsetCommitResponse)) :+: C1 (MetaCons "OffsetFetchResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 OffsetFetchResponse))) :+: (C1 (MetaCons "GroupCoordinatorResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 GroupCoordinatorResponse)) :+: C1 (MetaCons "CreateTopicsResponse" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 CreateTopicsResponse)))))

newtype Value Source #

Constructors

Value 
Instances
Eq Value Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Value -> Value -> Bool #

(/=) :: Value -> Value -> Bool #

Show Value Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

showsPrec :: Int -> Value -> ShowS #

show :: Value -> String #

showList :: [Value] -> ShowS #

Generic Value Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Value :: Type -> Type #

Methods

from :: Value -> Rep Value x #

to :: Rep Value x -> Value #

Deserializable Value Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Value Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Value -> Put Source #

type Rep Value Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Value = D1 (MetaData "Value" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Value" PrefixI True) (S1 (MetaSel (Just "_valueBytes") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe KafkaBytes))))

newtype Key Source #

Constructors

Key 
Instances
Eq Key Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Key -> Key -> Bool #

(/=) :: Key -> Key -> Bool #

Show Key Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

showsPrec :: Int -> Key -> ShowS #

show :: Key -> String #

showList :: [Key] -> ShowS #

Generic Key Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Key :: Type -> Type #

Methods

from :: Key -> Rep Key x #

to :: Rep Key x -> Key #

Deserializable Key Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Key Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Key -> Put Source #

type Rep Key Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Key = D1 (MetaData "Key" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Key" PrefixI True) (S1 (MetaSel (Just "_keyBytes") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe KafkaBytes))))

data Attributes Source #

Instances
Eq Attributes Source # 
Instance details

Defined in Network.Kafka.Protocol

Show Attributes Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic Attributes Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Attributes :: Type -> Type #

Deserializable Attributes Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Attributes Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Attributes Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Attributes = D1 (MetaData "Attributes" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" False) (C1 (MetaCons "Attributes" PrefixI True) (S1 (MetaSel (Just "_compressionCodec") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 CompressionCodec)))

newtype MagicByte Source #

Constructors

MagicByte Int8 
Instances
Enum MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Num MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Real MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Show MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep MagicByte :: Type -> Type #

Deserializable MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MagicByte = D1 (MetaData "MagicByte" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "MagicByte" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int8)))

newtype Crc Source #

Constructors

Crc Int32 
Instances
Enum Crc Source # 
Instance details

Defined in Network.Kafka.Protocol

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 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Crc -> Crc -> Bool #

(/=) :: Crc -> Crc -> Bool #

Integral Crc Source # 
Instance details

Defined in Network.Kafka.Protocol

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 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(+) :: Crc -> Crc -> Crc #

(-) :: Crc -> Crc -> Crc #

(*) :: Crc -> Crc -> Crc #

negate :: Crc -> Crc #

abs :: Crc -> Crc #

signum :: Crc -> Crc #

fromInteger :: Integer -> Crc #

Ord Crc Source # 
Instance details

Defined in Network.Kafka.Protocol

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 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

toRational :: Crc -> Rational #

Show Crc Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

showsPrec :: Int -> Crc -> ShowS #

show :: Crc -> String #

showList :: [Crc] -> ShowS #

Generic Crc Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Crc :: Type -> Type #

Methods

from :: Crc -> Rep Crc x #

to :: Rep Crc x -> Crc #

Deserializable Crc Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Crc Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Crc -> Put Source #

type Rep Crc Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Crc = D1 (MetaData "Crc" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Crc" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

data CompressionCodec Source #

Constructors

NoCompression 
Gzip 
Instances
Eq CompressionCodec Source # 
Instance details

Defined in Network.Kafka.Protocol

Show CompressionCodec Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic CompressionCodec Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep CompressionCodec :: Type -> Type #

type Rep CompressionCodec Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep CompressionCodec = D1 (MetaData "CompressionCodec" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" False) (C1 (MetaCons "NoCompression" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "Gzip" PrefixI False) (U1 :: Type -> Type))

newtype Message Source #

Constructors

Message 
Instances
Eq Message Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Message -> Message -> Bool #

(/=) :: Message -> Message -> Bool #

Show Message Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic Message Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Message :: Type -> Type #

Methods

from :: Message -> Rep Message x #

to :: Rep Message x -> Message #

Deserializable Message Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Message Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Message Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Message = D1 (MetaData "Message" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Message" PrefixI True) (S1 (MetaSel (Just "_messageFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Crc, MagicByte, Attributes, Key, Value))))

newtype Offset Source #

Constructors

Offset Int64 
Instances
Enum Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Offset -> Offset -> Bool #

(/=) :: Offset -> Offset -> Bool #

Integral Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Num Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Real Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Show Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Offset :: Type -> Type #

Methods

from :: Offset -> Rep Offset x #

to :: Rep Offset x -> Offset #

Deserializable Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Offset -> Put Source #

type Rep Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Offset = D1 (MetaData "Offset" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Offset" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

data MessageSetMember Source #

data MessageSet Source #

Instances
Eq MessageSet Source # 
Instance details

Defined in Network.Kafka.Protocol

Show MessageSet Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic MessageSet Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep MessageSet :: Type -> Type #

Deserializable MessageSet Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MessageSet Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MessageSet Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MessageSet = D1 (MetaData "MessageSet" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" False) (C1 (MetaCons "MessageSet" PrefixI True) (S1 (MetaSel (Just "_codec") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 CompressionCodec) :*: S1 (MetaSel (Just "_messageSetMembers") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [MessageSetMember])))

newtype Partition Source #

Constructors

Partition Int32 
Instances
Enum Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Num Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Real Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Show Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Partition :: Type -> Type #

Deserializable Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Partition = D1 (MetaData "Partition" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Partition" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype Timeout Source #

Constructors

Timeout Int32 
Instances
Enum Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Timeout -> Timeout -> Bool #

(/=) :: Timeout -> Timeout -> Bool #

Integral Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Num Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Real Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Show Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Timeout :: Type -> Type #

Methods

from :: Timeout -> Rep Timeout x #

to :: Rep Timeout x -> Timeout #

Deserializable Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Timeout = D1 (MetaData "Timeout" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Timeout" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype RequiredAcks Source #

Constructors

RequiredAcks Int16 
Instances
Enum RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Num RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Real RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Show RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep RequiredAcks :: Type -> Type #

Deserializable RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep RequiredAcks = D1 (MetaData "RequiredAcks" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "RequiredAcks" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int16)))

newtype ProduceRequest Source #

Instances
Eq ProduceRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Show ProduceRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic ProduceRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep ProduceRequest :: Type -> Type #

Serializable ProduceRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ProduceRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ProduceRequest = D1 (MetaData "ProduceRequest" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "ProduceReq" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (RequiredAcks, Timeout, [(TopicName, [(Partition, MessageSet)])]))))

newtype MaxBytes Source #

Constructors

MaxBytes Int32 
Instances
Enum MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Num MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Real MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Show MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep MaxBytes :: Type -> Type #

Methods

from :: MaxBytes -> Rep MaxBytes x #

to :: Rep MaxBytes x -> MaxBytes #

Deserializable MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MaxBytes = D1 (MetaData "MaxBytes" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "MaxBytes" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype MinBytes Source #

Constructors

MinBytes Int32 
Instances
Enum MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Num MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Real MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Show MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep MinBytes :: Type -> Type #

Methods

from :: MinBytes -> Rep MinBytes x #

to :: Rep MinBytes x -> MinBytes #

Deserializable MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MinBytes = D1 (MetaData "MinBytes" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "MinBytes" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype MaxWaitTime Source #

Constructors

MaxWaitTime Int32 
Instances
Enum MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Num MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Real MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Show MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep MaxWaitTime :: Type -> Type #

Deserializable MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MaxWaitTime = D1 (MetaData "MaxWaitTime" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "MaxWaitTime" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype ReplicaId Source #

Constructors

ReplicaId Int32 
Instances
Enum ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Num ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Real ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Show ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep ReplicaId :: Type -> Type #

Deserializable ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ReplicaId = D1 (MetaData "ReplicaId" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "ReplicaId" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype FetchRequest Source #

Instances
Eq FetchRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Show FetchRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic FetchRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep FetchRequest :: Type -> Type #

Deserializable FetchRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable FetchRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep FetchRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep FetchRequest = D1 (MetaData "FetchRequest" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "FetchReq" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (ReplicaId, MaxWaitTime, MinBytes, [(TopicName, [(Partition, Offset, MaxBytes)])]))))

newtype MaxNumberOfOffsets Source #

Instances
Enum MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Num MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Real MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Show MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep MaxNumberOfOffsets :: Type -> Type #

Serializable MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MaxNumberOfOffsets = D1 (MetaData "MaxNumberOfOffsets" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "MaxNumberOfOffsets" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype Time Source #

Constructors

Time 

Fields

Instances
Bounded Time Source # 
Instance details

Defined in Network.Kafka.Protocol

Enum Time Source # 
Instance details

Defined in Network.Kafka.Protocol

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 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Time -> Time -> Bool #

(/=) :: Time -> Time -> Bool #

Integral Time Source # 
Instance details

Defined in Network.Kafka.Protocol

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 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(+) :: Time -> Time -> Time #

(-) :: Time -> Time -> Time #

(*) :: Time -> Time -> Time #

negate :: Time -> Time #

abs :: Time -> Time #

signum :: Time -> Time #

fromInteger :: Integer -> Time #

Ord Time Source # 
Instance details

Defined in Network.Kafka.Protocol

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 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

toRational :: Time -> Rational #

Show Time Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

showsPrec :: Int -> Time -> ShowS #

show :: Time -> String #

showList :: [Time] -> ShowS #

Generic Time Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Time :: Type -> Type #

Methods

from :: Time -> Rep Time x #

to :: Rep Time x -> Time #

Serializable Time Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Time -> Put Source #

type Rep Time Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Time = D1 (MetaData "Time" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Time" PrefixI True) (S1 (MetaSel (Just "_timeInt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

newtype OffsetRequest Source #

Instances
Eq OffsetRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Show OffsetRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic OffsetRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep OffsetRequest :: Type -> Type #

Serializable OffsetRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep OffsetRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep OffsetRequest = D1 (MetaData "OffsetRequest" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "OffsetReq" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (ReplicaId, [(TopicName, [(Partition, Time, MaxNumberOfOffsets)])]))))

newtype Isr Source #

Constructors

Isr [Int32] 
Instances
Eq Isr Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Isr -> Isr -> Bool #

(/=) :: Isr -> Isr -> Bool #

Show Isr Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

showsPrec :: Int -> Isr -> ShowS #

show :: Isr -> String #

showList :: [Isr] -> ShowS #

Generic Isr Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Isr :: Type -> Type #

Methods

from :: Isr -> Rep Isr x #

to :: Rep Isr x -> Isr #

Deserializable Isr Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Isr Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Isr = D1 (MetaData "Isr" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Isr" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [Int32])))

newtype Replicas Source #

Constructors

Replicas [Int32] 
Instances
Eq Replicas Source # 
Instance details

Defined in Network.Kafka.Protocol

Show Replicas Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic Replicas Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Replicas :: Type -> Type #

Methods

from :: Replicas -> Rep Replicas x #

to :: Rep Replicas x -> Replicas #

Deserializable Replicas Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Replicas Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Replicas Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Replicas = D1 (MetaData "Replicas" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Replicas" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [Int32])))

newtype Leader Source #

Constructors

Leader 

Fields

Instances
Eq Leader Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Leader -> Leader -> Bool #

(/=) :: Leader -> Leader -> Bool #

Ord Leader Source # 
Instance details

Defined in Network.Kafka.Protocol

Show Leader Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic Leader Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Leader :: Type -> Type #

Methods

from :: Leader -> Rep Leader x #

to :: Rep Leader x -> Leader #

Deserializable Leader Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Leader Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Leader = D1 (MetaData "Leader" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Leader" PrefixI True) (S1 (MetaSel (Just "_leaderId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Int32))))

newtype TopicMetadata Source #

Instances
Eq TopicMetadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Show TopicMetadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic TopicMetadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep TopicMetadata :: Type -> Type #

Deserializable TopicMetadata Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep TopicMetadata Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep TopicMetadata = D1 (MetaData "TopicMetadata" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "TopicMetadata" PrefixI True) (S1 (MetaSel (Just "_topicMetadataFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (KafkaError, TopicName, [PartitionMetadata]))))

newtype Port Source #

Constructors

Port 

Fields

Instances
Enum Port Source # 
Instance details

Defined in Network.Kafka.Protocol

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 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Port -> Port -> Bool #

(/=) :: Port -> Port -> Bool #

Integral Port Source # 
Instance details

Defined in Network.Kafka.Protocol

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 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(+) :: Port -> Port -> Port #

(-) :: Port -> Port -> Port #

(*) :: Port -> Port -> Port #

negate :: Port -> Port #

abs :: Port -> Port #

signum :: Port -> Port #

fromInteger :: Integer -> Port #

Ord Port Source # 
Instance details

Defined in Network.Kafka.Protocol

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 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

toRational :: Port -> Rational #

Show Port Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

showsPrec :: Int -> Port -> ShowS #

show :: Port -> String #

showList :: [Port] -> ShowS #

Generic Port Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Port :: Type -> Type #

Methods

from :: Port -> Rep Port x #

to :: Rep Port x -> Port #

Deserializable Port Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Port Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Port = D1 (MetaData "Port" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Port" PrefixI True) (S1 (MetaSel (Just "_portInt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype Host Source #

Constructors

Host 
Instances
Eq Host Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Host -> Host -> Bool #

(/=) :: Host -> Host -> Bool #

Ord Host Source # 
Instance details

Defined in Network.Kafka.Protocol

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 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

showsPrec :: Int -> Host -> ShowS #

show :: Host -> String #

showList :: [Host] -> ShowS #

IsString Host Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

fromString :: String -> Host #

Generic Host Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Host :: Type -> Type #

Methods

from :: Host -> Rep Host x #

to :: Rep Host x -> Host #

Deserializable Host Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Host Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Host = D1 (MetaData "Host" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Host" PrefixI True) (S1 (MetaSel (Just "_hostKString") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString)))

newtype NodeId Source #

Constructors

NodeId 

Fields

Instances
Enum NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: NodeId -> NodeId -> Bool #

(/=) :: NodeId -> NodeId -> Bool #

Integral NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

Num NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

Real NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

Show NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep NodeId :: Type -> Type #

Methods

from :: NodeId -> Rep NodeId x #

to :: Rep NodeId x -> NodeId #

Deserializable NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep NodeId = D1 (MetaData "NodeId" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "NodeId" PrefixI True) (S1 (MetaSel (Just "_nodeId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype Broker Source #

Constructors

Broker 

Fields

Instances
Eq Broker Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: Broker -> Broker -> Bool #

(/=) :: Broker -> Broker -> Bool #

Ord Broker Source # 
Instance details

Defined in Network.Kafka.Protocol

Show Broker Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic Broker Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep Broker :: Type -> Type #

Methods

from :: Broker -> Rep Broker x #

to :: Rep Broker x -> Broker #

Deserializable Broker Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Broker Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep Broker = D1 (MetaData "Broker" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "Broker" PrefixI True) (S1 (MetaSel (Just "_brokerFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (NodeId, Host, Port))))

newtype MetadataResponse Source #

Instances
Eq MetadataResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Show MetadataResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic MetadataResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep MetadataResponse :: Type -> Type #

Deserializable MetadataResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MetadataResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MetadataResponse = D1 (MetaData "MetadataResponse" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "MetadataResp" PrefixI True) (S1 (MetaSel (Just "_metadataResponseFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ([Broker], [TopicMetadata]))))

newtype CreateTopicsResponse Source #

newtype FetchResponse Source #

Instances
Eq FetchResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Show FetchResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic FetchResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep FetchResponse :: Type -> Type #

Deserializable FetchResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable FetchResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep FetchResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep FetchResponse = D1 (MetaData "FetchResponse" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "FetchResp" PrefixI True) (S1 (MetaSel (Just "_fetchResponseFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [(TopicName, [(Partition, KafkaError, Offset, MessageSet)])])))

newtype PartitionOffsets Source #

Instances
Eq PartitionOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Show PartitionOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic PartitionOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep PartitionOffsets :: Type -> Type #

Deserializable PartitionOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep PartitionOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep PartitionOffsets = D1 (MetaData "PartitionOffsets" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "PartitionOffsets" PrefixI True) (S1 (MetaSel (Just "_partitionOffsetsFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Partition, KafkaError, [Offset]))))

newtype OffsetResponse Source #

Instances
Eq OffsetResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Show OffsetResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic OffsetResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep OffsetResponse :: Type -> Type #

Deserializable OffsetResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep OffsetResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep OffsetResponse = D1 (MetaData "OffsetResponse" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "OffsetResp" PrefixI True) (S1 (MetaSel (Just "_offsetResponseFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [(TopicName, [PartitionOffsets])])))

newtype ProduceResponse Source #

Instances
Eq ProduceResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Show ProduceResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic ProduceResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep ProduceResponse :: Type -> Type #

Deserializable ProduceResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ProduceResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ProduceResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ProduceResponse = D1 (MetaData "ProduceResponse" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "ProduceResp" PrefixI True) (S1 (MetaSel (Just "_produceResponseFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [(TopicName, [(Partition, KafkaError, Offset)])])))

newtype KafkaString Source #

Constructors

KString 

Fields

Instances
Eq KafkaString Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord KafkaString Source # 
Instance details

Defined in Network.Kafka.Protocol

Show KafkaString Source # 
Instance details

Defined in Network.Kafka.Protocol

IsString KafkaString Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic KafkaString Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep KafkaString :: Type -> Type #

Deserializable KafkaString Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable KafkaString Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep KafkaString Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep KafkaString = D1 (MetaData "KafkaString" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "KString" PrefixI True) (S1 (MetaSel (Just "_kString") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ByteString)))

newtype KafkaBytes Source #

Constructors

KBytes 
Instances
Eq KafkaBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Show KafkaBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

IsString KafkaBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic KafkaBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep KafkaBytes :: Type -> Type #

Deserializable KafkaBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable KafkaBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep KafkaBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep KafkaBytes = D1 (MetaData "KafkaBytes" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "KBytes" PrefixI True) (S1 (MetaSel (Just "_kafkaByteString") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ByteString)))

newtype TopicName Source #

Constructors

TName 

Fields

Instances
Eq TopicName Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord TopicName Source # 
Instance details

Defined in Network.Kafka.Protocol

Show TopicName Source # 
Instance details

Defined in Network.Kafka.Protocol

IsString TopicName Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic TopicName Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep TopicName :: Type -> Type #

Deserializable TopicName Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable TopicName Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep TopicName Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep TopicName = D1 (MetaData "TopicName" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "TName" PrefixI True) (S1 (MetaSel (Just "_tName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString)))

newtype MetadataRequest Source #

Constructors

MetadataReq [TopicName] 
Instances
Eq MetadataRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Show MetadataRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic MetadataRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep MetadataRequest :: Type -> Type #

Deserializable MetadataRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MetadataRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MetadataRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep MetadataRequest = D1 (MetaData "MetadataRequest" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "MetadataReq" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [TopicName])))

data RequestMessage Source #

Instances
Eq RequestMessage Source # 
Instance details

Defined in Network.Kafka.Protocol

Show RequestMessage Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic RequestMessage Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep RequestMessage :: Type -> Type #

Serializable RequestMessage Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep RequestMessage Source # 
Instance details

Defined in Network.Kafka.Protocol

newtype ClientId Source #

Constructors

ClientId KafkaString 
Instances
Eq ClientId Source # 
Instance details

Defined in Network.Kafka.Protocol

Show ClientId Source # 
Instance details

Defined in Network.Kafka.Protocol

IsString ClientId Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic ClientId Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep ClientId :: Type -> Type #

Methods

from :: ClientId -> Rep ClientId x #

to :: Rep ClientId x -> ClientId #

Deserializable ClientId Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ClientId Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ClientId Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ClientId = D1 (MetaData "ClientId" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "ClientId" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString)))

newtype CorrelationId Source #

Constructors

CorrelationId Int32 
Instances
Enum CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Num CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Real CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Show CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep CorrelationId :: Type -> Type #

Deserializable CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep CorrelationId = D1 (MetaData "CorrelationId" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "CorrelationId" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype ApiVersion Source #

Constructors

ApiVersion Int16 
Instances
Enum ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Integral ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Num ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Real ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Show ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep ApiVersion :: Type -> Type #

Deserializable ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ApiVersion = D1 (MetaData "ApiVersion" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "ApiVersion" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int16)))

newtype ApiKey Source #

Constructors

ApiKey Int16 
Instances
Enum ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Eq ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

(==) :: ApiKey -> ApiKey -> Bool #

(/=) :: ApiKey -> ApiKey -> Bool #

Integral ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Num ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Ord ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Real ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Show ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Generic ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Associated Types

type Rep ApiKey :: Type -> Type #

Methods

from :: ApiKey -> Rep ApiKey x #

to :: Rep ApiKey x -> ApiKey #

Deserializable ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: ApiKey -> Put Source #

type Rep ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

type Rep ApiKey = D1 (MetaData "ApiKey" "Network.Kafka.Protocol" "milena-0.5.3.0-56TArgubqLBEBU4ve7tukD" True) (C1 (MetaCons "ApiKey" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int16)))

class Deserializable a where Source #

Methods

deserialize :: Get a Source #

Instances
Deserializable Int8 Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Int16 Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Int32 Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Int64 Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Metadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable ConsumerGroup Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Value Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Key Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Attributes Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Crc Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Message Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable MessageSetMember Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable MessageSet Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable FetchRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable OffsetFetchResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable OffsetCommitResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Isr Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Replicas Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Leader Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable PartitionMetadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable TopicMetadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Port Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Host Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable NodeId Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable Broker Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable MetadataResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable CreateTopicsResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable FetchResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable PartitionOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable OffsetResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable ProduceResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable KafkaString Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable KafkaBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable TopicName Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable MetadataRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable ClientId Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable GroupCoordinatorResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Deserializable a => Deserializable [a] Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

deserialize :: Get [a] Source #

(Deserializable a, Deserializable b) => Deserializable (a, b) Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

deserialize :: Get (a, b) Source #

(Deserializable a, Deserializable b, Deserializable c) => Deserializable (a, b, c) Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

deserialize :: Get (a, b, c) Source #

(Deserializable a, Deserializable b, Deserializable c, Deserializable d) => Deserializable (a, b, c, d) Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

deserialize :: Get (a, b, c, d) Source #

(Deserializable a, Deserializable b, Deserializable c, Deserializable d, Deserializable e) => Deserializable (a, b, c, d, e) Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

deserialize :: Get (a, b, c, d, e) Source #

class Serializable a where Source #

Methods

serialize :: a -> Put Source #

Instances
Serializable Int8 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Int8 -> Put Source #

Serializable Int16 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Int16 -> Put Source #

Serializable Int32 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Int32 -> Put Source #

Serializable Int64 Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Int64 -> Put Source #

Serializable Request Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable KafkaError Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Metadata Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ConsumerGroup Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable OffsetFetchRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable OffsetCommitRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable CreateTopicsRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable GroupCoordinatorRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ReplicationFactor Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Value Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Value -> Put Source #

Serializable Key Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Key -> Put Source #

Serializable Attributes Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MagicByte Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Crc Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Crc -> Put Source #

Serializable Message Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Offset Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Offset -> Put Source #

Serializable MessageSetMember Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MessageSet Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Partition Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Timeout Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable RequiredAcks Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ProduceRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MaxBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MinBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MaxWaitTime Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ReplicaId Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable FetchRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MaxNumberOfOffsets Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Time Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: Time -> Put Source #

Serializable OffsetRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable Replicas Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable CreateTopicsResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable FetchResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ProduceResponse Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable KafkaString Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable KafkaBytes Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable TopicName Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable MetadataRequest Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable RequestMessage Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ClientId Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable CorrelationId Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ApiVersion Source # 
Instance details

Defined in Network.Kafka.Protocol

Serializable ApiKey Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: ApiKey -> Put Source #

Serializable a => Serializable [a] Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: [a] -> Put Source #

(Serializable a, Serializable b) => Serializable (a, b) Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: (a, b) -> Put Source #

(Serializable a, Serializable b, Serializable c) => Serializable (a, b, c) Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: (a, b, c) -> Put Source #

(Serializable a, Serializable b, Serializable c, Serializable d) => Serializable (a, b, c, d) Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: (a, b, c, d) -> Put Source #

(Serializable a, Serializable b, Serializable c, Serializable d, Serializable e) => Serializable (a, b, c, d, e) Source # 
Instance details

Defined in Network.Kafka.Protocol

Methods

serialize :: (a, b, c, d, e) -> Put Source #

keyed :: (Field1 a a b b, Choice p, Applicative f, Eq b) => b -> Optic' p f a a Source #