Safe Haskell | None |
---|---|
Language | Haskell2010 |
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 #
Instances
Eq EncodeError Source # | |
Defined in Kafka.Avro.Encode (==) :: EncodeError -> EncodeError -> Bool # (/=) :: EncodeError -> EncodeError -> Bool # | |
Show EncodeError Source # | |
Defined in Kafka.Avro.Encode 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 #