MQTTClientPersistence.h

Go to the documentation of this file.

/*******************************************************************************
 * Copyright (c) 2009, 2020 IBM Corp.
 *
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v2.0
 * and Eclipse Distribution License v1.0 which accompany this distribution. 
 *
 * The Eclipse Public License is available at 
 *    https://www.eclipse.org/legal/epl-2.0/
 * and the Eclipse Distribution License is available at 
 *   http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *    Ian Craggs - initial API and implementation and/or initial documentation
 *******************************************************************************/
 
/*
*/
#if !defined(MQTTCLIENTPERSISTENCE_H)
#define MQTTCLIENTPERSISTENCE_H
/*
*/
 
#define MQTTCLIENT_PERSISTENCE_DEFAULT 0
#define MQTTCLIENT_PERSISTENCE_NONE 1
#define MQTTCLIENT_PERSISTENCE_USER 2
 
#define MQTTCLIENT_PERSISTENCE_ERROR -2
 
typedef int (*Persistence_open)(void** handle, const char* clientID, const char* serverURI, void* context);
 
typedef int (*Persistence_close)(void* handle); 
 
typedef int (*Persistence_put)(void* handle, char* key, int bufcount, char* buffers[], int buflens[]);
 
typedef int (*Persistence_get)(void* handle, char* key, char** buffer, int* buflen);
 
typedef int (*Persistence_remove)(void* handle, char* key);
 
typedef int (*Persistence_keys)(void* handle, char*** keys, int* nkeys);
 
typedef int (*Persistence_clear)(void* handle);
 
typedef int (*Persistence_containskey)(void* handle, char* key);
 
typedef struct {
        void* context;
        Persistence_open popen;
        Persistence_close pclose;
        Persistence_put pput;
        Persistence_get pget;
        Persistence_remove premove;
        Persistence_keys pkeys;
        Persistence_clear pclear;
        Persistence_containskey pcontainskey;
} MQTTClient_persistence;
 
 
typedef int MQTTPersistence_beforeWrite(void* context, int bufcount, char* buffers[], int buflens[]);
 
 
typedef int MQTTPersistence_afterRead(void* context, char** buffer, int* buflen);
 
#endif