Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/avro-rs
/ functions
Functions
1,631 in github.com/apache/avro-rs
⨍
Functions
1,631
◇
Types & classes
404
↓ 6 callers
Function
write_schema_for_default_value_test
()
avro/tests/schema.rs:1645
↓ 6 callers
Method
writer_schemata
Set the schemata that will be used to resolve any references in the writer's schema. This is equivalent to `.resolved_writer_schemata(ResolvedSchema:
avro/src/reader/datum.rs:96
↓ 5 callers
Function
avro_4032_codec_settings
(codec: Codec)
avro/tests/codecs.rs:62
↓ 5 callers
Function
big_decimal_as_bytes
(decimal: &BigDecimal)
avro/src/bigdecimal.rs:29
↓ 5 callers
Method
checked_read_int
Read an integer from the reader. This will check that the current schema is [`Schema::Int`] or a logical type based on that. It does not read [`Schem
avro/src/serde/deser_schema/mod.rs:146
↓ 5 callers
Method
checked_write_int
Write an integer to the writer. This will check that the current schema is [`Schema::Int`] or a logical type based on that. This also handles [`Schem
avro/src/serde/ser_schema/mod.rs:146
↓ 5 callers
Method
checked_write_int
Write an integer to the writer. This will check that the current schema is [`Schema::Int`] or a logical type based on that. This will write the union
avro/src/serde/ser_schema/union.rs:69
↓ 5 callers
Method
compress
Compress a stream of bytes in-place.
avro/src/codec.rs:83
↓ 5 callers
Function
compress_and_decompress
(codec: Codec)
avro/src/codec.rs:342
↓ 5 callers
Method
get_custom_attributes
( &self, complex: &Map<String, Value>, excluded: &[&'static str], )
avro/src/schema/parser.rs:597
↓ 5 callers
Method
get_root_schema
(&self)
avro/src/schema/resolve.rs:127
↓ 5 callers
Method
get_schema
Get the schema for this name.
avro/src/serde/ser_schema/mod.rs:66
↓ 5 callers
Method
into_details
(self)
avro/src/error.rs:49
↓ 5 callers
Function
is_human_readable
()
avro/src/util.rs:203
↓ 5 callers
Method
map
( reader: &'r mut R, schema: &'s MapSchema, config: Config<'s, S>, )
avro/src/serde/deser_schema/block.rs:55
↓ 5 callers
Method
maybe_write_header
(&mut self)
avro/src/writer/mod.rs:559
↓ 5 callers
Function
permutations
Return all permutations of an input slice
avro/tests/schema.rs:399
↓ 5 callers
Method
read_array
Read `n` bytes from the reader. This does not check the current schema.
avro/src/serde/deser_schema/mod.rs:203
↓ 5 callers
Method
read_value
(&self, reader: &mut R)
avro/src/reader/single_object.rs:61
↓ 5 callers
Method
serialize_i32
(self, v: i32)
avro/src/serde/ser.rs:131
↓ 5 callers
Method
write_ref
Write the object to the writer. Returns the number of bytes written. Each call writes a complete single-object encoded message (header + data), maki
avro/src/writer/single_object.rs:195
↓ 5 callers
Method
write_value_ref
Write a value to the writer.
avro/src/writer/datum.rs:125
↓ 4 callers
Function
create_datum
Creates a new datum to write
avro/tests/append_to_existing.rs:93
↓ 4 callers
Function
decode_internal
( schema: &Schema, names: &HashMap<Name, S>, enclosing_namespace: NamespaceRef, reader: &mut R
avro/src/decode.rs:77
↓ 4 callers
Function
decode_len
(reader: &mut R)
avro/src/decode.rs:47
↓ 4 callers
Function
decode_long
(reader: &mut R)
avro/src/decode.rs:37
↓ 4 callers
Function
encode_internal
( value: &Value, schema: &Schema, names: &HashMap<Name, S>, enclosing_namespace: NamespaceRef,
avro/src/encode.rs:65
↓ 4 callers
Function
examples
()
avro_test_helper/src/data.rs:605
↓ 4 callers
Method
find_named_schema
Get the index and schema for the provided Rust type name. This ignores the namespace of schemas. Will use `names` to resolve references.
avro/src/schema/union.rs:107
↓ 4 callers
Function
get_record_fields_in_ctxt
( named_schemas: &mut HashSet<Name>, enclosing_namespace: NamespaceRef, schema_fn: fn(named_schema
avro/src/serde/derive.rs:372
↓ 4 callers
Method
get_resolved_union_variant
Get the schema at the given index of the union, resolving references.
avro/src/serde/ser_schema/mod.rs:131
↓ 4 callers
Function
long_record_datum
()
avro/tests/io.rs:203
↓ 4 callers
Function
preserve_optional
(op: Option<impl quote::ToTokens>)
avro_derive/src/utils.rs:30
↓ 4 callers
Function
read
(schema: &Schema, bytes: &[u8])
avro/benches/serde.rs:253
↓ 4 callers
Function
schema_to_base_schemakind
Get the [`SchemaKind`] of a [`Schema`] converting logical types to their base type.
avro/src/schema/union.rs:501
↓ 4 callers
Method
serialize
(&self, serializer: S)
avro/src/schema/mod.rs:856
↓ 4 callers
Function
serialize_big_decimal
(decimal: &BigDecimal)
avro/src/bigdecimal.rs:39
↓ 4 callers
Method
serialize_next_field
( &mut self, position: usize, value: &T, )
avro/src/serde/ser_schema/record/mod.rs:99
↓ 4 callers
Method
update
(&mut self, data: &[u8])
avro/src/rabin.rs:96
↓ 4 callers
Method
validate
Validates the schema name and returns the start byte of the name. Requires that the implementation of [`Self::regex`] provides a capture group named
avro/src/validator.rs:95
↓ 4 callers
Method
validate_internal
Validates the value against the provided schema.
avro/src/types.rs:417
↓ 4 callers
Method
with_different_schema
Create a new serializer with the existing writer and config. This will resolve the schema if it is a reference.
avro/src/serde/ser_schema/mod.rs:121
↓ 3 callers
Method
append_value_ref
Append a compatible value to a `Writer`, also performs schema validation. Returns the number of bytes written (it might be 0, see below). NOTE**: Th
avro/src/writer/mod.rs:218
↓ 3 callers
Function
assert_avro_3512_aliases
(aliases: &Aliases)
avro/src/schema/mod.rs:2322
↓ 3 callers
Function
assert_not_logged
(unexpected_message: &str)
avro_test_helper/src/logger.rs:78
↓ 3 callers
Function
check
Checks the read values
avro/tests/append_to_existing.rs:100
↓ 3 callers
Method
copy_only_size
Create a new `FixedSchema` copying only the size. All other fields are `None` or empty.
avro/src/schema/mod.rs:399
↓ 3 callers
Method
custom_attributes
Returns the custom attributes (metadata) if the schema supports them.
avro/src/schema/mod.rs:636
↓ 3 callers
Method
decompress
Decompress a stream of bytes in-place.
avro/src/codec.rs:146
↓ 3 callers
Method
deprecated
(&self, span: Span)
avro_derive/src/attributes/avro.rs:63
↓ 3 callers
Method
deserialize_bytes
(self, visitor: V)
avro/src/serde/de.rs:603
↓ 3 callers
Method
deserialize_string
(mut self, visitor: V)
avro/src/serde/deser_schema/mod.rs:501
↓ 3 callers
Function
encode_int
(i: i32, writer: W)
avro/src/encode.rs:61
↓ 3 callers
Method
field_error
(&self, position: usize, error: Error)
avro/src/serde/ser_schema/record/mod.rs:68
↓ 3 callers
Method
find_fully_qualified_named_schema
Get the index and schema for the provided Rust type name. Will use `names` to resolve references.
avro/src/schema/union.rs:134
↓ 3 callers
Method
fix_aliases_namespace
A type alias may be specified either as a fully namespace-qualified, or relative to the namespace of the name it is an alias for. For example, if a ty
avro/src/schema/parser.rs:798
↓ 3 callers
Method
get_already_seen_schema
Returns already parsed schema or a schema that is currently being resolved.
avro/src/schema/parser.rs:518
↓ 3 callers
Method
get_variant
Get the variant at the given index.
avro/src/schema/union.rs:85
↓ 3 callers
Method
into_deser_iter
Convert this reader into an iterator that deserializes to `T`.
avro/src/reader/mod.rs:115
↓ 3 callers
Method
is_nullable
Returns true if any of the variants of this `UnionSchema` is `Null`.
avro/src/schema/union.rs:223
↓ 3 callers
Function
make_big_record
()
avro/benches/single.rs:152
↓ 3 callers
Function
make_small_record
()
avro/benches/single.rs:141
↓ 3 callers
Function
max_prec_for_len
Compute the maximum decimal value precision of a byte array of length `len` could hold.
avro/src/types.rs:44
↓ 3 callers
Function
pcf_string
(s: &str)
avro/src/schema/mod.rs:1174
↓ 3 callers
Method
register_parsed_schema
( &mut self, fully_qualified_name: &Name, schema: &Schema, aliases: &Aliases,
avro/src/schema/parser.rs:493
↓ 3 callers
Method
resolve_enum
( self, symbols: &[String], enum_default: &Option<String>, _field_default: &Op
avro/src/types.rs:1044
↓ 3 callers
Function
resolve_names
Resolve all references in the schema, saving any named type found in `names` `known_schemata` will be used to resolve references but they won't be ad
avro/src/schema/resolve.rs:146
↓ 3 callers
Method
resolve_schemata
Attempt to perform schema resolution on the value, with the given [Schema](../schema/enum.Schema.html) and set of schemas to use for Refs resolution.
avro/src/types.rs:675
↓ 3 callers
Function
safe_len
(len: usize)
avro/src/util.rs:173
↓ 3 callers
Method
serialize_seq
(self, len: Option<usize>)
avro/src/serde/ser.rs:249
↓ 3 callers
Method
try_name
Try to set a Name from the given string.
avro/src/schema/record/schema.rs:70
↓ 3 callers
Method
unvalidated_append_value_ref
Append a compatible value to a `Writer`. This function does **not** validate that the provided value matches the schema. If it does not match, the fi
avro/src/writer/mod.rs:261
↓ 3 callers
Method
with_different_schema
Create a new deserializer with the existing reader and config. This will resolve the schema if it is a reference.
avro/src/serde/deser_schema/mod.rs:123
↓ 3 callers
Method
write
(&mut self, buf: &[u8])
avro/src/writer/mod.rs:1192
↓ 3 callers
Method
write_bytes
Write bytes to the writer. This does not check the current schema.
avro/src/serde/ser_schema/mod.rs:189
↓ 3 callers
Method
write_bytes
Write bytes to the writer. This does not check the current schema and does not write the union index.
avro/src/serde/ser_schema/union.rs:117
↓ 3 callers
Method
write_bytes_with_len
Write bytes to the writer with preceding length header. This does not check the current schema.
avro/src/serde/ser_schema/mod.rs:179
↓ 3 callers
Method
write_bytes_with_len
Write bytes to the writer with preceding length header. This does not check the current schema and does not write the union index.
avro/src/serde/ser_schema/union.rs:107
↓ 3 callers
Method
write_value_ref
Write the referenced Value to the provided Write object. Returns a result with the number of bytes written including the header
avro/src/writer/single_object.rs:70
↓ 2 callers
Function
aliases
Convert a list of strings to an expression that resolves to a `Option<Vec<Alias>>`.
avro_derive/src/utils.rs:39
↓ 2 callers
Method
append_bytes
Append pure bytes to the payload.
avro/src/writer/mod.rs:486
↓ 2 callers
Method
append_raw
Append a raw Avro Value to the payload avoiding to encode it again.
avro/src/writer/mod.rs:481
↓ 2 callers
Method
apply_to_variant
Apply a renaming rule to an enum variant, returning the version expected in the source.
avro_derive/src/case.rs:89
↓ 2 callers
Function
assert_attribute_type
(attribute: (&String, &serde_json::Value))
avro/tests/schema.rs:714
↓ 2 callers
Function
assert_doc
(schema: &Schema)
avro/tests/schema.rs:689
↓ 2 callers
Function
avro_3674_with_or_without_namespace
(with_namespace: bool)
avro/src/types.rs:2884
↓ 2 callers
Function
avro_3688_schema_resolution_panic
(set_field_b: bool)
avro/src/types.rs:2975
↓ 2 callers
Function
binary_encodings
()
avro/tests/io.rs:80
↓ 2 callers
Function
check_writer
(mut writer: Writer<'_, Vec<u8>>, schema: &Schema)
avro/src/writer/mod.rs:871
↓ 2 callers
Method
checked_read_long
Read a long from the reader. This will check that the current schema is [`Schema::Long`] or a logical type based on that. It does not read [`Schema::
avro/src/serde/deser_schema/mod.rs:160
↓ 2 callers
Method
checked_write_long
Write a long to the writer. This will check that the current schema is [`Schema::Long`] or a logical type based on that. This also handles [`Schema::
avro/src/serde/ser_schema/mod.rs:162
↓ 2 callers
Method
checked_write_long
Write a long to the writer. This will check that the current schema is [`Schema::Long`] or a logical type based on that. This will write the union in
avro/src/serde/ser_schema/union.rs:90
↓ 2 callers
Function
decode_int
(reader: &mut R)
avro/src/decode.rs:42
↓ 2 callers
Function
decode_seq_len
Decode the length of a sequence. Maps and arrays are 0-terminated, 0i64 is also encoded as 0 in Avro reading a length of 0 means the end of the map o
avro/src/decode.rs:56
↓ 2 callers
Method
default
()
avro/src/rabin.rs:90
↓ 2 callers
Method
deserialize_byte_buf
(mut self, visitor: V)
avro/src/serde/deser_schema/mod.rs:521
↓ 2 callers
Method
deserialize_seq
(self, visitor: V)
avro/src/serde/de.rs:715
↓ 2 callers
Method
deserialize_struct
( self, name: &'static str, fields: &'static [&'static str], visitor: V, )
avro/src/serde/deser_schema/mod.rs:689
↓ 2 callers
Method
deserialize_tuple
(self, len: usize, visitor: V)
avro/src/serde/deser_schema/mod.rs:626
↓ 2 callers
Method
extend_ser
Extend a `Writer` with an `Iterator` of anything implementing the `Serialize` trait for [`serde`](https://docs.serde.rs/serde/index.html) compatibilit
avro/src/writer/mod.rs:353
← previous
next →
101–200 of 1,631, ranked by callers