Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for SystemTargets (0.09 sec)

  1. internal/logger/targets.go

    	tl.list = tgts
    }
    
    var (
    
    	// systemTargets is the set of enabled loggers.
    	systemTargets = newTargetsList()
    
    	// auditTargets is the list of enabled audit loggers
    	auditTargets = newTargetsList()
    
    	// This is always set represent /dev/console target
    	consoleTgt Target
    )
    
    // SystemTargets returns active targets.
    // Returned slice may not be modified in any way.
    func SystemTargets() []Target {
    	return systemTargets.get()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. internal/logger/logger.go

    		return
    	}
    	if err == nil {
    		return
    	}
    	entry := errToEntry(ctx, subsystem, err, errKind...)
    	sendLog(ctx, entry)
    }
    
    func sendLog(ctx context.Context, entry log.Entry) {
    	systemTgts := SystemTargets()
    	if len(systemTgts) == 0 {
    		return
    	}
    
    	// Iterate over all logger targets to send the log entry
    	for _, t := range systemTgts {
    		if err := t.Send(ctx, entry); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top