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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Source Files
Click to show internal directories.
Click to hide internal directories.