database

Documentation

Overview

Package database is a database interface for export importing.

Index

• type ExportImportDB
  • func New(db *database.DB) *ExportImportDB
  • func (db *ExportImportDB) ActiveConfigs(ctx context.Context) ([]*model.ExportImport, error)
  • func (db *ExportImportDB) AddConfig(ctx context.Context, ei *model.ExportImport) error
  • func (db *ExportImportDB) AddImportFilePublicKey(ctx context.Context, ifpk *model.ImportFilePublicKey) error
  • func (db *ExportImportDB) AllowedKeys(ctx context.Context, ei *model.ExportImport) ([]*model.ImportFilePublicKey, error)
  • func (db *ExportImportDB) CompleteImportFile(ctx context.Context, ef *model.ImportFile, status string) error
  • func (db *ExportImportDB) CreateFiles(ctx context.Context, ei *model.ExportImport, filenames []string) (int, error)
  • func (db *ExportImportDB) ExpireImportFilePublicKey(ctx context.Context, ifpk *model.ImportFilePublicKey) error
  • func (db *ExportImportDB) GetConfig(ctx context.Context, id int64) (*model.ExportImport, error)
  • func (db *ExportImportDB) GetOpenImportFiles(ctx context.Context, lockDuration time.Duration, ei *model.ExportImport) ([]*model.ImportFile, error)
  • func (db *ExportImportDB) LeaseImportFile(ctx context.Context, lockDuration time.Duration, ef *model.ImportFile) error
  • func (db *ExportImportDB) ListConfigs(ctx context.Context) ([]*model.ExportImport, error)
  • func (db *ExportImportDB) UpdateConfig(ctx context.Context, c *model.ExportImport) error

Types

type ExportImportDB

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

func New

func New(db *database.DB) *ExportImportDB

func (*ExportImportDB) ActiveConfigs

func (db *ExportImportDB) ActiveConfigs(ctx context.Context) ([]*model.ExportImport, error)

func (*ExportImportDB) AddConfig

func (db *ExportImportDB) AddConfig(ctx context.Context, ei *model.ExportImport) error

func (*ExportImportDB) AddImportFilePublicKey

func (db *ExportImportDB) AddImportFilePublicKey(ctx context.Context, ifpk *model.ImportFilePublicKey) error

func (*ExportImportDB) AllowedKeys

func (db *ExportImportDB) AllowedKeys(ctx context.Context, ei *model.ExportImport) ([]*model.ImportFilePublicKey, error)

func (*ExportImportDB) CompleteImportFile

func (db *ExportImportDB) CompleteImportFile(ctx context.Context, ef *model.ImportFile, status string) error

func (*ExportImportDB) CreateFiles

func (db *ExportImportDB) CreateFiles(ctx context.Context, ei *model.ExportImport, filenames []string) (int, error)

func (*ExportImportDB) ExpireImportFilePublicKey

func (db *ExportImportDB) ExpireImportFilePublicKey(ctx context.Context, ifpk *model.ImportFilePublicKey) error

func (*ExportImportDB) GetConfig

func (db *ExportImportDB) GetConfig(ctx context.Context, id int64) (*model.ExportImport, error)

GetConfig gets the configuration for the given id.

func (*ExportImportDB) GetOpenImportFiles

func (db *ExportImportDB) GetOpenImportFiles(ctx context.Context, lockDuration time.Duration, ei *model.ExportImport) ([]*model.ImportFile, error)

func (*ExportImportDB) LeaseImportFile

func (db *ExportImportDB) LeaseImportFile(ctx context.Context, lockDuration time.Duration, ef *model.ImportFile) error

func (*ExportImportDB) ListConfigs

func (db *ExportImportDB) ListConfigs(ctx context.Context) ([]*model.ExportImport, error)

func (*ExportImportDB) UpdateConfig

func (db *ExportImportDB) UpdateConfig(ctx context.Context, c *model.ExportImport) error

UpdateConfig updates an existing ExportImporter.