Documentation ¶
Index ¶
- Variables
- func WriteManifestFile(manifest *Manifest, output file.File) error
- type AddBlobOp
- type AddDeleteFragmentOp
- type AddScalarFragmentOp
- type AddVectorFragmentOp
- type DataFile
- type Manifest
- 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
- type ManifestCommitOp
- type ManifestReaderWriter
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrManifestNotFound = errors.New("manifest not found")
Functions ¶
Types ¶
type AddDeleteFragmentOp ¶
type AddScalarFragmentOp ¶
type AddVectorFragmentOp ¶
type DataFile ¶
type DataFile struct {
// contains filtered or unexported fields
}
func NewDataFile ¶
type Manifest ¶
type Manifest struct { ScalarFragments fragment.FragmentVector // contains filtered or unexported fields }
func NewManifest ¶
func (*Manifest) AddDeleteFragment ¶
func (*Manifest) AddScalarFragment ¶
func (*Manifest) AddVectorFragment ¶
func (*Manifest) FromProtobuf ¶
func (m *Manifest) FromProtobuf(manifest *manifest_proto.Manifest) error
func (*Manifest) GetDeleteFragments ¶
func (m *Manifest) GetDeleteFragments() fragment.FragmentVector
func (*Manifest) GetScalarFragments ¶
func (m *Manifest) GetScalarFragments() fragment.FragmentVector
func (*Manifest) GetVectorFragments ¶
func (m *Manifest) GetVectorFragments() fragment.FragmentVector
func (*Manifest) RemoveBlobIfExist ¶
func (*Manifest) SetVersion ¶
func (*Manifest) ToProtobuf ¶
func (m *Manifest) ToProtobuf() (*manifest_proto.Manifest, error)
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
Click to show internal directories.
Click to hide internal directories.