Search Options

Results per page
Sort
Preferred Languages
Advance

Results 651 - 660 of 1,387 for funcs (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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 (1)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. utils/tests/dummy_dialecter.go

    	})
    
    	return nil
    }
    
    func (DummyDialector) DefaultValueOf(field *schema.Field) clause.Expression {
    	return clause.Expr{SQL: "DEFAULT"}
    }
    
    func (DummyDialector) Migrator(*gorm.DB) gorm.Migrator {
    	return nil
    }
    
    func (DummyDialector) BindVarTo(writer clause.Writer, stmt *gorm.Statement, v interface{}) {
    	writer.WriteByte('?')
    }
    
    func (DummyDialector) QuoteTo(writer clause.Writer, str string) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 06 06:03:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  10. cmd/bucket-object-lock.go

    	"github.com/minio/pkg/v3/policy"
    )
    
    // BucketObjectLockSys - map of bucket and retention configuration.
    type BucketObjectLockSys struct{}
    
    // Get - Get retention configuration.
    func (sys *BucketObjectLockSys) Get(bucketName string) (r objectlock.Retention, err error) {
    	config, _, err := globalBucketMetadataSys.GetObjectLockConfig(bucketName)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.2K bytes
    - Viewed (0)
Back to top