handler

func CreateBindingRuleHandler ¶

func CreateBindingRuleHandler(req *server.Request) (proto.Message, errors.Error)

func DeleteBindingRuleHandler ¶

func DeleteBindingRuleHandler(req *server.Request) (proto.Message, errors.Error)

func ListBindingRulesHandler ¶

func ListBindingRulesHandler(req *server.Request) (proto.Message, errors.Error)

func ServiceDownListener ¶

func ServiceDownListener(req *server.Request) (proto.Message, errors.Error)

Remove bindings on - This cluster, h2o -> instance id - All other clusters/brokers to this broker. Only needed if we have no more instances of that service in this AZ

func ServiceUpListener ¶

func ServiceUpListener(req *server.Request) (proto.Message, errors.Error)

Create bindings on - This broker from h2o -> queue - All other clusters/brokers to this broker

func SubscribeTopicHandler ¶

func SubscribeTopicHandler(req *server.Request) (proto.Message, errors.Error)

Subscribe a queue to a topic Just need to create a binding with routing key set as the topic