boltPackages

Documentation

Index

• func NewChangelogPool(directory string, fileMode os.FileMode, boltOptions *bolt.Options) (*timed.Pool, error)
• func NewDB(filename string, fileMode os.FileMode, boltOptions *bolt.Options) (db *bolt.DB, err error)
• type Logger
• type Service
  • func (s Service) AddDomain(o *packages.DomainOptions, byUserID string) (d *packages.Domain, err error)
  • func (s Service) AddPackage(o *packages.PackageOptions, byUserID string) (p *packages.Package, err error)
  • func (s Service) AddUserToDomain(ref, userID, byUserID string) (err error)
  • func (s Service) ChangelogForDomain(domainRef, start string, limit int) (page packages.Changelog, err error)
  • func (s Service) ChangelogRecord(domainRef, id string) (record *packages.ChangelogRecord, err error)
  • func (s Service) DataDump(ifModifiedSince *time.Time) (dump *dataDump.Dump, err error)
  • func (s Service) DeleteChangelogRecord(domainRef, id string) (record *packages.ChangelogRecord, err error)
  • func (s Service) DeleteDomain(ref, byUserID string) (d *packages.Domain, err error)
  • func (s Service) DeletePackage(id string, byUserID string) (p *packages.Package, err error)
  • func (s Service) Domain(ref string) (d *packages.Domain, err error)
  • func (s Service) DomainUsers(ref string) (users packages.DomainUsers, err error)
  • func (s Service) Domains(startRef string, limit int) (page packages.DomainsPage, err error)
  • func (s Service) DomainsByOwner(userID, startRef string, limit int) (p packages.DomainsPage, err error)
  • func (s Service) DomainsByUser(userID, startRef string, limit int) (p packages.DomainsPage, err error)
  • func (s Service) Package(id string) (p *packages.Package, err error)
  • func (s Service) PackagesByDomain(domainRef, startName string, limit int) (page packages.PackagesPage, err error)
  • func (s Service) RemoveUserFromDomain(ref, userID, byUserID string) (err error)
  • func (s Service) ResolvePackage(path string) (resolution *packages.PackageResolution, err error)
  • func (s Service) UpdateDomain(ref string, o *packages.DomainOptions, byUserID string) (d *packages.Domain, err error)
  • func (s Service) UpdatePackage(id string, o *packages.PackageOptions, byUserID string) (p *packages.Package, err error)

Functions

func NewChangelogPool

func NewChangelogPool(directory string, fileMode os.FileMode, boltOptions *bolt.Options) (*timed.Pool, error)

func NewDB

func NewDB(filename string, fileMode os.FileMode, boltOptions *bolt.Options) (db *bolt.DB, err error)

NewDB opens a new BoltDB database.

Types

type Logger

type Logger interface {
	Errorf(format string, a ...interface{})
}

Logger defines interface for logging messages with various severity levels.

type Service

type Service struct {
	DB        *bolt.DB
	Changelog *timed.Pool
	Logger    Logger
}

Service implements gopherpit.com/gopherpit/services/packages.Service interface.

func (Service) AddDomain

func (s Service) AddDomain(o *packages.DomainOptions, byUserID string) (d *packages.Domain, err error)

func (Service) AddPackage

func (s Service) AddPackage(o *packages.PackageOptions, byUserID string) (p *packages.Package, err error)

func (Service) AddUserToDomain

func (s Service) AddUserToDomain(ref, userID, byUserID string) (err error)

func (Service) ChangelogForDomain

func (s Service) ChangelogForDomain(domainRef, start string, limit int) (page packages.Changelog, err error)

func (Service) ChangelogRecord

func (s Service) ChangelogRecord(domainRef, id string) (record *packages.ChangelogRecord, err error)

func (Service) DataDump

func (s Service) DataDump(ifModifiedSince *time.Time) (dump *dataDump.Dump, err error)

DataDump implements dataDump.Interface interface to extract database data in a safe and reliable way.

func (Service) DeleteChangelogRecord

func (s Service) DeleteChangelogRecord(domainRef, id string) (record *packages.ChangelogRecord, err error)

func (Service) DeleteDomain

func (s Service) DeleteDomain(ref, byUserID string) (d *packages.Domain, err error)

func (Service) DeletePackage

func (s Service) DeletePackage(id string, byUserID string) (p *packages.Package, err error)

func (Service) Domain

func (s Service) Domain(ref string) (d *packages.Domain, err error)

func (Service) DomainUsers

func (s Service) DomainUsers(ref string) (users packages.DomainUsers, err error)

func (Service) Domains

func (s Service) Domains(startRef string, limit int) (page packages.DomainsPage, err error)

func (Service) DomainsByOwner

func (s Service) DomainsByOwner(userID, startRef string, limit int) (p packages.DomainsPage, err error)

func (Service) DomainsByUser

func (s Service) DomainsByUser(userID, startRef string, limit int) (p packages.DomainsPage, err error)

func (Service) Package

func (s Service) Package(id string) (p *packages.Package, err error)

func (Service) PackagesByDomain

func (s Service) PackagesByDomain(domainRef, startName string, limit int) (page packages.PackagesPage, err error)

func (Service) RemoveUserFromDomain

func (s Service) RemoveUserFromDomain(ref, userID, byUserID string) (err error)

func (Service) ResolvePackage

func (s Service) ResolvePackage(path string) (resolution *packages.PackageResolution, err error)

func (Service) UpdateDomain

func (s Service) UpdateDomain(ref string, o *packages.DomainOptions, byUserID string) (d *packages.Domain, err error)

func (Service) UpdatePackage

func (s Service) UpdatePackage(id string, o *packages.PackageOptions, byUserID string) (p *packages.Package, err error)