- Sort Score
- Result 10 results
- Languages All
Results 761 - 770 of 881 for exists (0.08 sec)
-
internal/event/target/mqtt.go
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() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(err) { return nil } return err } if err = target.send(eventData); err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.2K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/project/artifact/DefaultMavenMetadataCache.java
if (pomFile.canRead()) { return length != pomFile.length() || timestamp != pomFile.lastModified(); } else { // if the POM didn't exist, retry if any repo is configured to always update boolean snapshot = pomArtifact.isSnapshot(); for (ArtifactRepository repository : remoteRepositories) {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 11.8K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/exception/DefaultExceptionHandler.java
- artifact metadata retrieval problem - version range violation - circular dependency - artifact missing - artifact retrieval exception - md5 checksum doesn't match for local artifact, need to redownload this - POM doesn't exist for a goal that requires one - parent POM missing (in both the repository + relative path) - component not found Plugins: - plugin metadata missing - plugin metadata retrieval problem - plugin artifact missing
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 10.9K bytes - Viewed (0) -
internal/event/target/kafka.go
var event event.Event event, 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() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(err) { return nil } return err } err = target.send(event) case key.ItemCount > 1: var events []event.Event
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0) -
SECURITY.md
### Resource allocation A denial of service caused by one model could bring down the entire server, but we don't consider this as a vulnerability, given that models can exhaust resources in many different ways and solutions exist to prevent this from happening (e.g., rate limits, ACLs, monitors to restart broken servers). ### Model sharing If the multitenant design allows sharing models, make sure that tenants and
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Oct 16 16:10:43 UTC 2024 - 9.6K bytes - Viewed (0) -
docs/fr/README.md
## Site Web [fess.codelibs.org](https://fess.codelibs.org/) ## Problèmes/Questions [discuss.codelibs.org](https://discuss.codelibs.org/c/FessEN/) ## Démarrage rapide Il existe 2 manières d'essayer Fess. La première est de le télécharger et l'installer vous-même. La seconde est d'utiliser [Docker](https://www.docker.com/products/docker-engine). ### Télécharger et Installer/Exécuter
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Oct 12 07:19:47 UTC 2024 - 7.9K bytes - Viewed (0) -
internal/config/dns/etcd_dns.go
} srvRecord.Key = strings.TrimPrefix(string(n.Key), key) srvRecord.Key = strings.TrimSuffix(srvRecord.Key, srvRecord.Host) // Skip non-bucket entry like for a key // /skydns/net/miniocloud/10.0.0.1 that may exist as // dns entry for the server (rather than the bucket // itself). if srvRecord.Key == "" { continue } srvRecord.Key = msgUnPath(srvRecord.Key) srvRecords = append(srvRecords, srvRecord)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 15:03:08 UTC 2024 - 8K bytes - Viewed (0) -
internal/config/identity/openid/jwt.go
) func updateClaimsExpiry(dsecs string, claims map[string]interface{}) error { expStr := claims["exp"] if expStr == "" { return ErrTokenExpired } // No custom duration requested, the claims can be used as is. if dsecs == "" { return nil } if _, err := auth.ExpToInt64(expStr); err != nil { return err } defaultExpiryDuration, err := GetDefaultExpiration(dsecs)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 02:46:36 UTC 2024 - 8.4K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux_test.go
if !mountPointsEqual(mounts[2], mp) { t.Errorf("got unexpected mountInfo[2]: %#v", mounts[2]) } } // Failure case mounts path doesn't exist, if not fail. { if _, err = readProcMounts(filepath.Join(dir, "non-existent")); err != nil && !os.IsNotExist(err) { t.Fatal(err) } } } // Tests read proc mounts reader.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 7.3K bytes - Viewed (0) -
internal/event/target/redis.go
} eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and would've been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil { if xnet.IsConnRefusedErr(err) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 9.1K bytes - Viewed (0)