directory

Documentation

Index

• Constants
• type FileId
  • func NewFileId(VolumeId uint32, Key uint64, Hashcode uint32) *FileId
  • func ParseFileId(fid string) *FileId
  • func (n *FileId) String() string
• type Machine
  • func NewMachine(server, publicUrl string, volumes []storage.VolumeInfo) *Machine
• type MachineInfo
• type Mapper
  • func NewMapper(dirname string, filename string, volumeSizeLimit uint64) (m *Mapper)
  • func (m *Mapper) Add(machine Machine)
  • func (m *Mapper) Get(vid uint32) (*Machine, error)
  • func (m *Mapper) NextFileId(c string) (uint64, int)
  • func (m *Mapper) PickForWrite(c string) (string, int, MachineInfo, error)

Constants

const (
	FileIdSaveInterval = 10000
)

Types

type FileId

type FileId struct {
	VolumeId uint32
	Key      uint64
	Hashcode uint32
}

func NewFileId

func NewFileId(VolumeId uint32, Key uint64, Hashcode uint32) *FileId

func ParseFileId

func ParseFileId(fid string) *FileId

func (*FileId) String

func (n *FileId) String() string

type Machine

type Machine struct {
	Server  MachineInfo
	Volumes []storage.VolumeInfo
}

func NewMachine

func NewMachine(server, publicUrl string, volumes []storage.VolumeInfo) *Machine

type MachineInfo

type MachineInfo struct {
	Url       string //<server name/ip>[:port]
	PublicUrl string
}

type Mapper

type Mapper struct {
	Machines []*Machine

	Writers []uint32 // transient array of Writers volume id

	FileIdSequence uint64
	// contains filtered or unexported fields
}

func NewMapper

func NewMapper(dirname string, filename string, volumeSizeLimit uint64) (m *Mapper)

func (*Mapper) Add

func (m *Mapper) Add(machine Machine)

func (*Mapper) Get

func (m *Mapper) Get(vid uint32) (*Machine, error)

func (*Mapper) NextFileId

func (m *Mapper) NextFileId(c string) (uint64, int)

func (*Mapper) PickForWrite

func (m *Mapper) PickForWrite(c string) (string, int, MachineInfo, error)