Versions in this module Expand all Collapse all v1 v1.0.0 Aug 8, 2018 Changes in this version + const PGSyncAlterSet + const PGSyncUserAdd + const PGsyncUserAlter + func GetOperatorNamespace() string + type CloneDescription struct + ClusterName string + EndTimestamp string + UID string + type ClusterEvent struct + EventTime time.Time + EventType EventType + NewSpec *Postgresql + OldSpec *Postgresql + UID types.UID + WorkerID uint32 + type ClusterStatus struct + Cluster string + CurrentProcess Process + Error error + MasterEndpoint *v1.Endpoints + MasterService *v1.Service + PodDisruptionBudget *policyv1beta1.PodDisruptionBudget + ReplicaEndpoint *v1.Endpoints + ReplicaService *v1.Service + Spec PostgresSpec + StatefulSet *v1beta1.StatefulSet + Status PostgresStatus + Team string + Worker uint32 + type ControllerConfig struct + CRDReadyWaitInterval time.Duration + CRDReadyWaitTimeout time.Duration + ConfigMapName NamespacedName + InfrastructureRoles map[string]PgUser + Namespace string + NoDatabaseAccess bool + NoTeamsAPI bool + RestConfig *rest.Config + type ControllerStatus struct + Clusters int + LastSyncTime int64 + WorkerQueueSize map[int]int + type Diff struct + Diff []string + EventTime time.Time + ProcessTime time.Time + type Duration time.Duration + func (d *Duration) UnmarshalJSON(b []byte) error + type EventType string + const EventAdd + const EventDelete + const EventRepair + const EventSync + const EventUpdate + type LogEntry struct + ClusterName *NamespacedName + Level logrus.Level + Message string + Time time.Time + Worker *uint32 + type MaintenanceWindow struct + EndTime time.Time + Everyday bool + StartTime time.Time + Weekday time.Weekday + func (m *MaintenanceWindow) MarshalJSON() ([]byte, error) + func (m *MaintenanceWindow) UnmarshalJSON(data []byte) error + type NamespacedName types.NamespacedName + func (n *NamespacedName) Decode(value string) error + func (n *NamespacedName) DecodeWorker(value, operatorNamespace string) error + func (n *NamespacedName) UnmarshalJSON(data []byte) error + func (n NamespacedName) MarshalJSON() ([]byte, error) + func (n NamespacedName) String() string + type Patroni struct + InitDB map[string]string + LoopWait uint32 + MaximumLagOnFailover float32 + PgHba []string + RetryTimeout uint32 + TTL uint32 + type PgSyncUserRequest struct + Kind syncUserOperation + User PgUser + type PgUser struct + Flags []string + MemberOf []string + Name string + Origin RoleOrigin + Parameters map[string]string + Password string + type PgUserMap map[string]PgUser + type PodEvent struct + CurPod *v1.Pod + EventType EventType + PodName NamespacedName + PrevPod *v1.Pod + ResourceVersion string + type PostgresSpec struct + AllowedSourceRanges []string + Clone CloneDescription + ClusterName string + Databases map[string]string + DockerImage string + EnableMasterLoadBalancer *bool + EnableReplicaLoadBalancer *bool + MaintenanceWindows []MaintenanceWindow + NumberOfInstances int32 + PodPriorityClassName string + ReplicaLoadBalancer *bool + Sidecars []Sidecar + TeamID string + Tolerations []v1.Toleration + UseLoadBalancer *bool + Users map[string]UserFlags + type PostgresStatus string + const ClusterStatusAddFailed + const ClusterStatusCreating + const ClusterStatusInvalid + const ClusterStatusRunning + const ClusterStatusSyncFailed + const ClusterStatusUnknown + const ClusterStatusUpdateFailed + const ClusterStatusUpdating + func (status PostgresStatus) String() string + func (status PostgresStatus) Success() bool + type Postgresql struct + Error error + Spec PostgresSpec + Status PostgresStatus + func (p *Postgresql) Clone() *Postgresql + func (p *Postgresql) DeepCopy() *Postgresql + func (p *Postgresql) DeepCopyInto(out *Postgresql) + func (p *Postgresql) DeepCopyObject() runtime.Object + func (p *Postgresql) UnmarshalJSON(data []byte) error + type PostgresqlList struct + Items []Postgresql + func (pl *PostgresqlList) DeepCopy() *PostgresqlList + func (pl *PostgresqlList) DeepCopyInto(out *PostgresqlList) + func (pl *PostgresqlList) DeepCopyObject() runtime.Object + func (pl *PostgresqlList) UnmarshalJSON(data []byte) error + type PostgresqlParam struct + Parameters map[string]string + PgVersion string + type Process struct + Name string + StartTime time.Time + type QueueDump struct + Keys []string + List []interface{} + type ResourceDescription struct + CPU string + Memory string + type Resources struct + ResourceLimits ResourceDescription + ResourceRequest ResourceDescription + type RoleOrigin int + const RoleOriginInfrastructure + const RoleOriginManifest + const RoleOriginSystem + const RoleOriginTeamsAPI + const RoleOriginUnknown + func (r RoleOrigin) String() string + type Sidecar struct + DockerImage string + Env []v1.EnvVar + Name string + Ports []v1.ContainerPort + type UserFlags []string + type UserSyncer interface + ExecuteSyncRequests func(req []PgSyncUserRequest, db *sql.DB) error + ProduceSyncRequests func(dbUsers PgUserMap, newUsers PgUserMap) (req []PgSyncUserRequest) + type Volume struct + Size string + StorageClass string + type WorkerStatus struct + CurrentCluster NamespacedName + CurrentProcess Process