controller

Documentation

Index

• type Broker
• type Controller
  • func (c *Controller) Broker(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) ListBrokers(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) ListGroups(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) ListTopics(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) Release()
  • func (c *Controller) Topic(w http.ResponseWriter, r *http.Request)

Types

type Broker

type Broker struct {
	Jmx_port  int    `json:"jmx_port"`
	Timestamp string `json:"timestamp"`
	Host      string `json:"host"`
	Version   int    `json:"version"`
	Port      int    `json:"port"`
}

{"jmx_port":-1,"timestamp":"1446362470753","host":"U","version":1,"port":9092}

type Controller

type Controller struct {
	ara.Controller
	// contains filtered or unexported fields
}

func (*Controller) Broker

func (c *Controller) Broker(w http.ResponseWriter, r *http.Request)

func (*Controller) ListBrokers

func (c *Controller) ListBrokers(w http.ResponseWriter, r *http.Request)

request url: /brokers json from zk looks like: get /brokers/ids/0 {"jmx_port":-1,"timestamp":"1446347718036","host":"U","version":1,"port":9092}

func (*Controller) ListGroups

func (c *Controller) ListGroups(w http.ResponseWriter, r *http.Request)

func (*Controller) ListTopics

func (c *Controller) ListTopics(w http.ResponseWriter, r *http.Request)

func (*Controller) Release

func (c *Controller) Release()

close zookeeper and kafka connection while shutdown

func (*Controller) Topic

func (c *Controller) Topic(w http.ResponseWriter, r *http.Request)