clusterservice

package
v4.5.0-beta.1+incompat... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 10, 2020 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
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"
)

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 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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL