Documentation
¶
Index ¶
Constants ¶
View Source
const QueueHandlerPath = "/api/queue/"
Variables ¶
This section is empty.
Functions ¶
func RemoveStoreMetrics ¶
RemoveStoreMetrics removes all metrics for a deleted store.
func UpdateQueueMetrics ¶ added in v1.9.0
func UpdateQueueMetrics(namespace string, storeName string, transports []v1.QueueTransportStats)
func UpdateScheduledTaskMetrics ¶
UpdateScheduledTaskMetrics sets metrics for the scheduled task CronJob.
func UpdateStoreMetrics ¶
UpdateStoreMetrics sets all gauge values from a Store's status.
Types ¶
type QueueStats ¶ added in v1.9.0
type QueueStats struct {
Client client.Client
Clientset *kubernetes.Clientset
RestConfig *rest.Config
TTL time.Duration
Logger *zap.SugaredLogger
// contains filtered or unexported fields
}
QueueStats serves live queue lengths for the KEDA metrics-api scaler. The counts are fetched from the admin pod on demand and cached for a short TTL, so freshness is driven by the scaler polling instead of the reconcile interval of the store.
func NewQueueStats ¶ added in v1.9.0
func NewQueueStats( c client.Client, clientset *kubernetes.Clientset, restConfig *rest.Config, ttl time.Duration, logger *zap.SugaredLogger, ) *QueueStats
func (*QueueStats) Handler ¶ added in v1.9.0
func (q *QueueStats) Handler() http.Handler
Source Files
Click to show internal directories.
Click to hide internal directories.