Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewMSSWith (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top