Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 453 for ctx_ (0.06 sec)

  1. istioctl/pkg/multicluster/remote_secret_test.go

    				},
    				Type:       c.secType,
    				SecretName: c.secretName,
    			}
    
    			ctx := cli.NewFakeContext(&cli.NewFakeContextOption{
    				IstioNamespace: "istio-system",
    				Objects:        c.objs,
    				Namespace:      testNamespace,
    				Version:        c.k8sMinorVersion,
    			})
    			client, err := ctx.CLIClient()
    			if err != nil {
    				tt.Fatalf("failed to create client: %v", err)
    			}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  2. istioctl/pkg/cli/mock_client.go

    	return c.Results, nil
    }
    
    func (c MockClient) EnvoyDo(ctx context.Context, podName, podNamespace, method, path string) ([]byte, error) {
    	results, ok := c.Results[podName]
    	if !ok {
    		return nil, fmt.Errorf("unable to retrieve Pod: pods %q not found", podName)
    	}
    	return results, nil
    }
    
    func (c MockClient) EnvoyDoWithPort(ctx context.Context, podName, podNamespace, method, path string, port int) ([]byte, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Mar 08 08:38:19 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  3. docs/extensions/fan-out/README.md

    Fan-Out uploads are automatically enabled if `x-minio-fanout-list` form-field is provided with the PostUpload API, to keep things simple higher level APIs are provided in our SDKs for example in `minio-go` SDK:
    
    ```
    PutObjectFanOut(ctx context.Context, bucket string, fanOutContent io.Reader, fanOutReq minio.PutObjectFanOutRequest) ([]minio.PutObjectFanOutResponse, error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 25 05:51:07 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  4. cmd/format-erasure.go

    		return err
    	}
    
    	disk.SetDiskID(format.Erasure.This)
    	if healID != "" {
    		ctx := context.Background()
    		ht := initHealingTracker(disk, healID)
    		return ht.save(ctx)
    	}
    	return nil
    }
    
    // loadFormatErasure - loads format.json from disk.
    func loadFormatErasure(disk StorageAPI, heal bool) (format *formatErasureV3, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  5. tests/test_regex_deprecated_body.py

                        "input": "nonregexquery",
                        "ctx": {"pattern": "^fixedquery$"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
                        "ctx": {"pattern": "^fixedquery$"},
                        "loc": ["body", "q"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  6. internal/config/crypto.go

    // ciphertext.
    func Encrypt(k *kms.KMS, plaintext io.Reader, ctx kms.Context) (io.Reader, error) {
    	algorithm := sio.AES_256_GCM
    	if !fips.Enabled && !sioutil.NativeAES() {
    		algorithm = sio.ChaCha20Poly1305
    	}
    
    	key, err := k.GenerateKey(context.Background(), &kms.GenerateKeyRequest{AssociatedData: ctx})
    	if err != nil {
    		return nil, err
    	}
    	stream, err := algorithm.Stream(key.Plaintext)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. internal/config/identity/openid/jwt.go

    	return nil
    }
    
    const (
    	audClaim = "aud"
    	azpClaim = "azp"
    )
    
    // Validate - validates the id_token.
    func (r *Config) Validate(ctx context.Context, arn arn.ARN, token, accessToken, dsecs string, claims map[string]interface{}) error {
    	jp := new(jwtgo.Parser)
    	jp.ValidMethods = []string{
    		"RS256", "RS384", "RS512",
    		"ES256", "ES384", "ES512",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 02:46:36 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. cmd/metrics-v3-bucket-replication.go

    // such as latency and sent bytes.
    func loadBucketReplicationMetrics(ctx context.Context, m MetricValues, c *metricsCache, buckets []string) error {
    	if globalSiteReplicationSys.isEnabled() {
    		return nil
    	}
    
    	dataUsageInfo, err := c.dataUsageInfo.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return nil
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  9. internal/http/transports.go

    // communicating with client cert authentication.
    func (s ConnSettings) NewHTTPTransportWithClientCerts(ctx context.Context, clientCert, clientKey string) (*http.Transport, error) {
    	transport := s.NewHTTPTransportWithTimeout(1 * time.Minute)
    	if clientCert != "" && clientKey != "" {
    		c, err := certs.NewManager(ctx, clientCert, clientKey, tls.LoadX509KeyPair)
    		if err != nil {
    			return nil, err
    		}
    		if c != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. cmd/handler-utils_test.go

    	"testing"
    
    	"github.com/minio/minio/internal/config"
    )
    
    // Tests validate bucket LocationConstraint.
    func TestIsValidLocationConstraint(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatal(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top