- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 184 for Present (0.12 sec)
-
pkg/kube/kubetypes/types.go
FieldSelector string // Namespace to watch. // This is a *server side* filter. Namespace string // ObjectFilter allows arbitrary filtering logic. // This is a *client side* filter. This means CPU/memory costs are still present for filtered objects. // Use LabelSelector or FieldSelector instead, if possible. ObjectFilter DynamicObjectFilter // ObjectTransform allows arbitrarily modifying objects stored in the underlying cache.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 6.1K bytes - Viewed (0) -
tests/integration/pilot/multi_version_revision_test.go
}) } } } } // installRevisionOrFail takes an Istio version and installs a revisioned control plane running that version // provided istio version must be present in tests/integration/pilot/testdata/upgrade for the installation to succeed func installRevisionOrFail(t framework.TestContext, version string, configs map[string]string) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 6.1K bytes - Viewed (0) -
security/pkg/nodeagent/caclient/providers/citadel/client_test.go
} if !expectError && !reflect.DeepEqual(resp, fakeCert) { t.Fatalf("expected cert: %v", resp) } } certDir := filepath.Join(env.IstioSrc, "./tests/testdata/certs/pilot") t.Run("cert always present", func(t *testing.T) { server := mockCAServer{Certs: fakeCert, Err: nil, Authenticator: security.NewFakeAuthenticator("ca")} addr := serve(t, server, tlsOptions(t)) opts := &security.Options{ CAEndpoint: addr,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 21:03:23 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/kube/krt/core.go
// directly. Most importantly, consumers can subscribe to events when objects change. type Collection[T any] interface { // GetKey returns an object by its key, if present. Otherwise, nil is returned. GetKey(k Key[T]) *T // List returns all objects in the collection. // Order of the list is undefined. List() []T EventStream[T] }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/kube/kclient/crdwatcher.go
func (c *crdWatcher) KnownOrCallback(s schema.GroupVersionResource, f func(stop <-chan struct{})) bool { c.mutex.Lock() defer c.mutex.Unlock() // If we are already synced, return immediately if the CRD is present. if c.crds.HasSynced() && c.known(s) { // Already known, return early return true } name := fmt.Sprintf("%s.%s", s.Resource, s.Group) c.callbacks[name] = append(c.callbacks[name], func() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/istio-agent/grpcxds/grpc_bootstrap.go
) const ( ServerListenerNamePrefix = "xds.istio.io/grpc/lds/inbound/" // ServerListenerNameTemplate for the name of the Listener resource to subscribe to for a gRPC // server. If the token `%s` is present in the string, all instances of the // token will be replaced with the server's listening "IP:port" (e.g., // "0.0.0.0:8080", "[::]:8080"). ServerListenerNameTemplate = ServerListenerNamePrefix + "%s" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 00:31:03 UTC 2024 - 7.1K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters.go
) // EndpointsByNetworkFilter is a network filter function to support Split Horizon EDS - filter the endpoints based on the network // of the connected sidecar. The filter will filter out all endpoints which are not present within the // sidecar network and add a gateway endpoint to remote networks that have endpoints // (if gateway exists and its IP is an IP and not a dns name).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/model/proxy.go
// or from different versions of proxies connecting. While Pilot has access to the meshConfig.defaultConfig, // this field should be preferred if it is present. ProxyConfig *NodeMetaProxyConfig `json:"PROXY_CONFIG,omitempty"` // IstioVersion specifies the Istio version associated with the proxy IstioVersion string `json:"ISTIO_VERSION,omitempty"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 17:18:17 UTC 2024 - 18.7K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter.go
} // GetPodConditionFromList extracts the provided condition from the given list of condition and // returns the index of the condition and the condition. Returns -1 and nil if the condition is not present. func GetPodConditionFromList(conditions []v1.PodCondition, conditionType v1.PodConditionType) (int, *v1.PodCondition) { if conditions == nil { return -1, nil } for i := range conditions {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/helpers.go
} // GetPodConditionFromList extracts the provided condition from the given list of condition and // returns the index of the condition and the condition. Returns -1 and nil if the condition is not present. func GetPodConditionFromList(conditions []v1.PodCondition, conditionType v1.PodConditionType) (int, *v1.PodCondition) { if conditions == nil { return -1, nil } for i := range conditions {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 22 20:35:23 UTC 2024 - 7.2K bytes - Viewed (0)