avro

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

type ConverterOptions struct {
	AvroNamespace string // prefix for namespace prefix which will be used to identify self defined records
	ToLowerCase   bool   // map all field names to lower case
}

type Deserializer[E any] func(r io.Reader, schema string) (E, error)

type Event interface {
	// Schema returns the avro schema of this event
	Schema() string

	// Serialize writes the event (in avro format) to the given writer.
	Serialize(io.Writer) error
}

type EventSource struct {
	Record any
	Schema string
}

type SchemaCache struct {
	ConfluentClient confluent.Client
	// contains filtered or unexported fields
}