Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for isopen (0.16 sec)

  1. internal/event/target/postgresql.go

    	PostgresPassword           = "password"
    	PostgresDatabase           = "database"
    	PostgresQueueDir           = "queue_dir"
    	PostgresQueueLimit         = "queue_limit"
    	PostgresMaxOpenConnections = "max_open_connections"
    
    	EnvPostgresEnable             = "MINIO_NOTIFY_POSTGRES_ENABLE"
    	EnvPostgresFormat             = "MINIO_NOTIFY_POSTGRES_FORMAT"
    	EnvPostgresConnectionString   = "MINIO_NOTIFY_POSTGRES_CONNECTION_STRING"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:51:07 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  2. cmd/admin-bucket-handlers.go

    			rpt.SetStatus(file.Name, "", fmt.Errorf("malformed zip - expecting format bucket/<config.json>"))
    			continue
    		}
    		bucket, fileName := slc[0], slc[1]
    		if fileName == objectLockConfig {
    			reader, err := file.Open()
    			if err != nil {
    				rpt.SetStatus(bucket, fileName, err)
    				continue
    			}
    			config, err := objectlock.ParseObjectLockConfig(reader)
    			if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  3. cmd/common-main.go

    		color.TurnOff()
    	}
    
    	if runtime.GOOS == "windows" {
    		if mousetrap.StartedByExplorer() {
    			fmt.Printf("Don't double-click %s\n", os.Args[0])
    			fmt.Println("You need to open cmd.exe/PowerShell and run it from the command line")
    			fmt.Println("Refer to the docs here on how to run it as a Windows Service https://github.com/minio/minio-service/tree/master/windows")
    			fmt.Println("Press the Enter Key to Exit")
    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. docs/metrics/v3.md

    | `file_descriptor_limit_total` | `gauge`   | Limit on total number of open file descriptors for the MinIO Server process                                    | `server` |
    | `file_descriptor_open_total`  | `gauge`   | Total number of open file descriptors by the MinIO Server process                                              | `server` |
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 28.5K bytes
    - Viewed (0)
  5. docs/metrics/prometheus/list.md

    | `minio_node_file_descriptor_limit_total`   | Limit on total number of open file descriptors for the MinIO Server process.                                    |
    | `minio_node_file_descriptor_open_total`    | Total number of open file descriptors by the MinIO Server process.                                              |
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 43.4K bytes
    - Viewed (2)
  6. internal/grid/connection.go

    func (c ContextDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error) {
    	return c(ctx, network, address)
    }
    
    const (
    	defaultOutQueue    = 65535    // kind of close to max open fds per user
    	readBufferSize     = 32 << 10 // 32 KiB is the most optimal on Linux
    	writeBufferSize    = 32 << 10 // 32 KiB is the most optimal on Linux
    	defaultDialTimeout = 2 * time.Second
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  7. cmd/s3-zip-handlers.go

    		gr, err := objectAPI.GetObjectNInfo(ctx, bucket, zipPath, rs, nil, opts)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		defer gr.Close()
    		rc, err = file.Open(gr)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	} else {
    		rc = io.NopCloser(bytes.NewReader([]byte{}))
    	}
    
    	defer rc.Close()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2_test.go

    	"github.com/klauspost/compress/zstd"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func TestReadXLMetaNoData(t *testing.T) {
    	f, err := os.Open("testdata/xl.meta-corrupt.gz")
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer f.Close()
    
    	gz, err := gzip.NewReader(bufio.NewReader(f))
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	buf, err := io.ReadAll(gz)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
  9. internal/config/notify/help.go

    			Description: config.DefaultComment,
    			Optional:    true,
    			Type:        "sentence",
    		},
    		config.HelpKV{
    			Key:         target.PostgresMaxOpenConnections,
    			Description: "To set the maximum number of open connections to the database. The value is set to `2` by default.",
    			Optional:    true,
    			Type:        "number",
    		},
    	}
    
    	HelpMySQL = config.HelpKVS{
    		config.HelpKV{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 18.8K bytes
    - Viewed (0)
  10. internal/logger/target/http/http.go

    		queueStore := store.NewQueueStore[interface{}](
    			filepath.Join(h.config.QueueDir, h.Name()),
    			uint64(h.config.QueueSize),
    			httpLoggerExtension,
    		)
    
    		if err := queueStore.Open(); err != nil {
    			return h, fmt.Errorf("unable to initialize the queue store of %s webhook: %w", h.Name(), err)
    		}
    
    		h.store = queueStore
    
    	}
    
    	return h, nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
Back to top