- Sort Score
- Result 10 results
- Languages All
Results 41 - 45 of 45 for Implementation (0.17 sec)
-
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/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/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) -
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) -
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)