diff options
Diffstat (limited to 'fluent-bit/lib/avro/src/encoding.h')
-rw-r--r-- | fluent-bit/lib/avro/src/encoding.h | 106 |
1 files changed, 0 insertions, 106 deletions
diff --git a/fluent-bit/lib/avro/src/encoding.h b/fluent-bit/lib/avro/src/encoding.h deleted file mode 100644 index 6333d588d..000000000 --- a/fluent-bit/lib/avro/src/encoding.h +++ /dev/null @@ -1,106 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to you under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * https://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or - * implied. See the License for the specific language governing - * permissions and limitations under the License. - */ -#ifndef AVRO_ENCODING_H -#define AVRO_ENCODING_H -#ifdef __cplusplus -extern "C" { -#define CLOSE_EXTERN } -#else -#define CLOSE_EXTERN -#endif - -#include <avro/platform.h> -#include "avro/io.h" - -/* - * TODO: this will need more functions when JSON encoding is added - */ -struct avro_encoding_t { - const char *description; - /* - * string - */ - int (*read_string) (avro_reader_t reader, char **s, int64_t *len); - int (*skip_string) (avro_reader_t reader); - int (*write_string) (avro_writer_t writer, const char *s); - int64_t(*size_string) (avro_writer_t writer, const char *s); - /* - * bytes - */ - int (*read_bytes) (avro_reader_t reader, char **bytes, int64_t * len); - int (*skip_bytes) (avro_reader_t reader); - int (*write_bytes) (avro_writer_t writer, - const char *bytes, const int64_t len); - int64_t(*size_bytes) (avro_writer_t writer, - const char *bytes, const int64_t len); - /* - * int - */ - int (*read_int) (avro_reader_t reader, int32_t * i); - int (*skip_int) (avro_reader_t reader); - int (*write_int) (avro_writer_t writer, const int32_t i); - int64_t(*size_int) (avro_writer_t writer, const int32_t i); - /* - * long - */ - int (*read_long) (avro_reader_t reader, int64_t * l); - int (*skip_long) (avro_reader_t reader); - int (*write_long) (avro_writer_t writer, const int64_t l); - int64_t(*size_long) (avro_writer_t writer, const int64_t l); - /* - * float - */ - int (*read_float) (avro_reader_t reader, float *f); - int (*skip_float) (avro_reader_t reader); - int (*write_float) (avro_writer_t writer, const float f); - int64_t(*size_float) (avro_writer_t writer, const float f); - /* - * double - */ - int (*read_double) (avro_reader_t reader, double *d); - int (*skip_double) (avro_reader_t reader); - int (*write_double) (avro_writer_t writer, const double d); - int64_t(*size_double) (avro_writer_t writer, const double d); - /* - * boolean - */ - int (*read_boolean) (avro_reader_t reader, int8_t * b); - int (*skip_boolean) (avro_reader_t reader); - int (*write_boolean) (avro_writer_t writer, const int8_t b); - int64_t(*size_boolean) (avro_writer_t writer, const int8_t b); - /* - * null - */ - int (*read_null) (avro_reader_t reader); - int (*skip_null) (avro_reader_t reader); - int (*write_null) (avro_writer_t writer); - int64_t(*size_null) (avro_writer_t writer); -}; -typedef struct avro_encoding_t avro_encoding_t; - -#define AVRO_WRITE(writer, buf, len) \ -{ int rval = avro_write( writer, buf, len ); if(rval) return rval; } -#define AVRO_READ(reader, buf, len) \ -{ int rval = avro_read( reader, buf, len ); if(rval) return rval; } -#define AVRO_SKIP(reader, len) \ -{ int rval = avro_skip( reader, len); if (rval) return rval; } - -extern const avro_encoding_t avro_binary_encoding; /* in - * encoding_binary - */ -CLOSE_EXTERN -#endif |