*
     * @return error count
     */
    public long getOperationErrors() {
        return operationErrors.get();
    }

    /**
     * Get total number of connections created
     *
     * @return connection count
     */
    public long getConnectionsCreated() {
        return connectionsCreated.get();
    }

    /**
     * Get number of currently active connections

```

## Create a bucket and upload some data

Create a bucket named `functionbucket`
```
mc alias set myminio/ http://localhost:9000 minioadmin minioadmin
mc mb myminio/functionbucket
```

Create a file `testobject` with some test data that will be transformed
```
cat > testobject << EOF

    /**
     * Create a new stopwords entry.
     *
     * @param form the create form containing the new entry data
     * @return HTML response redirecting to the list page after successful creation
     */
    @Execute
    @Secured({ ROLE })
    public HtmlResponse create(final CreateForm form) {
        verifyCrudMode(form.crudMode, CrudMode.CREATE, form.dictId);

     */
    public void setMaxAge(long maxAge) {
        this.maxAge = maxAge;
    }

    /**
     * Gets the timestamp when this cache entry was created
     * @return the create time
     */
    public long getCreateTime() {
        return createTime;
    }

    /**
     * Gets the timestamp of the last cache update
     * @return the last update time
     */

	if err := mkdirAll(pathJoin(diskPath, minioMetaTmpDeletedBucket), 0o777, diskPath); err != nil {
		storageLogIf(GlobalContext, fmt.Errorf("unable to create (%s) %w, drive may be faulty, please investigate",
			pathJoin(diskPath, minioMetaTmpBucket),
			err))
	}

	// Delete all temporary files created for DirectIO write check
	files, _ := filepath.Glob(filepath.Join(diskPath, ".writable-check-*.tmp"))
	for _, file := range files {

  }

  override fun finishRequest() {
    stream!!.sink.close()
  }

  override fun readResponseHeaders(expectContinue: Boolean): Response.Builder? {
    val stream = stream ?: throw IOException("stream wasn't created")
    val headers = stream.takeHeaders(callerIsIdle = expectContinue)
    val responseBuilder = readHttp2HeadersList(headers, protocol)
    return if (expectContinue && responseBuilder.code == HTTP_CONTINUE) {
      null

	defer tearDown()

	tests := []kmsTestCase{
		// Create key test
		{
			name:   "create key as user with no policy want forbidden",
			method: http.MethodPost,
			path:   kmsKeyCreatePath,
			query:  map[string]string{"key-id": "new-test-key"},
			asRoot: false,

			wantStatusCode: http.StatusForbidden,
			wantResp:       []string{"AccessDenied"},
		},
		{
			name:   "create key as user with no resources specified want success",

        // Test: create setting api.
        for (int i = 0; i < NUM; i++) {
            final Map<String, Object> requestBody = createTestParam(i);
            checkPostMethod(requestBody, getItemEndpointSuffix()).then()
                    .body("response.created", equalTo(true))
                    .body("response.status", equalTo(0));

///

## Import Pydantic's `BaseModel` { #import-pydantics-basemodel }

First, you need to import `BaseModel` from `pydantic`:

{* ../../docs_src/body/tutorial001_py310.py hl[2] *}

## Create your data model { #create-your-data-model }

Then you declare your data model as a class that inherits from `BaseModel`.

Use standard Python types for all the attributes:

{* ../../docs_src/body/tutorial001_py310.py hl[5:9] *}

        void testConfigurationHandling() {
            // Given - create a mock configuration
            Configuration testConfig = mock(Configuration.class);

            // When
            Smb2FlushResponse newResponse = new Smb2FlushResponse(testConfig);

            // Then
            assertNotNull(newResponse);
            // Verify the response was created successfully with the configuration