clusterservice

Documentation

Index

• Constants
• 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(clientset kubernetes.Interface, cluster *crv1.Pgcluster) ([]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

const (
	// ErrInvalidDataSource defines the error string that is displayed when the data source
	// parameters for a create cluster request are invalid
	ErrInvalidDataSource = "Unable to validate data source"
)

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 GetPods

func GetPods(clientset kubernetes.Interface, cluster *crv1.Pgcluster) ([]msgs.ShowClusterPod, error)

func GetPrimaryAndReplicaPods

func GetPrimaryAndReplicaPods(cluster *crv1.Pgcluster, ns string) ([]msgs.ShowClusterPod, error)

func ScaleCluster

func ScaleCluster(name, replicaCount, 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