public CrawlingInfoCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsCrawlingInfoCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (CrawlingInfoCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

    public CrawlingInfoParamCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsCrawlingInfoParamCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (CrawlingInfoParamCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

    @Override
    public void finish(int exitCode) throws Exception {}

    @Override
    public void fail(Throwable t) throws Exception {}

    @Override
    public void log(String msg) {
        output.accept(msg);
    }

    @Override
    public void transfer(String projectId, TransferEvent e) {}

    </body>
</html>
"""


class ConnectionManager:
    def __init__(self):
        self.active_connections: list[WebSocket] = []

    async def connect(self, websocket: WebSocket):
        await websocket.accept()
        self.active_connections.append(websocket)

    def disconnect(self, websocket: WebSocket):
        self.active_connections.remove(websocket)

Example: Limit a MinIO cluster to accept at max 1600 simultaneous S3 API requests across all nodes of the cluster.

```sh
export MINIO_API_REQUESTS_MAX=1600
export MINIO_ROOT_USER=your-access-key
export MINIO_ROOT_PASSWORD=your-secret-key

    public BoostDocumentRuleCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsBoostDocumentRuleCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (BoostDocumentRuleCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

    public FileAuthenticationCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsFileAuthenticationCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (FileAuthenticationCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

    public KeyMatchCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsKeyMatchCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (KeyMatchCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

    public LabelTypeCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsLabelTypeCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (LabelTypeCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }

    public RequestHeaderCB acceptPK(String id) {
        assertObjectNotNull("id", id);
        BsRequestHeaderCB cb = this;
        cb.query().docMeta().setId_Equal(id);
        return (RequestHeaderCB) this;
    }

    @Override
    public void acceptPrimaryKeyMap(Map<String, ? extends Object> primaryKeyMap) {
        acceptPK((String) primaryKeyMap.get("_id"));
    }