Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 411 - 420 of 1,039 for take (0.02 seconds)

  1. internal/event/config.go

    	type filterRuleWrapper FilterRule
    	return e.EncodeElement(filterRuleWrapper(filter), start)
    }
    
    // UnmarshalXML - decodes XML data.
    func (filter *FilterRule) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type filterRule FilterRule
    	rule := filterRule{}
    	if err := d.DecodeElement(&rule, &start); err != nil {
    		return err
    	}
    
    	if rule.Name != "prefix" && rule.Name != "suffix" {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  2. src/bytes/bytes_test.go

    	if allocs > 0 {
    		t.Errorf("Equal allocated %v times", allocs)
    	}
    }
    
    func TestEqualExhaustive(t *testing.T) {
    	var size = 128
    	if testing.Short() {
    		size = 32
    	}
    	a := make([]byte, size)
    	b := make([]byte, size)
    	b_init := make([]byte, size)
    	// randomish but deterministic data
    	for i := 0; i < size; i++ {
    		a[i] = byte(17 * i)
    		b_init[i] = byte(23*i + 100)
    	}
    
    	for len := 0; len <= size; len++ {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Dec 23 23:54:14 GMT 2025
    - 62.9K bytes
    - Click Count (0)
  3. statement.go

    		newStmt.SQL.WriteString(stmt.SQL.String())
    		newStmt.Vars = make([]interface{}, 0, len(stmt.Vars))
    		newStmt.Vars = append(newStmt.Vars, stmt.Vars...)
    	}
    
    	for k, c := range stmt.Clauses {
    		newStmt.Clauses[k] = c
    	}
    
    	for k, p := range stmt.Preloads {
    		newStmt.Preloads[k] = p
    	}
    
    	if len(stmt.Joins) > 0 {
    		newStmt.Joins = make([]join, len(stmt.Joins))
    		copy(newStmt.Joins, stmt.Joins)
    	}
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Sep 12 04:33:27 GMT 2025
    - 20.9K bytes
    - Click Count (0)
  4. internal/config/lambda/config.go

    	Webhook map[string]target.WebhookArgs `json:"webhook"`
    }
    
    const (
    	defaultTarget = "1"
    )
    
    // NewConfig - initialize lambda config.
    func NewConfig() Config {
    	// Make sure to initialize lambda targets
    	cfg := Config{
    		Webhook: make(map[string]target.WebhookArgs),
    	}
    	cfg.Webhook[defaultTarget] = target.WebhookArgs{}
    	return cfg
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 1.3K bytes
    - Click Count (0)
  5. helm/minio/templates/post-job.yaml

            {{- end }}
          {{- if .Values.serviceAccount.create }}
          serviceAccountName: {{ .Values.serviceAccount.name }}
          {{- end }}
          {{- if .Values.policies }}
          initContainers:
            - name: minio-make-policy
              image: "{{ .Values.mcImage.repository }}:{{ .Values.mcImage.tag }}"
              {{- if .Values.makePolicyJob.securityContext.enabled }}
              {{- with .Values.makePolicyJob.containerSecurityContext }}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 10 15:48:31 GMT 2024
    - 10.4K bytes
    - Click Count (0)
  6. internal/config/config.go

    func kvFields(input string, keys []string) []string {
    	valueIndexes := make([]int, 0, len(keys))
    	for _, key := range keys {
    		i := strings.Index(input, key+KvSeparator)
    		if i == -1 {
    			continue
    		}
    		valueIndexes = append(valueIndexes, i)
    	}
    
    	sort.Ints(valueIndexes)
    	fields := make([]string, len(valueIndexes))
    	for i := range valueIndexes {
    		j := i + 1
    		if j < len(valueIndexes) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 37.7K bytes
    - Click Count (0)
  7. internal/grid/types_test.go

    		t.Errorf("MSS: %v != %v", v, v2)
    	}
    }
    
    func TestMarshalUnmarshalMSSNil(t *testing.T) {
    	v := MSS(nil)
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	v2 := MSS(make(map[string]string, 1))
    	left, err := v2.UnmarshalMsg(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) != 0 {
    		t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  8. cmd/api-response.go

    	listMultipartUploadsResponse.CommonPrefixes = make([]CommonPrefix, len(multipartsInfo.CommonPrefixes))
    	for index, commonPrefix := range multipartsInfo.CommonPrefixes {
    		listMultipartUploadsResponse.CommonPrefixes[index] = CommonPrefix{
    			Prefix: s3EncodeName(commonPrefix, encodingType),
    		}
    	}
    	listMultipartUploadsResponse.Uploads = make([]Upload, len(multipartsInfo.Uploads))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 35K bytes
    - Click Count (0)
  9. cmd/bucket-targets.go

    func NewBucketTargetSys(ctx context.Context) *BucketTargetSys {
    	sys := &BucketTargetSys{
    		arnRemotesMap: make(map[string]arnTarget),
    		targetsMap:    make(map[string][]madmin.BucketTarget),
    		arnErrsMap:    make(map[string]arnErrs),
    		hc:            make(map[string]epHealth),
    		hcClient:      newHCClient(),
    	}
    	// reload healthCheck endpoints map periodically to remove stale endpoints from the map.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.9K bytes
    - Click Count (0)
  10. cmd/metrics-v3.go

    	// Add the serverName and poolIndex labels to all non-cluster metrics.
    	//
    	// Also create metric group maps and set the cache.
    	metricsCache := newMetricsCache()
    	mgMap := make(map[collectorPath]*MetricsGroup)
    	bucketMGMap := make(map[collectorPath]*MetricsGroup)
    	for _, mg := range allMetricGroups {
    		if !strings.HasPrefix(string(mg.CollectorPath), clusterBasePath) {
    			mg.AddExtraLabels(
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 02 00:55:27 GMT 2024
    - 13.6K bytes
    - Click Count (0)
Back to Top