- Sort Score
- Result 10 results
- Languages All
Results 41 - 48 of 48 for Implementation (0.19 sec)
-
pilot/pkg/serviceregistry/serviceentry/controller.go
// nolint: govet shallowSvc := *svc out = append(out, &shallowSvc) } return out } // GetService retrieves a service by host name if it exists. // NOTE: The service entry implementation is used only for tests. func (s *Controller) GetService(hostname host.Name) *model.Service { if s.workloadEntryController { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
} // Stop gRPC services. If gRPC services fail to stop in the shutdown duration, // force stop them. This does not happen normally. stopped := make(chan struct{}) go func() { // Some grpcServer implementations do not support GracefulStop. Unfortunately, this is not // exposed; they just panic. To avoid this, we will recover and do a standard Stop when its not // support. defer func() { if r := recover(); r != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
// TLS is not terminated, so we will attempt to decode as HTTP and fail Error: simulation.ErrProtocolError, }, Permissive: simulation.Result{ // This could also be a protocol error. In the current implementation, we choose not // to create a match since if we did it would just be rejected in HCM; no match // is more performant Error: simulation.ErrNoFilterChain, }, Strict: simulation.Result{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
pilot/pkg/model/service.go
ips := svct.Service.ClusterVIPs.GetAddressesFor(node.GetClusterID()) key.Addresses = append(key.Addresses, ips...) } return key } // NoopAmbientIndexes provides an implementation of AmbientIndexes that always returns nil, to easily "skip" it. type NoopAmbientIndexes struct{} func (u NoopAmbientIndexes) AddressInformation(sets.String) ([]AddressInfo, sets.String) { return nil, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
instanceID string // TODO move WorkloadEntry related tasks into their own object and give InternalGen a reference. // store should either be k8s (for running pilot) or in-memory (for tests). MCP and other config store implementations // do not support writing. We only use it here for reading WorkloadEntry/WorkloadGroup. store model.ConfigStoreController // Note: unregister is to update the workload entry status: like setting `istio.io/disconnectedAt`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/deployment.go
"istio.io/istio/pkg/util/protomarshal" ) const ( // for proxyless we add a special gRPC server that doesn't get configured with xDS for test-runner use grpcMagicPort = 17171 // for non-Go implementations of gRPC echo, this is the port used to forward non-gRPC requests to the Go server grpcFallbackPort = 17777 ) var echoKubeTemplatesDir = path.Join(env.IstioSrc, "pkg/test/framework/components/echo/kube/templates")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 12:26:52 UTC 2024 - 24.1K bytes - Viewed (0) -
tests/integration/pilot/common/routing.go
port string dest string auth string checker echo.Checker }{ // TODO: All these cases *should* succeed (except the TLS mismatch cases) - but don't due to issues in our implementation // For auto port, outbound request will be delayed by the protocol sniffer, regardless of configuration {"auto-tcp-server", "DISABLE", "DISABLE", check.Error()},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.9K bytes - Viewed (0) -
operator/pkg/apis/istio/v1alpha1/values_types.pb.go
// The minimum amount of compute resources required. If Requests is omitted for a container, // it defaults to Limits if that is explicitly specified, otherwise to an implementation-defined value. // More info: https://kubernetes.io/docs/concepts/configuration/manage-compute-resources-container/
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 01:55:05 UTC 2024 - 329.6K bytes - Viewed (0)