- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for notification (0.25 sec)
-
docs/bucket/notifications/README.md
notify_webhook publish bucket notifications to webhook endpoints notify_amqp publish bucket notifications to AMQP endpoints notify_kafka publish bucket notifications to Kafka endpoints notify_mqtt publish bucket notifications to MQTT endpoints notify_nats publish bucket notifications to NATS endpoints notify_nsq publish bucket notifications to NSQ endpoints
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2) -
src/main/java/jcifs/smb/SmbTransportImpl.java
} else { Response notification = createNotification(key); if ( notification != null ) { log.debug("Parsing notification"); doRecv(notification); handleNotification(notification); return; } log.warn("Skipping message " + key);
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Wed Jan 18 23:47:00 GMT 2023 - 67K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java
setSystemProperty(Constants.NOTIFICATION_LOGIN, value); } default String getNotificationLogin() { return getSystemProperty(Constants.NOTIFICATION_LOGIN, StringUtil.EMPTY); } default String getNotificationAdvanceSearch() { return getSystemProperty(Constants.NOTIFICATION_ADVANCE_SEARCH, StringUtil.EMPTY); }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 85K bytes - Viewed (0) -
cmd/iam-store.go
return v, ok } return cache.iamUserPolicyMap.Load(name) } // GroupNotificationHandler - updates in-memory cache on notification of // change (e.g. peer notification for object storage and etcd watch // notification). func (store *IAMStoreSys) GroupNotificationHandler(ctx context.Context, group string) error { cache := store.lock() defer store.unlock()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/test-utils_test.go
return makeTestTargetURL(endPoint, bucketName, objectName, url.Values{}) } // return URL for inserting bucket notification. func getPutNotificationURL(endPoint, bucketName string) string { queryValue := url.Values{} queryValue.Set("notification", "") return makeTestTargetURL(endPoint, bucketName, "", queryValue) } // return URL for inserting bucket policy.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:06:57 GMT 2024 - 75.7K bytes - Viewed (0) -
cmd/api-errors.go
Description: "The transition storage class was not found", HTTPStatusCode: http.StatusNotFound, }, // Bucket notification related errors. ErrEventNotification: { Code: "InvalidArgument", Description: "A specified event is not supported for notifications.", HTTPStatusCode: http.StatusBadRequest, }, ErrARNNotification: { Code: "InvalidArgument",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 90.6K bytes - Viewed (6) -
guava/src/com/google/common/cache/CacheBuilder.java
* requested entries may be evicted on each cache modification. * * <p>If {@link #expireAfterWrite expireAfterWrite} or {@link #expireAfterAccess expireAfterAccess} * is requested entries may be evicted on each cache modification, on occasional cache accesses, or * on calls to {@link Cache#cleanUp}. Expired entries may be counted by {@link Cache#size}, but will
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 51.3K bytes - Viewed (0) -
cmd/batch-handlers.go
if err != nil { return err } xhttp.DrainBody(resp.Body) if resp.StatusCode != http.StatusOK { return errors.New(resp.Status) } return nil } // Notify notifies notification endpoint if configured regarding job failure or success. func (r BatchJobReplicateV1) Notify(ctx context.Context, ri *batchJobInfo) error { return notifyEndpoint(ctx, ri, r.Flags.Notify.Endpoint, r.Flags.Notify.Token) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/admin-handlers.go
} else { // Close ldap connection to avoid leaks. ldapConn.Close() ldap.Status = string(madmin.ItemOnline) } } log, audit := fetchLoggerInfo(ctx) // Get the notification target info notifyTarget := fetchLambdaInfo() local := getLocalServerProperty(globalEndpoints, r, metrics) servers := globalNotificationSys.ServerInfo(metrics) servers = append(servers, local)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/iam.go
} return roleArn, rolePolicy, nil } // DeletePolicy - deletes a canned policy from backend. `notifyPeers` is true // whenever this is called via the API. It is false when called via a // notification from another peer. This is to avoid infinite loops. func (sys *IAMSys) DeletePolicy(ctx context.Context, policyName string, notifyPeers bool) error { if !sys.Initialized() { return errServerNotInitialized }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1)