Documentation
¶
Index ¶
- func CreateCluster(request *msgs.CreateClusterRequest, ns, pgouser string) msgs.CreateClusterResponse
- func CreateClusterHandler(w http.ResponseWriter, r *http.Request)
- func DeleteCluster(name, selector string, deleteData, deleteBackups bool, ns, pgouser string) msgs.DeleteClusterResponse
- func DeleteClusterHandler(w http.ResponseWriter, r *http.Request)
- func GetPods(cluster *crv1.Pgcluster, ns string) ([]msgs.ShowClusterPod, error)
- func GetPrimaryAndReplicaPods(cluster *crv1.Pgcluster, ns string) ([]msgs.ShowClusterPod, error)
- func ScaleCluster(...) msgs.ClusterScaleResponse
- func ScaleClusterHandler(w http.ResponseWriter, r *http.Request)
- func ScaleDown(deleteData bool, clusterName, replicaName, ns string) msgs.ScaleDownResponse
- func ScaleDownHandler(w http.ResponseWriter, r *http.Request)
- func ScaleQuery(name, ns string) msgs.ScaleQueryResponse
- func ScaleQueryHandler(w http.ResponseWriter, r *http.Request)
- func ShowCluster(name, selector, ccpimagetag, ns string, allflag bool) msgs.ShowClusterResponse
- func ShowClusterHandler(w http.ResponseWriter, r *http.Request)
- func TestCluster(name, selector, ns, pgouser string, allFlag bool) msgs.ClusterTestResponse
- func TestClusterHandler(w http.ResponseWriter, r *http.Request)
- func UpdateCluster(request *msgs.UpdateClusterRequest) msgs.UpdateClusterResponse
- func UpdateClusterHandler(w http.ResponseWriter, r *http.Request)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateCluster ¶
func CreateCluster(request *msgs.CreateClusterRequest, ns, pgouser string) msgs.CreateClusterResponse
CreateCluster ... pgo create cluster mycluster
func CreateClusterHandler ¶
func CreateClusterHandler(w http.ResponseWriter, r *http.Request)
CreateClusterHandler ... pgo create cluster parameters secretfrom
func DeleteCluster ¶
func DeleteCluster(name, selector string, deleteData, deleteBackups bool, ns, pgouser string) msgs.DeleteClusterResponse
DeleteCluster ...
func DeleteClusterHandler ¶
func DeleteClusterHandler(w http.ResponseWriter, r *http.Request)
DeleteClusterHandler ... pgo delete mycluster parameters showsecrets parameters selector parameters postgresversion returns a ShowClusterResponse
func ScaleCluster ¶
func ScaleCluster(name, replicaCount, resourcesConfig, storageConfig, nodeLabel, ccpImageTag, serviceType, ns, pgouser string) msgs.ClusterScaleResponse
ScaleCluster ...
func ScaleClusterHandler ¶
func ScaleClusterHandler(w http.ResponseWriter, r *http.Request)
ScaleClusterHandler ... pgo scale mycluster --replica-count=1 parameters showsecrets returns a ScaleResponse
func ScaleDown ¶
func ScaleDown(deleteData bool, clusterName, replicaName, ns string) msgs.ScaleDownResponse
ScaleDown ...
func ScaleDownHandler ¶
func ScaleDownHandler(w http.ResponseWriter, r *http.Request)
ScaleDownHandler ... pgo scale mycluster --scale-down-target=somereplicaname returns a ScaleDownResponse
func ScaleQuery ¶
func ScaleQuery(name, ns string) msgs.ScaleQueryResponse
ScaleQuery lists the replicas that are in the PostgreSQL cluster with information that is helpful in determining which one to fail over to, such as the lag behind the replica as well as the timeline
func ScaleQueryHandler ¶
func ScaleQueryHandler(w http.ResponseWriter, r *http.Request)
ScaleQueryHandler ... pgo scale mycluster --query returns a ScaleQueryResponse
func ShowCluster ¶
func ShowCluster(name, selector, ccpimagetag, ns string, allflag bool) msgs.ShowClusterResponse
ShowCluster ...
func ShowClusterHandler ¶
func ShowClusterHandler(w http.ResponseWriter, r *http.Request)
ShowClusterHandler ... pgo show cluster pgo delete mycluster parameters showsecrets parameters selector parameters postgresversion returns a ShowClusterResponse
func TestCluster ¶
func TestCluster(name, selector, ns, pgouser string, allFlag bool) msgs.ClusterTestResponse
TestCluster performs a variety of readiness checks against one or more clusters within a namespace. It leverages the following two Kubernetes constructs in order to determine the availability of PostgreSQL clusters:
- Pod readiness checks. The Pod readiness checks leverage "pg_isready" to determine if the PostgreSQL cluster is able to accept connecions
- Endpoint checks. The check sees if the services in front of the the PostgreSQL instances are able to route connections from the "outside" into the instances
func TestClusterHandler ¶
func TestClusterHandler(w http.ResponseWriter, r *http.Request)
TestClusterHandler ... pgo test mycluster
func UpdateCluster ¶
func UpdateCluster(request *msgs.UpdateClusterRequest) msgs.UpdateClusterResponse
UpdateCluster ...
func UpdateClusterHandler ¶
func UpdateClusterHandler(w http.ResponseWriter, r *http.Request)
UpdateClusterHandler ... pgo update cluster mycluster --autofail=true pgo update cluster --selector=env=research --autofail=false returns a UpdateClusterResponse
Types ¶
This section is empty.
Source Files