Safe Haskell | None |
---|---|
Language | Haskell2010 |
- encodeKey :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString)
- encodeValue :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString)
- keySubject :: Subject -> Subject
- valueSubject :: Subject -> Subject
- encodeWithSchema :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString)
- data EncodeError = EncodeRegistryError SchemaRegistryError
Documentation
encodeKey :: (MonadIO m, 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, 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.
keySubject :: Subject -> Subject Source #
valueSubject :: Subject -> Subject Source #
encodeWithSchema :: (MonadIO m, ToAvro a) => SchemaRegistry -> Subject -> a -> m (Either EncodeError ByteString) Source #
Encodes a provided value into Avro and registers value's schema in SchemaRegistry.