Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 1,387 for funcs (0.03 sec)

  1. internal/event/targetidset.go

    // IsEmpty returns true if the set is empty.
    func (set TargetIDSet) IsEmpty() bool {
    	return len(set) != 0
    }
    
    // Clone - returns copy of this set.
    func (set TargetIDSet) Clone() TargetIDSet {
    	setCopy := NewTargetIDSet()
    	for k, v := range set {
    		setCopy[k] = v
    	}
    	return setCopy
    }
    
    // add - adds TargetID to the set.
    func (set TargetIDSet) add(targetID TargetID) {
    	set[targetID] = struct{}{}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/lifecycle.go

    	ActionCount
    )
    
    // DeleteRestored - Returns true if action demands delete on restored objects
    func (a Action) DeleteRestored() bool {
    	return a == DeleteRestoredAction || a == DeleteRestoredVersionAction
    }
    
    // DeleteVersioned - Returns true if action demands delete on a versioned object
    func (a Action) DeleteVersioned() bool {
    	return a == DeleteVersionAction || a == DeleteRestoredVersionAction
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  3. cni/pkg/ipset/nldeps_unspecified.go

    import (
    	"errors"
    	"net/netip"
    )
    
    func RealNlDeps() NetlinkIpsetDeps {
    	return &realDeps{}
    }
    
    type realDeps struct{}
    
    func (m *realDeps) ipsetIPHashCreate(name string, v6 bool) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) destroySet(name string) error {
    	return errors.New("not implemented on this platform")
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. cmd/iam-object-store.go

    	usersSysType UsersSysType
    
    	objAPI ObjectLayer
    }
    
    func newIAMObjectStore(objAPI ObjectLayer, usersSysType UsersSysType) *IAMObjectStore {
    	return &IAMObjectStore{
    		iamCache:     newIamCache(),
    		objAPI:       objAPI,
    		usersSysType: usersSysType,
    	}
    }
    
    func (iamOS *IAMObjectStore) rlock() *iamCache {
    	iamOS.RLock()
    	return iamOS.iamCache
    }
    
    func (iamOS *IAMObjectStore) runlock() {
    	iamOS.RUnlock()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  5. internal/s3select/sql/value_test.go

    // Values should match if type is the same.
    var valueBuilders = []func() *Value{
    	FromNull,
    	func() *Value {
    		return FromBool(true)
    	},
    	func() *Value {
    		return FromBytes([]byte("byte contents"))
    	},
    	func() *Value {
    		return FromFloat(math.Pi)
    	},
    	func() *Value {
    		return FromInt(0x1337)
    	},
    	func() *Value {
    		t, err := time.Parse(time.RFC3339, "2006-01-02T15:04:05Z")
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  6. internal/dsync/lock-args_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgLockArgs(b *testing.B) {
    	v := LockArgs{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgLockArgs(b *testing.B) {
    	v := LockArgs{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/pod_cache.go

    type podNetnsCache struct {
    	openNetns func(nspath string) (NetnsCloser, error)
    
    	currentPodCache map[string]WorkloadInfo
    	mu              sync.RWMutex
    }
    
    type WorkloadInfo struct {
    	Workload *zdsapi.WorkloadInfo
    	Netns    NetnsCloser
    }
    
    var _ PodNetnsCache = &podNetnsCache{}
    
    func newPodNetnsCache(openNetns func(nspath string) (NetnsCloser, error)) *podNetnsCache {
    	return &podNetnsCache{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 31 17:18:11 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  8. cmd/sftp-server_test.go

    )
    
    type MockConnMeta struct {
    	username string
    }
    
    func (m *MockConnMeta) User() string {
    	return m.username
    }
    
    func (m *MockConnMeta) SessionID() []byte {
    	return []byte{}
    }
    
    func (m *MockConnMeta) ClientVersion() []byte {
    	return []byte{}
    }
    
    func (m *MockConnMeta) ServerVersion() []byte {
    	return []byte{}
    }
    
    func (m *MockConnMeta) RemoteAddr() net.Addr {
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  9. internal/dsync/dsync-client_test.go

    	}
    }
    
    // Close closes the underlying socket file descriptor.
    func (restClient *ReconnectRESTClient) IsOnline() bool {
    	// If rest client has not connected yet there is nothing to close.
    	return restClient.rest != nil
    }
    
    func (restClient *ReconnectRESTClient) IsLocal() bool {
    	return false
    }
    
    // Close closes the underlying socket file descriptor.
    func (restClient *ReconnectRESTClient) Close() error {
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  10. cmd/erasure-healing-common.go

    		return checkPartDiskNotFound
    	default:
    		return checkPartUnknown
    	}
    }
    
    func partNeedsHealing(partErrs []int) bool {
    	return slices.IndexFunc(partErrs, func(i int) bool { return i != checkPartSuccess && i != checkPartUnknown }) > -1
    }
    
    func hasPartErr(partErrs []int) bool {
    	return slices.IndexFunc(partErrs, func(i int) bool { return i != checkPartSuccess }) > -1
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top