- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 130 for ServiceName (0.22 sec)
-
pkg/windows/service/service.go
// service. It returns an indication of whether it is running as a service; // and an error. func InitService(serviceName string) error { h := &handler{ tosvc: make(chan bool), fromsvc: make(chan error), } var err error go func() { err = svc.Run(serviceName, h) h.fromsvc <- err }() // Wait for the first signal from the service handler. err = <-h.fromsvc if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 24 11:25:33 UTC 2022 - 3.3K bytes - Viewed (0) -
pkg/test/framework/components/echo/match/matchers.go
} // Not negates the given matcher. Example: // // Not(Naked()) func Not(m Matcher) Matcher { return func(i echo.Instance) bool { return !m(i) } } // ServiceName matches instances with the given namespace and service name. func ServiceName(n echo.NamespacedName) Matcher { return func(i echo.Instance) bool { return n == i.NamespacedName() } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 5.6K bytes - Viewed (0) -
hack/testdata/rollingupdate-statefulset.yaml
apiVersion: apps/v1 kind: StatefulSet metadata: name: nginx labels: app: nginx-statefulset spec: selector: matchLabels: app: nginx-statefulset updateStrategy: type: RollingUpdate serviceName: "nginx" replicas: 0 template: metadata: labels: app: nginx-statefulset spec: terminationGracePeriodSeconds: 5 containers: - name: nginx
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 14:16:53 UTC 2022 - 593 bytes - Viewed (0) -
tests/integration/security/external_ca/reachability_test.go
from := apps.EchoNamespace.A to := apps.EchoNamespace.B fromAndTo := from.Append(to) echotest.New(t, fromAndTo). WithDefaultFilters(1, 1). FromMatch(match.ServiceName(from.NamespacedName())). ToMatch(match.ServiceName(to.NamespacedName())). Run(func(t framework.TestContext, from echo.Instance, to echo.Target) { // Verify mTLS works between a and b opts := echo.CallOptions{ To: to,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.go
// doesn't already exist. func (c *Controller) CreateOrUpdateMasterServiceIfNeeded(serviceName string, serviceIP net.IP, servicePorts []corev1.ServicePort, serviceType corev1.ServiceType, reconcile bool) error { if s, err := c.serviceLister.Services(metav1.NamespaceDefault).Get(serviceName); err == nil { // The service already exists.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java
private final Supplier<String> threadNameSupplier = new ThreadNameSupplier(); @WeakOuter private final class ThreadNameSupplier implements Supplier<String> { @Override public String get() { return serviceName() + " " + state(); } } /* use AbstractService for state management */ private final Service delegate = new DelegateService(); @WeakOuter
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 17 13:59:28 UTC 2023 - 5.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/reconcilers.go
// endpoints for their {rw, ro} services. // * ReconcileEndpoints is called periodically from all apiservers. ReconcileEndpoints(serviceName string, ip net.IP, endpointPorts []corev1.EndpointPort, reconcilePorts bool) error // RemoveEndpoints removes this apiserver's lease. RemoveEndpoints(serviceName string, ip net.IP, endpointPorts []corev1.EndpointPort) error // StopReconciling turns any later ReconcileEndpoints call into a noop.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 26 13:49:31 UTC 2022 - 2.7K bytes - Viewed (0) -
tests/integration/security/cacert_rotation/main_test.go
} // Verify traffic works between a and b echotest.New(t, fromAndTo). WithDefaultFilters(1, 1). FromMatch(match.ServiceName(from.NamespacedName())). ToMatch(match.ServiceName(to.NamespacedName())). Run(func(t framework.TestContext, from echo.Instance, to echo.Target) { // Verify mTLS works between a and b opts := echo.CallOptions{ To: to,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 6.6K bytes - Viewed (0) -
tests/integration/security/testdata/reachability/workload-dr.yaml.tmpl
apiVersion: networking.istio.io/v1beta1 kind: DestinationRule metadata: name: "{{ .To.ServiceName }}" spec: host: "{{ .To.ClusterLocalFQDN }}" trafficPolicy: tls:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 06 18:43:28 UTC 2022 - 200 bytes - Viewed (0) -
cmd/kube-proxy/app/init_windows.go
*/ package app import ( "github.com/spf13/pflag" "k8s.io/kubernetes/pkg/windows/service" ) const ( serviceName = "kube-proxy" ) func initForOS(windowsService bool) error { if windowsService { return service.InitService(serviceName) } return nil } func (o *Options) addOSFlags(fs *pflag.FlagSet) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 25 23:41:55 UTC 2024 - 1.8K bytes - Viewed (0)