Rhaarm validators

benchmark/benchmark.py

@@ -5,17 +5,7 @@
 from fastavro import writer, reader
 from fastavro._timezone import utc
 
-try:
-    from fastavro.validate import validate, validate_many
-except ImportError:
-    try:
-        from fastavro._write import validate
-    except ImportError:
-        from fastavro._write_py import validate
-
-
-    def validate_many(records, schema):
-        return all([validate(record, schema) for record in records])
+from fastavro.validation import validate, validate_many
 
 
 def write(schema, records, runs=1):

docs/index.rst

@@ -68,6 +68,7 @@ Documentation
 
    reader
    writer
+   validation
    command_line_script
 
 * :ref:`genindex`

docs/validation.rst

@@ -0,0 +1,6 @@
+fastavro.validation
+===================
+
+.. autofunction:: fastavro._validation_py.validate
+
+.. autofunction:: fastavro._validation_py.validate_many

fastavro/__init__.py

@@ -47,7 +47,7 @@
 import fastavro.read
 import fastavro.write
 import fastavro.schema
-import fastavro.validate
+import fastavro.validation
 
 
 def _acquaint_schema(schema):
@@ -71,7 +71,7 @@ def _acquaint_schema(schema):
 acquaint_schema = _acquaint_schema
 fastavro.schema.acquaint_schema = _acquaint_schema
 is_avro = fastavro.read.is_avro
-validator = fastavro.validate.validate
+validate = fastavro.validation.validate
 
 __all__ = [
     n for n in locals().keys() if not n.startswith('_')

fastavro/_schema.pyx

@@ -28,7 +28,7 @@ cpdef inline str extract_logical_type(schema):
     return None
 
 
-def schema_name(object schema, parent_ns):
+def schema_name(schema, parent_ns):
     name = schema.get('name')
     if not name:
         return parent_ns, None