in controllers/etcd_plane.go [29:55]
func NewEtcdPlane(ctx context.Context, client client.Client, cluster *clusterv1.Cluster, ec *etcdv1.EtcdadmCluster, ownedMachines collections.Machines) (*EtcdPlane, error) {
infraObjects, err := getInfraResources(ctx, client, ownedMachines)
if err != nil {
return nil, err
}
etcdadmConfigs, err := getEtcdadmConfigs(ctx, client, ownedMachines)
if err != nil {
return nil, err
}
patchHelpers := map[string]*patch.Helper{}
for _, machine := range ownedMachines {
patchHelper, err := patch.NewHelper(machine, client)
if err != nil {
return nil, errors.Wrapf(err, "failed to create patch helper for machine %s", machine.Name)
}
patchHelpers[machine.Name] = patchHelper
}
return &EtcdPlane{
EC: ec,
Cluster: cluster,
Machines: ownedMachines,
machinesPatchHelpers: patchHelpers,
infraResources: infraObjects,
etcdadmConfigs: etcdadmConfigs,
}, nil
}