- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 139 for DR (0.03 sec)
-
pilot/pkg/networking/core/cluster_cache.go
h.WriteString(string(t.service.Hostname)) h.Write(Slash) h.WriteString(t.service.Attributes.Namespace) } h.Write(Separator) for _, dr := range t.destinationRule.GetFrom() { h.WriteString(dr.Name) h.Write(Slash) h.WriteString(dr.Namespace) } h.Write(Separator) for _, efk := range t.envoyFilterKeys { h.WriteString(efk) h.Write(Separator) } h.Write(Separator)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 6.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
dr.expiration = expiration; if (path.equals("")) { dr.server = resp.referrals[di].path.substring(1).toLowerCase(); } else { dfsPathSplit(resp.referrals[di].node, arr); dr.server = arr[1]; dr.share = arr[2]; dr.path = arr[3]; } dr.pathConsumed = resp.pathConsumed;
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 31.2K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
} } } func (b *EndpointBuilder) DestinationRule() *v1alpha3.DestinationRule { if dr := b.destinationRule.GetRule(); dr != nil { dr, _ := dr.Spec.(*v1alpha3.DestinationRule) return dr } return nil } func (b *EndpointBuilder) Type() string { return model.EDSType } func (b *EndpointBuilder) ServiceFound() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
tests/integration/security/ca_custom_root/secure_naming_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.5K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
// consider using AllRequestAndProcessXds or FirstRequestAndProcessXds // nolint: lll func RequestAndProcessXds(dr *discovery.DiscoveryRequest, centralOpts clioptions.CentralControlPlaneOptions, istioNamespace string, kubeClient kube.CLIClient) (*discovery.DiscoveryResponse, error) { responses, err := MultiRequestAndProcessXds(true, dr, centralOpts, istioNamespace, istioNamespace, tokenServiceAccount, kubeClient, DefaultOptions) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
return false } func printDestinationRule(writer io.Writer, initPrintNum int, dr *clientnetworking.DestinationRule, podsLabels []klabels.Set, ) { fmt.Fprintf(writer, "%sDestinationRule: %s for %q\n", printSpaces(initPrintNum+printLevel0), kname(dr.ObjectMeta), dr.Spec.Host) matchingSubsets, nonmatchingSubsets := getDestRuleSubsets(dr.Spec.Subsets, podsLabels) if len(matchingSubsets) != 0 || len(nonmatchingSubsets) != 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 50.4K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route_cache.go
configs = append(configs, r.DelegateVirtualServices...) for _, mergedDR := range r.DestinationRules { for _, dr := range mergedDR.GetFrom() { configs = append(configs, model.ConfigKey{Kind: kind.DestinationRule, Name: dr.Name, Namespace: dr.Namespace}.HashCode()) } } for _, efKey := range r.EnvoyFilterKeys { items := strings.Split(efKey, "/")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 5.8K bytes - Viewed (0) -
src/test/java/jcifs/tests/FileLocationTest.java
DfsReferralData dr = new TestDfsReferral("2.3.4.5", null, "", 0); String reqPath = "\\foo\\bar\\"; SmbResourceLocator fl = p.getLocator(); assertEquals(reqPath, ( (SmbResourceLocatorInternal) fl ).handleDFSReferral(dr, reqPath)); assertEquals("1.2.3.4", fl.getServer());
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Wed Jan 08 13:16:07 UTC 2020 - 23K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
} err = adscConn.Run() if err != nil { return nil, fmt.Errorf("ADSC: failed running %v", err) } err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err } // DialOptions constructs gRPC dial options from command line configuration
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/DfsReferral.java
DfsReferral next; Map map; String key = null; public DfsReferral() { this.next = this; } void append(DfsReferral dr) { dr.next = next; next = dr; } public String toString() { return "DfsReferral[pathConsumed=" + pathConsumed + ",server=" + server + ",share=" + share +
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 1.8K bytes - Viewed (0)