- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for vertices (0.19 sec)
-
cni/pkg/iptables/iptables.go
// via the nodeIP // - kubelet (node-local healthchecks, which we do not capture) // - kube-proxy (fowarded/proxied traffic from LoadBalancer-backed services, potentially with public IPs, which we must capture) func (cfg *IptablesConfigurator) CreateHostRulesForHealthChecks(hostSNATIP, hostSNATIPV6 *netip.Addr) error { // Append our rules here
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
Use: "service", Short: "Retrieves services for the specified Ztunnel pod.", Long: `Retrieve information about services for the Ztunnel instance.`, Example: ` # Retrieve summary about services configuration for a randomly chosen ztunnel. istioctl x ztunnel-config services # Retrieve full certificate dump of workloads for a given Ztunnel instance. istioctl x ztunnel-config services <ztunnel-name[.namespace]> -o json `,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
// In 1.22, we remove the default tracing config which points to zipkin.istio-system // This has no effect for users, unless they have this service. svc, err := cli.Kube().CoreV1().Services("istio-system").Get(context.Background(), "zipkin", metav1.GetOptions{}) if err != nil && !kerrors.IsNotFound(err) { return err } if err != nil { // not found return nil } // found
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
internal/s3select/message.go
// https://github.com/aws/aws-sdk-java/blob/master/aws-java-sdk-s3/src/main/java/com/amazonaws/services/s3/internal/eventstreaming/MessageDecoder.java#L26 // but we must make sure there is always space to add 256 bytes: // https://github.com/aws/aws-sdk-java/blob/master/aws-java-sdk-s3/src/main/java/com/amazonaws/services/s3/model/SelectObjectContentEventStream.java#L197 maxRecordMessageLength = (128 << 10) - 256 )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
p := strings.Split(ingressSvc, ".") ingressNs := istioNamespace if len(p) == 2 { ingressSvc = p[0] ingressNs = p[1] } ingress, err := kubeClient.Kube().CoreV1().Services(ingressNs).Get(context.Background(), ingressSvc, metav1.GetOptions{}) if err == nil { if ingress.Status.LoadBalancer.Ingress != nil && len(ingress.Status.LoadBalancer.Ingress) > 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/server-main.go
}) // Configure server. bootstrapTrace("configureServer", func() { handler, err := configureServerHandler(globalEndpoints) if err != nil { logger.Fatal(config.ErrUnexpectedError(err), "Unable to configure one of server's RPC services") } // Allow grid to start after registering all services. xioutil.SafeClose(globalGridStart)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (1) -
istioctl/pkg/validate/validate.go
# Validate current deployments under 'default' namespace within the cluster kubectl get deployments -o yaml | istioctl validate -f - # Validate current services under 'default' namespace within the cluster kubectl get services -o yaml | istioctl validate -f - # Also see the related command 'istioctl analyze' istioctl analyze samples/bookinfo/networking/bookinfo-gateway.yaml `, Args: cobra.NoArgs,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
cmd/admin-handlers_test.go
globalPolicySys = NewPolicySys() objLayer, err := newErasureServerPools(ctx, endpoints) if err != nil { return nil, nil, err } // Make objLayer available to all internal services via globalObjectAPI. globalObjLayerMutex.Lock() globalObjectAPI = objLayer globalObjLayerMutex.Unlock() return objLayer, erasureDirs, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/notification.go
for index, err := range g.Wait() { if err != nil { sys.addNodeErr(&reply[index], sys.peerClients[index], err) } } return reply } // GetSysServices - Get information about system services // (only the services that are of concern to minio) func (sys *NotificationSys) GetSysServices(ctx context.Context) []madmin.SysServices { reply := make([]madmin.SysServices, len(sys.peerClients))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
client := http.Client{ Timeout: time.Second * 5, Transport: &http.Transport{ TLSClientConfig: tlsClientConfig, }, } if cc.Service != nil { svc, err := e.client.Kube().CoreV1().Services(cc.Service.Namespace).Get(context.Background(), cc.Service.Name, metav1.GetOptions{}) if err != nil { return nil, err } namespace, selector, err := polymorphichelpers.SelectorsForObject(svc) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0)