Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 341 for Unit (0.06 sec)

  1. internal/event/target/mqtt.go

    		}
    		if m.QoS == 0 {
    			return errors.New("qos should be set to 1 or 2 if queueDir is set")
    		}
    	}
    
    	return nil
    }
    
    // MQTTTarget - MQTT target.
    type MQTTTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       MQTTArgs
    	client     mqtt.Client
    	store      store.Store[event.Event]
    	quitCh     chan struct{}
    	loggerOnce logger.LogOnce
    }
    
    // ID - returns target ID.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  2. internal/init/init_darwin_amd64.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package init
    
    import (
    	"os"
    
    	"github.com/klauspost/cpuid/v2"
    )
    
    func init() {
    	// All MinIO operations must be under UTC.
    	os.Setenv("TZ", "UTC")
    
    	// Temporary workaround for
    	// https://github.com/golang/go/issues/49233
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Nov 04 23:44:38 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/DuplicateHostHelper.java

    public class DuplicateHostHelper {
        private static final Logger logger = LogManager.getLogger(DuplicateHostHelper.class);
    
        protected List<DuplicateHost> duplicateHostList;
    
        @PostConstruct
        public void init() {
            if (logger.isDebugEnabled()) {
                logger.debug("Initialize {}", this.getClass().getSimpleName());
            }
            if (duplicateHostList == null) {
                duplicateHostList = new ArrayList<>();
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  4. internal/event/target/kafka.go

    			return errors.New("batch commit timeout should be set only if queue dir is enabled and batch size > 1")
    		}
    	}
    	return nil
    }
    
    // KafkaTarget - Kafka target.
    type KafkaTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       KafkaArgs
    	client     sarama.Client
    	producer   sarama.SyncProducer
    	config     *sarama.Config
    	store      store.Store[event.Event]
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. cmd/bucket-quota.go

    // NewBucketQuotaSys returns initialized BucketQuotaSys
    func NewBucketQuotaSys() *BucketQuotaSys {
    	return &BucketQuotaSys{}
    }
    
    var bucketStorageCache = cachevalue.New[DataUsageInfo]()
    
    // Init initialize bucket quota.
    func (sys *BucketQuotaSys) Init(objAPI ObjectLayer) {
    	bucketStorageCache.InitOnce(10*time.Second,
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (DataUsageInfo, error) {
    			if objAPI == nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  6. cmd/metacache-manager.go

    var localMetacacheMgr = &metacacheManager{
    	buckets: make(map[string]*bucketMetacache),
    	trash:   make(map[string]metacache),
    }
    
    type metacacheManager struct {
    	mu      sync.RWMutex
    	init    sync.Once
    	buckets map[string]*bucketMetacache
    	trash   map[string]metacache // Recently deleted lists.
    }
    
    const metacacheMaxEntries = 5000
    
    // initManager will start async saving the cache.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  7. internal/event/target/redis.go

    			return fmt.Errorf("expected type %v does not match with available type %v", expectedType, typeAvailable)
    		}
    	}
    
    	return nil
    }
    
    // RedisTarget - Redis target.
    type RedisTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       RedisArgs
    	pool       *redis.Pool
    	store      store.Store[event.Event]
    	firstPing  bool
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/helper/PathMappingHelper.java

        protected final Map<String, List<PathMapping>> pathMappingMap = new HashMap<>();
    
        protected volatile List<PathMapping> cachedPathMappingList = null;
    
        @PostConstruct
        public void init() {
            if (logger.isDebugEnabled()) {
                logger.debug("Initialize {}", this.getClass().getSimpleName());
            }
            load();
        }
    
        @Override
        public int load() {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/curl/CurlTest.java

                TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
                trustManagerFactory.init(keyStore);
    
                SSLContext sslContext = SSLContext.getInstance("TLS");
                sslContext.init(null, trustManagerFactory.getTrustManagers(), null);
    
                Curl.get("https://localhost:9200/").sslSocketFactory(sslContext.getSocketFactory()).execute(response -> {
    Registered: Sun Oct 27 04:35:21 UTC 2024
    - Last Modified: Mon Nov 14 21:05:19 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  10. internal/event/target/postgresql.go

    		return errors.New("maxOpenConnections cannot be less than zero")
    	}
    
    	return nil
    }
    
    // PostgreSQLTarget - PostgreSQL target.
    type PostgreSQLTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       PostgreSQLArgs
    	updateStmt *sql.Stmt
    	deleteStmt *sql.Stmt
    	insertStmt *sql.Stmt
    	db         *sql.DB
    	store      store.Store[event.Event]
    	firstPing  bool
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top