Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SystemTargets (2.36 sec)

  1. cmd/metrics-v3-logger-webhook.go

    // loadLoggerWebhookMetrics - `MetricsLoaderFn` for logger webhook
    // such as failed messages and total messages.
    func loadLoggerWebhookMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	tgts := append(logger.SystemTargets(), logger.AuditTargets()...)
    	for _, t := range tgts {
    		labels := []string{nameL, t.String(), endpointL, t.Endpoint()}
    		m.Set(webhookFailedMessages, float64(t.Stats().FailedMessages), labels...)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 14 07:27:33 UTC 2024
    - 2K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    // fetchLoggerInfo return log info
    func fetchLoggerInfo(ctx context.Context) ([]madmin.Logger, []madmin.Audit) {
    	var loggerInfo []madmin.Logger
    	var auditloggerInfo []madmin.Audit
    	for _, tgt := range logger.SystemTargets() {
    		if tgt.Endpoint() != "" {
    			loggerInfo = append(loggerInfo, madmin.Logger{tgt.String(): targetStatus(ctx, tgt)})
    		}
    	}
    
    	for _, tgt := range logger.AuditTargets() {
    		if tgt.Endpoint() != "" {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    }
    
    func getWebhookMetrics() *MetricsGroupV2 {
    	mg := &MetricsGroupV2{
    		cacheInterval: 10 * time.Second,
    	}
    	mg.RegisterRead(func(ctx context.Context) []MetricV2 {
    		tgts := append(logger.SystemTargets(), logger.AuditTargets()...)
    		metrics := make([]MetricV2, 0, len(tgts)*4)
    		for _, t := range tgts {
    			isOnline := 0
    			if t.IsOnline(ctx) {
    				isOnline = 1
    			}
    			labels := map[string]string{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
Back to top