Queries("versioning", "")
		// GetBucketNotification
		router.Methods(http.MethodGet).
			HandlerFunc(s3APIMiddleware(api.GetBucketNotificationHandler)).
			Queries("notification", "")
		// ListenNotification
		router.Methods(http.MethodGet).
			HandlerFunc(s3APIMiddleware(api.ListenNotificationHandler, noThrottleS3HFlag, traceHdrsS3HFlag)).
			Queries("events", "{events:.*}")

{* ../../docs_src/background_tasks/tutorial001_py310.py hl[14] *}

`.add_task()` 的引數包括：

* 要在背景執行的任務函式（`write_notification`）。
* 依序傳給任務函式的位置引數（`email`）。
* 要傳給任務函式的關鍵字引數（`message="some notification"`）。

## 相依性注入 { #dependency-injection }

在相依性注入系統中也可使用 `BackgroundTasks`。你可以在多個層級宣告 `BackgroundTasks` 型別的參數：路徑操作函式、相依項（dependable）、次級相依項等。

**FastAPI** 會在各種情況下正確處理並重用同一個物件，將所有背景任務合併，並在之後於背景執行：

        // Verify flags (RECURSIVE_TREE + NOTIFICATIONS)
        int expectedFlags = DirectoryLeaseContext.DIRECTORY_LEASE_FLAG_RECURSIVE | DirectoryLeaseContext.DIRECTORY_LEASE_FLAG_NOTIFICATIONS;
        assertEquals(expectedFlags, SMBUtil.readInt4(buffer, 68));

        // Verify notification filter
        assertEquals(0x1F, SMBUtil.readInt4(buffer, 72));
    }

    @Test

                List<WitnessAsyncNotifyMessage.WitnessNotificationResponse> notifications = message.getNotifications();
                if (!notifications.isEmpty()) {
                    log.debug("Received {} notifications", notifications.size());
                    return notifications.get(0); // Return first notification
                }
            } else {

    AtomicInteger totalSum = new AtomicInteger();

    RemovalListener<Integer, AtomicInteger> removalListener =
        notification -> {
          if (notification.wasEvicted()) {
            evictionCount.incrementAndGet();
            totalSum.addAndGet(notification.getValue().get());
          }
        };

    CacheLoader<Integer, AtomicInteger> loader =

        assertFalse(entry1.hasChild("subfolder"));
        assertTrue(entry2.hasChild("subfolder"));
        assertFalse(entry2.hasChild("document.txt"));

        // Test individual change notification
        directoryLeaseManager.handleDirectoryChange(dir1, "document.txt", DirectoryChangeNotifier.DirectoryChangeType.FILE_REMOVED);

        // Only first directory should be affected

package event

import (
	"encoding/json"
	"encoding/xml"
)

// Name - event type enum.
// Refer http://docs.aws.amazon.com/AmazonS3/latest/dev/NotificationHowTo.html#notification-how-to-event-types-and-destinations
// for most basic values we have since extend this and its not really much applicable other than a reference point.
// "s3:Replication:OperationCompletedReplication" is a MinIO extension.

	auditCollectorPath         collectorPath = "/audit"
	loggerWebhookCollectorPath collectorPath = "/logger/webhook"
	replicationCollectorPath   collectorPath = "/replication"
	notificationCollectorPath  collectorPath = "/notification"
	scannerCollectorPath       collectorPath = "/scanner"
)

const (
	clusterBasePath = "/cluster"
)

type metricsV3Collection struct {
	mgMap       map[collectorPath]*MetricsGroup

	}:
	case <-list.ctx.Done():
		list.eventsSkipped.Add(int64(len(list.queue)))
		return
	default:
		list.eventsSkipped.Add(1)
		err := fmt.Errorf("concurrent target notifications exceeded %d, configured notification target is too slow to accept events for the incoming request rate", maxConcurrentAsyncSend)
		for id := range targetIDset {
			reqInfo := &logger.ReqInfo{}
			reqInfo.AppendTags("targetID", id.String())

		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()