- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 341 for Unit (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)