Documentation ¶
Index ¶
- Constants
- Variables
- func AddContainerUser(w rest.ResponseWriter, r *rest.Request)
- func AddProject(w rest.ResponseWriter, r *rest.Request)
- func AddRole(w rest.ResponseWriter, r *rest.Request)
- func AddSchedule(w rest.ResponseWriter, r *rest.Request)
- func AddServer(w rest.ResponseWriter, r *rest.Request)
- func AddUser(w rest.ResponseWriter, r *rest.Request)
- func AdminFailover(w rest.ResponseWriter, r *rest.Request)
- func AdminStartNode(w rest.ResponseWriter, r *rest.Request)
- func AdminStartServerContainers(w rest.ResponseWriter, r *rest.Request)
- func AdminStartpg(w rest.ResponseWriter, r *rest.Request)
- func AdminStopNode(w rest.ResponseWriter, r *rest.Request)
- func AdminStopServerContainers(w rest.ResponseWriter, r *rest.Request)
- func AdminStoppg(w rest.ResponseWriter, r *rest.Request)
- func AutoCluster(w rest.ResponseWriter, r *rest.Request)
- func BackupNow(w rest.ResponseWriter, r *rest.Request)
- func BadgerGenerate(w rest.ResponseWriter, r *rest.Request)
- func ChangePassword(w rest.ResponseWriter, r *rest.Request)
- func ConfigureCluster(w rest.ResponseWriter, r *rest.Request)
- func ContainerAccessRuleGetAll(w rest.ResponseWriter, r *rest.Request)
- func ContainerAccessRuleUpdate(w rest.ResponseWriter, r *rest.Request)
- func ContainerInfoBgwriter(w rest.ResponseWriter, r *rest.Request)
- func ContainerInfoStatdatabase(w rest.ResponseWriter, r *rest.Request)
- func ContainerInfoStatrepl(w rest.ResponseWriter, r *rest.Request)
- func ContainerLoadTest(w rest.ResponseWriter, r *rest.Request)
- func DeleteCluster(w rest.ResponseWriter, r *rest.Request)
- func DeleteContainerAccessRule(dbConn *sql.DB, ID string) error
- func DeleteContainerUser(w rest.ResponseWriter, r *rest.Request)
- func DeleteNode(w rest.ResponseWriter, r *rest.Request)
- func DeleteProject(w rest.ResponseWriter, r *rest.Request)
- func DeleteRole(w rest.ResponseWriter, r *rest.Request)
- func DeleteRule(dbConn *sql.DB, ID string) error
- func DeleteSchedule(w rest.ResponseWriter, r *rest.Request)
- func DeleteServer(w rest.ResponseWriter, r *rest.Request)
- func DeleteUser(w rest.ResponseWriter, r *rest.Request)
- func EventJoinCluster(w rest.ResponseWriter, r *rest.Request)
- func GetAllClusters(w rest.ResponseWriter, r *rest.Request)
- func GetAllClustersForProject(w rest.ResponseWriter, r *rest.Request)
- func GetAllGeneralSettings(w rest.ResponseWriter, r *rest.Request)
- func GetAllNodes(w rest.ResponseWriter, r *rest.Request)
- func GetAllNodesForCluster(w rest.ResponseWriter, r *rest.Request)
- func GetAllNodesForProject(w rest.ResponseWriter, r *rest.Request)
- func GetAllNodesForServer(w rest.ResponseWriter, r *rest.Request)
- func GetAllNodesNotInCluster(w rest.ResponseWriter, r *rest.Request)
- func GetAllProjects(w rest.ResponseWriter, r *rest.Request)
- func GetAllRoles(w rest.ResponseWriter, r *rest.Request)
- func GetAllSchedules(w rest.ResponseWriter, r *rest.Request)
- func GetAllServers(w rest.ResponseWriter, r *rest.Request)
- func GetAllSettings(w rest.ResponseWriter, r *rest.Request)
- func GetAllStatus(w rest.ResponseWriter, r *rest.Request)
- func GetAllUsers(w rest.ResponseWriter, r *rest.Request)
- func GetAllUsersForContainer(w rest.ResponseWriter, r *rest.Request)
- func GetBackupNodes(w rest.ResponseWriter, r *rest.Request)
- func GetCluster(w rest.ResponseWriter, r *rest.Request)
- func GetContainerUser(w rest.ResponseWriter, r *rest.Request)
- func GetHealthCheck(w rest.ResponseWriter, r *rest.Request)
- func GetNode(w rest.ResponseWriter, r *rest.Request)
- func GetPGStatus2(dbConn *sql.DB, nodename string, hostname string) (string, error)
- func GetProject(w rest.ResponseWriter, r *rest.Request)
- func GetRole(w rest.ResponseWriter, r *rest.Request)
- func GetSchedule(w rest.ResponseWriter, r *rest.Request)
- func GetServer(w rest.ResponseWriter, r *rest.Request)
- func GetStatus(w rest.ResponseWriter, r *rest.Request)
- func GetUser(w rest.ResponseWriter, r *rest.Request)
- func GetVersion(w rest.ResponseWriter, r *rest.Request)
- func InsertContainerAccessRule(dbConn *sql.DB, car ContainerAccessRule) error
- func InsertRule(dbConn *sql.DB, rule Rule) error
- func Login(w rest.ResponseWriter, r *rest.Request)
- func Logout(w rest.ResponseWriter, r *rest.Request)
- func MonitorContainerControldata(w rest.ResponseWriter, r *rest.Request)
- func MonitorContainerSettings(w rest.ResponseWriter, r *rest.Request)
- func MonitorServerGetInfo(w rest.ResponseWriter, r *rest.Request)
- func MonitorStatements(w rest.ResponseWriter, r *rest.Request)
- func OpenshiftCreate(username string, password string, templatePath string) error
- func OpenshiftDelete(username string, password string, objectName string, objectType string) error
- func PostCluster(w rest.ResponseWriter, r *rest.Request)
- func Provision(w rest.ResponseWriter, r *rest.Request)
- func RulesDelete(w rest.ResponseWriter, r *rest.Request)
- func RulesGet(w rest.ResponseWriter, r *rest.Request)
- func RulesGetAll(w rest.ResponseWriter, r *rest.Request)
- func RulesInsert(w rest.ResponseWriter, r *rest.Request)
- func RulesUpdate(w rest.ResponseWriter, r *rest.Request)
- func SaveClusterProfiles(w rest.ResponseWriter, r *rest.Request)
- func SaveProfiles(w rest.ResponseWriter, r *rest.Request)
- func SaveSetting(w rest.ResponseWriter, r *rest.Request)
- func SaveSettings(w rest.ResponseWriter, r *rest.Request)
- func ScaleUpCluster(w rest.ResponseWriter, r *rest.Request)
- func UpdateContainerUser(w rest.ResponseWriter, r *rest.Request)
- func UpdateProject(w rest.ResponseWriter, r *rest.Request)
- func UpdateRole(w rest.ResponseWriter, r *rest.Request)
- func UpdateRule(dbConn *sql.DB, rule Rule) error
- func UpdateSchedule(w rest.ResponseWriter, r *rest.Request)
- func UpdateUser(w rest.ResponseWriter, r *rest.Request)
- type AddSchedulePost
- type AutoClusterInfo
- type BackupNowPost
- type Bgwriter
- type ChgPassword
- type Child
- type Child2
- type Cluster
- type ClusterNode
- type ClusterProfiles
- type ContainerAccessRule
- type KubeResponse
- type LinuxStats
- type Loadtestresults
- type LoginToken
- type MonitorContainerParam
- type MonitorOutput
- type MonitorServerParam
- type NodeUser
- type PGStats
- type PostgresControldata
- type PostgresSetting
- type PostgresStatement
- type Profiles
- type Project
- type Project2
- type Rule
- type Server
- type Setting
- type Settings
- type SimpleStatus
- type Statdatabase
- type Statrepl
Constants ¶
View Source
const ( STANDBY = "standby" CPM_NODE_IMAGE = "cpm-node-os" CPM_PGPOOL_IMAGE = "cpm-pgpool-os" )
View Source
const CLUSTERADMIN_DB = "clusteradmin"
View Source
const CONTAINER_NOT_FOUND = "CONTAINER NOT FOUND"
Variables ¶
View Source
var CPMTEST_DB = "cpmtest"
View Source
var CPMTEST_USER = "cpmtest"
View Source
var KubeEnv = false
View Source
var KubeURL = ""
View Source
var OPENSHIFT_URL string
Functions ¶
func AddContainerUser ¶
func AddContainerUser(w rest.ResponseWriter, r *rest.Request)
func AddProject ¶
func AddProject(w rest.ResponseWriter, r *rest.Request)
func AddSchedule ¶
func AddSchedule(w rest.ResponseWriter, r *rest.Request)
func AddServer ¶
func AddServer(w rest.ResponseWriter, r *rest.Request)
we use AddServer for both updating and inserting based on the ID passed in
func AdminFailover ¶
func AdminFailover(w rest.ResponseWriter, r *rest.Request)
func AdminStartNode ¶
func AdminStartNode(w rest.ResponseWriter, r *rest.Request)
func AdminStartServerContainers ¶
func AdminStartServerContainers(w rest.ResponseWriter, r *rest.Request)
func AdminStartpg ¶
func AdminStartpg(w rest.ResponseWriter, r *rest.Request)
func AdminStopNode ¶
func AdminStopNode(w rest.ResponseWriter, r *rest.Request)
func AdminStopServerContainers ¶
func AdminStopServerContainers(w rest.ResponseWriter, r *rest.Request)
func AdminStoppg ¶
func AdminStoppg(w rest.ResponseWriter, r *rest.Request)
func AutoCluster ¶
func AutoCluster(w rest.ResponseWriter, r *rest.Request)
func BadgerGenerate ¶
func BadgerGenerate(w rest.ResponseWriter, r *rest.Request)
func ChangePassword ¶
func ChangePassword(w rest.ResponseWriter, r *rest.Request)
func ConfigureCluster ¶
func ConfigureCluster(w rest.ResponseWriter, r *rest.Request)
func ContainerAccessRuleGetAll ¶
func ContainerAccessRuleGetAll(w rest.ResponseWriter, r *rest.Request)
func ContainerAccessRuleUpdate ¶
func ContainerAccessRuleUpdate(w rest.ResponseWriter, r *rest.Request)
func ContainerAccessRuleDelete(w rest.ResponseWriter, r *rest.Request) { var err error err = secimpl.Authorize(r.PathParam("Token"), "perm-read") if err != nil { logit.Error.Println("ContainerRuleDelete: authorize error " + err.Error()) rest.Error(w, err.Error(), http.StatusUnauthorized) return } containerRuleID := r.PathParam("ID") if containerRuleID == "" { rest.Error(w, "ID required", http.StatusBadRequest) return } err = DeleteContainerAccessRule(containerRuleID) if err != nil { logit.Error.Println("ContainerRuleDelete:" + err.Error()) rest.Error(w, err.Error(), http.StatusBadRequest) return } status := SimpleStatus{} status.Status = "OK" w.WriteHeader(http.StatusOK) w.WriteJson(&status) }
func ContainerAccessRuleInsert(w rest.ResponseWriter, r *rest.Request) { logit.Info.Println("ContainerAccessRuleInsert") car := ContainerAccessRule{} err := r.DecodeJsonPayload(&car) if err != nil { logit.Error.Println("ContainerAccessRuleInsert: error in decode" + err.Error()) rest.Error(w, err.Error(), http.StatusInternalServerError) return } err = secimpl.Authorize(car.Token, "perm-container") if err != nil { logit.Error.Println("ContainerAccessRuleInsert: authorize error " + err.Error()) rest.Error(w, err.Error(), http.StatusUnauthorized) return } err = InsertContainerAccessRule(car) if err != nil { logit.Error.Println("ContainerAccessRuleUpdate: error " + err.Error()) rest.Error(w, err.Error(), http.StatusBadRequest) return } status := SimpleStatus{} status.Status = "OK" w.WriteHeader(http.StatusOK) w.WriteJson(&status) }
func ContainerInfoBgwriter ¶
func ContainerInfoBgwriter(w rest.ResponseWriter, r *rest.Request)
func ContainerInfoStatdatabase ¶
func ContainerInfoStatdatabase(w rest.ResponseWriter, r *rest.Request)
func ContainerInfoStatrepl ¶
func ContainerInfoStatrepl(w rest.ResponseWriter, r *rest.Request)
func ContainerLoadTest ¶
func ContainerLoadTest(w rest.ResponseWriter, r *rest.Request)
func DeleteCluster ¶
func DeleteCluster(w rest.ResponseWriter, r *rest.Request)
func DeleteContainerUser ¶
func DeleteContainerUser(w rest.ResponseWriter, r *rest.Request)
func DeleteNode ¶
func DeleteNode(w rest.ResponseWriter, r *rest.Request)
TODO refactor this to share code with DeleteCluster!!!!!
func DeleteProject ¶
func DeleteProject(w rest.ResponseWriter, r *rest.Request)
func DeleteRole ¶
func DeleteRole(w rest.ResponseWriter, r *rest.Request)
func DeleteSchedule ¶
func DeleteSchedule(w rest.ResponseWriter, r *rest.Request)
func DeleteServer ¶
func DeleteServer(w rest.ResponseWriter, r *rest.Request)
func DeleteUser ¶
func DeleteUser(w rest.ResponseWriter, r *rest.Request)
func EventJoinCluster ¶
func EventJoinCluster(w rest.ResponseWriter, r *rest.Request)
func GetAllClusters ¶
func GetAllClusters(w rest.ResponseWriter, r *rest.Request)
func GetAllClustersForProject ¶
func GetAllClustersForProject(w rest.ResponseWriter, r *rest.Request)
func GetAllGeneralSettings ¶
func GetAllGeneralSettings(w rest.ResponseWriter, r *rest.Request)
func GetAllNodes ¶
func GetAllNodes(w rest.ResponseWriter, r *rest.Request)
func GetAllNodesForCluster ¶
func GetAllNodesForCluster(w rest.ResponseWriter, r *rest.Request)
func GetAllNodesForProject ¶
func GetAllNodesForProject(w rest.ResponseWriter, r *rest.Request)
func GetAllNodesForServer ¶
func GetAllNodesForServer(w rest.ResponseWriter, r *rest.Request)
func GetAllNodesNotInCluster ¶
func GetAllNodesNotInCluster(w rest.ResponseWriter, r *rest.Request)
func GetAllProjects ¶
func GetAllProjects(w rest.ResponseWriter, r *rest.Request)
func GetAllRoles ¶
func GetAllRoles(w rest.ResponseWriter, r *rest.Request)
func GetAllSchedules ¶
func GetAllSchedules(w rest.ResponseWriter, r *rest.Request)
func GetAllServers ¶
func GetAllServers(w rest.ResponseWriter, r *rest.Request)
func GetAllSettings ¶
func GetAllSettings(w rest.ResponseWriter, r *rest.Request)
func GetAllStatus ¶
func GetAllStatus(w rest.ResponseWriter, r *rest.Request)
func GetAllUsers ¶
func GetAllUsers(w rest.ResponseWriter, r *rest.Request)
func GetAllUsersForContainer ¶
func GetAllUsersForContainer(w rest.ResponseWriter, r *rest.Request)
func GetBackupNodes ¶
func GetBackupNodes(w rest.ResponseWriter, r *rest.Request)
func GetCluster ¶
func GetCluster(w rest.ResponseWriter, r *rest.Request)
func GetContainerUser ¶
func GetContainerUser(w rest.ResponseWriter, r *rest.Request)
func GetHealthCheck ¶
func GetHealthCheck(w rest.ResponseWriter, r *rest.Request)
func GetPGStatus2 ¶
func GetProject ¶
func GetProject(w rest.ResponseWriter, r *rest.Request)
func GetSchedule ¶
func GetSchedule(w rest.ResponseWriter, r *rest.Request)
func GetVersion ¶
func GetVersion(w rest.ResponseWriter, r *rest.Request)
func InsertContainerAccessRule ¶
func InsertContainerAccessRule(dbConn *sql.DB, car ContainerAccessRule) error
func MonitorContainerControldata ¶
func MonitorContainerControldata(w rest.ResponseWriter, r *rest.Request)
func MonitorContainerSettings ¶
func MonitorContainerSettings(w rest.ResponseWriter, r *rest.Request)
func MonitorServerGetInfo ¶
func MonitorServerGetInfo(w rest.ResponseWriter, r *rest.Request)
monitor server - get info
func MonitorStatements ¶
func MonitorStatements(w rest.ResponseWriter, r *rest.Request)
func OpenshiftCreate ¶
func OpenshiftDelete ¶
func PostCluster ¶
func PostCluster(w rest.ResponseWriter, r *rest.Request)
we use POST for both updating and inserting based on the ID passed in
func Provision ¶
func Provision(w rest.ResponseWriter, r *rest.Request)
docker run TODO: convert this to POST
func RulesDelete ¶
func RulesDelete(w rest.ResponseWriter, r *rest.Request)
func RulesGetAll ¶
func RulesGetAll(w rest.ResponseWriter, r *rest.Request)
func RulesInsert ¶
func RulesInsert(w rest.ResponseWriter, r *rest.Request)
func RulesUpdate ¶
func RulesUpdate(w rest.ResponseWriter, r *rest.Request)
func SaveClusterProfiles ¶
func SaveClusterProfiles(w rest.ResponseWriter, r *rest.Request)
func SaveProfiles ¶
func SaveProfiles(w rest.ResponseWriter, r *rest.Request)
func SaveSetting ¶
func SaveSetting(w rest.ResponseWriter, r *rest.Request)
func SaveSettings ¶
func SaveSettings(w rest.ResponseWriter, r *rest.Request)
func ScaleUpCluster ¶
func ScaleUpCluster(w rest.ResponseWriter, r *rest.Request)
func UpdateContainerUser ¶
func UpdateContainerUser(w rest.ResponseWriter, r *rest.Request)
func UpdateProject ¶
func UpdateProject(w rest.ResponseWriter, r *rest.Request)
func UpdateRole ¶
func UpdateRole(w rest.ResponseWriter, r *rest.Request)
func UpdateSchedule ¶
func UpdateSchedule(w rest.ResponseWriter, r *rest.Request)
func UpdateUser ¶
func UpdateUser(w rest.ResponseWriter, r *rest.Request)
Types ¶
type AddSchedulePost ¶
type AutoClusterInfo ¶
type BackupNowPost ¶
type ChgPassword ¶
type ClusterNode ¶
type ClusterProfiles ¶
type ContainerAccessRule ¶
type ContainerAccessRule struct { ID string Token string ContainerID string AccessRuleID string AccessRuleName string Selected string CreateDate string }
func GetAllContainerAccessRule ¶
func GetAllContainerAccessRule(dbConn *sql.DB, containerID string) ([]ContainerAccessRule, error)
func GetContainerAccessRule ¶
func GetContainerAccessRule(dbConn *sql.DB, ID string) (ContainerAccessRule, error)
type KubeResponse ¶
type KubeResponse struct {
URL string
}
type LinuxStats ¶
type Loadtestresults ¶
type LoginToken ¶
type LoginToken struct {
Contents string
}
type MonitorContainerParam ¶
type MonitorOutput ¶
type MonitorServerParam ¶
type PostgresControldata ¶
type PostgresSetting ¶
type PostgresStatement ¶
type Rule ¶
type SimpleStatus ¶
type SimpleStatus struct {
Status string
}
type Statdatabase ¶
Click to show internal directories.
Click to hide internal directories.