MCPcopy Create free account

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

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

↓ 1 callersMethodget_parsed_schemas
(&mut self)
avro/src/schema/parser.rs:57
↓ 1 callersFunctionhas_default_attr
(attrs: &[Attribute])
avro_derive/src/enums/plain.rs:140
↓ 1 callersMethodinner_full_match_schemas
( &mut self, writers_schema: &Schema, readers_schema: &Schema, )
avro/src/schema_compatibility.rs:177
↓ 1 callersFunctioninstall
()
avro_test_helper/src/logger.rs:129
↓ 1 callersFunctionis_named_type
(typ: Option<&str>)
avro/src/schema/mod.rs:1158
↓ 1 callersFunctionjson_value_expr
Convert a `Value` into a `TokenStream`. The `Value` is constructed, not parsed from a JSON string.
avro_derive/src/utils.rs:73
↓ 1 callersFunctionmake_records_ser
(record: T, count: usize)
avro/benches/serde.rs:237
↓ 1 callersFunctionmake_writer_with_builder
(schema: &Schema)
avro/src/writer/mod.rs:862
↓ 1 callersFunctionmake_writer_with_codec
(schema: &Schema)
avro/src/writer/mod.rs:854
↓ 1 callersFunctionmax_allocation_bytes
Set the maximum number of bytes that can be allocated when decoding data. This function only changes the setting once. On subsequent calls the value
avro/src/util.rs:169
↓ 1 callersMethodmerge
(&self, err: &ErrorsDesc)
avro/tests/shared.rs:84
↓ 1 callersMethodnamespace
(&self)
avro/src/schema/name.rs:127
↓ 1 callersFunctionnormal
( input_span: Span, ident: Ident, generics: Generics, container_attrs: NamedTypeOptions, d
avro_derive/src/structs.rs:44
↓ 1 callersMethodparse_array
Parse a `serde_json::Value` representing a Avro array type into a `Schema`.
avro/src/schema/parser.rs:691
↓ 1 callersMethodparse_complex
Parse a `serde_json::Value` representing a complex Avro type into a `Schema`. Avro supports "recursive" definition of types. e.g: `{"type": {"type":
avro/src/schema/parser.rs:251
↓ 1 callersMethodparse_enum
Parse a `serde_json::Value` representing a Avro enum type into a `Schema`.
avro/src/schema/parser.rs:614
↓ 1 callersMethodparse_json_integer_for_decimal
( &self, value: &serde_json::Number, )
avro/src/schema/parser.rs:830
↓ 1 callersMethodparse_list
Create an array of `Schema`'s from a list of named JSON Avro schemas (Record, Enum, and Fixed). It is allowed that the schemas have cross-dependencie
avro/src/schema/mod.rs:540
↓ 1 callersMethodparse_map
Parse a `serde_json::Value` representing a Avro map type into a `Schema`.
avro/src/schema/parser.rs:707
↓ 1 callersMethodparse_precision_and_scale
( &self, complex: &Map<String, Value>, )
avro/src/schema/parser.rs:229
↓ 1 callersMethodparse_record
Parse a `serde_json::Value` representing an Avro record type into a `Schema`.
avro/src/schema/parser.rs:540
↓ 1 callersFunctionpcf_array
(arr: &[JsonValue], defined_names: &mut HashSet<String>)
avro/src/schema/mod.rs:1165
↓ 1 callersFunctionpcf_map
(schema: &Map<String, JsonValue>, defined_names: &mut HashSet<String>)
avro/src/schema/mod.rs:1076
↓ 1 callersFunctionpermutation_indices
Return all permutations of the indices of a vector
avro/tests/schema.rs:414
↓ 1 callersMethodread
(&self, reader: &mut R)
avro/src/reader/datum.rs:193
↓ 1 callersMethodread
(&self, reader: &mut R)
avro/src/reader/single_object.rs:132
↓ 1 callersFunctionread_codec
(metadata: &HashMap<String, Value>)
avro/src/reader/block.rs:298
↓ 1 callersMethodread_deser
(&self, reader: &mut impl Read)
avro/src/reader/single_object.rs:71
↓ 1 callersMethodread_from_value
(&self, reader: &mut R)
avro/src/reader/single_object.rs:123
↓ 1 callersMethodread_header
Try to read the header and to set the writer `Schema`, the `Codec` and the marker based on its content.
avro/src/reader/block.rs:82
↓ 1 callersMethodread_next
(&mut self)
avro/src/reader/mod.rs:123
↓ 1 callersFunctionread_schemaless
(bytes: &[u8])
avro/benches/serde.rs:262
↓ 1 callersMethodread_user_metadata
(&mut self, key: String, value: Value)
avro/src/reader/block.rs:286
↓ 1 callersMethodread_writer_schema
(&mut self, metadata: &HashMap<String, Value>)
avro/src/reader/block.rs:256
↓ 1 callersMethodregister_resolving_schema
(&mut self, name: &Name, aliases: &Aliases)
avro/src/schema/parser.rs:477
↓ 1 callersMethodreset
(&mut self)
avro/src/rabin.rs:111
↓ 1 callersMethodreset
Reset the writer. This will clear the underlying writer, the internal buffer, and the user metadata. It will also generate a new sync marker. # Exam
avro/src/writer/mod.rs:621
↓ 1 callersMethodresolve_array
( self, schema: &Schema, names: &HashMap<Name, S>, enclosing_namespace: Namesp
avro/src/types.rs:1108
↓ 1 callersMethodresolve_bigdecimal
(self)
avro/src/types.rs:782
↓ 1 callersMethodresolve_boolean
(self)
avro/src/types.rs:934
↓ 1 callersMethodresolve_bytes
(self)
avro/src/types.rs:999
↓ 1 callersMethodresolve_date
(self)
avro/src/types.rs:853
↓ 1 callersMethodresolve_decimal
( self, precision: Precision, scale: Scale, inner: &InnerDecimalSchema, )
avro/src/types.rs:806
↓ 1 callersMethodresolve_double
(self)
avro/src/types.rs:974
↓ 1 callersMethodresolve_duration
(self)
avro/src/types.rs:790
↓ 1 callersMethodresolve_fixed
(self, size: usize)
avro/src/types.rs:1023
↓ 1 callersMethodresolve_float
(self)
avro/src/types.rs:960
↓ 1 callersMethodresolve_int
(self)
avro/src/types.rs:941
↓ 1 callersMethodresolve_local_timestamp_micros
(self)
avro/src/types.rs:909
↓ 1 callersMethodresolve_local_timestamp_millis
(self)
avro/src/types.rs:899
↓ 1 callersMethodresolve_local_timestamp_nanos
(self)
avro/src/types.rs:919
↓ 1 callersMethodresolve_long
(self)
avro/src/types.rs:952
↓ 1 callersMethodresolve_map
( self, schema: &Schema, names: &HashMap<Name, S>, enclosing_namespace: Namesp
avro/src/types.rs:1129
↓ 1 callersMethodresolve_null
(self)
avro/src/types.rs:927
↓ 1 callersMethodresolve_record
( self, fields: &[RecordField], names: &HashMap<Name, S>, enclosing_namespace:
avro/src/types.rs:1154
↓ 1 callersMethodresolve_string
(self)
avro/src/types.rs:1013
↓ 1 callersMethodresolve_time_micros
(self)
avro/src/types.rs:867
↓ 1 callersMethodresolve_time_millis
(self)
avro/src/types.rs:860
↓ 1 callersMethodresolve_timestamp_micros
(self)
avro/src/types.rs:883
↓ 1 callersMethodresolve_timestamp_millis
(self)
avro/src/types.rs:875
↓ 1 callersMethodresolve_timestamp_nanos
(self)
avro/src/types.rs:891
↓ 1 callersMethodresolve_union
( self, schema: &UnionSchema, names: &HashMap<Name, S>, enclosing_namespace: N
avro/src/types.rs:1082
↓ 1 callersMethodresolve_uuid
(self, inner: &UuidSchema)
avro/src/types.rs:755
↓ 1 callersFunctionsend
(_s: S)
avro/src/schema/mod.rs:2118
↓ 1 callersFunctionser
(obj: &T)
avro_derive/tests/serde.rs:44
↓ 1 callersFunctionser
(obj: &T)
avro_derive/tests/derive.rs:58
↓ 1 callersFunctionserde
(obj: &T)
avro_derive/tests/derive.rs:50
↓ 1 callersMethodserialize_as_newtype_variant
( &self, serializer: S, index: usize, union: &'s UnionSchema, )
avro/src/serde/ser_schema/record/field_default.rs:37
↓ 1 callersMethodserialize_bool
(mut self, v: bool)
avro/src/serde/ser_schema/mod.rs:224
↓ 1 callersMethodserialize_bytes
(mut self, v: &[u8])
avro/src/serde/ser_schema/mod.rs:356
↓ 1 callersMethodserialize_element
(&mut self, value: &T)
avro/src/serde/ser.rs:306
↓ 1 callersMethodserialize_f32
(mut self, v: f32)
avro/src/serde/ser_schema/mod.rs:313
↓ 1 callersMethodserialize_f64
(mut self, v: f64)
avro/src/serde/ser_schema/mod.rs:323
↓ 1 callersMethodserialize_i32
(self, v: i32)
avro/src/serde/ser_schema/mod.rs:242
↓ 1 callersMethodserialize_i64
(self, v: i64)
avro/src/serde/ser.rs:135
↓ 1 callersMethodserialize_i64
(self, v: i64)
avro/src/serde/ser_schema/mod.rs:246
↓ 1 callersMethodserialize_newtype_variant
( self, _name: &'static str, variant_index: u32, variant: &'static str,
avro/src/serde/ser_schema/mod.rs:483
↓ 1 callersMethodserialize_none
(self)
avro/src/serde/ser_schema/mod.rs:375
↓ 1 callersMethodserialize_some
(self, value: &T)
avro/src/serde/ser_schema/mod.rs:386
↓ 1 callersMethodserialize_str
(mut self, v: &str)
avro/src/serde/ser_schema/mod.rs:344
↓ 1 callersMethodserialize_unit
(self)
avro/src/serde/ser.rs:202
↓ 1 callersMethodserialize_unit
(self)
avro/src/serde/ser_schema/mod.rs:404
↓ 1 callersMethodstring
(name: &'s str)
avro/src/serde/deser_schema/identifier.rs:29
↓ 1 callersFunctionstring_array_schema
()
avro/src/schema_compatibility.rs:466
↓ 1 callersFunctionstring_map_schema
()
avro/src/schema_compatibility.rs:478
↓ 1 callersMethodsubsec_nanos
(&self)
avro_derive/tests/serde.rs:398
↓ 1 callersFunctiontest_folder
(folder: &Path)
avro/tests/shared.rs:99
↓ 1 callersFunctiontest_logger
()
avro_test_helper/src/logger.rs:44
↓ 1 callersFunctiontest_read
(mut encoded: &[u8])
avro/examples/test_interop_single_object_encoding.rs:75
↓ 1 callersFunctiontest_user_metadata
( reader: &Reader<BufReader<R>>, expected_user_metadata: &HashMap<String, Vec<u8>>, )
avro/examples/test_interop_data.rs:72
↓ 1 callersFunctiontest_write
(expected: &[u8])
avro/examples/test_interop_single_object_encoding.rs:66
↓ 1 callersFunctiontransparent
( input_span: Span, ident: Ident, generics: Generics, data: DataStruct, )
avro_derive/src/structs.rs:169
↓ 1 callersFunctiontype_to_field_default_expr
(ty: &Type)
avro_derive/src/fields.rs:145
↓ 1 callersFunctiontype_to_record_fields_expr
(ty: &Type)
avro_derive/src/fields.rs:123
↓ 1 callersFunctiontype_to_schema_expr
Takes in the Tokens of a type and returns the tokens of an expression with return type `Schema`
avro_derive/src/fields.rs:101
↓ 1 callersMethodunvalidated_append_value
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:245
↓ 1 callersFunctionvalid_examples
()
avro_test_helper/src/data.rs:632
↓ 1 callersMethodvalidate_schemata
Validate the value against the given schemata. # Panics Will panic if the schemata contain unresolved references or duplicate schemas.
avro/src/types.rs:386
↓ 1 callersFunctionwrite_ser
(schema: &Schema, records: &[T])
avro/benches/serde.rs:247
↓ 1 callersFunctionwrite_user_metadata
(writer: &mut Writer<BufWriter<W>>)
avro/examples/generate_interop_data.rs:111
← previousnext →301–400 of 1,631, ranked by callers