replica

Documentation

Index

• Constants
• type BackingFile
• type Info
  • func ReadInfo(dir string) (Info, error)
• type Replica
  • func New(size, sectorSize int64, dir string, backingFile *BackingFile) (*Replica, error)
  • func (r *Replica) Chain() ([]string, error)
  • func (r *Replica) Close() error
  • func (r *Replica) Delete() error
  • func (r *Replica) Info() Info
  • func (r *Replica) ReadAt(buf []byte, offset int64) (int, error)
  • func (r *Replica) Reload() (*Replica, error)
  • func (r *Replica) RemoveDiffDisk(name string) error
  • func (r *Replica) SetRebuilding(rebuilding bool) error
  • func (r *Replica) Snapshot(name string) error
  • func (r *Replica) WriteAt(buf []byte, offset int64) (int, error)
• type Server
  • func NewServer(dir string, backing *BackingFile, sectorSize int64) *Server
  • func (s *Server) Close() error
  • func (s *Server) Create(size int64) error
  • func (s *Server) Delete() error
  • func (s *Server) Open() error
  • func (s *Server) ReadAt(buf []byte, offset int64) (int, error)
  • func (s *Server) Reload() error
  • func (s *Server) RemoveDiffDisk(name string) error
  • func (s *Server) Replica() *Replica
  • func (s *Server) SetRebuilding(rebuilding bool) error
  • func (s *Server) Snapshot(name string) error
  • func (s *Server) Status() (State, Info)
  • func (s *Server) WriteAt(buf []byte, offset int64) (int, error)
• type State

Constants

const (
	Initial    = State("initial")
	Open       = State("open")
	Closed     = State("closed")
	Dirty      = State("dirty")
	Rebuilding = State("rebuilding")
	Error      = State("error")
)

Types

type BackingFile

type BackingFile struct {
	Size       int64
	SectorSize int64
	Name       string
	Disk       types.DiffDisk
}

type Info

type Info struct {
	Size        int64
	Head        string
	Dirty       bool
	Rebuilding  bool
	Parent      string
	SectorSize  int64
	BackingFile *BackingFile `json:"-"`
}

func ReadInfo

func ReadInfo(dir string) (Info, error)

type Replica

type Replica struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New(size, sectorSize int64, dir string, backingFile *BackingFile) (*Replica, error)

func (*Replica) Chain

func (r *Replica) Chain() ([]string, error)

func (*Replica) Close

func (r *Replica) Close() error

func (*Replica) Delete

func (r *Replica) Delete() error

func (*Replica) Info

func (r *Replica) Info() Info

func (*Replica) ReadAt

func (r *Replica) ReadAt(buf []byte, offset int64) (int, error)

func (*Replica) Reload

func (r *Replica) Reload() (*Replica, error)

func (*Replica) RemoveDiffDisk

func (r *Replica) RemoveDiffDisk(name string) error

func (*Replica) SetRebuilding

func (r *Replica) SetRebuilding(rebuilding bool) error

func (*Replica) Snapshot

func (r *Replica) Snapshot(name string) error

func (*Replica) WriteAt

func (r *Replica) WriteAt(buf []byte, offset int64) (int, error)

type Server

type Server struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewServer

func NewServer(dir string, backing *BackingFile, sectorSize int64) *Server

func (*Server) Close

func (s *Server) Close() error

func (*Server) Create

func (s *Server) Create(size int64) error

func (*Server) Delete

func (s *Server) Delete() error

func (*Server) Open

func (s *Server) Open() error

func (*Server) ReadAt

func (s *Server) ReadAt(buf []byte, offset int64) (int, error)

func (*Server) Reload

func (s *Server) Reload() error

func (*Server) RemoveDiffDisk

func (s *Server) RemoveDiffDisk(name string) error

func (*Server) Replica

func (s *Server) Replica() *Replica

func (*Server) SetRebuilding

func (s *Server) SetRebuilding(rebuilding bool) error

func (*Server) Snapshot

func (s *Server) Snapshot(name string) error

func (*Server) Status

func (s *Server) Status() (State, Info)

func (*Server) WriteAt

func (s *Server) WriteAt(buf []byte, offset int64) (int, error)

type State

type State string