kaa_common_schema.h File Reference

#include <stddef.h>
#include "avro_src/avro/io.h"
#include "collections/kaa_list.h"

Go to the source code of this file.

Data Structures
struct	kaa_bytes_t
struct	kaa_string_t
struct	kaa_union_t

Macros
#define	AVRO_NULL_SIZE   0
#define	AVRO_FLOAT_SIZE   4
#define	AVRO_DOUBLE_SIZE   8

Typedefs
typedef void(*	serialize_fn )(avro_writer_t writer, void *data)
typedef void *(*	deserialize_fn )()
	This is like a parent class both for deserialize_wo_ctx_fn and deserialize_w_ctx_fn that is why it has an empty parameter list instead of using void. More...
typedef void *(*	deserialize_wo_ctx_fn )(avro_reader_t reader)
	See deserialize_fn. More...
typedef void *(*	deserialize_w_ctx_fn )(avro_reader_t reader, void *context)
	See deserialize_fn. More...
typedef size_t(*	get_size_fn )(void *data)
typedef void(*	destroy_fn )(void *data)

Functions
kaa_string_t *	kaa_string_move_create (const char *data, destroy_fn destroy)
kaa_string_t *	kaa_string_copy_create (const char *data)
void	kaa_string_destroy (void *data)
void	kaa_string_serialize (avro_writer_t writer, void *data)
kaa_string_t *	kaa_string_deserialize (avro_reader_t reader)
size_t	kaa_string_get_size (void *data)
kaa_bytes_t *	kaa_bytes_move_create (const uint8_t *data, size_t data_len, destroy_fn destroy)
kaa_bytes_t *	kaa_bytes_copy_create (const uint8_t *data, size_t data_len)
void	kaa_bytes_destroy (void *data)
void	kaa_bytes_serialize (avro_writer_t writer, void *data)
kaa_bytes_t *	kaa_bytes_deserialize (avro_reader_t reader)
size_t	kaa_bytes_get_size (void *data)
kaa_bytes_t *	kaa_fixed_move_create (const uint8_t *data, size_t data_len, destroy_fn destroy)
kaa_bytes_t *	kaa_fixed_copy_create (const uint8_t *data, size_t data_len)
void	kaa_fixed_destroy (void *data)
void	kaa_fixed_serialize (avro_writer_t writer, void *data)
kaa_bytes_t *	kaa_fixed_deserialize (avro_reader_t reader, void *context)
size_t	kaa_fixed_get_size (void *data)
void	kaa_boolean_serialize (avro_writer_t writer, void *data)
int8_t *	kaa_boolean_deserialize (avro_reader_t reader)
size_t	kaa_boolean_get_size (void *data)
void	kaa_int_serialize (avro_writer_t writer, void *data)
int32_t *	kaa_int_deserialize (avro_reader_t reader)
size_t	kaa_int_get_size (void *data)
void	kaa_long_serialize (avro_writer_t writer, void *data)
int64_t *	kaa_long_deserialize (avro_reader_t reader)
size_t	kaa_long_get_size (void *data)
void	kaa_enum_serialize (avro_writer_t writer, void *data)
int *	kaa_enum_deserialize (avro_reader_t reader)
size_t	kaa_enum_get_size (void *data)
void	kaa_float_serialize (avro_writer_t writer, void *data)
float *	kaa_float_deserialize (avro_reader_t reader)
size_t	kaa_float_get_size (void *data)
void	kaa_double_serialize (avro_writer_t writer, void *data)
double *	kaa_double_deserialize (avro_reader_t reader)
size_t	kaa_double_get_size (void *data)
void	kaa_array_serialize (avro_writer_t writer, kaa_list_t *array, serialize_fn serialize)
kaa_list_t *	kaa_array_deserialize_wo_ctx (avro_reader_t reader, deserialize_wo_ctx_fn deserialize)
kaa_list_t *	kaa_array_deserialize_w_ctx (avro_reader_t reader, deserialize_w_ctx_fn deserialize, void *deserialize_context)
size_t	kaa_array_get_size (kaa_list_t *array, get_size_fn get_size)
void	kaa_null_serialize (avro_writer_t writer, void *data)
void *	kaa_null_deserialize (avro_reader_t reader)
void	kaa_null_destroy (void *data)
size_t	kaa_null_get_size (void *data)
void	kaa_data_destroy (void *data)
size_t	avro_long_get_size (int64_t l)

Macro Definition Documentation

#define AVRO_DOUBLE_SIZE   8

#define AVRO_FLOAT_SIZE   4

#define AVRO_NULL_SIZE   0

Typedef Documentation

typedef void*(* deserialize_fn)()

