manager

Documentation

Index

• Variables
• type Size
• type VolumeManager
  • func NewVolumeManager(dir string) (*VolumeManager, error)
  • func (vm *VolumeManager) Heartbeat()
  • func (vm *VolumeManager) Start()
  • func (vm *VolumeManager) Stop()

Variables

var (
	MaxDiskUsedPercent uint          = 99
	HeartbeatDuration  time.Duration = time.Second * 5
	ReadOnly           bool          = false
	DefaultExpires                   = time.Minute * 30
)

Types

type Size

type Size interface {
	Size() int64
}

type VolumeManager

type VolumeManager struct {
	DataDir string
	Volumes map[uint64]*volume.Volume

	AdminPort    int
	AdminHost    string
	PublicPort   int
	PublicHost   string
	AdminServer  *http.ServeMux
	PublicServer *http.ServeMux

	Machine    string
	DataCenter string

	MasterHost string
	MasterPort int
}

func NewVolumeManager

func NewVolumeManager(dir string) (*VolumeManager, error)

func (*VolumeManager) Heartbeat

func (vm *VolumeManager) Heartbeat()

func (*VolumeManager) Start

func (vm *VolumeManager) Start()

func (*VolumeManager) Stop

func (vm *VolumeManager) Stop()