- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 275 for beraber (0.28 sec)
-
staging/src/k8s.io/api/authentication/v1/generated.proto
// +optional optional BoundObjectReference boundObjectRef = 3; } // TokenRequestStatus is the result of a token request. message TokenRequestStatus { // Token is the opaque bearer token. optional string token = 1; // ExpirationTimestamp is the time of expiration of the returned token. optional .k8s.io.apimachinery.pkg.apis.meta.v1.Time expirationTimestamp = 2; }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 7.7K bytes - Viewed (0) -
internal/event/target/webhook.go
// <Key> <Token> like format, if this is // already present we can blindly use the // authToken as is instead of adding 'Bearer' tokens := strings.Fields(target.args.AuthToken) switch len(tokens) { case 2: req.Header.Set("Authorization", target.args.AuthToken) case 1: req.Header.Set("Authorization", "Bearer "+target.args.AuthToken) } req.Header.Set("Content-Type", "application/json")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.5K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_traffic_policy.go
} } // getDefaultCircuitBreakerThresholds returns a copy of the default circuit breaker thresholds for the given traffic direction. func getDefaultCircuitBreakerThresholds() *cluster.CircuitBreakers_Thresholds { return &cluster.CircuitBreakers_Thresholds{ // DefaultMaxRetries specifies the default for the Envoy circuit breaker parameter max_retries. This
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 20K bytes - Viewed (0) -
cmd/batch-expire_test.go
# retainVersions: 5 # keep the latest 5 versions of the object including delete markers. notify: endpoint: https://notify.endpoint # notification endpoint to receive job completion status token: Bearer xxxxx # optional authentication token for the notification endpoint retry: attempts: 10 # number of retries for the job before giving up delay: 500ms # least amount of delay between each retry `
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 3K bytes - Viewed (0) -
pkg/kube/rpc_creds.go
} else { log.Infof("GetRequestMetadata failed to recreate token: %v", err.Error()) } } token = its.Token its.mu.Unlock() } return map[string]string{ "authorization": "Bearer " + token, }, nil } // RequireTransportSecurity fulfills the grpc/credentials.PerRPCCredentials interface func (its *tokenSupplier) RequireTransportSecurity() bool { return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4K bytes - Viewed (0) -
api/openapi-spec/v3/api_openapi.json
}, "required": [ "clientCIDR", "serverAddress" ], "type": "object" } }, "securitySchemes": { "BearerToken": { "description": "Bearer Token authentication", "in": "header", "name": "authorization", "type": "apiKey" } } }, "info": { "title": "Kubernetes", "version": "unversioned" },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 27 20:05:52 UTC 2023 - 4.8K bytes - Viewed (0) -
tests/integration/security/jwt_test.go
customizeCall: func(t framework.TestContext, from echo.Instance, opts *echo.CallOptions) { opts.HTTP.Path = "/valid-token-noauthz" opts.HTTP.Headers = headers.New(). With("Authorization", "Bearer "+jwt.TokenIssuer1WithNestedClaims2). With("X-Jwt-Nested-Claim", "value_to_be_replaced"). Build() opts.HTTP.Headers = headers.New().WithAuthz(jwt.TokenIssuer1WithNestedClaims2).Build()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 25.3K bytes - Viewed (0) -
pkg/registry/authentication/tokenreview/storage.go
} if r.tokenAuthenticator == nil { return tokenReview, nil } // create a header that contains nothing but the token fakeReq := &http.Request{Header: http.Header{}} fakeReq.Header.Add("Authorization", "Bearer "+tokenReview.Spec.Token) auds := tokenReview.Spec.Audiences if len(auds) == 0 { auds = r.apiAudiences } if len(auds) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 3.7K bytes - Viewed (0) -
internal/event/target/kafka.go
} return target, nil } func isKafkaConnErr(err error) bool { // Sarama opens the circuit breaker after 3 consecutive connection failures. return err == sarama.ErrLeaderNotAvailable || err.Error() == "circuit breaker is open"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
) ([]grpc.DialOption, error) { ctx := context.TODO() // If we are using the insecure 15010 don't bother getting a token if opts.Plaintext || opts.CertDir != "" { return make([]grpc.DialOption, 0), nil } // Use bearer token aud := tokenAudiences isMCP := strings.HasSuffix(opts.Xds, ".googleapis.com") || strings.HasSuffix(opts.Xds, ".googleapis.com:443") if isMCP { // Special credentials handling when using ASM Managed Control Plane.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0)