Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/peer-rest-client.go

    		peerRESTBucket: bucket,
    	}))
    	return err
    }
    
    // DeleteBucketMetadata - Delete bucket metadata
    func (client *peerRESTClient) DeleteBucketMetadata(bucket string) error {
    	_, err := deleteBucketMetadataRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{
    		peerRESTBucket: bucket,
    	}))
    	return err
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K 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),
    	})
    
    	_, err := healBucketRPC.Call(ctx, conn, mss)
    
    	// Initialize heal result info
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K 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.
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 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.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K 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)
    	},
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K 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"))
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 30.1K bytes
    - Viewed (0)
Back to top