MCPcopy Create free account

hub / github.com/Ten0/serde_avro_fast / functions

Functions461 in github.com/Ten0/serde_avro_fast

⨍ Functions 461◇ Types & classes 176
↓ 2 callersMethodserialize_all
Serialize each value of the provided sequence in the object container file
serde_avro_fast/src/object_container_file_encoding/writer/mod.rs:338
↓ 2 callersMethodserialize_element
(&mut self, value: &T)
serde_avro_fast/src/ser/serializer/seq_or_tuple.rs:88
↓ 2 callersMethodserialize_struct_or_struct_variant
( self, variant_or_struct_name: &str, len: usize, )
serde_avro_fast/src/ser/serializer/mod.rs:667
↓ 2 callersFunctionshould_not_be_finished
()
serde_avro_fast/src/ser/serializer/seq_or_tuple.rs:201
↓ 2 callersFunctiontest_schema_parse_round_trip
Skip apache avro and just do a local round trip - for cases when apache avro is buggy
serde_avro_fast/tests/round_trips.rs:172
↓ 2 callersMethodunnamed
( &self, variant: UnionVariantLookupKey, )
serde_avro_fast/src/schema/union_variants_per_type_lookup.rs:46
↓ 2 callersMethodwrite
(&mut self, data: &[u8])
serde_avro_fast/src/schema/safe/rabin.rs:18
↓ 2 callersFunctionwrite_all
Write all the elements of the provided sequence in an [object container file](https://avro.apache.org/docs/current/specification/#object-container-fil
serde_avro_fast/src/object_container_file_encoding/writer/mod.rs:81
↓ 1 callersMethodapprox_block_size
Approximate uncompressed block size in bytes If after serializing a value, the total size of the uncompressed block is greater than this value, the b
serde_avro_fast/src/object_container_file_encoding/writer/mod.rs:159
↓ 1 callersFunctionbuild_remap
(is_node_reachable_by_idx: &[bool])
serde_avro_fast/src/schema/safe/remove_unreferenced_nodes.rs:16
↓ 1 callersMethodbuild_with_user_metadata
Build the [`Writer`], also encoding [user-specified metadata](https://avro.apache.org/docs/current/specification/#object-container-files) After this
serde_avro_fast/src/object_container_file_encoding/writer/mod.rs:191
↓ 1 callersFunctionbuild_writer
()
serde_avro_fast/tests/owned_writer.rs:15
↓ 1 callersFunctioncheck_no_zero_sized_cycle_inner
( schema: &SchemaMut, node_idx: usize, visited_nodes: &mut Vec<bool>, checked_nodes: &mut Vec<bool>, )
serde_avro_fast/src/schema/safe/check_for_cycles.rs:40
↓ 1 callersMethodcodec
(&self)
serde_avro_fast/src/object_container_file_encoding/mod.rs:163
↓ 1 callersMethodcompressed_buffer
(&self)
serde_avro_fast/src/object_container_file_encoding/writer/compression.rs:82
↓ 1 callersMethoddeserialize_bytes
(self, visitor: V)
serde_avro_fast/src/de/deserializer/mod.rs:216
↓ 1 callersMethoddeserialize_ignored_any
(self, visitor: V)
serde_avro_fast/src/de/deserializer/types/blocks.rs:161
↓ 1 callersMethoddeserialize_inner
Iterator over the deserialized values Note that this may fail if the provided `T` requires to borrow from the input and the input is actually an `imp
serde_avro_fast/src/object_container_file_encoding/reader/mod.rs:242
↓ 1 callersMethoddeserialize_next_inner
Attempt to deserialize the next value Note that this may fail if the provided `seed` requires to borrow from the input and the input is actually an `
serde_avro_fast/src/object_container_file_encoding/reader/mod.rs:317
↓ 1 callersMethoddeserialize_str
(self, visitor: V)
serde_avro_fast/src/de/deserializer/mod.rs:193
↓ 1 callersMethodencode
(&mut self, input: &[u8])
serde_avro_fast/src/object_container_file_encoding/writer/compression.rs:99
↓ 1 callersFunctionfrom_single_object_reader
Deserialize from an avro [single object encoding](https://avro.apache.org/docs/current/specification/#single-object-encoding) `impl BufRead` If you o
serde_avro_fast/src/single_object_encoding.rs:32
↓ 1 callersFunctionfrom_single_object_slice
Deserialize from an avro [single object encoding](https://avro.apache.org/docs/current/specification/#single-object-encoding) slice This is zero-allo
serde_avro_fast/src/single_object_encoding.rs:10
↓ 1 callersMethodget
(&mut self)
serde_avro_derive/src/lib.rs:323
↓ 1 callersMethodinto_inner
Consume the `ReaderRead` and return the inner reader
serde_avro_fast/src/de/read/mod.rs:168
↓ 1 callersMethodinto_reader
Turn the `DeserializerState` into the reader it was built from
serde_avro_fast/src/de/mod.rs:163
↓ 1 callersMethodinto_source_reader_and_config
( self, )
serde_avro_fast/src/object_container_file_encoding/reader/decompression.rs:188
↓ 1 callersMethodio_error
If this error was caused by an IO error, return it
serde_avro_fast/src/de/error.rs:52
↓ 1 callersMethodjson
Obtain the JSON for this schema
serde_avro_fast/src/schema/self_referential.rs:69
↓ 1 callersFunctionmake_big_record
()
serde_avro_fast/benches/single.rs:191
↓ 1 callersFunctionmake_big_record
()
serde_avro_fast/tests/from_benches.rs:104
↓ 1 callersFunctionmake_small_record
()
serde_avro_fast/benches/single.rs:176
↓ 1 callersFunctionmark_reachable
( schema: &SchemaMut, key: SchemaKey, is_node_reachable_by_idx: &mut [bool], )
serde_avro_fast/src/schema/safe/remove_unreferenced_nodes.rs:82
↓ 1 callersMethodname
The rightmost component of the fully qualified name e.g. in `a.b.c` it's `c`
serde_avro_fast/src/schema/mod.rs:66
↓ 1 callersMethodname
(&self)
serde_avro_fast/src/schema/safe/parsing/mod.rs:357
↓ 1 callersMethodname_mut
If the type is a named type, returns the name of the type (mutably).
serde_avro_fast/src/schema/safe/mod.rs:279
↓ 1 callersFunctionname_override
()
serde_avro_derive/tests/derive_schema.rs:445
↓ 1 callersMethodnamed
(&self, name: &str)
serde_avro_fast/src/schema/union_variants_per_type_lookup.rs:52
↓ 1 callersMethodnodes_mut
Obtain the underlying graph storage mutably This loses the original JSON. If obtaining it again (for e.g. object container file encoding) it will be
serde_avro_fast/src/schema/safe/mod.rs:62
↓ 1 callersFunctionprettify_json
(s: &str)
serde_avro_fast/tests/schema_construction.rs:48
↓ 1 callersFunctionread_block_len
( state: &mut DeserializerState<'_, R>, ignored: bool, )
serde_avro_fast/src/de/deserializer/types/blocks.rs:5
↓ 1 callersFunctionread_bool
( state: &mut DeserializerState<'_, R>, visitor: V, )
serde_avro_fast/src/de/deserializer/types/boolean.rs:3
↓ 1 callersFunctionread_enum_as_str
( state: &mut DeserializerState<'_, R>, symbols: &[String], visitor: V, )
serde_avro_fast/src/de/deserializer/types/enums.rs:3
↓ 1 callersFunctionremap_and_remove_unreachable_nodes
( schema: &mut SchemaMut, is_node_reachable_by_idx: &[bool], key_remap: &[Option<SchemaKey>], )
serde_avro_fast/src/schema/safe/remove_unreferenced_nodes.rs:32
↓ 1 callersMethodroot
This is private API, you probably intended to call that on an [`SchemaMut`](crate::schema::SchemaMut) instead of `Schema`. The Avro schema is represe
serde_avro_fast/src/schema/self_referential.rs:46
↓ 1 callersMethodroot_with_fake_static_lifetime
SAFETY: this `NodeRef` must never be dereferenced after the corresponding schema was dropped.
serde_avro_fast/src/schema/self_referential.rs:59
↓ 1 callersMethodschema
Get the schema used for deserialization It was read from the header of the object container file.
serde_avro_fast/src/object_container_file_encoding/reader/mod.rs:423
↓ 1 callersMethodserializable_with_namespace
Current field overrides the namespace, so we need to propagate that to children
serde_avro_fast/src/schema/safe/serialize.rs:52
↓ 1 callersMethodserialize_to_json
(&self)
serde_avro_fast/src/schema/safe/serialize.rs:9
↓ 1 callersMethodserialize_unit
(self)
serde_avro_fast/src/ser/serializer/mod.rs:289
↓ 1 callersMethodserializer_overriding_schema_root
( &'r mut self, schema_root: &'s SchemaNode<'s>, )
serde_avro_fast/src/ser/mod.rs:220
↓ 1 callersMethodskip_bytes
(&mut self, n_bytes: u64)
serde_avro_fast/src/de/read/mod.rs:93
↓ 1 callersMethodstate
( self, reader: R, config: DeserializerConfig<'s>, decompression_buffer: Vec<u8>, block_size: usize,
serde_avro_fast/src/object_container_file_encoding/reader/decompression.rs:7
↓ 1 callersMethodsync_marker
Enforce the 16-byte inter-block sync marker value This is [the 16-byte value that is written at the end of each block to help detect corrupt blocks](
serde_avro_fast/src/object_container_file_encoding/writer/mod.rs:174
↓ 1 callersFunctiontest
( datum: &'de [u8], rust_value: T, avro_value: apache_avro::Duration, schema: &Schema, apache_schema: &ap
serde_avro_fast/tests/duration.rs:5
↓ 1 callersFunctionto_datum_vec
Serialize an avro "datum" (raw data, no headers...) to a newly allocated Vec Note that unless you would otherwise allocate a new `Vec` anyway, it wi
serde_avro_fast/src/lib.rs:217
↓ 1 callersFunctionto_single_object
Serialize to an avro [single object encoding](https://avro.apache.org/docs/current/specification/#single-object-encoding) to the provided writer [`S
serde_avro_fast/src/single_object_encoding.rs:85
↓ 1 callersMethodvisit_borrowed
How to construct the `Value` from a borrowed slice
serde_avro_fast/src/de/read/mod.rs:251
↓ 1 callersMethodvisit_borrowed_str
(self, v: &'de str)
serde_avro_fast/src/schema/safe/parsing/raw.rs:129
↓ 1 callersMethodvisit_type
(&mut self, v: &syn::Type)
serde_avro_derive_macros/src/build_schema/field_types_and_instantiations.rs:371
↓ 1 callersFunctionwrite_all_vectored
( writer: &mut W, slices: [&'a [u8]; N], )
serde_avro_fast/src/object_container_file_encoding/writer/vectored_write_polyfill.rs:3
↓ 1 callersFunctionwrite_all_vectored_inner
Taken from std before stabilization https://github.com/rust-lang/rust/issues/70436 One less level of generics compared to the function above
serde_avro_fast/src/object_container_file_encoding/writer/vectored_write_polyfill.rs:15
↓ 1 callersMethodwrite_canonical_form
Manual implementation that strictly copies that of the reference implementation in Java. According to the java code, this is not guaranteed to actuall
serde_avro_fast/src/schema/safe/canonical_form.rs:40
Methodappend_schema
(builder: &mut SchemaBuilder)
serde_avro_derive/src/lib.rs:227
Methodarray
( block_writer: BlockWriter<'r, 'c, 's, W>, elements_schema: &'s SchemaNode<'s>, )
serde_avro_fast/src/ser/serializer/seq_or_tuple.rs:28
Functionavro_3642_test_single_object_reader_incomplete_reads
()
serde_avro_fast/tests/single_object_encoding.rs:94
Functionbench_big_schema_read_record
(c: &mut Criterion)
serde_avro_fast/benches/single.rs:243
Functionbench_object_container_file_deserialization
(c: &mut Criterion)
serde_avro_fast/benches/object_container_file_encoding.rs:200
Functionbench_object_container_file_serialization
(c: &mut Criterion)
serde_avro_fast/benches/object_container_file_encoding.rs:114
Functionbench_small_schema_read_record
(c: &mut Criterion)
serde_avro_fast/benches/single.rs:219
Functionbig_record
()
serde_avro_fast/tests/from_benches.rs:168
Methodbuffered_bytes
(state: &'r mut SerializerState<'c, 's, W>)
serde_avro_fast/src/ser/serializer/seq_or_tuple.rs:49
Methodbuild_duplicate
Insert a new [`SchemaNode`] corresponding to the schema for the type `T` into [`nodes`](SchemaBuilder::nodes), regardless of whether it has already be
serde_avro_derive/src/lib.rs:126
Methodbuild_logical_type
Register a new node for this logical type, where the regular type specified with `T` is annotated with the logical type specified as the `logical_type
serde_avro_derive/src/lib.rs:143
Functionbuild_schema_derive
Derive the ability to build an Avro schema for a type (implements `BuildSchema`) # Example ``` use serde_avro_derive::BuildSchema; #[derive(BuildSc
serde_avro_derive_macros/src/lib.rs:272
Methodbytes
( state: &'r mut SerializerState<'c, 's, W>, len: usize, )
serde_avro_fast/src/ser/serializer/seq_or_tuple.rs:64
Functioncomplex
()
serde_avro_derive/tests/derive_schema.rs:101
Functioncomplex_schema_parsing_serialization_round_trip
()
serde_avro_fast/tests/round_trips.rs:453
Functioncompression_codec_serializes_properly
()
serde_avro_fast/src/object_container_file_encoding/mod.rs:232
Methodconfig
Get the configuration that this `DeserializerState` uses (that it was built with)
serde_avro_fast/src/de/mod.rs:176
Methodconsume
(&mut self, amt: usize)
serde_avro_fast/src/de/read/take.rs:87
Functionconvert_error
(e: std::fmt::Error)
serde_avro_fast/src/schema/safe/canonical_form.rs:185
Methodcustom
(msg: T)
serde_avro_fast/src/de/error.rs:58
Methodcustom
(msg: T)
serde_avro_fast/src/ser/error.rs:37
Methodcustom
(_msg: T)
serde_avro_fast/src/schema/safe/parsing/raw.rs:166
Methodcustom_io
(msg: &'static str, io_error: std::io::Error)
serde_avro_fast/src/de/error.rs:43
Methoddefault
Use the default compression level of the considered algorithm
serde_avro_fast/src/object_container_file_encoding/mod.rs:109
Methoddefault
()
serde_avro_fast/src/schema/safe/rabin.rs:12
Methodderef
(&self)
serde_avro_fast/src/de/mod.rs:204
Methodderef
(&self)
serde_avro_fast/src/ser/mod.rs:274
Methodderef
(&self)
serde_avro_fast/src/schema/self_referential.rs:139
Methodderef_mut
(&mut self)
serde_avro_fast/src/de/mod.rs:210
Methodderef_mut
(&mut self)
serde_avro_fast/src/ser/mod.rs:282
Methoddeserialize
(deserializer: D)
serde_avro_fast/src/schema/safe/parsing/raw.rs:80
Methoddeserialize_any
(self, visitor: V)
serde_avro_fast/src/de/deserializer/types/duration.rs:44
Methoddeserialize_any
(self, visitor: V)
serde_avro_fast/src/de/deserializer/types/union.rs:61
Methoddeserialize_any
(self, visitor: V)
serde_avro_fast/src/de/deserializer/types/blocks.rs:154
Methoddeserialize_byte_buf
(self, visitor: V)
serde_avro_fast/src/de/deserializer/mod.rs:227
Methoddeserialize_enum
( self, _: &'static str, _: &'static [&'static str], visitor: V, )
serde_avro_fast/src/de/deserializer/mod.rs:344
Methoddeserialize_enum
( self, _name: &'static str, _variants: &'static [&'static str], visitor: V, )
serde_avro_fast/src/de/deserializer/types/union.rs:174
← previousnext →101–200 of 461, ranked by callers