storage

Documentation

Index

• type Space
  • func NewSpace(f fs.Fs, path string, m *manifest.Manifest, lockManager lock.LockManager) *Space
  • func Open(uri string, opt options.Options) (*Space, error)
  • func (s *Space) Delete(reader array.RecordReader) error
  • func (s *Space) Fs() fs.Fs
  • func (s *Space) GetBlobByteSize(name string) (int64, error)
  • func (s *Space) GetCurrentVersion() int64
  • func (s *Space) LockManager() lock.LockManager
  • func (s *Space) Manifest() *manifest.Manifest
  • func (s *Space) NewTransaction() transaction.Transaction
  • func (s *Space) Path() string
  • func (s *Space) Read(readOptions *options.ReadOptions) (array.RecordReader, error)
  • func (s *Space) ReadBlob(name string, output []byte) (int, error)
  • func (s *Space) ScanDelete() (array.RecordReader, error)
  • func (s *Space) SetLockManager(lockManager lock.LockManager)
  • func (s *Space) SetManifest(manifest *manifest.Manifest)
  • func (s *Space) StatisticsBlobs() []blob.Blob
  • func (s *Space) Write(reader array.RecordReader, options *options.WriteOptions) error
  • func (s *Space) WriteBlob(content []byte, name string, replace bool) error

Types

type Space

type Space struct {
	// contains filtered or unexported fields
}

func NewSpace

func NewSpace(f fs.Fs, path string, m *manifest.Manifest, lockManager lock.LockManager) *Space

func Open

func Open(uri string, opt options.Options) (*Space, error)

Open opened a space or create if the space does not exist. If space does not exist. schema should not be nullptr, or an error will be returned. If space exists and version is specified, it will restore to the state at this version, or it will choose the latest version.

func (*Space) Delete

func (s *Space) Delete(reader array.RecordReader) error

func (*Space) Fs

func (s *Space) Fs() fs.Fs

func (*Space) GetBlobByteSize

func (s *Space) GetBlobByteSize(name string) (int64, error)

func (*Space) GetCurrentVersion

func (s *Space) GetCurrentVersion() int64

func (*Space) LockManager

func (s *Space) LockManager() lock.LockManager

func (*Space) Manifest

func (s *Space) Manifest() *manifest.Manifest

func (*Space) NewTransaction

func (s *Space) NewTransaction() transaction.Transaction

func (*Space) Path

func (s *Space) Path() string

func (*Space) Read

func (s *Space) Read(readOptions *options.ReadOptions) (array.RecordReader, error)

func (*Space) ReadBlob

func (s *Space) ReadBlob(name string, output []byte) (int, error)

func (*Space) ScanDelete

func (s *Space) ScanDelete() (array.RecordReader, error)

func (*Space) SetLockManager

func (s *Space) SetLockManager(lockManager lock.LockManager)

func (*Space) SetManifest

func (s *Space) SetManifest(manifest *manifest.Manifest)

func (*Space) StatisticsBlobs

func (s *Space) StatisticsBlobs() []blob.Blob

func (*Space) Write

func (s *Space) Write(reader array.RecordReader, options *options.WriteOptions) error

func (*Space) WriteBlob

func (s *Space) WriteBlob(content []byte, name string, replace bool) error