Safe Haskell | None |
---|---|
Language | Haskell2010 |
Synopsis
- schemaRegistry :: MonadIO m => String -> m SchemaRegistry
- loadSchema :: MonadIO m => SchemaRegistry -> SchemaId -> m (Either SchemaRegistryError Schema)
- sendSchema :: MonadIO m => SchemaRegistry -> Subject -> Schema -> m (Either SchemaRegistryError SchemaId)
- loadSubjectSchema :: MonadIO m => SchemaRegistry -> Subject -> Version -> m (Either SchemaRegistryError Schema)
- getGlobalConfig :: MonadIO m => SchemaRegistry -> m (Either SchemaRegistryError Compatibility)
- getSubjectConfig :: MonadIO m => SchemaRegistry -> Subject -> m (Either SchemaRegistryError Compatibility)
- getVersions :: MonadIO m => SchemaRegistry -> Subject -> m (Either SchemaRegistryError [Version])
- isCompatible :: MonadIO m => SchemaRegistry -> Subject -> Version -> Schema -> m (Either SchemaRegistryError Bool)
- getSubjects :: MonadIO m => SchemaRegistry -> m (Either SchemaRegistryError [Subject])
- newtype SchemaId = SchemaId {
- unSchemaId :: Int32
- newtype Subject = Subject {}
- data SchemaRegistry
- data SchemaRegistryError
- type Schema = Type
- data Compatibility
- newtype Version = Version {}
Documentation
schemaRegistry :: MonadIO m => String -> m SchemaRegistry Source #
loadSchema :: MonadIO m => SchemaRegistry -> SchemaId -> m (Either SchemaRegistryError Schema) Source #
sendSchema :: MonadIO m => SchemaRegistry -> Subject -> Schema -> m (Either SchemaRegistryError SchemaId) Source #
loadSubjectSchema :: MonadIO m => SchemaRegistry -> Subject -> Version -> m (Either SchemaRegistryError Schema) Source #
getGlobalConfig :: MonadIO m => SchemaRegistry -> m (Either SchemaRegistryError Compatibility) Source #
getSubjectConfig :: MonadIO m => SchemaRegistry -> Subject -> m (Either SchemaRegistryError Compatibility) Source #
getVersions :: MonadIO m => SchemaRegistry -> Subject -> m (Either SchemaRegistryError [Version]) Source #
isCompatible :: MonadIO m => SchemaRegistry -> Subject -> Version -> Schema -> m (Either SchemaRegistryError Bool) Source #
getSubjects :: MonadIO m => SchemaRegistry -> m (Either SchemaRegistryError [Subject]) Source #
Instances
Eq Subject Source # | |
Ord Subject Source # | |
Show Subject Source # | |
IsString Subject Source # | |
Defined in Kafka.Avro.SchemaRegistry fromString :: String -> Subject # | |
Generic Subject Source # | |
Hashable Subject Source # | |
Defined in Kafka.Avro.SchemaRegistry | |
type Rep Subject Source # | |
Defined in Kafka.Avro.SchemaRegistry |
data SchemaRegistry Source #
data SchemaRegistryError Source #
SchemaRegistryConnectError String | |
SchemaRegistryLoadError SchemaId | |
SchemaRegistrySchemaNotFound SchemaId | |
SchemaRegistrySendError String |
Instances
Eq SchemaRegistryError Source # | |
Defined in Kafka.Avro.SchemaRegistry (==) :: SchemaRegistryError -> SchemaRegistryError -> Bool # (/=) :: SchemaRegistryError -> SchemaRegistryError -> Bool # | |
Show SchemaRegistryError Source # | |
Defined in Kafka.Avro.SchemaRegistry showsPrec :: Int -> SchemaRegistryError -> ShowS # show :: SchemaRegistryError -> String # showList :: [SchemaRegistryError] -> ShowS # |
An Avro schema is either * A "JSON object in the form `{"type":"typeName" ...` * A "JSON string, naming a defined type" (basic type wo free variablesnames) * A "JSON array, representing a union"
N.B. It is possible to create a Haskell value (of Schema type) that is
not a valid Avro schema by violating one of the above or one of the
conditions called out in validateSchema
.
data Compatibility Source #
Instances
Eq Compatibility Source # | |
Defined in Kafka.Avro.SchemaRegistry (==) :: Compatibility -> Compatibility -> Bool # (/=) :: Compatibility -> Compatibility -> Bool # | |
Ord Compatibility Source # | |
Defined in Kafka.Avro.SchemaRegistry compare :: Compatibility -> Compatibility -> Ordering # (<) :: Compatibility -> Compatibility -> Bool # (<=) :: Compatibility -> Compatibility -> Bool # (>) :: Compatibility -> Compatibility -> Bool # (>=) :: Compatibility -> Compatibility -> Bool # max :: Compatibility -> Compatibility -> Compatibility # min :: Compatibility -> Compatibility -> Compatibility # | |
Show Compatibility Source # | |
Defined in Kafka.Avro.SchemaRegistry showsPrec :: Int -> Compatibility -> ShowS # show :: Compatibility -> String # showList :: [Compatibility] -> ShowS # | |
FromJSON Compatibility Source # | |
Defined in Kafka.Avro.SchemaRegistry parseJSON :: Value -> Parser Compatibility # parseJSONList :: Value -> Parser [Compatibility] # |