Search Options

Results per page
Sort
Preferred Languages
Advance

Results 351 - 360 of 938 for Nil (0.04 sec)

  1. schema/index.go

    }
    
    func (schema *Schema) LookIndex(name string) *Index {
    	if schema != nil {
    		indexes := schema.ParseIndexes()
    		for _, index := range indexes {
    			if index.Name == name {
    				return &index
    			}
    
    			for _, field := range index.Fields {
    				if field.Name == name {
    					return &index
    				}
    			}
    		}
    	}
    
    	return nil
    }
    
    func parseFieldIndexes(field *Field) (indexes []Index, err error) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sun Feb 04 07:49:19 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  2. internal/grid/handlers.go

    }
    
    func (h *handlers) hasAny(id HandlerID) bool {
    	if !id.valid() {
    		return false
    	}
    	return h.single[id] != nil || h.stateless[id] != nil || h.streams[id] != nil
    }
    
    func (h *handlers) hasSubhandler(id subHandlerID) bool {
    	return h.subSingle[id] != nil || h.subStateless[id] != nil || h.subStreams[id] != nil
    }
    
    // RoundTripper provides an interface for type roundtrip serialization.
    type RoundTripper interface {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  3. docs/sts/ldap.go

    	if err != nil {
    		log.Fatalf("Error initializing LDAP Identity: %v", err)
    	}
    
    	stsEndpointURL, err := url.Parse(stsEndpoint)
    	if err != nil {
    		log.Fatalf("Error parsing sts endpoint: %v", err)
    	}
    
    	opts := &minio.Options{
    		Creds:  li,
    		Secure: stsEndpointURL.Scheme == "https",
    	}
    
    	v, err := li.Get()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 07 12:59:47 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. cmd/metacache-walk.go

    		if contextCanceled(ctx) {
    			return ctx.Err()
    		}
    		if opts.Limit > 0 && objsReturned >= opts.Limit {
    			return nil
    		}
    
    		if s.walkMu != nil {
    			s.walkMu.Lock()
    		}
    		entries, err := s.ListDir(ctx, "", opts.Bucket, current, -1)
    		if s.walkMu != nil {
    			s.walkMu.Unlock()
    		}
    		if err != nil {
    			// Folder could have gone away in-between
    			if err != errVolumeNotFound && err != errFileNotFound {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  5. internal/http/server.go

    		listenCtx,
    		srv.Addrs,
    		srv.TCPOptions,
    	)
    
    	var interfaceFound bool
    	for i := range listenErrs {
    		if listenErrs[i] != nil {
    			listenErrCallback(srv.Addrs[i], listenErrs[i])
    		} else {
    			interfaceFound = true
    		}
    	}
    	if !interfaceFound {
    		return nil, errors.New("no available interface found")
    	}
    
    	// Wrap given handler to do additional
    	// * return 503 (service unavailable) if the server in shutdown.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. internal/event/target/mqtt.go

    func (target *MQTTTarget) SendFromStore(key store.Key) error {
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	// Do not send if the connection is not active.
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	eventData, err := target.store.Get(key)
    	if err != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  7. src/cmd/buildid/buildid.go

    	id, err := buildid.ReadFile(file)
    	if err != nil {
    		log.Fatal(err)
    	}
    	if !*wflag {
    		fmt.Printf("%s\n", id)
    		return
    	}
    
    	// Keep in sync with src/cmd/go/internal/work/buildid.go:updateBuildID
    
    	f, err := os.Open(file)
    	if err != nil {
    		log.Fatal(err)
    	}
    	matches, hash, err := buildid.FindAndHash(f, id, 0)
    	f.Close()
    	if err != nil {
    		log.Fatal(err)
    	}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  8. internal/grid/grid.go

    		}
    		n, err := r.Read(b[len(b):cap(b)])
    		b = b[:len(b)+n]
    		if err != nil {
    			if errors.Is(err, io.EOF) {
    				if want >= 0 && read+int64(n) != want {
    					return nil, io.ErrUnexpectedEOF
    				}
    				err = nil
    			}
    			return b, err
    		}
    		read += int64(n)
    		if want >= 0 && read == want {
    			// No need to read more...
    			return b, nil
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. internal/logger/target/http/http.go

    func (h *Target) Send(ctx context.Context, entry interface{}) error {
    	if h.status.Load() == statusClosed {
    		if h.migrateTarget != nil {
    			return h.migrateTarget.Send(ctx, entry)
    		}
    		return nil
    	}
    
    	h.logChMu.RLock()
    	defer h.logChMu.RUnlock()
    	if h.logCh == nil {
    		// We are closing...
    		return nil
    	}
    
    	select {
    	case h.logCh <- entry:
    		h.totalMessages.Add(1)
    	case <-ctx.Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  10. cmd/erasure-metadata-utils.go

    	if len(errs) != len(disks) {
    		bugLogIf(GlobalContext, errors.New("unexpected drives/errors slice length"))
    		return nil
    	}
    	newDisks := make([]StorageAPI, len(disks))
    	for index := range errs {
    		if errs[index] == nil {
    			newDisks[index] = disks[index]
    		} else {
    			newDisks[index] = nil
    		}
    	}
    	return newDisks
    }
    
    // Errors specifically generated by calculatePartSizeFromIdx function.
    var (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
Back to top