- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,644 for go (0.01 sec)
-
internal/config/identity/openid/openid.go
import ( "crypto/sha1" "encoding/base64" "errors" "io" "maps" "net/http" "slices" "sort" "strconv" "strings" "sync" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio/internal/arn" "github.com/minio/minio/internal/auth" "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/config/identity/openid/provider"
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 17.3K bytes - Viewed (0) -
src/cmd/api/boring_test.go
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Wed Aug 16 16:02:26 UTC 2023 - 300 bytes - Viewed (0) -
internal/s3select/jstream/scanner.go
readerErr error // underlying reader error, if any } func newScanner(r io.Reader) *scanner { sr := &scanner{ end: maxInt, fillReq: make(chan struct{}), fillReady: make(chan int64), } go func() { var rpos int64 // total bytes read into buffer defer func() { atomic.StoreInt64(&sr.end, rpos) close(sr.fillReady) }() for range sr.fillReq { scan: n, err := r.Read(sr.nbuf[:])
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 2.5K bytes - Viewed (0) -
cmd/untar.go
asyncWriters <- struct{}{} bufp := xioutil.ODirectPoolMedium.Get() b := (*bufp)[:header.Size] if _, err := io.ReadFull(tarReader, b); err != nil { return err } wg.Add(1) go func(name string, fi fs.FileInfo, b []byte) { rc := disconnectReader{r: bytes.NewReader(b)} defer func() { rc.Close() <-asyncWriters wg.Done() xioutil.ODirectPoolMedium.Put(bufp)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6K bytes - Viewed (2) -
internal/handlers/forwarder.go
if f.Logger != nil && err != context.Canceled { f.Logger(err) } w.WriteHeader(http.StatusBadGateway) } func (f *Forwarder) getURLFromRequest(req *http.Request) *url.URL { // If the Request was created by Go via a real HTTP request, RequestURI will // contain the original query string. If the Request was created in code, RequestURI // will be empty, and we will use the URL object instead u := req.URL if req.RequestURI != "" {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 5.7K bytes - Viewed (0) -
internal/s3select/json/record.go
func NewRecord(f sql.SelectObjectFormat) *Record { return &Record{ KVS: jstream.KVS{}, SelectFormat: f, } } // jsonFloat converts a float to string similar to Go stdlib formats json floats. func jsonFloat(f float64) string { var tmp [32]byte dst := tmp[:0] // Convert as if by ES6 number to string conversion. // This matches most other JSON generators.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.2K bytes - Viewed (0) -
internal/s3select/simdj/record.go
"io" csv "github.com/minio/csvparser" "github.com/minio/minio/internal/s3select/json" "github.com/minio/minio/internal/s3select/jstream" "github.com/minio/minio/internal/s3select/sql" "github.com/minio/simdjson-go" ) // Record - is JSON record. type Record struct { // object object simdjson.Object } // Get - gets the value for a column name. func (r *Record) Get(name string) (*sql.Value, error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.4K bytes - Viewed (0) -
internal/http/server.go
package http import ( "context" "crypto/tls" "errors" "log" "net" "net/http" "sync" "sync/atomic" "time" "github.com/dustin/go-humanize" ) var ( // GlobalMinIOVersion - is sent in the header to all http targets GlobalMinIOVersion string // GlobalDeploymentID - is sent in the header to all http targets GlobalDeploymentID string )
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6.5K bytes - Viewed (0) -
internal/logger/targets.go
group1 = append(group1, target) } else { group2 = append(group2, target) } } return group1, group2 } func cancelTargets(targets []Target) { for _, target := range targets { go target.Cancel() } } // UpdateHTTPWebhooks swaps system webhook targets with newly loaded ones from the cfg func UpdateHTTPWebhooks(ctx context.Context, cfgs map[string]http.Config) (errs []error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6K bytes - Viewed (0) -
src/cmd/api/testdata/src/pkg/p2/p2.go
// Copyright 2012 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package p2 type Twoer interface { // Deprecated: No good. PackageTwoMeth() } // Deprecated: No good. func F() string {} func G() Twoer {}Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Fri Dec 02 16:29:41 UTC 2022 - 337 bytes - Viewed (0)