api

Documentation

Index

• func Acl(w http.ResponseWriter, r *http.Request)
• func Acls(w http.ResponseWriter, r *http.Request)
• func Broker(w http.ResponseWriter, r *http.Request)
• func Brokers(w http.ResponseWriter, r *http.Request)
• func CreateAcl(w http.ResponseWriter, r *http.Request)
• func CreateTopic(w http.ResponseWriter, r *http.Request)
• func CreateUser(w http.ResponseWriter, r *http.Request)
• func DeleteAcl(w http.ResponseWriter, r *http.Request)
• func DeleteTopic(w http.ResponseWriter, r *http.Request)
• func DeleteUser(w http.ResponseWriter, r *http.Request)
• func GetKafkaConfig(w http.ResponseWriter, r *http.Request)
• func GetKafkaConfigBroker(w http.ResponseWriter, r *http.Request)
• func KafkaMetrics(w http.ResponseWriter, r *http.Request)
• func ListConsumerGroups(w http.ResponseWriter, r *http.Request)
• func Notifications(w http.ResponseWriter, r *http.Request)
• func Overview(w http.ResponseWriter, r *http.Request)
• func Page(pageSize, p int, items pageable) page
• func Partitions(w http.ResponseWriter, r *http.Request)
• func Router() *goji.Mux
• func SSEHeaders(rw http.ResponseWriter)
• func SetupSSE(retry int, rw http.ResponseWriter)
• func Topic(w http.ResponseWriter, r *http.Request)
• func TopicBrowser(rw http.ResponseWriter, r *http.Request)
• func Topics(w http.ResponseWriter, r *http.Request)
• func UpdateKafkaConfig(w http.ResponseWriter, r *http.Request)
• func UpdateKafkaConfigAll(w http.ResponseWriter, r *http.Request)
• func UpdateTopic(w http.ResponseWriter, r *http.Request)
• func User(w http.ResponseWriter, r *http.Request)
• func Users(w http.ResponseWriter, r *http.Request)
• func Version(w http.ResponseWriter, r *http.Request)
• func ViewConsumerGroup(w http.ResponseWriter, r *http.Request)
• func WhoAmI(w http.ResponseWriter, r *http.Request)
• func ZookeeperMetrics(w http.ResponseWriter, r *http.Request)
• type MessageData
• type TopicModel
  • func (topic TopicModel) Validate() []string

Functions

func Acl

func Acl(w http.ResponseWriter, r *http.Request)

func Acls

func Acls(w http.ResponseWriter, r *http.Request)

func Broker

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

func Brokers

func Brokers(w http.ResponseWriter, r *http.Request)

func CreateAcl

func CreateAcl(w http.ResponseWriter, r *http.Request)

func CreateTopic

func CreateTopic(w http.ResponseWriter, r *http.Request)

func CreateUser

func CreateUser(w http.ResponseWriter, r *http.Request)

func DeleteAcl

func DeleteAcl(w http.ResponseWriter, r *http.Request)

func DeleteTopic

func DeleteTopic(w http.ResponseWriter, r *http.Request)

func DeleteUser

func DeleteUser(w http.ResponseWriter, r *http.Request)

func GetKafkaConfig

func GetKafkaConfig(w http.ResponseWriter, r *http.Request)

func GetKafkaConfigBroker

func GetKafkaConfigBroker(w http.ResponseWriter, r *http.Request)

Get kafka config for a specific broker

func KafkaMetrics

func KafkaMetrics(w http.ResponseWriter, r *http.Request)

func ListConsumerGroups

func ListConsumerGroups(w http.ResponseWriter, r *http.Request)

func Notifications

func Notifications(w http.ResponseWriter, r *http.Request)

func Overview

func Overview(w http.ResponseWriter, r *http.Request)

func Page

func Page(pageSize, p int, items pageable) page

func Partitions

func Partitions(w http.ResponseWriter, r *http.Request)

func Router

func Router() *goji.Mux

func SSEHeaders

func SSEHeaders(rw http.ResponseWriter)

func SetupSSE

func SetupSSE(retry int, rw http.ResponseWriter)

func Topic

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

func TopicBrowser

func TopicBrowser(rw http.ResponseWriter, r *http.Request)

func Topics

func Topics(w http.ResponseWriter, r *http.Request)

func UpdateKafkaConfig

func UpdateKafkaConfig(w http.ResponseWriter, r *http.Request)

Update kafka config on one broker

func UpdateKafkaConfigAll

func UpdateKafkaConfigAll(w http.ResponseWriter, r *http.Request)

Update kafka config on all brokers, rolling

func UpdateTopic

func UpdateTopic(w http.ResponseWriter, r *http.Request)

func User

func User(w http.ResponseWriter, r *http.Request)

func Users

func Users(w http.ResponseWriter, r *http.Request)

func Version

func Version(w http.ResponseWriter, r *http.Request)

func ViewConsumerGroup

func ViewConsumerGroup(w http.ResponseWriter, r *http.Request)

func WhoAmI

func WhoAmI(w http.ResponseWriter, r *http.Request)

func ZookeeperMetrics

func ZookeeperMetrics(w http.ResponseWriter, r *http.Request)

Types

type MessageData

type MessageData struct {
	Message   string `json:"message"`
	Key       string `json:"key"`
	Topic     string `json:"topic"`
	Partition int32  `json:"partition"`
	Offset    string `json:"offset"`
}

type TopicModel

type TopicModel struct {
	Name              string                 `json:"name"`
	PartitionCount    int                    `json:"partition_count"`
	ReplicationFactor int                    `json:"replication_factor"`
	Config            map[string]interface{} `json:"config"`
}

func (TopicModel) Validate

func (topic TopicModel) Validate() []string