- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for buildExternalSDSCluster (0.3 sec)
-
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) -
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) -
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)