Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 6,358 for RETURN (0.05 sec)

  1. internal/logger/target/kafka/kafka.go

    	if !h.kconfig.Enabled {
    		return nil
    	}
    	if err := h.validate(); err != nil {
    		return err
    	}
    	if h.kconfig.QueueDir != "" {
    		if err := h.initQueueStoreOnce.DoWithContext(ctx, h.initQueueStore); err != nil {
    			return err
    		}
    		return h.initKafkaOnce.Do(h.init)
    	}
    	if err := h.init(); err != nil {
    		return err
    	}
    	go h.startKafkaLogger()
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. internal/event/target/amqp.go

    )
    
    // Validate AMQP arguments
    func (a *AMQPArgs) Validate() error {
    	if !a.Enable {
    		return nil
    	}
    	if _, err := amqp091.ParseURI(a.URL.String()); err != nil {
    		return err
    	}
    	if a.QueueDir != "" {
    		if !filepath.IsAbs(a.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    	}
    
    	return nil
    }
    
    // AMQPTarget - AMQP target
    type AMQPTarget struct {
    	initOnce once.Init
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/CrawlingConfigHelper.java

                return ConfigType.DATA;
            }
            return null;
        }
    
        protected String getId(final String configId) {
            if (configId == null || configId.length() < 2) {
                return null;
            }
            return configId.substring(1);
        }
    
        public CrawlingConfig getCrawlingConfig(final String configId) {
            try {
                return crawlingConfigCache.get(configId, () -> {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/log/bsentity/dbmeta/FavoriteLogDbm.java

            return _columnCreatedAt;
        }
    
        public ColumnInfo columnDocId() {
            return _columnDocId;
        }
    
        public ColumnInfo columnQueryId() {
            return _columnQueryId;
        }
    
        public ColumnInfo columnUrl() {
            return _columnUrl;
        }
    
        public ColumnInfo columnUserInfoId() {
            return _columnUserInfoId;
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/config/bsentity/dbmeta/FileAuthenticationDbm.java

        }
    
        public ColumnInfo columnPassword() {
            return _columnPassword;
        }
    
        public ColumnInfo columnPort() {
            return _columnPort;
        }
    
        public ColumnInfo columnProtocolScheme() {
            return _columnProtocolScheme;
        }
    
        public ColumnInfo columnUpdatedBy() {
            return _columnUpdatedBy;
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  6. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/LegacyLocalRepositoryManager.java

                return !metadata.getVersion().isEmpty();
            }
    
            public boolean storedInGroupDirectory() {
                return metadata.getArtifactId().isEmpty();
            }
    
            public String getGroupId() {
                return nullify(metadata.getGroupId());
            }
    
            public String getArtifactId() {
                return nullify(metadata.getArtifactId());
            }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/MapMakerInternalMap.java

      E getEntry(@CheckForNull Object key) {
        if (key == null) {
          return null;
        }
        int hash = hash(key);
        return segmentFor(hash).getEntry(key, hash);
      }
    
      @Override
      public boolean containsKey(@CheckForNull Object key) {
        if (key == null) {
          return false;
        }
        int hash = hash(key);
        return segmentFor(hash).containsKey(key, hash);
      }
    
      @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  8. cmd/bucket-listobjects-handlers.go

    	if maxKeys < 0 {
    		return ErrInvalidMaxKeys
    	}
    
    	if encodingType != "" {
    		// AWS S3 spec only supports 'url' encoding type
    		if !strings.EqualFold(encodingType, "url") {
    			return ErrInvalidEncodingMethod
    		}
    	}
    
    	if !IsValidObjectPrefix(prefix) {
    		return ErrInvalidObjectName
    	}
    
    	if marker != "" && !HasPrefix(marker, prefix) {
    		return ErrNotImplemented
    	}
    
    	return ErrNone
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractConditionQuery.java

            return null;
        }
    
        @Override
        public int xgetNestLevel() {
            return 0;
        }
    
        @Override
        public int xgetNextNestLevel() {
            return 0;
        }
    
        @Override
        public boolean isBaseQuery() {
            return false;
        }
    
        @Override
        public String xgetForeignPropertyName() {
            return null;
        }
    
        @Override
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  10. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/MavenRepositorySystemSupplier.java

            checkClosed();
            if (pathProcessor == null) {
                pathProcessor = createPathProcessor();
            }
            return pathProcessor;
        }
    
        protected PathProcessor createPathProcessor() {
            return new DefaultPathProcessor();
        }
    
        private ChecksumProcessor checksumProcessor;
    
        public final ChecksumProcessor getChecksumProcessor() {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top