allocate_volume.go 1000 B

1234567891011121314151617181920212223242526272829303132
  1. package topology
  2. import (
  3. "context"
  4. "github.com/chrislusf/seaweedfs/weed/operation"
  5. "github.com/chrislusf/seaweedfs/weed/pb/volume_server_pb"
  6. "github.com/chrislusf/seaweedfs/weed/storage/needle"
  7. "google.golang.org/grpc"
  8. )
  9. type AllocateVolumeResult struct {
  10. Error string
  11. }
  12. func AllocateVolume(dn *DataNode, grpcDialOption grpc.DialOption, vid needle.VolumeId, option *VolumeGrowOption) error {
  13. return operation.WithVolumeServerClient(false, dn.ServerAddress(), grpcDialOption, func(client volume_server_pb.VolumeServerClient) error {
  14. _, deleteErr := client.AllocateVolume(context.Background(), &volume_server_pb.AllocateVolumeRequest{
  15. VolumeId: uint32(vid),
  16. Collection: option.Collection,
  17. Replication: option.ReplicaPlacement.String(),
  18. Ttl: option.Ttl.String(),
  19. Preallocate: option.Preallocate,
  20. MemoryMapMaxSizeMb: option.MemoryMapMaxSizeMb,
  21. DiskType: string(option.DiskType),
  22. })
  23. return deleteErr
  24. })
  25. }