Versions in this module Expand all Collapse all v0 v0.0.5 Mar 24, 2021 Changes in this version + const DefaultUsageByteLimit + const SamplingIntervalInSeconds + type TenantsUsage struct + func NewTenantsUsage(url, pulsarToken, clusterName string, tenantByteOutLimit uint64) *TenantsUsage + func (t *TenantsUsage) PromGauge(gaugeType, tenant string, num uint64) + func (t *TenantsUsage) ReportHighUsageTenant() (errStr string) + func (t *TenantsUsage) UpdateUsages() + type Usage struct + MsgInBacklog uint64 + Name string + TotalBytesIn uint64 + TotalBytesOut uint64 + TotalMessagesIn uint64 + TotalMessagesOut uint64 + UpdatedAt time.Time + type Usages []Usage
Go to main page