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
↓ 1 callers
Method
get_parsed_schemas
(&mut self)
avro/src/schema/parser.rs:57
↓ 1 callers
Function
has_default_attr
(attrs: &[Attribute])
avro_derive/src/enums/plain.rs:140
↓ 1 callers
Method
inner_full_match_schemas
( &mut self, writers_schema: &Schema, readers_schema: &Schema, )
avro/src/schema_compatibility.rs:177
↓ 1 callers
Function
install
()
avro_test_helper/src/logger.rs:129
↓ 1 callers
Function
is_named_type
(typ: Option<&str>)
avro/src/schema/mod.rs:1158
↓ 1 callers
Function
json_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 callers
Function
make_records_ser
(record: T, count: usize)
avro/benches/serde.rs:237
↓ 1 callers
Function
make_writer_with_builder
(schema: &Schema)
avro/src/writer/mod.rs:862
↓ 1 callers
Function
make_writer_with_codec
(schema: &Schema)
avro/src/writer/mod.rs:854
↓ 1 callers
Function
max_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 callers
Method
merge
(&self, err: &ErrorsDesc)
avro/tests/shared.rs:84
↓ 1 callers
Method
namespace
(&self)
avro/src/schema/name.rs:127
↓ 1 callers
Function
normal
( input_span: Span, ident: Ident, generics: Generics, container_attrs: NamedTypeOptions, d
avro_derive/src/structs.rs:44
↓ 1 callers
Method
parse_array
Parse a `serde_json::Value` representing a Avro array type into a `Schema`.
avro/src/schema/parser.rs:691
↓ 1 callers
Method
parse_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 callers
Method
parse_enum
Parse a `serde_json::Value` representing a Avro enum type into a `Schema`.
avro/src/schema/parser.rs:614
↓ 1 callers
Method
parse_json_integer_for_decimal
( &self, value: &serde_json::Number, )
avro/src/schema/parser.rs:830
↓ 1 callers
Method
parse_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 callers
Method
parse_map
Parse a `serde_json::Value` representing a Avro map type into a `Schema`.
avro/src/schema/parser.rs:707
↓ 1 callers
Method
parse_precision_and_scale
( &self, complex: &Map<String, Value>, )
avro/src/schema/parser.rs:229
↓ 1 callers
Method
parse_record
Parse a `serde_json::Value` representing an Avro record type into a `Schema`.
avro/src/schema/parser.rs:540
↓ 1 callers
Function
pcf_array
(arr: &[JsonValue], defined_names: &mut HashSet<String>)
avro/src/schema/mod.rs:1165
↓ 1 callers
Function
pcf_map
(schema: &Map<String, JsonValue>, defined_names: &mut HashSet<String>)
avro/src/schema/mod.rs:1076
↓ 1 callers
Function
permutation_indices
Return all permutations of the indices of a vector
avro/tests/schema.rs:414
↓ 1 callers
Method
read
(&self, reader: &mut R)
avro/src/reader/datum.rs:193
↓ 1 callers
Method
read
(&self, reader: &mut R)
avro/src/reader/single_object.rs:132
↓ 1 callers
Function
read_codec
(metadata: &HashMap<String, Value>)
avro/src/reader/block.rs:298
↓ 1 callers
Method
read_deser
(&self, reader: &mut impl Read)
avro/src/reader/single_object.rs:71
↓ 1 callers
Method
read_from_value
(&self, reader: &mut R)
avro/src/reader/single_object.rs:123
↓ 1 callers
Method
read_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 callers
Method
read_next
(&mut self)
avro/src/reader/mod.rs:123
↓ 1 callers
Function
read_schemaless
(bytes: &[u8])
avro/benches/serde.rs:262
↓ 1 callers
Method
read_user_metadata
(&mut self, key: String, value: Value)
avro/src/reader/block.rs:286
↓ 1 callers
Method
read_writer_schema
(&mut self, metadata: &HashMap<String, Value>)
avro/src/reader/block.rs:256
↓ 1 callers
Method
register_resolving_schema
(&mut self, name: &Name, aliases: &Aliases)
avro/src/schema/parser.rs:477
↓ 1 callers
Method
reset
(&mut self)
avro/src/rabin.rs:111
↓ 1 callers
Method
reset
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 callers
Method
resolve_array
( self, schema: &Schema, names: &HashMap<Name, S>, enclosing_namespace: Namesp
avro/src/types.rs:1108
↓ 1 callers
Method
resolve_bigdecimal
(self)
avro/src/types.rs:782
↓ 1 callers
Method
resolve_boolean
(self)
avro/src/types.rs:934
↓ 1 callers
Method
resolve_bytes
(self)
avro/src/types.rs:999
↓ 1 callers
Method
resolve_date
(self)
avro/src/types.rs:853
↓ 1 callers
Method
resolve_decimal
( self, precision: Precision, scale: Scale, inner: &InnerDecimalSchema, )
avro/src/types.rs:806
↓ 1 callers
Method
resolve_double
(self)
avro/src/types.rs:974
↓ 1 callers
Method
resolve_duration
(self)
avro/src/types.rs:790
↓ 1 callers
Method
resolve_fixed
(self, size: usize)
avro/src/types.rs:1023
↓ 1 callers
Method
resolve_float
(self)
avro/src/types.rs:960
↓ 1 callers
Method
resolve_int
(self)
avro/src/types.rs:941
↓ 1 callers
Method
resolve_local_timestamp_micros
(self)
avro/src/types.rs:909
↓ 1 callers
Method
resolve_local_timestamp_millis
(self)
avro/src/types.rs:899
↓ 1 callers
Method
resolve_local_timestamp_nanos
(self)
avro/src/types.rs:919
↓ 1 callers
Method
resolve_long
(self)
avro/src/types.rs:952
↓ 1 callers
Method
resolve_map
( self, schema: &Schema, names: &HashMap<Name, S>, enclosing_namespace: Namesp
avro/src/types.rs:1129
↓ 1 callers
Method
resolve_null
(self)
avro/src/types.rs:927
↓ 1 callers
Method
resolve_record
( self, fields: &[RecordField], names: &HashMap<Name, S>, enclosing_namespace:
avro/src/types.rs:1154
↓ 1 callers
Method
resolve_string
(self)
avro/src/types.rs:1013
↓ 1 callers
Method
resolve_time_micros
(self)
avro/src/types.rs:867
↓ 1 callers
Method
resolve_time_millis
(self)
avro/src/types.rs:860
↓ 1 callers
Method
resolve_timestamp_micros
(self)
avro/src/types.rs:883
↓ 1 callers
Method
resolve_timestamp_millis
(self)
avro/src/types.rs:875
↓ 1 callers
Method
resolve_timestamp_nanos
(self)
avro/src/types.rs:891
↓ 1 callers
Method
resolve_union
( self, schema: &UnionSchema, names: &HashMap<Name, S>, enclosing_namespace: N
avro/src/types.rs:1082
↓ 1 callers
Method
resolve_uuid
(self, inner: &UuidSchema)
avro/src/types.rs:755
↓ 1 callers
Function
send
(_s: S)
avro/src/schema/mod.rs:2118
↓ 1 callers
Function
ser
(obj: &T)
avro_derive/tests/serde.rs:44
↓ 1 callers
Function
ser
(obj: &T)
avro_derive/tests/derive.rs:58
↓ 1 callers
Function
serde
(obj: &T)
avro_derive/tests/derive.rs:50
↓ 1 callers
Method
serialize_as_newtype_variant
( &self, serializer: S, index: usize, union: &'s UnionSchema, )
avro/src/serde/ser_schema/record/field_default.rs:37
↓ 1 callers
Method
serialize_bool
(mut self, v: bool)
avro/src/serde/ser_schema/mod.rs:224
↓ 1 callers
Method
serialize_bytes
(mut self, v: &[u8])
avro/src/serde/ser_schema/mod.rs:356
↓ 1 callers
Method
serialize_element
(&mut self, value: &T)
avro/src/serde/ser.rs:306
↓ 1 callers
Method
serialize_f32
(mut self, v: f32)
avro/src/serde/ser_schema/mod.rs:313
↓ 1 callers
Method
serialize_f64
(mut self, v: f64)
avro/src/serde/ser_schema/mod.rs:323
↓ 1 callers
Method
serialize_i32
(self, v: i32)
avro/src/serde/ser_schema/mod.rs:242
↓ 1 callers
Method
serialize_i64
(self, v: i64)
avro/src/serde/ser.rs:135
↓ 1 callers
Method
serialize_i64
(self, v: i64)
avro/src/serde/ser_schema/mod.rs:246
↓ 1 callers
Method
serialize_newtype_variant
( self, _name: &'static str, variant_index: u32, variant: &'static str,
avro/src/serde/ser_schema/mod.rs:483
↓ 1 callers
Method
serialize_none
(self)
avro/src/serde/ser_schema/mod.rs:375
↓ 1 callers
Method
serialize_some
(self, value: &T)
avro/src/serde/ser_schema/mod.rs:386
↓ 1 callers
Method
serialize_str
(mut self, v: &str)
avro/src/serde/ser_schema/mod.rs:344
↓ 1 callers
Method
serialize_unit
(self)
avro/src/serde/ser.rs:202
↓ 1 callers
Method
serialize_unit
(self)
avro/src/serde/ser_schema/mod.rs:404
↓ 1 callers
Method
string
(name: &'s str)
avro/src/serde/deser_schema/identifier.rs:29
↓ 1 callers
Function
string_array_schema
()
avro/src/schema_compatibility.rs:466
↓ 1 callers
Function
string_map_schema
()
avro/src/schema_compatibility.rs:478
↓ 1 callers
Method
subsec_nanos
(&self)
avro_derive/tests/serde.rs:398
↓ 1 callers
Function
test_folder
(folder: &Path)
avro/tests/shared.rs:99
↓ 1 callers
Function
test_logger
()
avro_test_helper/src/logger.rs:44
↓ 1 callers
Function
test_read
(mut encoded: &[u8])
avro/examples/test_interop_single_object_encoding.rs:75
↓ 1 callers
Function
test_user_metadata
( reader: &Reader<BufReader<R>>, expected_user_metadata: &HashMap<String, Vec<u8>>, )
avro/examples/test_interop_data.rs:72
↓ 1 callers
Function
test_write
(expected: &[u8])
avro/examples/test_interop_single_object_encoding.rs:66
↓ 1 callers
Function
transparent
( input_span: Span, ident: Ident, generics: Generics, data: DataStruct, )
avro_derive/src/structs.rs:169
↓ 1 callers
Function
type_to_field_default_expr
(ty: &Type)
avro_derive/src/fields.rs:145
↓ 1 callers
Function
type_to_record_fields_expr
(ty: &Type)
avro_derive/src/fields.rs:123
↓ 1 callers
Function
type_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 callers
Method
unvalidated_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 callers
Function
valid_examples
()
avro_test_helper/src/data.rs:632
↓ 1 callers
Method
validate_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 callers
Function
write_ser
(schema: &Schema, records: &[T])
avro/benches/serde.rs:247
↓ 1 callers
Function
write_user_metadata
(writer: &mut Writer<BufWriter<W>>)
avro/examples/generate_interop_data.rs:111
← previous
next →
301–400 of 1,631, ranked by callers