- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for priority (2.98 sec)
-
internal/config/api/help.go
Optional: true, Type: "string", }, config.HelpKV{ Key: apiReplicationPriority, Description: `set replication priority` + defaultHelpPostfix(apiReplicationPriority), Optional: true, Type: "string", }, config.HelpKV{ Key: apiReplicationMaxWorkers,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 15 01:07:19 GMT 2024 - 4.7K bytes - Viewed (0) -
internal/config/api/api.go
apiCorsAllowOrigin = "cors_allow_origin" apiRemoteTransportDeadline = "remote_transport_deadline" apiListQuorum = "list_quorum" apiReplicationPriority = "replication_priority" apiReplicationMaxWorkers = "replication_max_workers" apiTransitionWorkers = "transition_workers" apiStaleUploadsCleanupInterval = "stale_uploads_cleanup_interval"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
cmd/bucket-replication.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/site-replication.go
}) } func getPriorityHelper(replicationConfig replication.Config) int { maxPrio := 0 for _, rule := range replicationConfig.Rules { if rule.Priority > maxPrio { maxPrio = rule.Priority } } // leave some gaps in priority numbers for flexibility return maxPrio + 10 } // returns a slice with site names participating in site replciation but unspecified while adding // a new site.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
internal/bucket/replication/replication_test.go
eteReplication><Status>Disabled</Status></DeleteReplication><Prefix>prefix</Prefix><Priority>2</Priority><Destination><Bucket>arn:minio:replication:xxx::destinationbucket2</Bucket></Destination></Rule><Rule><Status>Enabled</Status><DeleteMarkerReplication><Status>Disabled</Status></DeleteMarkerReplication><DeleteReplication><Status>Disabled</Status></DeleteReplication><Prefix>prefix</Prefix><Priority>4</Priority><Destination><Bucket>arn:minio:replication:xxx::destinationbucket2</Bucket></Destina...
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 32.5K bytes - Viewed (0) -
internal/bucket/replication/replication.go
targetMap[r.Destination.Bucket] = struct{}{} } if err := r.Validate(bucket, sameTarget); err != nil { return err } if _, ok := priorityMap[strconv.Itoa(r.Priority)]; ok { return errReplicationUniquePriority } priorityMap[strconv.Itoa(r.Priority)] = struct{}{} if r.Destination.LegacyArn() { legacyArn = true } if c.RoleArn == "" && !r.Destination.TargetArn() { return errDestinationArnMissing
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) -
internal/http/dial_others.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package http import ( "context" "net" "syscall" "time" ) // TODO: if possible implement for non-linux platforms, not a priority at the moment // //nolint:unused func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error { return func(network, address string, c syscall.RawConn) error { return nil } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 1.6K bytes - Viewed (0) -
cmd/handler-api.go
t.mu.RLock() defer t.mu.RUnlock() if t.replicationPriority == "" { return replicationPoolOpts{ Priority: "auto", MaxWorkers: WorkerMaxLimit, } } return replicationPoolOpts{ Priority: t.replicationPriority, MaxWorkers: t.replicationMaxWorkers, } } func (t *apiConfig) getTransitionWorkers() int { t.mu.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 10K bytes - Viewed (0) -
cmd/bucket-replication_test.go
) var configs = []replication.Config{ { // Config0 - Replication config has no filters, existing object replication enabled Rules: []replication.Rule{ { Status: replication.Enabled, Priority: 1, DeleteMarkerReplication: replication.DeleteMarkerReplication{Status: replication.Enabled}, DeleteReplication: replication.DeleteReplication{Status: replication.Enabled},
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/config/notify/help.go
Optional: true, Type: "string", Sensitive: true, Secret: true, }, config.HelpKV{ Key: target.MqttQoS, Description: "set the quality of service priority, defaults to '0'", Optional: true, Type: "number", }, config.HelpKV{ Key: target.MqttKeepAliveInterval, Description: "keep-alive interval for MQTT connections in s,m,h,d",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0)