- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 51 for grid (0.13 sec)
-
cmd/peer-rest-server.go
loadRebalanceMetaRPC = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerLoadRebalanceMeta, grid.NewMSS, grid.NewNoPayload) loadSvcActRPC = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerLoadServiceAccount, grid.NewMSS, grid.NewNoPayload).IgnoreNilConn()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/peer-rest-client.go
xhttp.DrainBody(respBody) return !isNetworkError(err) } var gridConn atomic.Pointer[grid.Connection] return &peerRESTClient{ host: peer, restClient: restClient, gridHost: gridHost, gridConn: func() *grid.Connection { // Lazy initialization of grid connection. // When we create this peer client, the grid connection is likely not yet initialized. if gridHost == "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
internal/grid/debug.go
debugIsOutgoingClosed ) // TestGrid contains a grid of servers for testing purposes. type TestGrid struct { Servers []*httptest.Server Listeners []net.Listener Managers []*Manager Mux []*mux.Router Hosts []string cleanupOnce sync.Once cancel context.CancelFunc } // SetupTestGrid creates a new grid for testing purposes. // Select the number of hosts to create.
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) -
cmd/storage-rest-server.go
storageStatVolRPC = grid.NewSingleHandler[*grid.MSS, *VolInfo](grid.HandlerStatVol, grid.NewMSS, func() *VolInfo { return &VolInfo{} }) storageUpdateMetadataRPC = grid.NewSingleHandler[*MetadataHandlerParams, grid.NoPayload](grid.HandlerUpdateMetadata, func() *MetadataHandlerParams { return &MetadataHandlerParams{} }, grid.NewNoPayload)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
internal/grid/handlers_string.go
// Code generated by "stringer -type=HandlerID -output=handlers_string.go -trimprefix=Handler msg.go handlers.go"; DO NOT EDIT. package grid import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[handlerInvalid-0] _ = x[HandlerLockLock-1] _ = x[HandlerLockRLock-2] _ = x[HandlerLockUnlock-3]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/grid/manager.go
}) } if !found { return nil, fmt.Errorf("grid: local host not found") } return m, nil } // AddToMux will add the grid manager to the given mux. func (m *Manager) AddToMux(router *mux.Router) { router.Handle(RoutePath, m.Handler()) } // Handler returns a handler that can be used to serve grid requests. // This should be connected on RoutePath to the main server.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/grid/benchmark_test.go
b.Helper() if err != nil { b.Fatal(err) } } rpc := NewSingleHandler[*testRequest, *testResponse](handlerTest2, newTestRequest, newTestResponse) grid, err := SetupTestGrid(n) errFatal(err) b.Cleanup(grid.Cleanup) // Create n managers. for _, remote := range grid.Managers { // Register a single handler which echos the payload. errFatal(remote.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/peer-s3-client.go
} // Returns a peer S3 client. func newPeerS3Client(node Node) peerS3Client { var gridConn atomic.Pointer[grid.Connection] return &remotePeerS3Client{ node: node, gridConn: func() *grid.Connection { // Lazy initialization of grid connection. // When we create this peer client, the grid connection is likely not yet initialized. if node.GridHost == "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/globals.go
"github.com/minio/minio/internal/bpool" "github.com/minio/minio/internal/bucket/bandwidth" "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/config/browser" "github.com/minio/minio/internal/grid" "github.com/minio/minio/internal/handlers" "github.com/minio/minio/internal/kms" "go.uber.org/atomic" "github.com/dustin/go-humanize" "github.com/minio/minio/internal/auth"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
// Copy inline data to a new buffer to function with deadlines. if len(fi.Data) > 0 { fi.Data = append(grid.GetByteBufferCap(len(fi.Data))[:0], fi.Data...) } return xioutil.WithDeadline[RenameDataResp](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (res RenameDataResp, err error) { if len(fi.Data) > 0 { defer grid.PutByteBuffer(fi.Data) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0)