Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 45 of 45 for Implementation (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top