table_view.h

 
#pragma once
 
#include <pulsar/defines.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include <pulsar/c/message.h>
#include <pulsar/c/messages.h>
#include <pulsar/c/result.h>
#include <stdint.h>
 
typedef struct _pulsar_table_view pulsar_table_view_t;
 
typedef void (*pulsar_table_view_action)(const char *key, const void *value, size_t value_size, void *ctx);
typedef void (*pulsar_result_callback)(pulsar_result, void *);
 
PULSAR_PUBLIC bool pulsar_table_view_retrieve_value(pulsar_table_view_t *table_view, const char *key,
                                                    void **value, size_t *value_size);
 
PULSAR_PUBLIC bool pulsar_table_view_get_value(pulsar_table_view_t *table_view, const char *key, void **value,
                                               size_t *value_size);
 
PULSAR_PUBLIC bool pulsar_table_view_contain_key(pulsar_table_view_t *table_view, const char *key);
 
PULSAR_PUBLIC int pulsar_table_view_size(pulsar_table_view_t *table_view);
 
PULSAR_PUBLIC void pulsar_table_view_for_each(pulsar_table_view_t *table_view,
                                              pulsar_table_view_action action, void *ctx);
 
PULSAR_PUBLIC void pulsar_table_view_for_each_add_listen(pulsar_table_view_t *table_view,
                                                         pulsar_table_view_action action, void *ctx);
 
PULSAR_PUBLIC void pulsar_table_view_free(pulsar_table_view_t *table_view);
 
PULSAR_PUBLIC pulsar_result pulsar_table_view_close(pulsar_table_view_t *table_view);
 
PULSAR_PUBLIC void pulsar_table_view_close_async(pulsar_table_view_t *table_view,
                                                 pulsar_result_callback callback, void *ctx);
 
#ifdef __cplusplus
}
#endif