- Sort Score
- Result 10 results
- Languages All
Results 561 - 570 of 710 for jconst (0.08 sec)
-
internal/event/targetlist.go
package event import ( "context" "fmt" "runtime" "sync" "sync/atomic" "github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/store" "github.com/minio/pkg/v3/workers" ) const ( logSubsys = "notify" // The maximum allowed number of concurrent Send() calls to all configured notifications targets maxConcurrentAsyncSend = 50000 ) // Target - event target interface
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0) -
cmd/handler-api.go
enableODirect bool gzipObjects bool rootAccess bool syncEvents bool objectMaxVersions int64 } const ( cgroupV1MemLimitFile = "/sys/fs/cgroup/memory/memory.limit_in_bytes" cgroupV2MemLimitFile = "/sys/fs/cgroup/memory.max" ) func cgroupMemLimit() (limit uint64) { buf, err := os.ReadFile(cgroupV2MemLimitFile)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 17:07:10 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
globalBucketTargetSys.set(buckets[i], meta) // set remote replication targets } } func (sys *BucketMetadataSys) refreshBucketsMetadataLoop(ctx context.Context) { const bucketMetadataRefresh = 15 * time.Minute sleeper := newDynamicSleeper(2, 150*time.Millisecond, false) t := time.NewTimer(bucketMetadataRefresh) defer t.Stop() for { select { case <-ctx.Done():
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0) -
cmd/bucket-targets.go
"github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7/pkg/credentials" "github.com/minio/minio/internal/bucket/replication" "github.com/minio/minio/internal/crypto" "github.com/minio/minio/internal/kms" ) const ( defaultHealthCheckDuration = 5 * time.Second // default interval for reload of all remote target endpoints defaultHealthCheckReloadDuration = 30 * time.Minute ) type arnTarget struct { Client *TargetClient
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 20.9K bytes - Viewed (0) -
cmd/encryption-v1.go
errInvalidEncryptionParameters = errors.New("The encryption parameters are not applicable to this object") errInvalidEncryptionParametersSSEC = errors.New("SSE-C encryption parameters are not supported on this bucket") ) const ( // SSECustomerKeySize is the size of valid client provided encryption keys in bytes. // Currently AWS supports only AES256. So the SSE-C key size is fixed to 32 bytes. SSECustomerKeySize = 32
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:06:08 UTC 2024 - 37.2K bytes - Viewed (0) -
cmd/erasure-object_test.go
// than small data threshold and checks reading them again func TestPutObjectSmallInlineData(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() const numberOfDisks = 4 // Create an instance of xl backend. obj, fsDirs, err := prepareErasure(ctx, numberOfDisks) if err != nil { t.Fatal(err) } // Cleanup backend directories.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 36.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
if !errors.Is(err, context.Canceled) { storageLogIf(ctx, fmt.Errorf("saving pool.bin for pool index %d failed with: %v", i, err)) } return err } } return nil } const ( poolMetaName = "pool.bin" poolMetaFormat = 1 poolMetaVersionV1 = 1 poolMetaVersion = poolMetaVersionV1 ) // Init() initializes pools and saves additional information about them
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 42.2K bytes - Viewed (1) -
cmd/metacache-walk.go
Limit int // DiskID contains the disk ID of the disk. // Leave empty to not check disk ID. DiskID string } // supported FS for Nlink optimization in readdir. const ( xfs = "XFS" ext4 = "EXT4" ) // WalkDir will traverse a directory and return all entries found. // On success a sorted meta cache stream will be returned. // Metadata has data stripped, if any.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/install/cniconfig_test.go
} goldenFilepath := existingConfFilepath + ".golden" goldenConfig := testutils.ReadFile(t, goldenFilepath) testutils.CompareBytes(t, output, goldenConfig, goldenFilepath) }) } } const ( // For testing purposes, set kubeconfigFilename equivalent to the path in the test files and use __KUBECONFIG_FILENAME__ // CreateCNIConfigFile joins the MountedCNINetDir and KubeconfigFilename if __KUBECONFIG_FILEPATH__ was used
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 01 18:38:14 UTC 2024 - 15.3K bytes - Viewed (0) -
istioctl/pkg/tag/generate.go
"istio.io/istio/operator/pkg/helm" "istio.io/istio/operator/pkg/render" "istio.io/istio/operator/pkg/values" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/maps" ) const ( DefaultRevisionName = "default" istioInjectionWebhookSuffix = "sidecar-injector.istio.io" vwhBaseTemplateName = "istiod-default-validator" operatorNamespace = "operator.istio.io" )
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 13.3K bytes - Viewed (0)