Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 54 of 54 for Model (0.23 sec)

  1. cmd/notification.go

    	// utilization to be optimal, instead of blindly throttling the way we are
    	// doing below. However the changes that are needed here are a bit involved,
    	// further discussion advised. Remove this comment and remove the worker model
    	// for this function in future.
    	maxWorkers := runtime.GOMAXPROCS(0) / 2
    	if maxWorkers > len(sys.peerClients) {
    		maxWorkers = len(sys.peerClients)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  2. istioctl/pkg/waypoint/waypoint.go

    	"k8s.io/apimachinery/pkg/types"
    	gateway "sigs.k8s.io/gateway-api/apis/v1"
    	"sigs.k8s.io/yaml"
    
    	"istio.io/api/label"
    	"istio.io/istio/istioctl/pkg/cli"
    	"istio.io/istio/pilot/pkg/model/kstatus"
    	"istio.io/istio/pkg/config/constants"
    	"istio.io/istio/pkg/config/protocol"
    	"istio.io/istio/pkg/config/schema/gvk"
    	"istio.io/istio/pkg/kube"
    	"istio.io/istio/pkg/slices"
    	"istio.io/istio/pkg/util/sets"
    )
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  3. cmd/object-handlers-common.go

    }
    
    func deleteObjectVersions(ctx context.Context, o ObjectLayer, bucket string, toDel []ObjectToDelete, lcEvent lifecycle.Event) {
    	for remaining := toDel; len(remaining) > 0; toDel = remaining {
    		if len(toDel) > maxDeleteList {
    			remaining = toDel[maxDeleteList:]
    			toDel = toDel[:maxDeleteList]
    		} else {
    			remaining = nil
    		}
    		vc, _ := globalBucketVersioningSys.Get(bucket)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 09 08:17:49 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    			objectInfos = append(objectInfos, obj)
    			continue
    		}
    
    		toDel = append(toDel, ObjectToDelete{
    			ObjectV: ObjectV{
    				ObjectName: obj.Name,
    				VersionID:  obj.VersionID,
    			},
    		})
    	}
    
    	if len(toDel) > 0 {
    		expState.enqueueByNewerNoncurrent(i.bucket, toDel, event)
    	}
    	return objectInfos, nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
Back to top