- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 1,387 for funcs (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)