manager

package
v0.2.25 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Filer added in v0.2.20 

type Filer struct {
	pg.PoolConn
	*credential.Credentials
	// contains filtered or unexported fields
}

func New 

func New(ctx context.Context, pool pg.PoolConn, opts ...Opt) (_ *Filer, err error)

New creates a new filer object

func (*Filer) CreateArtwork added in v0.2.20 

func (filer *Filer) CreateArtwork(ctx context.Context, req schema.ArtworkMeta, object *schema.ObjectKey) (_ *schema.Artwork, err error)

func (*Filer) CreateLLMProvider added in v0.2.20 

func (filer *Filer) CreateLLMProvider(ctx context.Context, req schema.LLMProviderCreate) (_ *schema.LLMProvider, err error)

CreateLLMProvider creates a new LLM provider which can be used for extracting metadata whilst indexing objects

func (*Filer) CreateObject added in v0.2.24 

func (filer *Filer) CreateObject(ctx context.Context, req schema.CreateObjectRequest, attr schema.ObjectAttr) (_ *schema.Object, _ bool, err error)

func (*Filer) CreateVolume added in v0.2.20 

func (filer *Filer) CreateVolume(ctx context.Context, url *url.URL, meta schema.VolumeMeta) (_ *schema.Volume, err error)

CreateVolume creates a new volume record in the database, and returns the created record.

func (*Filer) DeleteVolume added in v0.2.20 

func (filer *Filer) DeleteVolume(ctx context.Context, name string) (_ *schema.Volume, err error)

DeleteVolume deletes a volume record from the database, and returns the deleted record.

func (*Filer) GetArtwork added in v0.2.20 

func (filer *Filer) GetArtwork(ctx context.Context, req schema.GetArtworkRequest) (_ *schema.Artwork, err error)

func (*Filer) GetMetadata added in v0.2.20 

func (filer *Filer) GetMetadata(ctx context.Context, r io.Reader) (_ *schema.ObjectMeta, err error)

func (*Filer) GetObject added in v0.2.20 

func (filer *Filer) GetObject(ctx context.Context, req schema.ObjectKey) (_ *schema.Object, err error)

func (*Filer) GetVolume added in v0.2.20 

func (filer *Filer) GetVolume(ctx context.Context, name string) (_ *schema.Volume, err error)

GetVolume returns a volume status

func (*Filer) LinkArtwork added in v0.2.20 

func (filer *Filer) LinkArtwork(ctx context.Context, object schema.ObjectKey, artwork schema.ArtworkKey) (_ *schema.ObjectArtwork, err error)

func (*Filer) ListObjects added in v0.2.20 

func (filer *Filer) ListObjects(ctx context.Context, req schema.ObjectListRequest) (_ *schema.ObjectList, err error)

func (*Filer) ListVolumes added in v0.2.20 

func (filer *Filer) ListVolumes(ctx context.Context, req schema.VolumeListRequest) (_ *schema.VolumeList, err error)

ListVolumes returns all volumes as a list.

func (*Filer) ReadObject added in v0.2.25 

func (filer *Filer) ReadObject(ctx context.Context, req schema.ObjectKey, attr schema.ObjectAttr) (_ io.ReadCloser, _ *schema.Object, err error)

func (*Filer) RegisterVolumeMetrics added in v0.2.20 

func (filer *Filer) RegisterVolumeMetrics(name string) (err error)

func (*Filer) ReindexVolume added in v0.2.20 

func (filer *Filer) ReindexVolume(ctx context.Context, name string, req schema.ObjectListFilters, force bool, callback func(total uint64)) (err error)

ReindexVolume reindexes objects in a volume according to the provided object filters.

func (*Filer) Run added in v0.2.20 

func (filer *Filer) Run(ctx context.Context, logger *slog.Logger) (err error)

func (*Filer) Search added in v0.2.20 

func (filer *Filer) Search(ctx context.Context, req schema.SearchListRequest) (_ *schema.SearchList, err error)

func (*Filer) UnlinkArtwork added in v0.2.20 

func (filer *Filer) UnlinkArtwork(ctx context.Context, object schema.ObjectKey, artwork schema.ArtworkKey) (_ *schema.ObjectArtwork, err error)

func (*Filer) UpdateVolume added in v0.2.20 

func (filer *Filer) UpdateVolume(ctx context.Context, name string, meta schema.VolumeMeta) (_ *schema.Volume, err error)

UpdateVolume updates a volume record in the database, and returns the updated record.

type Opt 

type Opt func(*opt) error

Opt is a functional option for filer manager configuration.

func WithIndexer added in v0.2.0 

func WithIndexer(indexer bool) Opt

WithIndexer uses this instance as an indexer of content

func WithLLMClientOpts added in v0.2.10 

func WithLLMClientOpts(opts ...client.ClientOpt) Opt

WithLLMClientOpts sets options for the LLM provider registry's HTTP clients.

func WithMeter added in v0.2.0 

func WithMeter(meter metric.Meter) Opt

WithMeter sets the OpenTelemetry meter used for manager metrics.

func WithPassphrase added in v0.2.7 

func WithPassphrase(version uint64, passphrase string) Opt

WithPassphrase registers an in-memory storage passphrase for a certificate passphrase version. Versions are uint64 and passphrases must be non-empty.

func WithSchema added in v0.2.20 

func WithSchema(schema string) Opt

WithSchema sets the database schema used for storing filer objects.

func WithTracer 

func WithTracer(tracer trace.Tracer) Opt

WithTracer sets the tracer used for tracing operations.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.