Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for getFs (0.12 sec)

  1. internal/kms/policy-manager.go

    	// DescribePolicy describes a policy by returning its metadata.
    	// e.g. who created the policy at which point in time.
    	DescribePolicy(ctx context.Context, policy string) (*kes.PolicyInfo, error)
    
    	// GetPolicy gets a policy from KMS.
    	GetPolicy(ctx context.Context, policy string) (*kes.Policy, error)
    
    	// ListPolicies lists all policies.
    	ListPolicies(ctx context.Context) (*kes.ListIter[string], error)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 1.3K bytes
    - Viewed (0)
  2. internal/s3select/simdj/record.go

    	"github.com/minio/minio/internal/s3select/sql"
    	"github.com/minio/simdjson-go"
    )
    
    // Record - is JSON record.
    type Record struct {
    	// object
    	object simdjson.Object
    }
    
    // Get - gets the value for a column name.
    func (r *Record) Get(name string) (*sql.Value, error) {
    	elem := r.object.FindKey(name, nil)
    	if elem == nil {
    		return nil, nil
    	}
    	return iterToValue(elem.Iter)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  3. docs/docker/README.md

    MinIO needs a persistent volume to store configuration and application data. For testing purposes, you can launch MinIO by simply passing a directory (`/data` in the example below). This directory gets created in the container filesystem at the time of container start. But all the data is lost after container exits.
    
    ```sh
    docker run \
      -p 9000:9000 \
      -p 9001:9001 \
      -e "MINIO_ROOT_USER=AKIAIOSFODNN7EXAMPLE" \
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 8.2K bytes
    - Viewed (0)
  4. internal/bpool/bpool.go

    // Populate - populates and pre-warms the byte pool, this function is non-blocking.
    func (bp *BytePoolCap) Populate() {
    	for _, buf := range reedsolomon.AllocAligned(cap(bp.c), bp.wcap) {
    		bp.Put(buf[:bp.w])
    	}
    }
    
    // Get gets a []byte from the BytePool, or creates a new one if none are
    // available in the pool.
    func (bp *BytePoolCap) Get() (b []byte) {
    	if bp == nil {
    		return nil
    	}
    	select {
    	case b = <-bp.c:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  5. CONTRIBUTING.md

    ```
    
    ### Create a Pull Request
    
    Pull requests can be created via GitHub. Refer to [this document](https://help.github.com/articles/creating-a-pull-request/) for detailed steps on how to create a pull request. After a Pull Request gets peer reviewed and approved, it will be merged.
    
    ## FAQs
    
    ### How does ``MinIO`` manage dependencies?
    
    ``MinIO`` uses `go mod` to manage its dependencies.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 2.8K bytes
    - Viewed (0)
  6. internal/s3select/csv/record.go

    	"github.com/minio/minio/internal/s3select/sql"
    )
    
    // Record - is a CSV record.
    type Record struct {
    	columnNames  []string
    	csvRecord    []string
    	nameIndexMap map[string]int64
    }
    
    // Get - gets the value for a column name. CSV fields do not have any
    // defined type (other than the default string). So this function
    // always returns fields using sql.FromBytes so that the type
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Sep 13 00:00:59 GMT 2022
    - 4.1K bytes
    - Viewed (0)
  7. internal/config/cache/cache.go

    	}
    
    	if c.Endpoint == "" {
    		// Endpoint not set, make this a no-op
    		return nil, nil
    	}
    
    	buf, err := r.MarshalMsg(nil)
    	if err != nil {
    		return nil, err
    	}
    
    	// We do not want Gets to take so much time, anything
    	// beyond 250ms we should cut it, remote cache is too
    	// busy already.
    	ctx, cancel := context.WithTimeout(context.Background(), 250*time.Millisecond)
    	defer cancel()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  8. cmd/bucket-encryption.go

    type BucketSSEConfigSys struct{}
    
    // NewBucketSSEConfigSys - Creates an empty in-memory bucket encryption configuration cache
    func NewBucketSSEConfigSys() *BucketSSEConfigSys {
    	return &BucketSSEConfigSys{}
    }
    
    // Get - gets bucket encryption config for the given bucket.
    func (sys *BucketSSEConfigSys) Get(bucket string) (*sse.BucketSSEConfig, error) {
    	sseCfg, _, err := globalBucketMetadataSys.GetSSEConfig(bucket)
    	return sseCfg, err
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 1.7K bytes
    - Viewed (0)
  9. docs/federation/lookup/README.md

    points to the public IP address where each cluster might be accessible, this is unique for each cluster.
    
    NOTE: `mybucket` only exists on one cluster either `cluster1` or `cluster2` this is random and
    is decided by how `domain.com` gets resolved, if there is a round-robin DNS on `domain.com` then
    it is randomized which cluster might provision the bucket.
    
    ### 3. Test your setup
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 4K bytes
    - Viewed (0)
  10. internal/bucket/bandwidth/monitor.go

    }
    
    // BucketBandwidthReport captures the details for all buckets.
    type BucketBandwidthReport struct {
    	BucketStats map[BucketOptions]Details `json:"bucketStats,omitempty"`
    }
    
    // GetReport gets the report for all bucket bandwidth details.
    func (m *Monitor) GetReport(selectBucket SelectionFunction) *BucketBandwidthReport {
    	m.mlock.RLock()
    	defer m.mlock.RUnlock()
    	return m.getReport(selectBucket)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 6K bytes
    - Viewed (0)
Back to top