Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for rimmed (0.22 sec)

  1. cmd/xl-storage-format-v2_test.go

    	}
    
    	// Test trimmed
    	xl2 = xlMetaV2{}
    	trimmed := xlMetaV2TrimData(serialized)
    	failOnErr(xl2.Load(trimmed))
    	if len(xl2.data) != 0 {
    		t.Fatal("data, was not trimmed, bytes left:", len(xl2.data))
    	}
    	// Corrupt metadata, last 5 bytes is the checksum, so go a bit further back.
    	trimmed[len(trimmed)-10] += 10
    	if err := xl2.Load(trimmed); err == nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/envoy/configdump/configdump.go

    // PrintBootstrapDump prints just the bootstrap config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintBootstrapDump(outputFormat string) error {
    	if c.configDump == nil {
    		return fmt.Errorf("config writer has not been primed")
    	}
    	bootstrapDump, err := c.configDump.GetBootstrapConfigDump()
    	if err != nil {
    		return err
    	}
    	out, err := protomarshal.ToJSONWithIndent(bootstrapDump, "    ")
    	if err != nil {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Thu Feb 29 20:46:41 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  3. internal/s3select/sql/funceval.go

    		// String might contain trimming spaces, which
    		// needs to be trimmed.
    		res, ok := strToInt(strings.TrimSpace(x))
    		if !ok {
    			return 0, errCastFailure("could not parse as int")
    		}
    		return res, nil
    	case []byte:
    		// Parse as number, truncate floating point if
    		// needed.
    		// String might contain trimming spaces, which
    		// needs to be trimmed.
    		res, ok := strToInt(strings.TrimSpace(string(x)))
    		if !ok {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 13.2K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/ztunnel/configdump/configdump_test.go

    	}{
    		{
    			name:             "returns expected secret summary onto Stdout",
    			callPrime:        true,
    			wantOutputSecret: "testdata/secretsummary.txt",
    		},
    		{
    			name:    "errors if config dump is not primed",
    			wantErr: true,
    		},
    		{
    			name:               "returns expected workload summary onto Stdout",
    			callPrime:          true,
    			wantOutputWorkload: "testdata/workloadsummary.txt",
    		},
    		{
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Feb 02 18:21:48 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/cluster.go

    	return w, clusters, nil
    }
    
    func (c *ConfigWriter) retrieveSortedClusterSlice() ([]*cluster.Cluster, error) {
    	if c.configDump == nil {
    		return nil, fmt.Errorf("config writer has not been primed")
    	}
    	clusterDump, err := c.configDump.GetClusterConfigDump()
    	if err != nil {
    		return nil, err
    	}
    	clusters := make([]*cluster.Cluster, 0)
    	for _, c := range clusterDump.DynamicActiveClusters {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Thu May 11 05:38:17 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  6. internal/dsync/drwmutex.go

    			}
    		}(index, c)
    	}
    
    	// Wait until we have either
    	//
    	// a) received all refresh responses
    	// b) received too many refreshed for quorum to be still possible
    	// c) timed out
    	//
    	lockNotFound, lockRefreshed := 0, 0
    	done := false
    
    	for i := 0; i < len(restClnts); i++ {
    		select {
    		case refreshResult := <-ch:
    			if refreshResult.offline {
    				continue
    			}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/envoy/configdump/endpoint.go

    		}
    	}
    	return "unknown"
    }
    
    func (c *ConfigWriter) PrintEndpoints(filter EndpointFilter, outputFormat string) error {
    	if c.configDump == nil {
    		return fmt.Errorf("config writer has not been primed")
    	}
    	dump, err := c.retrieveSortedEndpointsSlice(filter)
    	if err != nil {
    		return err
    	}
    	marshaller := make(proto.MessageSlice, 0, len(dump))
    	for _, eds := range dump {
    		marshaller = append(marshaller, eds)
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/ecds.go

    )
    
    const typeURLPrefix = "type.googleapis.com/"
    
    func (c *ConfigWriter) PrintEcds(outputFormat string) error {
    	if c.configDump == nil {
    		return fmt.Errorf("config writer has not been primed")
    	}
    
    	dump, err := c.configDump.GetEcdsConfigDump()
    	if err != nil {
    		return err
    	}
    
    	out, err := protomarshal.MarshalIndentWithGlobalTypesResolver(dump, "    ")
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Sat Jan 14 02:41:27 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/envoy/configdump/configdump_test.go

    	}{
    		{
    			name:           "returns expected bootstrap dump from Envoy onto Stdout",
    			callPrime:      true,
    			wantOutputFile: "testdata/bootstrapdump.json",
    		},
    		{
    			name:    "errors if config dump is not primed",
    			wantErr: true,
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			gotOut := &bytes.Buffer{}
    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile("testdata/configdump.json")
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Wed Jan 03 23:08:06 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/envoy/configdump/route.go

    	return w, routes, nil
    }
    
    func (c *ConfigWriter) retrieveSortedRouteSlice() ([]*route.RouteConfiguration, error) {
    	if c.configDump == nil {
    		return nil, fmt.Errorf("config writer has not been primed")
    	}
    	routeDump, err := c.configDump.GetRouteConfigDump()
    	if err != nil {
    		return nil, err
    	}
    	routes := make([]*route.RouteConfiguration, 0)
    	for _, r := range routeDump.DynamicRouteConfigs {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Thu May 11 05:38:17 GMT 2023
    - 7.2K bytes
    - Viewed (0)
Back to top