file

Documentation

Index

• func New() types.BackendFactory
• type Factory
  • func (ff *Factory) Create(volumeName, address string, dataServerProtocol types.DataServerProtocol, ...) (types.Backend, error)
• type Wrapper
  • func (f *Wrapper) Close() error
  • func (f *Wrapper) Expand(size int64) (err error)
  • func (f *Wrapper) GetHeadFileSize() (int64, error)
  • func (f *Wrapper) GetLastModifyTime() (int64, error)
  • func (f *Wrapper) GetMonitorChannel() types.MonitorChannel
  • func (f *Wrapper) GetRevisionCounter() (int64, error)
  • func (f *Wrapper) GetState() (string, error)
  • func (f *Wrapper) GetUnmapMarkSnapChainRemoved() (bool, error)
  • func (f *Wrapper) IsRevisionCounterDisabled() (bool, error)
  • func (f *Wrapper) PingResponse() error
  • func (f *Wrapper) RemainSnapshots() (int, error)
  • func (f *Wrapper) SectorSize() (int64, error)
  • func (f *Wrapper) SetRevisionCounter(counter int64) error
  • func (f *Wrapper) SetUnmapMarkSnapChainRemoved(enabled bool) error
  • func (f *Wrapper) Size() (int64, error)
  • func (f *Wrapper) Snapshot(name string, userCreated bool, created string, labels map[string]string) error
  • func (f *Wrapper) StopMonitoring()
  • func (f *Wrapper) UnmapAt(length uint32, off int64) (int, error)

Functions

func New

func New() types.BackendFactory

Types

type Factory

type Factory struct {
}

func (*Factory) Create

func (ff *Factory) Create(volumeName, address string, dataServerProtocol types.DataServerProtocol, engineToReplicaTimeout time.Duration) (types.Backend, error)

type Wrapper

type Wrapper struct {
	*os.File
	types.UnmapperAt
}

func (*Wrapper) Close

func (f *Wrapper) Close() error

func (*Wrapper) Expand

func (f *Wrapper) Expand(size int64) (err error)

func (*Wrapper) GetHeadFileSize

func (f *Wrapper) GetHeadFileSize() (int64, error)

GetHeadFileSize uses dummy head file size for file backend

func (*Wrapper) GetLastModifyTime

func (f *Wrapper) GetLastModifyTime() (int64, error)

func (*Wrapper) GetMonitorChannel

func (f *Wrapper) GetMonitorChannel() types.MonitorChannel

func (*Wrapper) GetRevisionCounter

func (f *Wrapper) GetRevisionCounter() (int64, error)

func (*Wrapper) GetState

func (f *Wrapper) GetState() (string, error)

func (*Wrapper) GetUnmapMarkSnapChainRemoved

func (f *Wrapper) GetUnmapMarkSnapChainRemoved() (bool, error)

func (*Wrapper) IsRevisionCounterDisabled

func (f *Wrapper) IsRevisionCounterDisabled() (bool, error)

func (*Wrapper) PingResponse

func (f *Wrapper) PingResponse() error

func (*Wrapper) RemainSnapshots

func (f *Wrapper) RemainSnapshots() (int, error)

func (*Wrapper) SectorSize

func (f *Wrapper) SectorSize() (int64, error)

func (*Wrapper) SetRevisionCounter

func (f *Wrapper) SetRevisionCounter(counter int64) error

func (*Wrapper) SetUnmapMarkSnapChainRemoved

func (f *Wrapper) SetUnmapMarkSnapChainRemoved(enabled bool) error

func (*Wrapper) Size

func (f *Wrapper) Size() (int64, error)

func (*Wrapper) Snapshot

func (f *Wrapper) Snapshot(name string, userCreated bool, created string, labels map[string]string) error

func (*Wrapper) StopMonitoring

func (f *Wrapper) StopMonitoring()

func (*Wrapper) UnmapAt

func (f *Wrapper) UnmapAt(length uint32, off int64) (int, error)