- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 225 for toSend (0.36 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) -
internal/grid/muxserver.go
} // sendResponses will send responses to the client. func (m *muxServer) sendResponses(ctx context.Context, toSend <-chan []byte, c *Connection, handlerErr *atomic.Pointer[RemoteErr], outBlock <-chan struct{}) { for { // Process outgoing message. var payload []byte var ok bool select { case payload, ok = <-toSend: case <-ctx.Done(): return } select { case <-ctx.Done(): return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/dict/kuromoji/KuromojiFileTest.java
List<KuromojiItem> itemList = new ArrayList<>(); itemList.add(new KuromojiItem(1, "token1", "seg1", "reading1", "pos1")); itemList.add(new KuromojiItem(2, "token2", "seg2", "reading2", "pos2")); itemList.add(new KuromojiItem(3, "token3", "seg3", "reading3", "pos3")); kuromojiFile.kuromojiItemList = itemList; } public void test_selectList() {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.3K 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) -
tests/integration/security/authz_test.go
}, { prefix: "[Token2]", jwt: jwt.TokenIssuer2, path: "/token1", allow: false, }, { prefix: "[Token2]", jwt: jwt.TokenIssuer2, path: "/token2", allow: true, }, { prefix: "[Token3]", jwt: jwt.TokenIssuer1, path: "/token3", allow: false, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 23:36:51 UTC 2024 - 50.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/bootstraptoken/node/token.go
return UpdateOrCreateTokens(client, true, tokens) } // UpdateOrCreateTokens attempts to update a token with the given ID, or create if it does not already exist. func UpdateOrCreateTokens(client clientset.Interface, failIfExists bool, tokens []bootstraptokenv1.BootstrapToken) error { for _, token := range tokens { secretName := bootstraputil.BootstrapTokenSecretName(token.Token.ID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 2.5K bytes - Viewed (0) -
tests/integration/security/testdata/authz/jwt.yaml.tmpl
# - Allow request principal ******@****.***/sub-1 to access path /token1 # - Allow request in group-2 to access path /token2 # - Allow request with any token to access path /tokenAny # - Allow request with permission claim of "write" or "append" to access path /permission # - Allow request with valid JWT token to access path /jwt1 # - Allow request with valid JWT token of presenter bar to access path with suffix "/presenter"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 23:36:51 UTC 2024 - 3K bytes - Viewed (0) -
cmd/kubeadm/app/discovery/token/token.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 10.1K bytes - Viewed (0) -
pkg/controller/bootstrap/bootstrapsigner.go
tokenID := strings.TrimPrefix(key, bootstrapapi.JWSSignatureKeyPrefix) sigs[tokenID] = value delete(newCM.Data, key) } } // Now recompute signatures and store them on the new map tokens := e.getTokens(ctx) for tokenID, tokenValue := range tokens { sig, err := jws.ComputeDetachedSignature(content, tokenID, tokenValue) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0)