db

Documentation

Index

• Variables
• func AddSystem(system *pkg.System, cols ...string) (string, error)
• func AddSystemSpec(id string, system v1.System) (string, error)
• func Cleanup()
• func ConvertNamedParams(sql string, namedArgs map[string]interface{}) (string, []interface{})
• func CreateCanary(canary *pkg.Canary) error
• func CreateCheck(canary pkg.Canary, check *pkg.Check) error
• func DeleteCanary(canary v1.Canary) error
• func FindCanary(namespace, name string) (*pkg.Canary, error)
• func FindCheck(canary pkg.Canary, name string) (*pkg.Check, error)
• func FindSystem(systemID, systemType string) (*models.System, error)
• func GetAllCanaries() ([]v1.Canary, error)
• func GetAllChecks() ([]pkg.Check, error)
• func GetCanary(id string) (*pkg.Canary, error)
• func GetCheck(id string) (*pkg.Check, error)
• func GetDB() (*sql.DB, error)
• func Init() error
• func IsConfigured() bool
• func IsConnected() bool
• func Migrate() error
• func NewComponentModel(component *pkg.Component) models.Component
• func NewSystemModel(system *pkg.System) models.System
• func Persist(results []*pkg.System) error
• func PersistCanary(canary v1.Canary, source string) (string, bool, error)
• func PersistCheck(check pkg.Check) (string, error)
• func PersistComponent(systemID string, component *pkg.Component, parent *models.Component) error
• func QueryNamed(ctx context.Context, sql string, args map[string]interface{}) (pgx.Rows, error)
• func Start(ctx context.Context) error
• func StopServer() error

Variables

var ConnectionString string

var DefaultExpiryDays int

var Gorm *gorm.DB

var Pool *pgxpool.Pool

var PostgresServer *embeddedpostgres.EmbeddedPostgres

var Trace bool

Functions

func AddSystem

func AddSystem(system *pkg.System, cols ...string) (string, error)

func AddSystemSpec

func AddSystemSpec(id string, system v1.System) (string, error)

func Cleanup

func Cleanup()

func ConvertNamedParams

func ConvertNamedParams(sql string, namedArgs map[string]interface{}) (string, []interface{})

func CreateCanary

func CreateCanary(canary *pkg.Canary) error

func CreateCheck

func CreateCheck(canary pkg.Canary, check *pkg.Check) error

func DeleteCanary

func DeleteCanary(canary v1.Canary) error

func FindCanary

func FindCanary(namespace, name string) (*pkg.Canary, error)

func FindCheck

func FindCheck(canary pkg.Canary, name string) (*pkg.Check, error)

func FindSystem

func FindSystem(systemID, systemType string) (*models.System, error)

func GetAllCanaries

func GetAllCanaries() ([]v1.Canary, error)

func GetAllChecks

func GetAllChecks() ([]pkg.Check, error)

func GetCanary

func GetCanary(id string) (*pkg.Canary, error)

func GetCheck

func GetCheck(id string) (*pkg.Check, error)

func GetDB

func GetDB() (*sql.DB, error)

func Init

func Init() error

func IsConfigured

func IsConfigured() bool

func IsConnected

func IsConnected() bool

func Migrate

func Migrate() error

func NewComponentModel

func NewComponentModel(component *pkg.Component) models.Component

func NewSystemModel

func NewSystemModel(system *pkg.System) models.System

func Persist

func Persist(results []*pkg.System) error

func PersistCanary

func PersistCanary(canary v1.Canary, source string) (string, bool, error)

func PersistCheck

func PersistCheck(check pkg.Check) (string, error)

func PersistComponent

func PersistComponent(systemID string, component *pkg.Component, parent *models.Component) error

func QueryNamed

func QueryNamed(ctx context.Context, sql string, args map[string]interface{}) (pgx.Rows, error)

func Start

func Start(ctx context.Context) error

func StopServer

func StopServer() error