Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 471 - 480 of 1,760 for func (0.02 seconds)

  1. cmd/decommetric_string.go

    // Code generated by "stringer -type=decomMetric -trimprefix=decomMetric erasure-server-pool-decom.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[decomMetricDecommissionBucket-0]
    	_ = x[decomMetricDecommissionObject-1]
    	_ = x[decomMetricDecommissionRemoveObject-2]
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Aug 10 19:46:45 GMT 2022
    - 830 bytes
    - Click Count (0)
  2. clause/locking.go

    	LockingOptionsNoWait     = "NOWAIT"
    )
    
    type Locking struct {
    	Strength string
    	Table    Table
    	Options  string
    }
    
    // Name where clause name
    func (locking Locking) Name() string {
    	return "FOR"
    }
    
    // Build build where clause
    func (locking Locking) Build(builder Builder) {
    	builder.WriteString(locking.Strength)
    	if locking.Table.Name != "" {
    		builder.WriteString(" OF ")
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Dec 15 08:32:56 GMT 2023
    - 773 bytes
    - Click Count (0)
  3. cmd/erasure-metadata-utils_test.go

    	if err != nil {
    		removeRoots(disks)
    		t.Fatal(err)
    	}
    	defer removeRoots(disks)
    	z := objLayer.(*erasureServerPools)
    	testShuffleDisks(t, z)
    }
    
    func Test_hashOrder(t *testing.T) {
    	for x := 1; x < 17; x++ {
    		t.Run(fmt.Sprintf("%d", x), func(t *testing.T) {
    			var first [17]int
    			rng := rand.New(rand.NewSource(0))
    			var tmp [16]byte
    			rng.Read(tmp[:])
    			prefix := hex.EncodeToString(tmp[:])
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  4. cmd/api-utils.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"net/http"
    	"reflect"
    	"runtime"
    	"strings"
    )
    
    func shouldEscape(c byte) bool {
    	if 'A' <= c && c <= 'Z' || 'a' <= c && c <= 'z' || '0' <= c && c <= '9' {
    		return false
    	}
    
    	switch c {
    	case '-', '_', '.', '/', '*':
    		return false
    	}
    	return true
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  5. internal/lock/lock_solaris.go

    // This implementation doesn't support all the open
    // flags and shouldn't be considered as replacement
    // for os.OpenFile().
    func LockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
    	return lockedOpenFile(path, flag, perm, syscall.F_SETLKW)
    }
    
    // Open - Call os.OpenFile
    func Open(path string, flag int, perm os.FileMode) (*os.File, error) {
    	return os.OpenFile(path, flag, perm)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 2.8K bytes
    - Click Count (0)
  6. cmd/erasure-decode.go

    		stashBuffer:   b,
    	}
    }
    
    // Done will release any resources used by the parallelReader.
    func (p *parallelReader) Done() {
    	if p.stashBuffer != nil {
    		globalBytePoolCap.Load().Put(p.stashBuffer)
    		p.stashBuffer = nil
    	}
    }
    
    // preferReaders can mark readers as preferred.
    // These will be chosen before others.
    func (p *parallelReader) preferReaders(prefer []bool) {
    	if len(prefer) != len(p.orgReaders) {
    		return
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 29 01:40:52 GMT 2024
    - 9.5K bytes
    - Click Count (0)
  7. cmd/batch-handlers_gen.go

    		}
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z BatchJobPrefix) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendArrayHeader(o, uint32(len(z)))
    	for zb0003 := range z {
    		o = msgp.AppendString(o, z[zb0003])
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BatchJobPrefix) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var zb0002 uint32
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  8. cmd/admin-handlers-config-kv.go

    }
    
    type badConfigErr struct {
    	Err error
    }
    
    // Error - return the error message
    func (bce badConfigErr) Error() string {
    	return bce.Err.Error()
    }
    
    // Unwrap the error to its underlying error.
    func (bce badConfigErr) Unwrap() error {
    	return bce.Err
    }
    
    type setConfigResult struct {
    	Cfg                     config.Config
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.8K bytes
    - Click Count (1)
  9. internal/grid/debugmsg_string.go

    // Code generated by "stringer -type=debugMsg debug.go"; DO NOT EDIT.
    
    package grid
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[debugShutdown-0]
    	_ = x[debugKillInbound-1]
    	_ = x[debugKillOutbound-2]
    	_ = x[debugWaitForExit-3]
    	_ = x[debugSetConnPingDuration-4]
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jun 07 15:51:52 GMT 2024
    - 1K bytes
    - Click Count (0)
  10. logger/slog_test.go

    import (
    	"bytes"
    	"context"
    	"log/slog"
    	"strings"
    	"testing"
    	"time"
    )
    
    func TestSlogLogger(t *testing.T) {
    	buf := &bytes.Buffer{}
    	handler := slog.NewTextHandler(buf, &slog.HandlerOptions{AddSource: true})
    	logger := NewSlogLogger(slog.New(handler), Config{LogLevel: Info})
    
    	logger.Trace(context.Background(), time.Now(), func() (string, int64) {
    		return "select count(*) from users", 0
    	}, nil)
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Oct 30 10:56:26 GMT 2025
    - 782 bytes
    - Click Count (0)
Back to Top