Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 50 for SELECT (0.14 sec)

  1. cmd/bucket-targets.go

    }
    
    // heartBeat performs liveness check on remote endpoints.
    func (sys *BucketTargetSys) heartBeat(ctx context.Context) {
    	hcTimer := time.NewTimer(defaultHealthCheckDuration)
    	defer hcTimer.Stop()
    	for {
    		select {
    		case <-hcTimer.C:
    			sys.hMutex.RLock()
    			eps := make([]madmin.ServerProperties, 0, len(sys.hc))
    			for _, ep := range sys.hc {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    		return fmt.Errorf("Select parameters can only be specified with SELECT request type")
    	}
    	if r.Type == SelectRestoreRequest && r.SelectParameters.IsEmpty() {
    		return fmt.Errorf("SELECT restore request requires select parameters to be specified")
    	}
    
    	if r.Type != SelectRestoreRequest && !r.OutputLocation.IsEmpty() {
    		return fmt.Errorf("OutputLocation required only for SELECT request type")
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    		}
    
    		timer := time.NewTimer(randSleepFor())
    		defer timer.Stop()
    
    		var (
    			quit     bool
    			traceMsg string
    		)
    
    		for {
    			select {
    			case rebalErr := <-doneCh:
    				quit = true
    				now := time.Now()
    				var status rebalStatus
    
    				switch {
    				case errors.Is(rebalErr, context.Canceled):
    					status = rebalStopped
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  4. internal/grid/muxclient.go

    	for {
    		select {
    		case <-m.ctx.Done():
    			if debugPrint {
    				fmt.Println("Client sending disconnect to mux", m.MuxID)
    			}
    			err := context.Cause(m.ctx)
    			if !errors.Is(err, errStreamEOF) {
    				m.addErrorNonBlockingClose(respHandler, err)
    			}
    			return
    		case resp, ok := <-respServer:
    			if !ok {
    				return
    			}
    			select {
    			case respHandler <- resp:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    		time.Sleep(time.Duration(rng.Int63n(int64(1 * time.Second))))
    
    		dctx, dcancel := context.WithCancel(ctx)
    		started := time.Now()
    		go func() {
    			timeout := time.NewTimer(globalDriveConfig.GetMaxTimeout())
    			select {
    			case <-dctx.Done():
    				if !timeout.Stop() {
    					<-timeout.C
    				}
    			case <-timeout.C:
    				spent := time.Since(started)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  6. cmd/peer-rest-client.go

    	}
    	st.Results(func(b *grid.Bytes) error {
    		select {
    		case listenCh <- *b:
    		default:
    			// Do not block on slow receivers.
    			b.Recycle()
    		}
    		return nil
    	})
    }
    
    // Listen - listen on peers.
    func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
    	go func() {
    		for {
    			client.doListen(ctx, listenCh, v)
    			select {
    			case <-ctx.Done():
    				return
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  7. cmd/batch-expire.go

    			toDelCopy := make([]ObjectToDelete, len(toDel))
    			for attempts := 1; attempts <= retryAttempts; attempts++ {
    				select {
    				case <-ctx.Done():
    					return
    				default:
    				}
    
    				stopFn := globalBatchJobsMetrics.trace(batchJobMetricExpire, ri.JobID, attempts)
    				// Copying toDel to select from objects whose
    				// deletion failed
    				copy(toDelCopy, toDel)
    				var failed int
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  8. 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)
  9. cmd/object-api-errors.go

    type BucketAlreadyExists GenericError
    
    func (e BucketAlreadyExists) Error() string {
    	return "The requested bucket name is not available. The bucket namespace is shared by all users of the system. Please select a different name and try again."
    }
    
    // BucketAlreadyOwnedByYou already owned by you.
    type BucketAlreadyOwnedByYou GenericError
    
    func (e BucketAlreadyOwnedByYou) Error() string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  10. 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)
Back to top