Documentation
¶
Overview ¶
Package db manages the SQLite database for epos-opensource. It embeds the SQL schema, ensures the database file is created under the configured data directory, and provides functions to open the connection and perform CRUD operations on K8s and Docker entries.
Index ¶
- func DeleteDocker(name string) error
- func DeleteIngestedFilesByEnvironment(envType, envName string) error
- func DeleteK8s(name string) error
- func Get() (*sqlc.Queries, error)
- func GetAllDocker() ([]sqlc.Docker, error)
- func GetAllK8s() ([]sqlc.K8s, error)
- func GetDockerByName(name string) (*sqlc.Docker, error)
- func GetIngestedFilesByEnvironment(envType, envName string) ([]sqlc.GetIngestedFilesByEnvironmentRow, error)
- func GetK8sByName(name string) (*sqlc.K8s, error)
- func GetLatestReleaseCache() (sqlc.LatestReleaseCache, error)
- func InsertDocker(docker sqlc.Docker) (*sqlc.Docker, error)
- func InsertIngestedFile(envType, envName, filePath string) error
- func InsertK8s(name, dir, contextStr, apiURL, guiURL, backofficeURL, protocol string, ...) (*sqlc.K8s, error)
- func UpsertLatestReleaseCache(tagName string, fetchedAt time.Time) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteDocker ¶
DeleteDocker removes a docker entry from the database for the given name.
func DeleteIngestedFilesByEnvironment ¶
DeleteIngestedFilesByEnvironment deletes all ingested file records for an environment.
func Get ¶
Get opens a new connection to the database, creating the database file and schema if they do not exist.
func GetAllDocker ¶
GetAllDocker retrieves all docker entries from the database.
func GetDockerByName ¶
GetDockerByName retrieves a single docker entry by name from the database.
func GetIngestedFilesByEnvironment ¶
func GetIngestedFilesByEnvironment(envType, envName string) ([]sqlc.GetIngestedFilesByEnvironmentRow, error)
GetIngestedFilesByEnvironment retrieves all ingested file records for an environment.
func GetK8sByName ¶
GetK8sByName retrieves a single k8s entry by name from the database.
func GetLatestReleaseCache ¶
func GetLatestReleaseCache() (sqlc.LatestReleaseCache, error)
GetLatestReleaseCache retrieves the latest release cache from the database.
func InsertDocker ¶
InsertDocker adds a new docker entry to the database.
func InsertIngestedFile ¶
InsertIngestedFile inserts or updates an ingested file record.
Types ¶
This section is empty.