MCPcopy Create free account

hub / github.com/apache/avro-rs / functions

Functions1,631 in github.com/apache/avro-rs

⨍ Functions 1,631◇ Types & classes 404
↓ 2 callersFunctionextract_rustdoc
(attributes: &[Attribute])
avro_derive/src/attributes/mod.rs:352
↓ 2 callersFunctionfield_ordering_position
Used to define the ordering and inclusion of fields.
avro/src/schema/mod.rs:1196
↓ 2 callersFunctionfield_to_field_default_expr
( field: &Field, default: FieldDefault, )
avro_derive/src/fields.rs:84
↓ 2 callersFunctionfield_to_record_fields_expr
( field: &Field, with: &With, )
avro_derive/src/fields.rs:49
↓ 2 callersFunctionfield_to_schema_expr
(field: &Field, with: &With)
avro_derive/src/fields.rs:25
↓ 2 callersMethodfind_fixed_of_size_n
Find a [`Schema::Fixed`] with the given size. Will use `names` to resolve references.
avro/src/schema/union.rs:161
↓ 2 callersMethodfind_record_with_n_fields
Find a [`Schema::Record`] with `n` fields. Will use `names` to resolve references.
avro/src/schema/union.rs:197
↓ 2 callersMethodfind_schema_with_known_schemata
Optionally returns a reference to the schema matched by this value, as well as its position within this union. Extra arguments: - `known_schemata` -
avro/src/schema/union.rs:232
↓ 2 callersMethodget_decimal_integer
( &self, complex: &Map<String, Value>, key: &'static str, )
avro/src/schema/parser.rs:207
↓ 2 callersMethodget_ref
Gets a reference to the underlying writer. NOTE**: There is likely data still in the buffer. To have all the data in the writer call [`flush`](Writer
avro/src/writer/mod.rs:457
↓ 2 callersMethodget_schema_type_name
(&self, name: Name, value: &Value)
avro/src/schema/parser.rs:818
↓ 2 callersMethodheader
Create an Avro header based on schema, codec and sync marker.
avro/src/writer/mod.rs:508
↓ 2 callersMethodindependent_canonical_form
Returns the [Parsing Canonical Form] of `self` that is self contained (not dependent on any definitions in `schemata`) If you require a self containe
avro/src/schema/mod.rs:481
↓ 2 callersMethodis_named
(self)
avro/src/schema/mod.rs:234
↓ 2 callersFunctionmake_records
(record: Value, count: usize)
avro/benches/serde.rs:233
↓ 2 callersMethodname
(&self)
avro/src/schema/name.rs:123
↓ 2 callersFunctionnanos
(duration: Duration)
avro/examples/benchmark.rs:29
↓ 2 callersMethodparse_fixed
Parse a `serde_json::Value` representing a Avro fixed type into a `Schema`.
avro/src/schema/parser.rs:752
↓ 2 callersMethodparse_input_schemas
Convert the input schemas to `parsed_schemas`.
avro/src/schema/parser.rs:85
↓ 2 callersMethodparse_known_schema
Parse a string as a primitive type or reference to `parsed_schemas`.
avro/src/schema/parser.rs:119
↓ 2 callersMethodparse_union
Parse a `serde_json::Value` representing a Avro union type into a `Schema`.
avro/src/schema/parser.rs:724
↓ 2 callersFunctionparsing_canonical_form
Parses a valid Avro schema into [the Parsing Canonical Form]. [the Parsing Canonical Form](https://avro.apache.org/docs/++version++/specification/#pa
avro/src/schema/mod.rs:1067
↓ 2 callersMethodread_block_next
Try to read a data block, also performing schema resolution for the objects contained in the block. The objects are stored in an internal buffer to th
avro/src/reader/block.rs:143
↓ 2 callersMethodread_bytes
Read `n` bytes from the reader. This does not check the current schema.
avro/src/serde/deser_schema/mod.rs:192
↓ 2 callersMethodread_bytes_with_len
Read a bytes from the reader. This does not check the current schema.
avro/src/serde/deser_schema/mod.rs:184
↓ 2 callersMethodread_header
(&self, reader: &mut impl Read)
avro/src/reader/single_object.rs:84
↓ 2 callersFunctionread_long
(reader: &mut R)
avro/src/util.rs:76
↓ 2 callersFunctionread_marker
Reads the marker bytes from Avro bytes generated earlier by a `Writer` # Panics Will panic if `bytes` does not contain at least 16 bytes.
avro/src/reader/mod.rs:190
↓ 2 callersMethodread_string
Read a string from the reader. This does not check the current schema.
avro/src/serde/deser_schema/mod.rs:176
↓ 2 callersMethodreader_schemata
Set the schemata that will be used to resolve any references in the reader's schema. This is equivalent to `.resolved_reader_schemata(ResolvedSchema:
avro/src/reader/datum.rs:115
↓ 2 callersFunctionresolve_names_with_schemata
( schemata: impl IntoIterator<Item = &'s Schema>, names: &mut NamesRef<'s>, enclosing_namespace: N
avro/src/schema/resolve.rs:217
↓ 2 callersFunctionschemas_to_validate
()
avro/tests/io.rs:25
↓ 2 callersFunctionseconds
(nanos: u64)
avro/examples/benchmark.rs:33
↓ 2 callersMethodserialize_bytes
(self, v: &[u8])
avro/src/serde/ser.rs:183
↓ 2 callersMethodserialize_default
(&mut self, position: usize)
avro/src/serde/ser_schema/record/mod.rs:149
↓ 2 callersMethodserialize_element
(&mut self, value: &T)
avro/src/serde/ser_schema/block.rs:110
↓ 2 callersMethodserialize_unit_variant
( self, _name: &'static str, variant_index: u32, variant: &'static str, )
avro/src/serde/ser_schema/mod.rs:429
↓ 2 callersMethodsize_hint
(&self)
avro/src/serde/deser_schema/tuple.rs:77
↓ 2 callersMethodstring
(&self, key: &str)
avro/src/util.rs:58
↓ 2 callersFunctionsync
(_s: S)
avro/src/schema/mod.rs:2126
↓ 2 callersFunctionto_implementation
( input_span: Span, ident: Ident, generics: Generics, container_attrs: NamedTypeOptions, d
avro_derive/src/structs.rs:30
↓ 2 callersMethodto_sign_extended_bytes_with_len
(&self, len: usize)
avro/src/decimal.rs:91
↓ 2 callersMethoduser_metadata
(&self)
avro/src/reader/mod.rs:110
↓ 2 callersMethodvalidate
Validate the value against the given [`Schema`]. See the [Avro specification](https://avro.apache.org/docs/++version++/specification) for the full se
avro/src/types.rs:378
↓ 2 callersFunctionvalidate_enum_symbol_name
(symbol: &str)
avro/src/validator.rs:228
↓ 2 callersFunctionvalidate_namespace
(ns: &str)
avro/src/validator.rs:177
↓ 2 callersFunctionvalidate_record_field_name
(field_name: &str)
avro/src/validator.rs:279
↓ 2 callersFunctionvalidate_schema_name
(schema_name: &str)
avro/src/validator.rs:124
↓ 2 callersFunctionwrite
(schema: &Schema, records: &[Value])
avro/benches/serde.rs:241
↓ 2 callersMethodwrite_block
Write a block including the items and size header.
avro/src/serde/ser_schema/block.rs:275
↓ 2 callersMethodwrite_ser
Serialize `T` to the writer.
avro/src/writer/datum.rs:144
↓ 2 callersMethodwrite_value
Write a value to the writer.
avro/src/writer/datum.rs:115
↓ 2 callersMethodwrite_value
(&mut self, v: Value, writer: &mut W)
avro/src/writer/single_object.rs:90
↓ 2 callersFunctionwrite_value_ref_owned_resolved
( resolved_schema: &ResolvedOwnedSchema, value: &Value, writer: &mut W, )
avro/src/writer/single_object.rs:230
↓ 1 callersMethodadd
(&self, msg: &str)
avro/tests/shared.rs:78
↓ 1 callersMethodappend
(&mut self, value: T)
avro/src/writer/mod.rs:195
↓ 1 callersMethodappend_marker
Generate and append synchronization marker to the payload.
avro/src/writer/mod.rs:472
↓ 1 callersMethodapply_to_field
Apply a renaming rule to a struct field, returning the version expected in the source.
avro_derive/src/case.rs:114
↓ 1 callersFunctionbench_from_file
( c: &mut Criterion, file_path: &str, name: &str, )
avro/benches/serde.rs:308
↓ 1 callersFunctionclear_log_messages
Clears all log messages of this thread.
avro_test_helper/src/logger.rs:56
↓ 1 callersMethodcompare_fields
(&self, fields_one: &[RecordField], fields_two: &[RecordField])
avro/src/schema_equality.rs:226
↓ 1 callersFunctioncompare_schemata
(schema_one: &Schema, schema_two: &Schema)
avro/src/schema_equality.rs:251
↓ 1 callersMethodcompression
(&self)
avro/src/codec.rs:239
↓ 1 callersMethodcompression_level
Get the compression level as a `u8`, note that this means the [`miniz_oxide::deflate::CompressionLevel::DefaultCompression`] variant will appear as `2
avro/src/codec.rs:35
↓ 1 callersFunctioncreate_datum
(schema: &Schema)
avro/examples/generate_interop_data.rs:30
↓ 1 callersFunctionde
(mut encoded: &[u8])
avro_derive/tests/serde.rs:54
↓ 1 callersFunctionde
(mut encoded: &[u8])
avro_derive/tests/derive.rs:71
↓ 1 callersFunctiondecode_variable
Read a varint from the reader. Note: this function does not do zigzag decoding, for that see [`zag_i32`] and [`zag_i64`].
avro/src/util.rs:136
↓ 1 callersFunctiondefault_barparent_bar
()
avro/tests/avro-3787.rs:182
↓ 1 callersFunctiondefault_value_examples
()
avro/tests/io.rs:97
↓ 1 callersMethoddenormalize
Remove all external references from the schema. `schemata` must contain all externally referenced schemas. # Errors Will return a [`Details::SchemaR
avro/src/schema/mod.rs:731
↓ 1 callersMethoddenormalize_inner
( &mut self, schemata: &[Schema], defined_names: &mut HashSet<Name>, )
avro/src/schema/mod.rs:735
↓ 1 callersFunctionderive_avro_schema
(input: DeriveInput)
avro_derive/src/lib.rs:56
↓ 1 callersMethoddeserialize_any
(self, visitor: V)
avro/src/serde/de.rs:318
↓ 1 callersMethoddeserialize_any
(self, visitor: V)
avro/src/serde/deser_schema/mod.rs:228
↓ 1 callersMethoddeserialize_bool
(self, visitor: V)
avro/src/serde/deser_schema/mod.rs:274
↓ 1 callersMethoddeserialize_enum
( self, _name: &'static str, // This also includes aliases, so can't be used to check
avro/src/serde/deser_schema/mod.rs:712
↓ 1 callersMethoddeserialize_f32
(mut self, visitor: V)
avro/src/serde/deser_schema/mod.rs:444
↓ 1 callersMethoddeserialize_f64
(mut self, visitor: V)
avro/src/serde/deser_schema/mod.rs:455
↓ 1 callersMethoddeserialize_i32
(mut self, visitor: V)
avro/src/serde/deser_schema/mod.rs:324
↓ 1 callersMethoddeserialize_i64
(mut self, visitor: V)
avro/src/serde/deser_schema/mod.rs:335
↓ 1 callersMethoddeserialize_identifier
(self, visitor: V)
avro/src/serde/deser_schema/identifier.rs:252
↓ 1 callersMethoddeserialize_map
(self, visitor: V)
avro/src/serde/deser_schema/mod.rs:672
↓ 1 callersMethoddeserialize_seq
(self, visitor: V)
avro/src/serde/deser_schema/mod.rs:613
↓ 1 callersMethoddeserialize_str
(self, visitor: V)
avro/src/serde/de.rs:541
↓ 1 callersMethoddeserialize_struct
( self, _struct_name: &'static str, _fields: &'static [&'static str], visitor:
avro/src/serde/de.rs:768
↓ 1 callersMethoddeserialize_tuple
(self, _: usize, visitor: V)
avro/src/serde/de.rs:735
↓ 1 callersMethoddeserialize_unit
(self, visitor: V)
avro/src/serde/de.rs:667
↓ 1 callersMethoddeserialize_unit
(self, visitor: V)
avro/src/serde/deser_schema/mod.rs:558
↓ 1 callersMethodenabled
(&self, _metadata: &Metadata)
avro_test_helper/src/logger.rs:29
↓ 1 callersFunctionencode_to_vec
(value: &Value, schema: &Schema)
avro/src/encode.rs:368
↓ 1 callersFunctionencode_variable
Write the number as a varint to the writer. Note: this function does not do zigzag encoding, for that see [`zig_i32`] and [`zig_i64`].
avro/src/util.rs:110
↓ 1 callersMethoderror
(&self, ty: &'static str, error: impl Into<String>)
avro/src/serde/deser_schema/enums.rs:165
↓ 1 callersMethodfetch_schema_ref
Given a name, tries to retrieve the parsed schema from `parsed_schemas`. If a parsed schema is not found, it checks if a currently resolving schema w
avro/src/schema/parser.rs:147
↓ 1 callersFunctionfield_aliases
Convert a list of strings to an expression that resolves to a `Vec<String>`.
avro_derive/src/utils.rs:57
↓ 1 callersMethodfill_buf
(&mut self, n: usize)
avro/src/reader/block.rs:121
↓ 1 callersFunctionfind_first_ref
Find the first Schema::Ref that has the target name
avro/src/serde/derive.rs:403
↓ 1 callersFunctionfp_table
()
avro/src/rabin.rs:26
↓ 1 callersFunctiongenerate_sync_marker
()
avro/src/writer/mod.rs:640
↓ 1 callersFunctionget_avro_bytes
Simulates reading from a pre-existing .avro file and returns its bytes
avro/tests/append_to_existing.rs:84
← previousnext →201–300 of 1,631, ranked by callers