- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 52 for Erenst (0.76 sec)
-
cmd/routers.go
// Register storage REST router only if its a distributed setup. registerStorageRESTHandlers(router, endpointServerPools, globalGrid.Load()) // Register peer REST router only if its a distributed setup. registerPeerRESTHandlers(router, globalGrid.Load()) // Register bootstrap REST router for distributed setups. registerBootstrapRESTHandlers(globalGrid.Load())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (1) -
cmd/admin-handlers_test.go
globalEndpoints = mustGetPoolEndpoints(0, erasureDirs...) initAllSubsystems(ctx) initConfigSubsystem(ctx, objLayer) globalIAMSys.Init(ctx, objLayer, globalEtcdClient, 2*time.Second) // Setup admin mgmt REST API handlers. adminRouter := mux.NewRouter() registerAdminRouter(adminRouter, true) return &adminErasureTestBed{ erasureDirs: erasureDirs, objLayer: objLayer, router: adminRouter,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/peer-rest-common.go
Klaus Post <******@****.***> 1709924898 +0100
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 2.7K bytes - Viewed (0) -
internal/config/policy/plugin/config.go
return nil } return &AuthZPlugin{ args: args, client: &http.Client{Transport: args.Transport}, } } // IsAllowed - checks given policy args is allowed to continue the REST API. func (o *AuthZPlugin) IsAllowed(args policy.Args) (bool, error) { if o == nil { return false, nil } // Access Management Plugin Input body := make(map[string]interface{}) body["input"] = args
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.8K bytes - Viewed (0) -
docs/bigdata/README.md
fs.s3a.socket.recv.buffer=65536 # Read socket buffer hint fs.s3a.socket.send.buffer=65536 # Write socket buffer hint fs.s3a.threads.max=2048 # Maximum number of threads for S3A ``` The rest of the other optimization options are discussed in the links below - [https://hadoop.apache.org/docs/current/hadoop-aws/tools/hadoop-aws/index.html](https://hadoop.apache.org/docs/current/hadoop-aws/tools/hadoop-aws/index.html)
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 14.7K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// Retry unit interval var lockRetryMinInterval time.Duration var lockRetryBackOff func(*rand.Rand, uint) time.Duration func init() { // Check for MINIO_DSYNC_TRACE env variable, if set logging will be enabled for failed REST operations. dsyncLog = env.Get("_MINIO_DSYNC_TRACE", "0") == "1" lockRetryMinInterval = 250 * time.Millisecond if lri := env.Get("_MINIO_LOCK_RETRY_INTERVAL", ""); lri != "" { v, err := strconv.Atoi(lri)
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) -
cmd/metrics-v3-system-network.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "github.com/minio/minio/internal/rest" ) const ( internodeErrorsTotal MetricName = "errors_total" internodeDialErrorsTotal MetricName = "dial_errors_total" internodeDialAvgTimeNanos MetricName = "dial_avg_time_nanos"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 2.4K bytes - Viewed (0) -
cmd/lock-rest-client.go
} // RLock calls read lock REST API. func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRLock, &args) } // Lock calls lock REST API. func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCLock, &args) } // RUnlock calls read unlock REST API.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 24 17:07:14 GMT 2023 - 3.3K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
if ver.header.Type == invalidVersionType { t.Errorf("Invalid result returned: %v", ver.header) } } }) t.Run(fmt.Sprintf("modtime-q%d", i), func(t *testing.T) { // Mutate modtime, but rest is consistent. vMod := make([][]xlMetaV2ShallowVersion, 0, len(vers)) for i, ver := range vers { newVers := make([]xlMetaV2ShallowVersion, 0, len(ver)) for _, v := range ver {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
cmd/notification.go
// setup becoming a reality we must try to shard the work properly such as // pick 10 nodes that precisely can send those 100 requests the first node // in the 10 node shard would coordinate between other 9 shards to get the // rest of the `99*9` requests. // // This essentially splits the workload properly and also allows for network // utilization to be optimal, instead of blindly throttling the way we are
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0)