postgres

Documentation

Index

• type PgDB
  • func Connect(dbURL string) (*PgDB, error)
  • func (pgdb *PgDB) AllStorages(ctx context.Context) (ret []model.Storage, err error)
  • func (pgdb *PgDB) AllVolumes(ctx context.Context, filter database.VolumeFilter) (ret []model.Volume, err error)
  • func (pgdb *PgDB) Close() error
  • func (pgdb *PgDB) CreateStorage(ctx context.Context, storage *model.Storage) error
  • func (pgdb *PgDB) CreateVolume(ctx context.Context, volume *model.Volume) error
  • func (pgdb *PgDB) DeleteStorage(ctx context.Context, storage *model.Storage) error
  • func (pgdb *PgDB) DeleteVolume(ctx context.Context, volume *model.Volume) error
  • func (pgdb *PgDB) DeleteVolumes(ctx context.Context, volumes []model.Volume) error
  • func (pgdb *PgDB) LeastUsedStorage(ctx context.Context, minFree int) (ret model.Storage, err error)
  • func (pgdb *PgDB) NamespaceVolumes(ctx context.Context, nsID string) (ret []model.Volume, err error)
  • func (pgdb *PgDB) StorageByName(ctx context.Context, name string) (ret model.Storage, err error)
  • func (pgdb *PgDB) Transactional(fn func(tx database.DB) error) error
  • func (pgdb *PgDB) UpdateStorage(ctx context.Context, name string, storage model.Storage) error
  • func (pgdb *PgDB) UpdateVolume(ctx context.Context, volume *model.Volume) error
  • func (pgdb *PgDB) UserVolumes(ctx context.Context, userID string) (ret []model.Volume, err error)
  • func (pgdb *PgDB) VolumeByLabel(ctx context.Context, nsID, label string) (ret model.Volume, err error)
• type VolumeFilter
  • func (f *VolumeFilter) Filter(q *orm.Query) (*orm.Query, error)

Types

type PgDB

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

func Connect

func Connect(dbURL string) (*PgDB, error)

func (*PgDB) AllStorages

func (pgdb *PgDB) AllStorages(ctx context.Context) (ret []model.Storage, err error)

func (*PgDB) AllVolumes

func (pgdb *PgDB) AllVolumes(ctx context.Context, filter database.VolumeFilter) (ret []model.Volume, err error)

func (*PgDB) Close

func (pgdb *PgDB) Close() error

func (*PgDB) CreateStorage

func (pgdb *PgDB) CreateStorage(ctx context.Context, storage *model.Storage) error

func (*PgDB) CreateVolume

func (pgdb *PgDB) CreateVolume(ctx context.Context, volume *model.Volume) error

func (*PgDB) DeleteStorage

func (pgdb *PgDB) DeleteStorage(ctx context.Context, storage *model.Storage) error

func (*PgDB) DeleteVolume

func (pgdb *PgDB) DeleteVolume(ctx context.Context, volume *model.Volume) error

func (*PgDB) DeleteVolumes

func (pgdb *PgDB) DeleteVolumes(ctx context.Context, volumes []model.Volume) error

func (*PgDB) LeastUsedStorage

func (pgdb *PgDB) LeastUsedStorage(ctx context.Context, minFree int) (ret model.Storage, err error)

func (*PgDB) NamespaceVolumes

func (pgdb *PgDB) NamespaceVolumes(ctx context.Context, nsID string) (ret []model.Volume, err error)

func (*PgDB) StorageByName

func (pgdb *PgDB) StorageByName(ctx context.Context, name string) (ret model.Storage, err error)

func (*PgDB) Transactional

func (pgdb *PgDB) Transactional(fn func(tx database.DB) error) error

func (*PgDB) UpdateStorage

func (pgdb *PgDB) UpdateStorage(ctx context.Context, name string, storage model.Storage) error

func (*PgDB) UpdateVolume

func (pgdb *PgDB) UpdateVolume(ctx context.Context, volume *model.Volume) error

func (*PgDB) UserVolumes

func (pgdb *PgDB) UserVolumes(ctx context.Context, userID string) (ret []model.Volume, err error)

func (*PgDB) VolumeByLabel

func (pgdb *PgDB) VolumeByLabel(ctx context.Context, nsID, label string) (ret model.Volume, err error)

type VolumeFilter

type VolumeFilter database.VolumeFilter

func (*VolumeFilter) Filter

func (f *VolumeFilter) Filter(q *orm.Query) (*orm.Query, error)