Search Options

Results per page
Sort
Preferred Languages
Advance

Results 571 - 580 of 1,384 for funcs (0.03 sec)

  1. internal/s3select/select_benchmark_test.go

    	return buf.Bytes()
    }
    
    type nullResponseWriter struct{}
    
    func (w *nullResponseWriter) Header() http.Header {
    	return nil
    }
    
    func (w *nullResponseWriter) Write(p []byte) (int, error) {
    	return len(p), nil
    }
    
    func (w *nullResponseWriter) WriteHeader(statusCode int) {
    }
    
    func (w *nullResponseWriter) Flush() {
    }
    
    func benchmarkSelect(b *testing.B, count int, query string) {
    	requestXML := []byte(`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 14 13:54:47 UTC 2022
    - 5K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-v1.go

    // format version and erasure coding information.
    func (m *xlMetaV1Object) valid() bool {
    	return isXLMetaFormatValid(m.Version, m.Format) &&
    		isXLMetaErasureInfoValid(m.Erasure.DataBlocks, m.Erasure.ParityBlocks)
    }
    
    // Verifies if the backend format metadata is sane by validating
    // the version string and format style.
    func isXLMetaFormatValid(version, format string) bool {
    	return ((version == xlMetaVersion101 ||
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. cni/pkg/iptables/iptables_unspecified.go

    package iptables
    
    import (
    	"errors"
    )
    
    func AddInpodMarkIPRule(cfg *Config) error {
    	return errors.New("not implemented on this platform")
    }
    
    func DelInpodMarkIPRule(cfg *Config) error {
    	return errors.New("not implemented on this platform")
    }
    
    func AddLoopbackRoutes(cfg *Config) error {
    	return errors.New("not implemented on this platform")
    }
    
    func DelLoopbackRoutes(cfg *Config) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1K bytes
    - Viewed (0)
  4. cmd/endpoint_contrib_test.go

     */
    
    package cmd
    
    import (
    	"testing"
    
    	"github.com/minio/minio-go/v7/pkg/set"
    )
    
    func TestUpdateDomainIPs(t *testing.T) {
    	tempGlobalMinioPort := globalMinioPort
    	defer func() {
    		globalMinioPort = tempGlobalMinioPort
    	}()
    	globalMinioPort = "9000"
    
    	tempGlobalDomainIPs := globalDomainIPs
    	defer func() {
    		globalDomainIPs = tempGlobalDomainIPs
    	}()
    
    	ipv4TestCases := []struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 30 15:50:39 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  5. internal/disk/directio_darwin.go

    const ODirectPlatform = true
    
    // OpenFileDirectIO - bypass kernel cache.
    func OpenFileDirectIO(filePath string, flag int, perm os.FileMode) (*os.File, error) {
    	return directio.OpenFile(filePath, flag, perm)
    }
    
    // DisableDirectIO - disables directio mode.
    func DisableDirectIO(f *os.File) error {
    	fd := f.Fd()
    	_, err := unix.FcntlInt(fd, unix.F_NOCACHE, 0)
    	return err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 17 14:31:36 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  6. cmd/bucket-lifecycle_test.go

    import (
    	"bytes"
    	"net/http"
    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    // TestParseRestoreObjStatus tests parseRestoreObjStatus
    func TestParseRestoreObjStatus(t *testing.T) {
    	testCases := []struct {
    		restoreHdr     string
    		expectedStatus restoreObjStatus
    		expectedErr    error
    	}{
    		{
    			// valid: represents a restored object, 'pending' expiry.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 31 09:57:57 UTC 2022
    - 7K bytes
    - Viewed (0)
  7. istioctl/pkg/proxystatus/proxystatus.go

    	pilotxds "istio.io/istio/pilot/pkg/xds"
    	"istio.io/istio/pkg/log"
    )
    
    var configDumpFile string
    
    func readConfigFile(filename string) ([]byte, error) {
    	file := os.Stdin
    	if filename != "-" {
    		var err error
    		file, err = os.Open(filename)
    		if err != nil {
    			return nil, err
    		}
    	}
    	defer func() {
    		if err := file.Close(); err != nil {
    			log.Errorf("failed to close %s: %s", filename, err)
    		}
    	}()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  8. internal/s3select/message.go

    // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-frame-overview.png
    // hence the calculation is made accordingly.
    func totalByteLength(headerLength, payloadLength int) int {
    	return 4 + 4 + 4 + headerLength + payloadLength + 4
    }
    
    func genMessage(header, payload []byte) []byte {
    	headerLength := len(header)
    	payloadLength := len(payload)
    	totalLength := totalByteLength(headerLength, payloadLength)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  9. internal/disk/stat_linux_s390x.go

    }
    
    // getFSType returns the filesystem type of the underlying mounted filesystem
    func getFSType(ftype uint32) string {
    	fsTypeHex := strconv.FormatUint(uint64(ftype), 16)
    	fsTypeString, ok := fsType2StringMap[fsTypeHex]
    	if !ok {
    		return "UNKNOWN"
    	}
    	return fsTypeString
    }
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, _ bool) (info Info, err error) {
    	s := syscall.Statfs_t{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  10. internal/config/etcd/etcd.go

    	}
    
    	return etcdEndpoints, etcdSecure, nil
    }
    
    // Enabled returns if etcd is enabled.
    func Enabled(kvs config.KVS) bool {
    	endpoints := kvs.Get(Endpoints)
    	return endpoints != ""
    }
    
    // LookupConfig - Initialize new etcd config.
    func LookupConfig(kvs config.KVS, rootCAs *x509.CertPool) (Config, error) {
    	cfg := Config{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 23:17:22 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top