- Sort Score
- Result 10 results
- Languages All
Results 351 - 360 of 453 for ctx_ (0.06 sec)
-
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) -
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) -
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) -
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) -
tests/test_regex_deprecated_body.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Apr 18 19:40:57 UTC 2024 - 6.2K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)