Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1101 - 1110 of 1,385 for _func (0.03 sec)

  1. cmd/erasure-healing-common_test.go

    	"bytes"
    	"context"
    	"fmt"
    	"os"
    	"path/filepath"
    	"runtime"
    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    // Returns the latest updated FileInfo files and error in case of failure.
    func getLatestFileInfo(ctx context.Context, partsMetadata []FileInfo, defaultParityCount int, errs []error) (FileInfo, error) {
    	// There should be at least half correct entries, if not return failure
    	expectedRQuorum := len(partsMetadata) / 2
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  2. src/cmd/api/boring_test.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    //go:build boringcrypto
    
    package main
    
    import (
    	"fmt"
    	"os"
    )
    
    func init() {
    	fmt.Printf("SKIP with boringcrypto enabled\n")
    	os.Exit(0)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 16 16:02:26 UTC 2023
    - 300 bytes
    - Viewed (0)
  3. docs/debugging/s3-check-md5/main.go

    	debug                          bool
    	versions                       bool
    	insecure                       bool
    )
    
    // getMD5Sum returns MD5 sum of given data.
    func getMD5Sum(data []byte) []byte {
    	hash := md5.New()
    	hash.Write(data)
    	return hash.Sum(nil)
    }
    
    func main() {
    	flag.StringVar(&endpoint, "endpoint", "https://play.min.io", "S3 endpoint URL")
    	flag.StringVar(&accessKey, "access-key", "Q3AM3UQ867SPQQA43P2F", "S3 Access Key")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. docs/debugging/healing-bin/main.go

    package main
    
    import (
    	"archive/zip"
    	"bytes"
    	"encoding/json"
    	"fmt"
    	"io"
    	"log"
    	"os"
    	"strings"
    
    	"github.com/minio/cli"
    	"github.com/tinylib/msgp/msgp"
    )
    
    func main() {
    	app := cli.NewApp()
    	app.Copyright = "MinIO, Inc."
    	app.Usage = "healing.bin to JSON"
    	app.HideVersion = true
    	app.HideHelpCommand = true
    	app.CustomAppHelpTemplate = `NAME:
      {{.Name}} - {{.Usage}}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.2K bytes
    - Viewed (0)
  5. internal/deadlineconn/deadlineconn_test.go

    package deadlineconn
    
    import (
    	"bufio"
    	"io"
    	"net"
    	"sync"
    	"testing"
    	"time"
    )
    
    // Test deadlineconn handles read timeout properly by reading two messages beyond deadline.
    func TestBuffConnReadTimeout(t *testing.T) {
    	l, err := net.Listen("tcp", "localhost:0")
    	if err != nil {
    		t.Fatalf("unable to create listener. %v", err)
    	}
    	defer l.Close()
    	serverAddr := l.Addr().String()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Nov 05 18:09:21 UTC 2022
    - 3K bytes
    - Viewed (0)
  6. cmd/server_test.go

    	testType string
    }
    
    // Assert - checks if gotValue is same as expectedValue, if not fails the test.
    func (c *check) Assert(gotValue interface{}, expectedValue interface{}) {
    	c.Helper()
    	if !reflect.DeepEqual(gotValue, expectedValue) {
    		c.Fatalf("Test %s expected %v, got %v", c.testType, expectedValue, gotValue)
    	}
    }
    
    func verifyError(c *check, response *http.Response, code, description string, statusCode int) {
    	c.Helper()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  7. cmd/site-replication-utils_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *SiteResyncStatus) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 7.2K bytes
    - Viewed (0)
  8. tests/customize_field_test.go

    package tests_test
    
    import (
    	"testing"
    	"time"
    
    	"gorm.io/gorm"
    	. "gorm.io/gorm/utils/tests"
    )
    
    func TestCustomizeColumn(t *testing.T) {
    	type CustomizeColumn struct {
    		ID   int64      `gorm:"column:mapped_id; primary_key:yes"`
    		Name string     `gorm:"column:mapped_name"`
    		Date *time.Time `gorm:"column:mapped_time"`
    	}
    
    	DB.Migrator().DropTable(&CustomizeColumn{})
    	DB.AutoMigrate(&CustomizeColumn{})
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Sep 11 09:33:31 UTC 2020
    - 6.9K bytes
    - Viewed (0)
  9. cmd/config-migrate.go

    )
    
    // Save config file to corresponding backend
    func Save(configFile string, data interface{}) error {
    	return quick.SaveConfig(data, configFile, globalEtcdClient)
    }
    
    // Load config from backend
    func Load(configFile string, data interface{}) (quick.Config, error) {
    	return quick.LoadConfig(configFile, globalEtcdClient, data)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  10. cmd/streaming-signature-v4_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bufio"
    	"bytes"
    	"fmt"
    	"io"
    	"strings"
    	"testing"
    )
    
    // Test read chunk line.
    func TestReadChunkLine(t *testing.T) {
    	type testCase struct {
    		reader         *bufio.Reader
    		expectedErr    error
    		chunkSize      []byte
    		chunkSignature []byte
    	}
    	// List of readers used.
    	readers := []io.Reader{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 5.7K bytes
    - Viewed (0)
Back to top