cpid::RedisStore Class Reference

c10d::Store for rendez-vous backed by Redis. More...

#include <redisstore.h>

Inherits c10d::Store.

Public Member Functions
	RedisStore (std::string prefix, std::string_view host, int port)
virtual	~RedisStore ()
void	set (std::string const &key, std::vector< uint8_t > const &value) override
std::vector< uint8_t >	get (std::string const &key) override
int64_t	add (std::string const &key, int64_t value) override
bool	check (std::vector< std::string > const &keys) override
void	wait (std::vector< std::string > const &keys) override
void	wait (std::vector< std::string > const &keys, std::chrono::milliseconds const &timeout) override
Public Member Functions inherited from c10d::Store
virtual	~Store ()=default
void	setTimeout (const std::chrono::seconds &)

Detailed Description

c10d::Store for rendez-vous backed by Redis.

This is pretty much a copy of gloo's RedisStore: https://github.com/facebookincubator/gloo/blob/master/gloo/rendezvous/redis_store.cc

Constructor & Destructor Documentation

cpid::RedisStore::RedisStore	(	std::string	prefix,
		std::string_view	host,
		int	port
	)

cpid::RedisStore::~RedisStore ( )

virtual

Member Function Documentation

int64_t cpid::RedisStore::add ( std::string const &  key, int64_t  value  )

overridevirtual

Implements c10d::Store.

bool cpid::RedisStore::check ( std::vector< std::string > const &  keys )

overridevirtual

Implements c10d::Store.

std::vector< uint8_t > cpid::RedisStore::get ( std::string const &  key )

overridevirtual

Implements c10d::Store.

void cpid::RedisStore::set ( std::string const &  key, std::vector< uint8_t > const &  value  )

overridevirtual

Implements c10d::Store.

void cpid::RedisStore::wait ( std::vector< std::string > const &  keys )

overridevirtual

Implements c10d::Store.

void cpid::RedisStore::wait ( std::vector< std::string > const &  keys, std::chrono::milliseconds const &  timeout  )

overridevirtual

Implements c10d::Store.

---

The documentation for this class was generated from the following files:

• cpid/redisstore.h
• cpid/redisstore.cpp