db

Documentation

Index

• Variables
• 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 DeleteComponnent(systemID string, deleteTime time.Time) error
• func DeleteSystem(systemTemplateID string, deleteTime time.Time) (string, error)
• func DeleteSystemTemplate(systemTemplate *v1.SystemTemplate) error
• func FindCanary(namespace, name string) (*pkg.Canary, error)
• func FindCheck(canary pkg.Canary, name string) (*pkg.Check, error)
• func GetAllCanaries() ([]v1.Canary, error)
• func GetAllChecks() ([]pkg.Check, error)
• func GetAllSystemTemplates() ([]v1.SystemTemplate, 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 PersistCanary(canary v1.Canary, source string) (string, bool, error)
• func PersistCheck(check pkg.Check) (string, error)
• func PersistComponent(component *pkg.Component) (string, error)
• func PersistSystem(system *pkg.System) error
• func PersistSystemTemplate(system *v1.SystemTemplate) (string, bool, error)
• func PersistSystems(results []*pkg.System) 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 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 DeleteComponnent

func DeleteComponnent(systemID string, deleteTime time.Time) error

func DeleteSystem

func DeleteSystem(systemTemplateID string, deleteTime time.Time) (string, error)

func DeleteSystemTemplate

func DeleteSystemTemplate(systemTemplate *v1.SystemTemplate) error

func FindCanary

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

func FindCheck

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

func GetAllCanaries

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

func GetAllChecks

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

func GetAllSystemTemplates

func GetAllSystemTemplates() ([]v1.SystemTemplate, 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 PersistCanary

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

func PersistCheck

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

func PersistComponent

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

func PersistSystem

func PersistSystem(system *pkg.System) error

func PersistSystemTemplate

func PersistSystemTemplate(system *v1.SystemTemplate) (string, bool, error)

func PersistSystems

func PersistSystems(results []*pkg.System) 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