- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 89 for SplitV (0.22 sec)
-
chainable_api.go
if results[1] != "" { tx.Statement.Table = results[1] } else { tx.Statement.Table = results[2] } } } else if tables := strings.Split(name, "."); len(tables) == 2 { tx.Statement.TableExpr = &clause.Expr{SQL: tx.Statement.Quote(name)} tx.Statement.Table = tables[1] } else if name != "" { tx.Statement.TableExpr = &clause.Expr{SQL: tx.Statement.Quote(name)}
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 09:47:34 UTC 2024 - 14.5K bytes - Viewed (0) -
cmd/iam-object-store.go
policyDBPrefix = "policydb/" policyDBUsersListKey = "policydb/users/" policyDBSTSUsersListKey = "policydb/sts-users/" policyDBGroupsListKey = "policydb/groups/" ) // splitPath splits a path into a top-level directory and a child item. The // parent directory retains the trailing slash. func splitPath(s string, lastIndex bool) (string, string) { var i int if lastIndex {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 19.5K bytes - Viewed (0) -
pilot/test/xds/fake.go
return objects } func kubernetesObjectsFromString(s string) ([]runtime.Object, error) { var objects []runtime.Object decode := kubelib.IstioCodec.UniversalDeserializer().Decode objectStrs := strings.Split(s, "---") for _, s := range objectStrs { if len(strings.TrimSpace(s)) == 0 { continue } o, _, err := decode([]byte(s), nil, nil) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
return []byte(sk.String()), nil } // EndpointShards holds the set of endpoint shards of a service. Registries update // individual shards incrementally. The shards are aggregated and split into // clusters when a push for the specific cluster is needed. type EndpointShards struct { // mutex protecting below map. sync.RWMutex // Shards is used to track the shards. EDS updates are grouped by shard.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/model/telemetry_logging.go
if service == "" { err = fmt.Errorf("service must not be empty") return } // TODO(yangminzhu): Verify the service and its cluster is supported, e.g. resolution type is not OriginalDst. if parts := strings.Split(service, "/"); len(parts) == 2 { namespace, name := parts[0], parts[1] if svc := push.ServiceIndex.HostnameAndNamespace[host.Name(name)][namespace]; svc != nil { hostname = string(svc.Hostname)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 23K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux.go
v1.IPv4Protocol: proxyutil.NewNoOpLocalDetector(), v1.IPv6Protocol: proxyutil.NewNoOpLocalDetector(), } switch config.DetectLocalMode { case proxyconfigapi.LocalModeClusterCIDR: clusterCIDRs := strings.Split(strings.TrimSpace(config.ClusterCIDR), ",") for family, cidrs := range proxyutil.MapCIDRsByIPFamily(clusterCIDRs) { localDetectors[family] = proxyutil.NewDetectLocalByCIDR(cidrs[0].String()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 18.1K bytes - Viewed (0) -
cluster/gce/util.sh
declare -a pairs # indexed array declare -A map # associative array IFS="${item_sep}" read -ra pairs <<<"${encoded}" # split on item_sep for pair in "${pairs[@]}"; do declare key declare value IFS="${kv_sep}" read -r key value <<<"${pair}" # split on kv_sep map[$key]="${map[$key]+${map[$key]}${item_sep}}${value}" # append values from duplicate keys done
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:17 UTC 2024 - 161.6K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultModelValidator.java
private static int compareModelVersions(String first, String second) { // we use a dedicated comparator because we control our model version scheme. String[] firstSegments = first.split("\\."); String[] secondSegments = second.split("\\."); for (int i = 0; i < Math.max(firstSegments.length, secondSegments.length); i++) { int result = Long.valueOf(i < firstSegments.length ? firstSegments[i] : "0")
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Jun 10 11:04:53 UTC 2024 - 73.9K bytes - Viewed (0) -
cmd/bucket-replication.go
return } // if already replicated, return true if a new reset was requested. splits := strings.SplitN(rs, ";", 2) if len(splits) != 2 { return } newReset := splits[1] != resetID if !newReset && tgtStatus == replication.Completed { // already replicated and no reset requested return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
cmd/object-api-utils.go
if isMinioMetaBucketName(bucket) { return true } if len(bucket) < 3 || len(bucket) > 63 { return false } // Split on dot and check each piece conforms to rules. allNumbers := true pieces := strings.Split(bucket, dnsDelimiter) for _, piece := range pieces { if len(piece) == 0 || piece[0] == '-' || piece[len(piece)-1] == '-' { // Current piece has 0-length or starts or
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 36.3K bytes - Viewed (0)