4ae2c3a101
This PS makes sure we have linter and unit tests processed. The code has been reformatted to adhere to Go's code formatting conventions. Change-Id: I31f15d6d6c4b9bda7e3837941b6c9c3c3735aea7
135 lines
3.4 KiB
Go
135 lines
3.4 KiB
Go
package mocks
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
v1 "k8s.io/api/apps/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
types "k8s.io/apimachinery/pkg/types"
|
|
watch "k8s.io/apimachinery/pkg/watch"
|
|
appsv1applyconfigurations "k8s.io/client-go/applyconfigurations/apps/v1"
|
|
appsv1 "k8s.io/client-go/kubernetes/typed/apps/v1"
|
|
)
|
|
|
|
type dClient struct{}
|
|
|
|
const (
|
|
SucceedingDaemonsetName = "DAEMONSET_SUCCEED"
|
|
FailingDaemonsetName = "DAEMONSET_FAIL"
|
|
CorrectNamespaceDaemonsetName = "CORRECT_DAEMONSET_NAMESPACE"
|
|
IncorrectNamespaceDaemonsetName = "INCORRECT_DAEMONSET_NAMESPACE"
|
|
CorrectDaemonsetNamespace = "CORRECT_DAEMONSET"
|
|
|
|
FailingMatchLabelsDaemonsetName = "DAEMONSET_INCORRECT_MATCH_LABELS"
|
|
NotReadyMatchLabelsDaemonsetName = "DAEMONSET_NOT_READY_MATCH_LABELS"
|
|
)
|
|
|
|
func (d dClient) Create(
|
|
ctx context.Context,
|
|
daemonSet *v1.DaemonSet,
|
|
opts metav1.CreateOptions,
|
|
) (*v1.DaemonSet, error) {
|
|
return nil, fmt.Errorf("not implemented")
|
|
}
|
|
|
|
func (d dClient) Update(
|
|
ctx context.Context,
|
|
daemonSet *v1.DaemonSet,
|
|
opts metav1.UpdateOptions,
|
|
) (*v1.DaemonSet, error) {
|
|
return nil, fmt.Errorf("not implemented")
|
|
}
|
|
|
|
func (d dClient) UpdateStatus(
|
|
ctx context.Context,
|
|
daemonSet *v1.DaemonSet,
|
|
opts metav1.UpdateOptions,
|
|
) (*v1.DaemonSet, error) {
|
|
return nil, fmt.Errorf("not implemented")
|
|
}
|
|
|
|
func (d dClient) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
|
|
return fmt.Errorf("not implemented")
|
|
}
|
|
|
|
func (d dClient) DeleteCollection(
|
|
ctx context.Context,
|
|
opts metav1.DeleteOptions,
|
|
listOpts metav1.ListOptions,
|
|
) error {
|
|
return fmt.Errorf("not implemented")
|
|
}
|
|
|
|
func (d dClient) Get(
|
|
ctx context.Context,
|
|
name string,
|
|
opts metav1.GetOptions,
|
|
) (*v1.DaemonSet, error) {
|
|
if name == FailingDaemonsetName || name == IncorrectNamespaceDaemonsetName {
|
|
return nil, fmt.Errorf("mock daemonset didn't work")
|
|
}
|
|
|
|
matchLabelName := MockContainerName
|
|
switch name {
|
|
case FailingMatchLabelsDaemonsetName:
|
|
matchLabelName = FailingMatchLabel
|
|
case NotReadyMatchLabelsDaemonsetName:
|
|
matchLabelName = SameHostNotReadyMatchLabel
|
|
}
|
|
|
|
ds := &v1.DaemonSet{
|
|
ObjectMeta: metav1.ObjectMeta{Name: name},
|
|
Spec: v1.DaemonSetSpec{
|
|
Selector: &metav1.LabelSelector{
|
|
MatchLabels: map[string]string{"name": matchLabelName},
|
|
},
|
|
},
|
|
}
|
|
|
|
if name == CorrectNamespaceDaemonsetName {
|
|
ds.ObjectMeta.Namespace = CorrectDaemonsetNamespace
|
|
}
|
|
|
|
return ds, nil
|
|
}
|
|
|
|
func (d dClient) List(ctx context.Context, opts metav1.ListOptions) (*v1.DaemonSetList, error) {
|
|
return nil, fmt.Errorf("not implemented")
|
|
}
|
|
|
|
func (d dClient) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) {
|
|
return nil, fmt.Errorf("not implemented")
|
|
}
|
|
|
|
func (d dClient) Patch(
|
|
ctx context.Context,
|
|
name string,
|
|
pt types.PatchType,
|
|
data []byte,
|
|
opts metav1.PatchOptions,
|
|
subresources ...string,
|
|
) (result *v1.DaemonSet, err error) {
|
|
return nil, fmt.Errorf("not implemented")
|
|
}
|
|
|
|
func (d dClient) Apply(
|
|
ctx context.Context,
|
|
daemonSet *appsv1applyconfigurations.DaemonSetApplyConfiguration,
|
|
opts metav1.ApplyOptions,
|
|
) (result *v1.DaemonSet, err error) {
|
|
return nil, fmt.Errorf("not implemented")
|
|
}
|
|
|
|
func (d dClient) ApplyStatus(
|
|
ctx context.Context,
|
|
daemonSet *appsv1applyconfigurations.DaemonSetApplyConfiguration,
|
|
opts metav1.ApplyOptions,
|
|
) (result *v1.DaemonSet, err error) {
|
|
return nil, fmt.Errorf("not implemented")
|
|
}
|
|
|
|
func NewDSClient() appsv1.DaemonSetInterface {
|
|
return dClient{}
|
|
}
|