Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1641 - 1650 of 2,701 for content (0.08 sec)

  1. istioctl/pkg/multicluster/remote_secret_test.go

      name: {cluster}
    contexts:
    - context:
        cluster: {cluster}
        user: {cluster}
      name: {cluster}
    current-context: {cluster}
    kind: Config
    preferences: {}
    users:
    - name: {cluster}
      user:
        token: token
    `, "{cluster}", fakeClusterName)
    
    	cases := []struct {
    		name               string
    		clusterName        string
    		context            string
    		server             string
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    	go func() {
    		err := globalTierConfigMgr.Reload(context.Background(), newObjectLayerFn())
    		if err != nil {
    			peersLogIf(context.Background(), fmt.Errorf("Failed to reload remote tier config %s", err))
    		}
    	}()
    
    	return
    }
    
    // ConsoleLogHandler sends console logs of this node back to peer rest client
    func (s *peerRESTServer) ConsoleLogHandler(ctx context.Context, params *grid.MSS, out chan<- *grid.Bytes) *grid.RemoteErr {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  3. cmd/background-newdisks-heal-ops.go

    	// Be sure that they are included in toHealingDisk
    }
    
    // loadHealingTracker will load the healing tracker from the supplied disk.
    // The disk ID will be validated against the loaded one.
    func loadHealingTracker(ctx context.Context, disk StorageAPI) (*healingTracker, error) {
    	if disk == nil {
    		return nil, errors.New("loadHealingTracker: nil drive given")
    	}
    	diskID, err := disk.GetDiskID()
    	if err != nil {
    		return nil, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. cmd/bucket-object-lock.go

    }
    
    // enforceRetentionForDeletion checks if it is appropriate to remove an
    // object according to locking configuration when this is lifecycle/ bucket quota asking.
    func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) {
    	if objInfo.DeleteMarker {
    		return false
    	}
    
    	lhold := objectlock.GetObjectLegalHoldMeta(objInfo.UserDefined)
    	if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  5. cmd/sftp-server-driver.go

    	}
    	ok, err := clnt.BucketExists(r.Context(), bucket)
    	if err != nil {
    		return nil, err
    	}
    	if !ok {
    		return nil, os.ErrNotExist
    	}
    
    	pr, pw := io.Pipe()
    
    	wa := &writerAt{
    		buffer: make(map[int64][]byte),
    		w:      pw,
    		r:      pr,
    		wg:     &sync.WaitGroup{},
    	}
    	wa.wg.Add(1)
    	go func() {
    		oi, err := clnt.PutObject(r.Context(), bucket, object, pr, -1, minio.PutObjectOptions{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/ProtoSession.java

        }
    
        protected ProtoSession(
                RepositorySystemSession session,
                RepositorySystem repositorySystem,
                List<RemoteRepository> repositories,
                List<org.eclipse.aether.repository.RemoteRepository> resolverRepositories,
                Lookup lookup,
                Context context) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  7. scripts/playwright/cookie_param_models/image01.py

    def run(playwright: Playwright) -> None:
        browser = playwright.chromium.launch(headless=False)
        # Update the viewport manually
        context = browser.new_context(viewport={"width": 960, "height": 1080})
        browser = playwright.chromium.launch(headless=False)
        context = browser.new_context()
        page = context.new_page()
        page.goto("http://localhost:8000/docs")
        page.get_by_role("link", name="/items/").click()
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  8. istioctl/pkg/dashboard/dashboard.go

    	port := 15014
    	pod, err := client.Kube().CoreV1().Pods(ns).Get(context.Background(), name, metav1.GetOptions{})
    	if err != nil {
    		return port
    	}
    	return kube.FindIstiodMonitoringPort(pod)
    }
    
    // port-forward to SkyWalking UI on istio-system
    func skywalkingDashCmd(ctx cli.Context) *cobra.Command {
    	var opts clioptions.ControlPlaneOptions
    	cmd := &cobra.Command{
    		Use:   "skywalking",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Apr 15 01:29:35 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  9. istioctl/pkg/proxyconfig/proxyconfig.go

    	return configCmd
    }
    
    func getPodNames(ctx cli.Context, podflag, ns string) ([]string, string, error) {
    	podNames, ns, err := ctx.InferPodsFromTypedResource(podflag, ns)
    	if err != nil {
    		log.Errorf("pods lookup failed")
    		return []string{}, "", err
    	}
    	return podNames, ns, nil
    }
    
    func getPodName(ctx cli.Context, podflag string) (string, string, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  10. cmd/erasure-encode.go

    package cmd
    
    import (
    	"context"
    	"fmt"
    	"io"
    )
    
    // Writes to multiple writers
    type multiWriter struct {
    	writers     []io.Writer
    	writeQuorum int
    	errs        []error
    }
    
    // Write writes data to writers.
    func (p *multiWriter) Write(ctx context.Context, blocks [][]byte) error {
    	for i := range p.writers {
    		if p.errs[i] != nil {
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top