Search Options

Results per page
Sort
Preferred Languages
Advance

Results 451 - 460 of 1,387 for funcs (0.03 sec)

  1. internal/bucket/versioning/error.go

    // the string as a value that satisfies error of type tagging.Error
    func Errorf(format string, a ...interface{}) error {
    	return Error{err: fmt.Errorf(format, a...)}
    }
    
    // Unwrap the internal error.
    func (e Error) Unwrap() error { return e.err }
    
    // Error 'error' compatible method.
    func (e Error) Error() string {
    	if e.err == nil {
    		return "versioning: cause <nil>"
    	}
    	return e.err.Error()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.3K bytes
    - Viewed (0)
  2. cmd/api-router.go

    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/rs/cors"
    )
    
    func newHTTPServerFn() *xhttp.Server {
    	globalObjLayerMutex.RLock()
    	defer globalObjLayerMutex.RUnlock()
    	return globalHTTPServer
    }
    
    func setHTTPServer(h *xhttp.Server) {
    	globalObjLayerMutex.Lock()
    	globalHTTPServer = h
    	globalObjLayerMutex.Unlock()
    }
    
    func newConsoleServerFn() *consoleapi.Server {
    	globalObjLayerMutex.RLock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  3. src/cmd/cgo/ast.go

    		f.ExpFunc = append(f.ExpFunc, &ExpFunc{
    			Func:    n,
    			ExpName: name,
    			Doc:     doc,
    		})
    		break
    	}
    }
    
    // Make f.ExpFunc[i] point at the Func from this AST instead of the other one.
    func (f *File) saveExport2(x interface{}, context astContext) {
    	n, ok := x.(*ast.FuncDecl)
    	if !ok {
    		return
    	}
    
    	for _, exp := range f.ExpFunc {
    		if exp.Func.Name.Name == n.Name.Name {
    			exp.Func = n
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 14 15:47:06 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  4. cmd/mrf.go

    // the current heal status in one available disk
    func (m *mrfState) shutdown() {
    	atomic.StoreInt32(&m.closing, 1)
    	m.wg.Wait()
    	close(m.opCh)
    	atomic.StoreInt32(&m.closed, 1)
    
    	if len(m.opCh) > 0 {
    		healingLogEvent(context.Background(), "Saving MRF healing data (%d entries)", len(m.opCh))
    	}
    
    	newReader := func() io.ReadCloser {
    		r, w := io.Pipe()
    		go func() {
    			// Initialize MRF meta header.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  5. cmd/background-newdisks-heal-ops.go

    	h.HealedBuckets = nil
    	h.Object = ""
    	h.Bucket = ""
    }
    
    func (h *healingTracker) getLastUpdate() time.Time {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.LastUpdate
    }
    
    func (h *healingTracker) getBucket() string {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.Bucket
    }
    
    func (h *healingTracker) setBucket(bucket string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  6. internal/grid/muxclient.go

    		m.closed = true
    	}
    }
    
    // respHandler
    func (m *muxClient) handleOneWayStream(respHandler chan<- Response, respServer <-chan Response) {
    	if debugPrint {
    		start := time.Now()
    		defer func() {
    			fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond))
    		}()
    	}
    	defer func() {
    		// addErrorNonBlockingClose will close the response channel
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  7. cmd/bucket-metadata.go

    	}
    
    	return
    }
    
    // Versioning returns true if versioning is enabled
    func (b BucketMetadata) Versioning() bool {
    	return b.LockEnabled || (b.versioningConfig != nil && b.versioningConfig.Enabled()) || (b.objectLockConfig != nil && b.objectLockConfig.Enabled())
    }
    
    // ObjectLocking returns true if object locking is enabled
    func (b BucketMetadata) ObjectLocking() bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  8. internal/config/batch/batch.go

    // would wait before working on next object.
    func (opts Config) ExpirationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return opts.ExpirationWorkersWait
    }
    
    // ReplicationWait returns the duration for which a batch replication worker
    // would wait before working on next object.
    func (opts Config) ReplicationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  9. cni/pkg/log/uds.go

    func (l *UDSLogger) StartUDSLogServer(sockAddress string, stop <-chan struct{}) error {
    	if sockAddress == "" {
    		return nil
    	}
    	log.Debugf("starting UDS server for CNI plugin logs")
    	unixListener, err := uds.NewListener(sockAddress)
    	if err != nil {
    		return fmt.Errorf("failed to create UDS listener: %v", err)
    	}
    	go func() {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/compare/comparator.go

    func (c *Comparator) Diff() error {
    	if err := c.ClusterDiff(); err != nil {
    		return err
    	}
    	if err := c.ListenerDiff(); err != nil {
    		return err
    	}
    	return c.RouteDiff()
    }
    
    // nonstrictResolver is an AnyResolver that ignores unknown proto messages
    type nonstrictResolver struct{}
    
    var envoyResolver nonstrictResolver
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 3.7K bytes
    - Viewed (0)
Back to top