- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 234 for discoveryv1 (0.16 sec)
-
pkg/proxy/winkernel/proxier_test.go
}), ) populateEndpointSlices(proxier, makeTestEndpointSlice(svcPortName.Namespace, svcPortName.Name, 1, func(eps *discovery.EndpointSlice) { eps.AddressType = discovery.AddressTypeIPv4 eps.Endpoints = []discovery.Endpoint{{ Addresses: []string{epIpAddressRemote}, }} eps.Ports = []discovery.EndpointPort{{ Name: ptr.To(svcPortName.Port), Port: ptr.To(int32(svcPort)),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 28 14:30:51 UTC 2024 - 30.2K bytes - Viewed (0) -
pkg/apis/discovery/v1beta1/zz_generated.conversion.go
package v1beta1 import ( unsafe "unsafe" v1 "k8s.io/api/core/v1" v1beta1 "k8s.io/api/discovery/v1beta1" conversion "k8s.io/apimachinery/pkg/conversion" runtime "k8s.io/apimachinery/pkg/runtime" core "k8s.io/kubernetes/pkg/apis/core" discovery "k8s.io/kubernetes/pkg/apis/discovery" ) func init() { localSchemeBuilder.Register(RegisterConversions) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 15.3K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
p.connectedMutex.Unlock() } func (p *XdsProxy) forwardDeltaToTap(resp *discovery.DeltaDiscoveryResponse) { select { // Convert back to a SotW response case p.tapResponseChannel <- &discovery.DiscoveryResponse{ VersionInfo: resp.SystemVersionInfo, Resources: slices.Map(resp.Resources, (*discovery.Resource).GetResource), Canary: false, TypeUrl: resp.TypeUrl,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
return nil, err } return map[string]*discovery.DiscoveryResponse{ CpInfo(response).ID: response, }, nil } } return nil, err } return mapShards(responses) } func mapShards(responses []*discovery.DiscoveryResponse) (map[string]*discovery.DiscoveryResponse, error) { retval := map[string]*discovery.DiscoveryResponse{} for _, response := range responses {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.6K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice_test.go
s.Verify(s.Connect().RequestResponseAck(t, &discovery.DiscoveryRequest{ResourceNames: []string{testResourceName}}), expectCert) s.Verify(s.Connect().RequestResponseAck(t, &discovery.DiscoveryRequest{ResourceNames: []string{testResourceName}}), expectCert) }) t.Run("unsubscribe", func(t *testing.T) { s := setupSDS(t) c := s.Connect() res := c.RequestResponseAck(t, &discovery.DiscoveryRequest{ResourceNames: []string{testResourceName}})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 17 20:12:58 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/adsc/delta_test.go
) type mockDeltaXdsServer struct{} var deltaHandler func(stream discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error func (t *mockDeltaXdsServer) StreamAggregatedResources(discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error { return nil } func (t *mockDeltaXdsServer) DeltaAggregatedResources(delta discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 13.9K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/join.go
) flagSet.BoolVar( &cfg.Discovery.BootstrapToken.UnsafeSkipCAVerification, options.TokenDiscoverySkipCAHash, false, "For token-based discovery, allow joining without --discovery-token-ca-cert-hash pinning.", ) // discovery via kube config file flag flagSet.StringVar( &cfg.Discovery.File.KubeConfigPath, options.FileDiscovery, "",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 15:33:38 UTC 2024 - 25.2K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/join_test.go
}, { name: "pass if file discovery is set", flags: map[string]string{ options.FileDiscovery: "https://foo", }, validate: func(t *testing.T, data *joinData) { // validate that file discovery settings are set into join data if data.cfg.Discovery.File == nil || data.cfg.Discovery.File.KubeConfigPath != "https://foo" { t.Error("Invalid data.cfg.Discovery.File") } }, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 12:26:20 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
// See the License for the specific language governing permissions and // limitations under the License. package xds_test import ( "fmt" "reflect" "testing" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pilot/pkg/model" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pilot/test/xds" "istio.io/istio/pilot/test/xdstest"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
pilot/pkg/model/typed_xds_cache.go
size(l.store.Len()) } type cacheValue struct { value *discovery.Resource token CacheToken dependentConfigs []ConfigHash } func (l *lruCache[K]) Get(key K) *discovery.Resource { return l.get(key, 0) } // get return the cached value if it exists. func (l *lruCache[K]) get(key K, token CacheToken) *discovery.Resource { l.mu.Lock() defer l.mu.Unlock() cv, ok := l.store.Get(key)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 11K bytes - Viewed (0)