Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

database

package

Go to main page

Versions in this module

v0

v0.2.0

Sep 6, 2025

Changes in this version

type Database

+ func (db *Database) DiskFreeAdd(dev *model.Device, free *model.DiskFree) error

+ func (db *Database) DiskFreeGet() (map[int64]*model.DiskFree, error)

v0.1.1

Sep 4, 2025

v0.1.0

Sep 2, 2025

Changes in this version

+ var ErrEmptyUpdate = errors.New("Update operation does not change any values")

+ var ErrInvalidSavepoint = errors.New("that save point does not exist")

+ var ErrInvalidValue = errors.New("Invalid value for parameter")

+ var ErrNoTxInProgress = errors.New("There is no transaction in progress")

+ var ErrObjectNotFound = errors.New("object was not found in database")

+ var ErrTxInProgress = errors.New("A Transaction is already in progress")

+ func InitPool(size int) error

+ type Database struct

+ func Open(path string) (*Database, error)

+ func (db *Database) Begin() error

+ func (db *Database) Close() error

+ func (db *Database) Commit() error

+ func (db *Database) DeviceAdd(dev *model.Device) error

+ func (db *Database) DeviceGetAll() ([]*model.Device, error)

+ func (db *Database) DeviceGetByID(id int64) (*model.Device, error)

+ func (db *Database) DeviceGetByName(name string) (*model.Device, error)

+ func (db *Database) DeviceGetByNetwork(network *model.Network) ([]*model.Device, error)

+ func (db *Database) DeviceUpdateLastSeen(dev *model.Device, t time.Time) error

+ func (db *Database) DeviceUpdateOS(dev *model.Device, osname string) error

+ func (db *Database) NetworkAdd(n *model.Network) error

+ func (db *Database) NetworkDevCnt() (map[int64]int, error)

+ func (db *Database) NetworkGetAll() ([]*model.Network, error)

+ func (db *Database) NetworkGetByAddr(addr *net.IPNet) (*model.Network, error)

+ func (db *Database) NetworkGetByID(id int64) (*model.Network, error)

+ func (db *Database) NetworkUpdateDesc(n *model.Network, desc string) error

+ func (db *Database) NetworkUpdateScanStamp(n *model.Network, t time.Time) error

+ func (db *Database) PerformMaintenance() error

+ func (db *Database) Rollback() error

+ func (db *Database) SavepointCreate(name string) error

+ func (db *Database) SavepointRelease(name string) error

+ func (db *Database) SavepointRollback(name string) error

+ func (db *Database) UpdatesAdd(u *model.Updates) error

+ func (db *Database) UpdatesGetByDevice(d *model.Device, max int64) ([]*model.Updates, error)

+ func (db *Database) UpdatesGetRecent() ([]*model.Updates, error)

+ func (db *Database) UptimeAdd(u *model.Uptime) error

+ func (db *Database) UptimeGetByDevice(d *model.Device, cnt int) ([]*model.Uptime, error)

+ type Pool struct

+ var DBPool *Pool

+ func NewPool(cnt int) (*Pool, error)

+ func (pool *Pool) Close() error

+ func (pool *Pool) Get() *Database

+ func (pool *Pool) GetNoWait() (*Database, error)

+ func (pool *Pool) IsEmpty() bool

+ func (pool *Pool) Put(db *Database)