Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 591 - 600 of 877 for Strict (0.04 seconds)

  1. internal/config/drive/drive.go

    var DefaultKVS = config.KVS{
    	config.KV{
    		Key:   MaxTimeout,
    		Value: "30s",
    	},
    }
    
    var configLk sync.RWMutex
    
    // Config represents the subnet related configuration
    type Config struct {
    	// MaxTimeout - maximum timeout for a drive operation
    	MaxTimeout time.Duration `json:"maxTimeout"`
    }
    
    // Update - updates the config with latest values
    func (c *Config) Update(updated Config) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Nov 11 14:51:43 GMT 2024
    - 3K bytes
    - Click Count (0)
  2. internal/s3select/sql/jsonpath_test.go

    	}
    
    	b, err := io.ReadAll(f)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	p := participle.MustBuild(
    		&JSONPath{},
    		participle.Lexer(sqlLexer),
    		participle.CaseInsensitive("Keyword"),
    	)
    	cases := []struct {
    		str string
    		res []any
    	}{
    		{"s.title", []any{"Murder on the Orient Express", "The Robots of Dawn", "Pigs Have Wings"}},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  3. internal/config/dns/etcd_dns_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package dns
    
    import "testing"
    
    func TestDNSJoin(t *testing.T) {
    	tests := []struct {
    		in  []string
    		out string
    	}{
    		{[]string{"bla", "bliep", "example", "org"}, "bla.bliep.example.org."},
    		{[]string{"example", "."}, "example."},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 28 17:31:12 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  4. internal/crypto/header.go

    	h.Del(xhttp.AmzMetaUnencryptedContentMD5)
    }
    
    // SSECopy represents AWS SSE-C for copy requests. It provides
    // functionality to handle SSE-C copy requests.
    var SSECopy = ssecCopy{}
    
    type ssecCopy struct{}
    
    // IsRequested returns true if the HTTP headers contains
    // at least one SSE-C copy header. Regular SSE-C headers
    // are ignored.
    func (ssecCopy) IsRequested(h http.Header) bool {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 2.9K bytes
    - Click Count (0)
  5. cmd/global-heal.go

    	if !ok {
    		return madmin.BgHealState{}, false
    	}
    
    	status := madmin.BgHealState{
    		ScannedItemsCount: bgSeq.getScannedItemsCount(),
    	}
    
    	healDisksMap := map[string]struct{}{}
    	for _, ep := range getLocalDisksToHeal() {
    		healDisksMap[ep.String()] = struct{}{}
    	}
    
    	if o == nil {
    		healing := globalBackgroundHealState.getLocalHealingDisks()
    		for _, disk := range healing {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  6. internal/kms/config_test.go

    		}
    
    		if !test.ShouldFail && ok != test.IsPresent {
    			t.Fatalf("Test %d: reported that KMS present=%v - want present=%v", i, ok, test.IsPresent)
    		}
    	}
    }
    
    var isPresentTests = []struct {
    	Env        map[string]string
    	IsPresent  bool
    	ShouldFail bool
    }{
    	{Env: map[string]string{}}, // 0
    	{ // 1
    		Env: map[string]string{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  7. internal/lock/lock_windows_test.go

    	// doesn't really matter anyway, since this is purely a string
    	// function we're testing, and it's not actually being used to
    	// do a system call)
    	veryLong := "l" + strings.Repeat("o", 248) + "ng"
    	for _, test := range []struct{ in, want string }{
    		// Short; unchanged:
    		{`C:\short.txt`, `C:\short.txt`},
    		{`C:\`, `C:\`},
    		{`C:`, `C:`},
    		// The "long" substring is replaced by a looooooong
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 18 18:08:15 GMT 2023
    - 2.2K bytes
    - Click Count (0)
  8. cmd/warm-backend-azure.go

    	"github.com/Azure/azure-sdk-for-go/sdk/storage/azblob"
    	"github.com/Azure/azure-sdk-for-go/sdk/storage/azblob/blob"
    	"github.com/minio/madmin-go/v3"
    )
    
    type warmBackendAzure struct {
    	clnt         *azblob.Client
    	Bucket       string
    	Prefix       string
    	StorageClass string
    }
    
    func (az *warmBackendAzure) tier() *blob.AccessTier {
    	if az.StorageClass == "" {
    		return nil
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 31 22:10:24 GMT 2024
    - 7K bytes
    - Click Count (0)
  9. internal/s3select/jstream/decoder_test.go

    }
    
    func TestDecoderFlat(t *testing.T) {
    	var (
    		counter int
    		mv      *MetaValue
    		body    = `[
      "1st test string",
      "Roberto*Maestro", "Charles",
      0, null, false,
      1, 2.5
    ]`
    		expected = []struct {
    			Value     any
    			ValueType ValueType
    		}{
    			{
    				"1st test string",
    				String,
    			},
    			{
    				"Roberto*Maestro",
    				String,
    			},
    			{
    				"Charles",
    				String,
    			},
    			{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  10. cmd/signature-v4_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	defer removeRoots([]string{fsDir})
    
    	credentialTemplate := "%s/%s/%s/s3/aws4_request"
    	now := UTCNow()
    	accessKey := globalActiveCred.AccessKey
    
    	testCases := []struct {
    		form     http.Header
    		expected APIErrorCode
    	}{
    		// (0) It should fail if 'X-Amz-Credential' is missing.
    		{
    			form:     http.Header{},
    			expected: ErrCredMalformed,
    		},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 10.5K bytes
    - Click Count (0)
Back to Top