postgres

package
v1.0.2 Latest Latest
Warning

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

Go to latest
Published: Sep 3, 2018 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL