Search Options

Results per page
Sort
Preferred Languages
Advance

Results 801 - 810 of 1,425 for Func (0.02 sec)

  1. tests/error_translator_test.go

    package tests_test
    
    import (
    	"errors"
    	"testing"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/utils/tests"
    )
    
    func TestDialectorWithErrorTranslatorSupport(t *testing.T) {
    	// it shouldn't translate error when the TranslateError flag is false
    	translatedErr := errors.New("translated error")
    	untranslatedErr := errors.New("some random error")
    	db, _ := gorm.Open(tests.DummyDialector{TranslatedErr: translatedErr})
    
    	err := db.AddError(untranslatedErr)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jul 12 13:21:22 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  2. cmd/xl-storage-free-version_test.go

    )
    
    func (x xlMetaV2) listFreeVersions(volume, path string) ([]FileInfo, error) {
    	fivs, err := x.ListVersions(volume, path, true)
    	if err != nil {
    		return nil, err
    	}
    	n := 0
    	for _, fiv := range fivs {
    		if fiv.TierFreeVersion() {
    			fivs[n] = fiv
    			n++
    		}
    	}
    	fivs = fivs[:n]
    	return fivs, nil
    }
    
    func TestFreeVersion(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  3. cmd/peer-s3-server.go

    				Deleted: v.Created,
    			})
    		}
    	}
    
    	return buckets, nil
    }
    
    func cloneDrives(drives map[string]StorageAPI) []StorageAPI {
    	copyDrives := make([]StorageAPI, 0, len(drives))
    	for _, drive := range drives {
    		copyDrives = append(copyDrives, drive)
    	}
    	return copyDrives
    }
    
    func getBucketInfoLocal(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/arch/arm.go

    	"BGE":  true,
    	"BLT":  true,
    	"BGT":  true,
    	"BLE":  true,
    	"CALL": true,
    	"JMP":  true,
    }
    
    func jumpArm(word string) bool {
    	return armJump[word]
    }
    
    // IsARMCMP reports whether the op (as defined by an arm.A* constant) is
    // one of the comparison instructions that require special handling.
    func IsARMCMP(op obj.As) bool {
    	switch op {
    	case arm.ACMN, arm.ACMP, arm.ATEQ, arm.ATST:
    		return true
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 23 15:18:14 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. statement.go

    }
    
    // WriteByte write byte
    func (stmt *Statement) WriteByte(c byte) error {
    	return stmt.SQL.WriteByte(c)
    }
    
    // WriteQuoted write quoted value
    func (stmt *Statement) WriteQuoted(value interface{}) {
    	stmt.QuoteTo(&stmt.SQL, value)
    }
    
    // QuoteTo write quoted value to writer
    func (stmt *Statement) QuoteTo(writer clause.Writer, field interface{}) {
    	write := func(raw bool, str string) {
    		if raw {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  6. cmd/object-api-options_test.go

    )
    
    // TestGetAndValidateAttributesOpts is currently minimal and covers a subset of getAndValidateAttributesOpts(),
    // it is intended to be expanded when the function is worked on in the future.
    func TestGetAndValidateAttributesOpts(t *testing.T) {
    	globalBucketVersioningSys = &BucketVersioningSys{}
    	bucket := minioMetaBucket
    	ctx := context.Background()
    	testCases := []struct {
    		name            string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  7. docs/site-replication/gen-oidc-sts-cred.go

    import (
    	"context"
    	"fmt"
    	"log"
    	"net/http"
    	"os"
    
    	cr "github.com/minio/minio-go/v7/pkg/credentials"
    	cmd "github.com/minio/minio/cmd"
    )
    
    func main() {
    	ctx := context.Background()
    
    	endpoint := os.Getenv("MINIO_ENDPOINT")
    	if endpoint == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 29 01:27:09 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  8. docs/auditlog/auditlog-echo.go

    package main
    
    import (
    	"bytes"
    	"encoding/json"
    	"flag"
    	"fmt"
    	"io"
    	"log"
    	"net/http"
    )
    
    var port int
    
    func init() {
    	flag.IntVar(&port, "port", 8080, "Port to listen on")
    }
    
    func mainHandler(w http.ResponseWriter, r *http.Request) {
    	body, err := io.ReadAll(r.Body)
    	defer r.Body.Close()
    	if err != nil {
    		log.Printf("Error reading request body: %v", err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 21:31:13 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  9. internal/s3select/csv/record.go

    func (r *Record) Raw() (sql.SelectObjectFormat, interface{}) {
    	return sql.SelectFmtCSV, r
    }
    
    // Replace - is not supported for CSV
    func (r *Record) Replace(_ interface{}) error {
    	return errors.New("Replace is not supported for CSV")
    }
    
    // NewRecord - creates new CSV record.
    func NewRecord() *Record {
    	return &Record{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. istioctl/pkg/precheck/precheck.go

    type clusterOrigin struct{}
    
    func (o clusterOrigin) ClusterName() istiocluster.ID {
    	return "Cluster"
    }
    
    func (o clusterOrigin) String() string {
    	return ""
    }
    
    func (o clusterOrigin) FriendlyName() string {
    	return "Cluster"
    }
    
    func (o clusterOrigin) Comparator() string {
    	return o.FriendlyName()
    }
    
    func (o clusterOrigin) Namespace() resource.Namespace {
    	return ""
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 02:31:32 UTC 2024
    - 15.3K bytes
    - Viewed (0)
Back to top