http4k-connect-kafka-schemaregistry/org.http4k.connect.kafka.schemaregistry.action

Package-level declarations

Types

CheckSchemaRegistered

data class CheckSchemaRegistered(val subject: Subject, val schema: Schema) : NullableAutoMarshalledAction<RegisteredSchemaVersion> , SchemaRegistryAction<RegisteredSchemaVersion?>

data class GetSchemaById(val id: SchemaId) : NullableAutoMarshalledAction<SchemaById> , SchemaRegistryAction<SchemaById?>

object GetSubjects : NonNullAutoMarshalledAction<Array<Subject>> , SchemaRegistryAction<Array<Subject>>

GetSubjectVersion

data class GetSubjectVersion(val subject: Subject, val version: Version) : NullableAutoMarshalledAction<RegisteredSchemaVersion> , SchemaRegistryAction<RegisteredSchemaVersion?>

GetSubjectVersions

data class GetSubjectVersions(val subject: Subject) : NonNullAutoMarshalledAction<Array<Version>> , SchemaRegistryAction<Array<Version>>

data class PostedSchema(val schema: Schema)

data class References(val name: SchemaName, val subject: Subject, val version: Version)

RegisteredSchema

data class RegisteredSchema(val id: SchemaId)

RegisteredSchemaVersion

@JsonSerializable

data class RegisteredSchemaVersion(val subject: Subject, val id: SchemaId, val version: Version, val schema: Schema)

data class RegisterSchema(val subject: Subject, val schema: Schema, val schemaType: SchemaType, val references: List<References>) : NonNullAutoMarshalledAction<RegisteredSchema> , SchemaRegistryAction<RegisteredSchema>

RegisterSchemaVersionReq

data class RegisterSchemaVersionReq(val schema: Schema, val schemaType: SchemaType, val references: List<References>)

data class SchemaById(val schema: Schema)