Haskakafka.InternalRdKafka

Documentation

type CInt64T = CLong

type CInt32T = CInt

type CFilePtr = Ptr CFile

type CSizePtr = Ptr CSize

type Word8Ptr = Ptr Word8

type CCharBufPointer = Ptr CChar

type RdKafkaMsgFlag = Int

rdKafkaMsgFlagFree :: RdKafkaMsgFlag

rdKafkaMsgFlagCopy :: RdKafkaMsgFlag

nErrorBytes :: Int

rdKafkaVersion :: Int

rdKafkaVersionStr :: String

rdKafkaErr2str :: RdKafkaRespErrT -> String

rdKafkaErrno2err :: Int -> RdKafkaRespErrT

kafkaErrnoString :: IO String

data RdKafkaConfT

type RdKafkaConfTPtr = ForeignPtr RdKafkaConfT

data RdKafkaTopicConfT

type RdKafkaTopicConfTPtr = ForeignPtr RdKafkaTopicConfT

data RdKafkaT

type RdKafkaTPtr = ForeignPtr RdKafkaT

data RdKafkaTopicT

type RdKafkaTopicTPtr = ForeignPtr RdKafkaTopicT

data RdKafkaMessageT

Constructors

RdKafkaMessageT

Fields

err'RdKafkaMessageT :: RdKafkaRespErrT

partition'RdKafkaMessageT :: Int

len'RdKafkaMessageT :: Int

keyLen'RdKafkaMessageT :: Int

offset'RdKafkaMessageT :: Int64

payload'RdKafkaMessageT :: Word8Ptr

key'RdKafkaMessageT :: Word8Ptr

Instances

Eq RdKafkaMessageT

Show RdKafkaMessageT

Storable RdKafkaMessageT

type RdKafkaMessageTPtr = ForeignPtr RdKafkaMessageT

data RdKafkaMetadataBrokerT

Constructors

RdKafkaMetadataBrokerT

Fields

id'RdKafkaMetadataBrokerT :: Int

host'RdKafkaMetadataBrokerT :: CString

port'RdKafkaMetadataBrokerT :: Int

Instances

Eq RdKafkaMetadataBrokerT

Show RdKafkaMetadataBrokerT

Storable RdKafkaMetadataBrokerT

type RdKafkaMetadataBrokerTPtr = Ptr RdKafkaMetadataBrokerT

data RdKafkaMetadataPartitionT

Constructors

RdKafkaMetadataPartitionT

Fields

id'RdKafkaMetadataPartitionT :: Int

err'RdKafkaMetadataPartitionT :: RdKafkaRespErrT

leader'RdKafkaMetadataPartitionT :: Int

replicaCnt'RdKafkaMetadataPartitionT :: Int

replicas'RdKafkaMetadataPartitionT :: Ptr CInt32T

isrCnt'RdKafkaMetadataPartitionT :: Int

isrs'RdKafkaMetadataPartitionT :: Ptr CInt32T

Instances

Eq RdKafkaMetadataPartitionT

Show RdKafkaMetadataPartitionT

Storable RdKafkaMetadataPartitionT

type RdKafkaMetadataPartitionTPtr = Ptr RdKafkaMetadataPartitionT

data RdKafkaMetadataTopicT

Constructors

RdKafkaMetadataTopicT

Fields

topic'RdKafkaMetadataTopicT :: CString

partitionCnt'RdKafkaMetadataTopicT :: Int

partitions'RdKafkaMetadataTopicT :: Ptr RdKafkaMetadataPartitionT

err'RdKafkaMetadataTopicT :: RdKafkaRespErrT

Instances

Eq RdKafkaMetadataTopicT

Show RdKafkaMetadataTopicT

Storable RdKafkaMetadataTopicT

type RdKafkaMetadataTopicTPtr = Ptr RdKafkaMetadataTopicT

data RdKafkaMetadataT

Constructors

RdKafkaMetadataT

Fields

brokerCnt'RdKafkaMetadataT :: Int

brokers'RdKafkaMetadataT :: RdKafkaMetadataBrokerTPtr

topicCnt'RdKafkaMetadataT :: Int

topics'RdKafkaMetadataT :: RdKafkaMetadataTopicTPtr

origBrokerId'RdKafkaMetadataT :: CInt32T

Instances

Eq RdKafkaMetadataT

Show RdKafkaMetadataT

Storable RdKafkaMetadataT

