remote

Documentation

Index

• Constants
• func New() types.BackendFactory
• type Factory
  • func (rf *Factory) Create(volumeName, address string, dataServerProtocol types.DataServerProtocol, ...) (types.Backend, error)
• type Remote
  • func (r *Remote) Close() error
  • func (r *Remote) Expand(size int64) (err error)
  • func (r *Remote) GetHeadFileSize() (int64, error)
  • func (r *Remote) GetLastModifyTime() (int64, error)
  • func (r *Remote) GetMonitorChannel() types.MonitorChannel
  • func (r *Remote) GetRevisionCounter() (int64, error)
  • func (r *Remote) GetSnapshotCountAndSizeUsage() (int, int64, error)
  • func (r *Remote) GetState() (string, error)
  • func (r *Remote) GetUnmapMarkSnapChainRemoved() (bool, error)
  • func (r *Remote) IsReplicaRebuilding() (bool, error)
  • func (r *Remote) IsRevisionCounterDisabled() (bool, error)
  • func (r *Remote) ResetRebuild() error
  • func (r *Remote) SectorSize() (int64, error)
  • func (r *Remote) SetRevisionCounter(counter int64) error
  • func (r *Remote) SetSnapshotMaxCount(count int) error
  • func (r *Remote) SetSnapshotMaxSize(size int64) error
  • func (r *Remote) SetUnmapMarkSnapChainRemoved(enabled bool) error
  • func (r *Remote) Size() (int64, error)
  • func (r *Remote) Snapshot(name string, userCreated bool, created string, labels map[string]string) error
  • func (r *Remote) StopMonitoring()
• type RevisionCounter

Constants

const (
	PingInterval        = 2 * time.Second
	NumberOfConnections = 2
)

Functions

func New

func New() types.BackendFactory

Types

type Factory

type Factory struct {
}

func (*Factory) Create

func (rf *Factory) Create(volumeName, address string, dataServerProtocol types.DataServerProtocol,
	sharedTimeouts types.SharedTimeouts) (types.Backend, error)

type Remote

type Remote struct {
	types.ReaderWriterUnmapperAt
	// contains filtered or unexported fields
}

func (*Remote) Close

func (r *Remote) Close() error

func (*Remote) Expand

func (r *Remote) Expand(size int64) (err error)

func (*Remote) GetHeadFileSize

func (r *Remote) GetHeadFileSize() (int64, error)

func (*Remote) GetLastModifyTime

func (r *Remote) GetLastModifyTime() (int64, error)

func (*Remote) GetMonitorChannel

func (r *Remote) GetMonitorChannel() types.MonitorChannel

func (*Remote) GetRevisionCounter

func (r *Remote) GetRevisionCounter() (int64, error)

func (*Remote) GetSnapshotCountAndSizeUsage

func (r *Remote) GetSnapshotCountAndSizeUsage() (int, int64, error)

func (*Remote) GetState

func (r *Remote) GetState() (string, error)

func (*Remote) GetUnmapMarkSnapChainRemoved

func (r *Remote) GetUnmapMarkSnapChainRemoved() (bool, error)

func (*Remote) IsReplicaRebuilding

func (r *Remote) IsReplicaRebuilding() (bool, error)

func (*Remote) IsRevisionCounterDisabled

func (r *Remote) IsRevisionCounterDisabled() (bool, error)

func (*Remote) ResetRebuild

func (r *Remote) ResetRebuild() error

func (*Remote) SectorSize

func (r *Remote) SectorSize() (int64, error)

func (*Remote) SetRevisionCounter

func (r *Remote) SetRevisionCounter(counter int64) error

func (*Remote) SetSnapshotMaxCount

func (r *Remote) SetSnapshotMaxCount(count int) error

func (*Remote) SetSnapshotMaxSize

func (r *Remote) SetSnapshotMaxSize(size int64) error

func (*Remote) SetUnmapMarkSnapChainRemoved

func (r *Remote) SetUnmapMarkSnapChainRemoved(enabled bool) error

func (*Remote) Size

func (r *Remote) Size() (int64, error)

func (*Remote) Snapshot

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

func (*Remote) StopMonitoring

func (r *Remote) StopMonitoring()

type RevisionCounter

type RevisionCounter struct {
	Counter int64 `json:"counter,string"`
}