postgres

Documentation

Index

• Constants
• func Migrate(db *sql.DB) error
• func New(cfg *Config, driver *ddrv.Driver) dp.DataProvider
• func NewDb(connStr string, skipMigration bool) *sql.DB
• type Config
• type PGProvider
  • func (pgp *PGProvider) CHTime(name string, mtime time.Time) error
  • func (pgp *PGProvider) Close() error
  • func (pgp *PGProvider) Create(name, parent string, dir bool) (*dp.File, error)
  • func (pgp *PGProvider) CreateNodes(fid string, nodes []ddrv.Node) error
  • func (pgp *PGProvider) Delete(id, parent string) error
  • func (pgp *PGProvider) Get(id, parent string) (*dp.File, error)
  • func (pgp *PGProvider) GetChild(id string) ([]*dp.File, error)
  • func (pgp *PGProvider) GetNodes(id string) ([]ddrv.Node, error)
  • func (pgp *PGProvider) Ls(name string, limit int, offset int) ([]*dp.File, error)
  • func (pgp *PGProvider) Mkdir(name string) error
  • func (pgp *PGProvider) Mv(name, newname string) error
  • func (pgp *PGProvider) Name() string
  • func (pgp *PGProvider) Rm(name string) error
  • func (pgp *PGProvider) Stat(name string) (*dp.File, error)
  • func (pgp *PGProvider) Touch(name string) error
  • func (pgp *PGProvider) Truncate(fid string) error
  • func (pgp *PGProvider) Update(id, parent string, file *dp.File) (*dp.File, error)

Constants

const Driver = "postgres"

Driver - fot now we only support postgres

const RootDirId = "11111111-1111-1111-1111-111111111111"

Functions

func Migrate

func Migrate(db *sql.DB) error

Migrate performs database migrations using the provided *sql.DB connection.

func New

func New(cfg *Config, driver *ddrv.Driver) dp.DataProvider

func NewDb

func NewDb(connStr string, skipMigration bool) *sql.DB

NewDb creates a new database connection using the dbUrl It returns the *sql.DB object representing the connection.

Types

type Config

type Config struct {
	DbURL string `mapstructure:"db_url"`
}

type PGProvider

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

func (*PGProvider) CHTime

func (pgp *PGProvider) CHTime(name string, mtime time.Time) error

func (*PGProvider) Close

func (pgp *PGProvider) Close() error

func (*PGProvider) Create

func (pgp *PGProvider) Create(name, parent string, dir bool) (*dp.File, error)

func (*PGProvider) CreateNodes

func (pgp *PGProvider) CreateNodes(fid string, nodes []ddrv.Node) error

func (*PGProvider) Delete

func (pgp *PGProvider) Delete(id, parent string) error

func (*PGProvider) Get

func (pgp *PGProvider) Get(id, parent string) (*dp.File, error)

func (*PGProvider) GetChild

func (pgp *PGProvider) GetChild(id string) ([]*dp.File, error)

func (*PGProvider) GetNodes

func (pgp *PGProvider) GetNodes(id string) ([]ddrv.Node, error)

func (*PGProvider) Ls

func (pgp *PGProvider) Ls(name string, limit int, offset int) ([]*dp.File, error)

func (*PGProvider) Mkdir

func (pgp *PGProvider) Mkdir(name string) error

func (*PGProvider) Mv

func (pgp *PGProvider) Mv(name, newname string) error

func (*PGProvider) Name

func (pgp *PGProvider) Name() string

func (*PGProvider) Rm

func (pgp *PGProvider) Rm(name string) error

func (*PGProvider) Stat

func (pgp *PGProvider) Stat(name string) (*dp.File, error)

func (*PGProvider) Touch

func (pgp *PGProvider) Touch(name string) error

func (*PGProvider) Truncate

func (pgp *PGProvider) Truncate(fid string) error

func (*PGProvider) Update

func (pgp *PGProvider) Update(id, parent string, file *dp.File) (*dp.File, error)