type RdKafkaMetadataTPtr = ForeignPtr RdKafkaMetadataT

rdKafkaMessageDestroy :: FunPtr (Ptr RdKafkaMessageT -> IO ())

rdKafkaConfNew :: IO RdKafkaConfTPtr

rdKafkaConfDestroy :: FunPtr (Ptr RdKafkaConfT -> IO ())

rdKafkaConfDup :: RdKafkaConfTPtr -> IO RdKafkaConfTPtr

rdKafkaConfSet :: RdKafkaConfTPtr -> String -> String -> CCharBufPointer -> CSize -> IO RdKafkaConfResT

newRdKafkaConfT :: IO RdKafkaConfTPtr

rdKafkaConfDump :: RdKafkaConfTPtr -> CSizePtr -> IO (Ptr CString)

rdKafkaConfDumpFree :: Ptr CString -> CSize -> IO ()

rdKafkaConfPropertiesShow :: CFilePtr -> IO ()

rdKafkaTopicConfNew :: IO RdKafkaTopicConfTPtr

rdKafkaTopicConfDup :: RdKafkaTopicConfTPtr -> IO RdKafkaTopicConfTPtr

rdKafkaTopicConfDestroy :: FunPtr (Ptr RdKafkaTopicConfT -> IO ())

rdKafkaTopicConfSet :: RdKafkaTopicConfTPtr -> String -> String -> CCharBufPointer -> CSize -> IO RdKafkaConfResT

newRdKafkaTopicConfT :: IO RdKafkaTopicConfTPtr

rdKafkaTopicConfDump :: RdKafkaTopicConfTPtr -> CSizePtr -> IO (Ptr CString)

rdKafkaNew :: RdKafkaTypeT -> RdKafkaConfTPtr -> CCharBufPointer -> CSize -> IO RdKafkaTPtr

rdKafkaDestroy :: FunPtr (Ptr RdKafkaT -> IO ())

newRdKafkaT :: RdKafkaTypeT -> RdKafkaConfTPtr -> IO (Either String RdKafkaTPtr)

rdKafkaBrokersAdd :: RdKafkaTPtr -> String -> IO Int

rdKafkaSetLogLevel :: RdKafkaTPtr -> Int -> IO ()

rdKafkaConsumeStartInternal :: RdKafkaTopicTPtr -> CInt32T -> CInt64T -> IO Int

rdKafkaConsumeStart :: RdKafkaTopicTPtr -> Int -> Int64 -> IO (Maybe String)

rdKafkaConsumeStopInternal :: RdKafkaTopicTPtr -> CInt32T -> IO Int

rdKafkaConsume :: RdKafkaTopicTPtr -> CInt32T -> Int -> IO RdKafkaMessageTPtr

rdKafkaConsumeBatch :: RdKafkaTopicTPtr -> CInt32T -> Int -> Ptr (Ptr RdKafkaMessageT) -> CSize -> IO CSize

rdKafkaConsumeStop :: RdKafkaTopicTPtr -> Int -> IO (Maybe String)

rdKafkaOffsetStore :: RdKafkaTopicTPtr -> CInt32T -> CInt64T -> IO RdKafkaRespErrT

rdKafkaProduce :: RdKafkaTopicTPtr -> CInt32T -> Int -> Word8Ptr -> CSize -> Word8Ptr -> CSize -> Word8Ptr -> IO Int

rdKafkaProduceBatch :: RdKafkaTopicTPtr -> CInt32T -> Int -> RdKafkaMessageTPtr -> Int -> IO Int

castMetadata :: Ptr (Ptr RdKafkaMetadataT) -> Ptr (Ptr ())

rdKafkaMetadata :: RdKafkaTPtr -> Bool -> RdKafkaTopicTPtr -> Ptr (Ptr RdKafkaMetadataT) -> Int -> IO RdKafkaRespErrT

rdKafkaMetadataDestroy :: Ptr RdKafkaMetadataT -> IO ()

rdKafkaPoll :: RdKafkaTPtr -> Int -> IO Int

rdKafkaOutqLen :: RdKafkaTPtr -> IO Int

rdKafkaDump :: CFilePtr -> RdKafkaTPtr -> IO ()

rdKafkaTopicNew :: RdKafkaTPtr -> String -> RdKafkaTopicConfTPtr -> IO RdKafkaTopicTPtr

rdKafkaTopicDestroy :: FunPtr (Ptr RdKafkaTopicT -> IO ())

