- Sort Score
- Result 10 results
- Languages All
Results 31 - 39 of 39 for isopen (0.2 sec)
-
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) -
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) -
internal/event/target/redis.go
if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-redis-"+id) queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { return nil, fmt.Errorf("unable to initialize the queue store of Redis `%s`: %w", id, err) } } pool := &redis.Pool{ MaxIdle: 3, IdleTimeout: 2 * 60 * time.Second,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
internal/ioutil/read_file.go
"io" "io/fs" "os" "github.com/minio/minio/internal/disk" ) var ( // OpenFileDirectIO allows overriding default function. OpenFileDirectIO = disk.OpenFileDirectIO // OsOpen allows overriding default function. OsOpen = os.Open // OsOpenFile allows overriding default function. OsOpenFile = os.OpenFile ) // ReadFileWithFileInfo reads the named file and returns the contents.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 09 18:17:51 GMT 2023 - 2.3K bytes - Viewed (0) -
cmd/admin-handlers.go
started = true setCommonHeaders(w) setEventStreamHeaders(w) // Set 200 OK status w.WriteHeader(200) } // Send whitespace and keep connection open if _, err := w.Write([]byte(" ")); err != nil { return } w.(http.Flusher).Flush() case hr := <-respCh: switch hr.apiErr { case noError: if started {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
internal/lock/lock_solaris.go
// This implementation doesn't support all the open // flags and shouldn't be considered as replacement // for os.OpenFile(). func LockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) { return lockedOpenFile(path, flag, perm, syscall.F_SETLKW) } // Open - Call os.OpenFile func Open(path string, flag int, perm os.FileMode) (*os.File, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.8K bytes - Viewed (0) -
docs/sts/ldap.go
// LDAP STS API. // Initialize LDAP credentials var ldapOpts []cr.LDAPIdentityOpt if sessionPolicyFile != "" { var policy string if f, err := os.Open(sessionPolicyFile); err != nil { log.Fatalf("Unable to open session policy file: %v", sessionPolicyFile, err) } else { bs, err := io.ReadAll(f) if err != nil { log.Fatalf("Error reading session policy file: %v", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 4K bytes - Viewed (0) -
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) -
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)