manifest

Documentation

Index

• Variables
• func WriteManifestFile(manifest *Manifest, output file.File) error
• type AddBlobOp
• type AddDeleteFragmentOp
• type AddScalarFragmentOp
• type AddVectorFragmentOp
• type DataFile
  • func NewDataFile(path string) *DataFile
  • func (d *DataFile) Path() string
• type Manifest
  • func Init() *Manifest
  • func NewManifest(schema *schema.Schema) *Manifest
  • func ParseFromFile(f fs.Fs, path string) (*Manifest, error)
  • func (m *Manifest) AddBlob(blob blob.Blob)
  • func (m *Manifest) AddDeleteFragment(fragment fragment.Fragment)
  • func (m *Manifest) AddScalarFragment(fragment fragment.Fragment)
  • func (m *Manifest) AddVectorFragment(fragment fragment.Fragment)
  • func (m *Manifest) Copy() *Manifest
  • func (m *Manifest) FromProtobuf(manifest *manifest_proto.Manifest) error
  • func (m *Manifest) GetBlob(name string) (blob.Blob, bool)
  • func (m *Manifest) GetBlobs() []blob.Blob
  • func (m *Manifest) GetDeleteFragments() fragment.FragmentVector
  • func (m *Manifest) GetScalarFragments() fragment.FragmentVector
  • func (m *Manifest) GetSchema() *schema.Schema
  • func (m *Manifest) GetVectorFragments() fragment.FragmentVector
  • func (m *Manifest) HasBlob(name string) bool
  • func (m *Manifest) RemoveBlobIfExist(name string)
  • func (m *Manifest) SetVersion(version int64)
  • func (m *Manifest) ToProtobuf() (*manifest_proto.Manifest, error)
  • func (m *Manifest) Version() int64
• type ManifestCommit
  • func NewManifestCommit(lock lock.LockManager, rw ManifestReaderWriter) ManifestCommit
  • func (m *ManifestCommit) AddOp(op ...ManifestCommitOp)
  • func (m ManifestCommit) Commit() (manifest *Manifest, err error)
• type ManifestCommitOp
• type ManifestReaderWriter
  • func NewManifestReaderWriter(fs fs.Fs, root string) ManifestReaderWriter
  • func (rw ManifestReaderWriter) MaxVersion() (int64, error)
  • func (rw ManifestReaderWriter) Read(version int64) (*Manifest, error)
  • func (rw ManifestReaderWriter) Write(m *Manifest) error

Variables

var ErrManifestNotFound = errors.New("manifest not found")

Functions

func WriteManifestFile

func WriteManifestFile(manifest *Manifest, output file.File) error

Types

type AddBlobOp

type AddBlobOp struct {
	Replace bool
	Blob    blob.Blob
}

type AddDeleteFragmentOp

type AddDeleteFragmentOp struct {
	DeleteFragment fragment.Fragment
}

type AddScalarFragmentOp

type AddScalarFragmentOp struct {
	ScalarFragment fragment.Fragment
}

type AddVectorFragmentOp

type AddVectorFragmentOp struct {
	VectorFragment fragment.Fragment
}

type DataFile

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

func NewDataFile

func NewDataFile(path string) *DataFile

func (*DataFile) Path

func (d *DataFile) Path() string

type Manifest

type Manifest struct {
	ScalarFragments fragment.FragmentVector
	// contains filtered or unexported fields
}

func Init

func Init() *Manifest

func NewManifest

func NewManifest(schema *schema.Schema) *Manifest

func ParseFromFile

func ParseFromFile(f fs.Fs, path string) (*Manifest, error)

func (*Manifest) AddBlob

func (m *Manifest) AddBlob(blob blob.Blob)

func (*Manifest) AddDeleteFragment

func (m *Manifest) AddDeleteFragment(fragment fragment.Fragment)

func (*Manifest) AddScalarFragment

func (m *Manifest) AddScalarFragment(fragment fragment.Fragment)

func (*Manifest) AddVectorFragment

func (m *Manifest) AddVectorFragment(fragment fragment.Fragment)

func (*Manifest) Copy

func (m *Manifest) Copy() *Manifest

func (*Manifest) FromProtobuf

func (m *Manifest) FromProtobuf(manifest *manifest_proto.Manifest) error

func (*Manifest) GetBlob

func (m *Manifest) GetBlob(name string) (blob.Blob, bool)

func (*Manifest) GetBlobs

func (m *Manifest) GetBlobs() []blob.Blob

func (*Manifest) GetDeleteFragments

func (m *Manifest) GetDeleteFragments() fragment.FragmentVector

func (*Manifest) GetScalarFragments

func (m *Manifest) GetScalarFragments() fragment.FragmentVector

func (*Manifest) GetSchema

func (m *Manifest) GetSchema() *schema.Schema

func (*Manifest) GetVectorFragments

func (m *Manifest) GetVectorFragments() fragment.FragmentVector

func (*Manifest) HasBlob

func (m *Manifest) HasBlob(name string) bool

func (*Manifest) RemoveBlobIfExist

func (m *Manifest) RemoveBlobIfExist(name string)

func (*Manifest) SetVersion

func (m *Manifest) SetVersion(version int64)

func (*Manifest) ToProtobuf

func (m *Manifest) ToProtobuf() (*manifest_proto.Manifest, error)

func (*Manifest) Version

func (m *Manifest) Version() int64

type ManifestCommit

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

func NewManifestCommit

func NewManifestCommit(lock lock.LockManager, rw ManifestReaderWriter) ManifestCommit

func (*ManifestCommit) AddOp

func (m *ManifestCommit) AddOp(op ...ManifestCommitOp)

func (ManifestCommit) Commit

func (m ManifestCommit) Commit() (manifest *Manifest, err error)

type ManifestCommitOp

type ManifestCommitOp interface {
	// contains filtered or unexported methods
}

type ManifestReaderWriter

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

func NewManifestReaderWriter

func NewManifestReaderWriter(fs fs.Fs, root string) ManifestReaderWriter

func (ManifestReaderWriter) MaxVersion

func (rw ManifestReaderWriter) MaxVersion() (int64, error)

func (ManifestReaderWriter) Read

func (rw ManifestReaderWriter) Read(version int64) (*Manifest, error)

func (ManifestReaderWriter) Write

func (rw ManifestReaderWriter) Write(m *Manifest) error