newRdKafkaTopicT :: RdKafkaTPtr -> String -> RdKafkaTopicConfTPtr -> IO (Either String RdKafkaTopicTPtr)

enumToCInt :: Enum a => a -> CInt

cIntToEnum :: Enum a => CInt -> a

cIntConv :: (Integral a, Num b) => a -> b

boolToCInt :: Bool -> CInt

fdopen :: Fd -> CString -> IO (Ptr CFile)

handleToCFile :: Handle -> String -> IO CFilePtr

c_stdin :: IO CFilePtr

c_stdout :: IO CFilePtr

c_stderr :: IO CFilePtr

rdKafkaVersion'_ :: CInt

rdKafkaVersionStr'_ :: Ptr CChar

rdKafkaErr2str'_ :: CInt -> Ptr CChar

rdKafkaErrno2err'_ :: CInt -> CInt

rdKafkaConfNew'_ :: IO (Ptr RdKafkaConfT)

rdKafkaConfDup'_ :: Ptr RdKafkaConfT -> IO (Ptr RdKafkaConfT)

rdKafkaConfSet'_ :: Ptr RdKafkaConfT -> Ptr CChar -> Ptr CChar -> Ptr CChar -> CULong -> IO CInt

rdKafkaConfDump'_ :: Ptr RdKafkaConfT -> CSizePtr -> IO (Ptr (Ptr CChar))

rdKafkaConfDumpFree'_ :: Ptr (Ptr CChar) -> CULong -> IO ()

rdKafkaConfPropertiesShow'_ :: CFilePtr -> IO ()

rdKafkaTopicConfNew'_ :: IO (Ptr RdKafkaTopicConfT)

rdKafkaTopicConfDup'_ :: Ptr RdKafkaTopicConfT -> IO (Ptr RdKafkaTopicConfT)

rdKafkaTopicConfSet'_ :: Ptr RdKafkaTopicConfT -> Ptr CChar -> Ptr CChar -> Ptr CChar -> CULong -> IO CInt

rdKafkaTopicConfDump'_ :: Ptr RdKafkaTopicConfT -> CSizePtr -> IO (Ptr (Ptr CChar))

rdKafkaNew'_ :: CInt -> Ptr RdKafkaConfT -> Ptr CChar -> CULong -> IO (Ptr RdKafkaT)

rdKafkaBrokersAdd'_ :: Ptr RdKafkaT -> Ptr CChar -> IO CInt

rdKafkaSetLogLevel'_ :: Ptr RdKafkaT -> CInt -> IO ()

rdKafkaConsumeStartInternal'_ :: Ptr RdKafkaTopicT -> CInt -> CLong -> IO CInt

rdKafkaConsumeStopInternal'_ :: Ptr RdKafkaTopicT -> CInt -> IO CInt

rdKafkaConsume'_ :: Ptr RdKafkaTopicT -> CInt -> CInt -> IO (Ptr RdKafkaMessageT)

rdKafkaConsumeBatch'_ :: Ptr RdKafkaTopicT -> CInt -> CInt -> Ptr (Ptr RdKafkaMessageT) -> CULong -> IO CLong

rdKafkaOffsetStore'_ :: Ptr RdKafkaTopicT -> CInt -> CLong -> IO CInt

rdKafkaProduce'_ :: Ptr RdKafkaTopicT -> CInt -> CInt -> Ptr () -> CULong -> Ptr () -> CULong -> Ptr () -> IO CInt

rdKafkaProduceBatch'_ :: Ptr RdKafkaTopicT -> CInt -> CInt -> Ptr RdKafkaMessageT -> CInt -> IO CInt

rdKafkaMetadata'_ :: Ptr RdKafkaT -> CInt -> Ptr RdKafkaTopicT -> Ptr (Ptr ()) -> CInt -> IO CInt

rdKafkaMetadataDestroy'_ :: Ptr () -> IO ()

rdKafkaPoll'_ :: Ptr RdKafkaT -> CInt -> IO CInt

rdKafkaOutqLen'_ :: Ptr RdKafkaT -> IO CInt

rdKafkaDump'_ :: CFilePtr -> Ptr RdKafkaT -> IO ()

rdKafkaTopicNew'_ :: Ptr RdKafkaT -> Ptr CChar -> Ptr RdKafkaTopicConfT -> IO (Ptr RdKafkaTopicT)