make cluster resources private
This commit is contained in:
		
							parent
							
								
									101dc06acb
								
							
						
					
					
						commit
						655f6dcadb
					
				|  | @ -41,7 +41,7 @@ type Config struct { | ||||||
| 	OpConfig       *config.Config | 	OpConfig       *config.Config | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| type KubeResources struct { | type kubeResources struct { | ||||||
| 	Service     *v1.Service | 	Service     *v1.Service | ||||||
| 	Endpoint    *v1.Endpoints | 	Endpoint    *v1.Endpoints | ||||||
| 	Secrets     map[types.UID]*v1.Secret | 	Secrets     map[types.UID]*v1.Secret | ||||||
|  | @ -51,7 +51,7 @@ type KubeResources struct { | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| type Cluster struct { | type Cluster struct { | ||||||
| 	KubeResources | 	kubeResources | ||||||
| 	spec.Postgresql | 	spec.Postgresql | ||||||
| 	Config | 	Config | ||||||
| 	logger         *logrus.Entry | 	logger         *logrus.Entry | ||||||
|  | @ -64,7 +64,7 @@ type Cluster struct { | ||||||
| 
 | 
 | ||||||
| func New(cfg Config, pgSpec spec.Postgresql, logger *logrus.Logger) *Cluster { | func New(cfg Config, pgSpec spec.Postgresql, logger *logrus.Logger) *Cluster { | ||||||
| 	lg := logger.WithField("pkg", "cluster").WithField("cluster-name", pgSpec.Metadata.Name) | 	lg := logger.WithField("pkg", "cluster").WithField("cluster-name", pgSpec.Metadata.Name) | ||||||
| 	kubeResources := KubeResources{Secrets: make(map[types.UID]*v1.Secret)} | 	kubeResources := kubeResources{Secrets: make(map[types.UID]*v1.Secret)} | ||||||
| 
 | 
 | ||||||
| 	cluster := &Cluster{ | 	cluster := &Cluster{ | ||||||
| 		Config:         cfg, | 		Config:         cfg, | ||||||
|  | @ -73,7 +73,7 @@ func New(cfg Config, pgSpec spec.Postgresql, logger *logrus.Logger) *Cluster { | ||||||
| 		pgUsers:        make(map[string]spec.PgUser), | 		pgUsers:        make(map[string]spec.PgUser), | ||||||
| 		podEvents:      make(chan spec.PodEvent), | 		podEvents:      make(chan spec.PodEvent), | ||||||
| 		podSubscribers: make(map[spec.PodName]chan spec.PodEvent), | 		podSubscribers: make(map[spec.PodName]chan spec.PodEvent), | ||||||
| 		KubeResources:  kubeResources, | 		kubeResources:  kubeResources, | ||||||
| 	} | 	} | ||||||
| 
 | 
 | ||||||
| 	return cluster | 	return cluster | ||||||
|  |  | ||||||
		Loading…
	
		Reference in New Issue