- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 95 for into (0.12 sec)
-
cmd/storage-errors.go
errDiskNotFound, errFaultyDisk, errFaultyRemoteDisk, } var baseIgnoredErrs = baseErrs // Is a one place function which converts all os.PathError // into a more FS object layer friendly form, converts // known errors into their typed form for top level // interpretation. func osErrToFileErr(err error) error { if err == nil { return nil } if osIsNotExist(err) { return errFileNotFound
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/kms/key-manager.go
DeleteKey(ctx context.Context, keyID string) error // ListKeys lists all key names. ListKeys(ctx context.Context) (*kes.ListIter[string], error) // ImportKey imports a cryptographic key into the KMS. ImportKey(ctx context.Context, keyID string, bytes []byte) error // EncryptKey Encrypts and authenticates a (small) plaintext with the cryptographic key // The plaintext must not exceed 1 MB
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 1.9K bytes - Viewed (0) -
internal/logger/targets.go
if l.Enabled { t := kafka.New(l) tgts = append(tgts, t) e := t.Init(ctx) if e != nil { errs = append(errs, e) } } } return tgts, errs } // Split targets into two groups: // // group1 contains all targets of type t // group2 contains the remaining targets func splitTargets(targets []Target, t types.TargetType) (group1 []Target, group2 []Target) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 22:56:14 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/bucket/lifecycle/delmarker-expiration.go
XMLName xml.Name `xml:"DelMarkerExpiration"` Days int `xml:"Days,omitempty"` } // Empty returns if a DelMarkerExpiration XML element is empty. // Used to detect if lifecycle.Rule contained a DelMarkerExpiration element. func (de DelMarkerExpiration) Empty() bool { return de.Days == 0 } // UnmarshalXML decodes a single XML element into a DelMarkerExpiration value
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 2.3K bytes - Viewed (0) -
internal/bpool/bpool.go
case bp.c <- b: // buffer went back into pool default: // buffer didn't go back into pool, just discard } } // Width returns the width of the byte arrays in this pool. func (bp *BytePoolCap) Width() (n int) { if bp == nil { return 0 } return bp.w } // WidthCap returns the cap width of the byte arrays in this pool. func (bp *BytePoolCap) WidthCap() (n int) { if bp == nil { return 0 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 2.6K bytes - Viewed (0) -
cmd/signature-v4-parser.go
ch, s3Err = parseCredentialHeader(authFields[0], region, stype) if s3Err != ErrNone { return auth.Credentials{}, false, s3Err } } return checkKeyValid(r, ch.accessKey) } // parse credentialHeader string into its structured form. func parseCredentialHeader(credElement string, region string, stype serviceType) (ch credentialHeader, aec APIErrorCode) { creds := strings.SplitN(strings.TrimSpace(credElement), "=", 2) if len(creds) != 2 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/crypto/sse-kms.go
} err = key.Unseal(unsealKey, sealedKey, s3.String(), bucket, object) return key, err } // CreateMetadata encodes the sealed object key into the metadata and returns // the modified metadata. If the keyID and the kmsKey is not empty it encodes // both into the metadata as well. It allocates a new metadata map if metadata // is nil.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.4K bytes - Viewed (0) -
cmd/leak-detect_test.go
if strings.HasPrefix(stack, "testing.RunTests") { continue } // Ignore the following go routines. // testing and run time go routines should be ignored, only the application generated go routines should be taken into account. if isIgnoredStackFn(stack) { continue } gs = append(gs, g) } sort.Strings(gs) return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
internal/logger/logrotate.go
// or when files are being rotated. f *os.File pw *xioutil.PipeWriter pr *xioutil.PipeReader } // Write writes p into the current file, rotating if necessary. // Write is non-blocking, if the writer's queue is not full. // Write is blocking otherwise. func (w *Writer) Write(p []byte) (n int, err error) { return w.pw.Write(p) } // Close closes the writer.
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) -
internal/disk/stat_linux.go
if err != nil { return Info{}, err } //nolint:unconvert devID := uint64(st.Dev) // Needed to support multiple GOARCHs info.Major = unix.Major(devID) info.Minor = unix.Minor(devID) // Check for overflows. // https://github.com/minio/minio/issues/8035 // XFS can show wrong values at times error out // in such scenarios. if info.Free > info.Total {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0)