mirror of
https://github.com/kubesphere/kubekey.git
synced 2025-12-28 20:22:45 +00:00
85 lines
3.1 KiB
Go
85 lines
3.1 KiB
Go
/*
|
|
Copyright 2022 The KubeSphere Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package kubernetes
|
|
|
|
import (
|
|
"text/template"
|
|
|
|
"github.com/kubesphere/kubekey/pkg/clients/ssh"
|
|
"github.com/kubesphere/kubekey/pkg/scope"
|
|
"github.com/kubesphere/kubekey/pkg/service/operation"
|
|
"github.com/kubesphere/kubekey/pkg/service/operation/file"
|
|
)
|
|
|
|
// Service holds a collection of interfaces.
|
|
// The interfaces are broken down like this to group functions together.
|
|
type Service struct {
|
|
sshClient ssh.Interface
|
|
scope scope.KKInstanceScope
|
|
instanceScope *scope.InstanceScope
|
|
|
|
templateFactory func(sshClient ssh.Interface, template *template.Template, data file.Data, dst string) (operation.Template, error)
|
|
kubeadmFactory func(sshClient ssh.Interface, version, arch string) (operation.Binary, error)
|
|
kubeletFactory func(sshClient ssh.Interface, version, arch string) (operation.Binary, error)
|
|
kubecniFactory func(sshClient ssh.Interface, version, arch string) (operation.Binary, error)
|
|
kubectlFactory func(sshClient ssh.Interface, version, arch string) (operation.Binary, error)
|
|
}
|
|
|
|
// NewService returns a new service given the remote instance.
|
|
func NewService(sshClient ssh.Interface, scope scope.KKInstanceScope, instanceScope *scope.InstanceScope) *Service {
|
|
return &Service{
|
|
sshClient: sshClient,
|
|
scope: scope,
|
|
instanceScope: instanceScope,
|
|
}
|
|
}
|
|
|
|
func (s *Service) getTemplateService(template *template.Template, data file.Data, dst string) (operation.Template, error) {
|
|
if s.templateFactory != nil {
|
|
return s.templateFactory(s.sshClient, template, data, dst)
|
|
}
|
|
return file.NewTemplate(s.sshClient, s.scope.RootFs(), template, data, dst)
|
|
}
|
|
|
|
func (s *Service) getKubeadmService(version, arch string) (operation.Binary, error) {
|
|
if s.kubeadmFactory != nil {
|
|
return s.kubeadmFactory(s.sshClient, version, arch)
|
|
}
|
|
return file.NewKubeadm(s.sshClient, s.scope.RootFs(), version, arch)
|
|
}
|
|
|
|
func (s *Service) getKubeletService(version, arch string) (operation.Binary, error) {
|
|
if s.kubeletFactory != nil {
|
|
return s.kubeletFactory(s.sshClient, version, arch)
|
|
}
|
|
return file.NewKubelet(s.sshClient, s.scope.RootFs(), version, arch)
|
|
}
|
|
|
|
func (s *Service) getKubecniService(version, arch string) (operation.Binary, error) {
|
|
if s.kubecniFactory != nil {
|
|
return s.kubecniFactory(s.sshClient, version, arch)
|
|
}
|
|
return file.NewKubecni(s.sshClient, s.scope.RootFs(), version, arch)
|
|
}
|
|
|
|
func (s *Service) getKubectlService(version, arch string) (operation.Binary, error) {
|
|
if s.kubectlFactory != nil {
|
|
return s.kubectlFactory(s.sshClient, version, arch)
|
|
}
|
|
return file.NewKubectl(s.sshClient, s.scope.RootFs(), version, arch)
|
|
}
|