Search Options

Results per page
Sort
Preferred Languages
Advance

Results 411 - 420 of 1,214 for Func (0.1 sec)

  1. internal/http/response-recorder.go

    // when the request is finished to provide accurate data
    func (lrw *ResponseRecorder) TTFB() time.Duration {
    	if lrw.ttfbBody != 0 {
    		return lrw.ttfbBody
    	}
    	return lrw.ttfbHeader
    }
    
    // NewResponseRecorder - returns a wrapped response writer to trap
    // http status codes for auditing purposes.
    func NewResponseRecorder(w http.ResponseWriter) *ResponseRecorder {
    	rf, _ := w.(io.ReaderFrom)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. internal/fips/api.go

    // for the DARE object encryption.
    func DARECiphers() []byte {
    	if Enabled {
    		return []byte{sio.AES_256_GCM}
    	}
    	return []byte{sio.AES_256_GCM, sio.CHACHA20_POLY1305}
    }
    
    // TLSCiphers returns a list of supported TLS transport
    // cipher suite IDs.
    //
    // The list contains only ciphers that use AES-GCM or
    // (non-FIPS) CHACHA20-POLY1305 and ellitpic curve key
    // exchange.
    func TLSCiphers() []uint16 {
    	if Enabled {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:11:25 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. cmd/kms-handlers_test.go

    	adminTestBed, err := prepareAdminErasureTestBed(context.Background())
    	if err != nil {
    		t.Fatal(err)
    	}
    	registerKMSRouter(adminTestBed.router)
    
    	if enableKMS {
    		GlobalKMS = kms.NewStub("default-test-key")
    	}
    
    	tearDown := func() {
    		adminTestBed.TearDown()
    		GlobalKMS = nil
    	}
    	return adminTestBed, tearDown
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  4. cmd/warm-backend-gcs.go

    	client       *storage.Client
    	Bucket       string
    	Prefix       string
    	StorageClass string
    }
    
    func (gcs *warmBackendGCS) getDest(object string) string {
    	destObj := object
    	if gcs.Prefix != "" {
    		destObj = fmt.Sprintf("%s/%s", gcs.Prefix, object)
    	}
    	return destObj
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. internal/event/target/nats_contrib_test.go

     * limitations under the License.
     */
    
    package target
    
    import (
    	"testing"
    
    	xnet "github.com/minio/pkg/v3/net"
    	natsserver "github.com/nats-io/nats-server/v2/test"
    )
    
    func TestNatsConnPlain(t *testing.T) {
    	opts := natsserver.DefaultTestOptions
    	opts.Port = 14222
    	s := natsserver.RunServer(&opts)
    	defer s.Shutdown()
    
    	clientConfig := &NATSArgs{
    		Enable: true,
    		Address: xnet.Host{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  6. cmd/api-router.go

    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/rs/cors"
    )
    
    func newHTTPServerFn() *xhttp.Server {
    	globalObjLayerMutex.RLock()
    	defer globalObjLayerMutex.RUnlock()
    	return globalHTTPServer
    }
    
    func setHTTPServer(h *xhttp.Server) {
    	globalObjLayerMutex.Lock()
    	globalHTTPServer = h
    	globalObjLayerMutex.Unlock()
    }
    
    func newConsoleServerFn() *consoleapi.Server {
    	globalObjLayerMutex.RLock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  7. src/cmd/cgo/ast.go

    		f.ExpFunc = append(f.ExpFunc, &ExpFunc{
    			Func:    n,
    			ExpName: name,
    			Doc:     doc,
    		})
    		break
    	}
    }
    
    // Make f.ExpFunc[i] point at the Func from this AST instead of the other one.
    func (f *File) saveExport2(x interface{}, context astContext) {
    	n, ok := x.(*ast.FuncDecl)
    	if !ok {
    		return
    	}
    
    	for _, exp := range f.ExpFunc {
    		if exp.Func.Name.Name == n.Name.Name {
    			exp.Func = n
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 14 15:47:06 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  8. tests/prepared_stmt_test.go

    	if err := tx.Find(&result3, user2.ID).Error; err != nil {
    		t.Fatalf("no error should happen but got %v", err)
    	}
    }
    
    func TestPreparedStmtFromTransaction(t *testing.T) {
    	db := DB.Session(&gorm.Session{PrepareStmt: true, SkipDefaultTransaction: true})
    
    	tx := db.Begin()
    	defer func() {
    		if r := recover(); r != nil {
    			tx.Rollback()
    		}
    	}()
    	if err := tx.Error; err != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  9. tests/count_test.go

    	}
    
    	expects = []User{{Name: "count-1", Age: 1}, {Name: "count-2", Age: 1}, {Name: "count-3", Age: 1}}
    	sort.SliceStable(users, func(i, j int) bool {
    		return strings.Compare(users[i].Name, users[j].Name) < 0
    	})
    
    	AssertEqual(t, users, expects)
    
    	var count9 int64
    	if err := DB.Scopes(func(tx *gorm.DB) *gorm.DB {
    		return tx.Table("users")
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Oct 30 09:15:49 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  10. internal/s3select/json/reader.go

    	return dstRec, nil
    }
    
    // Close - closes underlying reader.
    func (r *Reader) Close() error {
    	// Close the input.
    	err := r.readCloser.Close()
    	for range r.valueCh {
    		// Drain values so we don't leak a goroutine.
    		// Since we have closed the input, it should fail rather quickly.
    	}
    	return err
    }
    
    // NewReader - creates new JSON reader using readCloser.
    func NewReader(readCloser io.ReadCloser, args *ReaderArgs) *Reader {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top