metadata

Documentation

Index

• type Chunkserver
  • func GenChunkserver(jsonMap map[string]interface{}) (*Chunkserver, error)
• type Chunkservers
• type MetaDataDriver

Types

type Chunkserver

type Chunkserver struct {
	Id               string `json:"-"`
	GroupId          uint16
	Ip               string
	Port             int
	Status           int       `json:",omitempty"`
	GlobalStatus     int       `json:",omitempty"`
	TotalFreeSpace   int64     `json:",omitempty"`
	MaxFreeSpace     int64     `json:",omitempty"`
	PendingWrites    int       `json:",omitempty"`
	WritingCount     int       `json:",omitempty"`
	ReadingCount     uint32    `json:",omitempty"`
	TotalChunks      uint32    `json:",omitempty"`
	ConnectionsCount uint32    `json:",omitempty"`
	DataDir          string    `json:",omitempty"`
	UpdateTime       time.Time `json:"-"`
}

func GenChunkserver

func GenChunkserver(jsonMap map[string]interface{}) (*Chunkserver, error)

type Chunkservers

type Chunkservers []*Chunkserver

type MetaDataDriver

type MetaDataDriver interface {
	Close() error

	AddChunkserver(chunkserver *Chunkserver) error
	UpdateChunkserverStatus(chunkserver *Chunkserver, preStatus int, status int) error
	IsExistChunkserver(chunkServer *Chunkserver) (bool, error)
	UpdateChunkserverInfo(chunkserver *Chunkserver, preStatus int, status int) error
	ListChunkserver() (Chunkservers, error)
	ListChunkserverGroup(groupId int) (Chunkservers, error)
	UpdateChunkserverNORMAL(ip string, port, status, count int) error
	UpdateChunkserverERROR(ip string, port, status, count int) error

	GetFid() (uint64, error)
	UpdateFid(fid uint64) error
}