Search Options

Results per page
Sort
Preferred Languages
Advance

Results 791 - 800 of 1,425 for Func (0.03 sec)

  1. internal/disk/stat_solaris.go

    package disk
    
    import (
    	"errors"
    	"fmt"
    
    	"golang.org/x/sys/unix"
    )
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, _ bool) (info Info, err error) {
    	s := unix.Statvfs_t{}
    	if err = unix.Statvfs(path, &s); err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := uint64(s.Bfree) - uint64(s.Bavail)
    	info = Info{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  2. cmd/auth-handler.go

    )
    
    // Verify if request has JWT.
    func isRequestJWT(r *http.Request) bool {
    	return strings.HasPrefix(r.Header.Get(xhttp.Authorization), jwtAlgorithm)
    }
    
    // Verify if request has AWS Signature Version '4'.
    func isRequestSignatureV4(r *http.Request) bool {
    	return strings.HasPrefix(r.Header.Get(xhttp.Authorization), signV4Algorithm)
    }
    
    // Verify if request has AWS Signature Version '2'.
    func isRequestSignatureV2(r *http.Request) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. src/archive/tar/reader_test.go

    		}
    	}
    }
    
    func TestReadOldGNUSparseMap(t *testing.T) {
    	populateSparseMap := func(sa sparseArray, sps []string) []string {
    		for i := 0; len(sps) > 0 && i < sa.maxEntries(); i++ {
    			copy(sa.entry(i), sps[0])
    			sps = sps[1:]
    		}
    		if len(sps) > 0 {
    			copy(sa.isExtended(), "\x80")
    		}
    		return sps
    	}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  4. internal/bucket/bandwidth/monitor_gen.go

    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BucketBandwidthReport) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 0
    	_ = z
    	err = en.Append(0x80)
    	if err != nil {
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z BucketBandwidthReport) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  5. internal/config/config.go

    // to operate on list of key values.
    type KVS []KV
    
    // Empty - return if kv is empty
    func (kvs KVS) Empty() bool {
    	return len(kvs) == 0
    }
    
    // Clone - returns a copy of the KVS
    func (kvs KVS) Clone() KVS {
    	return append(make(KVS, 0, len(kvs)), kvs...)
    }
    
    // GetWithDefault - returns default value if key not set
    func (kvs KVS) GetWithDefault(key string, defaultKVS KVS) string {
    	v := kvs.Get(key)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  6. clause/locking_test.go

    package clause_test
    
    import (
    	"fmt"
    	"testing"
    
    	"gorm.io/gorm/clause"
    )
    
    func TestLocking(t *testing.T) {
    	results := []struct {
    		Clauses []clause.Interface
    		Result  string
    		Vars    []interface{}
    	}{
    		{
    			[]clause.Interface{clause.Select{}, clause.From{}, clause.Locking{Strength: clause.LockingStrengthUpdate}},
    			"SELECT * FROM `users` FOR UPDATE", nil,
    		},
    		{
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Dec 15 08:32:56 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  7. internal/grid/msg_string.go

    // Code generated by "stringer -type=Op -output=msg_string.go -trimprefix=Op msg.go"; DO NOT EDIT.
    
    package grid
    
    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[OpConnect-1]
    	_ = x[OpConnectResponse-2]
    	_ = x[OpPing-3]
    	_ = x[OpPong-4]
    	_ = x[OpConnectMux-5]
    	_ = x[OpMuxConnectError-6]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  8. internal/once/singleton.go

    	set chan struct{}
    }
    
    // NewSingleton creates a new unset singleton.
    func NewSingleton[T any]() *Singleton[T] {
    	return &Singleton[T]{set: make(chan struct{}), v: nil}
    }
    
    // Get will return the singleton value.
    func (s *Singleton[T]) Get() *T {
    	<-s.set
    	return s.v
    }
    
    // GetNonBlocking will return the singleton value or nil if not set yet.
    func (s *Singleton[T]) GetNonBlocking() *T {
    	select {
    	case <-s.set:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 952 bytes
    - Viewed (0)
  9. clause/set.go

    package clause
    
    import "sort"
    
    type Set []Assignment
    
    type Assignment struct {
    	Column Column
    	Value  interface{}
    }
    
    func (set Set) Name() string {
    	return "SET"
    }
    
    func (set Set) Build(builder Builder) {
    	if len(set) > 0 {
    		for idx, assignment := range set {
    			if idx > 0 {
    				builder.WriteByte(',')
    			}
    			builder.WriteQuoted(assignment.Column)
    			builder.WriteByte('=')
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Nov 29 03:02:44 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  10. internal/http/dial_dnscache.go

    package http
    
    import (
    	"context"
    	"net"
    	"time"
    )
    
    // LookupHost is a function to make custom lookupHost for optional cached DNS requests
    type LookupHost func(ctx context.Context, host string) (addrs []string, err error)
    
    // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
Back to top