- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 119 for toSend (0.56 sec)
-
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/phases/bootstraptoken/node/token_test.go
ID: "token1", Secret: "token1data", }, }, }, wantErr: false, }, { name: "create multiple secrets which do not exist", failIfExists: true, tokens: []bootstraptokenv1.BootstrapToken{ { Token: &bootstraptokenv1.BootstrapTokenString{ ID: "token1", Secret: "token1data", }, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 28 08:42:29 UTC 2023 - 3.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/DefaultCancellationTokenSourceTest.groovy
def 'token operation idempotent'() { when: def token1 = source.token() def token2 = source.token() then: token1 == token2 } def 'can unpack token'() { expect: source.token().token != null } def 'can cancel'() { expect: !source.token().cancellationRequested when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 1.2K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/tokens.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package syntax type Token uint type token = Token //go:generate stringer -type token -linecomment tokens.go const ( _ token = iota _EOF // EOF // names and literals _Name // name _Literal // literal // operators and operations
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 20 14:52:38 UTC 2023 - 2.6K bytes - Viewed (0) -
src/go/token/token.go
// license that can be found in the LICENSE file. // Package token defines constants representing the lexical tokens of the Go // programming language and basic operations on tokens (printing, predicates). package token import ( "strconv" "unicode" "unicode/utf8" ) // Token is the set of lexical tokens of the Go programming language. type Token int // The list of tokens. const ( // Special tokens ILLEGAL Token = iota
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:03 UTC 2023 - 6.4K 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) -
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) -
pkg/serviceaccount/metrics.go
// LegacyTokensTotal is the number of legacy tokens used against apiserver. legacyTokensTotal = metrics.NewCounter( &metrics.CounterOpts{ Subsystem: kubeServiceAccountSubsystem, Name: "legacy_tokens_total", Help: "Cumulative legacy service account tokens used", StabilityLevel: metrics.ALPHA, }, ) // StaleTokensTotal is the number of stale projected tokens not refreshed on // client side.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 03:52:06 UTC 2023 - 3.4K bytes - Viewed (0)