kafka.h File Reference

#include <common/xroad_xml.h>
#include <stdint.h>
#include <string.h>

Include dependency graph for kafka.h:

Go to the source code of this file.

Classes
struct	kafka_callback_t

Typedefs
typedef struct kafka_s	kafka_t

Functions
kafka_t *	kafka_create (xroad_xml_tag_t cfg, kafka_callback_t cback)
void	kafka_destroy (kafka_t *k)
xroad_errno_t	kafka_start (kafka_t *k)
xroad_errno_t	kafka_stop (kafka_t *k)
xroad_errno_t	kafka_send (kafka_t *k, xroad_str_t topic, void *data, size_t len)

Detailed Description

Author

Dmitry S. Melnikov, dmitr.nosp@m.yme@.nosp@m.quant.nosp@m.box..nosp@m.ru

Function Documentation

kafka_create()

kafka_t* kafka_create	(	xroad_xml_tag_t	cfg,
		kafka_callback_t	cback
	)

create new kafka instance

Parameters

[in]	cfg	- xml config
[in]	cback	- kafka callback (see kafka_callback_t for details)

Returns

kafka instance, NULL - failed

kafka_destroy()

void kafka_destroy

(

kafka_t *

k

)

destroy kafka instance

Parameters

[in]

k

- kafka instance to destroy

kafka_send()

xroad_errno_t kafka_send	(	kafka_t *	k,
		xroad_str_t	topic,
		void *	data,
		size_t	len
	)

send message to AMQP broker

Parameters

[in]	k	- kafka instance
[in]	topic	- topic
[in]	data	- data to send
[in]	len	- data length

Returns

XROAD_OK - data has been sent, else sending failed

kafka_start()

xroad_errno_t kafka_start

(

kafka_t *

k

)

start kafka - establish connection with AMQP broker

Parameters

[in]

k

- kafka instance

Returns

XROAD_OK - connection established, XROAD_FAILED - shit happened

kafka_stop()

xroad_errno_t kafka_stop

(

kafka_t *

k

)

close kafka connection to AMQP broker

Parameters

[in]

k

- kafka instance to stop