This is like a parent class both for deserialize_wo_ctx_fn and deserialize_w_ctx_fn that is why it has an empty parameter list instead of using void.

Note

It is not expected to use it explicitly. It is used under the hood of Avro Gen C.

It is a workaround to specify different type of a deserializer. For now there is two kinds - with and without context. Now a context is used to deserialize the fixed Avro type. See kaa_fixed_deserialize().

typedef void*(* deserialize_w_ctx_fn)(avro_reader_t reader, void *context)

See deserialize_fn.

typedef void*(* deserialize_wo_ctx_fn)(avro_reader_t reader)

See deserialize_fn.

typedef void(* destroy_fn)(void *data)

typedef size_t(* get_size_fn)(void *data)

typedef void(* serialize_fn)(avro_writer_t writer, void *data)

Function Documentation

size_t avro_long_get_size

(

int64_t

l

)

kaa_list_t* kaa_array_deserialize_w_ctx	(	avro_reader_t	reader,
		deserialize_w_ctx_fn	deserialize,
		void *	deserialize_context
	)

kaa_list_t* kaa_array_deserialize_wo_ctx	(	avro_reader_t	reader,
		deserialize_wo_ctx_fn	deserialize
	)

size_t kaa_array_get_size	(	kaa_list_t *	array,
		get_size_fn	get_size
	)

void kaa_array_serialize	(	avro_writer_t	writer,
		kaa_list_t *	array,
		serialize_fn	serialize
	)

int8_t* kaa_boolean_deserialize

(

avro_reader_t

reader

)

size_t kaa_boolean_get_size

(

void *

data

)

void kaa_boolean_serialize	(	avro_writer_t	writer,
		void *	data
	)

kaa_bytes_t* kaa_bytes_copy_create	(	const uint8_t *	data,
		size_t	data_len
	)

kaa_bytes_t* kaa_bytes_deserialize

(

avro_reader_t

reader

)

void kaa_bytes_destroy

(

void *

data

)

size_t kaa_bytes_get_size

(

void *

data

)

kaa_bytes_t* kaa_bytes_move_create	(	const uint8_t *	data,
		size_t	data_len,
		destroy_fn	destroy
	)

void kaa_bytes_serialize	(	avro_writer_t	writer,
		void *	data
	)

void kaa_data_destroy

(

void *

data

)

double* kaa_double_deserialize

(

avro_reader_t

reader

)

size_t kaa_double_get_size

(

void *

data

)

void kaa_double_serialize	(	avro_writer_t	writer,
		void *	data
	)

int* kaa_enum_deserialize

(

avro_reader_t

reader

)

size_t kaa_enum_get_size

(

void *

data

)

void kaa_enum_serialize	(	avro_writer_t	writer,
		void *	data
	)

kaa_bytes_t* kaa_fixed_copy_create	(	const uint8_t *	data,
		size_t	data_len
	)

kaa_bytes_t* kaa_fixed_deserialize	(	avro_reader_t	reader,
		void *	context
	)

void kaa_fixed_destroy

(

void *

data

)

size_t kaa_fixed_get_size

(

void *

data

)

kaa_bytes_t* kaa_fixed_move_create	(	const uint8_t *	data,
		size_t	data_len,
		destroy_fn	destroy
	)

void kaa_fixed_serialize	(	avro_writer_t	writer,
		void *	data
	)

float* kaa_float_deserialize

(

avro_reader_t

reader

)

size_t kaa_float_get_size

(

void *

data

)

void kaa_float_serialize	(	avro_writer_t	writer,
		void *	data
	)

int32_t* kaa_int_deserialize

(

avro_reader_t

reader

)

size_t kaa_int_get_size

(

void *

data

)

void kaa_int_serialize	(	avro_writer_t	writer,
		void *	data
	)

int64_t* kaa_long_deserialize

(

avro_reader_t

reader

)

size_t kaa_long_get_size

(

void *

data

)

void kaa_long_serialize	(	avro_writer_t	writer,
		void *	data
	)

void* kaa_null_deserialize

(

avro_reader_t

reader

)

void kaa_null_destroy

(

void *

data

)

size_t kaa_null_get_size

(

void *

data

)

void kaa_null_serialize	(	avro_writer_t	writer,
		void *	data
	)

kaa_string_t* kaa_string_copy_create

(

const char *

data

)

kaa_string_t* kaa_string_deserialize

(

avro_reader_t

reader

)

void kaa_string_destroy

(

void *

data

)

size_t kaa_string_get_size

(

void *

data

)

kaa_string_t* kaa_string_move_create	(	const char *	data,
		destroy_fn	destroy
	)

void kaa_string_serialize	(	avro_writer_t	writer,
		void *	data
	)