postgres

README

/pkg/rsstorage/servers/postgres

Description

The Postgres implementation is alpha/experimental. It needs more testing (and probably more work) to prepare it for actual use.

A storage server implementation that uses PostgreSQL large object storage. Requires a connection pool from the pgx library.

Documentation

Index

• func NewStorageServer(args StorageServerArgs) rsstorage.StorageServer
• type StorageServer
  • func (s *StorageServer) Base() rsstorage.StorageServer
  • func (s *StorageServer) CalculateUsage() (types.Usage, error)
  • func (s *StorageServer) Check(ctx context.Context, dir, address string) (found bool, chunked *types.ChunksInfo, sz int64, ts time.Time, err error)
  • func (s *StorageServer) Copy(ctx context.Context, dir, address string, server rsstorage.StorageServer) error
  • func (s *StorageServer) Dir() string
  • func (s *StorageServer) Enumerate(ctx context.Context) (items []types.StoredItem, err error)
  • func (s *StorageServer) Flush(ctx context.Context, dir, address string)
  • func (s *StorageServer) Get(ctx context.Context, dir string, address string) (f io.ReadCloser, chunks *types.ChunksInfo, sz int64, lastMod time.Time, ...)
  • func (s *StorageServer) Locate(dir, address string) string
  • func (s *StorageServer) Move(ctx context.Context, dir, address string, server rsstorage.StorageServer) error
  • func (s *StorageServer) Put(ctx context.Context, resolve types.Resolver, dir, address string) (dirOut, addrOut string, err error)
  • func (s *StorageServer) PutChunked(ctx context.Context, resolve types.Resolver, dir, address string, sz uint64) (string, string, error)
  • func (s *StorageServer) Remove(ctx context.Context, dir, address string) (err error)
  • func (s *StorageServer) Type() types.StorageType
• type StorageServerArgs

Functions

func NewStorageServer

func NewStorageServer(args StorageServerArgs) rsstorage.StorageServer

Types

type StorageServer

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

func (*StorageServer) Base

func (s *StorageServer) Base() rsstorage.StorageServer

func (*StorageServer) CalculateUsage

func (s *StorageServer) CalculateUsage() (types.Usage, error)

func (*StorageServer) Check

func (s *StorageServer) Check(ctx context.Context, dir, address string) (found bool, chunked *types.ChunksInfo, sz int64, ts time.Time, err error)

func (*StorageServer) Copy

func (s *StorageServer) Copy(ctx context.Context, dir, address string, server rsstorage.StorageServer) error

func (*StorageServer) Dir

func (s *StorageServer) Dir() string

func (*StorageServer) Enumerate

func (s *StorageServer) Enumerate(ctx context.Context) (items []types.StoredItem, err error)

func (*StorageServer) Flush

func (s *StorageServer) Flush(ctx context.Context, dir, address string)

func (*StorageServer) Get

func (s *StorageServer) Get(
	ctx context.Context,
	dir string,
	address string,
) (f io.ReadCloser, chunks *types.ChunksInfo, sz int64, lastMod time.Time, found bool, err error)

func (*StorageServer) Locate

func (s *StorageServer) Locate(dir, address string) string

func (*StorageServer) Move

func (s *StorageServer) Move(ctx context.Context, dir, address string, server rsstorage.StorageServer) error

func (*StorageServer) Put

func (s *StorageServer) Put(ctx context.Context, resolve types.Resolver, dir, address string) (dirOut, addrOut string, err error)

func (*StorageServer) PutChunked

func (s *StorageServer) PutChunked(ctx context.Context, resolve types.Resolver, dir, address string, sz uint64) (string, string, error)

func (*StorageServer) Remove

func (s *StorageServer) Remove(ctx context.Context, dir, address string) (err error)

func (*StorageServer) Type

func (s *StorageServer) Type() types.StorageType

type StorageServerArgs

type StorageServerArgs struct {
	ChunkSize uint64
	Waiter    rsstorage.ChunkWaiter
	Notifier  rsstorage.ChunkNotifier
	Class     string
	Pool      *pgxpool.Pool
}