kafkaquota

Documentation

Index

• Constants
• type KafkaClient
  • func GetAllClients(nrAPIKey string) []KafkaClient
• type KafkaQuota
  • func GenerateQuotasForClients(clients []KafkaClient, throughputMultiplier int) []KafkaQuota

Constants

const QuotaLimit = 62914560

const QuotasTemplate = `{{ range . }}
  - clientId: {{ .ClientID }}
    perBrokerProducerByteRate: {{ .Quota }} # {{ .HumanReadableQuota }}
{{ end }}`

Types

type KafkaClient

type KafkaClient struct {
	ID                string `json:"clientId"`
	AverageThroughput float64
	MaxThroughput     int
}

func GetAllClients

func GetAllClients(nrAPIKey string) []KafkaClient

type KafkaQuota

type KafkaQuota struct {
	ClientID           string `json:"clientId"`
	Quota              int    `json:"perBrokerProducerByteRate"`
	HumanReadableQuota string
}

func GenerateQuotasForClients

func GenerateQuotasForClients(clients []KafkaClient, throughputMultiplier int) []KafkaQuota