- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 66 for static (0.19 sec)
-
cmd/site-replication-utils.go
switch bktStatus { case ResyncCompleted: st.BucketStatuses[o.bucket] = ResyncCompleted st.Status = siteResyncStatus(st.Status, st.BucketStatuses) st.LastUpdate = UTCNow() sm.resyncStatus[o.resyncID] = st case ResyncFailed: st.BucketStatuses[o.bucket] = ResyncFailed st.Status = siteResyncStatus(st.Status, st.BucketStatuses) st.LastUpdate = UTCNow() sm.resyncStatus[o.resyncID] = st } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.9K bytes - Viewed (1) -
cmd/bucket-replication_test.go
Rules: []replication.Rule{ { Status: replication.Enabled, Priority: 1, DeleteMarkerReplication: replication.DeleteMarkerReplication{Status: replication.Enabled}, DeleteReplication: replication.DeleteReplication{Status: replication.Enabled}, Filter: replication.Filter{},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 16 09:28:06 GMT 2023 - 12.2K bytes - Viewed (0) -
internal/bucket/replication/replication.go
config.Rules[i].SourceSelectionCriteria = SourceSelectionCriteria{ ReplicaModifications: ReplicaModifications{ Status: Enabled, }, } } // Default DeleteReplication to disabled if unset. if len(config.Rules[i].DeleteReplication.Status) == 0 { config.Rules[i].DeleteReplication = DeleteReplication{ Status: Disabled, } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
} } return replicateNone } var replStatusRegex = regexp.MustCompile(`([^=].*?)=([^,].*?);`) // TargetReplicationStatus - returns replication status of a target func (ri ReplicateObjectInfo) TargetReplicationStatus(arn string) (status replication.StatusType) { repStatMatches := replStatusRegex.FindAllStringSubmatch(ri.ReplicationStatusInternal, -1) for _, repStatMatch := range repStatMatches {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0) -
cmd/global-heal.go
ss.HealPriority = "high" status.HealDisks = append(status.HealDisks, disk.Endpoint) } } sortDisks(ss.Disks) status.Sets = append(status.Sets, ss) } sort.Slice(status.Sets, func(i, j int) bool { return status.Sets[i].ID < status.Sets[j].ID }) backendInfo := o.BackendInfo() status.SCParity = make(map[string]int) status.SCParity[storageclass.STANDARD] = backendInfo.StandardSCParity
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
buildscripts/heal-manual.go
} fmt.Println() for { _, status, err := madmClnt.Heal(context.Background(), "healing-rewrite-bucket", "", opts, start.ClientToken, false, false) if status.Summary == "finished" { fmt.Println("Healstatus on items ===") for _, item := range status.Items { if err = enc.Encode(&item); err != nil { log.Fatalln(err) } } break } if status.Summary == "stopped" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 09:47:58 GMT 2024 - 2.3K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
writeErrorResponseJSON(ctx, w, apiErr, r.URL) return } status, err := pools.Status(r.Context(), idx) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } adminLogIf(r.Context(), json.NewEncoder(w).Encode(&status)) } func (a adminAPIHandlers) ListPools(w http.ResponseWriter, r *http.Request) { ctx := r.Context()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 10.9K bytes - Viewed (0) -
internal/logger/target/http/http.go
func (h *Target) IsOnline(ctx context.Context) bool { return atomic.LoadInt32(&h.status) == statusOnline } // Stats returns the target statistics. func (h *Target) Stats() types.TargetStats { h.logChMu.RLock() queueLength := len(h.logCh) h.logChMu.RUnlock() stats := types.TargetStats{ TotalMessages: atomic.LoadInt64(&h.totalMessages),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
internal/http/headers.go
MinIOSourceDeleteMarkerDelete = "x-minio-source-deletemarker-delete" // Header indicates permanent delete replication status. MinIODeleteReplicationStatus = "X-Minio-Replication-Delete-Status" // Header indicates delete-marker replication status. MinIODeleteMarkerReplicationStatus = "X-Minio-Replication-DeleteMarker-Status" // Header indicates if its a GET/HEAD proxy request for active-active replication
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 10.4K bytes - Viewed (1) -
cmd/object-lambda-handlers.go
w.Header()[k[len(trim):]] = v } } } func fwdStatusToAPIError(resp *http.Response) *APIError { if status := resp.Header.Get(xhttp.AmzFwdStatus); status != "" && StatusCode(status) > -1 { apiErr := &APIError{ HTTPStatusCode: StatusCode(status), Description: resp.Header.Get(xhttp.AmzFwdErrorMessage), Code: resp.Header.Get(xhttp.AmzFwdErrorCode), }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Sep 15 04:58:17 GMT 2023 - 10.2K bytes - Viewed (1)