From 784cb3f86d61176aec7d56782c9b23d2fac99828 Mon Sep 17 00:00:00 2001 From: Mostafa Moradian Date: Sat, 28 Dec 2024 00:57:30 +0100 Subject: [PATCH] Remove compatibility policy --- api/api_test.go | 21 +++++++++------------ api/healthcheck_test.go | 7 +++---- network/proxy_test.go | 30 ++++++++++++------------------ network/server_test.go | 5 ++--- plugin/plugin_registry_test.go | 10 ++++------ 5 files changed, 30 insertions(+), 43 deletions(-) diff --git a/api/api_test.go b/api/api_test.go index 378030da..5bee86d1 100644 --- a/api/api_test.go +++ b/api/api_test.go @@ -137,10 +137,9 @@ func TestGetPlugins(t *testing.T) { pluginRegistry := plugin.NewRegistry( context.Background(), plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: zerolog.Logger{}, - DevMode: true, + ActRegistry: actRegistry, + Logger: zerolog.Logger{}, + DevMode: true, }, ) pluginRegistry.Add(&plugin.Plugin{ @@ -192,10 +191,9 @@ func TestGetPluginsWithEmptyPluginRegistry(t *testing.T) { pluginRegistry := plugin.NewRegistry( context.Background(), plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: zerolog.Logger{}, - DevMode: true, + ActRegistry: actRegistry, + Logger: zerolog.Logger{}, + DevMode: true, }, ) @@ -332,10 +330,9 @@ func TestGetServers(t *testing.T) { pluginRegistry := plugin.NewRegistry( context.Background(), plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: zerolog.Logger{}, - DevMode: true, + ActRegistry: actRegistry, + Logger: zerolog.Logger{}, + DevMode: true, }, ) diff --git a/api/healthcheck_test.go b/api/healthcheck_test.go index d304b14f..024f657a 100644 --- a/api/healthcheck_test.go +++ b/api/healthcheck_test.go @@ -57,10 +57,9 @@ func Test_Healthchecker(t *testing.T) { pluginRegistry := plugin.NewRegistry( context.Background(), plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: zerolog.Logger{}, - DevMode: true, + ActRegistry: actRegistry, + Logger: zerolog.Logger{}, + DevMode: true, }, ) diff --git a/network/proxy_test.go b/network/proxy_test.go index 4c205f80..fdb3e900 100644 --- a/network/proxy_test.go +++ b/network/proxy_test.go @@ -67,9 +67,8 @@ func TestNewProxy(t *testing.T) { PluginRegistry: plugin.NewRegistry( context.Background(), plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: logger, + ActRegistry: actRegistry, + Logger: logger, }, ), HealthCheckPeriod: config.DefaultHealthCheckPeriod, @@ -124,9 +123,8 @@ func BenchmarkNewProxy(b *testing.B) { PluginRegistry: plugin.NewRegistry( context.Background(), plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: logger, + ActRegistry: actRegistry, + Logger: logger, }, ), HealthCheckPeriod: config.DefaultHealthCheckPeriod, @@ -182,9 +180,8 @@ func BenchmarkProxyConnectDisconnect(b *testing.B) { PluginRegistry: plugin.NewRegistry( context.Background(), plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: logger, + ActRegistry: actRegistry, + Logger: logger, }, ), HealthCheckPeriod: config.DefaultHealthCheckPeriod, @@ -248,9 +245,8 @@ func BenchmarkProxyPassThrough(b *testing.B) { PluginRegistry: plugin.NewRegistry( context.Background(), plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: logger, + ActRegistry: actRegistry, + Logger: logger, }, ), HealthCheckPeriod: config.DefaultHealthCheckPeriod, @@ -319,9 +315,8 @@ func BenchmarkProxyIsHealthyAndIsExhausted(b *testing.B) { PluginRegistry: plugin.NewRegistry( context.Background(), plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: logger, + ActRegistry: actRegistry, + Logger: logger, }, ), HealthCheckPeriod: config.DefaultHealthCheckPeriod, @@ -388,9 +383,8 @@ func BenchmarkProxyAvailableAndBusyConnectionsString(b *testing.B) { PluginRegistry: plugin.NewRegistry( context.Background(), plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: logger, + ActRegistry: actRegistry, + Logger: logger, }, ), HealthCheckPeriod: config.DefaultHealthCheckPeriod, diff --git a/network/server_test.go b/network/server_test.go index fcb65de4..7ccf1c4d 100644 --- a/network/server_test.go +++ b/network/server_test.go @@ -54,9 +54,8 @@ func TestRunServer(t *testing.T) { pluginRegistry := plugin.NewRegistry( ctx, plugin.Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: logger, + ActRegistry: actRegistry, + Logger: logger, }) pluginRegistry.AddHook(v1.HookName_HOOK_NAME_ON_TRAFFIC_FROM_CLIENT, 1, onIncomingTraffic) diff --git a/plugin/plugin_registry_test.go b/plugin/plugin_registry_test.go index 67996b60..d4e3fbd3 100644 --- a/plugin/plugin_registry_test.go +++ b/plugin/plugin_registry_test.go @@ -39,9 +39,8 @@ func NewPluginRegistry(t *testing.T) *Registry { reg := NewRegistry( context.Background(), Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: logger, + ActRegistry: actRegistry, + Logger: logger, }) return reg } @@ -157,9 +156,8 @@ func BenchmarkHookRun(b *testing.B) { reg := NewRegistry( context.Background(), Registry{ - ActRegistry: actRegistry, - Compatibility: config.Loose, - Logger: logger, + ActRegistry: actRegistry, + Logger: logger, }) hookFunction := func( _ context.Context, args *v1.Struct, _ ...grpc.CallOption,