message_id.h

 
#pragma once
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include <pulsar/defines.h>
#include <stddef.h>
#include <stdint.h>
 
typedef struct _pulsar_message_id pulsar_message_id_t;
 
PULSAR_PUBLIC const pulsar_message_id_t *pulsar_message_id_earliest();
 
PULSAR_PUBLIC const pulsar_message_id_t *pulsar_message_id_latest();
 
PULSAR_PUBLIC void *pulsar_message_id_serialize(pulsar_message_id_t *messageId, int *len);
 
PULSAR_PUBLIC pulsar_message_id_t *pulsar_message_id_deserialize(const void *buffer, uint32_t len);
 
PULSAR_PUBLIC char *pulsar_message_id_str(pulsar_message_id_t *messageId);
 
PULSAR_PUBLIC void pulsar_message_id_free(pulsar_message_id_t *messageId);
 
#ifdef __cplusplus
}
#endif