github-mirrors/gardener-extension-shoot-fleet-agent
1
0
Fork 0
mirror of https://github.com/ysoftdevs/gardener-extension-shoot-fleet-agent.git synced 2026-04-09 18:33:58 +02:00
Code Issues Packages Projects Releases 1 Wiki Activity

gofmt runned

Browse Source
This commit is contained in:
Jakub Vavřík
2021-01-28 18:26:43 +01:00
parent 879cd4b33d
commit ac4d934c86
7 changed files with 21 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/controller/actuator.go
View File

@@ -54,7 +54,7 @@ func NewActuator(config config.Config) extension.Actuator {
panic(err)
}
fleetClientConfig, _ := clientcmd.BuildConfigFromFlags("", kubeconfigPath)
fleetManager, err := NewManagerForConfig(fleetClientConfig, "clusters")//TODO get from config
fleetManager, err := NewManagerForConfig(fleetClientConfig, "clusters") //TODO get from config
if err != nil {
panic(err)
}
@@ -62,14 +62,14 @@ func NewActuator(config config.Config) extension.Actuator {
return &actuator{
logger: log.Log.WithName(ActuatorName),
serviceConfig: config,
fleetManager: fleetManager,
fleetManager: fleetManager,
}
}
type actuator struct {
client client.Client
config *rest.Config
decoder runtime.Decoder
client client.Client
config *rest.Config
decoder runtime.Decoder
fleetManager *FleetManager
serviceConfig config.Config
@@ -87,7 +87,7 @@ func (a *actuator) Reconcile(ctx context.Context, ex *extensionsv1alpha1.Extensi
}
cfg := &config.Config{}
if ex.Spec.ProviderConfig != nil {//here we parse providerconfig
if ex.Spec.ProviderConfig != nil { //here we parse providerconfig
if _, _, err := a.decoder.Decode(ex.Spec.ProviderConfig.Raw, nil, cfg); err != nil {
return fmt.Errorf("failed to decode provider config: %+v", err)
}
@@ -151,8 +151,8 @@ func (a *actuator) registerClusterInFleetManager(ctx context.Context, namespace
labels["corebundle"] = "true"
labels["region"] = cluster.Shoot.Spec.Region
labels["cluster"] = cluster.Shoot.Name
if a.serviceConfig.FleetAgentConfig.Labels != nil && len(a.serviceConfig.FleetAgentConfig.Labels) > 0 {//adds labels from configuration
for key, value := range a.serviceConfig.Labels{
if a.serviceConfig.FleetAgentConfig.Labels != nil && len(a.serviceConfig.FleetAgentConfig.Labels) > 0 { //adds labels from configuration
for key, value := range a.serviceConfig.Labels {
labels[key] = value
}
}
@@ -201,4 +201,4 @@ func (a *actuator) updateStatus(ctx context.Context, ex *extensionsv1alpha1.Exte
return controller.TryUpdateStatus(ctx, retry.DefaultBackoff, a.client, ex, func() error {
return nil
})
}
}