Documentation
¶
Overview ¶
Package admindb is the implementation of most of the database access code that CPM uses to control and get metadata out of the CPM administrative database. This database is implement in a Postgresql database.
Index ¶
- Constants
- func AddContainerUser(dbConn *sql.DB, s types.ContainerUser) (int, error)
- func DeleteCluster(dbConn *sql.DB, id string) error
- func DeleteContainer(dbConn *sql.DB, id string) error
- func DeleteContainerUser(dbConn *sql.DB, containername string, rolname string) error
- func DeleteHealthCheck(dbConn *sql.DB) error
- func DeleteProject(dbConn *sql.DB, id string) error
- func GetAllClustersForProject(dbConn *sql.DB, projectId string) ([]types.Cluster, error)
- func GetAllContainers(dbConn *sql.DB) ([]types.Container, error)
- func GetAllContainersForCluster(dbConn *sql.DB, clusterID string) ([]types.Container, error)
- func GetAllContainersForProject(dbConn *sql.DB, projectID string) ([]types.Container, error)
- func GetAllContainersForServer(dbConn *sql.DB, serverID string) ([]types.Container, error)
- func GetAllContainersNotInCluster(dbConn *sql.DB) ([]types.Container, error)
- func GetAllGeneralSettings(dbConn *sql.DB) ([]types.Setting, error)
- func GetAllProjects(dbConn *sql.DB) ([]types.Project, error)
- func GetAllProxiesForProject(dbConn *sql.DB, projectID string) ([]types.Proxy, error)
- func GetAllSettings(dbConn *sql.DB) ([]types.Setting, error)
- func GetAllSettingsMap(dbConn *sql.DB) (map[string]string, error)
- func GetAllStandbyContainers(dbConn *sql.DB, clusterid string) ([]types.Container, error)
- func GetCluster(dbConn *sql.DB, id string) (types.Cluster, error)
- func GetClusterName(dbConn *sql.DB, id string) (string, error)
- func GetContainer(dbConn *sql.DB, id string) (types.Container, error)
- func GetContainerByName(dbConn *sql.DB, name string) (types.Container, error)
- func GetContainerMaster(dbConn *sql.DB, clusterid string) (types.Container, error)
- func GetContainerOldestInCluster(dbConn *sql.DB, clusterid string) (types.Container, error)
- func GetContainerPgpool(dbConn *sql.DB, clusterid string) (types.Container, error)
- func GetContainerUser(dbConn *sql.DB, containername string, usename string) (types.ContainerUser, error)
- func GetDatabaseStatus(proxy types.Proxy, containerid string) (string, error)
- func GetHealthCheck(dbConn *sql.DB) ([]types.HealthCheck, error)
- func GetProject(dbConn *sql.DB, id string) (types.Project, error)
- func GetProxy(dbConn *sql.DB, containername string) (types.Proxy, error)
- func GetProxyByContainerID(dbConn *sql.DB, containerID string) (types.Proxy, error)
- func GetSetting(dbConn *sql.DB, key string) (types.Setting, error)
- func GetUserCredentials(dbConn *sql.DB, node *types.Container) (types.Credential, error)
- func InsertCluster(dbConn *sql.DB, cluster types.Cluster) (int, error)
- func InsertContainer(dbConn *sql.DB, container types.Container) (int, error)
- func InsertHealthCheck(dbConn *sql.DB, hc types.HealthCheck) (int, error)
- func InsertProject(dbConn *sql.DB, project types.Project) (int, error)
- func InsertSetting(dbConn *sql.DB, setting types.Setting) error
- func UpdateCluster(dbConn *sql.DB, cluster types.Cluster) error
- func UpdateContainer(dbConn *sql.DB, container types.Container) error
- func UpdateContainerUser(dbConn *sql.DB, user types.ContainerUser) error
- func UpdateProject(dbConn *sql.DB, project types.Project) error
- func UpdateSetting(dbConn *sql.DB, setting types.Setting) error
Constants ¶
const CPMTEST_DB = "cpmtest"
const CPMTEST_USER = "cpmtest"
Variables ¶
This section is empty.
Functions ¶
func AddContainerUser ¶
AddContainerUser inserts a new database user for a given container and returns the new ID
func DeleteCluster ¶
DeleteCluster deletes a given cluster from the database
func DeleteContainer ¶
DeleteContainer deleles a given container
func DeleteContainerUser ¶
DeleteContainerUser deletes a container database user
func DeleteHealthCheck ¶
DeleteHealthCheck deleles the entire set of health check metrics that are persisted
func DeleteProject ¶
DeleteProject deletes a given project
func GetAllClustersForProject ¶
GetAllClustersForProject returns a list of cluster objects from the database for a given project
func GetAllContainers ¶
GetAllContainers returns a list of all containers
func GetAllContainersForCluster ¶
GetAllContainersForCluster returns a list of container objects for a given cluster
func GetAllContainersForProject ¶
GetAllContainersForProject returns a list of container objects for a given project
func GetAllContainersForServer ¶
GetAllContainersForServer returns a list of container objects for a given server
func GetAllContainersNotInCluster ¶
GetAllContainersNotInCluster is used to fetch all nodes that are eligible to be added into a cluster
func GetAllGeneralSettings ¶
GetAllGeneralSettings returns a list of all settings of 'general' types
func GetAllProjects ¶
GetAllProjects returns a list of all project objects
func GetAllProxiesForProject ¶
GetAllProxiesForProject returns a list of proxy objects for a given project
func GetAllSettings ¶
GetAllSettings returns a list of all settings
func GetAllSettingsMap ¶
GetAllSettingsMap returns a map of all settings
func GetAllStandbyContainers ¶
GetAllStandbyContainers returns a list of container standby objects for a given cluster TODO combine with GetMaster into a GetContainersByRole func
func GetCluster ¶
GetCluster returns a cluster object from the database for a given cluster ID
func GetClusterName ¶
GetClusterName returns the name of a cluster based for a given cluster ID
func GetContainer ¶
GetContainer returns a container object based on a container ID
func GetContainerByName ¶
GetContainerByName returns a container object based on a container name
func GetContainerMaster ¶
GetContainerMaster find the master container in a cluster
func GetContainerOldestInCluster ¶
GetContainerOldestInCluster find the oldest container in a cluster
func GetContainerPgpool ¶
GetContainerPgpool find the pgpool container in a cluster
func GetContainerUser ¶
func GetContainerUser(dbConn *sql.DB, containername string, usename string) (types.ContainerUser, error)
GetContainerUser returns a container user for a given container and user name
func GetDatabaseStatus ¶
GetDatabaseStatus returns a simple status of a container database
func GetHealthCheck ¶
func GetHealthCheck(dbConn *sql.DB) ([]types.HealthCheck, error)
GetHealthCheck return the current set of healthcheck metrics that are persisted
func GetProject ¶
GetProject returns a given project object
func GetProxyByContainerID ¶
GetProxyByContainerID returns a proxy object by container ID
func GetSetting ¶
GetSetting returns a particular setting based on it's key
func GetUserCredentials ¶
GetUserCredentials return the set of database credentials stored for a given container
func InsertCluster ¶
InsertCluster inserts a new cluster object into the database
func InsertContainer ¶
InsertContainer inserts a new container object and returns the container id
func InsertHealthCheck ¶
InsertHealthCheck insert a health check metric into the database, return the key
func InsertProject ¶
InsertProject inserts a new project object
func UpdateCluster ¶
UpdateCluster updates a given cluster object in the database
func UpdateContainer ¶
UpdateContainer updates a given container
func UpdateContainerUser ¶
func UpdateContainerUser(dbConn *sql.DB, user types.ContainerUser) error
UpdateContainerUser updates a given container database user
func UpdateProject ¶
UpdateProject updates a given project object
Types ¶
This section is empty.
Source Files