producer.h

 
#pragma once
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include <pulsar/c/message.h>
#include <pulsar/c/result.h>
#include <pulsar/defines.h>
#include <stdint.h>
 
typedef struct _pulsar_producer pulsar_producer_t;
 
typedef void (*pulsar_send_callback)(pulsar_result, pulsar_message_id_t *msgId, void *ctx);
typedef void (*pulsar_close_callback)(pulsar_result, void *ctx);
typedef void (*pulsar_flush_callback)(pulsar_result, void *ctx);
 
PULSAR_PUBLIC const char *pulsar_producer_get_topic(pulsar_producer_t *producer);
 
PULSAR_PUBLIC const char *pulsar_producer_get_producer_name(pulsar_producer_t *producer);
 
PULSAR_PUBLIC pulsar_result pulsar_producer_send(pulsar_producer_t *producer, pulsar_message_t *msg);
 
PULSAR_PUBLIC void pulsar_producer_send_async(pulsar_producer_t *producer, pulsar_message_t *msg,
                                              pulsar_send_callback callback, void *ctx);
 
PULSAR_PUBLIC int64_t pulsar_producer_get_last_sequence_id(pulsar_producer_t *producer);
 
PULSAR_PUBLIC pulsar_result pulsar_producer_close(pulsar_producer_t *producer);
 
PULSAR_PUBLIC void pulsar_producer_close_async(pulsar_producer_t *producer, pulsar_close_callback callback,
                                               void *ctx);
 
// Flush all the messages buffered in the client and wait until all messages have been successfully persisted.
PULSAR_PUBLIC pulsar_result pulsar_producer_flush(pulsar_producer_t *producer);
 
PULSAR_PUBLIC void pulsar_producer_flush_async(pulsar_producer_t *producer, pulsar_flush_callback callback,
                                               void *ctx);
 
PULSAR_PUBLIC void pulsar_producer_free(pulsar_producer_t *producer);
 
PULSAR_PUBLIC int pulsar_producer_is_connected(pulsar_producer_t *producer);
 
#ifdef __cplusplus
}
#endif