schema

var ObservationExtractedEvent = &avro.Schema{
	Definition: observationExtractedEvent,
}

ObservationExtractedEvent is the Avro schema for each observation extracted.

var ObservationsInsertedEvent = &avro.Schema{
	Definition: observationsInsertedEvent,
}

ObservationsInsertedEvent is the Avro schema for each observation batch inserted.