corrected breaking changes

e2e/test_plugin/syncers/interceptor.go

@@ -43,10 +43,9 @@ func (d DummyInterceptor) Name() string {
 	return "testinterceptor"
 }
 
-func (d DummyInterceptor) InterceptedRequests() []v2.Interceptor {
-	return []v2.Interceptor{
+func (d DummyInterceptor) InterceptionRules() []v2.InterceptorRule {
+	return []v2.InterceptorRule{
 		{
-			HandlerName:   "testhandler",
 			APIGroups:     []string{"*"},
 			Resources:     []string{"pods"},
 			ResourceNames: []string{"*"},

plugin/manager.go

@@ -53,7 +53,7 @@ type manager struct {
 	syncers []syncertypes.Base
 
 	interceptorsHandlers map[string]http.Handler
-	interceptors         map[string][]Interceptor
+	interceptors         []Interceptor
 	interceptorsPort     int
 
 	proConfig v2.InitConfigPro
@@ -202,7 +202,7 @@ func (m *manager) Register(syncer syncertypes.Base) error {
 			return fmt.Errorf("could not add the interceptor %s because its name is already in use", int.Name())
 		}
 		m.interceptorsHandlers[int.Name()] = int
-		m.interceptors[int.Name()] = append(m.interceptors[int.Name()], int)
+		m.interceptors = append(m.interceptors, int)
 	} else {
 		m.syncers = append(m.syncers, syncer)
 	}

plugin/server.go

@@ -21,7 +21,7 @@ type server interface {
 	Serve()
 
 	// SetReady signals the plugin server the plugin is ready to start
-	SetReady(hooks map[types.VersionKindType][]ClientHook, interceptors map[string][]Interceptor, port int)
+	SetReady(hooks map[types.VersionKindType][]ClientHook, interceptors []Interceptor, port int)
 
 	// Initialized retrieves the initialize request
 	Initialized() <-chan *pluginv2.Initialize_Request
@@ -44,7 +44,7 @@ type pluginServer struct {
 	pluginv2.UnimplementedPluginServer
 
 	hooks            map[types.VersionKindType][]ClientHook
-	interceptors     map[string][]Interceptor
+	interceptors     []Interceptor
 	interceptorsPort int
 
 	initialized chan *pluginv2.Initialize_Request
@@ -90,7 +90,7 @@ func (p *pluginServer) IsLeader() <-chan struct{} {
 	return p.isLeader
 }
 
-func (p *pluginServer) SetReady(hooks map[types.VersionKindType][]ClientHook, interceptors map[string][]Interceptor, port int) {
+func (p *pluginServer) SetReady(hooks map[types.VersionKindType][]ClientHook, interceptors []Interceptor, port int) {
 	p.hooks = hooks
 	p.interceptors = interceptors
 	p.interceptorsPort = port
@@ -271,12 +271,13 @@ func (p *pluginServer) getClientHooks() ([]*v2.ClientHook, error) {
 	return registeredHooks, nil
 }
 
-func (p *pluginServer) getInterceptorConfig() map[string]v2.Interceptor {
+func (p *pluginServer) getInterceptorConfig() map[string][]v2.InterceptorRule {
+	res := make(map[string][]v2.InterceptorRule)
 	for _, interceptor := range p.interceptors {
-		interceptorConfig.Interceptors = append(interceptorConfig.Interceptors, interceptor.InterceptedRequests()...)
+		res[interceptor.Name()] = interceptor.InterceptionRules()
 	}
 
-	return interceptorConfig
+	return res
 }
 
 var _ plugin.Plugin = &pluginServer{}

plugin/types.go

@@ -65,8 +65,8 @@ type Interceptor interface {
 	// Handler is the handler that will handle the requests delegated by the syncer
 	http.Handler
 
-	// InterceptedRequests returns an rbac style struct which defines what to intercept
-	InterceptedRequests() []v2.Interceptor
+	// InterceptionRules returns an rbac style struct which defines what to intercept
+	InterceptionRules() []v2.InterceptorRule
 }
 
 type MutateCreateVirtual interface {