- Sort Score
- Result 10 results
- Languages All
Results 651 - 660 of 1,384 for funcs (0.07 sec)
-
cmd/storage-datatypes_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "encoding/gob" "io" "testing" "time" "github.com/tinylib/msgp/msgp" ) func BenchmarkDecodeVolInfoMsgp(b *testing.B) { v := VolInfo{ Name: "uuid", Created: time.Now(), } var buf bytes.Buffer msgp.Encode(&buf, &v) rd := msgp.NewEndlessReader(buf.Bytes(), b)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 9.4K bytes - Viewed (0) -
internal/event/name_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package event import ( "encoding/json" "encoding/xml" "reflect" "testing" ) func TestNameExpand(t *testing.T) { testCases := []struct { name Name expectedResult []Name }{ {BucketCreated, []Name{BucketCreated}}, {BucketRemoved, []Name{BucketRemoved}},
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 01 01:11:10 UTC 2024 - 7.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
}, } return fakePod, fakeNS } func (mrdir *mockInterceptRuleMgr) Program(podName, netns string, redirect *Redirect) error { mrdir.lastRedirect = append(mrdir.lastRedirect, redirect) return nil } // returns the test server URL and a dispose func for the test server func setupCNIEventClientWithMockServer(serverErr bool) func() bool { cniAddServerCalled := false
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 17.3K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
ObjectInfo } func (f freeVersionTask) OpHash() uint64 { return xxh3.HashString(f.TransitionedObject.Tier + f.TransitionedObject.Name) } func (n newerNoncurrentTask) OpHash() uint64 { return xxh3.HashString(n.bucket + n.versions[0].ObjectV.ObjectName) } func (j jentry) OpHash() uint64 { return xxh3.HashString(j.TierName + j.ObjName) } func (e expiryTask) OpHash() uint64 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0) -
internal/lock/lock_windows.go
lockFileFailImmediately = 1 // see https://msdn.microsoft.com/en-us/library/windows/desktop/ms681382(v=vs.85).aspx errLockViolation syscall.Errno = 0x21 ) // lockedOpenFile is an internal function. func lockedOpenFile(path string, flag int, perm os.FileMode, lockType uint32) (*LockedFile, error) { f, err := Open(path, flag, perm) if err != nil { return nil, err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 18 18:08:15 UTC 2023 - 7.9K bytes - Viewed (0) -
callbacks/query.go
"gorm.io/gorm/schema" "gorm.io/gorm/utils" ) func Query(db *gorm.DB) { if db.Error == nil { BuildQuerySQL(db) if !db.DryRun && db.Error == nil { rows, err := db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...) if err != nil { db.AddError(err) return } defer func() { db.AddError(rows.Close()) }() gorm.Scan(rows, db, 0)
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:03:42 UTC 2024 - 10.1K bytes - Viewed (0) -
internal/ioutil/ioutil.go
) // aligned sync.Pool's var ( ODirectPoolLarge = sync.Pool{ New: func() interface{} { b := disk.AlignedBlock(LargeBlock) return &b }, } ODirectPoolMedium = sync.Pool{ New: func() interface{} { b := disk.AlignedBlock(MediumBlock) return &b }, } ODirectPoolSmall = sync.Pool{ New: func() interface{} { b := disk.AlignedBlock(SmallBlock) return &b }, } )
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 10.9K bytes - Viewed (0) -
prepare_stmt.go
return nil, ErrInvalidDB } func (db *PreparedStmtDB) Close() { db.Mux.Lock() defer db.Mux.Unlock() for _, stmt := range db.Stmts { go func(s *Stmt) { // make sure the stmt must finish preparation first <-s.prepared if s.Stmt != nil { _ = s.Close() } }(stmt) } // setting db.Stmts to nil to avoid further using db.Stmts = nil } func (sdb *PreparedStmtDB) Reset() {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:02:05 UTC 2024 - 6.6K bytes - Viewed (0) -
cmd/tier-handlers.go
errTierReservedName = AdminError{ Code: "XMinioAdminTierReserved", Message: "Cannot use reserved tier name", StatusCode: http.StatusBadRequest, } ) func (api adminAPIHandlers) AddTierHandler(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objAPI, cred := validateAdminReq(ctx, w, r, policy.SetTierAction) if objAPI == nil { return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:44:05 UTC 2024 - 7.5K bytes - Viewed (0) -
istioctl/pkg/cli/mock_client.go
"istio.io/istio/pkg/kube" ) type MockPortForwarder struct{} func (m MockPortForwarder) Start() error { return nil } func (m MockPortForwarder) Address() string { return "localhost:3456" } func (m MockPortForwarder) Close() { } func (m MockPortForwarder) ErrChan() <-chan error { return make(chan error) } func (m MockPortForwarder) WaitForStop() { }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 2.1K bytes - Viewed (0)