Documentation ¶
Index ¶
- Constants
- Variables
- func Bin(i int64) string
- func Dump(d Diskable) string
- func ReadAt(r io.ReaderAt, offset int64, d Diskable) error
- func ReadDiskable(raw RawDiskerReader, addr int64, disk Diskable) error
- func WriteAt(w io.WriterAt, offset int64, d Diskable) error
- type Device
- func (d *Device) Buffered() int
- func (d *Device) Bytes() []byte
- func (d *Device) Flush() error
- func (d *Device) FlushSize() int64
- func (d *Device) GetWriter(off int64, size int) *Writer
- func (d *Device) Len() int64
- func (d *Device) Offset() int64
- func (d *Device) Raw() RawDisker
- func (d *Device) ReadAt(b []byte, off int64) (int, error)
- func (d *Device) Write(b []byte) (int, error)
- func (d *Device) WriteAt(b []byte, off int64) (int, error)
- type DeviceMgr
- func (d *DeviceMgr) Close()
- func (d *DeviceMgr) Done()
- func (d *DeviceMgr) Flush() error
- func (d *DeviceMgr) GetFlushNotify() chan struct{}
- func (d *DeviceMgr) Malloc(n int) int64
- func (d *DeviceMgr) MallocWriter(n int) *DeviceWriter
- func (d *DeviceMgr) Raw() RawDisker
- func (d *DeviceMgr) ReadAt(b []byte, off int64) (int, error)
- func (d *DeviceMgr) WriteDisk(off int64, disk Diskable)
- type DeviceWriter
- type DiskReader
- type DiskWriter
- type Diskable
- type File
- type RawDisker
- type RawDiskerReader
- type Reader
- func (r *Reader) Available() int
- func (r *Reader) Byte(n int) []byte
- func (r *Reader) Check(d Diskable, n int) error
- func (r *Reader) Int32() int32
- func (r *Reader) Int64() int64
- func (r *Reader) Offset() int
- func (r *Reader) ReadDisk(d Diskable) error
- func (r *Reader) Skip(n int)
- func (r *Reader) Verify(b []byte) bool
- type Writer
Constants ¶
View Source
const (
SlotSize = 8
)
Variables ¶
View Source
var ( ErrDeviceWriteback = logex.Define("write back is not allowed") ErrDeviceBufOverflow = logex.Define("buffer overflowed") )
Functions ¶
func ReadDiskable ¶
func ReadDiskable(raw RawDiskerReader, addr int64, disk Diskable) error
Types ¶
type Device ¶
type Device struct {
// contains filtered or unexported fields
}
buffered writer
type DeviceMgr ¶
type DeviceMgr struct {
// contains filtered or unexported fields
}
func (*DeviceMgr) GetFlushNotify ¶
func (d *DeviceMgr) GetFlushNotify() chan struct{}
when client received signal, it's time to Done writing and try GetFlushNotify() to get a new one
func (*DeviceMgr) MallocWriter ¶
func (d *DeviceMgr) MallocWriter(n int) *DeviceWriter
type DeviceWriter ¶
type DeviceWriter struct { *Writer // contains filtered or unexported fields }
func (*DeviceWriter) Offset ¶
func (d *DeviceWriter) Offset() int64
type DiskReader ¶
type DiskWriter ¶
type Diskable ¶
type Diskable interface { Size() int ReadDisk(r DiskReader) error WriteDisk(w DiskWriter) }
type RawDisker ¶
type RawDisker interface { RawDiskerReader WriteAt(b []byte, off int64) (n int, err error) }
type RawDiskerReader ¶
Click to show internal directories.
Click to hide internal directories.