Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1021 - 1030 of 1,384 for funcs (0.02 sec)

  1. cmd/ilm-config.go

    }
    
    type ilmConfig struct {
    	mu  sync.RWMutex
    	cfg ilm.Config
    }
    
    func (c *ilmConfig) getExpirationWorkers() int {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    
    	return c.cfg.ExpirationWorkers
    }
    
    func (c *ilmConfig) getTransitionWorkers() int {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    
    	return c.cfg.TransitionWorkers
    }
    
    func (c *ilmConfig) update(cfg ilm.Config) {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 05 02:50:24 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  2. cni/pkg/monitoring/monitoring.go

    		return
    	}
    	mux.Handle(path, exporter)
    	monitoringServer := &http.Server{
    		Handler: mux,
    	}
    	go func() {
    		if err = monitoringServer.Serve(listener); network.IsUnexpectedListenerError(err) {
    			log.Errorf("error running monitoring http server: %s", err)
    		}
    	}()
    	go func() {
    		<-stop
    		err := monitoringServer.Close()
    		log.Debugf("monitoring server terminated: %v", err)
    	}()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 09 07:54:01 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  3. tests/associations_has_many_test.go

    package tests_test
    
    import (
    	"testing"
    
    	"gorm.io/gorm"
    	. "gorm.io/gorm/utils/tests"
    )
    
    func TestHasManyAssociation(t *testing.T) {
    	user := *GetUser("hasmany", Config{Pets: 2})
    
    	if err := DB.Create(&user).Error; err != nil {
    		t.Fatalf("errors happened when create: %v", err)
    	}
    
    	CheckUser(t, user, user)
    
    	// Find
    	var user2 User
    	DB.Find(&user2, "id = ?", user.ID)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 10:49:45 UTC 2024
    - 16K bytes
    - Viewed (0)
  4. src/cmd/api/testdata/src/issue21181/p/p.go

    package p
    
    import (
    	"dep"
    )
    
    type algo struct {
    	indrt func(dep.Interface)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Oct 05 17:53:43 UTC 2018
    - 78 bytes
    - Viewed (0)
  5. cmd/bucket-policy-handlers.go

    	bucketPolicyConfig = "policy.json"
    )
    
    // PutBucketPolicyHandler - This HTTP handler stores given bucket policy configuration as per
    // https://docs.aws.amazon.com/AmazonS3/latest/dev/access-policy-language-overview.html
    func (api objectAPIHandlers) PutBucketPolicyHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "PutBucketPolicy")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	objAPI := api.ObjectAPI()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. cmd/signature-v4-utils.go

    	}
    
    	return cred, owner, ErrNone
    }
    
    // sumHMAC calculate hmac between two input byte array.
    func sumHMAC(key []byte, data []byte) []byte {
    	hash := hmac.New(sha256.New, key)
    	hash.Write(data)
    	return hash.Sum(nil)
    }
    
    // extractSignedHeaders extract signed headers from Authorization header
    func extractSignedHeaders(signedHeaders []string, r *http.Request) (http.Header, APIErrorCode) {
    	reqHeaders := r.Header
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  7. istioctl/pkg/tag/generate_test.go

    	assertFunc(t, wh.Webhooks, defaultWh.Webhooks)
    }
    
    func TestGenerateOptions(t *testing.T) {
    	// Test generate option 'true', should not modify webhooks
    	testGenerateOption(t, true, func(t *testing.T, actual, expected []admitv1.MutatingWebhook) {
    		assert.Equal(t, actual, expected)
    	})
    
    	// Test generate option 'false', should modify webhooks
    	testGenerateOption(t, false, func(t *testing.T, actual, expected []admitv1.MutatingWebhook) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  8. cmd/metacache.go

    	status       scanStatus `msg:"stat"`
    	recursive    bool       `msg:"rec"`
    	dataVersion  uint8      `msg:"v"`
    }
    
    func (m *metacache) finished() bool {
    	return !m.ended.IsZero()
    }
    
    // worthKeeping indicates if the cache by itself is worth keeping.
    func (m *metacache) worthKeeping() bool {
    	if m == nil {
    		return false
    	}
    	cache := m
    	switch {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. internal/s3select/simdj/reader_amd64_test.go

    	return js
    }
    
    var testCases = []struct {
    	name  string
    	array bool
    }{
    	{
    		name: "parking-citations-10",
    	},
    }
    
    func TestNDJSON(t *testing.T) {
    	if !simdjson.SupportedCPU() {
    		t.Skip("Unsupported cpu")
    	}
    
    	for _, tt := range testCases {
    		t.Run(tt.name, func(t *testing.T) {
    			ref := loadCompressed(t, tt.name)
    
    			var err error
    			dst := make(chan simdjson.Object, 100)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  10. internal/config/bool-flag_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package config
    
    import (
    	"testing"
    )
    
    // Test BoolFlag.String()
    func TestBoolFlagString(t *testing.T) {
    	var bf BoolFlag
    
    	testCases := []struct {
    		flag           BoolFlag
    		expectedResult string
    	}{
    		{bf, "off"},
    		{BoolFlag(true), "on"},
    		{BoolFlag(false), "off"},
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 3.5K bytes
    - Viewed (0)
Back to top