handler

package
v0.0.0-...-9b813e6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 14, 2016 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL