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
↓ 255 callersMethodclone
(&self)
avro/src/serde/ser_schema/mod.rs:78
↓ 193 callersMethodbuild
Create the `UnionSchema`.
avro/src/schema/union.rs:488
↓ 112 callersMethodmap
( #[builder(start_fn)] types: Schema, attributes: Option<BTreeMap<String, JsonValue>>, )
avro/src/schema/builders.rs:31
↓ 104 callersMethodput
Add a field to the `Record`. TODO: This should return an error at least panic NOTE**: If the field name does not exist in the schema, the value is si
avro/src/types.rs:249
↓ 86 callersFunctionassert_roundtrip
(value: T, schema: &Schema, schemata: Vec<&Schema>)
avro/src/serde/deser_schema/mod.rs:779
↓ 84 callersMethodget
Get the value for a given field name. Returns `None` if the field is not present in the schema
avro/src/types.rs:261
↓ 77 callersMethodlen
(&self)
avro/src/writer/mod.rs:1186
↓ 75 callersFunctionassert_serialize_err
( t: T, schema: &Schema, names: &HashMap<Name, &Schema>, expected: &str, )
avro/src/serde/ser_schema/mod.rs:769
↓ 66 callersFunctionassert_serialize
( t: T, schema: &Schema, names: &HashMap<Name, &Schema>, expected: &[u8],
avro/src/serde/ser_schema/mod.rs:789
↓ 62 callersMethodserialize_entry
(&mut self, key: &K, value: &V)
avro/src/serde/ser_schema/record/mod.rs:236
↓ 58 callersMethodname
Returns the name of the schema if it has one.
avro/src/schema/mod.rs:671
↓ 54 callersMethodlen
(&self)
avro/src/decimal.rs:83
↓ 47 callersMethodappend_value
Append a value to the `Writer`, also performs schema validation. Returns the number of bytes written (it might be 0, see below). NOTE**: This functi
avro/src/writer/mod.rs:206
↓ 47 callersMethodinto_inner
Return what the `Writer` is writing to, consuming the `Writer` itself. NOTE**: This function forces the written data to be flushed (an implicit call
avro/src/writer/mod.rs:435
↓ 47 callersMethodreader_schema
(&self)
avro/src/reader/mod.rs:104
↓ 46 callersMethodis_empty
(&self)
avro/src/reader/block.rs:183
↓ 43 callersFunctionencode
Encode a `Value` into avro format. NOTE** This will not perform schema validation. The value is assumed to be valid with regards to the schema. Schem
avro/src/encode.rs:38
↓ 43 callersMethodschema
Get a reference to the `Schema` associated to a `Writer`.
avro/src/writer/mod.rs:189
↓ 42 callersFunctionzig_i32
Write the number as a zigzagged varint to the writer.
avro/src/util.rs:81
↓ 41 callersFunctionzig_i64
Write the number as a zigzagged varint to the writer.
avro/src/util.rs:86
↓ 39 callersMethodas_ref
(&self)
avro/src/schema/name.rs:234
↓ 37 callersMethodnamespace
Returns the namespace of the schema if it has one.
avro/src/schema/mod.rs:688
↓ 35 callersFunctionto_value
Interpret a serializeable instance as a `Value`. This conversion can fail if the value is not valid as per the Avro specification. e.g: `HashMap` wit
avro/src/serde/ser.rs:485
↓ 34 callersFunctioninit
Does nothing. Just loads the crate. Should be used in the integration tests, because they do not use [dev-dependencies] and do not auto-load this crat
avro_test_helper/src/lib.rs:76
↓ 34 callersMethodwrite_value_to_vec
Write a value to a [`Vec`].
avro/src/writer/datum.rs:137
↓ 33 callersFunctionsuccess
(value: &Value, schema: &Schema)
avro/src/encode.rs:383
↓ 31 callersMethoderror
Create an error for the current type being deserialized with the given message. This will also include the current schema.
avro/src/serde/deser_schema/mod.rs:112
↓ 31 callersMethodserialize
(&self, serializer: S)
avro/src/serde/ser_schema/record/field_default.rs:117
↓ 30 callersMethodcanonical_form
Converts `self` into its [Parsing Canonical Form]. [Parsing Canonical Form]: https://avro.apache.org/docs/++version++/specification/#parsing-canonica
avro/src/schema/mod.rs:466
↓ 29 callersMethodcompare
(&self, schema_one: &Schema, schema_two: &Schema)
avro/src/schema_equality.rs:77
↓ 29 callersMethodread_value
Read a Avro datum from the reader.
avro/src/reader/datum.rs:132
↓ 29 callersMethodto_vec
(&self)
avro/src/decimal.rs:87
↓ 28 callersMethodcontains
Check if a schema already exists in this union.
avro/src/schema/union.rs:470
↓ 28 callersMethoderror
(&self, ty: &'static str, error: impl Into<String>)
avro/src/serde/ser_schema/mod.rs:110
↓ 28 callersMethoderror
(&self, ty: &'static str, error: impl Into<String>)
avro/src/serde/ser_schema/union.rs:57
↓ 28 callersMethodresolve
Attempt to perform schema resolution on the value, with the given [Schema](../schema/enum.Schema.html). See [Schema Resolution](https://avro.apache.o
avro/src/types.rs:665
↓ 27 callersMethoderror
(&self, error: &'static str)
avro/src/serde/deser_schema/identifier.rs:37
↓ 26 callersMethodget_names
(&self)
avro/src/schema/resolve.rs:37
↓ 25 callersMethodflush
Flush the content to the inner `Writer`. Call this function to make sure all the content has been written before releasing the `Writer`. This will al
avro/src/writer/mod.rs:404
↓ 25 callersFunctionget_schema_in_ctxt
( _named_schemas: &mut HashSet<Name>, _enclosing_namespace: NamespaceRef, )
avro_derive/tests/derive.rs:1876
↓ 25 callersMethodwith_union
Read the union and create a new deserializer with the existing reader and config. This will resolve the read schema if it is a reference.
avro/src/serde/deser_schema/mod.rs:135
↓ 24 callersMethoddeserialize
(deserializer: D)
avro/src/serde/de.rs:1771
↓ 22 callersMethodclear
(&mut self)
avro/src/writer/mod.rs:578
↓ 20 callersMethodend
(self)
avro/src/serde/ser.rs:314
↓ 19 callersMethodserialize_map
(self, len: Option<usize>)
avro/src/serde/ser.rs:275
↓ 18 callersMethodas_bytes
(&self)
avro/src/duration.rs:37
↓ 18 callersFunctionserde_assert
(obj: T)
avro_derive/tests/derive.rs:42
↓ 17 callersMethodfullname
Return the `fullname` of this `Name` More information about fullnames can be found in the [Avro specification](https://avro.apache.org/docs/++version
avro/src/schema/name.rs:139
↓ 17 callersMethodvariants
Returns a slice to all variants of this schema.
avro/src/schema/union.rs:80
↓ 17 callersMethodwrite
(&self, data: T, writer: &mut W)
avro/src/writer/single_object.rs:225
↓ 17 callersFunctionzag_i64
Decode a zigzagged varint from the reader.
avro/src/util.rs:98
↓ 16 callersMethodclone
(&self)
avro/src/serde/deser_schema/mod.rs:69
↓ 16 callersMethodextend
Extend a `Writer` with an `Iterator` of values, also performs schema validation. Returns the number of bytes written. NOTE**: This function forces t
avro/src/writer/mod.rs:318
↓ 16 callersFunctionfrom_value
Interpret a `Value` as an instance of type `D`. This conversion can fail if the structure of the `Value` does not match the structure expected by `D`
avro/src/serde/de.rs:946
↓ 16 callersMethodindex_of_schema_kind
Get the index of the provided [`SchemaKind`]. The schema must not be a logical type, as only the base type are saved in the lookup index.
avro/src/schema/union.rs:98
↓ 16 callersMethodnext
(&mut self)
avro/src/reader/mod.rs:147
↓ 15 callersMethodaliases
Returns the aliases of the schema if it has ones.
avro/src/schema/mod.rs:693
↓ 15 callersFunctionassert_logged
(expected_message: &str)
avro_test_helper/src/logger.rs:114
↓ 15 callersMethoddoc
Returns the doc of the schema if it has one.
avro/src/schema/mod.rs:709
↓ 14 callersMethodmap
( writer: &'w mut W, schema: &'s MapSchema, config: Config<'s, S>, len: Option
avro/src/serde/ser_schema/mod.rs:697
↓ 14 callersFunctionserde_assert
(obj: T)
avro_derive/tests/serde.rs:30
↓ 13 callersFunctionassert_roundtrip
(input: &T, schema: &Schema, schemata: &[Schema])
avro/tests/union_schema.rs:73
↓ 13 callersMethodextend_from_slice
Extend a `Writer` by appending each `Value` from a slice, while also performing schema validation on each value appended. Returns the number of bytes
avro/src/writer/mod.rs:387
↓ 13 callersFunctionunion_schema
(schemas: Vec<Schema>)
avro/src/schema_compatibility.rs:561
↓ 12 callersMethodfully_qualified_name
Construct the fully qualified name ``` # use apache_avro::{Error, schema::Name}; assert_eq!( Name::new("some_name")?.fully_qualified_name(Some("some_
avro/src/schema/name.rs:164
↓ 12 callersFunctionget_schema_in_ctxt
Returns [`Schema::Bytes`]
avro/src/serde/with.rs:107
↓ 12 callersMethodresolve_internal
( mut self, schema: &Schema, names: &HashMap<Name, S>, enclosing_namespace: Na
avro/src/types.rs:685
↓ 12 callersMethodwrite_ser_to_vec
Serialize `T` to a [`Vec`].
avro/src/writer/datum.rs:158
↓ 11 callersMethodread_deser
Read a Avro datum from the reader. # Panics Will panic if a reader schema has been configured, this is a WIP.
avro/src/reader/datum.rs:145
↓ 11 callersMethodserialize_str
(self, v: &str)
avro/src/serde/ser.rs:179
↓ 10 callersFunctiondecode
Decode a `Value` from avro format given its `Schema`.
avro/src/decode.rs:72
↓ 9 callersMethodadd_user_metadata
Adds custom metadata to the file. This method could be used only before adding the first record to the writer.
avro/src/writer/mod.rs:494
↓ 9 callersMethodlen
(&self)
avro/src/reader/block.rs:179
↓ 9 callersMethodparse
Parses an Avro schema from JSON.
avro/src/schema/mod.rs:623
↓ 9 callersMethodvariant
Add a variant to this union. # Errors Will return a [`Details::GetUnionDuplicateNamedSchemas`] or [`Details::GetUnionDuplicate`] if duplicate names o
avro/src/schema/union.rs:446
↓ 9 callersMethodvariant_ignore_duplicates
This is not a public API, it should only be used by `avro_derive` Add a variant to this union, if it already exists ignore it. # Errors Will return
avro/src/schema/union.rs:392
↓ 9 callersMethodvisit_bytes
(self, v: &[u8])
avro/src/serde/de.rs:1783
↓ 8 callersMethodappend_ser
Append anything implementing the `Serialize` trait to a `Writer` for [`serde`](https://docs.serde.rs/serde/index.html) compatibility, also performing
avro/src/writer/mod.rs:289
↓ 8 callersFunctionbenchmark
( schema: &Schema, record: &Value, big_or_small: &str, count: usize, runs: usize, )
avro/examples/benchmark.rs:43
↓ 8 callersFunctionencode_long
(i: i64, writer: W)
avro/src/encode.rs:57
↓ 8 callersFunctionlogical_type_test
( schema_str: &'static str, expected_schema: &Schema, value: Value, raw_sche
avro/src/writer/datum.rs:360
↓ 8 callersFunctionlong_record_schema
()
avro/tests/io.rs:179
↓ 8 callersMethodschemata
Set the schemata that will be used to resolve any references in the schema. This is equivalent to `.resolved_schemata(ResolvedSchema::new_with_schema
avro/src/writer/datum.rs:99
↓ 8 callersMethodvisit_seq
(self, mut seq: A)
avro/src/decimal.rs:58
↓ 8 callersFunctionzag_i32
Decode a zigzagged varint from the reader.
avro/src/util.rs:92
↓ 7 callersFunctionbench_read
( c: &mut Criterion, make_record: impl Fn() -> Result<(Schema, Value), Box<dyn std::error::Error>>,
avro/benches/serde.rs:295
↓ 7 callersFunctionencode_bytes
Encode `s` as the _bytes_ primitive type. This writes the length as the _long_ primitive and then the raw bytes.
avro/src/encode.rs:46
↓ 7 callersMethodfull_match_schemas
Check if the reader schema can be resolved from the writer schema.
avro/src/schema_compatibility.rs:143
↓ 7 callersMethodget_schema
Get the schema for this name.
avro/src/serde/deser_schema/mod.rs:57
↓ 7 callersMethodparse
Create a `Schema` from a `serde_json::Value` representing a JSON Avro schema.
avro/src/schema/parser.rs:105
↓ 7 callersMethodset
(temp: BytesType)
avro/src/serde/with.rs:43
↓ 7 callersFunctionwarn
Emit a compiler warning. This is a no-op when the `nightly` feature is not enabled.
avro_derive/src/attributes/mod.rs:384
↓ 6 callersFunctionbench_write
( c: &mut Criterion, make_record: impl Fn() -> Result<(Schema, Value), Box<dyn std::error::Error>>,
avro/benches/serde.rs:271
↓ 6 callersFunctionbench_write_ser
( c: &mut Criterion, make_record: impl Fn() -> Result<(Schema, T), Box<dyn std::error::Error>>, n_
avro/benches/serde.rs:283
↓ 6 callersMethodbuild_header
(&self)
avro/src/headers.rs:48
↓ 6 callersFunctiondeserialize
(deserializer: D)
avro/src/serde/with.rs:128
↓ 6 callersFunctiondeserialize_big_decimal
(mut bytes: &[u8])
avro/src/bigdecimal.rs:50
↓ 6 callersFunctionget_record_fields_in_ctxt
Returns `None`
avro/src/serde/with.rs:112
↓ 6 callersMethodwrite_array
Write an array of `n` bytes to the writer. This does not check the current schema.
avro/src/serde/ser_schema/mod.rs:197
↓ 6 callersMethodwrite_array
Write an array of `n` 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:125
next →1–100 of 1,631, ranked by callers