Safe Haskell	None
Language	Haskell2010

Network.Kafka.Protocol

Documentation

newtype Request Source #

Constructors

Request (CorrelationId, ClientId, RequestMessage)

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 Methods showsPrec :: Int -> Request -> ShowS # show :: Request -> String # showList :: [Request] -> ShowS #
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 Methods serialize :: Request -> Put Source #
type Rep Request Source #
Instance details Defined in Network.Kafka.Protocol type Rep Request = D1 (MetaData "Request" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 Methods minBound :: KafkaError # maxBound :: KafkaError #
Enum KafkaError Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: KafkaError -> KafkaError -> Bool # (/=) :: KafkaError -> KafkaError -> Bool #
Show KafkaError Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> KafkaError -> ShowS # show :: KafkaError -> String # showList :: [KafkaError] -> ShowS #
Generic KafkaError Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep KafkaError :: Type -> Type # Methods from :: KafkaError -> Rep KafkaError x # to :: Rep KafkaError x -> KafkaError #
Exception KafkaError Source #
Instance details Defined in Network.Kafka.Protocol Methods toException :: KafkaError -> SomeException # fromException :: SomeException -> Maybe KafkaError # displayException :: KafkaError -> String #
Deserializable KafkaError Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get KafkaError Source #
Serializable KafkaError Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: KafkaError -> Put Source #
type Rep KafkaError Source #
Instance details Defined in Network.Kafka.Protocol type Rep KafkaError = D1 (MetaData "KafkaError" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 Methods (==) :: Metadata -> Metadata -> Bool # (/=) :: Metadata -> Metadata -> Bool #
Show Metadata Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> Metadata -> ShowS # show :: Metadata -> String # showList :: [Metadata] -> ShowS #
IsString Metadata Source #
Instance details Defined in Network.Kafka.Protocol Methods fromString :: String -> Metadata #
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 Methods deserialize :: Get Metadata Source #
Serializable Metadata Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: Metadata -> Put Source #
type Rep Metadata Source #
Instance details Defined in Network.Kafka.Protocol type Rep Metadata = D1 (MetaData "Metadata" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "Metadata" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString)))

newtype ConsumerGroup Source #

Constructors

ConsumerGroup KafkaString

Instances

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

newtype OffsetFetchRequest Source #

Constructors

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

Instances

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

newtype OffsetCommitRequest Source #

Constructors

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

Instances

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

newtype DeleteTopicsRequest Source #

Constructors

DeleteTopicsReq ([TopicName], Timeout)

Instances

Eq DeleteTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: DeleteTopicsRequest -> DeleteTopicsRequest -> Bool # (/=) :: DeleteTopicsRequest -> DeleteTopicsRequest -> Bool #
Show DeleteTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> DeleteTopicsRequest -> ShowS # show :: DeleteTopicsRequest -> String # showList :: [DeleteTopicsRequest] -> ShowS #
Generic DeleteTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep DeleteTopicsRequest :: Type -> Type # Methods from :: DeleteTopicsRequest -> Rep DeleteTopicsRequest x # to :: Rep DeleteTopicsRequest x -> DeleteTopicsRequest #
Serializable DeleteTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: DeleteTopicsRequest -> Put Source #
type Rep DeleteTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol type Rep DeleteTopicsRequest = D1 (MetaData "DeleteTopicsRequest" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "DeleteTopicsReq" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ([TopicName], Timeout))))

newtype CreateTopicsRequest Source #

Constructors

CreateTopicsReq ([(TopicName, Partition, ReplicationFactor, [(Partition, Replicas)], [(KafkaString, Metadata)])], Timeout)

Instances

Eq CreateTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: CreateTopicsRequest -> CreateTopicsRequest -> Bool # (/=) :: CreateTopicsRequest -> CreateTopicsRequest -> Bool #
Show CreateTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> CreateTopicsRequest -> ShowS # show :: CreateTopicsRequest -> String # showList :: [CreateTopicsRequest] -> ShowS #
Generic CreateTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep CreateTopicsRequest :: Type -> Type # Methods from :: CreateTopicsRequest -> Rep CreateTopicsRequest x # to :: Rep CreateTopicsRequest x -> CreateTopicsRequest #
Serializable CreateTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: CreateTopicsRequest -> Put Source #
type Rep CreateTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol type Rep CreateTopicsRequest = D1 (MetaData "CreateTopicsRequest" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "CreateTopicsReq" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ([(TopicName, Partition, ReplicationFactor, [(Partition, Replicas)], [(KafkaString, Metadata)])], Timeout))))

newtype GroupCoordinatorRequest Source #

Constructors

GroupCoordinatorReq ConsumerGroup

Instances

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

newtype ReplicationFactor Source #

Constructors

ReplicationFactor Int16

Instances

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

data ResponseMessage Source #

Constructors

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

Instances

