Search Options

Results per page
Sort
Preferred Languages
Advance

Results 971 - 980 of 1,425 for Func (0.04 sec)

  1. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    }
    
    func TestHealingDanglingObject(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	resetGlobalHealState()
    	defer resetGlobalHealState()
    
    	// Set globalStorageClass.STANDARD to EC:4 for this test
    	saveSC := globalStorageClass
    	defer func() {
    		globalStorageClass.Update(saveSC)
    	}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. internal/kms/dek_test.go

    		},
    	},
    }
    
    func TestEncodeDecodeDEK(t *testing.T) {
    	for i, test := range dekEncodeDecodeTests {
    		text, err := test.Key.MarshalText()
    		if err != nil {
    			t.Fatalf("Test %d: failed to marshal DEK: %v", i, err)
    		}
    
    		var key DEK
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. internal/logger/legacy.go

    const (
    	legacyEnvAuditLoggerHTTPEndpoint = "MINIO_AUDIT_LOGGER_HTTP_ENDPOINT"
    	legacyEnvLoggerHTTPEndpoint      = "MINIO_LOGGER_HTTP_ENDPOINT"
    )
    
    // SetLoggerHTTPAudit - helper for migrating older config to newer KV format.
    func SetLoggerHTTPAudit(scfg config.Config, k string, args http.Config) {
    	if !args.Enabled {
    		// Do not enable audit targets, if not enabled
    		return
    	}
    	scfg[config.AuditWebhookSubSys][k] = config.KVS{
    		config.KV{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 03 09:47:07 UTC 2023
    - 2K bytes
    - Viewed (0)
  4. callbacks/callbacks.go

    type Config struct {
    	LastInsertIDReversed bool
    	CreateClauses        []string
    	QueryClauses         []string
    	UpdateClauses        []string
    	DeleteClauses        []string
    }
    
    func RegisterDefaultCallbacks(db *gorm.DB, config *Config) {
    	enableTransaction := func(db *gorm.DB) bool {
    		return !db.SkipDefaultTransaction
    	}
    
    	if len(config.CreateClauses) == 0 {
    		config.CreateClauses = createClauses
    	}
    	if len(config.QueryClauses) == 0 {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 27 23:56:55 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/healthServer_test.go

    // limitations under the License.
    
    package nodeagent
    
    import (
    	"net/http"
    	"net/http/httptest"
    	"testing"
    
    	"istio.io/istio/cni/pkg/constants"
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func TestServer(t *testing.T) {
    	router := http.NewServeMux()
    	installReady, watchReady := initRouter(router)
    
    	assert.Equal(t, installReady.Load(), false)
    	assert.Equal(t, watchReady.Load(), false)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 2K bytes
    - Viewed (0)
  6. istioctl/pkg/tag/generate.go

    }
    
    // Create applies the given tag manifests.
    func Create(client kube.CLIClient, manifests, ns string) error {
    	if err := client.ApplyYAMLContents(ns, manifests); err != nil {
    		return fmt.Errorf("failed to apply tag manifests to cluster: %v", err)
    	}
    	return nil
    }
    
    // generateValidatingWebhook renders a validating webhook configuration from the given tagWebhookConfig.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. src/cmd/asm/internal/arch/ppc64.go

    	"cmd/internal/obj/ppc64"
    )
    
    func jumpPPC64(word string) bool {
    	switch word {
    	case "BC", "BCL", "BEQ", "BGE", "BGT", "BL", "BLE", "BLT", "BNE", "BR", "BVC", "BVS", "BDNZ", "BDZ", "CALL", "JMP":
    		return true
    	}
    	return false
    }
    
    // IsPPC64CMP reports whether the op (as defined by an ppc64.A* constant) is
    // one of the CMP instructions that require special handling.
    func IsPPC64CMP(op obj.As) bool {
    	switch op {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri May 17 21:53:50 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  8. cmd/bucket-policy-handlers_test.go

    }
    
    // Wrapper for calling Create Bucket and ensure we get one and only one success.
    func TestCreateBucket(t *testing.T) {
    	ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{t: t, objAPITest: testCreateBucket, endpoints: []string{"MakeBucket"}})
    }
    
    // testCreateBucket - Test for calling Create Bucket and ensure we get one and only one success.
    func testCreateBucket(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  9. cmd/handler-utils_test.go

    	"bytes"
    	"context"
    	"encoding/xml"
    	"io"
    	"net/http"
    	"net/textproto"
    	"os"
    	"reflect"
    	"testing"
    
    	"github.com/minio/minio/internal/config"
    )
    
    // Tests validate bucket LocationConstraint.
    func TestIsValidLocationConstraint(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. cmd/data-scanner_test.go

    	"testing"
    	"time"
    
    	"github.com/google/uuid"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	"github.com/minio/minio/internal/bucket/object/lock"
    	"github.com/minio/minio/internal/bucket/versioning"
    )
    
    func TestApplyNewerNoncurrentVersionsLimit(t *testing.T) {
    	objAPI, disks, err := prepareErasure(context.Background(), 8)
    	if err != nil {
    		t.Fatalf("Failed to initialize object layer: %v", err)
    	}
    	defer removeRoots(disks)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
Back to top