Class faabric::state::StateKeyValue

class StateKeyValue

Subclassed by faabric::state::InMemoryStateKeyValue, faabric::state::RedisStateKeyValue

Public Functions

StateKeyValue(const std::string &userIn, const std::string &keyIn, size_t sizeIn)

StateKeyValue(const std::string &userIn, const std::string &keyIn)

void get(uint8_t *buffer)

uint8_t *get()

void getChunk(long offset, uint8_t *buffer, size_t length)

uint8_t *getChunk(long offset, long len)

std::vector<StateChunk> getAllChunks()

void set(const uint8_t *buffer)

void setChunk(long offset, const uint8_t *buffer, size_t length)

void append(const uint8_t *buffer, size_t length)

void getAppended(uint8_t *buffer, size_t length, long nValues)

void clearAppended()

void mapSharedMemory(void *destination, long pagesOffset, long nPages)

void unmapSharedMemory(void *mappedAddr)

void pull()

void pushPartial()

void pushPartialMask(const std::shared_ptr<StateKeyValue> &maskKv)

void lockRead()

void unlockRead()

void lockWrite()

void unlockWrite()

void flagDirty()

void flagChunkDirty(long offset, long len)

size_t size() const

size_t getSharedMemorySize() const

void pushFull()

Public Members

const std::string user

const std::string key

Public Static Functions

static uint32_t waitOnRedisRemoteLock(const std::string &redisKey)