MODULE_big = multimaster

OBJS = multimaster.o raftable.o arbiter.o bytebuf.o bgwpool.o pglogical_output.o pglogical_proto.o pglogical_receiver.o pglogical_apply.o pglogical_hooks.o pglogical_config.o ddd.o bkb.o

OBJS = multimaster.o arbiter.o bytebuf.o bgwpool.o pglogical_output.o pglogical_proto.o pglogical_receiver.o pglogical_apply.o pglogical_hooks.o pglogical_config.o ddd.o bkb.o

overrideCPPFLAGS += -I../raftable

EXTRA_INSTALL = contrib/raftable contrib/mmts

EXTENSION = multimaster

DATA = multimaster--1.0.sql

typedefstruct {

}

returnhasDeadlock;

}

void*RaftableGet(charconst*key,int*size,RaftableTimestamp*ts,boolnowait)

{

size_ts;

char*value;

if (!MtmUseRaftable)returnNULL;

Assert(ts==NULL);/* not implemented */

value=raftable_get(key,&s);

*size=s;

returnvalue;

}

voidRaftableSet(charconst*key,voidconst*value,intsize,boolnowait)

{

if (!MtmUseRaftable)return;

raftable_set(key,value,size,nowait ?0 :-1);

}

boolRaftableCAS(charconst*key,charconst*value,boolnowait)

{

if (!MtmUseRaftable)return false;

Assert(false);/* not implemented */

return false;

}

typedefstructRaftableTimestamp {

time_ttime;/* local time at master */

);

C API:

/* Gets value by key. Returns the value or NULL if not found. */

char *raftable_get(char *key);

char *raftable_get(constchar *key, size_t *vallen);

/*

* Adds/updates value by key. Returns when the value gets replicated on

* current machine. Storing NULL will delete the item from the table.

* Adds/updates value by key. Returns when the value gets replicated.

* Storing NULL will delete the item from the table. Gives up after

* 'timeout_ms' milliseconds.

*/

void raftable_set(char *key, char *value);

void raftable_set(constchar *key,constchar *value, size_t len, int timeout_ms);

/*

* Iterates over all items in the table, calling func(key, value, arg)

* for each of them.

*/

void raftable_every(void (*func)(char *, char *, void *), void *arg);

void raftable_every(void (*func)(constchar *,constchar *, size_t, void *), void *arg);

SQL API:

-- set

raftable(key varchar(64), value text,tries int);

raftable(key varchar(64), value text,timeout_ms int);

-- get

raftable(key varchar(64)) returns text;

LANGUAGE C;

CREATEFUNCTIONraftable(keyvarchar(64), valuetext,triesint)

CREATEFUNCTIONraftable(keyvarchar(64), valuetext,timeout_msint)

RETURNS void

AS'MODULE_PATHNAME','raftable_sql_set'

LANGUAGE C;