- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for googleapis (1.39 sec)
-
istioctl/pkg/xds/client.go
if opts.Plaintext || opts.CertDir != "" { return make([]grpc.DialOption, 0), nil } // Use bearer token aud := tokenAudiences isMCP := strings.HasSuffix(opts.Xds, ".googleapis.com") || strings.HasSuffix(opts.Xds, ".googleapis.com:443") if isMCP { // Special credentials handling when using ASM Managed Control Plane. mem, err := getHubMembership(ctx, kubeClient) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
istioctl/pkg/util/configdump/wrapper.go
// limitations under the License. package configdump import ( admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3" exprpb "google.golang.org/genproto/googleapis/api/expr/v1alpha1" "google.golang.org/protobuf/reflect/protoreflect" "google.golang.org/protobuf/reflect/protoregistry" "google.golang.org/protobuf/types/known/emptypb" "istio.io/istio/pkg/util/protomarshal" )
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 1.8K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
HTTPListener = wellknown.HTTPConnectionManager // TCPListener identifies a listener as being of TCP type by the presence of TCP proxy filter TCPListener = wellknown.TCPProxy IPMatcher = "type.googleapis.com/xds.type.matcher.v3.IPMatcher" ) // ListenerFilter is used to pass filter information into listener based config writer print functions type ListenerFilter struct { Address string Port uint32
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
istioctl/pkg/version/version.go
return func() (*[]istioVersion.ProxyInfo, error) { pi := []istioVersion.ProxyInfo{} for _, resource := range (*xdsResponse).Resources { switch resource.TypeUrl { case "type.googleapis.com/envoy.config.core.v3.Node": node := core.Node{} err := resource.UnmarshalTo(&node) if err != nil { return nil, fmt.Errorf("could not unmarshal Node: %w", err) }
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) -
istioctl/pkg/writer/compare/comparator.go
discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" legacyproto "github.com/golang/protobuf/proto" // nolint: staticcheck exprpb "google.golang.org/genproto/googleapis/api/expr/v1alpha1" "google.golang.org/protobuf/reflect/protoreflect" "google.golang.org/protobuf/reflect/protoregistry" "google.golang.org/protobuf/types/known/emptypb" "istio.io/istio/istioctl/pkg/util/configdump"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 3.7K bytes - Viewed (1) -
istioctl/pkg/authz/analyzer_test.go
input *configdump.Wrapper wantErr error }{ { name: "Test1", input: &configdump.Wrapper{ ConfigDump: &envoy_admin.ConfigDump{ Configs: []*anypb.Any{ { TypeUrl: "type.googleapis.com/envoy.admin.v3.ListenersConfigDump", }, }, }, }, wantErr: nil, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/util/configdump/util.go
const ( bootstrap configTypeURL = "type.googleapis.com/envoy.admin.v3.BootstrapConfigDump" listeners configTypeURL = "type.googleapis.com/envoy.admin.v3.ListenersConfigDump" endpoints configTypeURL = "type.googleapis.com/envoy.admin.v3.EndpointsConfigDump" clusters configTypeURL = "type.googleapis.com/envoy.admin.v3.ClustersConfigDump" routes configTypeURL = "type.googleapis.com/envoy.admin.v3.RoutesConfigDump"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Dec 24 08:16:26 GMT 2023 - 2.1K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
if err != nil { return nil, fmt.Errorf("could not get XDS from the agent pod %q: %v", pod.Name, err) } for _, resource := range response.GetResources() { switch resource.GetTypeUrl() { case "type.googleapis.com/envoy.service.status.v3.ClientConfig": clientConfig := xdsstatus.ClientConfig{} err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, err }
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) -
istioctl/pkg/multixds/google.go
// limitations under the License. package multixds import ( "fmt" "net/url" "strings" ) func isMCPAddr(u *url.URL) bool { return strings.HasSuffix(u.Host, ".googleapis.com") || strings.HasSuffix(u.Host, ".googleapis.com:443") } func parseMCPAddr(u *url.URL) (*xdsAddr, error) { ret := &xdsAddr{host: u.Host} if !strings.HasSuffix(ret.host, ":443") { ret.host += ":443" }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jun 06 03:39:27 GMT 2022 - 1.5K bytes - Viewed (1) -
istioctl/pkg/kubeinject/google.go
func isMCPAddr(addr string) bool { // A bit inexact but should be good enough. return strings.Contains(addr, ".googleapis.com/") || strings.Contains(addr, ".googleapis.com:443/") } func mcpTransport(ctx context.Context, tr http.RoundTripper) (http.RoundTripper, error) { creds, err := google.FindDefaultCredentials(ctx, "https://www.googleapis.com/auth/cloud-platform") if err != nil { return nil, fmt.Errorf("finding default GCP credentials: %w", err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.2K bytes - Viewed (0)