hw-kafka-avro-6.1.2: Avro support for Kafka infrastructure

Safe Haskell	Safe-Inferred
Language	Haskell2010

Kafka.Avro.Encode

Synopsis

data EncodeError = EncodeRegistryError SchemaRegistryError
encodeKey :: (MonadIO m, HasAvroSchema a, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString)
encodeValue :: (MonadIO m, HasAvroSchema a, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString)
encode :: (MonadIO m, HasAvroSchema a, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString)
encodeKeyWithSchema :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> Schema -> a -> m (Either EncodeError ByteString)
encodeValueWithSchema :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> Schema -> a -> m (Either EncodeError ByteString)
encodeWithSchema :: forall a m. (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> Schema -> a -> m (Either EncodeError ByteString)
keySubject :: Subject -> Subject
valueSubject :: Subject -> Subject

Documentation

data EncodeError Source #

Constructors

EncodeRegistryError SchemaRegistryError

Instances

Instances details

Show EncodeError Source #
Instance details Defined in Kafka.Avro.Encode Methods showsPrec :: Int -> EncodeError -> ShowS # show :: EncodeError -> String # showList :: [EncodeError] -> ShowS #
Eq EncodeError Source #
Instance details Defined in Kafka.Avro.Encode Methods (==) :: EncodeError -> EncodeError -> Bool # (/=) :: EncodeError -> EncodeError -> Bool #

encodeKey :: (MonadIO m, HasAvroSchema a, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString) Source #

Encodes a provided value as a message key with "subject-key" subject.

encodeValue :: (MonadIO m, HasAvroSchema a, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString) Source #

Encodes a provided value as a message value with "subject-value" subject.

encode :: (MonadIO m, HasAvroSchema a, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString) Source #

encodeKeyWithSchema :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> Schema -> a -> m (Either EncodeError ByteString) Source #

Encodes a provided value as a message key with "subject-key" subject.

encodeValueWithSchema :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> Schema -> a -> m (Either EncodeError ByteString) Source #

Encodes a provided value as a message value with "subject-value" subject.

encodeWithSchema :: forall a m. (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> Schema -> a -> m (Either EncodeError ByteString) Source #

Encodes a provided value into Avro

keySubject :: Subject -> Subject Source #

valueSubject :: Subject -> Subject Source #