| Safe Haskell | None |
|---|---|
| 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
| Eq EncodeError Source # | |
Defined in Kafka.Avro.Encode | |
| Show EncodeError Source # | |
Defined in Kafka.Avro.Encode Methods showsPrec :: Int -> EncodeError -> ShowS # show :: EncodeError -> String # showList :: [EncodeError] -> ShowS # | |
encodeKey :: (MonadIO m, HasAvroSchema a, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString) Source #
Encodes a provided value as a message key.
Registers the schema in SchemaRegistry 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.
Registers the schema in SchemaRegistry 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.
Registers the schema in SchemaRegistry 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.
Registers the schema in SchemaRegistry 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 and registers value's schema in SchemaRegistry.
keySubject :: Subject -> Subject Source #
valueSubject :: Subject -> Subject Source #