Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 96 for Logger (0.59 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/sftp-server.go

    		SSHHandshakeDeadline: 2 * time.Minute,
    		Logger:               new(sftpLogger),
    		SSHConfig:            sshConfig,
    		HandleSFTPSession:    handleSFTPSession,
    	})
    	if err != nil {
    		logger.Fatal(err, "Unable to start SFTP Server")
    	}
    
    	err = sftpServer.Listen()
    	if err != nil {
    		logger.Fatal(err, "SFTP Server had an unrecoverable error while accepting connections")
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  3. 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)
  4. internal/logger/config.go

    	EnvLoggerWebhookEnable     = "MINIO_LOGGER_WEBHOOK_ENABLE"
    	EnvLoggerWebhookEndpoint   = "MINIO_LOGGER_WEBHOOK_ENDPOINT"
    	EnvLoggerWebhookAuthToken  = "MINIO_LOGGER_WEBHOOK_AUTH_TOKEN"
    	EnvLoggerWebhookClientCert = "MINIO_LOGGER_WEBHOOK_CLIENT_CERT"
    	EnvLoggerWebhookClientKey  = "MINIO_LOGGER_WEBHOOK_CLIENT_KEY"
    	EnvLoggerWebhookProxy      = "MINIO_LOGGER_WEBHOOK_PROXY"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  5. cmd/auth-handler.go

    	logger.GetReqInfo(ctx).BucketName = bucketName
    	logger.GetReqInfo(ctx).ObjectName = objectName
    	logger.GetReqInfo(ctx).VersionID = versionID
    
    	_, _, s3Err = checkRequestAuthTypeCredential(ctx, r, action)
    	return s3Err
    }
    
    func authenticateRequest(ctx context.Context, r *http.Request, action policy.Action) (s3Err APIErrorCode) {
    	if logger.GetReqInfo(ctx) == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26K bytes
    - Viewed (0)
  6. 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)
  7. cmd/kms-handlers.go

    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/kms"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v2/policy"
    )
    
    // KMSStatusHandler - GET /minio/kms/v1/status
    func (a kmsAPIHandlers) KMSStatusHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "KMSStatus")
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.KMSStatusAction)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  8. cmd/storage-rest-server.go

    			logger.FatalIf(storageListDirRPC.RegisterNoInput(gm, server.ListDirHandler, endpoint.Path), "unable to register handler")
    			logger.FatalIf(storageReadAllRPC.Register(gm, server.ReadAllHandler, endpoint.Path), "unable to register handler")
    			logger.FatalIf(storageWriteAllRPC.Register(gm, server.WriteAllHandler, endpoint.Path), "unable to register handler")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  9. cmd/admin-router.go

    	handlerName := getHandlerName(f, "adminAPIHandlers")
    
    	var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    		// Update request context with `logger.ReqInfo`.
    		r = r.WithContext(newContext(r, w, handlerName))
    
    		defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
    
    		// Check if object layer is available, if not return error early.
    		if !handlerFlags.Has(noObjLayerFlag) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  10. cmd/admin-handlers-config-kv.go

    }
    
    // setLoggerWebhookSubnetProxy - Sets the logger webhook's subnet proxy value to
    // one being set for subnet proxy
    func setLoggerWebhookSubnetProxy(subSys string, cfg config.Config) bool {
    	if subSys == config.SubnetSubSys || subSys == config.LoggerWebhookSubSys {
    		subnetWebhookCfg := cfg[config.LoggerWebhookSubSys][subnet.LoggerWebhookName]
    		loggerWebhookSubnetProxy := subnetWebhookCfg.Get(logger.Proxy)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.7K bytes
    - Viewed (0)
Back to top