- Sort Score
- Result 10 results
- Languages All
Results 951 - 960 of 1,423 for Func (0.06 sec)
-
cmd/metacache-server-pool.go
"github.com/minio/minio/internal/grid" xioutil "github.com/minio/minio/internal/ioutil" ) func renameAllBucketMetacache(epPath string) error { // Rename all previous `.minio.sys/buckets/<bucketname>/.metacache` to // to `.minio.sys/tmp/` for deletion. return readDirFn(pathJoin(epPath, minioMetaBucket, bucketMetaPrefix), func(name string, typ os.FileMode) error { if typ == os.ModeDir {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/scannermetric_string.go
// Code generated by "stringer -type=scannerMetric -trimprefix=scannerMetric data-scanner-metric.go"; DO NOT EDIT. package cmd import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[scannerMetricReadMetadata-0] _ = x[scannerMetricCheckMissing-1] _ = x[scannerMetricSaveUsage-2]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 1.7K bytes - Viewed (0) -
cmd/bitrot_test.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "io" "testing" ) func testBitrotReaderWriterAlgo(t *testing.T, bitrotAlgo BitrotAlgorithm) { tmpDir := t.TempDir() volume := "testvol" filePath := "testfile" disk, err := newLocalXLStorage(tmpDir) if err != nil { t.Fatal(err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 2.1K bytes - Viewed (0) -
istioctl/pkg/util/configdump/util.go
ecds configTypeURL = "type.googleapis.com/envoy.admin.v3.EcdsConfigDump" ) // getSection takes a TypeURL and returns the types.Any from the config dump corresponding to that URL func (w *Wrapper) getSection(sectionTypeURL configTypeURL) (*anypb.Any, error) { var dumpAny *anypb.Any for _, conf := range w.Configs { if conf.TypeUrl == string(sectionTypeURL) { dumpAny = conf } }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sun Dec 24 08:16:26 UTC 2023 - 2.1K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
// ---------- // Places a quota configuration on the specified bucket. The quota // specified in the quota configuration will be applied by default // to enforce total quota for the specified bucket. func (a adminAPIHandlers) PutBucketQuotaConfigHandler(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, _ := validateAdminReq(ctx, w, r, policy.SetBucketQuotaAdminAction) if objectAPI == nil { return
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 33.2K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
t.Errorf("Read error: got %T, want testError1", err) } } func TestRingBufferCloseErrorUnblocks(t *testing.T) { const sz = 100 rb := New(sz).SetBlocking(true) testCancel := func(fn func()) { t.Helper() defer timeout(5 * time.Second)() rb.Reset() done := make(chan struct{}) go func() { defer close(done) time.Sleep(10 * time.Millisecond) fn() }()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
internal/config/identity/ldap/config.go
type Config struct { LDAP ldap.Config stsExpiryDuration time.Duration // contains converted value } // Enabled returns if LDAP is enabled. func (l *Config) Enabled() bool { return l.LDAP.Enabled } // Clone returns a cloned copy of LDAP config. func (l *Config) Clone() Config { if l == nil { return Config{} } cfg := Config{ LDAP: l.LDAP.Clone(), stsExpiryDuration: l.stsExpiryDuration,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 07 12:59:47 UTC 2024 - 8.4K bytes - Viewed (0) -
internal/bucket/encryption/bucket-sse-config.go
// Algo returns the SSE algorithm specified by the SSE configuration. func (b *BucketSSEConfig) Algo() Algorithm { for _, rule := range b.Rules { return rule.DefaultEncryptionAction.Algorithm } return "" } // KeyID returns the KMS key ID specified by the SSE configuration. // If the SSE configuration does not specify SSE-KMS it returns an // empty key ID. func (b *BucketSSEConfig) KeyID() string { for _, rule := range b.Rules {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 4.9K bytes - Viewed (0) -
internal/config/heal/heal.go
// -1 for not enabled // // 0 for contiunous bitrot scanning // // >0 interval duration between cycles func (opts Config) BitrotScanCycle() (d time.Duration) { configMutex.RLock() defer configMutex.RUnlock() return opts.cache.bitrotCycle } // Clone safely the heal configuration func (opts Config) Clone() (int, time.Duration, string) { configMutex.RLock() defer configMutex.RUnlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.9K bytes - Viewed (0) -
logger/sql.go
func ExplainSQL(sql string, numericPlaceholder *regexp.Regexp, escaper string, avars ...interface{}) string { var ( convertParams func(interface{}, int) vars = make([]string, len(avars)) ) convertParams = func(v interface{}, idx int) { switch v := v.(type) { case bool: vars[idx] = strconv.FormatBool(v)
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Mar 21 08:00:02 UTC 2024 - 5K bytes - Viewed (0)