Fetch the repository succeeded.
package rkenodeconfigserver
import (
"fmt"
"github.com/rancher/kontainer-engine/cluster"
kecerts "github.com/rancher/kontainer-engine/drivers/rke/rkecerts"
"github.com/rancher/rancher/pkg/controllers/management/clusterprovisioner"
"github.com/rancher/rancher/pkg/rkecerts"
"github.com/rancher/rke/pki"
v1 "github.com/rancher/types/apis/core/v1"
v3 "github.com/rancher/types/apis/management.cattle.io/v3"
)
type BundleLookup struct {
engineStore cluster.PersistentStore
}
func NewLookup(namespaces v1.NamespaceInterface, secrets v1.SecretsGetter) *BundleLookup {
return &BundleLookup{
engineStore: clusterprovisioner.NewPersistentStore(namespaces, secrets),
}
}
func (r *BundleLookup) Lookup(cluster *v3.Cluster) (*rkecerts.Bundle, error) {
c, err := r.engineStore.Get(cluster.Name)
if err != nil {
return nil, err
}
certs, ok := c.Metadata["Certs"]
if !ok {
return nil, fmt.Errorf("waiting for certs to be generated for cluster %s", cluster.Name)
}
certMap, err := kecerts.LoadString(certs)
if err != nil {
return nil, err
}
newCertMap := map[string]pki.CertificatePKI{}
for k, v := range certMap {
if v.Config != "" {
v.ConfigPath = pki.GetConfigPath(k)
}
if v.Key != nil {
v.KeyPath = pki.GetKeyPath(k)
}
if v.Certificate != nil {
v.Path = pki.GetCertPath(k)
}
newCertMap[k] = v
}
return rkecerts.NewBundle(newCertMap), nil
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。