1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

use crate::errors::DataGenResult;
use crate::DValue;

pub mod avro_schema_utils;
pub mod csv_sink;
pub mod avro_sink;
pub mod json_sink;

pub trait Sink {
    fn write(&mut self, value: DValue) -> DataGenResult<()>;
}