diskopt

Documentation

Index

• type Disk
  • func NewDisk(dirNames []string, maxVolumeCounts []int, ip string, port int) (v *Disk)
  • func (s *Disk) AddVolume(volumeListString string, collection string, replicaPlacement string, ...) (err error)
  • func (s *Disk) CheckCompactVolume(volumeIdString string, garbageThresholdString string) (error, bool)
  • func (s *Disk) CommitCompactVolume(volumeIdString string) error
  • func (s *Disk) CompactVolume(volumeIdString string) error
  • func (s *Disk) Delete(i util.VIDType, n *needle.Needle) (uint32, error)
  • func (s *Disk) DeleteVolume(vid util.VIDType) error
  • func (s *Disk) FindVolume(vid util.VIDType) *volume.Volume
  • func (s *Disk) HasVolume(i util.VIDType) bool
  • func (s *Disk) ReadVolumeNeedle(i util.VIDType, n *needle.Needle) (int, error)
  • func (s *Disk) Status() []*volume.VolumeInfo
  • func (s *Disk) Write(i util.VIDType, n *needle.Needle) (size uint32, isUnchanged bool, err error)
• type Location
  • func NewLocation(dir string, maxVolumeCount int) *Location
  • func (l *Location) DeleteVolumeById(vid util.VIDType) (e error)
  • func (l *Location) FindVolume(vid util.VIDType) (*volume.Volume, bool)
  • func (l *Location) SetVolume(vid util.VIDType, volume *volume.Volume)
  • func (l *Location) VolumesLen() int

Types

type Disk

type Disk struct {
	Locations       []*Location
	VolumeSizeLimit uint64
	Ip              string
	Port            int
}

func NewDisk

func NewDisk(dirNames []string, maxVolumeCounts []int, ip string, port int) (v *Disk)

NewDisk 新建磁盘

func (*Disk) AddVolume

func (s *Disk) AddVolume(volumeListString string, collection string, replicaPlacement string, ttlString string, preallocate int64) (err error)

func (*Disk) CheckCompactVolume

func (s *Disk) CheckCompactVolume(volumeIdString string, garbageThresholdString string) (error, bool)

func (*Disk) CommitCompactVolume

func (s *Disk) CommitCompactVolume(volumeIdString string) error

func (*Disk) CompactVolume

func (s *Disk) CompactVolume(volumeIdString string) error

func (*Disk) Delete

func (s *Disk) Delete(i util.VIDType, n *needle.Needle) (uint32, error)

func (*Disk) DeleteVolume

func (s *Disk) DeleteVolume(vid util.VIDType) error

func (*Disk) FindVolume

func (s *Disk) FindVolume(vid util.VIDType) *volume.Volume

func (*Disk) HasVolume

func (s *Disk) HasVolume(i util.VIDType) bool

func (*Disk) ReadVolumeNeedle

func (s *Disk) ReadVolumeNeedle(i util.VIDType, n *needle.Needle) (int, error)

func (*Disk) Status

func (s *Disk) Status() []*volume.VolumeInfo

func (*Disk) Write

func (s *Disk) Write(i util.VIDType, n *needle.Needle) (size uint32, isUnchanged bool, err error)

type Location

type Location struct {
	Directory      string
	MaxVolumeCount int
	Volumes        map[util.VIDType]*volume.Volume
	sync.RWMutex
}

func NewLocation

func NewLocation(dir string, maxVolumeCount int) *Location

func (*Location) DeleteVolumeById

func (l *Location) DeleteVolumeById(vid util.VIDType) (e error)

func (*Location) FindVolume

func (l *Location) FindVolume(vid util.VIDType) (*volume.Volume, bool)

func (*Location) SetVolume

func (l *Location) SetVolume(vid util.VIDType, volume *volume.Volume)

func (*Location) VolumesLen

func (l *Location) VolumesLen() int