in pkg/authenticator/target_cluster_client.go [70:95]
func (tcc *targetClusterClient) Initialize(ctx context.Context, clusterName string) error {
kubeconfig, err := tcc.getKubeconfig(ctx, clusterName)
if err != nil {
return err
}
tcc.targetSelf = false
if kubeconfig == nil {
tcc.targetSelf = true
tcc.clientConfig = clientcmd.NewDefaultClientConfig(clientcmdapi.Config{}, &clientcmd.ConfigOverrides{})
return nil
}
clientConfig, err := clientcmd.NewClientConfigFromBytes(kubeconfig)
if err != nil {
return err
}
rawConfig, err := clientConfig.RawConfig()
if err != nil {
return err
}
tcc.clientConfig = clientcmd.NewDefaultClientConfig(rawConfig, &clientcmd.ConfigOverrides{})
return nil
}