- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 233 for presync (0.27 sec)
-
cmd/bucket-replication-utils.go
} // ResyncStatusType status of resync operation type ResyncStatusType int const ( // NoResync - no resync in progress NoResync ResyncStatusType = iota // ResyncPending - resync pending ResyncPending // ResyncCanceled - resync canceled ResyncCanceled // ResyncStarted - resync in progress ResyncStarted // ResyncCompleted - resync finished ResyncCompleted
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K bytes - Viewed (0) -
cmd/bucket-replication.go
default: return brs, fmt.Errorf("unexpected resync meta version: %d", brs.Version) } return brs, nil } // save resync status to resync.bin func saveResyncStatus(ctx context.Context, bucket string, brs BucketReplicationResyncStatus, objectAPI ObjectLayer) error { data := make([]byte, 4, brs.Msgsize()+4) // Initialize the resync meta header.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
cmd/globals.go
// Allocated etcd endpoint for config and bucket DNS. globalEtcdClient *etcd.Client // Cluster replication manager. globalSiteReplicationSys SiteReplicationSys // Cluster replication resync metrics globalSiteResyncMetrics *siteResyncMetrics // Is set to true when Bucket federation is requested // and is 'true' when etcdConfig.PathPrefix is empty globalBucketFederation bool
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 16.4K bytes - Viewed (0) -
internal/kms/config.go
// environment and returns a: // // - connection to MinIO KMS if the "MINIO_KMS_SERVER" variable is present. // - connection to MinIO KES if the "MINIO_KMS_KES_ENDPOINT" is present. // - connection to a "local" KMS implementation using a static key if the // "MINIO_KMS_SECRET_KEY" or "MINIO_KMS_SECRET_KEY_FILE" is present. // // It returns an error if connecting to the KMS implementation fails,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 14:31:26 UTC 2024 - 13.9K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultDependencyManagementImporter.java
for (Dependency dependency : source.getDependencies()) { String key = dependency.getManagementKey(); Dependency present = dependencies.putIfAbsent(key, dependency); if (present != null && !equals(dependency, present) && !directDependencies.contains(key)) { // TODO: https://issues.apache.org/jira/browse/MNG-8004 problems.add(
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Jun 06 06:13:27 UTC 2024 - 6K bytes - Viewed (0) -
tools/istio-iptables/pkg/builder/iptables_builder_impl.go
for _, r := range rules { chainTable := fmt.Sprintf("%s:%s", r.chain, r.table) // Create new chain if key: `chainTable` isn't present in map if !chainTableLookupSet.Contains(chainTable) { // Ignore chain creation for built-in chains for iptables if _, present := constants.BuiltInChainsMap[r.chain]; !present { cmd := []string{"-t", r.table, "-N", r.chain} output = append(output, cmd) chainTableLookupSet.Insert(chainTable)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 14:29:54 UTC 2024 - 8.3K bytes - Viewed (0) -
maven-model-builder/src/main/java/org/apache/maven/model/composition/DefaultDependencyManagementImporter.java
for (Dependency dependency : source.getDependencies()) { String key = dependency.getManagementKey(); Dependency present = dependencies.putIfAbsent(key, dependency); if (present != null && !equals(dependency, present) && !directDependencies.contains(key)) { // TODO: https://issues.apache.org/jira/browse/MNG-8004
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Jun 06 06:13:27 UTC 2024 - 5.8K bytes - Viewed (0) -
src/cmd/compile/internal/types2/api.go
// dir and mode are ignored (since they are not present). Import(path string) (*Package, error) } // ImportMode is reserved for future use. type ImportMode int // An ImporterFrom resolves import paths to packages; it // supports vendoring per https://golang.org/s/go15vendor. // Use go/importer to obtain an ImporterFrom implementation. type ImporterFrom interface { // Importer is present for backward-compatibility. Calling
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 13:48:53 UTC 2024 - 17.4K bytes - Viewed (0) -
analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/annotations/KtAnnotationsList.kt
public fun hasAnnotation(classId: ClassId): Boolean = contains(classId) /** * A list of annotations applied with specified [classId]. * * To check if annotation is present, please use [contains]. * * The semantic is equivalent to * ``` * annotationsList.annotationsByClassId(classId) == annotationsList.annotations.filter { it.classId == classId } * ``` */
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 2.5K bytes - Viewed (0) -
src/sync/map.go
// The loaded result reports whether the key was present. func (m *Map) LoadAndDelete(key any) (value any, loaded bool) { read := m.loadReadOnly() e, ok := read.m[key] if !ok && read.amended { m.mu.Lock() read = m.loadReadOnly() e, ok = read.m[key] if !ok && read.amended { e, ok = m.dirty[key] delete(m.dirty, key) // Regardless of whether the entry was present, record a miss: this key
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 15.6K bytes - Viewed (0)