- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for demonte (0.18 sec)
-
cmd/tier-handlers.go
) var ( // error returned when remote tier already exists errTierAlreadyExists = AdminError{ Code: "XMinioAdminTierAlreadyExists", Message: "Specified remote tier already exists", StatusCode: http.StatusConflict, } // error returned when remote tier is not found errTierNotFound = AdminError{ Code: "XMinioAdminTierNotFound", Message: "Specified remote tier was not found",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 19:52:44 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/grid/trace.go
func (c *Connection) traceRequests(p *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]) { c.trace = &tracer{ Publisher: p, TraceType: madmin.TraceInternal, Prefix: "grid", Local: c.Local, Remote: c.Remote, Subroute: "", } } // subroute adds a specific subroute to the request. func (c *tracer) subroute(subroute string) *tracer { if c == nil { return nil } c2 := *c c2.Subroute = subroute
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 22:54:54 GMT 2024 - 4K bytes - Viewed (0) -
cmd/storage-errors.go
// errDriveIsRoot - cannot use the disk since its a root disk. var errDriveIsRoot = StorageErr("drive is part of root drive, will not be used") // errFaultyRemoteDisk - remote disk is faulty. var errFaultyRemoteDisk = StorageErr("remote drive is faulty") // errFaultyDisk - disk is faulty. var errFaultyDisk = StorageErr("drive is faulty") // errDiskAccessDenied - we don't have write permissions on disk.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/config/api/help.go
Optional: true, Type: "csv", }, config.HelpKV{ Key: apiRemoteTransportDeadline, Description: `set the deadline for API requests on remote transports while proxying between federated instances e.g. "2h"` + defaultHelpPostfix(apiRemoteTransportDeadline), Optional: true, Type: "duration", }, config.HelpKV{ Key: apiListQuorum,
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/event/arn_test.go
func TestParseARN(t *testing.T) { testCases := []struct { s string expectedARN *ARN expectErr bool }{ {"", nil, true}, {"arn:minio:sqs:::", nil, true}, {"arn:minio:sqs::1:webhook:remote", nil, true}, {"arn:aws:sqs::1:webhook", nil, true}, {"arn:minio:sns::1:webhook", nil, true}, {"arn:minio:sqs::1:webhook", &ARN{TargetID{"1", "webhook"}, ""}, false},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 3.8K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
retries++ // after 20 retries start logging that servers are not reachable yet if retries >= 20 { logger.Info(fmt.Sprintf("Waiting for at least %d remote servers with valid configuration to be online", len(clnts)/2)) if len(offlineEndpoints) > 0 { logger.Info(fmt.Sprintf("Following servers are currently offline or unreachable %s", offlineEndpoints)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/config/cache/remote.go
} if oi.CacheControl != "" { w.Header().Set(xhttp.CacheControl, oi.CacheControl) } statusCode() } // CondCheck represents the conditional request made to the remote cache // for validation during GET/HEAD object requests. type CondCheck struct { ObjectInfo IfMatch string `json:"ifMatch,omitempty" msg:",omitempty"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 21:46:17 GMT 2023 - 3.7K bytes - Viewed (0) -
internal/grid/debug.go
func (t *TestGrid) WaitAllConnect(ctx context.Context) { for _, manager := range t.Managers { for _, remote := range manager.Targets() { if manager.HostName() == remote { continue } if err := manager.Connection(remote).WaitForConnect(ctx); err != nil { panic(err) } } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/config/cache/cache.go
Value: "", }, } // Config represents the subnet related configuration type Config struct { // Flag indicating whether cache is enabled. Enable bool `json:"enable"` // Endpoint for caching uses remote mcache server to // store and retrieve pre-condition check entities such as // Etag and ModTime of an object + version Endpoint string `json:"endpoint"` // BlockSize indicates the maximum object size below which
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/dsync/locker.go
// Canceling the context will abort the remote call. // In that case, the resource may or may not be unlocked. RUnlock(ctx context.Context, args LockArgs) (bool, error) // Do write unlock for given LockArgs. It should return // * a boolean to indicate success/failure of the operation // * an error on failure of unlock request operation. // Canceling the context will abort the remote call.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0)