Search Options

Results per page
Sort
Preferred Languages
Advance

Results 691 - 700 of 1,423 for Func (0.03 sec)

  1. cmd/healthcheck-handler.go

    package cmd
    
    import (
    	"context"
    	"net/http"
    	"strconv"
    	"time"
    
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/kms"
    )
    
    const unavailable = "offline"
    
    func checkHealth(w http.ResponseWriter) ObjectLayer {
    	objLayer := newObjectLayerFn()
    	if objLayer == nil {
    		w.Header().Set(xhttp.MinIOServerStatus, unavailable)
    		writeResponse(w, http.StatusServiceUnavailable, nil, mimeNone)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. cmd/httprange.go

    func (h *HTTPRangeSpec) String(resourceSize int64) string {
    	if h == nil {
    		return ""
    	}
    	off, length, err := h.GetOffsetLength(resourceSize)
    	if err != nil {
    		return ""
    	}
    	return fmt.Sprintf("%d-%d", off, off+length-1)
    }
    
    // ToHeader returns the Range header value.
    func (h *HTTPRangeSpec) ToHeader() (string, error) {
    	if h == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 08:44:07 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. cmd/warm-backend-minio.go

    		UserMetadata:         meta,
    	})
    	return remoteVersionID(res.VersionID), m.ToObjectError(err, object)
    }
    
    func (m *warmBackendMinIO) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    	return m.PutWithMeta(ctx, object, r, length, map[string]string{})
    }
    
    func newWarmBackendMinIO(conf madmin.TierMinIO, tier string) (*warmBackendMinIO, error) {
    	// Validation of credentials
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. internal/bucket/replication/filter.go

    	cachedTags map[string]string
    }
    
    // IsEmpty returns true if filter is not set
    func (f Filter) IsEmpty() bool {
    	return f.And.isEmpty() && f.Tag.IsEmpty() && f.Prefix == ""
    }
    
    // MarshalXML - produces the xml representation of the Filter struct
    // only one of Prefix, And and Tag should be present in the output.
    func (f Filter) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 28 18:25:46 UTC 2022
    - 3.5K bytes
    - Viewed (0)
  5. internal/mountinfo/mountinfo_linux.go

    }
    
    // CheckCrossDevice - check if any list of paths has any sub-mounts at /proc/mounts.
    func CheckCrossDevice(absPaths []string) error {
    	return checkCrossDevice(absPaths, procMountsPath)
    }
    
    // Check cross device is an internal function.
    func checkCrossDevice(absPaths []string, mountsPath string) error {
    	mounts, err := readProcMounts(mountsPath)
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.7K bytes
    - Viewed (0)
  6. src/bufio/export_test.go

    )
    
    var IsSpace = isSpace
    
    const DefaultBufSize = defaultBufSize
    
    func (s *Scanner) MaxTokenSize(n int) {
    	if n < utf8.UTFMax || n > 1e9 {
    		panic("bad max token size")
    	}
    	if n < len(s.buf) {
    		s.buf = make([]byte, n)
    	}
    	s.maxTokenSize = n
    }
    
    // ErrOrEOF is like Err, but returns EOF. Used to test a corner case.
    func (s *Scanner) ErrOrEOF() error {
    	return s.err
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Nov 02 17:17:44 UTC 2017
    - 597 bytes
    - Viewed (0)
  7. internal/bucket/lifecycle/tag.go

    			default:
    				return errUnknownXMLTag
    			}
    		}
    	}
    
    	return nil
    }
    
    func (tag Tag) String() string {
    	return tag.Key + "=" + tag.Value
    }
    
    // IsEmpty returns whether this tag is empty or not.
    func (tag Tag) IsEmpty() bool {
    	return tag.Key == ""
    }
    
    // Validate checks this tag.
    func (tag Tag) Validate() error {
    	if len(tag.Key) == 0 || utf8.RuneCountInString(tag.Key) > 128 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/error.go

    )
    
    var ErrPartialAdd = errors.New("partial add error")
    
    type PartialAddError struct {
    	inner error
    }
    
    func (e *PartialAddError) Error() string {
    	return fmt.Sprintf("%s: %v", ErrPartialAdd.Error(), e.inner)
    }
    
    func (e *PartialAddError) Unwrap() []error {
    	return []error{ErrPartialAdd, e.inner}
    }
    
    func NewErrPartialAdd(err error) *PartialAddError {
    	return &PartialAddError{
    		inner: err,
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1K bytes
    - Viewed (0)
  9. cni/pkg/install/cniconfig_test.go

    			CNIConfName:      c.specifiedConfName,
    			ChainedCNIPlugin: c.chainedCNIPlugin,
    			PluginLogLevel:   "debug",
    			CNIAgentRunDir:   kubeconfigFilename,
    		}
    		test := func(cfg config.InstallConfig) func(t *testing.T) {
    			return func(t *testing.T) {
    				// Create temp directory for files
    				tempDir := t.TempDir()
    
    				// Create existing config files if specified in test case
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  10. cmd/rebalancemetric_string.go

    // Code generated by "stringer -type=rebalanceMetric -trimprefix=rebalanceMetric erasure-server-pool-rebalance.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[rebalanceMetricRebalanceBuckets-0]
    	_ = x[rebalanceMetricRebalanceBucket-1]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 19:36:57 UTC 2022
    - 988 bytes
    - Viewed (0)
Back to top