Search Options

Results per page
Sort
Preferred Languages
Advance

Results 741 - 750 of 1,387 for funcs (0.02 sec)

  1. internal/crypto/key.go

    type ObjectKey [32]byte
    
    // GenerateKey generates a unique ObjectKey from a 256 bit external key
    // and a source of randomness. If random is nil the default PRNG of the
    // system (crypto/rand) is used.
    func GenerateKey(extKey []byte, random io.Reader) (key ObjectKey) {
    	if random == nil {
    		random = rand.Reader
    	}
    	if len(extKey) != 32 { // safety check
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 20:28:10 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. istioctl/pkg/describe/describe_test.go

       Match: /prefix*
    `,
    		},
    	}
    
    	for i, c := range cases {
    		t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.args, " ")), func(t *testing.T) {
    			verifyExecAndK8sConfigTestCaseTestOutput(t, c)
    		})
    	}
    }
    
    func TestGetRevisionFromPodAnnotation(t *testing.T) {
    	cases := []struct {
    		anno klabels.Set
    
    		expected string
    	}{
    		{
    			anno: klabels.Set{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  3. internal/event/target/redis.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *RedisTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *RedisTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *RedisTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. internal/hash/checksum.go

    	Encoded   string
    	Raw       []byte
    	WantParts int
    }
    
    // Is returns if c is all of t.
    func (c ChecksumType) Is(t ChecksumType) bool {
    	if t == ChecksumNone {
    		return c == ChecksumNone
    	}
    	return c&t == t
    }
    
    // Key returns the header key.
    // returns empty string if invalid or none.
    func (c ChecksumType) Key() string {
    	switch {
    	case c.Is(ChecksumCRC32):
    		return xhttp.AmzChecksumCRC32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. cmd/endpoint_test.go

    		}
    	}
    }
    
    func TestCreateEndpoints(t *testing.T) {
    	tempGlobalMinioPort := globalMinioPort
    	defer func() {
    		globalMinioPort = tempGlobalMinioPort
    	}()
    	globalMinioPort = "9000"
    
    	// Filter ipList by IPs those do not start with '127.'.
    	nonLoopBackIPs := localIP4.FuncMatch(func(ip string, matchString string) bool {
    		return !net.ParseIP(ip).IsLoopback()
    	}, "")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jan 13 07:53:03 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  6. association.go

    		}
    	} else {
    		association.Error = err
    	}
    
    	return association
    }
    
    func (association *Association) Unscoped() *Association {
    	return &Association{
    		DB:           association.DB,
    		Relationship: association.Relationship,
    		Error:        association.Error,
    		Unscope:      true,
    	}
    }
    
    func (association *Association) Find(out interface{}, conds ...interface{}) error {
    	if association.Error == nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 10:49:45 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  7. cmd/generic-handlers.go

    	loginPathPrefix = SlashSeparator + "login"
    )
    
    func guessIsBrowserReq(r *http.Request) bool {
    	aType := getRequestAuthType(r)
    	return strings.Contains(r.Header.Get("User-Agent"), "Mozilla") &&
    		globalBrowserEnabled && aType == authTypeAnonymous
    }
    
    func setBrowserRedirectMiddleware(h http.Handler) http.Handler {
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  8. docs/debugging/s3-verify/main.go

    	wg.Add(2)
    	go func() {
    		defer wg.Done()
    		srcSize, err := io.Copy(srcSha256, sobj)
    		if err != nil {
    			fmt.Printf("unreadable on source: %s (%s)\n", srcCtnt.Key, err)
    			sourceFailed = true
    		} else if srcSize != srcCtnt.Size {
    			fmt.Printf("unreadable on source - size differs upon read: %s\n", srcCtnt.Key)
    			sourceFailed = true
    		}
    	}()
    	go func() {
    		defer wg.Done()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  9. istioctl/pkg/cli/kubectl_factory.go

    )
    
    type Factory struct {
    	kube.PartialFactory
    	full util.Factory
    }
    
    func (f Factory) NewBuilder() *resource.Builder {
    	return f.full.NewBuilder()
    }
    
    func (f Factory) ClientForMapping(mapping *meta.RESTMapping) (resource.RESTClient, error) {
    	return f.full.ClientForMapping(mapping)
    }
    
    func (f Factory) UnstructuredClientForMapping(mapping *meta.RESTMapping) (resource.RESTClient, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 09 18:17:49 UTC 2023
    - 2K bytes
    - Viewed (0)
  10. tests/soft_delete_test.go

    	}
    }
    
    func TestDeletedAtUnMarshal(t *testing.T) {
    	expected := &gorm.Model{}
    	b, _ := json.Marshal(expected)
    
    	result := &gorm.Model{}
    	_ = json.Unmarshal(b, result)
    	if result.DeletedAt != expected.DeletedAt {
    		t.Errorf("Failed, result.DeletedAt: %v is not same as expected.DeletedAt: %v", result.DeletedAt, expected.DeletedAt)
    	}
    }
    
    func TestDeletedAtOneOr(t *testing.T) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Feb 01 06:40:55 UTC 2023
    - 5.7K bytes
    - Viewed (0)
Back to top