reactor-c
C Runtime for Lingua Franca
Loading...
Searching...
No Matches
influxdb.h File Reference
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/uio.h>
#include <netdb.h>
#include <stdarg.h>
#include <string.h>
#include <stdio.h>
#include <unistd.h>
#include <curl/curl.h>

Go to the source code of this file.

Data Structures

struct  _influx_client_t
 
struct  _influx_v2_client_t
 

Macros

#define INFLUX_MEAS(m)   IF_TYPE_MEAS, (m)
 
#define INFLUX_TAG(k, v)   IF_TYPE_TAG, (k), (v)
 
#define INFLUX_F_STR(k, v)   IF_TYPE_FIELD_STRING, (k), (v)
 
#define INFLUX_F_FLT(k, v, p)   IF_TYPE_FIELD_FLOAT, (k), (double)(v), (int)(p)
 
#define INFLUX_F_INT(k, v)   IF_TYPE_FIELD_INTEGER, (k), (long long)(v)
 
#define INFLUX_F_BOL(k, v)   IF_TYPE_FIELD_BOOLEAN, (k), ((v) ? 1 : 0)
 
#define INFLUX_TS(ts)   IF_TYPE_TIMESTAMP, (long long)(ts)
 
#define INFLUX_END   IF_TYPE_ARG_END
 
#define IF_TYPE_ARG_END   0
 
#define IF_TYPE_MEAS   1
 
#define IF_TYPE_TAG   2
 
#define IF_TYPE_FIELD_STRING   3
 
#define IF_TYPE_FIELD_FLOAT   4
 
#define IF_TYPE_FIELD_INTEGER   5
 
#define IF_TYPE_FIELD_BOOLEAN   6
 
#define IF_TYPE_TIMESTAMP   7
 
#define _GET_NEXT_CHAR()
 
#define _LOOP_NEXT(statement)   for(;;) { if(!(_GET_NEXT_CHAR())) { ret_code = -8; goto END; } statement }
 
#define _UNTIL(c)   _LOOP_NEXT( if(ch == c) break; )
 
#define _GET_NUMBER(n)   _LOOP_NEXT( if(ch >= '0' && ch <= '9') n = n * 10 + (ch - '0'); else break; )
 
#define _(c)   if((_GET_NEXT_CHAR()) != c) break;
 
#define _APPEND(fmter...)
 

Typedefs

typedef struct _influx_client_t influx_client_t
 
typedef struct _influx_v2_client_t influx_v2_client_t
 

Functions

int format_line (char **buf, int *len, size_t used,...)
 
int post_http (influx_client_t *c,...)
 
int send_udp (influx_client_t *c,...)
 
int post_curl (influx_v2_client_t *c,...)
 
int _escaped_append (char **dest, size_t *len, size_t *used, const char *src, const char *escape_seq)
 
int _begin_line (char **buf)
 
int _format_line (char **buf, va_list ap)
 
int _format_line2 (char **buf, va_list ap, size_t *, size_t)
 
int post_http_send_line (influx_client_t *c, char *buf, int len)
 
int send_udp_line (influx_client_t *c, char *line, int len)
 

Macro Definition Documentation

◆ _

#define _ ( c)    if((_GET_NEXT_CHAR()) != c) break;

◆ _APPEND

#define _APPEND ( fmter...)
Value:
for(;;) {\
if((written = snprintf(*buf + used, len - used, ##fmter)) < 0)\
goto FAIL;\
if(used + written >= len && !(*buf = (char*)realloc(*buf, len *= 2)))\
return -1;\
else {\
break;\
}\
}
return address
Definition hashmap.h:74

◆ _GET_NEXT_CHAR

#define _GET_NEXT_CHAR ( )
Value:
(ch = (len >= (int)iv[0].iov_len && \
(iv[0].iov_len = recv(sock, iv[0].iov_base, iv[0].iov_len, len = 0)) == (size_t)(-1) ? \
0 : *((char*)iv[0].iov_base + len++)))

◆ _GET_NUMBER

#define _GET_NUMBER ( n)    _LOOP_NEXT( if(ch >= '0' && ch <= '9') n = n * 10 + (ch - '0'); else break; )

◆ _LOOP_NEXT

#define _LOOP_NEXT ( statement)    for(;;) { if(!(_GET_NEXT_CHAR())) { ret_code = -8; goto END; } statement }

◆ _UNTIL

#define _UNTIL ( c)    _LOOP_NEXT( if(ch == c) break; )

◆ IF_TYPE_ARG_END

#define IF_TYPE_ARG_END   0

◆ IF_TYPE_FIELD_BOOLEAN

#define IF_TYPE_FIELD_BOOLEAN   6

◆ IF_TYPE_FIELD_FLOAT

#define IF_TYPE_FIELD_FLOAT   4

◆ IF_TYPE_FIELD_INTEGER

#define IF_TYPE_FIELD_INTEGER   5

◆ IF_TYPE_FIELD_STRING

#define IF_TYPE_FIELD_STRING   3

◆ IF_TYPE_MEAS

#define IF_TYPE_MEAS   1

◆ IF_TYPE_TAG

#define IF_TYPE_TAG   2

◆ IF_TYPE_TIMESTAMP

#define IF_TYPE_TIMESTAMP   7

◆ INFLUX_END

#define INFLUX_END   IF_TYPE_ARG_END

◆ INFLUX_F_BOL

#define INFLUX_F_BOL ( k,
v )   IF_TYPE_FIELD_BOOLEAN, (k), ((v) ? 1 : 0)

◆ INFLUX_F_FLT

#define INFLUX_F_FLT ( k,
v,
p )   IF_TYPE_FIELD_FLOAT, (k), (double)(v), (int)(p)

◆ INFLUX_F_INT

#define INFLUX_F_INT ( k,
v )   IF_TYPE_FIELD_INTEGER, (k), (long long)(v)

◆ INFLUX_F_STR

#define INFLUX_F_STR ( k,
v )   IF_TYPE_FIELD_STRING, (k), (v)

◆ INFLUX_MEAS

#define INFLUX_MEAS ( m)    IF_TYPE_MEAS, (m)

◆ INFLUX_TAG

#define INFLUX_TAG ( k,
v )   IF_TYPE_TAG, (k), (v)

◆ INFLUX_TS

#define INFLUX_TS ( ts)    IF_TYPE_TIMESTAMP, (long long)(ts)

Typedef Documentation

◆ influx_client_t

◆ influx_v2_client_t

Function Documentation

◆ _begin_line()

int _begin_line ( char ** buf)

◆ _escaped_append()

int _escaped_append ( char ** dest,
size_t * len,
size_t * used,
const char * src,
const char * escape_seq )

◆ _format_line()

int _format_line ( char ** buf,
va_list ap )

◆ _format_line2()

int _format_line2 ( char ** buf,
va_list ap,
size_t * _len,
size_t used )

◆ format_line()

int format_line ( char ** buf,
int * len,
size_t used,
... )

◆ post_curl()

int post_curl ( influx_v2_client_t * c,
... )

◆ post_http()

int post_http ( influx_client_t * c,
... )

◆ post_http_send_line()

int post_http_send_line ( influx_client_t * c,
char * buf,
int len )

◆ send_udp()

int send_udp ( influx_client_t * c,
... )

◆ send_udp_line()

int send_udp_line ( influx_client_t * c,
char * line,
int len )