- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 48 for Hagrid (0.2 sec)
-
cmd/metacache-walk.go
var opts WalkDirOptions _, err := opts.UnmarshalMsg(payload) if err != nil { return grid.NewRemoteErr(err) } if !s.checkID(opts.DiskID) { return grid.NewRemoteErr(errDiskNotFound) } ctx, cancel := context.WithCancel(ctx) defer cancel() return grid.NewRemoteErr(s.getStorage().WalkDir(ctx, opts, grid.WriterToChannel(ctx, out)))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/routers.go
// Register bootstrap REST router for distributed setups. registerBootstrapRESTHandlers(globalGrid.Load()) // Register distributed namespace lock routers. registerLockRESTHandlers() // Add grid to router router.Handle(grid.RoutePath, adminMiddleware(globalGrid.Load().Handler(), noGZFlag, noObjLayerFlag)) } // List of some generic middlewares which are applied for all incoming requests. var globalMiddlewares = []mux.MiddlewareFunc{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (1) -
internal/grid/stats.go
// GNU Affero General Public License for more details. // // 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 grid // ConnectionStats contains connection statistics. type ConnectionStats struct { OutgoingStreams int IncomingStreams int
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 902 bytes - Viewed (0) -
internal/grid/grid.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 grid provides single-connection two-way grid communication. package grid import ( "context" "errors" "fmt" "io" "sync" "time" "github.com/gobwas/ws/wsutil" )
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/generic-handlers.go
"runtime/debug" "strings" "sync/atomic" "time" "github.com/dustin/go-humanize" "github.com/minio/minio-go/v7/pkg/s3utils" "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio/internal/grid" xnet "github.com/minio/pkg/v2/net" "golang.org/x/exp/maps" "golang.org/x/exp/slices" "github.com/minio/minio/internal/amztime" "github.com/minio/minio/internal/config/dns"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/admin-handlers.go
"github.com/klauspost/compress/zip" "github.com/minio/madmin-go/v3" "github.com/minio/madmin-go/v3/estream" "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio/internal/dsync" "github.com/minio/minio/internal/grid" "github.com/minio/minio/internal/handlers" xhttp "github.com/minio/minio/internal/http" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/kms" "github.com/minio/minio/internal/logger"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/lock-rest-server.go
lockRPCUnlock = newLockHandler(grid.HandlerLockUnlock) lockRPCRLock = newLockHandler(grid.HandlerLockRLock) lockRPCRUnlock = newLockHandler(grid.HandlerLockRUnlock) ) func newLockHandler(h grid.HandlerID) *grid.SingleHandler[*dsync.LockArgs, *dsync.LockResp] { return grid.NewSingleHandler[*dsync.LockArgs, *dsync.LockResp](h, func() *dsync.LockArgs { return &dsync.LockArgs{} }, func() *dsync.LockResp {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
internal/grid/connection_test.go
// GNU Affero General Public License for more details. // // 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 grid import ( "context" "net" "net/http" "net/http/httptest" "testing" "time" "github.com/minio/minio/internal/logger/target/testlogger" ) func TestDisconnect(t *testing.T) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 6K bytes - Viewed (0) -
cmd/lock-rest-client.go
"github.com/minio/minio/internal/dsync" "github.com/minio/minio/internal/grid" ) // lockRESTClient is authenticable lock REST client type lockRESTClient struct { connection *grid.Connection } // IsOnline - returns whether REST client failed to connect or not. func (c *lockRESTClient) IsOnline() bool { return c.connection.State() == grid.StateConnected } // Not a local locker
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Nov 24 17:07:14 GMT 2023 - 3.3K bytes - Viewed (0) -
internal/grid/muxserver.go
// GNU Affero General Public License for more details. // // 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 grid import ( "context" "errors" "fmt" "sync" "sync/atomic" "time" xioutil "github.com/minio/minio/internal/ioutil" ) const lastPingThreshold = 4 * clientPingInterval
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0)