- Sort Score
- Result 10 results
- Languages All
Results 631 - 640 of 1,170 for such (0.11 sec)
-
internal/event/target/amqp.go
return err } defer ch.Close() 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 wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData, ch, confirms); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10K bytes - Viewed (0) -
cmd/net.go
// Strip off IPv6 zone information. if i := strings.Index(host, "%"); i > -1 { host = host[:i] } return net.ParseIP(host) != nil } // extractHostPort - extracts host/port from many address formats // such as, ":9000", "localhost:9000", "http://localhost:9000/" func extractHostPort(hostAddr string) (string, string, error) { var addr, scheme string if hostAddr == "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 14:34:00 UTC 2024 - 9.6K bytes - Viewed (0) -
misc/cgo/gmp/gmp.go
y.doinit() C.mpz_tdiv_qr(&q.i[0], &r.i[0], &x.i[0], &y.i[0]) } // GcdInt sets d to the greatest common divisor of a and b, // which must be positive numbers. // If x and y are not nil, GcdInt sets x and y such that d = a*x + b*y. // If either a or b is not positive, GcdInt sets d = x = y = 0. func GcdInt(d, x, y, a, b *Int) { d.doinit() x.doinit() y.doinit() a.doinit() b.doinit()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Apr 11 16:34:30 UTC 2022 - 9.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* @since 13.0 */ void addListener(Listener listener, Executor executor); /** * The lifecycle states of a service. * * <p>The ordering of the {@link State} enum is defined such that if there is a state transition * from {@code A -> B} then {@code A.compareTo(B) < 0}. N.B. The converse is not true, i.e. if * {@code A.compareTo(B) < 0} then there is <b>not</b> guaranteed to be a valid state transition
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 10.7K bytes - Viewed (0) -
internal/event/target/kafka.go
case key.ItemCount == 1: 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:
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
targets of those operations, which could result in arbitrary read/write/executions. ### Running a TensorFlow server TensorFlow is a platform for distributed computing, and as such there is a TensorFlow server (`tf.train.Server`). The TensorFlow server is intended for internal communication only. It is not built for use in untrusted environments or networks.
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Oct 16 16:10:43 UTC 2024 - 9.6K bytes - Viewed (0) -
cmd/object-handlers.go
// whether you also have the s3:ListBucket // permission. // * If you have the s3:ListBucket permission // on the bucket, Amazon S3 will return an // HTTP status code 404 ("no such key") // error. // * if you don’t have the s3:ListBucket // permission, Amazon S3 will return an HTTP // status code 403 ("access denied") error.` if globalPolicySys.IsAllowed(policy.BucketPolicyArgs{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 05 05:16:15 UTC 2024 - 117.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CloserTest.java
Closer closer = Closer.create(); closer.register(null); closer.close(); } /** * Asserts that an exception was thrown when trying to close each of the given throwables and that * each such exception was suppressed because of the given thrown exception. */ private void assertSuppressed(Suppression... expected) { assertEquals(ImmutableList.copyOf(expected), suppressor.suppressions); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 07 15:26:58 UTC 2024 - 11.8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/Dfs.java
share = path.substring(s1 + 1, s2); key = path.substring(0, dr.pathConsumed).toLowerCase(); /* Samba has a tendency to return referral paths and pathConsumed values * in such a way that there can be a slash at the end of the path. This * causes problems matching keys in resolve() where an extra slash causes * a mismatch. This strips trailing slashes from all keys to eliminate
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 11.7K bytes - Viewed (0) -
docs/lambda/README.md
might include personally identifiable information (PII). When the same data is processed for analytics, PII should be redacted. However, if the same dataset is used for a marketing campaign, you might need to enrich the data with additional details, such as information from the customer loyalty database. MinIO's Object Lambda, enables application developers to process data retrieved from MinIO before returning it to an application. You can register a Lambda Function target on MinIO, once successfully...
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Apr 04 19:15:28 UTC 2023 - 7.6K bytes - Viewed (0)