Safe Haskell	Safe-Inferred
Language	Haskell2010

Kafka.Metadata.Response.V12

Contents

Predicates

Synopsis

data Response = Response {
- throttleTimeMilliseconds :: !Int32
- brokers :: !(SmallArray Broker)
- clusterId :: !Text
- controllerId :: !Int32
- topics :: !(SmallArray Topic)
- taggedFields :: !(SmallArray TaggedField)
}
data Broker = Broker {
- nodeId :: !Int32
- host :: !Text
- port :: !Word16
- rack :: !Text
- taggedFields :: !(SmallArray TaggedField)
}
data Topic = Topic {
- errorCode :: !ErrorCode
- name :: !Text
- id :: !Word128
- internal :: !Bool
- partitions :: !(SmallArray Partition)
- authorizedOperations :: !Word32
- taggedFields :: !(SmallArray TaggedField)
}
data Partition = Partition {
- errorCode :: !ErrorCode
- index :: !Int32
- leaderId :: !Int32
- leaderEpoch :: !Int32
- replicaNodes :: !(PrimArray Int32)
- isrNodes :: !(PrimArray Int32)
- offlineReplicas :: !(PrimArray Int32)
- taggedFields :: !(SmallArray TaggedField)
}
data Error = Error {
- index :: !Int32
- message :: !Text
- taggedFields :: !(SmallArray TaggedField)
}
parser :: Context -> Parser Context s Response
decode :: Bytes -> Either Context Response
decodeHeaded :: Bytes -> Either Context (Headed Response)
hasErrorCode :: Response -> Bool
findErrorCode :: Response -> Maybe ContextualizedErrorCode

Documentation

data Response Source #

Constructors

Response
Fields throttleTimeMilliseconds :: !Int32 brokers :: !(SmallArray Broker) clusterId :: !Text controllerId :: !Int32 topics :: !(SmallArray Topic) taggedFields :: !(SmallArray TaggedField)

Instances

Instances details

Show Response Source #
Instance details Defined in Kafka.Metadata.Response.V12 Methods showsPrec :: Int -> Response -> ShowS # show :: Response -> String # showList :: [Response] -> ShowS #

data Broker Source #

Constructors

Broker
Fields nodeId :: !Int32 host :: !Text port :: !Word16 Even though Kafka has this as a 32-bit signed integer, I believe that it should only ever be a 16-bit unsigned integer. rack :: !Text taggedFields :: !(SmallArray TaggedField)

Instances

Instances details

Show Broker Source #
Instance details Defined in Kafka.Metadata.Response.V12 Methods showsPrec :: Int -> Broker -> ShowS # show :: Broker -> String # showList :: [Broker] -> ShowS #

data Topic Source #

Constructors

Topic
Fields errorCode :: !ErrorCode name :: !Text id :: !Word128 internal :: !Bool partitions :: !(SmallArray Partition) authorizedOperations :: !Word32 Authorized Operations: a bitfield. The spec has this as a signed integral type, but that was probably only done because of limitations with Java. taggedFields :: !(SmallArray TaggedField)

Instances

Instances details

Show Topic Source #
Instance details Defined in Kafka.Metadata.Response.V12 Methods showsPrec :: Int -> Topic -> ShowS # show :: Topic -> String # showList :: [Topic] -> ShowS #

data Partition Source #

Constructors

Partition
Fields errorCode :: !ErrorCode index :: !Int32 leaderId :: !Int32 leaderEpoch :: !Int32 replicaNodes :: !(PrimArray Int32) isrNodes :: !(PrimArray Int32) offlineReplicas :: !(PrimArray Int32) taggedFields :: !(SmallArray TaggedField)

Instances

Instances details

Show Partition Source #
Instance details Defined in Kafka.Metadata.Response.V12 Methods showsPrec :: Int -> Partition -> ShowS # show :: Partition -> String # showList :: [Partition] -> ShowS #

data Error Source #

Constructors

Error
Fields index :: !Int32 message :: !Text taggedFields :: !(SmallArray TaggedField)

Instances

Instances details

Show Error Source #
Instance details Defined in Kafka.Metadata.Response.V12 Methods showsPrec :: Int -> Error -> ShowS # show :: Error -> String # showList :: [Error] -> ShowS #

parser :: Context -> Parser Context s Response Source #

decode :: Bytes -> Either Context Response Source #

decodeHeaded :: Bytes -> Either Context (Headed Response) Source #

Predicates

hasErrorCode :: Response -> Bool Source #

Search through all topics and partitions for any error codes that are not set to NONE.

findErrorCode :: Response -> Maybe ContextualizedErrorCode Source #

Find the first error code of any kind in the response. This looks for topic-level error codes first and then moves on searching for partition-level error codes.