Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ParseMeshNetworks (0.24 sec)

  1. tests/fuzz/mesh_fuzzer.go

    // limitations under the License.
    
    package fuzz
    
    import (
    	"istio.io/istio/pkg/config/mesh"
    )
    
    func FuzzParseMeshNetworks(data []byte) int {
    	_, _ = mesh.ParseMeshNetworks(string(data))
    	return 1
    }
    
    func FuzzValidateMeshConfig(data []byte) int {
    	_, _ = mesh.ApplyMeshConfigDefaults(string(data))
    	return 1
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 20 06:17:08 UTC 2022
    - 860 bytes
    - Viewed (0)
  2. pkg/config/mesh/mesh.go

    func EmptyMeshNetworks() meshconfig.MeshNetworks {
    	return meshconfig.MeshNetworks{
    		Networks: map[string]*meshconfig.Network{},
    	}
    }
    
    // ParseMeshNetworks returns a new MeshNetworks decoded from the
    // input YAML.
    func ParseMeshNetworks(yaml string) (*meshconfig.MeshNetworks, error) {
    	out := EmptyMeshNetworks()
    	if err := protomarshal.ApplyYAML(yaml, &out); err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 12K bytes
    - Viewed (0)
  3. pkg/config/mesh/kubemesh/watcher.go

    		log.Info("no ConfigMap found, using existing MeshNetworks config")
    		return nil, nil
    	}
    
    	cfgYaml, exists := cm.Data[key]
    	if !exists {
    		return nil, nil
    	}
    
    	meshNetworks, err := mesh.ParseMeshNetworks(cfgYaml)
    	if err != nil {
    		return nil, fmt.Errorf("failed reading MeshNetworks config: %v. YAML:\n%s", err, cfgYaml)
    	}
    
    	log.Info("Loaded MeshNetworks config from Kubernetes API server.")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jan 25 20:54:46 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  4. pkg/config/mesh/mesh_test.go

    				{
    					Gw: &meshconfig.Network_IstioNetworkGateway_RegistryServiceName{
    						RegistryServiceName: "reg1",
    					},
    					Port: 443,
    				},
    			},
    		},
    	}
    
    	got, err := mesh.ParseMeshNetworks(yml)
    	if err != nil {
    		t.Fatalf("ApplyMeshNetworksDefaults() failed: %v", err)
    	}
    	assert.Equal(t, got, &want)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  5. pkg/config/analysis/local/istiod_analyze.go

    	}
    
    	sa.meshCfg = cfg
    
    	meshNetworksYaml, ok := meshConfigMap.Data[meshNetworksMapKey]
    	if !ok {
    		return fmt.Errorf("missing config map key %q", meshNetworksMapKey)
    	}
    
    	mn, err := mesh.ParseMeshNetworks(meshNetworksYaml)
    	if err != nil {
    		return fmt.Errorf("error parsing mesh networks: %v", err)
    	}
    
    	sa.meshNetworks = mn
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 21:06:13 UTC 2024
    - 21.6K bytes
    - Viewed (0)
Back to top