Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for define (0.21 sec)

  1. internal/logger/logrotate.go

    	return fmt.Sprintf("minio-%s.log", fmt.Sprintf("%X", time.Now().UTC().UnixNano()))
    }
    
    // Options define configuration options for Writer
    type Options struct {
    	// Directory defines the directory where log files will be written to.
    	// If the directory does not exist, it will be created.
    	Directory string
    
    	// MaximumFileSize defines the maximum size of each log file in bytes.
    	MaximumFileSize int64
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 11:38:40 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  2. internal/logger/reqinfo.go

    		r.tags = append(r.tags, KeyVal{key, val})
    	}
    	return r
    }
    
    // GetTags - returns the user defined tags
    func (r *ReqInfo) GetTags() []KeyVal {
    	if r == nil {
    		return nil
    	}
    	r.RLock()
    	defer r.RUnlock()
    	return append(make([]KeyVal, 0, len(r.tags)), r.tags...)
    }
    
    // GetTagsMap - returns the user defined tags in a map structure
    func (r *ReqInfo) GetTagsMap() map[string]interface{} {
    	if r == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  3. internal/http/listener.go

    	RecvBufSize int              // SO_RECVBUF size for the socket connection, NOTE: this sets server and client connection
    	Interface   string           // This is a VRF device passed via `--interface` flag
    	Trace       func(msg string) // Trace when starting.
    }
    
    // newHTTPListener - creates new httpListener object which is interface compatible to net.Listener.
    // httpListener is capable to
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  4. internal/grid/stream.go

    	// Canceling the context will cause the context cancellation error to be returned.
    	responses <-chan Response
    	cancel    context.CancelCauseFunc
    
    	// Requests sent to the server.
    	// If the handler is defined with 0 incoming capacity this will be nil.
    	// Channel *must* be closed to signal the end of the stream.
    	// If the request context is canceled, the stream will no longer process requests.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 28 18:05:18 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  5. cmd/warm-backend.go

    	InUse(ctx context.Context) (bool, error)
    }
    
    const probeObject = "probeobject"
    
    // checkWarmBackend checks if tier config credentials have sufficient privileges
    // to perform all operations defined in the WarmBackend interface.
    func checkWarmBackend(ctx context.Context, w WarmBackend) error {
    	remoteVersionID, err := w.Put(ctx, probeObject, strings.NewReader("MinIO"), 5)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  6. internal/handlers/proxy.go

    	xForwardedProto  = http.CanonicalHeaderKey("X-Forwarded-Proto")
    	xForwardedScheme = http.CanonicalHeaderKey("X-Forwarded-Scheme")
    	xRealIP          = http.CanonicalHeaderKey("X-Real-IP")
    )
    
    var (
    	// RFC7239 defines a new "Forwarded: " header designed to replace the
    	// existing use of X-Forwarded-* headers.
    	// e.g. Forwarded: for=192.0.2.60;proto=https;by=203.0.113.43
    	forwarded = http.CanonicalHeaderKey("Forwarded")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  7. internal/kms/single-key.go

    )
    
    // Parse parses s as single-key KMS. The given string
    // is expected to have the following format:
    //
    //	<key-id>:<base64-key>
    //
    // The returned KMS implementation uses the parsed
    // key ID and key to derive new DEKs and decrypt ciphertext.
    func Parse(s string) (KMS, error) {
    	v := strings.SplitN(s, ":", 2)
    	if len(v) != 2 {
    		return nil, errors.New("kms: invalid master key format")
    	}
    
    	keyID, b64Key := v[0], v[1]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  8. cmd/routers.go

    	// accordingly. Client receives a HTTP error for invalid/unsupported
    	// signatures.
    	//
    	// Validates all incoming requests to have a valid date header.
    	setAuthMiddleware,
    	// Redirect some pre-defined browser request paths to a static location
    	// prefix.
    	setBrowserRedirectMiddleware,
    	// Adds 'crossdomain.xml' policy middleware to serve legacy flash clients.
    	setCrossDomainPolicyMiddleware,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 3.6K bytes
    - Viewed (1)
  9. internal/config/errors.go

    		`MINIO_STORAGE_CLASS_STANDARD: Format "EC:<Default_Parity_Standard_Class>" (e.g. "EC:3"). This sets the number of parity drives for MinIO server in Standard mode. Objects are stored in Standard mode, if storage class is not defined in Put request
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 18 22:25:32 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  10. cmd/veeam-sos-api.go

    //     higher task limit).
    //
    //     <S3ConcurrentTaskLimit>
    //
    //   - Defines how many S3 operations are executed parallel within one Repository Task Slot (and within one backup object
    //     that gets offloaded). The same registry key setting overwrites the storage-defined setting.
    //     Optional value, default 64, range: 1-unlimited
    //
    //   - <S3MultiObjectDeleteLimit>
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 18:43:58 GMT 2024
    - 8.2K bytes
    - Viewed (2)
Back to top