Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 367 for qselect (0.16 sec)

  1. 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)
  2. 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)
  3. internal/grid/muxserver.go

    	for {
    		// Process outgoing message.
    		var payload []byte
    		var ok bool
    		select {
    		case payload, ok = <-toSend:
    		case <-ctx.Done():
    			return
    		}
    		select {
    		case <-ctx.Done():
    			return
    		case <-outBlock:
    		}
    		msg := message{
    			MuxID: m.ID,
    			Op:    OpMuxServerMsg,
    			Flags: c.baseFlags,
    		}
    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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top