smax-private.h

/**
 * \file
 *
 * \date Jun 25, 2019
 * \author Attila Kovacs
 *
 * \brief
 *      A set of private SMA-X routines used by the API library but should not be exposed outside.
 *
 */


#ifndef SMAX_PRIVATE_H_
#define SMAX_PRIVATE_H_

#define __XCHANGE_INTERNAL_API__        ///< User internal definitions
#include <smax.h>


#define RELEASEID       "<release>"     ///< Redis PUB/SUB channel prefix for wait release notifications.

/// \cond PROTECTED

typedef struct PullRequest {
  char *group;
  char *key;
  void *value;      ///< Pointer to storage (such as double*), or pointer to pointers (char**) for X_STRING
  XType type;
  int count;
  XMeta *meta;
  struct PullRequest *next;
} PullRequest;


int smaxLockConfig();
int smaxUnlockConfig();
int smaxLockNotify();
int smaxUnlockNotify();

int smaxConfigTLSAsync(Redis *redis);
long smaxGetHash(const char *buf, int size);

int smaxRead(PullRequest *req, int channel);
int smaxWrite(const char *group, const XField *f);
void smaxDestroyPullRequest(PullRequest *p);
int smaxProcessReadResponse(RESP *reply, PullRequest *req);
void smaxProcessPipedWritesAsync(RESP *reply);
unsigned char smaxGetHashLookupIndex(const char *group, int lGroup, const char *key, int lKey);
char *smaxGetUpdateChannelPattern(const char *table, const char *key);
int smaxStorePush(const char *table, const XField *field);
void smaxSocketErrorHandler(Redis *r, enum redisx_channel channel, const char *op);
int smaxScriptError(const char *name, int status);
int smaxScriptErrorAsync(const char *name, int status);
boolean smaxIsDisabled();

/// \endcond

#endif /* SMAX_PRIVATE_H_ */