- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 367 for qselect (0.16 sec)
-
cmd/admin-heal-ops.go
// even if we aren't listening. task.respCh = make(chan healResult, 1) select { case globalBackgroundHealRoutine.tasks <- task: if serverDebugLog { fmt.Printf("Task in the queue: %#v\n", task) } case <-h.ctx.Done(): return nil } // task queued, now wait for the response. select { case res := <-task.respCh: if !h.reportProgress {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
operator/README.md
```bash istioctl profile dump --filename samples/pilot-k8s.yaml ``` #### Select a specific configuration profile The simplest customization is to select a profile different to `default` e.g. `minimal`. See [manifests/profiles/minimal.yaml](../manifests/profiles/minimal.yaml): ```yaml # minimal-install.yaml apiVersion: install.istio.io/v1alpha1 kind: IstioOperator
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Sep 17 08:27:52 GMT 2023 - 17.5K bytes - Viewed (0) -
internal/grid/muxserver.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
docs/bucket/replication/setup_ilm_expiry_replication.sh
flag=$(./mc admin replicate info sitea --json | jq '.sites[] | select (.name=="sitea") | ."replicate-ilm-expiry"') if [ "$flag" != "false" ]; then echo "BUG: ILM expiry replication not disabled for 'sitea'" exit 1 fi flag=$(./mc admin replicate info siteb --json | jq '.sites[] | select (.name=="sitea") | ."replicate-ilm-expiry"') if [ "$flag" != "false" ]; then
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 12.7K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/scopes/Maven3ScopeManagerConfiguration.java
select(CommonBuilds.PROJECT_PATH_TEST, CommonBuilds.BUILD_PATH_COMPILE), Collections.singletonList(system), nonTransitiveDependencyScopes)); result.add(internalScopeManager.createResolutionScope( RS_TEST_RUNTIME, InternalScopeManager.Mode.ELIMINATE,
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 7.6K bytes - Viewed (0) -
tests/update_test.go
}) AssertObjEqual(t, result2, result, "Name", "Account", "Toys", "Manager", "ManagerID", "Languages") DB.Model(&result).Select("Name", "Age").Updates(User{Name: "update_with_select"}) if result.Age != 0 || result.Name != "update_with_select" { t.Fatalf("Failed to update struct with select, got %+v", result) } AssertObjEqual(t, result, user, "UpdatedAt") var result3 User DB.First(&result3, result.ID)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Dec 04 03:50:58 GMT 2023 - 30.3K bytes - Viewed (0) -
tests/create_test.go
} } func TestSelectWithCreate(t *testing.T) { user := *GetUser("select_create", Config{Account: true, Pets: 3, Toys: 3, Company: true, Manager: true, Team: 3, Languages: 3, Friends: 4}) DB.Select("Account", "Toys", "Manager", "ManagerID", "Languages", "Name", "CreatedAt", "Age", "Active").Create(&user) var user2 User
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Mar 19 03:50:28 GMT 2024 - 26.4K bytes - Viewed (0) -
internal/grid/stream.go
muxID uint64 ctx context.Context } // Send a payload to the remote server. func (s *Stream) Send(b []byte) error { if s.Requests == nil { return errors.New("stream does not accept requests") } select { case s.Requests <- b: return nil case <-s.ctx.Done(): return context.Cause(s.ctx) } } // Results returns the results from the remote server one by one.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/mrf.go
if m == nil { return } select { case m.opCh <- op: default: } } var healSleeper = newDynamicSleeper(5, time.Second, false) // healRoutine listens to new disks reconnection events and // issues healing requests for queued objects belonging to the // corresponding erasure set func (m *mrfState) healRoutine(z *erasureServerPools) { for { select { case <-GlobalContext.Done(): return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/scopes/Maven4ScopeManagerConfiguration.java
select(CommonBuilds.PROJECT_PATH_TEST, CommonBuilds.BUILD_PATH_COMPILE), Collections.singletonList(system), nonTransitiveDependencyScopes)); result.add(internalScopeManager.createResolutionScope( RS_TEST_RUNTIME, InternalScopeManager.Mode.ELIMINATE,
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 9.1K bytes - Viewed (0)