Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for logger (0.2 sec)

  1. internal/logger/logger.go

    	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 {
    			if consoleTgt != nil { // Sending to the console never fails
    				entry.Trace.Message = fmt.Sprintf("event(%#v) was not sent to Logger target (%#v): %#v", entry, t, err)
    				consoleTgt.Send(ctx, entry)
    			}
    		}
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  2. cmd/common-main.go

    		err = mergeDisksLayoutFromArgs(serverCmdArgs(ctx), ctxt)
    	}
    
    	return err
    }
    
    func handleCommonArgs(ctxt serverCtxt) {
    	if ctxt.JSON {
    		logger.EnableJSON()
    	}
    	if ctxt.Quiet {
    		logger.EnableQuiet()
    	}
    	if ctxt.Anonymous {
    		logger.EnableAnonymous()
    	}
    
    	consoleAddr := ctxt.ConsoleAddr
    	addr := ctxt.Addr
    	configDir := ctxt.ConfigDir
    	configSet := ctxt.configDirSet
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  3. cmd/config-current.go

    		config.RegionSubSys:         config.DefaultRegionKVS,
    		config.APISubSys:            api.DefaultKVS,
    		config.LoggerWebhookSubSys:  logger.DefaultLoggerWebhookKVS,
    		config.AuditWebhookSubSys:   logger.DefaultAuditWebhookKVS,
    		config.AuditKafkaSubSys:     logger.DefaultAuditKafkaKVS,
    		config.ScannerSubSys:        scanner.DefaultKVS,
    		config.SubnetSubSys:         subnet.DefaultKVS,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  4. internal/logger/logrotate.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package logger
    
    import (
    	"encoding/json"
    	"fmt"
    	"io"
    	"os"
    	"path/filepath"
    	"time"
    
    	"github.com/klauspost/compress/gzip"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/pkg/v2/logger/message/log"
    )
    
    func defaultFilenameFunc() string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 11:38:40 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  5. cmd/object-handlers.go

    	}
    
    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    	// Tags XML will not be bigger than 1MiB in size, fail if its bigger.
    	tags, err := tags.ParseObjectXML(io.LimitReader(r.Body, 1<<20))
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  6. cmd/format-erasure.go

    					host = "local"
    				}
    				once.Do(func() {
    					if len(hostCount) == 1 {
    						return
    					}
    					logger.Info(" * Set %v:", i+1)
    					for j := 0; j < setDriveCount; j++ {
    						disk := storageDisks[i*setDriveCount+j]
    						logger.Info("   - Drive: %s", disk.String())
    					}
    				})
    				logger.Info(color.Yellow("WARNING:")+" Host %v has more than %v drives of set. "+
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    			})
    
    			healthy := erasureSetUpCount[poolIdx][setIdx].online >= poolWriteQuorums[poolIdx]
    			if !healthy {
    				storageLogIf(logger.SetReqInfo(ctx, reqInfo),
    					fmt.Errorf("Write quorum may be lost on pool: %d, set: %d, expected write quorum: %d",
    						poolIdx, setIdx, poolWriteQuorums[poolIdx]), logger.FatalKind)
    			}
    			result.Healthy = result.Healthy && healthy
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    	globalIsDistErasure = false
    
    	// Disable printing console messages during tests.
    	color.Output = io.Discard
    	// Disable Error logging in testing.
    	logger.DisableErrorLog = true
    
    	// Uncomment the following line to see trace logs during unit tests.
    	// logger.AddTarget(console.New())
    
    	// Set system resources to maximum.
    	setMaxResources(nil)
    
    	// Initialize globalConsoleSys system
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  9. cmd/server-main.go

    	if err != nil {
    		return nil, err
    	}
    	lgSize := ctx.Int("log-size")
    	output, err := logger.NewDir(logger.Options{
    		Directory:       lgDirAbs,
    		MaximumFileSize: int64(lgSize),
    		Compress:        ctx.Bool("log-compress"),
    	})
    	if err != nil {
    		return nil, err
    	}
    	logger.EnableJSON()
    	return output, nil
    }
    
    // serverMain handler called for 'minio server' command.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  10. cmd/erasure-object.go

    	"github.com/minio/minio/internal/grid"
    	"github.com/minio/minio/internal/hash"
    	xhttp "github.com/minio/minio/internal/http"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v2/mimedb"
    	"github.com/minio/pkg/v2/sync/errgroup"
    )
    
    // list all errors which can be ignored in object operations.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
Back to top