Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for buildExternalSDSCluster (0.48 sec)

  1. pilot/pkg/networking/core/cluster_builder.go

    			},
    			InitialFetchTimeout: durationpb.New(0),
    			ResourceApiVersion:  core.ApiVersion_V3,
    		},
    	}
    }
    
    // buildExternalSDSCluster generates a cluster that acts as external SDS server
    func (cb *ClusterBuilder) buildExternalSDSCluster(addr string) *cluster.Cluster {
    	ep := &endpoint.LbEndpoint{
    		HostIdentifier: &endpoint.LbEndpoint_Endpoint{
    			Endpoint: &endpoint.Endpoint{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/cluster.go

    	}
    
    	// if credential socket exists, create a cluster for it
    	if proxy.Metadata != nil && proxy.Metadata.Raw[security.CredentialMetaDataName] == "true" {
    		clusters = append(clusters, cb.buildExternalSDSCluster(security.CredentialNameSocketPath))
    	}
    	for _, c := range clusters {
    		resources = append(resources, &discovery.Resource{Name: c.Name, Resource: protoconv.MessageToAny(c)})
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster_builder_test.go

    		t.Run(tt.name, func(t *testing.T) {
    			cg := NewConfigGenTest(t, TestOptions{})
    			cb := NewClusterBuilder(cg.SetupProxy(proxy), &model.PushRequest{Push: cg.PushContext()}, nil)
    			cluster := cb.buildExternalSDSCluster(security.CredentialNameSocketPath)
    			path := cluster.LoadAssignment.Endpoints[0].LbEndpoints[0].GetEndpoint().Address.GetPipe().Path
    			anyOptions := cluster.TypedExtensionProtocolOptions[v3.HttpProtocolOptionsType]
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 110.4K bytes
    - Viewed (0)
Back to top