Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 1,214 for Func (0.04 sec)

  1. cmd/storage-rest-common_gen.go

    func (z *nsScannerOptions) Msgsize() (s int) {
    	s = 1 + 3 + msgp.StringPrefixSize + len(z.DiskID) + 2 + msgp.IntSize + 2
    	if z.Cache == nil {
    		s += msgp.NilSize
    	} else {
    		s += z.Cache.Msgsize()
    	}
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *nsScannerResp) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/and.go

    	Tags                  []Tag    `xml:"Tag,omitempty"`
    }
    
    // isEmpty returns true if Tags field is null
    func (a And) isEmpty() bool {
    	return len(a.Tags) == 0 && !a.Prefix.set &&
    		a.ObjectSizeGreaterThan == 0 && a.ObjectSizeLessThan == 0
    }
    
    // Validate - validates the And field
    func (a And) Validate() error {
    	// > This is used in a Lifecycle Rule Filter to apply a logical AND to two or more predicates.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. callbacks/delete.go

    					return
    				}
    			}
    		}
    
    	}
    }
    
    func Delete(config *Config) func(db *gorm.DB) {
    	supportReturning := utils.Contains(config.DeleteClauses, "RETURNING")
    
    	return func(db *gorm.DB) {
    		if db.Error != nil {
    			return
    		}
    
    		if db.Statement.Schema != nil {
    			for _, c := range db.Statement.Schema.DeleteClauses {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Feb 25 02:48:23 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  4. cmd/tier-sweeper.go

    func newObjSweeper(bucket, object string) *objSweeper {
    	return &objSweeper{
    		Object: object,
    		Bucket: bucket,
    	}
    }
    
    // WithVersion sets the version ID from v
    func (os *objSweeper) WithVersion(vid string) *objSweeper {
    	os.VersionID = vid
    	return os
    }
    
    // WithVersioning sets bucket versioning for sweeper.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 17 05:09:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. cmd/tier-last-day-stats_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgDailyAllTierStats(b *testing.B) {
    	v := DailyAllTierStats{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgDailyAllTierStats(b *testing.B) {
    	v := DailyAllTierStats{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. internal/bucket/bandwidth/monitor_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBucketBandwidthReport(b *testing.B) {
    	v := BucketBandwidthReport{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBucketBandwidthReport(b *testing.B) {
    	v := BucketBandwidthReport{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  7. internal/bucket/replication/datatypes_gen.go

    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *StatusType) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 string
    		zb0001, err = dc.ReadString()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = StatusType(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z StatusType) EncodeMsg(en *msgp.Writer) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 19:08:18 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  8. internal/event/target/nats.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *NATSTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *NATSTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *NATSTarget) 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
    - 12.9K bytes
    - Viewed (0)
  9. internal/rest/client.go

    	TraceOutput io.Writer // Debug trace output
    
    	httpClient *http.Client
    	url        *url.URL
    	auth       func() string
    
    	sync.RWMutex // mutex for lastErr
    	lastErr      error
    	lastErrTime  time.Time
    }
    
    type restError string
    
    func (e restError) Error() string {
    	return string(e)
    }
    
    func (e restError) Timeout() bool {
    	return true
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  10. cmd/server-startup-msg.go

    	"github.com/minio/minio/internal/logger"
    )
    
    // generates format string depending on the string length and padding.
    func getFormatStr(strLen int, padding int) string {
    	formatStr := fmt.Sprintf("%ds", strLen+padding)
    	return "%" + formatStr
    }
    
    // Prints the formatted startup message.
    func printStartupMessage(apiEndpoints []string, err error) {
    	banner := strings.Repeat("-", len(MinioBannerName))
    	if globalIsDistErasure {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 23 14:11:35 UTC 2024
    - 6.2K bytes
    - Viewed (0)
Back to top