jmessage.h

Go to the documentation of this file.

/*
 * JULEA - Flexible storage framework
 * Copyright (C) 2010-2024 Michael Kuhn
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
#ifndef JULEA_MESSAGE_H
#define JULEA_MESSAGE_H
 
#if !defined(JULEA_H) && !defined(JULEA_COMPILATION)
#error "Only <julea.h> can be included directly."
#endif
 
#include <glib.h>
#include <gio/gio.h>
 
G_BEGIN_DECLS
 
enum JMessageType
{
    J_MESSAGE_NONE,
    J_MESSAGE_PING,
    J_MESSAGE_STATISTICS,
    J_MESSAGE_OBJECT_CREATE,
    J_MESSAGE_OBJECT_DELETE,
    J_MESSAGE_OBJECT_GET_ALL,
    J_MESSAGE_OBJECT_GET_BY_PREFIX,
    J_MESSAGE_OBJECT_READ,
    J_MESSAGE_OBJECT_STATUS,
    J_MESSAGE_OBJECT_SYNC,
    J_MESSAGE_OBJECT_WRITE,
    J_MESSAGE_KV_PUT,
    J_MESSAGE_KV_DELETE,
    J_MESSAGE_KV_GET,
    J_MESSAGE_KV_GET_ALL,
    J_MESSAGE_KV_GET_BY_PREFIX,
    J_MESSAGE_DB_SCHEMA_CREATE,
    J_MESSAGE_DB_SCHEMA_GET,
    J_MESSAGE_DB_SCHEMA_DELETE,
    J_MESSAGE_DB_INSERT,
    J_MESSAGE_DB_UPDATE,
    J_MESSAGE_DB_DELETE,
    J_MESSAGE_DB_QUERY
};
 
typedef enum JMessageType JMessageType;
 
struct JMessage;
 
typedef struct JMessage JMessage;
 
G_END_DECLS
 
#include <core/jsemantics.h>
 
G_BEGIN_DECLS
 
JMessage* j_message_new(JMessageType op_type, gsize length);
 
JMessage* j_message_new_reply(JMessage* message);
 
JMessage* j_message_ref(JMessage* message);
 
void j_message_unref(JMessage* message);
 
G_DEFINE_AUTOPTR_CLEANUP_FUNC(JMessage, j_message_unref)
 
 
JMessageType j_message_get_type(JMessage const* message);
 
guint32 j_message_get_count(JMessage const* message);
 
gboolean j_message_append_1(JMessage* message, gconstpointer data);
 
gboolean j_message_append_4(JMessage* message, gconstpointer data);
 
gboolean j_message_append_8(JMessage* message, gconstpointer data);
 
gboolean j_message_append_n(JMessage* message, gconstpointer data, gsize length);
 
gboolean j_message_append_string(JMessage* message, gchar const* str);
 
gchar j_message_get_1(JMessage* message);
 
gint32 j_message_get_4(JMessage* message);
 
gint64 j_message_get_8(JMessage* message);
 
gpointer j_message_get_n(JMessage* message, gsize length);
 
gchar const* j_message_get_string(JMessage* message);
 
gboolean j_message_send(JMessage* message, gpointer stream);
 
gboolean j_message_receive(JMessage* message, gpointer stream);
 
gboolean j_message_read(JMessage* message, GInputStream* stream);
 
gboolean j_message_write(JMessage* message, GOutputStream* stream);
 
void j_message_add_send(JMessage* message, gconstpointer data, guint64 length);
 
void j_message_add_operation(JMessage* message, gsize length);
 
void j_message_set_semantics(JMessage* message, JSemantics* semantics);
 
JSemantics* j_message_get_semantics(JMessage* message);
 
G_END_DECLS
 
#endif