mirror of https://github.com/helm/helm
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
137 lines
4.2 KiB
137 lines
4.2 KiB
/*
|
|
Copyright The Helm 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 fake
|
|
|
|
import (
|
|
"io"
|
|
"strings"
|
|
"time"
|
|
|
|
v1 "k8s.io/api/core/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/cli-runtime/pkg/resource"
|
|
|
|
"helm.sh/helm/v3/pkg/kube"
|
|
)
|
|
|
|
// PrintingKubeClient implements KubeClient, but simply prints the reader to
|
|
// the given output.
|
|
type PrintingKubeClient struct {
|
|
Out io.Writer
|
|
}
|
|
|
|
// IsReachable checks if the cluster is reachable
|
|
func (p *PrintingKubeClient) IsReachable() error {
|
|
return nil
|
|
}
|
|
|
|
// Create prints the values of what would be created with a real KubeClient.
|
|
func (p *PrintingKubeClient) Create(resources kube.ResourceList) (*kube.Result, error) {
|
|
_, err := io.Copy(p.Out, bufferize(resources))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &kube.Result{Created: resources}, nil
|
|
}
|
|
|
|
func (p *PrintingKubeClient) Get(resources kube.ResourceList, _ bool) (map[string][]runtime.Object, error) {
|
|
_, err := io.Copy(p.Out, bufferize(resources))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return make(map[string][]runtime.Object), nil
|
|
}
|
|
|
|
func (p *PrintingKubeClient) Wait(resources kube.ResourceList, _ time.Duration) error {
|
|
_, err := io.Copy(p.Out, bufferize(resources))
|
|
return err
|
|
}
|
|
|
|
func (p *PrintingKubeClient) WaitWithJobs(resources kube.ResourceList, _ time.Duration) error {
|
|
_, err := io.Copy(p.Out, bufferize(resources))
|
|
return err
|
|
}
|
|
|
|
func (p *PrintingKubeClient) WaitForDelete(resources kube.ResourceList, _ time.Duration) error {
|
|
_, err := io.Copy(p.Out, bufferize(resources))
|
|
return err
|
|
}
|
|
|
|
// Delete implements KubeClient delete.
|
|
//
|
|
// It only prints out the content to be deleted.
|
|
func (p *PrintingKubeClient) Delete(resources kube.ResourceList) (*kube.Result, []error) {
|
|
_, err := io.Copy(p.Out, bufferize(resources))
|
|
if err != nil {
|
|
return nil, []error{err}
|
|
}
|
|
return &kube.Result{Deleted: resources}, nil
|
|
}
|
|
|
|
// WatchUntilReady implements KubeClient WatchUntilReady.
|
|
func (p *PrintingKubeClient) WatchUntilReady(resources kube.ResourceList, _ time.Duration) error {
|
|
_, err := io.Copy(p.Out, bufferize(resources))
|
|
return err
|
|
}
|
|
|
|
// Update implements KubeClient Update.
|
|
func (p *PrintingKubeClient) Update(_, modified kube.ResourceList, _ bool) (*kube.Result, error) {
|
|
_, err := io.Copy(p.Out, bufferize(modified))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
// TODO: This doesn't completely mock out have some that get created,
|
|
// updated, and deleted. I don't think these are used in any unit tests, but
|
|
// we may want to refactor a way to handle future tests
|
|
return &kube.Result{Updated: modified}, nil
|
|
}
|
|
|
|
// Build implements KubeClient Build.
|
|
func (p *PrintingKubeClient) Build(_ io.Reader, _ bool) (kube.ResourceList, error) {
|
|
return []*resource.Info{}, nil
|
|
}
|
|
|
|
// BuildTable implements KubeClient BuildTable.
|
|
func (p *PrintingKubeClient) BuildTable(_ io.Reader, _ bool) (kube.ResourceList, error) {
|
|
return []*resource.Info{}, nil
|
|
}
|
|
|
|
// WaitAndGetCompletedPodPhase implements KubeClient WaitAndGetCompletedPodPhase.
|
|
func (p *PrintingKubeClient) WaitAndGetCompletedPodPhase(_ string, _ time.Duration) (v1.PodPhase, error) {
|
|
return v1.PodSucceeded, nil
|
|
}
|
|
|
|
// DeleteWithPropagationPolicy implements KubeClient delete.
|
|
//
|
|
// It only prints out the content to be deleted.
|
|
func (p *PrintingKubeClient) DeleteWithPropagationPolicy(resources kube.ResourceList, _ metav1.DeletionPropagation) (*kube.Result, []error) {
|
|
_, err := io.Copy(p.Out, bufferize(resources))
|
|
if err != nil {
|
|
return nil, []error{err}
|
|
}
|
|
return &kube.Result{Deleted: resources}, nil
|
|
}
|
|
|
|
func bufferize(resources kube.ResourceList) io.Reader {
|
|
var builder strings.Builder
|
|
for _, info := range resources {
|
|
builder.WriteString(info.String() + "\n")
|
|
}
|
|
return strings.NewReader(builder.String())
|
|
}
|