Search Options

Results per page
Sort
Preferred Languages
Advance

Results 671 - 680 of 1,105 for errC (0.02 sec)

  1. internal/config/identity/openid/jwt.go

    	mclaims := jwtgo.MapClaims(claims)
    	jwtToken, err := jp.ParseWithClaims(token, &mclaims, keyFuncCallback)
    	if err != nil {
    		// Re-populate the public key in-case the JWKS
    		// pubkeys are refreshed
    		if err = r.PopulatePublicKey(arn); err != nil {
    			return err
    		}
    		jwtToken, err = jwtgo.ParseWithClaims(token, &mclaims, keyFuncCallback)
    		if err != nil {
    			return err
    		}
    	}
    
    	if !jwtToken.Valid {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 02:46:36 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. docs/sts/assume-role.go

    	madmClnt, err := madmin.NewWithOptions(stsEndpointURL.Host, mopts)
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	err = madmClnt.ServiceRestart(context.Background())
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	// Use generated credentials to authenticate with MinIO server
    	minioClient, err := minio.New(stsEndpointURL.Host, opts)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 17 01:24:54 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. tests/multi_primary_keys_test.go

    	DB.Migrator().DropTable(&Label{}, &Book{})
    	if err := DB.AutoMigrate(&Label{}, &Book{}); err != nil {
    		t.Fatalf("failed to migrate, got %v", err)
    	}
    
    	book := Book{
    		Name: "my book",
    		Labels: []Label{
    			{Name: "region", Value: "emea"},
    		},
    	}
    
    	DB.Create(&book)
    
    	var result Book
    	if err := DB.Preload("Labels").First(&result, book.ID).Error; err != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 12.8K bytes
    - Viewed (0)
  4. istioctl/pkg/workload/workload.go

    ) error {
    	if err := os.MkdirAll(outputDir, filePerms); err != nil {
    		return err
    	}
    	var (
    		err         error
    		proxyConfig *meshconfig.ProxyConfig
    	)
    	revision := kubeClient.Revision()
    	if proxyConfig, err = createMeshConfig(kubeClient, wg, istioNamespace, clusterID, outputDir, revision); err != nil {
    		return err
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 25.3K bytes
    - Viewed (0)
  5. internal/config/compress/compress.go

    func LookupConfig(kvs config.KVS) (Config, error) {
    	var err error
    	cfg := Config{}
    	if err = config.CheckValidKeys(config.CompressionSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	compress := env.Get(EnvCompressState, kvs.Get(config.Enable))
    	if compress == "" {
    		compress = env.Get(EnvCompress, "")
    	}
    	cfg.Enabled, err = config.ParseBool(compress)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. schema/index_test.go

    type CompIdxLevel2B struct {
    	Data2B string `gorm:"index:,unique,composite:comp_id2,priority:3"`
    }
    
    func TestParseIndex(t *testing.T) {
    	user, err := schema.Parse(&UserIndex{}, &sync.Map{}, schema.NamingStrategy{})
    	if err != nil {
    		t.Fatalf("failed to parse user index, got error %v", err)
    	}
    
    	results := map[string]schema.Index{
    		"idx_user_indices_name": {
    			Name:   "idx_user_indices_name",
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sun Feb 04 07:49:19 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. internal/s3select/json/record.go

    		case bool, int64:
    			columnValue = fmt.Sprintf("%v", val)
    		case nil:
    			columnValue = ""
    		case RawJSON:
    			columnValue = string([]byte(val))
    		case []interface{}:
    			b, err := json.Marshal(val)
    			if err != nil {
    				return err
    			}
    			columnValue = string(b)
    		default:
    			return fmt.Errorf("Cannot marshal unhandled type: %T", kv.Value)
    		}
    		csvRecord = append(csvRecord, columnValue)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. internal/kms/config.go

    		}
    		endpoints, err := expandEndpoints(rawEndpoint)
    		if err != nil {
    			return nil, err
    		}
    
    		key, err := kms.ParseAPIKey(env.Get(EnvKMSAPIKey, ""))
    		if err != nil {
    			return nil, err
    		}
    
    		var rootCAs *x509.CertPool
    		if opts != nil && opts.CADir != "" {
    			rootCAs, err = certs.GetRootCAs(opts.CADir)
    			if err != nil {
    				return nil, err
    			}
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  9. cmd/net.go

    	// Extract host & port from given parameters
    	host1, port1, err := extractHostPort(addr1)
    	if err != nil {
    		return false, err
    	}
    	host2, port2, err := extractHostPort(addr2)
    	if err != nil {
    		return false, err
    	}
    
    	var addr1Local, addr2Local bool
    
    	if host1 == "" {
    		// If empty host means it is localhost
    		addr1Local = true
    	} else if addr1Local, err = isLocalHost(host1, port1, port1); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:34:00 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  10. internal/bucket/lifecycle/tag.go

    	var keyAlreadyParsed, valueAlreadyParsed bool
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			var s string
    			if err = d.DecodeElement(&s, &se); err != nil {
    				return err
    			}
    			switch se.Name.Local {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
Back to top