Eq ResponseMessage Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: ResponseMessage -> ResponseMessage -> Bool # (/=) :: ResponseMessage -> ResponseMessage -> Bool #
Show ResponseMessage Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> ResponseMessage -> ShowS # show :: ResponseMessage -> String # showList :: [ResponseMessage] -> ShowS #
Generic ResponseMessage Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep ResponseMessage :: Type -> Type # Methods from :: ResponseMessage -> Rep ResponseMessage x # to :: Rep ResponseMessage x -> ResponseMessage #
type Rep ResponseMessage Source #
Instance details Defined in Network.Kafka.Protocol type Rep ResponseMessage = D1 (MetaData "ResponseMessage" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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
Fields _valueBytes :: Maybe KafkaBytes

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 Methods deserialize :: Get Value Source #
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.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "Value" PrefixI True) (S1 (MetaSel (Just "_valueBytes") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe KafkaBytes))))

newtype Key Source #

Constructors

Key
Fields _keyBytes :: Maybe KafkaBytes

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 Methods deserialize :: Get Key Source #
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.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "Key" PrefixI True) (S1 (MetaSel (Just "_keyBytes") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe KafkaBytes))))

data Attributes Source #

Constructors

Attributes
Fields _compressionCodec :: CompressionCodec

Instances

Eq Attributes Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: Attributes -> Attributes -> Bool # (/=) :: Attributes -> Attributes -> Bool #
Show Attributes Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> Attributes -> ShowS # show :: Attributes -> String # showList :: [Attributes] -> ShowS #
Generic Attributes Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep Attributes :: Type -> Type # Methods from :: Attributes -> Rep Attributes x # to :: Rep Attributes x -> Attributes #
Deserializable Attributes Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Attributes Source #
Serializable Attributes Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: Attributes -> Put Source #
type Rep Attributes Source #
Instance details Defined in Network.Kafka.Protocol type Rep Attributes = D1 (MetaData "Attributes" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: MagicByte -> MagicByte -> Bool # (/=) :: MagicByte -> MagicByte -> Bool #
Integral MagicByte Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: MagicByte -> MagicByte -> MagicByte # (-) :: MagicByte -> MagicByte -> MagicByte # (*) :: MagicByte -> MagicByte -> MagicByte # negate :: MagicByte -> MagicByte # abs :: MagicByte -> MagicByte # signum :: MagicByte -> MagicByte # fromInteger :: Integer -> MagicByte #
Ord MagicByte Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: MagicByte -> Rational #
Show MagicByte Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> MagicByte -> ShowS # show :: MagicByte -> String # showList :: [MagicByte] -> ShowS #
Generic MagicByte Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep MagicByte :: Type -> Type # Methods from :: MagicByte -> Rep MagicByte x # to :: Rep MagicByte x -> MagicByte #
Deserializable MagicByte Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MagicByte Source #
Serializable MagicByte Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MagicByte -> Put Source #
type Rep MagicByte Source #
Instance details Defined in Network.Kafka.Protocol type Rep MagicByte = D1 (MetaData "MagicByte" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 Methods deserialize :: Get Crc Source #
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.4.0-27nMlnYTid12v1ZBZP3eqt" 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 Methods (==) :: CompressionCodec -> CompressionCodec -> Bool # (/=) :: CompressionCodec -> CompressionCodec -> Bool #
Show CompressionCodec Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> CompressionCodec -> ShowS # show :: CompressionCodec -> String # showList :: [CompressionCodec] -> ShowS #
Generic CompressionCodec Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep CompressionCodec :: Type -> Type # Methods from :: CompressionCodec -> Rep CompressionCodec x # to :: Rep CompressionCodec x -> CompressionCodec #
type Rep CompressionCodec Source #
Instance details Defined in Network.Kafka.Protocol type Rep CompressionCodec = D1 (MetaData "CompressionCodec" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" False) (C1 (MetaCons "NoCompression" PrefixI False) (U1 :: Type -> Type) :+: C1 (MetaCons "Gzip" PrefixI False) (U1 :: Type -> Type))

newtype Message Source #

Constructors

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

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 Methods showsPrec :: Int -> Message -> ShowS # show :: Message -> String # showList :: [Message] -> ShowS #
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 Methods deserialize :: Get Message Source #
Serializable Message Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: Message -> Put Source #
type Rep Message Source #
Instance details Defined in Network.Kafka.Protocol type Rep Message = D1 (MetaData "Message" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: Offset -> Offset -> Offset # (-) :: Offset -> Offset -> Offset # (*) :: Offset -> Offset -> Offset # negate :: Offset -> Offset # abs :: Offset -> Offset # signum :: Offset -> Offset # fromInteger :: Integer -> Offset #
Ord Offset Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: Offset -> Rational #
Show Offset Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> Offset -> ShowS # show :: Offset -> String # showList :: [Offset] -> ShowS #
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 Methods deserialize :: Get Offset Source #
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.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "Offset" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

data MessageSetMember Source #

Constructors

MessageSetMember
Fields _setOffset :: Offset _setMessage :: Message

Instances

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

data MessageSet Source #

Constructors

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

Instances

Eq MessageSet Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: MessageSet -> MessageSet -> Bool # (/=) :: MessageSet -> MessageSet -> Bool #
Show MessageSet Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> MessageSet -> ShowS # show :: MessageSet -> String # showList :: [MessageSet] -> ShowS #
Generic MessageSet Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep MessageSet :: Type -> Type # Methods from :: MessageSet -> Rep MessageSet x # to :: Rep MessageSet x -> MessageSet #
Deserializable MessageSet Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MessageSet Source #
Serializable MessageSet Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MessageSet -> Put Source #
type Rep MessageSet Source #
Instance details Defined in Network.Kafka.Protocol type Rep MessageSet = D1 (MetaData "MessageSet" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: Partition -> Partition -> Bool # (/=) :: Partition -> Partition -> Bool #
Integral Partition Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: Partition -> Partition -> Partition # (-) :: Partition -> Partition -> Partition # (*) :: Partition -> Partition -> Partition # negate :: Partition -> Partition # abs :: Partition -> Partition # signum :: Partition -> Partition # fromInteger :: Integer -> Partition #
Ord Partition Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: Partition -> Rational #
Show Partition Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> Partition -> ShowS # show :: Partition -> String # showList :: [Partition] -> ShowS #
Generic Partition Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep Partition :: Type -> Type # Methods from :: Partition -> Rep Partition x # to :: Rep Partition x -> Partition #
Deserializable Partition Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Partition Source #
Serializable Partition Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: Partition -> Put Source #
type Rep Partition Source #
Instance details Defined in Network.Kafka.Protocol type Rep Partition = D1 (MetaData "Partition" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: Timeout -> Timeout -> Timeout # (-) :: Timeout -> Timeout -> Timeout # (*) :: Timeout -> Timeout -> Timeout # negate :: Timeout -> Timeout # abs :: Timeout -> Timeout # signum :: Timeout -> Timeout # fromInteger :: Integer -> Timeout #
Ord Timeout Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: Timeout -> Rational #
Show Timeout Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> Timeout -> ShowS # show :: Timeout -> String # showList :: [Timeout] -> ShowS #
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 Methods deserialize :: Get Timeout Source #
Serializable Timeout Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: Timeout -> Put Source #
type Rep Timeout Source #
Instance details Defined in Network.Kafka.Protocol type Rep Timeout = D1 (MetaData "Timeout" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: RequiredAcks -> RequiredAcks -> Bool # (/=) :: RequiredAcks -> RequiredAcks -> Bool #
Integral RequiredAcks Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: RequiredAcks -> RequiredAcks -> RequiredAcks # (-) :: RequiredAcks -> RequiredAcks -> RequiredAcks # (*) :: RequiredAcks -> RequiredAcks -> RequiredAcks # negate :: RequiredAcks -> RequiredAcks # abs :: RequiredAcks -> RequiredAcks # signum :: RequiredAcks -> RequiredAcks # fromInteger :: Integer -> RequiredAcks #
Ord RequiredAcks Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: RequiredAcks -> Rational #
Show RequiredAcks Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> RequiredAcks -> ShowS # show :: RequiredAcks -> String # showList :: [RequiredAcks] -> ShowS #
Generic RequiredAcks Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep RequiredAcks :: Type -> Type # Methods from :: RequiredAcks -> Rep RequiredAcks x # to :: Rep RequiredAcks x -> RequiredAcks #
Deserializable RequiredAcks Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get RequiredAcks Source #
Serializable RequiredAcks Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: RequiredAcks -> Put Source #
type Rep RequiredAcks Source #
Instance details Defined in Network.Kafka.Protocol type Rep RequiredAcks = D1 (MetaData "RequiredAcks" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "RequiredAcks" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int16)))

newtype ProduceRequest Source #

Constructors

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

Instances

Eq ProduceRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: ProduceRequest -> ProduceRequest -> Bool # (/=) :: ProduceRequest -> ProduceRequest -> Bool #
Show ProduceRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> ProduceRequest -> ShowS # show :: ProduceRequest -> String # showList :: [ProduceRequest] -> ShowS #
Generic ProduceRequest Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep ProduceRequest :: Type -> Type # Methods from :: ProduceRequest -> Rep ProduceRequest x # to :: Rep ProduceRequest x -> ProduceRequest #
Serializable ProduceRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ProduceRequest -> Put Source #
type Rep ProduceRequest Source #
Instance details Defined in Network.Kafka.Protocol type Rep ProduceRequest = D1 (MetaData "ProduceRequest" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: MaxBytes -> MaxBytes -> Bool # (/=) :: MaxBytes -> MaxBytes -> Bool #
Integral MaxBytes Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: MaxBytes -> MaxBytes -> MaxBytes # (-) :: MaxBytes -> MaxBytes -> MaxBytes # (*) :: MaxBytes -> MaxBytes -> MaxBytes # negate :: MaxBytes -> MaxBytes # abs :: MaxBytes -> MaxBytes # signum :: MaxBytes -> MaxBytes # fromInteger :: Integer -> MaxBytes #
Ord MaxBytes Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: MaxBytes -> Rational #
Show MaxBytes Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> MaxBytes -> ShowS # show :: MaxBytes -> String # showList :: [MaxBytes] -> ShowS #
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 Methods deserialize :: Get MaxBytes Source #
Serializable MaxBytes Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MaxBytes -> Put Source #
type Rep MaxBytes Source #
Instance details Defined in Network.Kafka.Protocol type Rep MaxBytes = D1 (MetaData "MaxBytes" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: MinBytes -> MinBytes -> Bool # (/=) :: MinBytes -> MinBytes -> Bool #
Integral MinBytes Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: MinBytes -> MinBytes -> MinBytes # (-) :: MinBytes -> MinBytes -> MinBytes # (*) :: MinBytes -> MinBytes -> MinBytes # negate :: MinBytes -> MinBytes # abs :: MinBytes -> MinBytes # signum :: MinBytes -> MinBytes # fromInteger :: Integer -> MinBytes #
Ord MinBytes Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: MinBytes -> Rational #
Show MinBytes Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> MinBytes -> ShowS # show :: MinBytes -> String # showList :: [MinBytes] -> ShowS #
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 Methods deserialize :: Get MinBytes Source #
Serializable MinBytes Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MinBytes -> Put Source #
type Rep MinBytes Source #
Instance details Defined in Network.Kafka.Protocol type Rep MinBytes = D1 (MetaData "MinBytes" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: MaxWaitTime -> MaxWaitTime -> Bool # (/=) :: MaxWaitTime -> MaxWaitTime -> Bool #
Integral MaxWaitTime Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # (-) :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # (*) :: MaxWaitTime -> MaxWaitTime -> MaxWaitTime # negate :: MaxWaitTime -> MaxWaitTime # abs :: MaxWaitTime -> MaxWaitTime # signum :: MaxWaitTime -> MaxWaitTime # fromInteger :: Integer -> MaxWaitTime #
Ord MaxWaitTime Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: MaxWaitTime -> Rational #
Show MaxWaitTime Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> MaxWaitTime -> ShowS # show :: MaxWaitTime -> String # showList :: [MaxWaitTime] -> ShowS #
Generic MaxWaitTime Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep MaxWaitTime :: Type -> Type # Methods from :: MaxWaitTime -> Rep MaxWaitTime x # to :: Rep MaxWaitTime x -> MaxWaitTime #
Deserializable MaxWaitTime Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MaxWaitTime Source #
Serializable MaxWaitTime Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MaxWaitTime -> Put Source #
type Rep MaxWaitTime Source #
Instance details Defined in Network.Kafka.Protocol type Rep MaxWaitTime = D1 (MetaData "MaxWaitTime" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: ReplicaId -> ReplicaId -> Bool # (/=) :: ReplicaId -> ReplicaId -> Bool #
Integral ReplicaId Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: ReplicaId -> ReplicaId -> ReplicaId # (-) :: ReplicaId -> ReplicaId -> ReplicaId # (*) :: ReplicaId -> ReplicaId -> ReplicaId # negate :: ReplicaId -> ReplicaId # abs :: ReplicaId -> ReplicaId # signum :: ReplicaId -> ReplicaId # fromInteger :: Integer -> ReplicaId #
Ord ReplicaId Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: ReplicaId -> Rational #
Show ReplicaId Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> ReplicaId -> ShowS # show :: ReplicaId -> String # showList :: [ReplicaId] -> ShowS #
Generic ReplicaId Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep ReplicaId :: Type -> Type # Methods from :: ReplicaId -> Rep ReplicaId x # to :: Rep ReplicaId x -> ReplicaId #
Deserializable ReplicaId Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get ReplicaId Source #
Serializable ReplicaId Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ReplicaId -> Put Source #
type Rep ReplicaId Source #
Instance details Defined in Network.Kafka.Protocol type Rep ReplicaId = D1 (MetaData "ReplicaId" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "ReplicaId" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype FetchRequest Source #

Constructors

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

Instances

Eq FetchRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: FetchRequest -> FetchRequest -> Bool # (/=) :: FetchRequest -> FetchRequest -> Bool #
Show FetchRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> FetchRequest -> ShowS # show :: FetchRequest -> String # showList :: [FetchRequest] -> ShowS #
Generic FetchRequest Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep FetchRequest :: Type -> Type # Methods from :: FetchRequest -> Rep FetchRequest x # to :: Rep FetchRequest x -> FetchRequest #
Deserializable FetchRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get FetchRequest Source #
Serializable FetchRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: FetchRequest -> Put Source #
type Rep FetchRequest Source #
Instance details Defined in Network.Kafka.Protocol type Rep FetchRequest = D1 (MetaData "FetchRequest" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 #

Constructors

MaxNumberOfOffsets Int32

Instances

Enum MaxNumberOfOffsets Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> Bool # (/=) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> Bool #
Integral MaxNumberOfOffsets Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # (-) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # (*) :: MaxNumberOfOffsets -> MaxNumberOfOffsets -> MaxNumberOfOffsets # negate :: MaxNumberOfOffsets -> MaxNumberOfOffsets # abs :: MaxNumberOfOffsets -> MaxNumberOfOffsets # signum :: MaxNumberOfOffsets -> MaxNumberOfOffsets # fromInteger :: Integer -> MaxNumberOfOffsets #
Ord MaxNumberOfOffsets Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: MaxNumberOfOffsets -> Rational #
Show MaxNumberOfOffsets Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> MaxNumberOfOffsets -> ShowS # show :: MaxNumberOfOffsets -> String # showList :: [MaxNumberOfOffsets] -> ShowS #
Generic MaxNumberOfOffsets Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep MaxNumberOfOffsets :: Type -> Type # Methods from :: MaxNumberOfOffsets -> Rep MaxNumberOfOffsets x # to :: Rep MaxNumberOfOffsets x -> MaxNumberOfOffsets #
Serializable MaxNumberOfOffsets Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MaxNumberOfOffsets -> Put Source #
type Rep MaxNumberOfOffsets Source #
Instance details Defined in Network.Kafka.Protocol type Rep MaxNumberOfOffsets = D1 (MetaData "MaxNumberOfOffsets" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "MaxNumberOfOffsets" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype Time Source #

Constructors

Time
Fields _timeInt :: Int64

Instances

Bounded Time Source #
Instance details Defined in Network.Kafka.Protocol Methods minBound :: Time # maxBound :: Time #
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.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "Time" PrefixI True) (S1 (MetaSel (Just "_timeInt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

newtype OffsetRequest Source #

Constructors

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

Instances

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

newtype OffsetFetchResponse Source #

Constructors

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

Instances

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

newtype OffsetCommitResponse Source #

Constructors

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

Instances

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

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 Methods deserialize :: Get Isr Source #
type Rep Isr Source #
Instance details Defined in Network.Kafka.Protocol type Rep Isr = D1 (MetaData "Isr" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 Methods (==) :: Replicas -> Replicas -> Bool # (/=) :: Replicas -> Replicas -> Bool #
Show Replicas Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> Replicas -> ShowS # show :: Replicas -> String # showList :: [Replicas] -> ShowS #
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 Methods deserialize :: Get Replicas Source #
Serializable Replicas Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: Replicas -> Put Source #
type Rep Replicas Source #
Instance details Defined in Network.Kafka.Protocol type Rep Replicas = D1 (MetaData "Replicas" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "Replicas" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [Int32])))

newtype Leader Source #

Constructors

Leader
Fields _leaderId :: Maybe Int32

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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> Leader -> ShowS # show :: Leader -> String # showList :: [Leader] -> ShowS #
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 Methods deserialize :: Get Leader Source #
type Rep Leader Source #
Instance details Defined in Network.Kafka.Protocol type Rep Leader = D1 (MetaData "Leader" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "Leader" PrefixI True) (S1 (MetaSel (Just "_leaderId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Int32))))

newtype PartitionMetadata Source #

Constructors

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

Instances

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

newtype TopicMetadata Source #

Constructors

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

Instances

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

newtype Port Source #

Constructors

Port
Fields _portInt :: Int32

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 Methods deserialize :: Get Port Source #
type Rep Port Source #
Instance details Defined in Network.Kafka.Protocol type Rep Port = D1 (MetaData "Port" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "Port" PrefixI True) (S1 (MetaSel (Just "_portInt") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype Host Source #

Constructors

Host
Fields _hostKString :: KafkaString

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 Methods deserialize :: Get Host Source #
type Rep Host Source #
Instance details Defined in Network.Kafka.Protocol type Rep Host = D1 (MetaData "Host" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "Host" PrefixI True) (S1 (MetaSel (Just "_hostKString") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 KafkaString)))

newtype NodeId Source #

Constructors

NodeId
Fields _nodeId :: Int32

Instances

Enum NodeId Source #
Instance details Defined in Network.Kafka.Protocol 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 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: NodeId -> NodeId -> NodeId # (-) :: NodeId -> NodeId -> NodeId # (*) :: NodeId -> NodeId -> NodeId # negate :: NodeId -> NodeId # abs :: NodeId -> NodeId # signum :: NodeId -> NodeId # fromInteger :: Integer -> NodeId #
Ord NodeId Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: NodeId -> Rational #
Show NodeId Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> NodeId -> ShowS # show :: NodeId -> String # showList :: [NodeId] -> ShowS #
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 Methods deserialize :: Get NodeId Source #
type Rep NodeId Source #
Instance details Defined in Network.Kafka.Protocol type Rep NodeId = D1 (MetaData "NodeId" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "NodeId" PrefixI True) (S1 (MetaSel (Just "_nodeId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int32)))

newtype Broker Source #

Constructors

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

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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> Broker -> ShowS # show :: Broker -> String # showList :: [Broker] -> ShowS #
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 Methods deserialize :: Get Broker Source #
type Rep Broker Source #
Instance details Defined in Network.Kafka.Protocol type Rep Broker = D1 (MetaData "Broker" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "Broker" PrefixI True) (S1 (MetaSel (Just "_brokerFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (NodeId, Host, Port))))

newtype MetadataResponse Source #

Constructors

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

Instances

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

newtype DeleteTopicsResponse Source #

Constructors

DeleteTopicsResp
Fields _deleteTopicsResponseFields :: [(TopicName, KafkaError)]

Instances

Eq DeleteTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: DeleteTopicsResponse -> DeleteTopicsResponse -> Bool # (/=) :: DeleteTopicsResponse -> DeleteTopicsResponse -> Bool #
Show DeleteTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> DeleteTopicsResponse -> ShowS # show :: DeleteTopicsResponse -> String # showList :: [DeleteTopicsResponse] -> ShowS #
Generic DeleteTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep DeleteTopicsResponse :: Type -> Type # Methods from :: DeleteTopicsResponse -> Rep DeleteTopicsResponse x # to :: Rep DeleteTopicsResponse x -> DeleteTopicsResponse #
Deserializable DeleteTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get DeleteTopicsResponse Source #
Serializable DeleteTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: DeleteTopicsResponse -> Put Source #
type Rep DeleteTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol type Rep DeleteTopicsResponse = D1 (MetaData "DeleteTopicsResponse" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "DeleteTopicsResp" PrefixI True) (S1 (MetaSel (Just "_deleteTopicsResponseFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [(TopicName, KafkaError)])))

newtype CreateTopicsResponse Source #

Constructors

TopicsResp
Fields _topicsResponseFields :: [(TopicName, KafkaError)]

Instances

Eq CreateTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: CreateTopicsResponse -> CreateTopicsResponse -> Bool # (/=) :: CreateTopicsResponse -> CreateTopicsResponse -> Bool #
Show CreateTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> CreateTopicsResponse -> ShowS # show :: CreateTopicsResponse -> String # showList :: [CreateTopicsResponse] -> ShowS #
Generic CreateTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep CreateTopicsResponse :: Type -> Type # Methods from :: CreateTopicsResponse -> Rep CreateTopicsResponse x # to :: Rep CreateTopicsResponse x -> CreateTopicsResponse #
Deserializable CreateTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get CreateTopicsResponse Source #
Serializable CreateTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: CreateTopicsResponse -> Put Source #
type Rep CreateTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol type Rep CreateTopicsResponse = D1 (MetaData "CreateTopicsResponse" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "TopicsResp" PrefixI True) (S1 (MetaSel (Just "_topicsResponseFields") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [(TopicName, KafkaError)])))

newtype FetchResponse Source #

Constructors

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

Instances

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

newtype PartitionOffsets Source #

Constructors

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

Instances

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

newtype OffsetResponse Source #

Constructors

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

Instances

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

newtype ProduceResponse Source #

Constructors

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

Instances

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

newtype KafkaString Source #

Constructors

KString
Fields _kString :: ByteString

Instances

Eq KafkaString Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: KafkaString -> KafkaString -> Bool # (/=) :: KafkaString -> KafkaString -> Bool #
Ord KafkaString Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> KafkaString -> ShowS # show :: KafkaString -> String # showList :: [KafkaString] -> ShowS #
IsString KafkaString Source #
Instance details Defined in Network.Kafka.Protocol Methods fromString :: String -> KafkaString #
Generic KafkaString Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep KafkaString :: Type -> Type # Methods from :: KafkaString -> Rep KafkaString x # to :: Rep KafkaString x -> KafkaString #
Deserializable KafkaString Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get KafkaString Source #
Serializable KafkaString Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: KafkaString -> Put Source #
type Rep KafkaString Source #
Instance details Defined in Network.Kafka.Protocol type Rep KafkaString = D1 (MetaData "KafkaString" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "KString" PrefixI True) (S1 (MetaSel (Just "_kString") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ByteString)))

newtype KafkaBytes Source #

Constructors

KBytes
Fields _kafkaByteString :: ByteString

Instances

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

newtype TopicName Source #

Constructors

TName
Fields _tName :: KafkaString

Instances

Eq TopicName Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: TopicName -> TopicName -> Bool # (/=) :: TopicName -> TopicName -> Bool #
Ord TopicName Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> TopicName -> ShowS # show :: TopicName -> String # showList :: [TopicName] -> ShowS #
IsString TopicName Source #
Instance details Defined in Network.Kafka.Protocol Methods fromString :: String -> TopicName #
Generic TopicName Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep TopicName :: Type -> Type # Methods from :: TopicName -> Rep TopicName x # to :: Rep TopicName x -> TopicName #
Deserializable TopicName Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get TopicName Source #
Serializable TopicName Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: TopicName -> Put Source #
type Rep TopicName Source #
Instance details Defined in Network.Kafka.Protocol type Rep TopicName = D1 (MetaData "TopicName" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 Methods (==) :: MetadataRequest -> MetadataRequest -> Bool # (/=) :: MetadataRequest -> MetadataRequest -> Bool #
Show MetadataRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> MetadataRequest -> ShowS # show :: MetadataRequest -> String # showList :: [MetadataRequest] -> ShowS #
Generic MetadataRequest Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep MetadataRequest :: Type -> Type # Methods from :: MetadataRequest -> Rep MetadataRequest x # to :: Rep MetadataRequest x -> MetadataRequest #
Deserializable MetadataRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MetadataRequest Source #
Serializable MetadataRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MetadataRequest -> Put Source #
type Rep MetadataRequest Source #
Instance details Defined in Network.Kafka.Protocol type Rep MetadataRequest = D1 (MetaData "MetadataRequest" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "MetadataReq" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [TopicName])))

data RequestMessage Source #

Constructors

MetadataRequest MetadataRequest
ProduceRequest ProduceRequest
FetchRequest FetchRequest
OffsetRequest OffsetRequest
OffsetCommitRequest OffsetCommitRequest
OffsetFetchRequest OffsetFetchRequest
GroupCoordinatorRequest GroupCoordinatorRequest
CreateTopicsRequest CreateTopicsRequest
DeleteTopicsRequest DeleteTopicsRequest

Instances

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

newtype ClientId Source #

Constructors

ClientId KafkaString

Instances

Eq ClientId Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: ClientId -> ClientId -> Bool # (/=) :: ClientId -> ClientId -> Bool #
Show ClientId Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> ClientId -> ShowS # show :: ClientId -> String # showList :: [ClientId] -> ShowS #
IsString ClientId Source #
Instance details Defined in Network.Kafka.Protocol Methods fromString :: String -> ClientId #
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 Methods deserialize :: Get ClientId Source #
Serializable ClientId Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ClientId -> Put Source #
type Rep ClientId Source #
Instance details Defined in Network.Kafka.Protocol type Rep ClientId = D1 (MetaData "ClientId" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: CorrelationId -> CorrelationId -> Bool # (/=) :: CorrelationId -> CorrelationId -> Bool #
Integral CorrelationId Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: CorrelationId -> CorrelationId -> CorrelationId # (-) :: CorrelationId -> CorrelationId -> CorrelationId # (*) :: CorrelationId -> CorrelationId -> CorrelationId # negate :: CorrelationId -> CorrelationId # abs :: CorrelationId -> CorrelationId # signum :: CorrelationId -> CorrelationId # fromInteger :: Integer -> CorrelationId #
Ord CorrelationId Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: CorrelationId -> Rational #
Show CorrelationId Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> CorrelationId -> ShowS # show :: CorrelationId -> String # showList :: [CorrelationId] -> ShowS #
Generic CorrelationId Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep CorrelationId :: Type -> Type # Methods from :: CorrelationId -> Rep CorrelationId x # to :: Rep CorrelationId x -> CorrelationId #
Deserializable CorrelationId Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get CorrelationId Source #
Serializable CorrelationId Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: CorrelationId -> Put Source #
type Rep CorrelationId Source #
Instance details Defined in Network.Kafka.Protocol type Rep CorrelationId = D1 (MetaData "CorrelationId" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (==) :: ApiVersion -> ApiVersion -> Bool # (/=) :: ApiVersion -> ApiVersion -> Bool #
Integral ApiVersion Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: ApiVersion -> ApiVersion -> ApiVersion # (-) :: ApiVersion -> ApiVersion -> ApiVersion # (*) :: ApiVersion -> ApiVersion -> ApiVersion # negate :: ApiVersion -> ApiVersion # abs :: ApiVersion -> ApiVersion # signum :: ApiVersion -> ApiVersion # fromInteger :: Integer -> ApiVersion #
Ord ApiVersion Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: ApiVersion -> Rational #
Show ApiVersion Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> ApiVersion -> ShowS # show :: ApiVersion -> String # showList :: [ApiVersion] -> ShowS #
Generic ApiVersion Source #
Instance details Defined in Network.Kafka.Protocol Associated Types type Rep ApiVersion :: Type -> Type # Methods from :: ApiVersion -> Rep ApiVersion x # to :: Rep ApiVersion x -> ApiVersion #
Deserializable ApiVersion Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get ApiVersion Source #
Serializable ApiVersion Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ApiVersion -> Put Source #
type Rep ApiVersion Source #
Instance details Defined in Network.Kafka.Protocol type Rep ApiVersion = D1 (MetaData "ApiVersion" "Network.Kafka.Protocol" "milena-0.5.4.0-27nMlnYTid12v1ZBZP3eqt" 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 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 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 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods (+) :: ApiKey -> ApiKey -> ApiKey # (-) :: ApiKey -> ApiKey -> ApiKey # (*) :: ApiKey -> ApiKey -> ApiKey # negate :: ApiKey -> ApiKey # abs :: ApiKey -> ApiKey # signum :: ApiKey -> ApiKey # fromInteger :: Integer -> ApiKey #
Ord ApiKey Source #
Instance details Defined in Network.Kafka.Protocol 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 Source #
Instance details Defined in Network.Kafka.Protocol Methods toRational :: ApiKey -> Rational #
Show ApiKey Source #
Instance details Defined in Network.Kafka.Protocol Methods showsPrec :: Int -> ApiKey -> ShowS # show :: ApiKey -> String # showList :: [ApiKey] -> ShowS #
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 Methods deserialize :: Get ApiKey Source #
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.4.0-27nMlnYTid12v1ZBZP3eqt" True) (C1 (MetaCons "ApiKey" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int16)))

newtype GroupCoordinatorResponse Source #

Constructors

GroupCoordinatorResp (KafkaError, Broker)

Instances

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

class Deserializable a where Source #

Methods

deserialize :: Get a Source #

Instances

Deserializable Int8 Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Int8 Source #
Deserializable Int16 Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Int16 Source #
Deserializable Int32 Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Int32 Source #
Deserializable Int64 Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Int64 Source #
Deserializable KafkaError Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get KafkaError Source #
Deserializable Metadata Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Metadata Source #
Deserializable ConsumerGroup Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get ConsumerGroup Source #
Deserializable ReplicationFactor Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get ReplicationFactor Source #
Deserializable Value Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Value Source #
Deserializable Key Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Key Source #
Deserializable Attributes Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Attributes Source #
Deserializable MagicByte Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MagicByte Source #
Deserializable Crc Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Crc Source #
Deserializable Message Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Message Source #
Deserializable Offset Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Offset Source #
Deserializable MessageSetMember Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MessageSetMember Source #
Deserializable MessageSet Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MessageSet Source #
Deserializable Partition Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Partition Source #
Deserializable Timeout Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Timeout Source #
Deserializable RequiredAcks Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get RequiredAcks Source #
Deserializable MaxBytes Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MaxBytes Source #
Deserializable MinBytes Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MinBytes Source #
Deserializable MaxWaitTime Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MaxWaitTime Source #
Deserializable ReplicaId Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get ReplicaId Source #
Deserializable FetchRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get FetchRequest Source #
Deserializable OffsetFetchResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get OffsetFetchResponse Source #
Deserializable OffsetCommitResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get OffsetCommitResponse Source #
Deserializable Isr Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Isr Source #
Deserializable Replicas Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Replicas Source #
Deserializable Leader Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Leader Source #
Deserializable PartitionMetadata Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get PartitionMetadata Source #
Deserializable TopicMetadata Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get TopicMetadata Source #
Deserializable Port Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Port Source #
Deserializable Host Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Host Source #
Deserializable NodeId Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get NodeId Source #
Deserializable Broker Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get Broker Source #
Deserializable MetadataResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MetadataResponse Source #
Deserializable DeleteTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get DeleteTopicsResponse Source #
Deserializable CreateTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get CreateTopicsResponse Source #
Deserializable FetchResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get FetchResponse Source #
Deserializable PartitionOffsets Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get PartitionOffsets Source #
Deserializable OffsetResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get OffsetResponse Source #
Deserializable ProduceResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get ProduceResponse Source #
Deserializable KafkaString Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get KafkaString Source #
Deserializable KafkaBytes Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get KafkaBytes Source #
Deserializable TopicName Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get TopicName Source #
Deserializable MetadataRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get MetadataRequest Source #
Deserializable ClientId Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get ClientId Source #
Deserializable CorrelationId Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get CorrelationId Source #
Deserializable ApiVersion Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get ApiVersion Source #
Deserializable ApiKey Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get ApiKey Source #
Deserializable GroupCoordinatorResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods deserialize :: Get GroupCoordinatorResponse Source #
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 Methods serialize :: Request -> Put Source #
Serializable KafkaError Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: KafkaError -> Put Source #
Serializable Metadata Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: Metadata -> Put Source #
Serializable ConsumerGroup Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ConsumerGroup -> Put Source #
Serializable OffsetFetchRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: OffsetFetchRequest -> Put Source #
Serializable OffsetCommitRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: OffsetCommitRequest -> Put Source #
Serializable DeleteTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: DeleteTopicsRequest -> Put Source #
Serializable CreateTopicsRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: CreateTopicsRequest -> Put Source #
Serializable GroupCoordinatorRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: GroupCoordinatorRequest -> Put Source #
Serializable ReplicationFactor Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ReplicationFactor -> Put Source #
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 Methods serialize :: Attributes -> Put Source #
Serializable MagicByte Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MagicByte -> Put Source #
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 Methods serialize :: Message -> Put Source #
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 Methods serialize :: MessageSetMember -> Put Source #
Serializable MessageSet Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MessageSet -> Put Source #
Serializable Partition Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: Partition -> Put Source #
Serializable Timeout Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: Timeout -> Put Source #
Serializable RequiredAcks Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: RequiredAcks -> Put Source #
Serializable ProduceRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ProduceRequest -> Put Source #
Serializable MaxBytes Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MaxBytes -> Put Source #
Serializable MinBytes Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MinBytes -> Put Source #
Serializable MaxWaitTime Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MaxWaitTime -> Put Source #
Serializable ReplicaId Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ReplicaId -> Put Source #
Serializable FetchRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: FetchRequest -> Put Source #
Serializable MaxNumberOfOffsets Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MaxNumberOfOffsets -> Put Source #
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 Methods serialize :: OffsetRequest -> Put Source #
Serializable Replicas Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: Replicas -> Put Source #
Serializable DeleteTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: DeleteTopicsResponse -> Put Source #
Serializable CreateTopicsResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: CreateTopicsResponse -> Put Source #
Serializable FetchResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: FetchResponse -> Put Source #
Serializable ProduceResponse Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ProduceResponse -> Put Source #
Serializable KafkaString Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: KafkaString -> Put Source #
Serializable KafkaBytes Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: KafkaBytes -> Put Source #
Serializable TopicName Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: TopicName -> Put Source #
Serializable MetadataRequest Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: MetadataRequest -> Put Source #
Serializable RequestMessage Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: RequestMessage -> Put Source #
Serializable ClientId Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ClientId -> Put Source #
Serializable CorrelationId Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: CorrelationId -> Put Source #
Serializable ApiVersion Source #
Instance details Defined in Network.Kafka.Protocol Methods serialize :: ApiVersion -> Put Source #
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 #

data ReqResp a where Source #

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)
TopicsRR :: MonadIO m => CreateTopicsRequest -> ReqResp (m CreateTopicsResponse)
DeleteTopicsRR :: MonadIO m => DeleteTopicsRequest -> ReqResp (m DeleteTopicsResponse)
OffsetCommitRR :: MonadIO m => OffsetCommitRequest -> ReqResp (m OffsetCommitResponse)
OffsetFetchRR :: MonadIO m => OffsetFetchRequest -> ReqResp (m OffsetFetchResponse)