- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for Franke (0.17 sec)
-
cmd/endpoint.go
// Add add pool endpoints func (l *EndpointServerPools) Add(zeps PoolEndpoints) error { existSet := set.NewStringSet() for _, zep := range *l { for _, ep := range zep.Endpoints { existSet.Add(ep.String()) } } // Validate if there are duplicate endpoints across serverPools for _, ep := range zeps.Endpoints { if existSet.Contains(ep.String()) { return fmt.Errorf("duplicate endpoints found") } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
cmd/admin-handlers.go
} if globalIsTLS { for _, c := range globalPublicCerts { check := xxh3.Hash(c.RawIssuer) check ^= xxh3.Hash(c.RawSubjectPublicKeyInfo) // We XOR, so order doesn't matter. for _, v := range c.DNSNames { check ^= xxh3.HashString(v) } for _, v := range c.EmailAddresses { check ^= xxh3.HashString(v) } for _, v := range c.IPAddresses {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
fmt.Fprintln(w, "NAME\tSTATUS\tLOCALITY\tCLUSTER") dump, err := c.retrieveSortedEndpointsSlice(filter) if err != nil { return err } for _, eds := range dump { for _, llb := range eds.Endpoints { for _, ep := range llb.LbEndpoints { addr := retrieveEndpointAddress(ep) if includeConfigType { addr = fmt.Sprintf("endpoint/%s", addr) } fmt.Fprintf(w, "%v\t%v\t%v\t%v\n",
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/erasure-server-pool.go
func (z *erasureServerPools) GetDisksID(ids ...string) []StorageAPI { idMap := make(map[string]struct{}) for _, id := range ids { idMap[id] = struct{}{} } res := make([]StorageAPI, 0, len(idMap)) for _, s := range z.serverPools { for _, set := range s.sets { for _, disk := range set.getDisks() { if disk == OfflineDisk { continue } if id, _ := disk.GetDiskID(); id != "" {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 77.8K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/connections.go
w := c.tabwriter() d := c.ztunnelDump serviceNames := map[string]string{} workloadNames := map[string]string{} for netIP, s := range d.Services { _, ip, _ := strings.Cut(netIP, "/") serviceNames[ip] = s.Hostname } for netIP, s := range d.Workloads { _, ip, _ := strings.Cut(netIP, "/") workloadNames[ip] = s.Name + "." + s.Namespace } lookupIP := func(addr string) string { if filter.Raw {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 15:39:28 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/net_test.go
expectedPort string }{ {":54321", "", "54321"}, {"server:54321", "server", "54321"}, {":0", "", "0"}, {"server:https", "server", "443"}, {"server:http", "server", "80"}, } for _, testCase := range testCases { host, port := mustSplitHostPort(testCase.hostPort) if testCase.expectedHost != host { t.Fatalf("host: expected = %v, got = %v", testCase.expectedHost, host) } if testCase.expectedPort != port {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 08:43:09 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/erasure-multipart.go
var wg sync.WaitGroup for _, disk := range er.getLocalDisks() { if disk != nil { wg.Add(1) go func(disk StorageAPI) { defer wg.Done() er.cleanupStaleUploadsOnDisk(ctx, disk, expiry) }(disk) } } wg.Wait() } func (er erasureObjects) deleteAll(ctx context.Context, bucket, prefix string) { var wg sync.WaitGroup for _, disk := range er.getDisks() { if disk == nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 42.4K bytes - Viewed (0) -
cmd/postpolicyform.go
func isString(val interface{}) bool { _, ok := val.(string) return ok } // ContentLengthRange - policy content-length-range field. type contentLengthRange struct { Min int64 Max int64 Valid bool // If content-length-range was part of policy } // PostPolicyForm provides strict static type conversion and validation for Amazon S3's POST policy JSON string. type PostPolicyForm struct {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.2K bytes - Viewed (0) -
cmd/erasure-object.go
if disk == nil { for i := range objects { delObjErrs[index][i] = errDiskNotFound } return } errs := disk.DeleteVersions(ctx, bucket, dedupVersions, DeleteOptions{}) for i, err := range errs { if err == nil { continue } for _, v := range dedupVersions[i].Versions {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 76.3K bytes - Viewed (2) -
cmd/xl-storage-format-v2_gen.go
for za0004 := range z.PartNumbers { o = msgp.AppendInt(o, z.PartNumbers[za0004]) } // string "PartETags" o = append(o, 0xa9, 0x50, 0x61, 0x72, 0x74, 0x45, 0x54, 0x61, 0x67, 0x73) if z.PartETags == nil { // allownil: if nil o = msgp.AppendNil(o) } else { o = msgp.AppendArrayHeader(o, uint32(len(z.PartETags))) for za0005 := range z.PartETags {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 53.8K bytes - Viewed (0)