- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewMSSWith (0.08 sec)
-
cmd/peer-rest-client.go
_, err := loadBucketMetadataRPC.Call(ctx, client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTBucket: bucket, })) return err } // DeleteBucketMetadata - Delete bucket metadata func (client *peerRESTClient) DeleteBucketMetadata(ctx context.Context, bucket string) error { _, err := deleteBucketMetadataRPC.Call(ctx, client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTBucket: bucket, })) return err
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 26.1K bytes - Viewed (0) -
cmd/peer-s3-client.go
conn := client.gridConn() if conn == nil { return madmin.HealResultItem{}, nil } mss := grid.NewMSSWith(map[string]string{ peerS3Bucket: bucket, peerS3BucketDeleted: strconv.FormatBool(opts.Remove), }) ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout()) defer cancel()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 15.4K bytes - Viewed (0) -
internal/grid/README.md
```go handler := func(request *grid.MSS) (*grid.MSS, *grid.RemoteErr) { fmt.Println("Got request with field", request["myfield"]) // Do something with payload return NewMSSWith(map[string]string{"result": "ok"}), nil } // Create a typed handler. // Due to current generics limitations, a constructor of the empty type must be provided.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.4K bytes - Viewed (0) -
cmd/storage-rest-client.go
} // StatVol - get volume info over the network. func (client *storageRESTClient) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) { v, err := storageStatVolRPC.Call(ctx, client.gridConn, grid.NewMSSWith(map[string]string{ storageRESTDiskID: *client.diskID.Load(), storageRESTVolume: volume, })) if err != nil { return vol, toStorageErr(err) } vol = *v // Performs shallow copy, so we can reuse.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:07:21 UTC 2024 - 30.2K bytes - Viewed (0) -
internal/grid/types.go
} // NewMSS returns a new MSS. func NewMSS() *MSS { m := MSS(mssPool.Get().(map[string]string)) for k := range m { delete(m, k) } return &m } // NewMSSWith returns a new MSS with the given map. func NewMSSWith(m map[string]string) *MSS { m2 := MSS(m) return &m2 } var mssPool = sync.Pool{ New: func() interface{} { return make(map[string]string, 5) }, }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 15.5K bytes - Viewed (0) -
internal/grid/grid_test.go
errFatal(h2.Register(remote, handler2)) // local to remote connection remoteConn := local.Connection(remoteHost) const testPayload = "Hello Grid World!" start := time.Now() req := NewMSSWith(map[string]string{"test": testPayload}) resp, err := h1.Call(context.Background(), remoteConn, req) errFatal(err) if resp.Get("test") != testPayload { t.Errorf("want %q, got %q", testPayload, resp.Get("test")) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 36.4K bytes - Viewed (0)