- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 694 for toSend (0.21 sec)
-
internal/grid/connection.go
} toSend = merged[:0] m := message{Op: OpMerged, Seq: uint32(len(queue))} var err error toSend, err = m.MarshalMsg(toSend) if err != nil { gridLogIf(ctx, fmt.Errorf("msg.MarshalMsg: %w", err)) return } // Append as byte slices. for _, q := range queue { toSend = msgp.AppendBytes(toSend, q) PutByteBuffer(q) } queue = queue[:0]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
internal/grid/benchmark_test.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K 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 Nov 03 19:28:11 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: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.3K bytes - Viewed (0) -
cni/test/testdata/k8s_svcacct/token
John Howard <******@****.***> 1605827959 -0800
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Nov 19 23:19:19 UTC 2020 - 860 bytes - Viewed (0) -
docs/sts/custom-token-identity.go
"net/url" "time" "github.com/minio/minio-go/v7" cr "github.com/minio/minio-go/v7/pkg/credentials" ) var ( // LDAP integrated Minio endpoint stsEndpoint string // token to use with AssumeRoleWithCustomToken token string // Role ARN to use roleArn string // Display credentials flag displayCreds bool // Credential expiry duration expiryDuration time.Duration // Bucket to list
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 27 00:58:09 UTC 2022 - 3.4K bytes - Viewed (0) -
docs/sts/custom-token-identity.md
| Version | String | Yes | Value must be `2011-06-15` | | Token | String | Yes | Token to be authenticated by identity plugin | | RoleArn | String | Yes | Must match the Role ARN generated for the identity plugin |
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 27 00:58:09 UTC 2022 - 3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java
public void testAssignableClassToType() { TypeToken<List<String>> tokenL = new TypeToken<List<String>>() {}; assertTrue(tokenL.isSupertypeOf(StringList.class)); assertFalse(tokenL.isSupertypeOf(List.class)); TypeToken<First<String>> tokenF = new TypeToken<First<String>>() {}; assertTrue(tokenF.isSupertypeOf(ConcreteIS.class)); assertFalse(tokenF.isSupertypeOf(ConcreteSI.class)); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 21:13:09 UTC 2024 - 89.1K bytes - Viewed (0) -
cni/pkg/install/testdata/token-bar
Sergei Gavrilov <******@****.***> 1657207540 +0200
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jul 07 15:25:40 UTC 2022 - 3 bytes - Viewed (0) -
cni/pkg/install/testdata/token-foo
Sergei Gavrilov <******@****.***> 1657207540 +0200
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jul 07 15:25:40 UTC 2022 - 3 bytes - Viewed (0)