45 lines
790 B
Go
45 lines
790 B
Go
package config
|
|
|
|
import (
|
|
"context"
|
|
"sync"
|
|
|
|
corev1 "k8s.io/api/core/v1"
|
|
"k8s.io/apimachinery/pkg/types"
|
|
"sigs.k8s.io/controller-runtime/pkg/client"
|
|
)
|
|
|
|
type ConfigLoaderType struct {
|
|
Client client.Client
|
|
|
|
mu sync.Mutex
|
|
loaded bool
|
|
config *corev1.ConfigMap
|
|
err error
|
|
}
|
|
|
|
func NewConfigLoader(k8sClient client.Client) *ConfigLoaderType {
|
|
return &ConfigLoaderType{Client: k8sClient}
|
|
}
|
|
|
|
func (c *ConfigLoaderType) GetConfig(ctx context.Context, name string) (*corev1.ConfigMap, error) {
|
|
c.mu.Lock()
|
|
defer c.mu.Unlock()
|
|
|
|
if c.loaded {
|
|
return c.config, c.err
|
|
}
|
|
|
|
cm := &corev1.ConfigMap{}
|
|
err := c.Client.Get(ctx, types.NamespacedName{
|
|
Name: name,
|
|
Namespace: "unifi-network-operator-system",
|
|
}, cm)
|
|
|
|
c.loaded = true
|
|
c.config = cm
|
|
c.err = err
|
|
|
|
return cm, err
|
|
}
|