Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 65 for Tres (0.17 sec)

  1. internal/config/identity/ldap/config.go

    	}
    
    	// For now, ldapConfigs will only have a single entry for the default
    	// configuration.
    
    	var res []madmin.IDPListItem
    	for _, cfg := range ldapConfigs {
    		res = append(res, madmin.IDPListItem{
    			Type:    "ldap",
    			Name:    cfg,
    			Enabled: l.Enabled(),
    		})
    	}
    
    	return res, nil
    }
    
    // ErrProviderConfigNotFound - represents a non-existing provider error.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 7.9K bytes
    - Viewed (2)
  2. cmd/peer-rest-server.go

    	res := make([]*MetricV2, 0, len(resourceMetricsGroups))
    	populateAndPublish(resourceMetricsGroups, func(m MetricV2) bool {
    		if m.VariableLabels == nil {
    			m.VariableLabels = make(map[string]string, 1)
    		}
    		m.VariableLabels[serverName] = globalLocalNodeName
    		res = append(res, &m)
    		return true
    	})
    	return aoMetricsGroup.NewWith(res), nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    	select {
    	case res := <-task.respCh:
    		if !h.reportProgress {
    			if errors.Is(res.err, errSkipFile) { // this is only sent usually by nopHeal
    				return nil
    			}
    
    			// Report caller of any failure
    			return res.err
    		}
    		res.result.Type = healType
    		if res.err != nil {
    			res.result.Detail = res.err.Error()
    		}
    		return h.pushHealResultItem(res.result)
    	case <-h.ctx.Done():
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  4. cmd/site-replication.go

    		}); err != nil {
    			res.Buckets = append(res.Buckets, madmin.ResyncBucketStatus{
    				ErrDetail: err.Error(),
    				Bucket:    bucket,
    			})
    			continue
    		}
    	}
    	res = madmin.SRResyncOpStatus{
    		Status:   ResyncStarted.String(),
    		OpType:   "start",
    		ResyncID: rs.ResyncID,
    		Buckets:  res.Buckets,
    	}
    	if len(res.Buckets) > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  5. cmd/warm-backend-minio.go

    	partSize, err := optimalPartSize(length)
    	if err != nil {
    		return remoteVersionID(""), err
    	}
    	res, err := m.client.PutObject(ctx, m.Bucket, m.getDest(object), r, length, minio.PutObjectOptions{
    		StorageClass:         m.StorageClass,
    		PartSize:             uint64(partSize),
    		DisableContentSha256: true,
    	})
    	return remoteVersionID(res.VersionID), m.ToObjectError(err, object)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  6. cmd/warm-backend-azure.go

    			return "", azureToObjectError(err, az.Bucket, object)
    		}
    	}
    	res, err := azblob.UploadStreamToBlockBlob(ctx, r, blobURL, azblob.UploadStreamToBlockBlobOptions{})
    	if err != nil {
    		return "", azureToObjectError(err, az.Bucket, object)
    	}
    	return remoteVersionID(res.Version()), nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 05 16:44:08 GMT 2024
    - 7.8K bytes
    - Viewed (1)
  7. cmd/metacache-entries.go

    }
    
    // names will return all names in order.
    // Since this allocates it should not be used in critical functions.
    func (m metaCacheEntries) names() []string {
    	res := make([]string, 0, len(m))
    	for _, obj := range m {
    		res = append(res, obj.name)
    	}
    	return res
    }
    
    // metaCacheEntriesSorted contains metacache entries that are sorted.
    type metaCacheEntriesSorted struct {
    	o metaCacheEntries
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/net.go

    func (s *NetServer) scanProcForPodsAndCache(pods map[types.UID]*corev1.Pod) error {
    	// TODO: maybe remove existing uids in s.currentPodSnapshot from the filter set.
    	res, err := s.podNs.FindNetnsForPods(pods)
    	if err != nil {
    		return err
    	}
    
    	for uid, wl := range res {
    		s.currentPodSnapshot.UpsertPodCacheWithNetns(uid, wl)
    	}
    	return nil
    }
    
    func realDependencies() *dep.RealDependencies {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  9. internal/grid/handlers.go

    	}
    	if h.callReuseReq {
    		defer h.recycleReq(req)
    	}
    	res, err := c.Request(ctx, h.id, payload)
    	PutByteBuffer(payload)
    	if err != nil {
    		return resp, err
    	}
    	defer PutByteBuffer(res)
    	r := h.NewResponse()
    	_, err = r.UnmarshalMsg(res)
    	if err != nil {
    		h.PutResponse(r)
    		return resp, err
    	}
    	return r, err
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
  10. cmd/object-api-utils.go

    func getDiskInfos(ctx context.Context, disks ...StorageAPI) []*DiskInfo {
    	res := make([]*DiskInfo, len(disks))
    	opts := DiskInfoOptions{}
    	for i, disk := range disks {
    		if disk == nil {
    			continue
    		}
    		if di, err := disk.DiskInfo(ctx, opts); err == nil {
    			res[i] = &di
    		}
    	}
    	return res
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
Back to top