api

package

v0.0.0-...-6603b5a Latest Latest Go to latest Published: Jan 18, 2023 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cloudkarafka/cloudkarafka-manager

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

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