Kafka.Avro.SchemaRegistry

Documentation

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)

newtype SchemaId

Constructors

SchemaId Int32

Instances

Eq SchemaId

Methods

(==) :: SchemaId -> SchemaId -> Bool

(/=) :: SchemaId -> SchemaId -> Bool

Ord SchemaId

Methods

compare :: SchemaId -> SchemaId -> Ordering

(<) :: SchemaId -> SchemaId -> Bool

(<=) :: SchemaId -> SchemaId -> Bool

(>) :: SchemaId -> SchemaId -> Bool

(>=) :: SchemaId -> SchemaId -> Bool

max :: SchemaId -> SchemaId -> SchemaId

min :: SchemaId -> SchemaId -> SchemaId

Show SchemaId

Methods

showsPrec :: Int -> SchemaId -> ShowS

show :: SchemaId -> String

showList :: [SchemaId] -> ShowS

Hashable SchemaId

Methods

hashWithSalt :: Int -> SchemaId -> Int

hash :: SchemaId -> Int

FromJSON SchemaId

Methods

parseJSON :: Value -> Parser SchemaId

parseJSONList :: Value -> Parser [SchemaId]

newtype Subject

Constructors

Subject Text

Instances

Eq Subject

Methods

(==) :: Subject -> Subject -> Bool

(/=) :: Subject -> Subject -> Bool

Show Subject

Methods

showsPrec :: Int -> Subject -> ShowS

show :: Subject -> String

showList :: [Subject] -> ShowS

Generic Subject

Associated Types

type Rep Subject :: * -> *

Methods

from :: Subject -> Rep Subject x

to :: Rep Subject x -> Subject

Hashable Subject

Methods

hashWithSalt :: Int -> Subject -> Int

hash :: Subject -> Int

ToHttpApiData Subject

Methods

toUrlPiece :: Subject -> Text

toEncodedUrlPiece :: Subject -> Builder

toHeader :: Subject -> ByteString

toQueryParam :: Subject -> Text

type Rep Subject

type Rep Subject = D1 (MetaData "Subject" "Kafka.Avro.SchemaRegistry" "hw-kafka-avro-1.2.0-GX7nuTCBmaW7Anwhen9nuN" True) (C1 (MetaCons "Subject" PrefixI False) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data SchemaRegistry

data SchemaRegistryError

Constructors

SchemaRegistryConnectError String

SchemaDecodeError SchemaId String

SchemaRegistryLoadError SchemaId

SchemaRegistryError SchemaId

SchemaRegistrySendError String

Instances

Eq SchemaRegistryError

Methods

(==) :: SchemaRegistryError -> SchemaRegistryError -> Bool

(/=) :: SchemaRegistryError -> SchemaRegistryError -> Bool

Show SchemaRegistryError

Methods

showsPrec :: Int -> SchemaRegistryError -> ShowS

show :: SchemaRegistryError -> String

showList :: [SchemaRegistryError] -> ShowS

newtype RegisteredSchema

Constructors

RegisteredSchema Schema

Instances

Show RegisteredSchema

Methods

showsPrec :: Int -> RegisteredSchema -> ShowS

show :: RegisteredSchema -> String

showList :: [RegisteredSchema] -> ShowS

Generic RegisteredSchema

Associated Types

type Rep RegisteredSchema :: * -> *

Methods

from :: RegisteredSchema -> Rep RegisteredSchema x

to :: Rep RegisteredSchema x -> RegisteredSchema

ToJSON RegisteredSchema

Methods

toJSON :: RegisteredSchema -> Value

toEncoding :: RegisteredSchema -> Encoding

toJSONList :: [RegisteredSchema] -> Value

toEncodingList :: [RegisteredSchema] -> Encoding

FromJSON RegisteredSchema

Methods

parseJSON :: Value -> Parser RegisteredSchema

parseJSONList :: Value -> Parser [RegisteredSchema]

type Rep RegisteredSchema

type Rep RegisteredSchema = D1 (MetaData "RegisteredSchema" "Kafka.Avro.SchemaRegistry" "hw-kafka-avro-1.2.0-GX7nuTCBmaW7Anwhen9nuN" True) (C1 (MetaCons "RegisteredSchema" PrefixI False) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Schema)))