pg

Documentation

Overview

Package pg implements a blob store in a Postgresql relational database schema.

Index

• Constants
• type Store
  • func New(ctx context.Context, db *sql.DB) (*Store, error)
  • func (s *Store) AnchorMapRef(ctx context.Context) (bs.Ref, error)
  • func (s *Store) Get(ctx context.Context, ref bs.Ref) (bs.Blob, error)
  • func (s *Store) ListRefs(ctx context.Context, start bs.Ref, f func(bs.Ref) error) error
  • func (s *Store) Put(ctx context.Context, b bs.Blob) (bs.Ref, bool, error)
  • func (s *Store) UpdateAnchorMap(ctx context.Context, f anchor.UpdateFunc) error

Constants

const Schema = `` /* 232-byte string literal not displayed */

Schema is the SQL that New executes. It creates the `blobs` and `anchors` tables if they do not exist. (If they do exist, they must have the columns, constraints, and indexing described here.)

Types

type Store

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

Store is a Postgresql-based blob store.

func New

func New(ctx context.Context, db *sql.DB) (*Store, error)

New produces a new Store using `db` for storage.

func (*Store) AnchorMapRef

func (s *Store) AnchorMapRef(ctx context.Context) (bs.Ref, error)

AnchorMapRef implements anchor.Getter.

func (*Store) Get

func (s *Store) Get(ctx context.Context, ref bs.Ref) (bs.Blob, error)

Get gets the blob with hash `ref`.

func (*Store) ListRefs

func (s *Store) ListRefs(ctx context.Context, start bs.Ref, f func(bs.Ref) error) error

ListRefs produces all blob refs in the store, in lexicographic order.

func (*Store) Put

func (s *Store) Put(ctx context.Context, b bs.Blob) (bs.Ref, bool, error)

Put adds a blob to the store if it wasn't already present.

func (*Store) UpdateAnchorMap

func (s *Store) UpdateAnchorMap(ctx context.Context, f anchor.UpdateFunc) error

UpdateAnchorMap implements anchor.Store.