Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 79 for Drivers (0.04 seconds)

  1. internal/event/target/postgresql_test.go

    import (
    	"database/sql"
    	"slices"
    	"testing"
    )
    
    // TestPostgreSQLRegistration checks if postgres driver
    // is registered and fails otherwise.
    func TestPostgreSQLRegistration(t *testing.T) {
    	var found bool
    	if slices.Contains(sql.Drivers(), "postgres") {
    		found = true
    	}
    	if !found {
    		t.Fatal("postgres driver not registered")
    	}
    }
    
    func TestPsqlTableNameValidation(t *testing.T) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  2. internal/event/target/mysql_test.go

    import (
    	"database/sql"
    	"slices"
    	"testing"
    )
    
    // TestPostgreSQLRegistration checks if sql driver
    // is registered and fails otherwise.
    func TestMySQLRegistration(t *testing.T) {
    	var found bool
    	if slices.Contains(sql.Drivers(), "mysql") {
    		found = true
    	}
    	if !found {
    		t.Fatal("mysql driver not registered")
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 1.1K bytes
    - Click Count (0)
  3. cmd/ftp-server-driver.go

    	"github.com/minio/pkg/v3/mimedb"
    	ftp "goftp.io/server/v2"
    )
    
    var _ ftp.Driver = &ftpDriver{}
    
    // ftpDriver implements ftpDriver to store files in minio
    type ftpDriver struct {
    	endpoint string
    }
    
    // NewFTPDriver implements ftp.Driver interface
    func NewFTPDriver() ftp.Driver {
    	return &ftpDriver{endpoint: fmt.Sprintf("127.0.0.1:%s", globalMinioPort)}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  4. cmd/erasure-healing.go

    				xlMetaToHealCount++
    			}
    		}
    
    		driveState := objectErrToDriveState(reason)
    
    		result.Before.Drives = append(result.Before.Drives, madmin.HealDriveInfo{
    			UUID:     "",
    			Endpoint: storageEndpoints[i].String(),
    			State:    driveState,
    		})
    		result.After.Drives = append(result.After.Drives, madmin.HealDriveInfo{
    			UUID:     "",
    			Endpoint: storageEndpoints[i].String(),
    			State:    driveState,
    		})
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  5. cmd/erasure-heal_test.go

    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize())
    		}
    		_, err = erasure.Encode(t.Context(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  6. cmd/erasure-multipart.go

    	}
    
    	if len(buffer) > int(fi.Erasure.BlockSize) {
    		buffer = buffer[:fi.Erasure.BlockSize]
    	}
    	writers := make([]io.Writer, len(onlineDisks))
    	for i, disk := range onlineDisks {
    		if disk == nil {
    			continue
    		}
    		writers[i] = newBitrotWriter(disk, bucket, minioMetaTmpBucket, tmpPartPath, erasure.ShardFileSize(data.Size()), DefaultBitrotAlgorithm, erasure.ShardSize())
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  7. cmd/format-erasure.go

    				disks[i], len(formats), humanize.Ordinal(i+1), len(formatErasure.Erasure.Sets)*len(formatErasure.Erasure.Sets[0]))
    		}
    		if len(formatErasure.Erasure.Sets[0]) != setDriveCount {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  8. docs/distributed/README.md

    A stand-alone MinIO server would go down if the server hosting the drives goes offline. In contrast, a distributed MinIO setup with _m_ servers and _n_ drives will have your data safe as long as _m/2_ servers or _m*n_/2 or more drives are online.
    
    For example, an 16-server distributed setup with 200 drives per node would continue serving files, up to 4 servers can be offline in default configuration i.e around 800 drives down MinIO would continue to read and write objects.
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  9. cmd/peer-s3-server.go

    				Name:    v.Name,
    				Deleted: v.Created,
    			})
    		}
    		return true
    	})
    
    	return buckets, nil
    }
    
    func cloneDrives(drives map[string]StorageAPI) []StorageAPI {
    	copyDrives := make([]StorageAPI, 0, len(drives))
    	for _, drive := range drives {
    		copyDrives = append(copyDrives, drive)
    	}
    	return copyDrives
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  10. cmd/erasure-object.go

    			inlineBuffers[i] = bytes.NewBuffer(buf[:0])
    			defer grid.PutByteBuffer(buf)
    			writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    	}
    
    	n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum)
    	closeErrs := closeBitrotWriters(writers)
    	if erasureErr != nil {
    		return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
Back to Top