Search Options

Results per page
Sort
Preferred Languages
Advance

Results 791 - 800 of 1,423 for Func (0.02 sec)

  1. 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)
  2. tests/error_translator_test.go

    package tests_test
    
    import (
    	"errors"
    	"testing"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/utils/tests"
    )
    
    func TestDialectorWithErrorTranslatorSupport(t *testing.T) {
    	// it shouldn't translate error when the TranslateError flag is false
    	translatedErr := errors.New("translated error")
    	untranslatedErr := errors.New("some random error")
    	db, _ := gorm.Open(tests.DummyDialector{TranslatedErr: translatedErr})
    
    	err := db.AddError(untranslatedErr)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jul 12 13:21:22 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  3. cmd/object-api-interface_gen.go

    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z BucketOptions) Msgsize() (s int) {
    	s = 1 + 8 + msgp.BoolSize + 7 + msgp.BoolSize + 11 + msgp.BoolSize
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z ExpirationOptions) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 1
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  4. internal/disk/stat_freebsd.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package disk
    
    import (
    	"errors"
    	"fmt"
    	"syscall"
    )
    
    // 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{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := 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.7K bytes
    - Viewed (0)
  5. istioctl/pkg/util/configdump/wrapper.go

    	"google.golang.org/protobuf/types/known/emptypb"
    
    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    type resolver struct {
    	*protoregistry.Types
    }
    
    var nonStrictResolver = &resolver{protoregistry.GlobalTypes}
    
    func (r *resolver) FindMessageByURL(url string) (protoreflect.MessageType, error) {
    	typ, err := r.Types.FindMessageByURL(url)
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. cmd/xl-storage-free-version_test.go

    )
    
    func (x xlMetaV2) listFreeVersions(volume, path string) ([]FileInfo, error) {
    	fivs, err := x.ListVersions(volume, path, true)
    	if err != nil {
    		return nil, err
    	}
    	n := 0
    	for _, fiv := range fivs {
    		if fiv.TierFreeVersion() {
    			fivs[n] = fiv
    			n++
    		}
    	}
    	fivs = fivs[:n]
    	return fivs, nil
    }
    
    func TestFreeVersion(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  10. internal/grid/grid_types_test.go

    type testRequest struct {
    	Num    int
    	String string
    }
    
    type testResponse struct {
    	OrgNum    int
    	OrgString string
    	Embedded  testRequest
    }
    
    func newTestRequest() *testRequest {
    	return &testRequest{}
    }
    
    func newTestResponse() *testResponse {
    	return &testResponse{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 1.1K bytes
    - Viewed (0)
Back to top