The cinder.openstack.common.rpc.matchmaker_redis Module

The MatchMaker classes should accept a Topic or Fanout exchange key and return keys for direct exchanges, per (approximate) AMQP parlance.

class MatchMakerRedis

Bases: cinder.openstack.common.rpc.matchmaker.HeartbeatMatchMakerBase

MatchMaker registering and looking-up hosts with a Redis server.

ack_alive(key, host)

backend_register(key, key_host)

backend_unregister(key, key_host)

expire(topic, host)

is_alive(topic, host)

class RedisExchange(matchmaker)

Bases: cinder.openstack.common.rpc.matchmaker.Exchange

class RedisFanoutExchange(matchmaker)

Bases: cinder.openstack.common.rpc.matchmaker_redis.RedisExchange

Return a list of all hosts.

run(topic)

class RedisTopicExchange(matchmaker)

Bases: cinder.openstack.common.rpc.matchmaker_redis.RedisExchange

Exchange where all topic keys are split, sending to second half. i.e. “compute.host” sends a message to “compute” running on “host”

run(topic)