Skip to content

Commit c3ba0cd

Browse files
committed
Address initial reviews
On-behalf-of: @SAP [email protected] Signed-off-by: Marko Mudrinić <[email protected]>
1 parent e103892 commit c3ba0cd

File tree

5 files changed

+11
-10
lines changed

5 files changed

+11
-10
lines changed

cmd/virtual-workspaces/command/cmd.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,6 @@ import (
4444
kcpfeatures "github.com/kcp-dev/kcp/pkg/features"
4545
"github.com/kcp-dev/kcp/pkg/server/bootstrap"
4646
virtualrootapiserver "github.com/kcp-dev/kcp/pkg/virtual/framework/rootapiserver"
47-
virtualoptions "github.com/kcp-dev/kcp/pkg/virtual/options"
4847
kcpclientset "github.com/kcp-dev/kcp/sdk/client/clientset/versioned/cluster"
4948
kcpinformers "github.com/kcp-dev/kcp/sdk/client/informers/externalversions"
5049
)
@@ -179,8 +178,7 @@ func Run(ctx context.Context, o *options.Options) error {
179178
return err
180179
}
181180

182-
admissionOptions := virtualoptions.NewAdmission()
183-
if err := admissionOptions.ApplyTo(&recommendedConfig.Config, func() []virtualrootapiserver.NamedVirtualWorkspace {
181+
if err := o.VirtualWorkspaceAdmission.ApplyTo(&recommendedConfig.Config, func() []virtualrootapiserver.NamedVirtualWorkspace {
184182
return rootAPIServerConfig.Extra.VirtualWorkspaces
185183
}); err != nil {
186184
return err

cmd/virtual-workspaces/options/options.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,8 @@ type Options struct {
5555

5656
Logs *logs.Options
5757

58-
CoreVirtualWorkspaces corevwoptions.Options
58+
CoreVirtualWorkspaces corevwoptions.Options
59+
VirtualWorkspaceAdmission corevwoptions.Admission
5960

6061
ProfilerAddress string
6162
}
@@ -74,8 +75,9 @@ func NewOptions() *Options {
7475
Audit: *genericapiserveroptions.NewAuditOptions(),
7576
Logs: logs.NewOptions(),
7677

77-
CoreVirtualWorkspaces: *corevwoptions.NewOptions(),
78-
ProfilerAddress: "",
78+
CoreVirtualWorkspaces: *corevwoptions.NewOptions(),
79+
VirtualWorkspaceAdmission: *corevwoptions.NewAdmission(),
80+
ProfilerAddress: "",
7981
}
8082

8183
opts.SecureServing.ServerCert.CertKey.CertFile = filepath.Join(".", ".kcp", "apiserver.crt")

pkg/virtual/framework/admission/mutatingwebhook/plugin.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ import (
3131
)
3232

3333
const (
34-
PluginName = "apis.kcp.io/VWMutatingWebhook"
34+
PluginName = "apis.kcp.io/VirtualWorkspaceMutatingWebhook"
3535
)
3636

3737
type Plugin struct {

pkg/virtual/framework/admission/validatingwebhook/plugin.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ import (
3131
)
3232

3333
const (
34-
PluginName = "apis.kcp.io/qqqqqq"
34+
PluginName = "apis.kcp.io/VirtualWorkspaceValidatingWebhook"
3535
)
3636

3737
type Plugin struct {

pkg/virtual/options/admission.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ import (
2222
"k8s.io/apimachinery/pkg/runtime"
2323
utilruntime "k8s.io/apimachinery/pkg/util/runtime"
2424
"k8s.io/apiserver/pkg/admission"
25+
admissionmetrics "k8s.io/apiserver/pkg/admission/metrics"
2526
apiserverapi "k8s.io/apiserver/pkg/apis/apiserver"
2627
apiserverapiv1 "k8s.io/apiserver/pkg/apis/apiserver/v1"
2728
apiserverapiv1alpha1 "k8s.io/apiserver/pkg/apis/apiserver/v1alpha1"
@@ -73,7 +74,7 @@ func (s *Admission) ApplyTo(config *genericapiserver.Config, virtualWorkspaces f
7374
return err
7475
}
7576

76-
// config.AdmissionControl = admissionmetrics.WithStepMetrics(admissionChain)
77-
config.AdmissionControl = admissionChain
77+
config.AdmissionControl = admissionmetrics.WithStepMetrics(admissionChain)
78+
7879
return nil
7980
}

0 commit comments

Comments
 (0)