- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 88 for native (0.17 sec)
-
internal/grid/connection.go
c.handleMessages(ctx, conn) return nil } // reconnected signals the connection has been reconnected. // It will close all active requests and streams. // caller *must* hold reconnectMu. func (c *Connection) reconnected() { c.updateState(StateConnectionError) // Close all active requests. if debugReqs { fmt.Println(c.String(), "Reconnected. Clearing outgoing.") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/admin-heal-ops.go
} err := h.queueHealTask(healSource{ bucket: bucket, object: object, versionID: versionID, opts: &h.settings, }, madmin.HealItemObject) // Wait and proceed if there are active requests waitForLowHTTPReq() return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
docs/metrics/v3.md
| `minio_cluster_notification_current_send_in_progress` | `counter` | Number of concurrent async Send calls active to all targets | | | `minio_cluster_notification_events_errors_total` | `counter` | Events that were failed to be sent to the targets | |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 28.5K bytes - Viewed (0) -
cmd/rebalance-admin.go
ETA time.Duration `json:"eta"` } type rebalancePoolStatus struct { ID int `json:"id"` // Pool index (zero-based) Status string `json:"status"` // Active if rebalance is running, empty otherwise Used float64 `json:"used"` // Percentage used space Progress rebalPoolProgress `json:"progress,omitempty"` // is empty when rebalance is not running }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:43 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/object-api-interface.go
ProxyRequest bool // only set for GET/HEAD in active-active replication scenario ProxyHeaderSet bool // only set for GET/HEAD in active-active replication scenario ReplicationRequest bool // true only if replication request
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0) -
internal/config/errors.go
"Invalid value for batch key rotation workers wait", "Please input a non-negative duration", "keyrotation_workers_wait should be > 0ms", ) ErrInvalidBatchReplicationWorkersWait = newErrFn( "Invalid value for batch replication workers wait", "Please input a non-negative duration", "replication_workers_wait should be > 0ms", ) ErrInvalidBatchExpirationWorkersWait = newErrFn(
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 18 22:25:32 GMT 2024 - 9.1K bytes - Viewed (0) -
docs/sts/ldap.md
# AssumeRoleWithLDAPIdentity [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) ## Introduction MinIO provides a custom STS API that allows integration with LDAP based corporate environments including Microsoft Active Directory. The MinIO server uses a separate LDAP service account to lookup user information. The login flow for a user is as follows: - User provides their AD/LDAP username and password to the STS API.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.4K bytes - Viewed (1) -
internal/event/target/redis.go
return target.ID().String() } // Store returns any underlying store if set. func (target *RedisTarget) Store() event.TargetStore { return target.store } // IsActive - Return true if target is up and active func (target *RedisTarget) IsActive() (bool, error) { if err := target.init(); err != nil { return false, err } return target.isActive() } func (target *RedisTarget) isActive() (bool, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// tolerance is exactly half of the len(*locks) // then we need to make sure we have unlocked // upto tolerance+1 - especially for RUnlock // to ensure that we don't end up with active // read locks on the resource after unlocking // only half of the lockers. return unlocksFailed >= tolerance } return unlocksFailed > tolerance }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
helm/minio/templates/_helper_create_user.txt
if [ $ATTEMPTS -gt $LIMIT ]; then exit 1 ; fi ; sleep 2 ; # 1 second intervals between attempts $MC_COMMAND ; STATUS=$? ; done ; set -e ; # reset `e` as active return 0 } # checkUserExists () # Check if the user exists, by using the exit code of `mc admin user info` checkUserExists() {
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Dec 12 23:43:32 GMT 2023 - 3.2K bytes - Viewed (0)