Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 1,590 for go (0.01 seconds)

  1. cmd/metacache-entries_test.go

    tdata/random.data.bz2", "src/compress/flate/deflate.go", "src/compress/flate/deflate_test.go", "src/compress/flate/deflatefast.go", "src/compress/flate/dict_decoder.go", "src/compress/flate/dict_decoder_test.go", "src/compress/flate/example_test.go", "src/compress/flate/flate_test.go", "src/compress/flate/huffman_bit_writer.go", "src/compress/flate/huffman_bit_writer_test.go", "src/compress/flate/huffman_code.go", "src/compress/flate/inflate.go", "src/compress/flate/inflate_test.go", "src/compre...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 31.6K bytes
    - Click Count (0)
  2. internal/stmt_store/stmt_store.go

    func New(size int, ttl time.Duration) Store {
    	if size <= 0 {
    		size = defaultMaxSize
    	}
    
    	if ttl <= 0 {
    		ttl = defaultTTL
    	}
    
    	onEvicted := func(k string, v *Stmt) {
    		if v != nil {
    			go v.Close()
    		}
    	}
    	return &lruStore{lru: lru.NewLRU[string, *Stmt](size, onEvicted, ttl)}
    }
    
    type lruStore struct {
    	lru *lru.LRU[string, *Stmt]
    }
    
    func (s *lruStore) Keys() []string {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Apr 27 06:05:16 GMT 2025
    - 6K bytes
    - Click Count (0)
  3. internal/config/dns/operator_dns.go

    			ResponseHeaderTimeout: 3 * time.Second,
    			TLSHandshakeTimeout:   3 * time.Second,
    			ExpectContinueTimeout: 3 * time.Second,
    			TLSClientConfig: &tls.Config{
    				RootCAs: args.rootCAs,
    			},
    			// Go net/http automatically unzip if content-type is
    			// gzip disable this feature, as we are always interested
    			// in raw stream.
    			DisableCompression: true,
    		},
    	}
    	return args, nil
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Nov 11 14:51:43 GMT 2024
    - 6.6K bytes
    - Click Count (0)
  4. tests/embedded_struct_test.go

    	}
    }
    
    type Content struct {
    	Content interface{} `gorm:"type:String"`
    }
    
    func (c Content) Value() (driver.Value, error) {
    	// mssql driver with issue on handling null bytes https://github.com/denisenkom/go-mssqldb/issues/530,
    	b, err := json.Marshal(c)
    	return string(b[:]), err
    }
    
    func (c *Content) Scan(src interface{}) error {
    	var value Content
    	str, ok := src.(string)
    	if !ok {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Wed May 08 04:07:58 GMT 2024
    - 7.3K bytes
    - Click Count (0)
  5. tests/generics_test.go

    	if err != nil {
    		t.Errorf("failed to create users")
    	}
    
    	reusedb := gorm.G[User](DB).Where("name like ?", "TestGenericsReuse%")
    
    	sg := sync.WaitGroup{}
    	for i := 0; i < 5; i++ {
    		sg.Add(1)
    
    		go func() {
    			if u1, err := reusedb.Where("id = ?", users[0].ID).First(ctx); err != nil {
    				t.Errorf("failed to find user, got error: %v", err)
    			} else if u1.Name != users[0].Name || u1.ID != users[0].ID {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Nov 02 14:09:18 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  6. internal/event/config.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package event
    
    import (
    	"encoding/xml"
    	"errors"
    	"io"
    	"reflect"
    	"strings"
    	"unicode/utf8"
    
    	"github.com/minio/minio-go/v7/pkg/set"
    )
    
    // ValidateFilterRuleValue - checks if given value is filter rule value or not.
    func ValidateFilterRuleValue(value string) error {
    	for segment := range strings.SplitSeq(value, "/") {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  7. internal/event/target/mqtt.go

    func NewMQTTTarget(id string, args MQTTArgs, loggerOnce logger.LogOnce) (*MQTTTarget, error) {
    	if args.MaxReconnectInterval == 0 {
    		// Default interval
    		// https://github.com/eclipse/paho.mqtt.golang/blob/master/options.go#L115
    		args.MaxReconnectInterval = 10 * time.Minute
    	}
    
    	if args.KeepAlive == 0 {
    		args.KeepAlive = 10 * time.Second
    	}
    
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.2K bytes
    - Click Count (0)
  8. src/bytes/compare_test.go

    // Copyright 2013 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package bytes_test
    
    import (
    	. "bytes"
    	"fmt"
    	"testing"
    )
    
    var compareTests = []struct {
    	a, b []byte
    	i    int
    }{
    	{[]byte(""), []byte(""), 0},
    	{[]byte("a"), []byte(""), 1},
    	{[]byte(""), []byte("a"), -1},
    	{[]byte("abc"), []byte("abc"), 0},
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Jul 13 23:11:42 GMT 2023
    - 6.8K bytes
    - Click Count (0)
  9. cmd/endpoint.go

    import (
    	"fmt"
    	"net"
    	"net/http"
    	"net/url"
    	"path"
    	"path/filepath"
    	"reflect"
    	"runtime"
    	"slices"
    	"sort"
    	"strconv"
    	"strings"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/mountinfo"
    	"github.com/minio/pkg/v3/env"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  10. src/archive/zip/zip_test.go

    // Copyright 2011 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // Tests that involve both reading and writing.
    
    package zip
    
    import (
    	"bytes"
    	"cmp"
    	"errors"
    	"fmt"
    	"hash"
    	"internal/testenv"
    	"io"
    	"runtime"
    	"slices"
    	"strings"
    	"testing"
    	"time"
    )
    
    func TestOver65kFiles(t *testing.T) {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu May 23 01:00:11 GMT 2024
    - 19.6K bytes
    - Click Count (0)
Back to Top