Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for __component (0.22 sec)

  1. operator/cmd/mesh/profile-dump.go

    	default:
    		return []string{fmt.Sprintf("%s=%v", path, v)}, nil
    	}
    }
    
    func pathComponent(component string) string {
    	if !strings.Contains(component, util.PathSeparator) {
    		return component
    	}
    	return strings.ReplaceAll(component, util.PathSeparator, util.EscapedPathSeparator)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  2. istioctl/pkg/multixds/gather.go

    		return pilotxds.IstioControlPlaneInstance{
    			Component: "MISSING",
    			ID:        "MISSING",
    			Info: istioversion.BuildInfo{
    				Version: "MISSING CP ID",
    			},
    		}
    	}
    
    	cpID := pilotxds.IstioControlPlaneInstance{}
    	err := json.Unmarshal([]byte(xdsResponse.ControlPlane.Identifier), &cpID)
    	if err != nil {
    		return pilotxds.IstioControlPlaneInstance{
    			Component: "INVALID",
    			ID:        "INVALID",
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  3. cmd/metrics-v3-handler.go

    	var notFoundHandler http.Handler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		http.Error(w, "Metrics Resource Not found", http.StatusNotFound)
    	})
    
    	// Require that metrics path has at least component.
    	if path == "/" {
    		return notFoundHandler
    	}
    
    	if isListingRequest {
    		handler := h.listMetrics(path)
    		if handler == nil {
    			return notFoundHandler
    		}
    		return handler
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  4. istioctl/pkg/dashboard/dashboard.go

    	dashboardCmd.AddCommand(graf)
    
    	jaeger := jaegerDashCmd(cliContext)
    	jaeger.PersistentFlags().IntVar(&jaegerPort, "ui-port", defaultJaegerPort, "The component dashboard UI port.")
    	dashboardCmd.AddCommand(jaeger)
    
    	zipkin := zipkinDashCmd(cliContext)
    	zipkin.PersistentFlags().IntVar(&zipkinPort, "ui-port", defaultZipkinPort, "The component dashboard UI port.")
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 20.5K bytes
    - Viewed (0)
  5. operator/cmd/mesh/manifest-generate.go

    	ManifestsPath string
    	// Revision is the Istio control plane revision the command targets.
    	Revision string
    	// Components is a list of strings specifying which component's manifests to be generated.
    	Components []string
    	// Filter is the list of components to render
    	Filter []string
    }
    
    var kubeClientFunc func() (kube.CLIClient, error)
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 8.5K bytes
    - Viewed (0)
  6. internal/s3select/sql/utils.go

    	if o.Lit != nil {
    		return string(*o.Lit)
    	}
    	return o.ID.String()
    }
    
    // getLastKeypathComponent checks if the given expression is a path
    // expression, and if so extracts the last dot separated component of
    // the path. Otherwise it returns false.
    func getLastKeypathComponent(e *Expression) (string, bool) {
    	if len(e.And) > 1 ||
    		len(e.And[0].Condition) > 1 ||
    		e.And[0].Condition[0].Not != nil ||
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Nov 10 16:12:50 GMT 2021
    - 3.6K bytes
    - Viewed (0)
  7. istioctl/pkg/tag/tag_test.go

    							Name: "istio-revision-tag-sample",
    							Labels: map[string]string{
    								IstioTagLabel:                 "sample",
    								label.IoIstioRev.Name:         "sample-revision",
    								"operator.istio.io/component": "Pilot",
    							},
    						},
    					},
    				},
    			},
    			namespaces:    corev1.NamespaceList{},
    			outputMatches: []string{"sample", "sample-revision"},
    			error:         "",
    		},
    		{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Nov 17 22:41:06 GMT 2023
    - 8.7K bytes
    - Viewed (0)
  8. cmd/common-main.go

    			logger.Fatal(err, "Invalid MINIO_SERVER_URL value is environment variable")
    		}
    		u.Path = "" // remove any path component such as `/`
    		globalMinioEndpoint = u.String()
    		globalMinioEndpointURL = u
    	}
    
    	globalFSOSync, err = config.ParseBool(env.Get(config.EnvFSOSync, config.EnableOff))
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  9. istioctl/pkg/version/version.go

    		if err != nil {
    			return nil, fmt.Errorf("could not parse CP Identifier: %w", err)
    		}
    		return &istioVersion.MeshInfo{
    			istioVersion.ServerInfo{
    				Component: cpID.Component,
    				Info:      cpID.Info,
    				Revision:  opts.Revision,
    			},
    		}, nil
    	}
    }
    
    func xdsProxyVersionWrapper(xdsResponse **discovery.DiscoveryResponse) func() (*[]istioVersion.ProxyInfo, error) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 8.3K bytes
    - Viewed (0)
  10. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // each authentication attempt.
    type XDGSCRAMClient struct {
    	*scram.Client
    	*scram.ClientConversation
    	scram.HashGeneratorFcn
    }
    
    // Begin constructs a SCRAM client component based on a given hash.Hash
    // factory receiver.  This constructor will normalize the username, password
    // and authzID via the SASLprep algorithm, as recommended by RFC-5802.  If
    // SASLprep fails, the method returns an error.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
Back to top