handler

Documentation

Index

• func CreateBindingRuleHandler(req *server.Request) (proto.Message, errors.Error)
• func DeleteBindingRuleHandler(req *server.Request) (proto.Message, errors.Error)
• func ListBindingRulesHandler(req *server.Request) (proto.Message, errors.Error)
• func ServiceDownListener(req *server.Request) (proto.Message, errors.Error)
• func ServiceUpListener(req *server.Request) (proto.Message, errors.Error)
• func SubscribeTopicHandler(req *server.Request) (proto.Message, errors.Error)

Functions

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