manager

package

v0.2.6 Latest Latest Go to latest Published: Jun 19, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Manager struct {
	pg.PoolConn
	// contains filtered or unexported fields
}

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

New creates a new manager object

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

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

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

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

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

ListVolumes returns all volumes as a list.

func (manager *Manager) Run(ctx context.Context, logger *slog.Logger) error

type Opt func(*opt) error

Opt is a functional option for filer manager configuration.

func WithIndexer(indexer bool) Opt

WithIndexer uses this instance as an indexer of content

func WithMeter(meter metric.Meter) Opt

WithMeter sets the OpenTelemetry meter used for manager metrics.

func WithTracer(tracer trace.Tracer) Opt

WithTracer sets the tracer used for tracing operations.