Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for cd (0.16 sec)

  1. istioctl/pkg/writer/ztunnel/configdump/configdump_test.go

    			inputFile:   "testdata/dump.json",
    			wantConfigs: 27,
    			wantErr:     false,
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			cw := &ConfigWriter{}
    			cd, _ := os.ReadFile(tt.inputFile)
    			err := cw.Prime(cd)
    			if cw.ztunnelDump == nil {
    				if tt.wantConfigs != 0 {
    					t.Errorf("wanted some configs loaded but config dump was nil")
    				}
    			} else if len(cw.ztunnelDump.Workloads) != tt.wantConfigs {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Feb 02 18:21:48 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/envoy/configdump/route_test.go

    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			gotOut := &bytes.Buffer{}
    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile(fmt.Sprintf("testdata/routes/%s/configdump.json", tt.name))
    			if err := cw.Prime(cd); err != nil {
    				t.Errorf("failed to parse config dump: %s", err)
    			}
    			err := cw.PrintRouteSummary(RouteFilter{Verbose: true})
    			assert.NoError(t, err)
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 2.8K bytes
    - Viewed (0)
  3. internal/s3select/sql/stringfuncs_test.go

    		matchExpected      bool
    	}{
    		{"abcd", "bcd", false, "", false},
    		{"abcd", "bcd", true, "", true},
    		{"abcd", "abcd", false, "", true},
    		{"abcd", "abcd", true, "", true},
    		{"abcd", "ab", false, "cd", true},
    		{"abcd", "ab", true, "cd", true},
    		{"abcd", "bc", false, "", false},
    		{"abcd", "bc", true, "d", true},
    	}
    
    	for i, tc := range matcherCases {
    		res, ok := matcher(tc.iText, tc.iPat, tc.iHasLeadingPercent)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.1K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/envoy/configdump/configdump_test.go

    			inputFile:   "",
    			wantConfigs: 0,
    			wantErr:     true,
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			cw := &ConfigWriter{}
    			cd, _ := os.ReadFile(tt.inputFile)
    			err := cw.Prime(cd)
    			if cw.configDump == nil {
    				if tt.wantConfigs != 0 {
    					t.Errorf("wanted some configs loaded but config dump was nil")
    				}
    			} else if len(cw.configDump.Configs) != tt.wantConfigs {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Wed Jan 03 23:08:06 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  5. istioctl/pkg/util/configdump/wrapper.go

    type Wrapper struct {
    	*admin.ConfigDump
    }
    
    // UnmarshalJSON is a custom unmarshaller to handle protobuf pain
    func (w *Wrapper) UnmarshalJSON(b []byte) error {
    	cd := &admin.ConfigDump{}
    	err := protomarshal.UnmarshalAllowUnknownWithAnyResolver(nonStrictResolver, b, cd)
    	*w = Wrapper{cd}
    	return err
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  6. istioctl/pkg/util/clusters/wrapper.go

    	return protomarshal.Marshal(w)
    }
    
    // UnmarshalJSON is a custom unmarshaller to handle protobuf pain
    func (w *Wrapper) UnmarshalJSON(b []byte) error {
    	cd := &admin.Clusters{}
    	err := protomarshal.UnmarshalAllowUnknown(b, cd)
    	*w = Wrapper{cd}
    	return err
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 1.2K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/ztunnel/configdump/configdump.go

    func (c *ConfigWriter) Prime(b []byte) error {
    	cd := ZtunnelDump{}
    	// TODO(fisherxu): migrate this to jsonpb when issue fixed in golang
    	// Issue to track -> https://github.com/golang/protobuf/issues/632
    	err := json.Unmarshal(b, &cd)
    	if err != nil {
    		return fmt.Errorf("error unmarshalling config dump response from ztunnel: %v", err)
    	}
    	c.ztunnelDump = &cd
    	return nil
    }
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/clusters/clusters.go

    }
    
    // Prime loads the clusters output into the writer ready for printing
    func (c *ConfigWriter) Prime(b []byte) error {
    	cd := clusters.Wrapper{}
    	err := json.Unmarshal(b, &cd)
    	if err != nil {
    		return fmt.Errorf("error unmarshalling config dump response from Envoy: %v", err)
    	}
    	c.clusters = &cd
    	return nil
    }
    
    func retrieveEndpointAddress(host *admin.HostStatus) string {
    	addr := host.Address.GetSocketAddress()
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 5.8K bytes
    - Viewed (0)
  9. istioctl/pkg/describe/describe.go

    		},
    	}
    }
    
    func (v *myProtoValue) keyAsString(key string) string {
    	s := v.keyAsStruct(key)
    	return s.GetStringValue()
    }
    
    func getIstioRBACPolicies(cd *configdump.Wrapper, port int32) ([]string, error) {
    	hcm, err := getInboundHTTPConnectionManager(cd, port)
    	if err != nil || hcm == nil {
    		return []string{}, err
    	}
    
    	// Identify RBAC policies. Currently there are no "breadcrumbs" so we only return the policy names.
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 50.4K bytes
    - Viewed (0)
  10. misc/go_android_exec/main.go

    		`; export GOPROXY=` + os.Getenv("GOPROXY") +
    		`; export GOCACHE="` + deviceRoot + `/gocache"` +
    		`; export PATH="` + deviceGoroot + `/bin":$PATH` +
    		`; export HOME="` + deviceRoot + `/home"` +
    		`; cd "` + deviceCwd + `"` +
    		"; '" + deviceBin + "' " + strings.Join(os.Args[2:], " ")
    	code, err := adbRun(cmd)
    	signal.Reset(syscall.SIGQUIT)
    	close(quit)
    	return code, err
    }
    
    type exitCodeFilter struct {
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Mon Aug 21 17:46:57 GMT 2023
    - 15.3K bytes
    - Viewed (0)
Back to top