cluster

type Cluster struct {
	acidv1.Postgresql
	Config

	KubeClient k8sutil.KubernetesClient //TODO: move clients to the better place?

	ConnectionPooler map[PostgresRole]*ConnectionPoolerObjects
	EBSVolumes       map[string]volumes.VolumeProperties
	VolumeResizer    volumes.VolumeResizer
	// contains filtered or unexported fields
}

type ClusterStatus struct {
	Team                string
	Cluster             string
	Namespace           string
	MasterService       *v1.Service
	ReplicaService      *v1.Service
	MasterEndpoint      *v1.Endpoints
	ReplicaEndpoint     *v1.Endpoints
	StatefulSet         *appsv1.StatefulSet
	PodDisruptionBudget *policyv1.PodDisruptionBudget

	CurrentProcess Process
	Worker         uint32
	Status         acidv1.PostgresStatus
	Spec           acidv1.PostgresSpec
	Error          error
}

type Config struct {
	OpConfig                     config.Config
	RestConfig                   *rest.Config
	PgTeamMap                    *pgteams.PostgresTeamMap
	InfrastructureRoles          map[string]spec.PgUser // inherited from the controller
	PodServiceAccount            *v1.ServiceAccount
	PodServiceAccountRoleBinding *rbacv1.RoleBinding
}

type ConnectionPoolerObjects struct {
	Deployment  *appsv1.Deployment
	Service     *v1.Service
	Name        string
	ClusterName string
	Namespace   string
	Role        PostgresRole
	// It could happen that a connection pooler was enabled, but the operator
	// was not able to properly process a corresponding event or was restarted.
	// In this case we will miss missing/require situation and a lookup function
	// will not be installed. To avoid synchronizing it all the time to prevent
	// this, we can remember the result in memory at least until the next
	// restart.
	LookupFunction bool
}

type InstallFunction func(schema string, user string) error

type OAuthTokenGetter interface {
	// contains filtered or unexported methods
}

type PodEvent struct {
	ResourceVersion string
	PodName         types.NamespacedName
	PrevPod         *v1.Pod
	CurPod          *v1.Pod
	EventType       PodEventType
}

type PodEventType string

type PostgresRole string

type Process struct {
	Name      string
	StartTime time.Time
}

type SecretOauthTokenGetter struct {
	OAuthTokenSecretName spec.NamespacedName
	// contains filtered or unexported fields
}

type SyncReason []string

type TemplateParams map[string]interface{}

type WorkerStatus struct {
	CurrentCluster types.NamespacedName
	CurrentProcess Process
}