Versions in this module Expand all Collapse all v1 v1.0.0 Aug 8, 2018 Changes in this version + type Cluster struct + KubeClient k8sutil.KubernetesClient + func New(cfg Config, kubeClient k8sutil.KubernetesClient, pgSpec spec.Postgresql, ...) *Cluster + func (c *Cluster) Create() error + func (c *Cluster) Delete() + func (c *Cluster) ExecCommand(podName *spec.NamespacedName, command ...string) (string, error) + func (c *Cluster) GetCurrentProcess() spec.Process + func (c *Cluster) GetEndpointMaster() *v1.Endpoints + func (c *Cluster) GetEndpointReplica() *v1.Endpoints + func (c *Cluster) GetPodDisruptionBudget() *policybeta1.PodDisruptionBudget + func (c *Cluster) GetServiceMaster() *v1.Service + func (c *Cluster) GetServiceReplica() *v1.Service + func (c *Cluster) GetSpec() (*spec.Postgresql, error) + func (c *Cluster) GetStatefulSet() *v1beta1.StatefulSet + func (c *Cluster) GetStatus() *spec.ClusterStatus + func (c *Cluster) Lock() + func (c *Cluster) MigrateMasterPod(podName spec.NamespacedName) error + func (c *Cluster) MigrateReplicaPod(podName spec.NamespacedName, fromNodeName string) error + func (c *Cluster) NeedsRepair() (bool, spec.PostgresStatus) + func (c *Cluster) ReceivePodEvent(event spec.PodEvent) + func (c *Cluster) Run(stopCh <-chan struct{}) + func (c *Cluster) Switchover(curMaster *v1.Pod, candidate spec.NamespacedName) error + func (c *Cluster) Sync(newSpec *spec.Postgresql) error + func (c *Cluster) Unlock() + func (c *Cluster) Update(oldSpec, newSpec *spec.Postgresql) error + type Config struct + InfrastructureRoles map[string]spec.PgUser + OpConfig config.Config + PodServiceAccount *v1.ServiceAccount + PodServiceAccountRoleBinding *rbacv1beta1.RoleBinding + RestConfig *rest.Config + type OAuthTokenGetter interface + type PostgresRole string + const Master + const Replica + type SecretOauthTokenGetter struct + OAuthTokenSecretName spec.NamespacedName
Go to main page