Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,644 for Go (0.01 sec)

  1. 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)
  2. src/cmd/api/boring_test.go

    // Copyright 2022 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.
    
    //go:build boringcrypto
    
    package main
    
    import (
    	"fmt"
    	"os"
    )
    
    func init() {
    	fmt.Printf("SKIP with boringcrypto enabled\n")
    	os.Exit(0)
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Aug 16 16:02:26 UTC 2023
    - 300 bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top