internal

type Decoder struct {
	// contains filtered or unexported fields
}

type DownloadSchemaStrategy struct {
	Subject string
	// TODO add support for specifying "latest" - https://github.com/ConduitIO/conduit/issues/1095
	Version int
}

type Encoder struct {
	SchemaStrategy
	// contains filtered or unexported fields
}

type ExtractAndUploadSchemaStrategy struct {
	Subject string
}

type SchemaStrategy interface {
	GetSchema(context.Context, schemaregistry.Registry, log.CtxLogger, opencdc.StructuredData) (schema.Schema, error)
}