db

Documentation

Overview

Package db provides mechanisms for interacting with a database directly

Index

• type PostgresClient
  • func NewPostgresClient(host, database, user, password string, port int, use_ssl bool) (*PostgresClient, error)
  • func NewPostgresClientFromViper() (*PostgresClient, error)
  • func (d *PostgresClient) DeleteOne(asset_id int64) (models.Asset, []int64, error)
  • func (d *PostgresClient) Insert(assets []models.Asset) ([]models.Asset, error)
  • func (d *PostgresClient) InsertAssetAttributes(assetAttributes []models.AssetAttribute) ([]models.AssetAttribute, error)
  • func (d *PostgresClient) InsertAttributes(attributes []models.Attribute) ([]models.Attribute, error)
  • func (d *PostgresClient) List(deleted bool, pageSize, page int) ([]models.Asset, error)
  • func (d *PostgresClient) ListAssetAttributeValues(assetID int64) (keyValues []models.KeyValue, err error)
  • func (d *PostgresClient) ListAssetAttributes() (assetAttributes []models.AssetAttribute, err error)
  • func (d *PostgresClient) ListAttributes() (attributes []models.Attribute, err error)
  • func (d *PostgresClient) ListEvents() (events []models.Event, err error)
  • func (d *PostgresClient) RecordEvent(content string) error
  • func (d *PostgresClient) RestoreOne(asset_id int64) (models.Asset, error)
  • func (d *PostgresClient) Seed() (sql.Result, error)
  • func (d *PostgresClient) SelectAsset(id int64) (models.Asset, error)
  • func (d *PostgresClient) UpdateAssetDescription(assetID int64, description string) (int64, string, error)
  • func (d *PostgresClient) UpdateAssetStatus(assetID int64, status string) (int64, string, error)
  • func (d *PostgresClient) UpdateAssetTarget(assetID, target int64) (int64, int64, error)

Types

type PostgresClient

type PostgresClient struct {
	DB sqlx.DB
}

PostgresClient is a postgres client based on sqlx

func NewPostgresClient

func NewPostgresClient(host, database, user, password string, port int, use_ssl bool) (*PostgresClient, error)

func NewPostgresClientFromViper

func NewPostgresClientFromViper() (*PostgresClient, error)

func (*PostgresClient) DeleteOne

func (d *PostgresClient) DeleteOne(asset_id int64) (models.Asset, []int64, error)

DeleteOne deletes one asset identified by asset_id, returning the deleted asset as well as the ids of any asset that was affected by the deletion, and any error encountered.

func (*PostgresClient) Insert

func (d *PostgresClient) Insert(assets []models.Asset) ([]models.Asset, error)

func (*PostgresClient) InsertAssetAttributes

func (d *PostgresClient) InsertAssetAttributes(assetAttributes []models.AssetAttribute) ([]models.AssetAttribute, error)

func (*PostgresClient) InsertAttributes

func (d *PostgresClient) InsertAttributes(attributes []models.Attribute) ([]models.Attribute, error)

func (*PostgresClient) List

func (d *PostgresClient) List(deleted bool, pageSize, page int) ([]models.Asset, error)

func (*PostgresClient) ListAssetAttributeValues

func (d *PostgresClient) ListAssetAttributeValues(assetID int64) (keyValues []models.KeyValue, err error)

func (*PostgresClient) ListAssetAttributes

func (d *PostgresClient) ListAssetAttributes() (assetAttributes []models.AssetAttribute, err error)

func (*PostgresClient) ListAttributes

func (d *PostgresClient) ListAttributes() (attributes []models.Attribute, err error)

func (*PostgresClient) ListEvents

func (d *PostgresClient) ListEvents() (events []models.Event, err error)

func (*PostgresClient) RecordEvent

func (d *PostgresClient) RecordEvent(content string) error

RecordEvent allows inserting into events when an asset or a tag is modified or deleted.

func (*PostgresClient) RestoreOne

func (d *PostgresClient) RestoreOne(asset_id int64) (models.Asset, error)

func (*PostgresClient) Seed

func (d *PostgresClient) Seed() (sql.Result, error)

func (*PostgresClient) SelectAsset

func (d *PostgresClient) SelectAsset(id int64) (models.Asset, error)

func (*PostgresClient) UpdateAssetDescription

func (d *PostgresClient) UpdateAssetDescription(assetID int64, description string) (int64, string, error)

func (*PostgresClient) UpdateAssetStatus

func (d *PostgresClient) UpdateAssetStatus(assetID int64, status string) (int64, string, error)

func (*PostgresClient) UpdateAssetTarget

func (d *PostgresClient) UpdateAssetTarget(assetID, target int64) (int64, int64, error)