- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for toSend (0.25 sec)
-
internal/grid/benchmark_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
internal/grid/connection.go
} } var err error toSend, err = pingFrame.MarshalMsg(GetByteBuffer()[:0]) if err != nil { gridLogIf(ctx, err) // Fake it... atomic.StoreInt64(&c.LastPong, time.Now().UnixNano()) continue } case toSend = <-c.outQueue: if len(toSend) == 0 { continue } } if len(queue) < maxMergeMessages && queueSize+len(toSend) < writeBufferSize-1024 && len(c.outQueue) > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/token.go
BootstrapToken: bootstraptokenv1.BootstrapToken{ Token: &bootstraptokenv1.BootstrapTokenString{ID: token.Token.ID, Secret: token.Token.Secret}, Description: token.Description, TTL: token.TTL, Expires: token.Expires, Usages: token.Usages, Groups: token.Groups, }, } if err := printer.PrintObj(&outputToken, out); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 05:47:48 UTC 2024 - 15.9K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheEncryptionIntegrationTest.groovy
} private boolean isFoundInDirectory(File startDir, byte[] toFind) { try (Stream<Path> tree = Files.walk(startDir.toPath(), FileVisitOption.FOLLOW_LINKS)) { return tree.filter { it.toFile().file } .anyMatch { isSubArray(Files.readAllBytes(it), toFind) } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 13K bytes - Viewed (0) -
docs/en/docs/tutorial/security/oauth2-jwt.md
{!> ../../../docs_src/security/tutorial004.py!} ``` ## Update the dependencies Update `get_current_user` to receive the same token as before, but this time, using JWT tokens. Decode the received token, verify it, and return the current user. If the token is invalid, return an HTTP error right away. === "Python 3.10+" ```Python hl_lines="90-107"
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Mon May 20 17:37:28 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
tokens, err := e.listTokenSecrets(serviceAccount) if err != nil { // don't retry on cache lookup errors return false, err } retry := false errs := []error{} for _, token := range tokens { r, err := e.deleteToken(token.Namespace, token.Name, token.UID) if err != nil { errs = append(errs, err) } if r { retry = true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd.go
} for _, override := range s.EtcdServersOverrides { tokens := strings.Split(override, "#") if len(tokens) != 2 { allErrors = append(allErrors, fmt.Errorf("--etcd-servers-overrides invalid, must be of format: group/resource#servers, where servers are URLs, semicolon separated")) continue } apiresource := strings.Split(tokens[0], "/") if len(apiresource) != 2 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0) -
pilot/pkg/bootstrap/istio_ca.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 20.6K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/postupgrade.go
errs = append(errs, errors.Wrap(err, "error uploading crisocket")) } // Create RBAC rules that makes the bootstrap tokens able to get nodes if err := nodebootstraptoken.AllowBoostrapTokensToGetNodes(client); err != nil { errs = append(errs, err) } // Create/update RBAC rules that makes the bootstrap tokens able to post CSRs if err := nodebootstraptoken.AllowBootstrapTokensToPostCSRs(client); err != nil { errs = append(errs, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 11.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/ivy/IvyFileModule.groovy
LinkedHashMap<String, Object> tokens = toTokens(options) M2CompatibleIvyPatternHelper.substitute(pattern, m2Compatible, tokens) } private LinkedHashMap<String, String> toTokens(Map<String, ?> options) { def artifact = toArtifact(options)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 23.9K bytes - Viewed (0)