- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 397 for deploymentid (0.35 sec)
-
cmd/site-replication.go
} if info.DeploymentID != v.DeploymentID { return madmin.ReplicateEditStatus{}, errSRInvalidRequest(fmt.Errorf("Endpoint %s does not belong to deployment expected: %s (found %s) ", peer.Endpoint, v.DeploymentID, info.DeploymentID)) } } } // if disable/enable ILM expiry replication, deployment id not needed.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 184.1K bytes - Viewed (1) -
internal/logger/reqinfo.go
sync.RWMutex } // NewReqInfo : func NewReqInfo(remoteHost, userAgent, deploymentID, requestID, api, bucket, object string) *ReqInfo { return &ReqInfo{ RemoteHost: remoteHost, UserAgent: userAgent, API: api, DeploymentID: deploymentID, RequestID: requestID, BucketName: bucket, ObjectName: object, } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/site-replication-utils.go
return nil } for _, peer := range info.Sites { if peer.DeploymentID == globalDeploymentID() { continue } rs, err := loadSiteResyncMetadata(ctx, objAPI, peer.DeploymentID) if err != nil { return err } sm.Lock() if _, ok := sm.peerResyncMap[peer.DeploymentID]; !ok { sm.peerResyncMap[peer.DeploymentID] = resyncState{resyncID: rs.ResyncID, LastSaved: time.Time{}}
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.9K bytes - Viewed (1) -
cmd/perf-tests.go
// skip self if globalDeploymentID() == info.DeploymentID { continue } info := info wg.Add(connectionsPerPeer) for i := 0; i < connectionsPerPeer; i++ { go func() { defer wg.Done() ctx, cancel := context.WithTimeout(ctx, duration+10*time.Second) defer cancel() perfNetRequest( ctx, info.DeploymentID,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
internal/logger/target/console/console.go
apiString += "(" + args + ")" } } } else { apiString = "INTERNAL" } timeString := "Time: " + entry.Time.Format(logger.TimeFormat) var deploymentID string if entry.DeploymentID != "" { deploymentID = "\nDeploymentID: " + entry.DeploymentID } var requestID string if entry.RequestID != "" { requestID = "\nRequestID: " + entry.RequestID } var remoteHost string
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/logger/message/audit/entry.go
func NewEntry(deploymentID string) audit.Entry { return audit.Entry{ Version: Version, DeploymentID: deploymentID, Time: time.Now().UTC(), } } // ToEntry - constructs an audit entry from a http request func ToEntry(w http.ResponseWriter, r *http.Request, reqClaims map[string]interface{}, deploymentID string) audit.Entry { entry := NewEntry(deploymentID)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.2K bytes - Viewed (0) -
docs/debugging/hash-set/main.go
flag.StringVar(&deploymentID, "deployment-id", "", "MinIO deployment ID, obtained from 'format.json'") flag.IntVar(&setCount, "set-count", 0, "Total set count") flag.IntVar(&shards, "shards", 0, "Total shards count") flag.BoolVar(&verbose, "v", false, "Display all objects") flag.Parse() if deploymentID == "" { log.Fatalln("deployment ID is mandatory") } if setCount == 0 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.7K bytes - Viewed (0) -
cmd/site-replication_test.go
expNames []string }{ // Test1: missing some sites in replicated setup { []madmin.PeerInfo{ {Endpoint: "minio1:9000", Name: "minio1", DeploymentID: "dep1"}, {Endpoint: "minio2:9000", Name: "minio2", DeploymentID: "dep2"}, {Endpoint: "minio3:9000", Name: "minio3", DeploymentID: "dep3"}, }, set.CreateStringSet("dep1", "dep2", "dep3"), set.CreateStringSet("dep1"), []string{"minio2", "minio3"}, },
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 2.2K bytes - Viewed (0) -
cmd/site-replication-metrics.go
s.XferRateSml.measure.updateExponentialMovingAverage(time.Now()) } } // SRMetric captures replication metrics for a deployment type SRMetric struct { DeploymentID string `json:"deploymentID"` Endpoint string `json:"endpoint"` TotalDowntime time.Duration `json:"totalDowntime"` LastOnline time.Time `json:"lastOnline"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/prepare-storage.go
return nil, nil, errInvalidArgument } globalDeploymentIDPtr.Store(&format.ID) return storageDisks, format, nil } // Format disks before initialization of object layer. func waitForFormatErasure(firstDisk bool, endpoints Endpoints, poolCount, setCount, setDriveCount int, deploymentID string) ([]StorageAPI, *formatErasureV3, error) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0)