Versions in this module Expand all Collapse all v1 v1.1.0 Feb 20, 2019 Changes in this version + type ClusterStatus struct + Cluster string + CurrentProcess Process + Error error + MasterEndpoint *v1.Endpoints + MasterService *v1.Service + PodDisruptionBudget *policybeta1.PodDisruptionBudget + ReplicaEndpoint *v1.Endpoints + ReplicaService *v1.Service + Spec acidv1.PostgresSpec + StatefulSet *v1beta1.StatefulSet + Status acidv1.PostgresStatus + Team string + Worker uint32 + type PodEvent struct + CurPod *v1.Pod + EventType PodEventType + PodName types.NamespacedName + PrevPod *v1.Pod + ResourceVersion string + type PodEventType string + const PodEventAdd + const PodEventDelete + const PodEventUpdate + type Process struct + Name string + StartTime time.Time + type WorkerStatus struct + CurrentCluster types.NamespacedName + CurrentProcess Process 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